From 037c3f29cbc5fe466d34d876c8e7407ba63aff42 Mon Sep 17 00:00:00 2001 From: Oskar Thoren Date: Wed, 3 Jun 2020 19:30:37 +0800 Subject: [PATCH] Manual topic interest intermediate direct nodes work --- waku/node/v2/quicksim.nim | 10 ++++++++++ waku/protocol/v2/waku_protocol.nim | 3 ++- 2 files changed, 12 insertions(+), 1 deletion(-) diff --git a/waku/node/v2/quicksim.nim b/waku/node/v2/quicksim.nim index 60c824816..5b2374713 100644 --- a/waku/node/v2/quicksim.nim +++ b/waku/node/v2/quicksim.nim @@ -68,6 +68,16 @@ info "Version is", version let res1 = waitFor nodea.wakuSubscribe("foobar") let res2 = waitFor nodeb.wakuSubscribe("foobar") + +# Node 00 and 05 also subscribe +# XXX I confirm this works. Now to tweak it! +let node0 = newRpcHttpClient() +let node5 = newRpcHttpClient() +waitFor node0.connect("localhost", Port(8547)) +waitFor node5.connect("localhost", Port(8552)) +let res4 = waitFor node0.wakuSubscribe("foobar") +let res5 = waitFor node5.wakuSubscribe("foobar") + os.sleep(2000) # XXX: Where is hello world tho? diff --git a/waku/protocol/v2/waku_protocol.nim b/waku/protocol/v2/waku_protocol.nim index d8dbf134e..18d6de714 100644 --- a/waku/protocol/v2/waku_protocol.nim +++ b/waku/protocol/v2/waku_protocol.nim @@ -54,7 +54,8 @@ method initPubSub*(w: WakuSub) = w.text = "Foobar" debug "w.text", text = w.text - w.gossip_enabled = true + # Using FloodSub + w.gossip_enabled = false if w.gossip_enabled: procCall GossipSub(w).initPubSub()