logos-storage/nim-json-rpc
1
0
Fork 0
mirror of https://github.com/logos-storage/nim-json-rpc.git synced 2026-01-09 09:03:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Make the RPC procs async again

Browse Source
This commit is contained in:
Zahary Karadjov 2020-01-21 18:49:52 +02:00
parent fc0665f88a
commit 6f9da4ba8a
No known key found for this signature in database
GPG Key ID: C8936F8A3073D609
1 changed files with 9 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
json_rpc/router.nim
View File

@ -230,36 +230,32 @@ macro rpc*(server: RpcRouter, path: string, body: untyped): untyped =
let returnType = parameters[0]
# delegate async proc allows return and setting of result as native type
result.add(quote do:
proc `doMain`(`paramsIdent`: JsonNode): `returnType` =
result.add quote do:
proc `doMain`(`paramsIdent`: JsonNode): Future[`returnType`] {.async.} =
`setup`
`procBody`
)
if returnType == ident"JsonNode":
# `JsonNode` results don't need conversion
result.add( quote do:
result.add quote do:
proc `procName`(`paramsIdent`: JsonNode): Future[JsonNode] {.async, gcsafe.} =
trap(`pathStr`):
`res` = `doMain`(`paramsIdent`)
)
`res` = await `doMain`(`paramsIdent`)
else:
result.add(quote do:
result.add quote do:
proc `procName`(`paramsIdent`: JsonNode): Future[JsonNode] {.async, gcsafe.} =
trap(`pathStr`):
`res` = %`doMain`(`paramsIdent`)
)
`res` = %(await `doMain`(`paramsIdent`))
else:
# no return types, inline contents
result.add(quote do:
result.add quote do:
proc `procName`(`paramsIdent`: JsonNode): Future[JsonNode] {.async, gcsafe.} =
`setup`
trap(`pathStr`):
`procBody`
)
result.add( quote do:
result.add quote do:
`server`.register(`path`, `procName`)
)
when defined(nimDumpRpcs):
echo "\n", pathStr, ": ", result.repr