waku-org
/
nwaku
mirror of https://github.com/waku-org/nwaku.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Publish with RPC; fix RPC sigs

This commit is contained in:
Oskar Thoren 2020-05-22 14:25:09 +08:00
parent f7b9fc2613
commit 444da6a80a
No known key found for this signature in database
GPG Key ID: B2ECCFD3BC2EF77E
2 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -17,7 +17,7 @@ createRpcSigs(RpcHttpClient, sigWakuPath)
# More minimal than v1 quicksim, just RPC client for now
let node1 = newRpcHttpClient()
#let node2 = newRpcHttpClient()
let node2 = newRpcHttpClient()
# Where do we connect nodes here? Protocol so not RPC based, maybe?
# Using with static nodes, hardcoded "works":
@ -30,7 +30,10 @@ info "Hello there"
# portsShift=2
waitFor node1.connect("localhost", Port(8547))
waitFor node2.connect("localhost", Port(8548))
let version = waitFor node1.wakuVersion()
let res = waitFor node1.wakuPost("hello world")
info "Version is", version

7
waku/node/v2/rpc/wakucallsigs.nim
View File

@ -1,7 +1,8 @@
# NOTE: Taken from v1, only version exists right now
# Alpha - Currently implemented in v2
proc waku_version(): string
proc waku_publish(message: string): bool
proc waku_post(message: string): bool
# NYI
proc waku_info(): WakuInfo
proc waku_setMaxMessageSize(size: uint64): bool
proc waku_setMinPoW(pow: float): bool
@ -24,7 +25,7 @@ proc waku_deleteSymKey(id: Identifier): bool
proc waku_newMessageFilter(options: WakuFilterOptions): Identifier
proc waku_deleteMessageFilter(id: Identifier): bool
proc waku_getFilterMessages(id: Identifier): seq[WakuFilterMessage]
proc waku_post(message: WakuPostMessage): bool
#proc waku_post(message: WakuPostMessage): bool
proc wakusim_generateTraffic(amount: int): bool
proc wakusim_generateRandomTraffic(amount: int): bool