mirror of
https://github.com/logos-messaging/logos-messaging-nim.git
synced 2026-05-28 13:19:52 +00:00
deploy: 7c40f452793b6106d5a353218ef1d7b0bb84fddb
This commit is contained in:
parent
e83d2e1237
commit
7a5071fb2a
@ -104,14 +104,14 @@ proc toV1Topic*(contentTopic: ContentTopic): waku_protocol.Topic {.raises: [Defe
|
|||||||
|
|
||||||
# Message conversion
|
# Message conversion
|
||||||
|
|
||||||
func toWakuMessage(env: Envelope): WakuMessage =
|
func toWakuMessage(env: waku_protocol.Envelope): WakuMessage =
|
||||||
# Translate a Waku v1 envelope to a Waku v2 message
|
# Translate a Waku v1 envelope to a Waku v2 message
|
||||||
WakuMessage(payload: env.data,
|
WakuMessage(payload: env.data,
|
||||||
contentTopic: toV2ContentTopic(env.topic),
|
contentTopic: toV2ContentTopic(env.topic),
|
||||||
timestamp: (getNanosecondTime(env.expiry) - getNanosecondTime(env.ttl)),
|
timestamp: (getNanosecondTime(env.expiry) - getNanosecondTime(env.ttl)),
|
||||||
version: 1)
|
version: 1)
|
||||||
|
|
||||||
proc toWakuV2(bridge: WakuBridge, env: Envelope) {.async.} =
|
proc toWakuV2(bridge: WakuBridge, env: waku_protocol.Envelope) {.async.} =
|
||||||
let msg = env.toWakuMessage()
|
let msg = env.toWakuMessage()
|
||||||
|
|
||||||
if bridge.seen.containsOrAdd(msg.encode().buffer.hash()):
|
if bridge.seen.containsOrAdd(msg.encode().buffer.hash()):
|
||||||
@ -224,7 +224,7 @@ proc start*(bridge: WakuBridge) {.async.} =
|
|||||||
|
|
||||||
# Bridging
|
# Bridging
|
||||||
# Handle messages on Waku v1 and bridge to Waku v2
|
# 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
|
trace "Bridging envelope from V1 to V2", envelope=envelope
|
||||||
asyncSpawn bridge.toWakuV2(envelope)
|
asyncSpawn bridge.toWakuV2(envelope)
|
||||||
|
|
||||||
|
|||||||
@ -1,4 +1,4 @@
|
|||||||
{.push raises: [Defect, CatchableError].}
|
{.push raises: [Defect].}
|
||||||
|
|
||||||
import
|
import
|
||||||
std/[options, sequtils, sets],
|
std/[options, sequtils, sets],
|
||||||
|
|||||||
@ -1,4 +1,4 @@
|
|||||||
{.push raises: [Defect, CatchableError].}
|
{.push raises: [Defect].}
|
||||||
|
|
||||||
import
|
import
|
||||||
chronicles,
|
chronicles,
|
||||||
|
|||||||
@ -1,4 +1,4 @@
|
|||||||
{.push raises: [Defect, CatchableError].}
|
{.push raises: [Defect].}
|
||||||
|
|
||||||
import
|
import
|
||||||
std/[tables,sequtils],
|
std/[tables,sequtils],
|
||||||
|
|||||||
@ -1,4 +1,4 @@
|
|||||||
{.push raises: [Defect, CatchableError].}
|
{.push raises: [Defect].}
|
||||||
|
|
||||||
import
|
import
|
||||||
std/[tables,sequtils],
|
std/[tables,sequtils],
|
||||||
|
|||||||
@ -1,4 +1,4 @@
|
|||||||
{.push raises: [Defect, CatchableError].}
|
{.push raises: [Defect].}
|
||||||
|
|
||||||
import
|
import
|
||||||
std/[tables,sequtils],
|
std/[tables,sequtils],
|
||||||
|
|||||||
@ -1,4 +1,4 @@
|
|||||||
{.push raises: [Defect, CatchableError].}
|
{.push raises: [Defect].}
|
||||||
|
|
||||||
import
|
import
|
||||||
std/options,
|
std/options,
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user