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()