From 98abd8b55342cdd71bcbc4925a62b59ab7e6e899 Mon Sep 17 00:00:00 2001 From: xiaodino Date: Sat, 16 Mar 2024 16:16:41 -0700 Subject: [PATCH] fix(relayer): restart indexer when the indexer exits due to faield API requests --- packages/relayer/indexer/indexer.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/packages/relayer/indexer/indexer.go b/packages/relayer/indexer/indexer.go index 31483c90002..b79a335b901 100644 --- 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