bitcoind: get detailed transactions with concurrency

increase performance of querying address history by executing multiple
rpc calls concurrency with configurable limit

Author: braydonf

lib/services/bitcoind.js

@@ -76,6 +76,7 @@ Bitcoin.DEFAULT_TRY_ALL_INTERVAL = 1000;
 Bitcoin.DEFAULT_REINDEX_INTERVAL = 10000;
 Bitcoin.DEFAULT_START_RETRY_INTERVAL = 5000;
 Bitcoin.DEFAULT_TIP_UPDATE_INTERVAL = 15000;
+Bitcoin.DEFAULT_TRANSACTION_CONCURRENCY = 5;
 Bitcoin.DEFAULT_CONFIG_SETTINGS = {
   server: 1,
   whitelist: '127.0.0.1',
@@ -106,6 +107,9 @@ Bitcoin.prototype._initDefaults = function(options) {
   this.tryAllInterval = options.tryAllInterval || Bitcoin.DEFAULT_TRY_ALL_INTERVAL;
   this.startRetryInterval = options.startRetryInterval || Bitcoin.DEFAULT_START_RETRY_INTERVAL;
 
+  // rpc limits
+  this.transactionConcurrency = options.transactionConcurrency || Bitcoin.DEFAULT_TRANSACTION_CONCURRENCY;
+
   // sync progress level when zmq subscribes to events
   this.zmqSubscribeProgress = options.zmqSubscribeProgress || Bitcoin.DEFAULT_ZMQ_SUBSCRIBE_PROGRESS;
 };
@@ -1412,8 +1416,9 @@ Bitcoin.prototype.getAddressHistory = function(addressArg, options, callback) {
       return callback(e);
     }
 
-    async.mapSeries(
+    async.mapLimit(
       txids,
+      self.transactionConcurrency,
       function(txid, next) {
         self._getAddressDetailedTransaction(txid, {
           queryMempool: queryMempool,

test/services/bitcoind.unit.js

@@ -83,6 +83,16 @@ describe('Bitcoin Service', function() {
     });
   });
 
+  describe('#_initDefaults', function() {
+    it('will set transaction concurrency', function() {
+      var bitcoind = new BitcoinService(baseConfig);
+      bitcoind._initDefaults({transactionConcurrency: 10});
+      bitcoind.transactionConcurrency.should.equal(10);
+      bitcoind._initDefaults({});
+      bitcoind.transactionConcurrency.should.equal(5);
+    });
+  });
+
   describe('@dependencies', function() {
     it('will have no dependencies', function() {
       BitcoinService.dependencies.should.deep.equal([]);