diff --git a/waku/v2/node/wakunode2.go b/waku/v2/node/wakunode2.go index 31e61468..9a9f8b6c 100644 --- a/waku/v2/node/wakunode2.go +++ b/waku/v2/node/wakunode2.go @@ -697,7 +697,6 @@ func (w *WakuNode) DialPeer(address string) error { return err } - // Extract the peer ID from the multiaddr. info, err := peer.AddrInfoFromP2pAddr(p) if err != nil { return err @@ -706,6 +705,11 @@ func (w *WakuNode) DialPeer(address string) error { return w.host.Connect(w.ctx, *info) } +func (w *WakuNode) DialPeerByID(peerID peer.ID) error { + info := w.host.Peerstore().PeerInfo(peerID) + return w.host.Connect(w.ctx, info) +} + func (w *WakuNode) ClosePeerByAddress(address string) error { p, err := ma.NewMultiaddr(address) if err != nil {