status-im
/
nim-json-rpc
mirror of https://github.com/status-im/nim-json-rpc.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

Fix for latest changes in asyncdispatch2.

This commit is contained in:
cheatfate 2018-06-12 09:49:16 +03:00
parent 4daf3353aa
commit 1ff985b468
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
eth-rpc/server.nim
View File

@ -80,8 +80,9 @@ proc sendError*(client: StreamTransport, code: int, msg: string, id: JsonNode,
data: JsonNode = newJNull()) {.async.} =
## Send error message to client
let error = %{"code": %(code), "message": %msg, "data": data}
ifDebug: echo "Send error json: ", wrapReply(newJNull(), error, id)
result = client.write(wrapReply(id, newJNull(), error))
var res = wrapReply(id, newJNull(), error)
ifDebug: echo "Send error json: ", res
result = client.write(res)
proc sendJsonError*(state: RpcJsonError, client: StreamTransport, id: JsonNode,
data = newJNull()) {.async.} =
@ -110,7 +111,8 @@ proc processMessage(server: RpcServer, client: StreamTransport,
%(methodName & " is not a registered method."))
else:
let callRes = await server.procs[methodName](node["params"])
discard await client.write(wrapReply(id, callRes, newJNull()))
var res = wrapReply(id, callRes, newJNull())
discard await client.write(res)
proc processClient(server: StreamServer, client: StreamTransport) {.async.} =
var rpc = getUserData[RpcServer](server)