diff --git a/tests/test_waku_keepalive.nim b/tests/test_waku_keepalive.nim index 21cba115d..a21bba384 100644 --- a/tests/test_waku_keepalive.nim +++ b/tests/test_waku_keepalive.nim @@ -47,6 +47,9 @@ suite "Waku Keepalive": break await sleepAsync(100.millis) + assert node1.peerManager.isPeerConnected(node2.switch.peerInfo.peerId), + "could not establish connection between nodes" + let healthMonitor = NodeHealthMonitor() healthMonitor.setNodeToHealthMonitor(node1) healthMonitor.startKeepalive(2.seconds).isOkOr: diff --git a/waku/node/peer_manager/peer_manager.nim b/waku/node/peer_manager/peer_manager.nim index 30dc09b4a..a5c7be267 100644 --- a/waku/node/peer_manager/peer_manager.nim +++ b/waku/node/peer_manager/peer_manager.nim @@ -500,7 +500,7 @@ proc connectedPeers*( return (inPeers, outPeers) -proc isPeerConnected*(pm: PeerManager, peerId: PeerId): bool +proc isPeerConnected*(pm: PeerManager, peerId: PeerId): bool = let (inPeers, outPeers) = pm.connectedPeers() return inPeers.contains(peerId) or outPeers.contains(peerId)