From ec62e139144d492d4b5cb649e8229b58ed0eb19b Mon Sep 17 00:00:00 2001 From: Simon-Pierre Date: Fri, 12 Jun 2026 09:40:26 -0400 Subject: [PATCH] fixes --- logos_delivery/waku/node/waku_node.nim | 21 +++++++++++---------- 1 file changed, 11 insertions(+), 10 deletions(-) diff --git a/logos_delivery/waku/node/waku_node.nim b/logos_delivery/waku/node/waku_node.nim index ad0ba2d0a..af68ef2f8 100644 --- a/logos_delivery/waku/node/waku_node.nim +++ b/logos_delivery/waku/node/waku_node.nim @@ -150,6 +150,11 @@ type import ./subscription_manager +proc selectRandomPeers*(peers: seq[PeerId], numRandomPeers: int): seq[PeerId] = + var randomPeers = peers + shuffle(randomPeers) + return randomPeers[0 ..< min(len(randomPeers), numRandomPeers)] + proc deduceRelayShard( node: WakuNode, contentTopic: ContentTopic, @@ -336,6 +341,8 @@ proc mountMix*( return err(error.msg) return ok() +import logos_delivery/waku/factory/conf_builder/kademlia_discovery_conf_builder + proc mountKademlia*( node: WakuNode, config: KademliaDiscoveryConf ): Result[void, string] = @@ -343,11 +350,10 @@ proc mountKademlia*( return err("WakuKademlia already mounted, skipping") let wk = WakuKademlia.new( - node.switch, node.peerManager, - config.bootstrapNodes, config.servicesToAdvertise, config.servicesToDiscover, - config.randomLookupInterval, config.serviceLookupInterval, - node.rng, - config.kadDhtConfig, config.discoConfig, config.clientMode, config.xprPublishing + node.switch, node.peerManager, config.bootstrapNodes, config.servicesToAdvertise, + config.servicesToDiscover, config.randomLookupInterval, + config.serviceLookupInterval, node.rng, config.kadDhtConfig, config.discoConfig, + config.clientMode, config.xprPublishing, ).valueOr: return err("failed to create service discovery: " & error) @@ -416,11 +422,6 @@ proc reconnectRelayPeers*(node: WakuNode) {.async.} = node.wakuRelay.parameters.pruneBackoff + chronos.seconds(BackoffSlackTime) await node.peerManager.reconnectPeers(WakuRelayCodec, backoffPeriod) -proc selectRandomPeers*(peers: seq[PeerId], numRandomPeers: int): seq[PeerId] = - var randomPeers = peers - shuffle(randomPeers) - return randomPeers[0 ..< min(len(randomPeers), numRandomPeers)] - proc mountRendezvousClient*(node: WakuNode, clusterId: uint16) {.async: (raises: []).} = info "mounting rendezvous client"