Merge branch 'julien/persist-base' into julien/based-block-time

Author: julienrbrt

docs/guides/migrating-to-ev-abci.md

@@ -41,9 +41,9 @@ import (
 )
 ```
 
-1. Add the migration manager keeper to your app struct
-2. Register the module in your module manager
-3. Configure the migration manager in your app initialization
+2. Add the migration manager keeper to your app struct
+3. Register the module in your module manager
+4. Configure the migration manager in your app initialization
 
 ### Step 2: Replace Staking Module with Wrapper
 

sequencers/based/sequencer.go

@@ -71,10 +71,14 @@ func NewBasedSequencer(
 		}
 	} else {
 		bs.checkpoint = checkpoint
-		bs.logger.Info().
-			Uint64("da_height", checkpoint.DAHeight).
-			Uint64("tx_index", checkpoint.TxIndex).
-			Msg("loaded based sequencer checkpoint from DB")
+		// If we had a non-zero tx index, we're resuming from a crash mid-block
+		// The transactions starting from that index are what we need
+		if checkpoint.TxIndex > 0 {
+			bs.logger.Debug().
+				Uint64("tx_index", checkpoint.TxIndex).
+				Uint64("da_height", checkpoint.DAHeight).
+				Msg("resuming from checkpoint within DA epoch")
+		}
 	}
 
 	return bs, nil
@@ -109,9 +113,8 @@ func (s *BasedSequencer) GetNextBatch(ctx context.Context, req coresequencer.Get
 	batch := s.createBatchFromCheckpoint(req.MaxBytes)
 
 	// Update checkpoint with how many transactions we consumed
-	txCount := uint64(len(batch.Transactions))
-	if txCount > 0 {
-		s.checkpoint.TxIndex += txCount
+	if daHeight > 0 || len(batch.Transactions) > 0 {
+		s.checkpoint.TxIndex += uint64(len(batch.Transactions))
 
 		// If we've consumed all transactions from this DA epoch, move to next
 		if s.checkpoint.TxIndex >= uint64(len(s.currentBatchTxs)) {
@@ -125,7 +128,6 @@ func (s *BasedSequencer) GetNextBatch(ctx context.Context, req coresequencer.Get
 
 		// Persist checkpoint
 		if err := s.checkpointStore.Save(ctx, s.checkpoint); err != nil {
-			s.logger.Error().Err(err).Msg("failed to save checkpoint")
 			return nil, fmt.Errorf("failed to save checkpoint: %w", err)
 		}
 	}
@@ -150,17 +152,16 @@ func (s *BasedSequencer) fetchNextDAEpoch(ctx context.Context, maxBytes uint64)
 	if err != nil {
 		// Check if forced inclusion is not configured
 		if errors.Is(err, block.ErrForceInclusionNotConfigured) {
-			return time.Time{}, currentDAHeight, block.ErrForceInclusionNotConfigured
+			return time.Time{}, 0, block.ErrForceInclusionNotConfigured
 		} else if errors.Is(err, coreda.ErrHeightFromFuture) {
 			// If we get a height from future error, stay at current position
 			// We'll retry the same height on the next call until DA produces that block
 			s.logger.Debug().
 				Uint64("da_height", currentDAHeight).
 				Msg("DA height from future, waiting for DA to produce block")
-			return time.Time{}, currentDAHeight, nil
+			return time.Time{}, 0, nil
 		}
-		s.logger.Error().Err(err).Uint64("da_height", currentDAHeight).Msg("failed to retrieve forced inclusion transactions")
-		return time.Time{}, currentDAHeight, err
+		return time.Time{}, 0, fmt.Errorf("failed to retrieve forced inclusion transactions: %w", err)
 	}
 
 	// Validate and filter transactions
@@ -190,14 +191,6 @@ func (s *BasedSequencer) fetchNextDAEpoch(ctx context.Context, maxBytes uint64)
 	// Cache the transactions for this DA epoch
 	s.currentBatchTxs = validTxs
 
-	// If we had a non-zero tx index, we're resuming from a crash mid-block
-	// The transactions starting from that index are what we need
-	if s.checkpoint.TxIndex > 0 {
-		s.logger.Info().
-			Uint64("tx_index", s.checkpoint.TxIndex).
-			Msg("resuming from checkpoint within DA epoch")
-	}
-
 	return forcedTxsEvent.Timestamp.UTC(), forcedTxsEvent.EndDaHeight, nil
 }