From 093efbf73625913f9c5c5a54e447cf1a2a27e26f Mon Sep 17 00:00:00 2001 From: Kim De Mey Date: Tue, 6 Oct 2020 20:36:44 +0200 Subject: [PATCH] Begin of waku v2 rpc tests (#210) --- tests/all_tests_v2.nim | 3 ++- tests/v2/test_rpc_waku.nim | 43 ++++++++++++++++++++++++++++++++++++++ 2 files changed, 45 insertions(+), 1 deletion(-) create mode 100644 tests/v2/test_rpc_waku.nim diff --git a/tests/all_tests_v2.nim b/tests/all_tests_v2.nim index c25cd2a6a..358712ed6 100644 --- a/tests/all_tests_v2.nim +++ b/tests/all_tests_v2.nim @@ -4,4 +4,5 @@ import # ./v2/test_waku, ./v2/test_wakunode, ./v2/test_waku_store, - ./v2/test_waku_filter + ./v2/test_waku_filter, + ./v2/test_rpc_waku diff --git a/tests/v2/test_rpc_waku.nim b/tests/v2/test_rpc_waku.nim new file mode 100644 index 000000000..8cae40b52 --- /dev/null +++ b/tests/v2/test_rpc_waku.nim @@ -0,0 +1,43 @@ +{.used.} + +import + std/[unittest, options, os, strutils], + stew/shims/net as stewNet, + json_rpc/[rpcserver, rpcclient], + libp2p/crypto/crypto, + ../../waku/node/v2/[waku_types, wakunode2], + ../../waku/node/v2/rpc/wakurpc, + ../../waku/protocol/v2/waku_relay, + ../test_helpers + +template sourceDir*: string = currentSourcePath.rsplit(DirSep, 1)[0] +const sigPath = sourceDir / ParDir / ParDir / "waku" / "node" / "v2" / "rpc" / "wakucallsigs.nim" +createRpcSigs(RpcHttpClient, sigPath) + +suite "Waku v2 Remote Procedure Calls": + # WakuNode setup + let + rng = crypto.newRng() + privkey = crypto.PrivateKey.random(Secp256k1, rng[]).tryGet() + bindIp = ValidIpAddress.init("0.0.0.0") + extIp = ValidIpAddress.init("127.0.0.1") + port = Port(9000) + node = WakuNode.init(privkey, bindIp, port, some(extIp), some(port), @["waku"]) + + waitFor node.start() + + # RPC server setup + let + rpcPort = Port(8545) + ta = initTAddress(bindIp, rpcPort) + server = newRpcHttpServer([ta]) + + setupWakuRPC(node, server) + server.start() + + asyncTest "waku_info": + # RPC client setup + let client = newRpcHttpClient() + await client.connect("127.0.0.1", rpcPort) + + check await(client.waku_version()) == WakuRelayCodec