From 2ab9334b4b9273a72830d0dd9b0df1b510b5dd76 Mon Sep 17 00:00:00 2001
From: Christopher Jeffrey <chjjeffrey@gmail.com>
Date: Sun, 18 May 2014 03:59:09 -0500
Subject: [PATCH] pool: when proxying peer->pool events. pass `peer` as the 2nd
 arg.

Signed-off-by: Fedor Indutny <fedor@indutny.com>
---
 lib/bcoin/pool.js | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/lib/bcoin/pool.js b/lib/bcoin/pool.js
index 8e8620b0..471eafe0 100644
--- a/lib/bcoin/pool.js
+++ b/lib/bcoin/pool.js
@@ -289,13 +289,13 @@ Pool.prototype._addPeer = function _addPeer(backoff) {
 
     self._response(block);
     self.chain.add(block);
-    self.emit('chain-progress', self.chain.fillPercent());
-    self.emit('block', block);
+    self.emit('chain-progress', self.chain.fillPercent(), peer);
+    self.emit('block', block, peer);
   });
 
   // Just FYI
   peer.on('reject', function(payload) {
-    self.emit('reject', payload);
+    self.emit('reject', payload, peer);
   });
 
   peer.on('notfound', function(items) {
@@ -308,19 +308,19 @@ Pool.prototype._addPeer = function _addPeer(backoff) {
 
   peer.on('tx', function(tx) {
     self._response(tx);
-    self.emit('tx', tx);
+    self.emit('tx', tx, peer);
   });
 
   peer.on('addr', function(addr) {
-    self.emit('addr', addr);
+    self.emit('addr', addr, peer);
   });
 
   peer.on('blocks', function(blocks) {
-    self.emit('blocks', blocks);
+    self.emit('blocks', blocks, peer);
   });
 
   peer.on('txs', function(txs) {
-    self.emit('txs', txs);
+    self.emit('txs', txs, peer);
   });
 };