mirror of
https://github.com/logos-storage/nim-json-rpc.git
synced 2026-01-06 07:33:08 +00:00
ad0c3fb6e0
when an rpc method in server throw `InvalidRequest` using custom error code, the router need to mention the request id too. otherwise the client will throw error with confusing message.
110 lines
3.3 KiB
Nim
110 lines
3.3 KiB
Nim
import
|
|
unittest, json, chronicles,
|
|
../json_rpc/[rpcclient, rpcserver, clients/config]
|
|
|
|
const
|
|
compressionSupported = useNews
|
|
|
|
# Create RPC on server
|
|
proc setupServer*(srv: RpcServer) =
|
|
srv.rpc("myProc") do(input: string, data: array[0..3, int]):
|
|
return %("Hello " & input & " data: " & $data)
|
|
|
|
srv.rpc("myError") do(input: string, data: array[0..3, int]):
|
|
raise (ref ValueError)(msg: "someMessage")
|
|
|
|
srv.rpc("invalidRequest") do():
|
|
raise (ref InvalidRequest)(code: -32001, msg: "Unknown payload")
|
|
|
|
suite "Socket Server/Client RPC":
|
|
var srv = newRpcSocketServer(["localhost:8545"])
|
|
var client = newRpcSocketClient()
|
|
|
|
srv.setupServer()
|
|
srv.start()
|
|
waitFor client.connect("localhost", Port(8545))
|
|
|
|
test "Successful RPC call":
|
|
let r = waitFor client.call("myProc", %[%"abc", %[1, 2, 3, 4]])
|
|
check r.getStr == "Hello abc data: [1, 2, 3, 4]"
|
|
|
|
test "Missing params":
|
|
expect(CatchableError):
|
|
discard waitFor client.call("myProc", %[%"abc"])
|
|
|
|
test "Error RPC call":
|
|
expect(CatchableError): # The error type wont be translated
|
|
discard waitFor client.call("myError", %[%"abc", %[1, 2, 3, 4]])
|
|
|
|
test "Invalid request exception":
|
|
try:
|
|
discard waitFor client.call("invalidRequest", %[])
|
|
check false
|
|
except CatchableError as e:
|
|
check e.msg == """{"code":-32001,"message":"Unknown payload","data":null}"""
|
|
|
|
srv.stop()
|
|
waitFor srv.closeWait()
|
|
|
|
suite "Websocket Server/Client RPC":
|
|
var srv = newRpcWebSocketServer("127.0.0.1", Port(8545))
|
|
var client = newRpcWebSocketClient()
|
|
|
|
srv.setupServer()
|
|
srv.start()
|
|
waitFor client.connect("ws://127.0.0.1:8545/")
|
|
|
|
test "Successful RPC call":
|
|
let r = waitFor client.call("myProc", %[%"abc", %[1, 2, 3, 4]])
|
|
check r.getStr == "Hello abc data: [1, 2, 3, 4]"
|
|
|
|
test "Missing params":
|
|
expect(CatchableError):
|
|
discard waitFor client.call("myProc", %[%"abc"])
|
|
|
|
test "Error RPC call":
|
|
expect(CatchableError): # The error type wont be translated
|
|
discard waitFor client.call("myError", %[%"abc", %[1, 2, 3, 4]])
|
|
|
|
test "Invalid request exception":
|
|
try:
|
|
discard waitFor client.call("invalidRequest", %[])
|
|
check false
|
|
except CatchableError as e:
|
|
check e.msg == """{"code":-32001,"message":"Unknown payload","data":null}"""
|
|
|
|
srv.stop()
|
|
waitFor srv.closeWait()
|
|
|
|
suite "Websocket Server/Client RPC with Compression":
|
|
var srv = newRpcWebSocketServer("127.0.0.1", Port(8545),
|
|
compression = compressionSupported)
|
|
var client = newRpcWebSocketClient()
|
|
|
|
srv.setupServer()
|
|
srv.start()
|
|
waitFor client.connect("ws://127.0.0.1:8545/",
|
|
compression = compressionSupported)
|
|
|
|
test "Successful RPC call":
|
|
let r = waitFor client.call("myProc", %[%"abc", %[1, 2, 3, 4]])
|
|
check r.getStr == "Hello abc data: [1, 2, 3, 4]"
|
|
|
|
test "Missing params":
|
|
expect(CatchableError):
|
|
discard waitFor client.call("myProc", %[%"abc"])
|
|
|
|
test "Error RPC call":
|
|
expect(CatchableError): # The error type wont be translated
|
|
discard waitFor client.call("myError", %[%"abc", %[1, 2, 3, 4]])
|
|
|
|
test "Invalid request exception":
|
|
try:
|
|
discard waitFor client.call("invalidRequest", %[])
|
|
check false
|
|
except CatchableError as e:
|
|
check e.msg == """{"code":-32001,"message":"Unknown payload","data":null}"""
|
|
|
|
srv.stop()
|
|
waitFor srv.closeWait()
|