mirror of https://github.com/waku-org/nwaku.git
This reverts commit 93e09b8b77
.
This commit is contained in:
parent
960740713c
commit
613974c1b6
|
@ -1 +1 @@
|
|||
Subproject commit eb78292d9cb2d179e00af78b7ee969eaedf1736d
|
||||
Subproject commit a1eb53b1813df5d4fa1b343ef003ad9fb5ebb1d8
|
|
@ -199,7 +199,7 @@ proc subscribe*(w: WakuRelay, pubsubTopic: PubsubTopic, handler: WakuRelayHandle
|
|||
debug "subscribe", pubsubTopic=pubsubTopic
|
||||
|
||||
# we need to wrap the handler since gossipsub doesnt understand WakuMessage
|
||||
let wrappedHandler = proc(pubsubTopic: string, data: seq[byte]): Future[void] {.gcsafe, raises: [].} =
|
||||
let wrappedHandler = proc(pubsubTopic: string, data: seq[byte]): Future[void] {.gcsafe, raises: [Defect].} =
|
||||
let decMsg = WakuMessage.decode(data)
|
||||
if decMsg.isErr():
|
||||
# fine if triggerSelf enabled, since validators are bypassed
|
||||
|
|
Loading…
Reference in New Issue