mirror of https://github.com/waku-org/nwaku.git
chore(deps): bump libp2p & websock (#1800)
This commit is contained in:
parent
0e9ecbd6a9
commit
f6e89c311d
|
@ -1 +1 @@
|
||||||
Subproject commit a1eb53b1813df5d4fa1b343ef003ad9fb5ebb1d8
|
Subproject commit 49dfa84c6ffc8932aae03b64953ef1721d51a812
|
|
@ -1 +1 @@
|
||||||
Subproject commit fea05cde8b123b38d1a0a8524b77efbc84daa848
|
Subproject commit 2c3ae3137f3c9cb48134285bd4a47186fa51f0e8
|
|
@ -199,7 +199,7 @@ proc subscribe*(w: WakuRelay, pubsubTopic: PubsubTopic, handler: WakuRelayHandle
|
||||||
debug "subscribe", pubsubTopic=pubsubTopic
|
debug "subscribe", pubsubTopic=pubsubTopic
|
||||||
|
|
||||||
# we need to wrap the handler since gossipsub doesnt understand WakuMessage
|
# we need to wrap the handler since gossipsub doesnt understand WakuMessage
|
||||||
let wrappedHandler = proc(pubsubTopic: string, data: seq[byte]): Future[void] {.gcsafe, raises: [Defect].} =
|
let wrappedHandler = proc(pubsubTopic: string, data: seq[byte]): Future[void] {.gcsafe, raises: [].} =
|
||||||
let decMsg = WakuMessage.decode(data)
|
let decMsg = WakuMessage.decode(data)
|
||||||
if decMsg.isErr():
|
if decMsg.isErr():
|
||||||
# fine if triggerSelf enabled, since validators are bypassed
|
# fine if triggerSelf enabled, since validators are bypassed
|
||||||
|
|
Loading…
Reference in New Issue