diff --git a/src/app.js b/src/app.js index 11bf5e2b4b..635fe705d1 100644 --- a/src/app.js +++ b/src/app.js @@ -873,20 +873,17 @@ function run () { txlistener.startListening() - txlistener.event.register('newBlock', (block) => { - for (var t in block.transactions) { - var tx = block.transactions[t] - var resolvedTransaction = txlistener.resolvedTransaction(tx.hash) - var address = null - if (resolvedTransaction) { - address = resolvedTransaction.contractAddress ? resolvedTransaction.contractAddress : tx.to - } - console.log({ - tx: tx, - resolvedContract: txlistener.resolvedContract(address), - resolvedTransaction: resolvedTransaction - }) + txlistener.event.register('newTransaction', (tx) => { + var resolvedTransaction = txlistener.resolvedTransaction(tx.hash) + var address = null + if (resolvedTransaction) { + address = resolvedTransaction.contractAddress ? resolvedTransaction.contractAddress : tx.to } + console.log({ + tx: tx, + resolvedContract: txlistener.resolvedContract(address), + resolvedTransaction: resolvedTransaction + }) }) // ----------------- autoCompile ----------------- diff --git a/src/app/txListener.js b/src/app/txListener.js index 5967a66de7..751aadb902 100644 --- a/src/app/txListener.js +++ b/src/app/txListener.js @@ -124,7 +124,10 @@ class TxListener { _resolve (block, callback) { async.each(block.transactions, (tx, cb) => { - this._resolveTx(tx, cb) + this._resolveTx(tx, () => { + this.event.trigger('newTransaction', [tx]) + cb() + }) }, () => { callback() })