From 11b44e3e15c65d80cadf2ab8a51afac94098c24c Mon Sep 17 00:00:00 2001 From: Ivan FB <128452529+Ivansete-status@users.noreply.github.com> Date: Sat, 14 Jun 2025 10:09:51 +0200 Subject: [PATCH] chore: refactor rm discv5-only (#3453) --- waku/discovery/waku_discv5.nim | 1 - waku/factory/conf_builder/discv5_conf_builder.nim | 5 ----- waku/factory/conf_builder/waku_conf_builder.nim | 1 - waku/factory/external_config.nim | 7 ------- waku/factory/node_factory.nim | 4 ---- waku/factory/waku.nim | 11 +++++------ 6 files changed, 5 insertions(+), 24 deletions(-) diff --git a/waku/discovery/waku_discv5.nim b/waku/discovery/waku_discv5.nim index 221acef42..5bdb91a2e 100644 --- a/waku/discovery/waku_discv5.nim +++ b/waku/discovery/waku_discv5.nim @@ -26,7 +26,6 @@ logScope: type Discv5Conf* {.requiresInit.} = object # TODO: This should probably be an option on the builder # But translated to everything else "false" on the config - discv5Only*: bool bootstrapNodes*: seq[string] udpPort*: Port tableIpLimit*: uint diff --git a/waku/factory/conf_builder/discv5_conf_builder.nim b/waku/factory/conf_builder/discv5_conf_builder.nim index 950b2a4f6..30755669b 100644 --- a/waku/factory/conf_builder/discv5_conf_builder.nim +++ b/waku/factory/conf_builder/discv5_conf_builder.nim @@ -13,7 +13,6 @@ type Discv5ConfBuilder* = object bootstrapNodes*: seq[string] bitsPerHop*: Option[int] bucketIpLimit*: Option[uint] - discv5Only*: Option[bool] enrAutoUpdate*: Option[bool] tableIpLimit*: Option[uint] udpPort*: Option[Port] @@ -30,9 +29,6 @@ proc withBitsPerHop*(b: var Discv5ConfBuilder, bitsPerHop: int) = proc withBucketIpLimit*(b: var Discv5ConfBuilder, bucketIpLimit: uint) = b.bucketIpLimit = some(bucketIpLimit) -proc withDiscv5Only*(b: var Discv5ConfBuilder, discv5Only: bool) = - b.discv5Only = some(discv5Only) - proc withEnrAutoUpdate*(b: var Discv5ConfBuilder, enrAutoUpdate: bool) = b.enrAutoUpdate = some(enrAutoUpdate) @@ -56,7 +52,6 @@ proc build*(b: Discv5ConfBuilder): Result[Option[Discv5Conf], string] = bootstrapNodes: b.bootstrapNodes, bitsPerHop: b.bitsPerHop.get(1), bucketIpLimit: b.bucketIpLimit.get(2), - discv5Only: b.discv5Only.get(false), enrAutoUpdate: b.enrAutoUpdate.get(true), tableIpLimit: b.tableIpLimit.get(10), udpPort: b.udpPort.get(9000.Port), diff --git a/waku/factory/conf_builder/waku_conf_builder.nim b/waku/factory/conf_builder/waku_conf_builder.nim index f1f0ba471..46e303e70 100644 --- a/waku/factory/conf_builder/waku_conf_builder.nim +++ b/waku/factory/conf_builder/waku_conf_builder.nim @@ -82,7 +82,6 @@ type WakuConfBuilder* = object # TODO: move within a relayConf rendezvous: Option[bool] - discv5Only: Option[bool] clusterConf: Option[ClusterConf] diff --git a/waku/factory/external_config.nim b/waku/factory/external_config.nim index f85a9fae3..a9e828893 100644 --- a/waku/factory/external_config.nim +++ b/waku/factory/external_config.nim @@ -610,12 +610,6 @@ with the drawback of consuming some more bandwidth.""", name: "discv5-bits-per-hop" .}: int - discv5Only* {. - desc: "Disable all protocols other than discv5", - defaultValue: false, - name: "discv5-only" - .}: bool - ## waku peer exchange config peerExchange* {. desc: "Enable waku peer exchange protocol (responder side): true|false", @@ -1021,7 +1015,6 @@ proc toWakuConf*(n: WakuNodeConf): ConfResult[WakuConf] = b.discv5Conf.withTableIpLimit(n.discv5TableIpLimit) b.discv5Conf.withBucketIpLimit(n.discv5BucketIpLimit) b.discv5Conf.withBitsPerHop(n.discv5BitsPerHop) - b.discv5Conf.withDiscv5Only(n.discv5Only) b.withPeerExchange(n.peerExchange) diff --git a/waku/factory/node_factory.nim b/waku/factory/node_factory.nim index 5dc549317..7063f8476 100644 --- a/waku/factory/node_factory.nim +++ b/waku/factory/node_factory.nim @@ -151,10 +151,6 @@ proc setupProtocols( ## Optionally include persistent message storage. ## No protocols are started yet. - if conf.discv5Conf.isSome() and conf.discv5Conf.get().discv5Only: - notice "Running node only with Discv5, not mounting additional protocols" - return ok() - node.mountMetadata(conf.clusterId).isOkOr: return err("failed to mount waku metadata protocol: " & error) diff --git a/waku/factory/waku.nim b/waku/factory/waku.nim index fe797b0a3..006093648 100644 --- a/waku/factory/waku.nim +++ b/waku/factory/waku.nim @@ -361,13 +361,12 @@ proc startWaku*(waku: ptr Waku): Future[Result[void, string]] {.async.} = else: waku[].dynamicBootstrapNodes = dynamicBootstrapNodesRes.get() - if conf.discv5Conf.isNone or not conf.discv5Conf.get().discv5Only: - (await startNode(waku.node, waku.conf, waku.dynamicBootstrapNodes)).isOkOr: - return err("error while calling startNode: " & $error) + (await startNode(waku.node, waku.conf, waku.dynamicBootstrapNodes)).isOkOr: + return err("error while calling startNode: " & $error) - # Update waku data that is set dynamically on node start - updateWaku(waku).isOkOr: - return err("Error in updateApp: " & $error) + ## Update waku data that is set dynamically on node start + updateWaku(waku).isOkOr: + return err("Error in updateApp: " & $error) ## Discv5 if conf.discv5Conf.isSome: