refactor(p2p): delete inactive pending peer

ExchangeUnion · Oct 17, 2019 · 24b4eb1 · 24b4eb1
1 parent 6c6c6bd
commit 24b4eb1
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/lib/p2p/Pool.ts b/lib/p2p/Pool.ts
@@ -869,17 +869,17 @@ class Pool extends EventEmitter {
       this.pendingOutboundPeers.delete(peer.expectedNodePubKey);
     }
 
-    if (!peer.active) {
-      return;
-    }
-
     if (peer.nodePubKey) {
       this.pendingOutboundPeers.delete(peer.nodePubKey);
       this.peers.delete(peer.nodePubKey);
     }
-    this.emit('peer.close', peer.nodePubKey);
     peer.removeAllListeners();
+
+    if (!peer.active) {
+      return;
+    }
     peer.active = false;
+    this.emit('peer.close', peer.nodePubKey);
 
     const shouldReconnect =
       (peer.sentDisconnectionReason === undefined || peer.sentDisconnectionReason === DisconnectionReason.ResponseStalling) &&