waku-org/nwaku
1
0
Fork 0
mirror of https://github.com/waku-org/nwaku.git synced 2025-01-13 16:25:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Manual topic interest intermediate direct nodes work

Browse Source
This commit is contained in:
Oskar Thoren 2020-06-03 19:30:37 +08:00
parent 407ec3534f
commit 037c3f29cb
No known key found for this signature in database
GPG Key ID: B2ECCFD3BC2EF77E
2 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
waku/node/v2/quicksim.nim
View File

@ -68,6 +68,16 @@ info "Version is", version
let res1 = waitFor nodea.wakuSubscribe("foobar") let res1 = waitFor nodea.wakuSubscribe("foobar")
let res2 = waitFor nodeb.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) os.sleep(2000)
# XXX: Where is hello world tho? # XXX: Where is hello world tho?

3
waku/protocol/v2/waku_protocol.nim
View File

@ -54,7 +54,8 @@ method initPubSub*(w: WakuSub) =
w.text = "Foobar" w.text = "Foobar"
debug "w.text", text = w.text debug "w.text", text = w.text
w.gossip_enabled = true # Using FloodSub
w.gossip_enabled = false
if w.gossip_enabled: if w.gossip_enabled:
procCall GossipSub(w).initPubSub() procCall GossipSub(w).initPubSub()