mirror of
https://github.com/logos-messaging/logos-messaging-nim.git
synced 2026-01-04 06:53:12 +00:00
b0cd75f4cb
* update rendezvous to work with WakuPeeRecord and use libp2p updated version * split rendezvous client and service implementation * mount rendezvous client by default
47 lines
1.1 KiB
Nim
47 lines
1.1 KiB
Nim
{.push raises: [].}
|
|
|
|
import std/options, chronos
|
|
|
|
import ../common/enr, ../waku_enr/capabilities, ../waku_enr/sharding
|
|
|
|
const DiscoverLimit* = 1000
|
|
const DefaultRegistrationTTL* = 60.seconds
|
|
const DefaultRegistrationInterval* = 10.seconds
|
|
const DefaultRequestsInterval* = 1.minutes
|
|
const MaxRegistrationInterval* = 5.minutes
|
|
const PeersRequestedCount* = 12
|
|
|
|
proc computeMixNamespace*(clusterId: uint16): string =
|
|
var namespace = "rs/"
|
|
|
|
namespace &= $clusterId
|
|
namespace &= "/mix"
|
|
|
|
return namespace
|
|
|
|
proc computeNamespace*(clusterId: uint16, shard: uint16): string =
|
|
var namespace = "rs/"
|
|
|
|
namespace &= $clusterId
|
|
namespace &= '/'
|
|
namespace &= $shard
|
|
|
|
return namespace
|
|
|
|
proc computeNamespace*(clusterId: uint16, shard: uint16, cap: Capabilities): string =
|
|
var namespace = "rs/"
|
|
|
|
namespace &= $clusterId
|
|
namespace &= '/'
|
|
namespace &= $shard
|
|
namespace &= '/'
|
|
namespace &= $cap
|
|
|
|
return namespace
|
|
|
|
proc getRelayShards*(enr: enr.Record): Option[RelayShards] =
|
|
let typedRecord = enr.toTyped().valueOr:
|
|
return none(RelayShards)
|
|
|
|
return typedRecord.relaySharding()
|