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

Adding option mempoolOnly in querying

Browse Source 
- mempoolOnly option make the query in db from mempool only (ie, unconfirmed tx only
This commit is contained in:
sairajzero 2023-04-13 03:52:02 +05:30
parent 27f3993884
commit df7710ded1
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
lib/services/address/index.js
View File

@ -189,6 +189,10 @@ AddressService.prototype.getAddressHistory = function(addresses, options, stream
options.queryMempool = true; options.queryMempool = true;
} }
if (_.isUndefined(options.mempoolOnly)) {
options.mempoolOnly = false;
}
var old_support = false; var old_support = false;
//Quick support for `from` and `to` options (DEPRECATED! Not recommeded to use) //Quick support for `from` and `to` options (DEPRECATED! Not recommeded to use)
if( !_.isUndefined(options.from) || !_.isUndefined(options.to)) { if( !_.isUndefined(options.from) || !_.isUndefined(options.to)) {
@ -859,6 +863,10 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
options.queryMempool = true; options.queryMempool = true;
} }
if (_.isUndefined(options.mempoolOnly)) {
options.mempoolOnly = false;
}
//declare the queue to process tx data //declare the queue to process tx data
var tmpTxList = {}; //store processed txid temporarily to ignore duplication var tmpTxList = {}; //store processed txid temporarily to ignore duplication
@ -950,6 +958,10 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
// stream the rest of the confirmed txids out of the address index // stream the rest of the confirmed txids out of the address index
function(next) { function(next) {
if (options.mempoolOnly) { //Option to query from mempool only (ie, unconfirmed txs only)
return next();
}
var txIdTransformStream = new Transform({ objectMode: true }); var txIdTransformStream = new Transform({ objectMode: true });
txIdTransformStream._flush = function(cb) { txIdTransformStream._flush = function(cb) {