mirror of https://github.com/waku-org/nwaku.git
chore: update submodules (#974)
This commit is contained in:
parent
6a60458135
commit
984f3179a7
|
@ -26,9 +26,13 @@ procSuite "Peer Exchange":
|
|||
node3 = WakuNode.new(nodeKey3, bindIp, Port(60003), sendSignedPeerRecord = true)
|
||||
|
||||
var
|
||||
peerExchangeHandler: RoutingRecordsHandler
|
||||
peerExchangeHandler, emptyHandler: RoutingRecordsHandler
|
||||
completionFut = newFuture[bool]()
|
||||
|
||||
proc ignorePeerExchange(peer: PeerId, topic: string,
|
||||
peers: seq[RoutingRecordsPair]) {.gcsafe, raises: [Defect].} =
|
||||
discard
|
||||
|
||||
proc handlePeerExchange(peer: PeerId, topic: string,
|
||||
peers: seq[RoutingRecordsPair]) {.gcsafe, raises: [Defect].} =
|
||||
## Handle peers received via gossipsub peer exchange
|
||||
|
@ -44,9 +48,10 @@ procSuite "Peer Exchange":
|
|||
completionFut.complete(true)
|
||||
|
||||
peerExchangeHandler = handlePeerExchange
|
||||
emptyHandler = ignorePeerExchange
|
||||
|
||||
node1.mountRelay()
|
||||
node2.mountRelay()
|
||||
node1.mountRelay(peerExchangeHandler = some(emptyHandler))
|
||||
node2.mountRelay(peerExchangeHandler = some(emptyHandler))
|
||||
node3.mountRelay(peerExchangeHandler = some(peerExchangeHandler))
|
||||
|
||||
# Ensure that node1 prunes all peers after the first connection
|
||||
|
|
|
@ -48,4 +48,5 @@ procSuite "Waku Keepalive":
|
|||
check:
|
||||
(await completionFut.withTimeout(5.seconds)) == true
|
||||
|
||||
await allFutures([node1.stop(), node2.stop()])
|
||||
await node2.stop()
|
||||
await node1.stop()
|
||||
|
|
|
@ -1 +1 @@
|
|||
Subproject commit 65b74302e03912ab5bde64b6da10d05896139007
|
||||
Subproject commit 0ebb1d7a4af5f4b4d4756a9b6dbfe5d411fa55d9
|
|
@ -1 +1 @@
|
|||
Subproject commit bb4c3298f56ba7bc69fbccd08fd6e5474c410262
|
||||
Subproject commit 875d7d8e6ef0803ae1c331dbf76b1981b0caeb15
|
|
@ -1 +1 @@
|
|||
Subproject commit 5a5bfd3c09887cdf80b052d14bff7b9a0a919938
|
||||
Subproject commit 49e2c52eb5dda46b1c9c10d079abe7bffe6cea89
|
|
@ -1 +1 @@
|
|||
Subproject commit 40048e8b3e69284bdb5d4daa0a16ad93402c55db
|
||||
Subproject commit f83fbce4d6ec7927b75be3f85e4fa905fcb69788
|
|
@ -1 +1 @@
|
|||
Subproject commit 074cd026e61675708d518839e6914d55baa4b8ca
|
||||
Subproject commit 3509706517f3562cbcbe9d94988eccdd80474ab8
|
|
@ -1 +1 @@
|
|||
Subproject commit 9973b9466dd062d7406d0178c750249b7e48471f
|
||||
Subproject commit 13503f3799aa7c746e17db0a4af38f8aec4115b8
|
|
@ -1 +1 @@
|
|||
Subproject commit 24eb5e829ed07e71e3a5d09786d5f80aa988874f
|
||||
Subproject commit 9d23c0bebe7b3f58cb8a0ab6278d2b277a3d4a48
|
|
@ -1 +1 @@
|
|||
Subproject commit 14d852e0d40ce71d916545b54ac86c2e35315f62
|
||||
Subproject commit 8927db93f6ca96abaacfea39f8ca50ce9d41bcdb
|
|
@ -705,7 +705,8 @@ proc mountRelay*(node: WakuNode,
|
|||
wakuRelay.defaultTopics = concat(@[defaultTopic], topics)
|
||||
|
||||
## Add peer exchange handler
|
||||
if peerExchangeHandler.isSome():
|
||||
if peerExchangeHandler.isSome():
|
||||
wakuRelay.parameters.enablePX = true # Feature flag for peer exchange in nim-libp2p
|
||||
wakuRelay.routingRecordsHandler.add(peerExchangeHandler.get())
|
||||
|
||||
node.switch.mount(wakuRelay, protocolMatcher(WakuRelayCodec))
|
||||
|
|
Loading…
Reference in New Issue