fix(relayer): Save block progress when caught up and subscribing to n…

…ew events (#13177)

packages/relayer/indexer/subscribe.go

@@ -8,6 +8,7 @@ import (
 	"github.com/ethereum/go-ethereum/event"
 	"github.com/pkg/errors"
 	log "github.com/sirupsen/logrus"
+	"github.com/taikoxyz/taiko-mono/packages/relayer"
 	"github.com/taikoxyz/taiko-mono/packages/relayer/contracts/bridge"
 )
 
@@ -39,6 +40,23 @@ func (svc *Service) subscribe(ctx context.Context, chainID *big.Int) error {
 				if err != nil {
 					log.Errorf("svc.subscribe, svc.handleEvent: %v", err)
 				}
+
+				block, err := svc.blockRepo.GetLatestBlockProcessedForEvent(relayer.EventNameMessageSent, chainID)
+				if err != nil {
+					log.Errorf("svc.subscribe, blockRepo.GetLatestBlockProcessedForEvent: %v", err)
+				}
+
+				if block.Height < event.Raw.BlockNumber {
+					err = svc.blockRepo.Save(relayer.SaveBlockOpts{
+						Height:    event.Raw.BlockNumber,
+						Hash:      event.Raw.BlockHash,
+						ChainID:   chainID,
+						EventName: relayer.EventNameMessageSent,
+					})
+					if err != nil {
+						log.Errorf("svc.subscribe, svc.blockRepo.Save: %v", err)
+					}
+				}
 			}()
 		}
 	}

packages/relayer/indexer/subscribe_test.go

@@ -2,7 +2,6 @@ package indexer
 
 import (
 	"context"
-	"math/big"
 	"testing"
 	"time"
 
@@ -14,7 +13,7 @@ func Test_subscribe(t *testing.T) {
 	svc, bridge := newTestService()
 
 	go func() {
-		_ = svc.subscribe(context.Background(), big.NewInt(1))
+		_ = svc.subscribe(context.Background(), mock.MockChainID)
 	}()
 
 	<-time.After(6 * time.Second)