Merge 2969c48 into f73968d

waku-org · Jun 20, 2024 · b4d5906 · b4d5906
2 parents f73968d + 2969c48
commit b4d5906
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/waku/factory/node_factory.nim b/waku/factory/node_factory.nim
@@ -135,11 +135,12 @@ proc setupProtocols(
         # only peers with populated records
         .mapIt(toRemotePeerInfo(it.record.get()))
 
-      debug "connecting to exchanged peers",
+      debug "adding exchanged peers",
         src = peer, topic = topic, numPeers = exchangedPeers.len
 
-      # asyncSpawn, as we don't want to block here
-      asyncSpawn node.connectToNodes(exchangedPeers, "peer exchange")
+      for peer in exchangedPeers:
+        # Peers added are filtered by the peer manager
+        node.peerManager.addPeer(peer, PeerOrigin.PeerExchange)
 
     peerExchangeHandler = some(handlePeerExchange)