perf(sync): add utxo cache behavior to coin spend

indexing improvements for coin mints and spends, as well as converting mint operation to insert
nitsujlangston · Oct 24, 2018 · 3dd7521 · 3dd7521
1 parent 17eb0d9
commit 3dd7521
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 21 deletions.
diff --git a/packages/bitcore-node/src/models/coin.ts b/packages/bitcore-node/src/models/coin.ts
@@ -49,6 +49,10 @@ class Coin extends BaseModel<ICoin> {
 
   onConnect() {
     this.collection.createIndex({ mintTxid: 1, mintIndex: 1 });
+    this.collection.createIndex(
+      { mintTxid: 1, mintIndex: 1, chain: 1, network: 1 },
+      { partialFilterExpression: { spentHeight: { $lt: 0 } } }
+    );
     this.collection.createIndex(
       { address: 1, chain: 1, network: 1 },
       { partialFilterExpression: { spentHeight: { $lt: 0 } } }

diff --git a/packages/bitcore-node/src/models/transaction.ts b/packages/bitcore-node/src/models/transaction.ts
@@ -210,29 +210,20 @@ export class Transaction extends BaseModel<ITransaction> {
         }
 
         mintOps.push({
-          updateOne: {
-            filter: {
+          insertOne: {
+            document: {
+              chain,
+              network,
               mintTxid: txid,
               mintIndex: index,
-              spentHeight: { $lt: SpentHeightIndicators.minimum },
-              chain,
-              network
-            },
-            update: {
-              $set: {
-                chain,
-                network,
-                mintHeight: height,
-                coinbase: isCoinbase,
-                value: output.satoshis,
-                address,
-                script: scriptBuffer,
-                spentHeight: SpentHeightIndicators.unspent,
-                wallets: []
-              }
-            },
-            upsert: true,
-            forceServerObjectId: true
+              mintHeight: height,
+              address,
+              coinbase: isCoinbase,
+              value: output.satoshis,
+              script: scriptBuffer,
+              spentHeight: SpentHeightIndicators.unspent,
+              wallets: []
+            }
           }
         });
       }