mirror of
https://github.com/logos-messaging/logos-messaging-nim.git
synced 2026-01-07 16:33:08 +00:00
31 lines
803 B
Nim
31 lines
803 B
Nim
|
import
|
||
|
|
os, strutils, strformat, chronicles, json_rpc/[rpcclient, rpcserver], nimcrypto/sysrand,
|
||
|
|
libp2p/protobuf/minprotobuf,
|
||
|
|
libp2p/[peerinfo, multiaddress],
|
||
|
|
eth/common as eth_common, eth/keys,
|
||
|
|
system,
|
||
|
|
options
|
||
|
|
|
||
|
|
from strutils import rsplit
|
||
|
|
template sourceDir: string = currentSourcePath.rsplit(DirSep, 1)[0]
|
||
|
|
|
||
|
|
const sigWakuPath = sourceDir / "wakucallsigs.nim"
|
||
|
|
createRpcSigs(RpcHttpClient, sigWakuPath)
|
||
|
|
|
||
|
|
if paramCount() < 1:
|
||
|
|
echo "Please provide rpcPort as argument."
|
||
|
|
quit(1)
|
||
|
|
|
||
|
|
let rpcPort = Port(parseInt(paramStr(1)))
|
||
|
|
|
||
|
|
echo "Please enter your topic:"
|
||
|
|
let raw_input = readLine(stdin)
|
||
|
|
let input = fmt"{raw_input}"
|
||
|
|
echo "Input is:", input
|
||
|
|
|
||
|
|
var node = newRpcHttpClient()
|
||
|
|
waitfor node.connect("localhost", rpcPort)
|
||
|
|
|
||
|
|
var res = waitfor node.wakuQuery(@[input])
|
||
|
|
echo "Waku query response: ", res
|