RanchiMall/fcoin
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

wallet: emit updates with tx

Browse Source
This commit is contained in:
Fedor Indutny 2014-05-13 01:11:33 +04:00
parent 868e68be93
commit 2a6048f104
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
lib/bcoin/tx-pool.js
View File

@ -100,7 +100,7 @@ TXPool.prototype.add = function add(tx, noWrite) {
if (!own) { if (!own) {
if (updated) if (updated)
this.emit('update', this._lastTs); this.emit('update', this._lastTs, tx);
// Save spending TXs without adding unspents // Save spending TXs without adding unspents
if (this._storage && this._wallet.ownInput(tx)) if (this._storage && this._wallet.ownInput(tx))
@ -143,7 +143,7 @@ TXPool.prototype.add = function add(tx, noWrite) {
this._lastTs = Math.max(tx.ts, this._lastTs); this._lastTs = Math.max(tx.ts, this._lastTs);
if (updated) if (updated)
this.emit('update', this._lastTs); this.emit('update', this._lastTs, tx);
if (!noWrite) if (!noWrite)
this._storeTX(hash, tx); this._storeTX(hash, tx);

3
lib/bcoin/wallet.js
View File

@ -54,10 +54,11 @@ Wallet.prototype._init = function init() {
// Notify owners about new accepted transactions // Notify owners about new accepted transactions
var self = this; var self = this;
var prevBalance = null; var prevBalance = null;
this.tx.on('update', function() { this.tx.on('update', function(lastTs, tx) {
var b = this.balance(); var b = this.balance();
if (prevBalance && prevBalance.cmp(b) !== 0) if (prevBalance && prevBalance.cmp(b) !== 0)
self.emit('balance', b); self.emit('balance', b);
self.emit('update', tx);
prevBalance = b; prevBalance = b;
}); });