fix: extract peerIds from Multiaddrs for pendingDials function (#1567)

libp2p · Feb 15, 2023 · d1f0ec0 · d1f0ec0
1 parent 6a2b8b9
commit d1f0ec0
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/connection-manager/dialer/index.ts b/src/connection-manager/dialer/index.ts
@@ -23,6 +23,7 @@ import type { AddressSorter, PeerStore } from '@libp2p/interface-peer-store'
 import type { Metrics } from '@libp2p/interface-metrics'
 import type { Dialer } from '@libp2p/interface-connection-manager'
 import type { TransportManager } from '@libp2p/interface-transport'
+import { peerIdFromString } from '@libp2p/peer-id'
 
 const log = logger('libp2p:dialer')
 
@@ -228,6 +229,10 @@ export class DefaultDialer implements Startable, Dialer {
    * Returns true if the peer id is in the pending dials
    */
   hasPendingDial (peerId: PeerId | Multiaddr): boolean {
+    if (isMultiaddr(peerId)) {
+      return this.pendingDials.has(peerId.getPeerId() ?? '')
+    }
+
     return this.pendingDials.has(peerId.toString())
   }