diff --git a/library/waku_thread/config.nim b/library/waku_thread/config.nim index 8cd7a79810..bb0a7bfd5e 100644 --- a/library/waku_thread/config.nim +++ b/library/waku_thread/config.nim @@ -143,11 +143,11 @@ proc parseStore( return true proc parseTopics(jsonNode: JsonNode, conf: var WakuNodeConf) = - if jsonNode.contains("topics"): - for topic in jsonNode["topics"].items: - conf.topics.add(topic.getStr()) + if jsonNode.contains("pubsubTopics"): + for topic in jsonNode["pubsubTopics"].items: + conf.pubsubTopics.add(topic.getStr()) else: - conf.topics = @["/waku/2/default-waku/proto"] + conf.pubsubTopics = @["/waku/2/default-waku/proto"] proc parseConfig*( configNodeJson: string, diff --git a/tests/node/peer_manager/test_peer_manager.nim b/tests/node/peer_manager/test_peer_manager.nim index f9e8f9a29e..21fe312e7e 100644 --- a/tests/node/peer_manager/test_peer_manager.nim +++ b/tests/node/peer_manager/test_peer_manager.nim @@ -35,9 +35,9 @@ suite "Peer Manager": # Given two nodes with the same shardId let server = - newTestWakuNode(serverKey, listenAddress, listenPort, topics = @[shardTopic0]) + newTestWakuNode(serverKey, listenAddress, listenPort, pubsubTopics = @[shardTopic0]) client = - newTestWakuNode(clientKey, listenAddress, listenPort, topics = @[shardTopic1]) + newTestWakuNode(clientKey, listenAddress, listenPort, pubsubTopics = @[shardTopic1]) # And both mount metadata and filter discard client.mountMetadata(0) # clusterId irrelevant, overridden by topic @@ -68,9 +68,9 @@ suite "Peer Manager": # Given two nodes with the same shardId let server = - newTestWakuNode(serverKey, listenAddress, listenPort, topics = @[shardTopic0]) + newTestWakuNode(serverKey, listenAddress, listenPort, pubsubTopics = @[shardTopic0]) client = - newTestWakuNode(clientKey, listenAddress, listenPort, topics = @[shardTopic0]) + newTestWakuNode(clientKey, listenAddress, listenPort, pubsubTopics = @[shardTopic0]) # And both mount metadata and relay discard client.mountMetadata(0) # clusterId irrelevant, overridden by topic @@ -99,9 +99,9 @@ suite "Peer Manager": # Given two nodes with different shardIds let server = - newTestWakuNode(serverKey, listenAddress, listenPort, topics = @[shardTopic0]) + newTestWakuNode(serverKey, listenAddress, listenPort, pubsubTopics = @[shardTopic0]) client = - newTestWakuNode(clientKey, listenAddress, listenPort, topics = @[shardTopic1]) + newTestWakuNode(clientKey, listenAddress, listenPort, pubsubTopics = @[shardTopic1]) # And both mount metadata and relay discard client.mountMetadata(0) # clusterId irrelevant, overridden by topic diff --git a/tests/test_peer_manager.nim b/tests/test_peer_manager.nim index d16624e751..4c44086146 100644 --- a/tests/test_peer_manager.nim +++ b/tests/test_peer_manager.nim @@ -420,7 +420,7 @@ procSuite "Peer Manager": ValidIpAddress.init("0.0.0.0"), Port(0), clusterId = clusterId3, - topics = @["/waku/2/rs/3/0"], + pubsubTopics = @["/waku/2/rs/3/0"], ) # same network @@ -429,14 +429,14 @@ procSuite "Peer Manager": ValidIpAddress.init("0.0.0.0"), Port(0), clusterId = clusterId4, - topics = @["/waku/2/rs/4/0"], + pubsubTopics = @["/waku/2/rs/4/0"], ) node3 = newTestWakuNode( generateSecp256k1Key(), ValidIpAddress.init("0.0.0.0"), Port(0), clusterId = clusterId4, - topics = @["/waku/2/rs/4/0"], + pubsubTopics = @["/waku/2/rs/4/0"], ) node1.mountMetadata(clusterId3).expect("Mounted Waku Metadata") diff --git a/tests/test_peer_storage.nim b/tests/test_peer_storage.nim index 5c183b6b69..019d7e1b4f 100644 --- a/tests/test_peer_storage.nim +++ b/tests/test_peer_storage.nim @@ -21,11 +21,11 @@ suite "Peer Storage": peerProto = "/waku/2/default-waku/codec" connectedness = Connectedness.CanConnect disconn = 999999 - topics = @["/waku/2/rs/2/0", "/waku/2/rs/2/1"] + pubsubTopics = @["/waku/2/rs/2/0", "/waku/2/rs/2/1"] # Create ENR var enrBuilder = EnrBuilder.init(peerKey) - enrBuilder.withShardedTopics(topics).expect("Valid topics") + enrBuilder.withShardedTopics(pubsubTopics).expect("Valid topics") let record = enrBuilder.build().expect("Valid record") let stored = RemotePeerInfo( diff --git a/tests/testlib/wakunode.nim b/tests/testlib/wakunode.nim index 58b13bb471..732256ee23 100644 --- a/tests/testlib/wakunode.nim +++ b/tests/testlib/wakunode.nim @@ -33,7 +33,7 @@ proc defaultTestWakuNodeConf*(): WakuNodeConf = maxConnections: 50, maxMessageSize: "1024 KiB", clusterId: 1.uint32, - topics: @["/waku/2/rs/1/0"], + pubsubTopics: @["/waku/2/rs/1/0"], relay: true, storeMessageDbUrl: "sqlite://store.sqlite3", ) @@ -59,7 +59,7 @@ proc newTestWakuNode*( discv5UdpPort = none(Port), agentString = none(string), clusterId: uint32 = 1.uint32, - topics: seq[string] = @["/waku/2/rs/1/0"], + pubsubTopics: seq[string] = @["/waku/2/rs/1/0"], peerStoreCapacity = none(int), ): WakuNode = var resolvedExtIp = extIp @@ -74,7 +74,7 @@ proc newTestWakuNode*( var conf = defaultTestWakuNodeConf() conf.clusterId = clusterId - conf.topics = topics + conf.pubsubTopics = pubsubTopics if dns4DomainName.isSome() and extIp.isNone(): # If there's an error resolving the IP, an exception is thrown and test fails @@ -101,7 +101,7 @@ proc newTestWakuNode*( var enrBuilder = EnrBuilder.init(nodeKey) - enrBuilder.withShardedTopics(topics).isOkOr: + enrBuilder.withShardedTopics(pubsubTopics).isOkOr: raise newException(Defect, "Invalid record: " & error) enrBuilder.withIpAddressAndPorts( diff --git a/waku/factory/external_config.nim b/waku/factory/external_config.nim index a31f31afa7..89bae81356 100644 --- a/waku/factory/external_config.nim +++ b/waku/factory/external_config.nim @@ -297,13 +297,6 @@ type WakuNodeConf* = object name: "keep-alive" .}: bool - topics* {. - desc: - "Default topic to subscribe to. Argument may be repeated. Deprecated! Please use pubsub-topic and/or content-topic instead.", - defaultValue: @["/waku/2/default-waku/proto"], - name: "topic" - .}: seq[string] - pubsubTopics* {. desc: "Default pubsub topic to subscribe to. Argument may be repeated.", name: "pubsub-topic" diff --git a/waku/factory/internal_config.nim b/waku/factory/internal_config.nim index 51829a39b3..8b8a45f600 100644 --- a/waku/factory/internal_config.nim +++ b/waku/factory/internal_config.nim @@ -32,7 +32,7 @@ proc enrConfiguration*( let shards: seq[uint16] = # no shards configured if conf.shards.len == 0: - toSeq(0 ..< conf.topics.len).mapIt(uint16(it)) + toSeq(0 ..< conf.pubsubTopics.len).mapIt(uint16(it)) # some shards configured else: toSeq(conf.shards.mapIt(uint16(it))) diff --git a/waku/factory/node_factory.nim b/waku/factory/node_factory.nim index 9973036ccf..c2c3db0fd9 100644 --- a/waku/factory/node_factory.nim +++ b/waku/factory/node_factory.nim @@ -140,15 +140,9 @@ proc setupProtocols( peerExchangeHandler = some(handlePeerExchange) if conf.relay: - let pubsubTopics = - if conf.pubsubTopics.len > 0 or conf.contentTopics.len > 0: - # TODO autoshard content topics only once. - # Already checked for errors in app.init - let shards = - conf.contentTopics.mapIt(node.wakuSharding.getShard(it).expect("Valid Shard")) - conf.pubsubTopics & shards - else: - conf.topics + let shards = + conf.contentTopics.mapIt(node.wakuSharding.getShard(it).expect("Valid Shard")) + let pubsubTopics = conf.pubsubTopics & shards let parsedMaxMsgSize = parseMsgSize(conf.maxMessageSize).valueOr: return err("failed to parse 'max-num-bytes-msg-size' param: " & $error)