waku-org/nwaku
1
0
Fork 0
mirror of https://github.com/waku-org/nwaku.git synced 2025-03-01 07:20:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: adding peer exchange peers to the peerStore (#2824)

Browse Source
This commit is contained in:
gabrielmer 2024-06-20 10:46:40 +02:00 committed by GitHub
parent f73968d115
commit 325e131697
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
waku/factory/node_factory.nim
View File

@ -135,11 +135,12 @@ proc setupProtocols(
# only peers with populated records # only peers with populated records
.mapIt(toRemotePeerInfo(it.record.get())) .mapIt(toRemotePeerInfo(it.record.get()))
debug "connecting to exchanged peers", debug "adding exchanged peers",
src = peer, topic = topic, numPeers = exchangedPeers.len src = peer, topic = topic, numPeers = exchangedPeers.len
# asyncSpawn, as we don't want to block here for peer in exchangedPeers:
asyncSpawn node.connectToNodes(exchangedPeers, "peer exchange") # Peers added are filtered by the peer manager
node.peerManager.addPeer(peer, PeerOrigin.PeerExchange)
peerExchangeHandler = some(handlePeerExchange) peerExchangeHandler = some(handlePeerExchange)