logos-messaging/logos-delivery
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-delivery.git synced 2026-07-21 04:00:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixes

Browse Source
This commit is contained in:
Simon-Pierre 2026-06-12 09:40:26 -04:00
parent bbfa4cc529
commit ec62e13914
No known key found for this signature in database
GPG Key ID: C9458A8CB1852951
1 changed files with 11 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
logos_delivery/waku/node/waku_node.nim
View File

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