feat: scan safe blocks only

RSS3-Network · Jun 19, 2024 · 8da7f52 · 8da7f52
1 parent 21d9f6c
commit 8da7f52
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/internal/service/indexer/l2/indexer.go b/internal/service/indexer/l2/indexer.go
@@ -69,10 +69,17 @@ func (s *server) Run(ctx context.Context) (err error) {
 func (s *server) run(ctx context.Context) (err error) {
 	for {
 		// Refresh the latest block number.
-		if s.blockNumberLatest, err = s.ethereumClient.BlockNumber(ctx); err != nil {
+		var safeBlockHead *types.Header
+		if err = s.ethereumClient.Client().CallContext(
+			ctx, &safeBlockHead,
+			"eth_getBlockByNumber",
+			"safe", false,
+		); err != nil || safeBlockHead == nil {
 			return fmt.Errorf("get latest block number: %w", err)
 		}
 
+		s.blockNumberLatest = safeBlockHead.Number.Uint64()
+
 		zap.L().Info(
 			"refreshed the latest block number",
 			zap.Uint64("block.number.local", s.checkpoint.BlockNumber),