improve logging

smartcontractkit · Feb 11, 2025 · 58a0a64 · 58a0a64
1 parent 0ab32bf
commit 58a0a64
Showing 1 changed file with 10 additions and 4 deletions.
diff --git a/pkg/solana/logpoller/log_poller.go b/pkg/solana/logpoller/log_poller.go
@@ -243,12 +243,18 @@ func (lp *Service) backfillFilters(ctx context.Context, filters []Filter, to int
 		}
 	}
 
-	err := lp.processBlocksRange(ctx, addresses, minSlot, to)
-	if err != nil {
-		return err
+	if minSlot < to {
+		err := lp.processBlocksRange(ctx, addresses, minSlot, to)
+		if err != nil {
+			return err
+		}
+
+		lp.lggr.Infow("Done backfilling filters", "filters", len(filters), "from", minSlot, "to", to)
+	} else {
+		lp.lggr.Infow("Starting block for filters backfill is greater than the latest processed block - marking filters as backfilled and starting global processing", "filters", len(filters), "from", minSlot, "to", to)
 	}
 
-	lp.lggr.Infow("Done backfilling filters", "filters", len(filters), "from", minSlot, "to", to)
+	var err error
 	for _, filter := range filters {
 		filterErr := lp.filters.MarkFilterBackfilled(ctx, filter.ID)
 		if filterErr != nil {