6 nodes in quicksim and post 100 messages

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..<topicAmount:
+  let res2 = waitFor node1.wakuPublish("foobar", "hello world")
+
 os.sleep(2000)
-info "Version is", version

waku/node/v2/start_network.nim

@@ -68,7 +68,7 @@ proc starNetwork(amount: int): seq[NodeInfo] =
 when isMainModule:
   # TODO: WakuNetworkConf
   var nodes: seq[NodeInfo]
-  let amount = 2
+  let amount = 6
   nodes = starNetwork(amount)
 
   var commandStr = "multitail -s 2 -M 0 -x \"Waku Simulation\""