status-im/nimbus-eth1
2
0
Fork 0
mirror of https://github.com/status-im/nimbus-eth1.git synced 2025-01-13 22:04:52 +00:00
Code Issues Projects Releases Wiki Activity

Quicksim: Send more messages

Browse Source
This commit is contained in:
Oskar Thoren 2019-12-17 13:46:23 +08:00 committed by zah
parent bcaf6d03ee
commit 0f121927b5
1 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
waku/quicksim.nim
View File

@ -1,5 +1,5 @@
import import
strformat, chronicles, json_rpc/[rpcclient, rpcserver], os, strformat, chronicles, json_rpc/[rpcclient, rpcserver],
eth/common as eth_common, eth/keys, eth/p2p/rlpx_protocols/waku_protocol, eth/common as eth_common, eth/keys, eth/p2p/rlpx_protocols/waku_protocol,
../nimbus/rpc/[hexstrings, rpc_types, waku], ../nimbus/rpc/[hexstrings, rpc_types, waku],
options as what # TODO: Huh? options as what # TODO: Huh?
@ -30,16 +30,26 @@ let
let let
symkeyID2 = waitFor bob.shh_addSymKey(symKey) symkeyID2 = waitFor bob.shh_addSymKey(symKey)
message = WhisperPostMessage(symKeyID: some(symkeyID2),
var i = 1
while i <= 10000:
var message = WhisperPostMessage(symKeyID: some(symkeyID2),
ttl: 30, ttl: 30,
topic: some(topic), topic: some(topic),
payload: "0x45879632".HexDataStr, payload: "0x45879632".HexDataStr,
powTime: 1.0, powTime: 1.0,
powTarget: 0.002) powTarget: 0.002)
discard waitFor bob.shh_post(message) debug "Message", i, message
sleep(100)
discard waitFor bob.shh_post(message)
inc(i)
var messages: seq[WhisperFilterMessage] var messages: seq[WhisperFilterMessage]
debug "Messages len", length = messages.len
while messages.len == 0: while messages.len == 0:
messages = waitFor alice.shh_getFilterMessages(filterID) messages = waitFor alice.shh_getFilterMessages(filterID)
waitFor sleepAsync(100.milliseconds) waitFor sleepAsync(100.milliseconds)
debug "Received message", payload = messages[0].payload debug "Received message", payload = messages[0].payload
debug "Received messages", length = messages.len