RanchiMall/flocore-node
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add option to query **only** mempool

Browse Source
This commit is contained in:
Karel Bilek 2016-10-03 15:23:04 +02:00
parent 6a1e5770cf
commit b92d4340a1
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
lib/services/bitcoind.js
View File

@ -1211,6 +1211,7 @@ Bitcoin.prototype.getAddressTxids = function(addressArg, options, callback) {
/* jshint maxstatements: 16 */ /* jshint maxstatements: 16 */
var self = this; var self = this;
var queryMempool = _.isUndefined(options.queryMempool) ? true : options.queryMempool; var queryMempool = _.isUndefined(options.queryMempool) ? true : options.queryMempool;
var queryMempoolOnly = _.isUndefined(options.queryMempoolOnly) ? false : options.queryMempoolOnly;
var rangeQuery = false; var rangeQuery = false;
try { try {
rangeQuery = self._getHeightRangeQuery(options); rangeQuery = self._getHeightRangeQuery(options);
@ -1220,12 +1221,21 @@ Bitcoin.prototype.getAddressTxids = function(addressArg, options, callback) {
if (rangeQuery) { if (rangeQuery) {
queryMempool = false; queryMempool = false;
} }
if (queryMempoolOnly) {
queryMempool = true;
rangeQuery = false;
}
var addresses = self._normalizeAddressArg(addressArg); var addresses = self._normalizeAddressArg(addressArg);
var cacheKey = addresses.join(''); var cacheKey = addresses.join('');
var mempoolTxids = []; var mempoolTxids = [];
var txids = self.txidsCache.get(cacheKey); var txids = queryMempoolOnly ? false : self.txidsCache.get(cacheKey);
function finish() { function finish() {
if (queryMempoolOnly) {
return setImmediate(function() {
callback(null, mempoolTxids.reverse());
});
}
if (txids && !rangeQuery) { if (txids && !rangeQuery) {
var allTxids = mempoolTxids.reverse().concat(txids); var allTxids = mempoolTxids.reverse().concat(txids);
return setImmediate(function() { return setImmediate(function() {