diff --git a/lib/services/address/index.js b/lib/services/address/index.js index c18b02b3..d3abcf90 100644 --- a/lib/services/address/index.js +++ b/lib/services/address/index.js @@ -250,9 +250,6 @@ AddressService.prototype.blockHandler = function(block, connectBlock, callback) var inputs = tx.inputs; var outputs = tx.outputs; - // Subscription messages - var txmessages = {}; - var outputLength = outputs.length; for (var outputIndex = 0; outputIndex < outputLength; outputIndex++) { var output = outputs[outputIndex]; @@ -304,6 +301,7 @@ AddressService.prototype.blockHandler = function(block, connectBlock, callback) type: 'del', key: inputKey }); + next(); } else { // uncommon and slower, this happens during a reorg self.node.services.transaction.getTransaction(input.prevTxId, {}, function(err, tx) { var utxo = tx.outputs[input.outputIndex]; @@ -313,6 +311,7 @@ AddressService.prototype.blockHandler = function(block, connectBlock, callback) key: inputKey, value: inputValue }); + next(); }); } }, function(err) { @@ -326,7 +325,6 @@ AddressService.prototype.blockHandler = function(block, connectBlock, callback) if(err) { return callback(err); } - callback(null, operations); }); };