logos-messaging/logos-messaging-nim
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-nim.git synced 2026-05-16 23:39:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

rx_service: ensure fetch msgs query is performed when missing msg

Browse Source
This commit is contained in:
Ivan FB 2026-05-06 17:29:50 +02:00
parent 75864a705e
commit 2c92dd2745
No known key found for this signature in database
GPG Key ID: DF0C67A04C543270
1 changed files with 13 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
waku/node/delivery_service/recv_service/recv_service.nim
View File

@ -113,15 +113,19 @@ proc checkStore*(self: RecvService) {.async.} =
let missedHashes: seq[WakuMessageHash] = let missedHashes: seq[WakuMessageHash] =
msgHashesInStore.filterIt(not rxMsgHashes.contains(it)) msgHashesInStore.filterIt(not rxMsgHashes.contains(it))
## Now retrieve the missing WakuMessages and deliver them if missedHashes.len > 0:
let missingMsgsRet = await self.getMissingMsgsFromStore(missedHashes) info "missed messages detected, checking store for missed messages",
if missingMsgsRet.isOk(): pubsubTopic = pubsubTopic, missedCount = missedHashes.len
for msgTuple in missingMsgsRet.get():
if self.processIncomingMessageOfInterest(msgTuple.pubsubTopic, msgTuple.msg): ## Now retrieve the missing WakuMessages and deliver them
info "recv service store-recovered message", let missingMsgsRet = await self.getMissingMsgsFromStore(missedHashes)
msg_hash = shortLog(msgTuple.hash), pubsubTopic = msgTuple.pubsubTopic if missingMsgsRet.isOk():
else: for msgTuple in missingMsgsRet.get():
error "failed to retrieve missing messages: ", error = $missingMsgsRet.error if self.processIncomingMessageOfInterest(msgTuple.pubsubTopic, msgTuple.msg):
info "recv service store-recovered message",
msg_hash = shortLog(msgTuple.hash), pubsubTopic = msgTuple.pubsubTopic
else:
error "failed to retrieve missing messages: ", error = $missingMsgsRet.error
## update next check times ## update next check times
self.startTimeToCheck = self.endTimeToCheck self.startTimeToCheck = self.endTimeToCheck