fix: update logic to prevent duplicate broadcasts

Bisonai · Aug 14, 2024 · d6fa5ba · d6fa5ba
1 parent fa2b818
commit d6fa5ba
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/node/pkg/dal/collector/collector.go b/node/pkg/dal/collector/collector.go
@@ -196,7 +196,7 @@ func (c *Collector) compareAndSwapLatestTimestamp(data *aggregator.SubmissionDat
 	defer c.mu.Unlock()
 
 	old, ok := c.LatestTimestamps[data.GlobalAggregate.ConfigID]
-	if !ok || !old.After(data.GlobalAggregate.Timestamp) {
+	if !ok || old.Before(data.GlobalAggregate.Timestamp) {
 		c.LatestTimestamps[data.GlobalAggregate.ConfigID] = data.GlobalAggregate.Timestamp
 		return true
 	}