deploy: b483ae4b0d7ba59ead3cb724e81a9e5217f00208

tests/v2/test_peer_exchange.nim

@@ -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

tests/v2/test_waku_keepalive.nim

@@ -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()

waku/v2/node/wakunode2.nim

@@ -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))