Skip to content

Commit

Permalink
fix topic pre processing
Browse files Browse the repository at this point in the history
  • Loading branch information
SionoiS committed Feb 21, 2025
1 parent 56b7bf7 commit e4cc857
Showing 1 changed file with 8 additions and 2 deletions.
10 changes: 8 additions & 2 deletions waku/waku_store_sync/reconciliation.nim
Original file line number Diff line number Diff line change
Expand Up @@ -113,21 +113,27 @@ proc preProcessPayload(
if self.cluster != payload.cluster:
return none(RangesData)

if payload.pubsubTopics.len > 0:
if payload.pubsubTopics.len > 0 and self.pubsubTopics.len > 0:
let pubsubIntersection = self.pubsubTopics * payload.pubsubTopics.toHashSet()

if pubsubIntersection.len < 1:
return none(RangesData)

payload.pubsubTopics = pubsubIntersection.toSeq()
elif self.pubsubTopics.len > 0:
# Always use the smallest topic scope possible
payload.pubsubTopics = self.pubsubTopics.toSeq()

if payload.contentTopics.len > 0:
if payload.contentTopics.len > 0 and self.contentTopics.len > 0:
let contentIntersection = self.contentTopics * payload.contentTopics.toHashSet()

if contentIntersection.len < 1:
return none(RangesData)

payload.contentTopics = contentIntersection.toSeq()
elif self.contentTopics.len > 0:
# Always use the smallest topic scope possible
payload.contentTopics = self.contentTopics.toSeq()

let timeRange = calculateTimeRange(self.relayJitter, self.syncRange)
let selfLowerBound = timeRange.a
Expand Down

0 comments on commit e4cc857

Please sign in to comment.