status-im/nim-json-rpc
2
0
Fork 0
mirror of https://github.com/status-im/nim-json-rpc.git synced 2025-02-24 18:28:10 +00:00
Code Issues Projects Releases Wiki Activity

Added http rpc client definition

Browse Source
This commit is contained in:
coffeepots 2018-06-26 15:44:58 +01:00
parent 8685135fe9
commit 9e8121b405
1 changed files with 24 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
rpchttpservers.nim
View File

@ -1,5 +1,5 @@
import rpcserver, tables, chronicles, strformat import rpcserver, rpcclient, tables, chronicles, strformat, strutils
export rpcserver export rpcserver, rpcclient
type type
RpcHttpServer* = RpcServer[StreamServer] RpcHttpServer* = RpcServer[StreamServer]
@ -28,3 +28,25 @@ proc newRpcHttpServer*(address = "localhost", port: Port = Port(8545)): RpcHttpS
result = newRpcServer[StreamServer]() result = newRpcServer[StreamServer]()
result.addStreamServer(address, port, httpProcessClient) result.addStreamServer(address, port, httpProcessClient)
type RpcHttpClient* = RpcClient[StreamTransport, TransportAddress]
defineRpcClientTransport(StreamTransport, TransportAddress, "http"):
read:
client.transp.readLine()
afterRead:
# Strip out http header
# TODO: Performance
let p1 = find(value, '{')
if p1 > -1:
let p2 = rFind(value, '}')
if p2 == -1:
info "Cannot find json end brace", msg = value
else:
value = value[p1 .. p2]
debug "Extracted json", json = value
else:
info "Cannot find json start brace", msg = value
proc newRpcHttpClient*(): RpcHttpClient =
result = newRpcClient[StreamTransport, TransportAddress]()