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

logging

Browse Source
This commit is contained in:
sairajzero 2023-01-28 01:24:26 +05:30
parent 2de483ada3
commit 3cd4806d12
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -216,7 +216,7 @@ AddressService.prototype.getAddressHistory = function(addresses, options, stream
}, function(err) { }, function(err) {
console.debug('getAddressHistory-end', err, results.totalCount, results.items.length); console.debug('getAddressHistory-END', err, results.totalCount, results.items.length);
if (err) { if (err) {
return callback(err); return callback(err);
@ -318,7 +318,7 @@ AddressService.prototype.getAddressSummary = function(address, options, streamer
}, function(err) { }, function(err) {
console.debug('getAddressSummary', err, result); console.debug('getAddressSummary-END', err, result);
if (err) { if (err) {
return callback(err); return callback(err);
} }
@ -732,15 +732,17 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
}); });
} }
console.debug("Q-PROCESS", id.txid);
self._transaction.getDetailedTransaction(id.txid, options, cb); self._transaction.getDetailedTransaction(id.txid, options, cb);
}, 4); }, 4);
q.pause(); //pause and wait until queue is set q.pause(); //pause and wait until queue is set
q.empty(() => console.debug("Q-EMPTY"));
function process_chunk(err, tx){ function process_chunk(err, tx){
console.debug("PROCESS_CHUNK:", tx.txid()); console.debug("PROCESS_CHUNK:", [...q].length, tx.txid());
streamer(err, tx); streamer(err, tx);
if(err){ if(err){
@ -790,6 +792,7 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
}); });
txIdTransformStream.on('end', function() { txIdTransformStream.on('end', function() {
console.debug("TRANSFORM-END");
q.resume(); q.resume();
}); });
@ -804,7 +807,7 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
txidStream.pipe(txIdTransformStream); txidStream.pipe(txIdTransformStream);
q.drain(function (e, d){ q.drain(function (e, d){
console.debug("Drain reached...", e, d); console.debug("Q-DRAIN", e, d);
next(e, d); next(e, d);
}); });