mirror of https://github.com/waku-org/nwaku.git
chore: update submodules (#905)
This commit is contained in:
parent
bfd427baf0
commit
06f20af7d4
|
@ -1 +1 @@
|
|||
Subproject commit ba80e2a0d7ae8aab666cee013e38ff8d33a3e5e7
|
||||
Subproject commit 65b74302e03912ab5bde64b6da10d05896139007
|
|
@ -1 +1 @@
|
|||
Subproject commit 37a183153c071539ab870f427c09a1376ba311b9
|
||||
Subproject commit 1a85b3d50bf9a6dbbd58df045633dae0907c51c2
|
|
@ -1 +1 @@
|
|||
Subproject commit ad0c3fb6e07bef6a2037637a29ee841d29f9557e
|
||||
Subproject commit b4bab89abdde3653939abe36ab9f6cae4aa1cbd1
|
|
@ -1 +1 @@
|
|||
Subproject commit a12beabd2fa721407bc99492a0075ce43ad9994d
|
||||
Subproject commit 461fd03edb300b7946544b34442d1a05d4ef2270
|
|
@ -1 +1 @@
|
|||
Subproject commit 44a7260f0754341a6ae9864d4ece5a177cb8fc2b
|
||||
Subproject commit eaa72dcdbe26d8236c64711e32cf0c2f8ac65e64
|
|
@ -1 +1 @@
|
|||
Subproject commit 37bc0db558d85711967acb16e9bb822b06911d46
|
||||
Subproject commit 9631fbd1c81c8b25ff8740df440ca7ba87fa6131
|
|
@ -1 +1 @@
|
|||
Subproject commit bb705bf17b46d2c8f9bfb106d9cc7437009a2501
|
||||
Subproject commit 419903c9a31ab253cf5cf19f24d9a912dc4b5154
|
|
@ -1 +1 @@
|
|||
Subproject commit 91c998a0d488cef011e84d8a1ef3d4f83d963111
|
||||
Subproject commit c3b386b1e88c0d60bc4ff9da215f969b23ee2f39
|
|
@ -1 +1 @@
|
|||
Subproject commit 73edde4417f7b45003113b7a34212c3ccd95b9fd
|
||||
Subproject commit 4a7a058843cdb7a6a4fd25a55f0959c51b0b5847
|
|
@ -1 +1 @@
|
|||
Subproject commit 8425ff9e3b6adb83e226d408a5d06d31ac2a7789
|
||||
Subproject commit 041544c2b7681040d160f7bd95c0ecc010c06968
|
|
@ -104,14 +104,14 @@ proc toV1Topic*(contentTopic: ContentTopic): waku_protocol.Topic {.raises: [Defe
|
|||
|
||||
# Message conversion
|
||||
|
||||
func toWakuMessage(env: Envelope): WakuMessage =
|
||||
func toWakuMessage(env: waku_protocol.Envelope): WakuMessage =
|
||||
# Translate a Waku v1 envelope to a Waku v2 message
|
||||
WakuMessage(payload: env.data,
|
||||
contentTopic: toV2ContentTopic(env.topic),
|
||||
timestamp: (getNanosecondTime(env.expiry) - getNanosecondTime(env.ttl)),
|
||||
version: 1)
|
||||
|
||||
proc toWakuV2(bridge: WakuBridge, env: Envelope) {.async.} =
|
||||
proc toWakuV2(bridge: WakuBridge, env: waku_protocol.Envelope) {.async.} =
|
||||
let msg = env.toWakuMessage()
|
||||
|
||||
if bridge.seen.containsOrAdd(msg.encode().buffer.hash()):
|
||||
|
@ -224,7 +224,7 @@ proc start*(bridge: WakuBridge) {.async.} =
|
|||
|
||||
# Bridging
|
||||
# Handle messages on Waku v1 and bridge to Waku v2
|
||||
proc handleEnvReceived(envelope: Envelope) {.gcsafe, raises: [Defect].} =
|
||||
proc handleEnvReceived(envelope: waku_protocol.Envelope) {.gcsafe, raises: [Defect].} =
|
||||
trace "Bridging envelope from V1 to V2", envelope=envelope
|
||||
asyncSpawn bridge.toWakuV2(envelope)
|
||||
|
||||
|
|
|
@ -1,4 +1,4 @@
|
|||
{.push raises: [Defect, CatchableError].}
|
||||
{.push raises: [Defect].}
|
||||
|
||||
import
|
||||
std/[options, sequtils, sets],
|
||||
|
|
|
@ -1,4 +1,4 @@
|
|||
{.push raises: [Defect, CatchableError].}
|
||||
{.push raises: [Defect].}
|
||||
|
||||
import
|
||||
chronicles,
|
||||
|
|
|
@ -1,4 +1,4 @@
|
|||
{.push raises: [Defect, CatchableError].}
|
||||
{.push raises: [Defect].}
|
||||
|
||||
import
|
||||
std/[tables,sequtils],
|
||||
|
|
|
@ -1,4 +1,4 @@
|
|||
{.push raises: [Defect, CatchableError].}
|
||||
{.push raises: [Defect].}
|
||||
|
||||
import
|
||||
std/[tables,sequtils],
|
||||
|
|
|
@ -1,4 +1,4 @@
|
|||
{.push raises: [Defect, CatchableError].}
|
||||
{.push raises: [Defect].}
|
||||
|
||||
import
|
||||
std/[tables,sequtils],
|
||||
|
|
|
@ -1,4 +1,4 @@
|
|||
{.push raises: [Defect, CatchableError].}
|
||||
{.push raises: [Defect].}
|
||||
|
||||
import
|
||||
std/options,
|
||||
|
|
Loading…
Reference in New Issue