mirror of
https://github.com/logos-messaging/logos-delivery.git
synced 2026-06-06 05:59:33 +00:00
chore: update content-topic parsing for filter (#2835)
* chore: update content parsing for filter * chore: update according to suggestion * chore: update according to suggestion
This commit is contained in:
parent
944b044e93
commit
493ca50a2e
@ -144,13 +144,13 @@ proc setupProtocols(
|
|||||||
|
|
||||||
peerExchangeHandler = some(handlePeerExchange)
|
peerExchangeHandler = some(handlePeerExchange)
|
||||||
|
|
||||||
if conf.relay:
|
let shards =
|
||||||
let shards =
|
conf.contentTopics.mapIt(node.wakuSharding.getShard(it).expect("Valid Shard"))
|
||||||
conf.contentTopics.mapIt(node.wakuSharding.getShard(it).expect("Valid Shard"))
|
debug "Shards created from content topics",
|
||||||
let pubsubTopics = conf.pubsubTopics & shards
|
contentTopics = conf.contentTopics, shards = shards
|
||||||
|
|
||||||
debug "Shards created from content topics",
|
if conf.relay:
|
||||||
contentTopics = conf.contentTopics, shards = shards
|
let pubsubTopics = conf.pubsubTopics & shards
|
||||||
|
|
||||||
let parsedMaxMsgSize = parseMsgSize(conf.maxMessageSize).valueOr:
|
let parsedMaxMsgSize = parseMsgSize(conf.maxMessageSize).valueOr:
|
||||||
return err("failed to parse 'max-num-bytes-msg-size' param: " & $error)
|
return err("failed to parse 'max-num-bytes-msg-size' param: " & $error)
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user