use chunking when adding orders to mesh

0xProject · Feb 19, 2020 · 03f2d03 · 03f2d03
1 parent 1902655
commit 03f2d03
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/services/orderbook_service.ts b/src/services/orderbook_service.ts
@@ -182,7 +182,7 @@ export class OrderBookService {
     }
     public async addOrdersAsync(signedOrders: SignedOrder[]): Promise<void> {
         if (this._meshClient) {
-            const { rejected } = await this._meshClient.addOrdersAsync(signedOrders as any);
+            const { rejected } = await meshUtils.addOrdersToMeshAsync(this._meshClient, signedOrders);
             if (rejected.length !== 0) {
                 const validationErrors = rejected.map((r, i) => ({
                     field: `signedOrder[${i}]`,

diff --git a/src/utils/mesh_utils.ts b/src/utils/mesh_utils.ts
@@ -20,14 +20,14 @@ export const meshUtils = {
     addOrdersToMeshAsync: async (
         meshClient: WSClient,
         orders: SignedOrder[],
-        batchSize: number = 100,
+        batchSize: number = 200,
     ): Promise<ValidationResults> => {
         // Mesh rpc client can't handle a large amount of orders. This results in a fragmented
         // send which Mesh cannot accept.
         const validationResults: ValidationResults = { accepted: [], rejected: [] };
         const chunks = _.chunk(orders, batchSize);
         for (const chunk of chunks) {
-            const results = await meshClient.addOrdersAsync(chunk as any);
+            const results = await meshClient.addOrdersAsync(chunk);
             validationResults.accepted = [...validationResults.accepted, ...results.accepted];
             validationResults.rejected = [...validationResults.rejected, ...results.rejected];
         }