mirror of
https://github.com/logos-messaging/logos-messaging-nim.git
synced 2026-01-05 23:43:07 +00:00
fix: static sharding setup (#3494)
This commit is contained in:
parent
16bda047e1
commit
c3991dbbc1
@ -127,8 +127,12 @@ proc setupAppCallbacks(
|
|||||||
if node.wakuRelay.isNil():
|
if node.wakuRelay.isNil():
|
||||||
return err("Cannot configure relayHandler callback without Relay mounted")
|
return err("Cannot configure relayHandler callback without Relay mounted")
|
||||||
|
|
||||||
let autoShards = node.getAutoshards(conf.contentTopics).valueOr:
|
let autoShards =
|
||||||
return err("Could not get autoshards: " & error)
|
if node.wakuAutoSharding.isSome():
|
||||||
|
node.getAutoshards(conf.contentTopics).valueOr:
|
||||||
|
return err("Could not get autoshards: " & error)
|
||||||
|
else:
|
||||||
|
@[]
|
||||||
|
|
||||||
let confShards = conf.subscribeShards.mapIt(
|
let confShards = conf.subscribeShards.mapIt(
|
||||||
RelayShard(clusterId: conf.clusterId, shardId: uint16(it))
|
RelayShard(clusterId: conf.clusterId, shardId: uint16(it))
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user