Update

packages/relayer/indexer/handle_event.go

@@ -93,6 +93,8 @@ func (i *Indexer) handleEvent(
 		return errors.Wrap(err, "eventTypeAmountAndCanonicalTokenFromEvent(event)")
 	}
 
+	// TODO(xiaodino): Change to batch query
+
 	// check if we have an existing event already. this is mostly likely only true
 	// in the case of us crawling past blocks.
 	existingEvent, err := i.eventRepo.FirstByEventAndMsgHash(
@@ -141,8 +143,7 @@ func (i *Indexer) handleEvent(
 		if i.watchMode == CrawlPastBlocks && eventStatus == existingEvent.Status {
 			// If the status from contract matches the existing event status,
 			// we can return early as this message has been processed as expected.
-			slog.Info("crawler returning early", "eventStatus", eventStatus, "existingEvent.Status", existingEvent.Status)
-
+			// slog.Info("crawler returning early", "eventStatus", eventStatus, "existingEvent.Status", existingEvent.Status)
 			return nil
 		}
 

packages/relayer/indexer/indexer.go

@@ -349,8 +349,6 @@ func (i *Indexer) filter(ctx context.Context) error {
 					relayer.ErrorEvents.Inc()
 					// log error but always return nil to keep other goroutines active
 					slog.Error("error handling event", "err", err.Error())
-				} else {
-					slog.Info("handled event successfully")
 				}
 
 				return nil