logos-messaging/logos-messaging-nim
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-nim.git synced 2026-01-04 06:53:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: filter out ephemeral msg from waku sync (#3332)

Browse Source
This commit is contained in:
Simon-Pierre Vivier 2025-03-20 15:30:29 -04:00 committed by GitHub
parent 7dbc1fe061
commit cda48e25f7
3 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
waku/waku_archive/archive.nim
View File

@ -132,6 +132,9 @@ proc syncMessageIngress*(
pubsubTopic: PubsubTopic, pubsubTopic: PubsubTopic,
msg: WakuMessage, msg: WakuMessage,
): Future[Result[void, string]] {.async.} = ): Future[Result[void, string]] {.async.} =
if msg.ephemeral:
return err("ephemeral message, will not store")
let msgHashHex = msgHash.to0xHex() let msgHashHex = msgHash.to0xHex()
trace "handling message in syncMessageIngress", trace "handling message in syncMessageIngress",

6
waku/waku_store_sync/reconciliation.nim
View File

@ -68,6 +68,9 @@ type SyncReconciliation* = ref object of LPProtocol
proc messageIngress*( proc messageIngress*(
self: SyncReconciliation, pubsubTopic: PubsubTopic, msg: WakuMessage self: SyncReconciliation, pubsubTopic: PubsubTopic, msg: WakuMessage
) = ) =
if msg.ephemeral:
return
let msgHash = computeMessageHash(pubsubTopic, msg) let msgHash = computeMessageHash(pubsubTopic, msg)
let id = SyncID(time: msg.timestamp, hash: msgHash) let id = SyncID(time: msg.timestamp, hash: msgHash)
@ -78,6 +81,9 @@ proc messageIngress*(
proc messageIngress*( proc messageIngress*(
self: SyncReconciliation, msgHash: WakuMessageHash, msg: WakuMessage self: SyncReconciliation, msgHash: WakuMessageHash, msg: WakuMessage
) = ) =
if msg.ephemeral:
return
let id = SyncID(time: msg.timestamp, hash: msgHash) let id = SyncID(time: msg.timestamp, hash: msgHash)
self.storage.insert(id).isOkOr: self.storage.insert(id).isOkOr:

4
waku/waku_store_sync/transfer.nim
View File

@ -118,6 +118,10 @@ proc needsReceiverLoop(self: SyncTransfer) {.async.} =
error "failed to query archive", error = error error "failed to query archive", error = error
continue continue
if response.messages.len < 1:
error "failed to fetch message from db"
continue
let msg = let msg =
WakuMessageAndTopic(pubsub: response.topics[0], message: response.messages[0]) WakuMessageAndTopic(pubsub: response.topics[0], message: response.messages[0])