better handling of large wallets

nitsujlangston · Sep 24, 2018 · ede612e · ede612e
1 parent a9720c0
commit ede612e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/packages/bitcore-node/src/models/walletAddress.ts b/packages/bitcore-node/src/models/walletAddress.ts
@@ -69,8 +69,8 @@ export class WalletAddress extends BaseModel<IWalletAddress> {
     const { walletUpdates, coinUpdates } = updates;
     const { chain, network } = wallet;
 
-    let walletUpdateBatches = partition(walletUpdates, 500);
-    let coinUpdateBatches = partition(coinUpdates, 500);
+    let walletUpdateBatches = partition(walletUpdates, walletUpdates.length/4);
+    let coinUpdateBatches = partition(coinUpdates, coinUpdates.length/4);
 
     return new Promise(async resolve => {
       await Promise.all(
@@ -99,7 +99,7 @@ export class WalletAddress extends BaseModel<IWalletAddress> {
         }
       });
       await Promise.all(
-        partition(txUpdates, 500).map(txUpdate => {
+        partition(txUpdates, txUpdates.length/4).map(txUpdate => {
           return TransactionModel.collection.bulkWrite(txUpdate, { ordered: false });
         })
       )