mirror of
https://github.com/logos-messaging/logos-messaging-nim.git
synced 2026-01-02 14:03:06 +00:00
chore: update submodules (#905)
This commit is contained in:
parent
5da1213e0d
commit
7c40f45279
2
vendor/nim-bearssl
vendored
2
vendor/nim-bearssl
vendored
@ -1 +1 @@
|
||||
Subproject commit ba80e2a0d7ae8aab666cee013e38ff8d33a3e5e7
|
||||
Subproject commit 65b74302e03912ab5bde64b6da10d05896139007
|
||||
2
vendor/nim-faststreams
vendored
2
vendor/nim-faststreams
vendored
@ -1 +1 @@
|
||||
Subproject commit 37a183153c071539ab870f427c09a1376ba311b9
|
||||
Subproject commit 1a85b3d50bf9a6dbbd58df045633dae0907c51c2
|
||||
2
vendor/nim-json-rpc
vendored
2
vendor/nim-json-rpc
vendored
@ -1 +1 @@
|
||||
Subproject commit ad0c3fb6e07bef6a2037637a29ee841d29f9557e
|
||||
Subproject commit b4bab89abdde3653939abe36ab9f6cae4aa1cbd1
|
||||
2
vendor/nim-json-serialization
vendored
2
vendor/nim-json-serialization
vendored
@ -1 +1 @@
|
||||
Subproject commit a12beabd2fa721407bc99492a0075ce43ad9994d
|
||||
Subproject commit 461fd03edb300b7946544b34442d1a05d4ef2270
|
||||
2
vendor/nim-libp2p
vendored
2
vendor/nim-libp2p
vendored
@ -1 +1 @@
|
||||
Subproject commit 44a7260f0754341a6ae9864d4ece5a177cb8fc2b
|
||||
Subproject commit eaa72dcdbe26d8236c64711e32cf0c2f8ac65e64
|
||||
2
vendor/nim-serialization
vendored
2
vendor/nim-serialization
vendored
@ -1 +1 @@
|
||||
Subproject commit 37bc0db558d85711967acb16e9bb822b06911d46
|
||||
Subproject commit 9631fbd1c81c8b25ff8740df440ca7ba87fa6131
|
||||
2
vendor/nim-stew
vendored
2
vendor/nim-stew
vendored
@ -1 +1 @@
|
||||
Subproject commit bb705bf17b46d2c8f9bfb106d9cc7437009a2501
|
||||
Subproject commit 419903c9a31ab253cf5cf19f24d9a912dc4b5154
|
||||
2
vendor/nim-web3
vendored
2
vendor/nim-web3
vendored
@ -1 +1 @@
|
||||
Subproject commit 91c998a0d488cef011e84d8a1ef3d4f83d963111
|
||||
Subproject commit c3b386b1e88c0d60bc4ff9da215f969b23ee2f39
|
||||
2
vendor/nim-websock
vendored
2
vendor/nim-websock
vendored
@ -1 +1 @@
|
||||
Subproject commit 73edde4417f7b45003113b7a34212c3ccd95b9fd
|
||||
Subproject commit 4a7a058843cdb7a6a4fd25a55f0959c51b0b5847
|
||||
2
vendor/nimbus-build-system
vendored
2
vendor/nimbus-build-system
vendored
@ -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…
x
Reference in New Issue
Block a user