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

Fixed: Address-summary request not responding

Browse Source
This commit is contained in:
sairajzero 2023-01-28 02:04:40 +05:30
parent 6c164993bf
commit dbfe39991f
1 changed files with 4 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -304,15 +304,13 @@ AddressService.prototype.getAddressSummary = function(address, options, streamer
txApperances: 0, txApperances: 0,
}; };
self._aggregateAddressSummaryResult(tx, address, result);
self.getAddressHistory(address, options, function(err, tx) { self.getAddressHistory(address, options, function(err, tx) {
if(err) if(err)
return log.error(err); return log.error(err);
if(tx) if(tx)
self._aggregateAddressSummaryResult(tx, address, result); self._aggregateAddressSummaryResult(tx, address, result, options);
streamer(null, tx); streamer(null, tx);
@ -717,9 +715,7 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
//declare the queue to process tx data //declare the queue to process tx data
var q = async.queue(function(task, cb) { var q = async.queue(function(id, cb) {
let {id, options} = task;
if (id.height === 0xffffffff) { if (id.height === 0xffffffff) {
@ -790,6 +786,7 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
}); });
txIdTransformStream.on('end', function() { txIdTransformStream.on('end', function() {
q.drain = next;
q.resume(); q.resume();
}); });
@ -803,8 +800,6 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
var txidStream = self._getTxidStream(address, options); var txidStream = self._getTxidStream(address, options);
txidStream.pipe(txIdTransformStream); txidStream.pipe(txIdTransformStream);
q.drain(next);
} }
], callback); ], callback);