mirror of https://github.com/waku-org/nwaku.git
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
94947a8504
commit
733edae435
|
@ -144,14 +144,14 @@ 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"))
|
||||||
let pubsubTopics = conf.pubsubTopics & shards
|
|
||||||
|
|
||||||
debug "Shards created from content topics",
|
debug "Shards created from content topics",
|
||||||
contentTopics = conf.contentTopics, shards = shards
|
contentTopics = conf.contentTopics, shards = shards
|
||||||
|
|
||||||
|
if conf.relay:
|
||||||
|
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…
Reference in New Issue