diff --git a/waku/node/v2/quicksim.nim b/waku/node/v2/quicksim.nim index 2a64af4f3..33a910a47 100644 --- a/waku/node/v2/quicksim.nim +++ b/waku/node/v2/quicksim.nim @@ -1,8 +1,8 @@ import os, strformat, chronicles, json_rpc/[rpcclient, rpcserver], nimcrypto/sysrand, eth/common as eth_common, eth/keys, - ../v1/rpc/[hexstrings, rpc_types], - options as what # TODO: Huh? Redefinition? + options + #options as what # TODO: Huh? Redefinition? from os import DirSep from strutils import rsplit @@ -11,16 +11,16 @@ template sourceDir: string = currentSourcePath.rsplit(DirSep, 1)[0] const sigWakuPath = &"{sourceDir}{DirSep}rpc{DirSep}wakucallsigs.nim" createRpcSigs(RpcHttpClient, sigWakuPath) +const topicAmount = 100 + let node1 = newRpcHttpClient() let node2 = newRpcHttpClient() -info "Hello there" - -# portsShift=2 waitFor node1.connect("localhost", Port(8547)) waitFor node2.connect("localhost", Port(8548)) -let version = waitFor node1.wakuVersion() +#let version = waitFor node1.wakuVersion() +#info "Version is", version proc handler(topic: string, data: seq[byte]) {.async, gcsafe.} = debug "Hit handler", topic=topic, data=data @@ -28,6 +28,9 @@ proc handler(topic: string, data: seq[byte]) {.async, gcsafe.} = # TODO: Implement handler logic let res1 = waitFor node2.wakuSubscribe("foobar") os.sleep(2000) -let res2 = waitFor node1.wakuPublish("foobar", "hello world") + +# info "Posting envelopes on all subscribed topics" +for i in 0..