String wallets includes, and some logging help

Micah Riggan · Micah Riggan · commit 9dac9f77e1e1 · 2018-07-13T16:59:15.000-04:00
diff --git a/packages/bitcore-node/src/providers/chain-state/internal/internal.ts b/packages/bitcore-node/src/providers/chain-state/internal/internal.ts
@@ -220,7 +220,14 @@ export class InternalStateProvider implements CSP.IChainStateService {
     }
     let transactionStream = TransactionModel.getTransactions({ query });
     let listTransactionsStream = new ListTransactionsStream(wallet);
-    transactionStream.pipe(listTransactionsStream).pipe(stream);
+    let count = 0;
+    let txcount = 0;
+    transactionStream
+      .on('data', () => txcount++)
+      .pipe(listTransactionsStream)
+      .on('data', () => count++)
+      .on('finish', () => console.log(`txcount: ${txcount} count: ${count}`))
+      .pipe(stream);
   }
 
   async getWalletBalance(params: { wallet: IWallet }) {
diff --git a/packages/bitcore-node/src/providers/chain-state/internal/transforms.js b/packages/bitcore-node/src/providers/chain-state/internal/transforms.js
@@ -24,13 +24,14 @@ ListTransactionsStream.prototype._transform = function (transaction, enc, done)
 
       transaction.inputs = inputs;
       transaction.outputs = outputs;
-      var wallet = this.wallet._id;
+      var wallet = this.wallet._id.toString();
       var totalInputs = transaction.inputs.reduce((total, input) => { return total + input.value; }, 0);
       var totalOutputs = transaction.outputs.reduce((total, output) => { return total + output.value; }, 0);
       var fee = totalInputs - totalOutputs;
+      const stringifyWallets = (coin) => coin.wallets.map(w => w.toString());
 
       for(let input of transaction.inputs) {
-        if (input.wallets.includes(wallet)) {
+        if (stringifyWallets(input).includes(wallet)) {
           self.push(JSON.stringify({
             txid: transaction.txid,
             category: 'send',
@@ -53,7 +54,7 @@ ListTransactionsStream.prototype._transform = function (transaction, enc, done)
         }
       }
       for(let output of transaction.outputs) {
-        if (output.wallets.includes(wallet)) {
+        if (stringifyWallets(output).includes(wallet)) {
           self.push(JSON.stringify({
             txid: transaction.txid,
             category: 'receive',
