logos-messaging/logos-delivery
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-delivery.git synced 2026-08-11 06:13:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

deploy: 39e1c4e6c209d1be4b59e366f6a3fa9c7366eb9f

Browse Source
This commit is contained in:
jm-clius 2022-03-18 11:44:21 +00:00
parent ec93e29d7e
commit 3426000a3a
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
examples/v2/chat2.nim
View File

@ -23,7 +23,7 @@ import libp2p/[switch, # manage transports, a single entry poi
muxers/muxer] # define an interface for stream multiplexing, allowing peers to offer many protocols over a single connection
import ../../waku/v2/node/[wakunode2, waku_payload],
../../waku/v2/node/./dnsdisc/waku_dnsdisc,
../../waku/v2/utils/peers,
../../waku/v2/utils/[peers,time],
../../waku/common/utils/nat,
./config_chat2
@ -216,7 +216,7 @@ proc publish(c: Chat, line: string) =
encodedPayload = payload.encode(version, c.node.rng[])
if encodedPayload.isOk():
var message = WakuMessage(payload: encodedPayload.get(),
contentTopic: c.contentTopic, version: version)
contentTopic: c.contentTopic, version: version, timestamp: getNanosecondTime(time))
when defined(rln):
if not isNil(c.node.wakuRlnRelay):
# for future version when we support more than one rln protected content topic,
@ -238,7 +238,7 @@ proc publish(c: Chat, line: string) =
else:
# No payload encoding/encryption from Waku
var message = WakuMessage(payload: chat2pb.buffer,
contentTopic: c.contentTopic, version: 0)
contentTopic: c.contentTopic, version: 0, timestamp: getNanosecondTime(time))
when defined(rln):
if not isNil(c.node.wakuRlnRelay):
# for future version when we support more than one rln protected content topic,
@ -488,7 +488,8 @@ proc processInput(rfd: AsyncFD, rng: ref BrHmacDrbgContext) {.async.} =
let decoded = WakuMessage.init(data)
if decoded.isOk():
chat.printReceivedMessage(decoded.get())
if decoded.get().contentTopic == chat.contentTopic:
chat.printReceivedMessage(decoded.get())
else:
trace "Invalid encoded WakuMessage", error = decoded.error