From c6a77bcba7c7d96744744a98cc684657605b7d50 Mon Sep 17 00:00:00 2001 From: Prem Chaitanya Prathi Date: Sat, 29 Mar 2025 19:35:56 +0530 Subject: [PATCH] fix arg --- examples/lightpush_publisher_mix.nim | 16 ++++++++-------- examples/lightpush_publisher_mix_config.nim | 2 +- 2 files changed, 9 insertions(+), 9 deletions(-) diff --git a/examples/lightpush_publisher_mix.nim b/examples/lightpush_publisher_mix.nim index 461e0c83a..7c3394b4e 100644 --- a/examples/lightpush_publisher_mix.nim +++ b/examples/lightpush_publisher_mix.nim @@ -13,7 +13,7 @@ import eth/p2p/discoveryv5/enr, metrics -import mix/entry_connection, mix/protocol +import mix/entry_connection, mix/protocol, mix/curve25519 import waku/[ @@ -90,15 +90,13 @@ proc setupAndPublish(rng: ref HmacDrbgContext, conf: LPMixConf) {.async.} = @[MultiAddress.init(conf.destPeerAddr).get()], ) node.peerManager.addServicePeer(pxPeerInfo, WakuPeerExchangeCodec) + let keyPairResult = generateKeyPair() + if keyPairResult.isErr: + return + let (mixPrivKey, mixPubKey) = keyPairResult.get() ( - await node.mountMix( - intoCurve25519Key( - ncrutils.fromHex( - "401dd1eb5582f6dc9488d424aa26ed1092becefcf8543172e6d92c17ed07265a" - ) - ) - ) + await node.mountMix(mixPrivKey) ).isOkOr: error "failed to mount waku mix protocol: ", error = $error return @@ -154,6 +152,8 @@ proc setupAndPublish(rng: ref HmacDrbgContext, conf: LPMixConf) {.async.} = lp_mix_failed.inc(labelValues = ["publish_error"]) await sleepAsync(1000) + info "###########Sent all messages via mix" + quit(0) when isMainModule: let conf = LPMixConf.load() diff --git a/examples/lightpush_publisher_mix_config.nim b/examples/lightpush_publisher_mix_config.nim index 41bfcd7fc..bcbd37ff0 100644 --- a/examples/lightpush_publisher_mix_config.nim +++ b/examples/lightpush_publisher_mix_config.nim @@ -30,5 +30,5 @@ type minMixPoolSize* {. desc: "Number of messages to wait for before sending.", defaultValue: 3, - name: "mix-mix-pool-size", + name: "min-mix-pool-size", }: int \ No newline at end of file