From c8acdbbb3e65926bdb1d69b4b065e9ed4a23df4b Mon Sep 17 00:00:00 2001 From: SionoiS Date: Fri, 17 Apr 2026 10:06:19 -0400 Subject: [PATCH] remove randomwalk --- waku/discovery/waku_kademlia.nim | 14 +++++++------- waku/node/waku_node.nim | 8 +++++--- 2 files changed, 12 insertions(+), 10 deletions(-) diff --git a/waku/discovery/waku_kademlia.nim b/waku/discovery/waku_kademlia.nim index 3ea24a31f..5798a11f3 100644 --- a/waku/discovery/waku_kademlia.nim +++ b/waku/discovery/waku_kademlia.nim @@ -25,7 +25,7 @@ type WakuKademlia* = ref object protocol*: KademliaDiscovery peerManager: PeerManager loopInterval: Duration - periodicWalkFut: Future[void] + #periodicWalkFut: Future[void] periodicLookupFut: Future[void] proc toRemotePeerInfo(record: ExtendedPeerRecord): Option[RemotePeerInfo] = @@ -67,7 +67,7 @@ proc toRemotePeerInfo(record: ExtendedPeerRecord): Option[RemotePeerInfo] = ) ) -proc randomWalk*( +#[ proc randomWalk*( self: WakuKademlia ): Future[seq[RemotePeerInfo]] {.async: (raises: []).} = let res = catch: @@ -90,7 +90,7 @@ proc randomWalk*( peerInfos.add(peerInfo) - return peerInfos + return peerInfos ]# proc lookup*( self: WakuKademlia, codec: string @@ -124,7 +124,7 @@ proc lookup*( return peerInfos -proc periodicRandomWalk( +#[ proc periodicRandomWalk( self: WakuKademlia, interval: Duration ) {.async: (raises: [CancelledError]).} = debug "periodic random walk started", interval = interval @@ -132,7 +132,7 @@ proc periodicRandomWalk( while true: await sleepAsync(interval) - discard await self.randomWalk() + discard await self.randomWalk() ]# proc periodicLookup( self: WakuKademlia, interval: Duration @@ -173,8 +173,8 @@ proc new*( ) proc start*(self: WakuKademlia) = - if self.periodicWalkFut.isNil(): - self.periodicWalkFut = self.periodicRandomWalk(self.loopInterval) + #if self.periodicWalkFut.isNil(): + #self.periodicWalkFut = self.periodicRandomWalk(self.loopInterval) if self.periodicLookupFut.isNil(): self.periodicLookupFut = self.periodicLookup(self.loopInterval) diff --git a/waku/node/waku_node.nim b/waku/node/waku_node.nim index a1d243eec..85166a4cc 100644 --- a/waku/node/waku_node.nim +++ b/waku/node/waku_node.nim @@ -573,7 +573,8 @@ proc start*(node: WakuNode) {.async.} = if not node.wakuRendezvousClient.isNil(): await node.wakuRendezvousClient.start() - node.wakuKademlia.start() + if not node.wakuKademlia.isNil(): + node.wakuKademlia.start() ## The switch uses this mapper to update peer info addrs ## with announced addrs after start @@ -618,8 +619,6 @@ proc stop*(node: WakuNode) {.async.} = node.peerManager.stop() - node.wakuKademlia.stop() - if not node.wakuRlnRelay.isNil(): try: await node.wakuRlnRelay.stop() ## this can raise an exception @@ -642,6 +641,9 @@ proc stop*(node: WakuNode) {.async.} = if not node.wakuRendezvousClient.isNil(): await node.wakuRendezvousClient.stopWait() + if not node.wakuKademlia.isNil(): + node.wakuKademlia.stop() + node.started = false proc isReady*(node: WakuNode): Future[bool] {.async: (raises: [Exception]).} =