logos-messaging/logos-delivery
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-delivery.git synced 2026-03-15 13:33:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore(chat2): remove noise, set sender timestamp (#877)

Browse Source
This commit is contained in:
Hanno Cornelius 2022-03-18 13:13:32 +02:00 committed by GitHub
parent 988453f287
commit 39e1c4e6c2
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 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], import ../../waku/v2/node/[wakunode2, waku_payload],
../../waku/v2/node/./dnsdisc/waku_dnsdisc, ../../waku/v2/node/./dnsdisc/waku_dnsdisc,
../../waku/v2/utils/peers, ../../waku/v2/utils/[peers,time],
../../waku/common/utils/nat, ../../waku/common/utils/nat,
./config_chat2 ./config_chat2
@ -216,7 +216,7 @@ proc publish(c: Chat, line: string) =
encodedPayload = payload.encode(version, c.node.rng[]) encodedPayload = payload.encode(version, c.node.rng[])
if encodedPayload.isOk(): if encodedPayload.isOk():
var message = WakuMessage(payload: encodedPayload.get(), var message = WakuMessage(payload: encodedPayload.get(),
contentTopic: c.contentTopic, version: version) contentTopic: c.contentTopic, version: version, timestamp: getNanosecondTime(time))
when defined(rln): when defined(rln):
if not isNil(c.node.wakuRlnRelay): if not isNil(c.node.wakuRlnRelay):
# for future version when we support more than one rln protected content topic, # for future version when we support more than one rln protected content topic,
@ -238,7 +238,7 @@ proc publish(c: Chat, line: string) =
else: else:
# No payload encoding/encryption from Waku # No payload encoding/encryption from Waku
var message = WakuMessage(payload: chat2pb.buffer, var message = WakuMessage(payload: chat2pb.buffer,
contentTopic: c.contentTopic, version: 0) contentTopic: c.contentTopic, version: 0, timestamp: getNanosecondTime(time))
when defined(rln): when defined(rln):
if not isNil(c.node.wakuRlnRelay): if not isNil(c.node.wakuRlnRelay):
# for future version when we support more than one rln protected content topic, # 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) let decoded = WakuMessage.init(data)
if decoded.isOk(): if decoded.isOk():
chat.printReceivedMessage(decoded.get()) if decoded.get().contentTopic == chat.contentTopic:
chat.printReceivedMessage(decoded.get())
else: else:
trace "Invalid encoded WakuMessage", error = decoded.error trace "Invalid encoded WakuMessage", error = decoded.error