logos-messaging/logos-delivery
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-delivery.git synced 2026-05-06 23:09:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: relay validator registration and sync filter (#3823)

Browse Source 
* reuse stored validator in relay
* fix skip check in store sync
* increase sync tolerance in test (matches similar test)
This commit is contained in:
Fabiana Cecin 2026-04-23 16:02:34 -03:00 committed by GitHub
parent 820ccc6e10
commit ff98d85313
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/waku_store_sync/test_protocol.nim
View File

@ -372,7 +372,7 @@ suite "Waku Sync: reconciliation":
const
msgCount = 400_000
diffCount = 100_000
tol = 1000
tol = 10_000
var diffMsgHashes: HashSet[WakuMessageHash]
var missingIdx: HashSet[int]

2
waku/waku_relay/protocol.nim
View File

@ -618,7 +618,7 @@ proc subscribe*(w: WakuRelay, pubsubTopic: PubsubTopic, handler: WakuRelayHandle
# Otherwise this might lead to unintended behaviour.
if not w.topicValidator.hasKey(pubSubTopic):
let newValidator = w.generateOrderedValidator()
procCall GossipSub(w).addValidator(pubSubTopic, w.generateOrderedValidator())
procCall GossipSub(w).addValidator(pubSubTopic, newValidator)
w.topicValidator[pubSubTopic] = newValidator
# set this topic parameters for scoring

2
waku/waku_store_sync/reconciliation.nim
View File

@ -145,7 +145,7 @@ proc preProcessPayload(
# convert to skip range before processing
for i in 0 ..< payload.ranges.len:
let rangeType = payload.ranges[i][1]
if rangeType != RangeType.Skip:
if rangeType == RangeType.Skip:
continue
let upperBound = payload.ranges[i][0].b.time