logos-messaging/logos-messaging-nim
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-nim.git synced 2026-01-04 06:53:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

Don't crash on non WakuMessage in rpc subscribe (#175)

Browse Source 
Instead, log stringified version. (This is used for other PoC right now.)
This commit is contained in:
Oskar Thorén 2020-09-22 10:14:39 +08:00 committed by GitHub
parent bcae93300a
commit 3100d86f24
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
waku/node/v2/rpc/wakurpc.nim
View File

@ -54,11 +54,11 @@ proc setupWakuRPC*(node: WakuNode, rpcsrv: RpcServer) =
let msg = WakuMessage.init(data) let msg = WakuMessage.init(data)
if msg.isOk(): if msg.isOk():
debug "waku_subscribe handler", msg=msg debug "waku_subscribe handler", msg=msg
var readable_str = cast[string](msg[].payload)
info "Hit subscribe handler", topic=topic, msg=msg[], payload=readable_str
else: else:
warn "waku_subscribe decode error", msg=msg warn "waku_subscribe decode error", msg=msg
info "waku_subscribe raw data string", str=cast[string](data)
var readable_str = cast[string](msg[].payload)
info "Hit subscribe handler", topic=topic, msg=msg[], payload=readable_str
# XXX: Can we make this context async to use await? # XXX: Can we make this context async to use await?
discard node.subscribe(topic, handler) discard node.subscribe(topic, handler)