Skip to content

Commit 1e222b0

Browse files
fix: update bulk slice file expected JSON format
1 parent e73563f commit 1e222b0

File tree

1 file changed

+8
-15
lines changed

1 file changed

+8
-15
lines changed

src/Modules/Bulk.ts

Lines changed: 8 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -57,22 +57,15 @@ export function handleBulk(content: Bytes): void {
5757
// exclude slice out of deal bot range
5858
index >= botFirst &&
5959
index < botFirst.plus(botSize) &&
60-
entry.kind == JSONValueKind.OBJECT
60+
entry.kind == JSONValueKind.STRING
6161
) {
62-
let sliceCid = entry.toObject().getEntry('orders');
63-
if (sliceCid != null && sliceCid.value.kind == JSONValueKind.STRING) {
64-
let sliceContext = new DataSourceContext();
65-
sliceContext.setString(CONTEXT_BULK, bulkId);
66-
sliceContext.setString(CONTEXT_DEAL, dealId);
67-
sliceContext.setBigInt(CONTEXT_INDEX, index);
68-
sliceContext.setBytes(CONTEXT_DOMAIN_SEPARATOR_HASH, domainSeparator);
69-
70-
DataSourceTemplate.createWithContext(
71-
'BulkSlice',
72-
[sliceCid.value.toString()],
73-
sliceContext,
74-
);
75-
}
62+
const sliceCid = entry.toString();
63+
let sliceContext = new DataSourceContext();
64+
sliceContext.setString(CONTEXT_BULK, bulkId);
65+
sliceContext.setString(CONTEXT_DEAL, dealId);
66+
sliceContext.setBigInt(CONTEXT_INDEX, index);
67+
sliceContext.setBytes(CONTEXT_DOMAIN_SEPARATOR_HASH, domainSeparator);
68+
DataSourceTemplate.createWithContext('BulkSlice', [sliceCid], sliceContext);
7669
}
7770
}
7871
}

0 commit comments

Comments
 (0)