fix(relayer): restart indexer when the indexer exits due to faield AP…

…I requests
taikoxyz · Mar 16, 2024 · 98abd8b · 98abd8b
1 parent ebe2985
commit 98abd8b
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/packages/relayer/indexer/indexer.go b/packages/relayer/indexer/indexer.go
@@ -218,10 +218,6 @@ func (i *Indexer) Start() error {
 	i.wg.Add(1)
 
 	go func() {
-		defer func() {
-			i.wg.Done()
-		}()
-
 		if err := i.filter(i.ctx); err != nil {
 			slog.Error("error filtering blocks", "error", err.Error())
 		}
@@ -334,6 +330,7 @@ func (i *Indexer) filter(ctx context.Context) error {
 		if !messageSentEvents.Next() || messageSentEvents.Event == nil {
 			// use "end" not "filterEnd" here, because it will be used as the start
 			// of the next batch.
+
 			if err := i.handleNoEventsInBatch(ctx, i.srcChainId, int64(end)); err != nil {
 				return errors.Wrap(err, "i.handleNoEventsInBatch")
 			}
@@ -370,6 +367,7 @@ func (i *Indexer) filter(ctx context.Context) error {
 				// loop
 				if err := i.handleNoEventsInBatch(ctx, i.srcChainId, int64(end)); err != nil {
 					return errors.Wrap(err, "i.handleNoEventsInBatch")
+
 				}
 
 				break