pool: add version and peer events for peers.
This commit is contained in:
parent
005c11e967
commit
eadb7a50c7
@ -322,6 +322,7 @@ Peer.prototype._handleVersion = function handleVersion(payload) {
|
|||||||
// ACK
|
// ACK
|
||||||
this._write(this.framer.verack());
|
this._write(this.framer.verack());
|
||||||
this.version = payload;
|
this.version = payload;
|
||||||
|
this.emit('version', payload);
|
||||||
};
|
};
|
||||||
|
|
||||||
Peer.prototype._handleGetData = function handleGetData(items) {
|
Peer.prototype._handleGetData = function handleGetData(items) {
|
||||||
|
|||||||
@ -340,6 +340,14 @@ Pool.prototype._addPeer = function _addPeer(backoff) {
|
|||||||
peer.on('txs', function(txs) {
|
peer.on('txs', function(txs) {
|
||||||
self.emit('txs', txs, peer);
|
self.emit('txs', txs, peer);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
peer.on('version', function(version) {
|
||||||
|
self.emit('version', version, peer);
|
||||||
|
});
|
||||||
|
|
||||||
|
utils.nextTick(function() {
|
||||||
|
self.emit('peer', peer);
|
||||||
|
});
|
||||||
};
|
};
|
||||||
|
|
||||||
Pool.prototype._removePeer = function _removePeer(peer) {
|
Pool.prototype._removePeer = function _removePeer(peer) {
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user