Fixed finding txs after sending.
This commit is contained in:
parent
f604e4ca94
commit
725b58cd15
@ -60,7 +60,7 @@ AddressService.prototype.getAddressHistory = function(addresses, options, callba
|
|||||||
addresses = [addresses];
|
addresses = [addresses];
|
||||||
}
|
}
|
||||||
|
|
||||||
async.mapLimit(addresses, 4, function(address, next) {
|
async.mapSeries(addresses, function(address, next) {
|
||||||
|
|
||||||
self._getAddressHistory(address, options, next);
|
self._getAddressHistory(address, options, next);
|
||||||
|
|
||||||
@ -451,7 +451,7 @@ AddressService.prototype._getAddressHistory = function(address, options, callbac
|
|||||||
if (mempoolTxs.length <= 0) {
|
if (mempoolTxs.length <= 0) {
|
||||||
return next();
|
return next();
|
||||||
}
|
}
|
||||||
async.mapLimit(mempoolTxs, 4, function(tx, next) {
|
async.mapSeries(mempoolTxs, 4, function(tx, next) {
|
||||||
self._transaction.setTxMetaInfo(tx, options, next);
|
self._transaction.setTxMetaInfo(tx, options, next);
|
||||||
}, function(err, txs) {
|
}, function(err, txs) {
|
||||||
if (err) {
|
if (err) {
|
||||||
|
|||||||
@ -226,7 +226,7 @@ MempoolService.prototype._onTransaction = function(tx) {
|
|||||||
value: self._encoding.encodeMempoolTransactionValue(tx)
|
value: self._encoding.encodeMempoolTransactionValue(tx)
|
||||||
}];
|
}];
|
||||||
|
|
||||||
ops.concat(self._getAddressOperations(tx, true));
|
ops = ops.concat(self._getAddressOperations(tx, true));
|
||||||
self._db.batch(ops, function(err) {
|
self._db.batch(ops, function(err) {
|
||||||
if(err) {
|
if(err) {
|
||||||
log.error(err);
|
log.error(err);
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user