tx after coins

nitsujlangston · nitsujlangston · commit 25062f806e8b · 2018-08-04T21:47:05.000-04:00
diff --git a/packages/bitcore-node/src/models/transaction.ts b/packages/bitcore-node/src/models/transaction.ts
@@ -66,24 +66,25 @@ export class Transaction extends BaseModel<ITransaction> {
     if (mintOps.length) {
       mintOps = partition(mintOps, mintOps.length / config.maxPoolSize);
       mintOps = mintOps.map((mintBatch: Array<any>) => CoinModel.collection.bulkWrite(mintBatch, { ordered: false }));
-      await Promise.all(mintOps);
     }
     if (spendOps.length) {
       spendOps = partition(spendOps, spendOps.length / config.maxPoolSize);
       spendOps = spendOps.map((spendBatch: Array<any>) =>
         CoinModel.collection.bulkWrite(spendBatch, { ordered: false })
       );
     }
+    const coinOps = mintOps.concat(spendOps);
+    await Promise.all(coinOps);
 
     let txs: Promise<BulkWriteOpResultObject>[] = [];
     if (mintOps) {
       let txOps = await this.addTransactions(params);
       logger.debug('Writing Transactions', txOps.length);
       const txBatches = partition(txOps, txOps.length / config.maxPoolSize);
-      txs = txBatches.map((txBatch: Array<any>) => this.collection.bulkWrite(txBatch, { ordered: false }));
+      txs = txBatches.map((txBatch: Array<any>) => this.collection.bulkWrite(txBatch, { ordered: false, j: false, w: 0 }));
     }
 
-    await Promise.all(spendOps.concat(txs));
+    await Promise.all(txs);
   }
 
   async addTransactions(params: {
