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);
   });
 };