refactor

Author: colinlyguo

rollup/internal/controller/relayer/l2_relayer.go

@@ -278,19 +278,6 @@ func (r *Layer2Relayer) initializeGenesis() error {
 }
 
 func (r *Layer2Relayer) commitGenesisBatch(batchHash string, batchHeader []byte, stateRoot common.Hash) error {
-	// Basic sanity checks
-	if batchHash == "" {
-		return fmt.Errorf("batch hash is empty")
-	}
-
-	if len(batchHeader) == 0 {
-		return fmt.Errorf("batch header is empty")
-	}
-
-	if stateRoot == (common.Hash{}) {
-		return fmt.Errorf("state root is zero")
-	}
-
 	var calldata []byte
 	var packErr error
 
@@ -310,7 +297,11 @@ func (r *Layer2Relayer) commitGenesisBatch(batchHash string, batchHeader []byte,
 		log.Info("Rollup importGenesis", "calldata", common.Bytes2Hex(calldata), "stateRoot", stateRoot)
 	}
 
-	// Check generated calldata is not empty
+	// Sanity checks before sending the transaction
+	if stateRoot == (common.Hash{}) {
+		return fmt.Errorf("state root is zero")
+	}
+
 	if len(calldata) == 0 {
 		return fmt.Errorf("generated calldata is empty")
 	}
@@ -492,12 +483,6 @@ func (r *Layer2Relayer) ProcessPendingBatches() {
 		log.Info("Forcing submission of batches due to timeout", "batch index", batchesToSubmit[0].Batch.Index, "first block created at", oldestBlockTimestamp)
 	}
 
-	// Sanity checks before constructing the transaction
-	if err := r.sanityChecksBeforeConstructingTransaction(batchesToSubmit); err != nil {
-		log.Error("Sanity checks failed before constructing transaction", "batches count", len(batchesToSubmit), "first batch index", batchesToSubmit[0].Batch.Index, "last batch index", batchesToSubmit[len(batchesToSubmit)-1].Batch.Index, "err", err)
-		return
-	}
-
 	// We have at least 1 batch to commit
 	firstBatch := batchesToSubmit[0].Batch
 	lastBatch := batchesToSubmit[len(batchesToSubmit)-1].Batch
@@ -527,9 +512,9 @@ func (r *Layer2Relayer) ProcessPendingBatches() {
 				return
 			}
 
-			err = r.sanityChecksCommitBatchCodecV7CalldataAndBlobs(calldata, blobs, batchesToSubmit, firstBatch, lastBatch)
+			err = r.sanityChecksCommitBatchCodecV7CalldataAndBlobs(calldata, blobs)
 			if err != nil {
-				log.Error("Sanity check failed for calldata and blobs", "err", err)
+				log.Error("Sanity check failed for calldata and blobs", "codecVersion", codecVersion, "start index", firstBatch.Index, "end index", lastBatch.Index, "err", err)
 				return
 			}
 		}
@@ -972,25 +957,6 @@ func (r *Layer2Relayer) handleL2RollupRelayerConfirmLoop(ctx context.Context) {
 }
 
 func (r *Layer2Relayer) constructCommitBatchPayloadCodecV7(batchesToSubmit []*dbBatchWithChunks, firstBatch, lastBatch *orm.Batch) ([]byte, []*kzg4844.Blob, uint64, uint64, error) {
-	// Basic sanity checks
-	if len(batchesToSubmit) == 0 {
-		return nil, nil, 0, 0, fmt.Errorf("no batches to submit")
-	}
-	if firstBatch == nil {
-		return nil, nil, 0, 0, fmt.Errorf("first batch is nil")
-	}
-	if lastBatch == nil {
-		return nil, nil, 0, 0, fmt.Errorf("last batch is nil")
-	}
-
-	// Check firstBatch and lastBatch match batchesToSubmit
-	if firstBatch.Index != batchesToSubmit[0].Batch.Index {
-		return nil, nil, 0, 0, fmt.Errorf("first batch index mismatch: expected %d, got %d", batchesToSubmit[0].Batch.Index, firstBatch.Index)
-	}
-	if lastBatch.Index != batchesToSubmit[len(batchesToSubmit)-1].Batch.Index {
-		return nil, nil, 0, 0, fmt.Errorf("last batch index mismatch: expected %d, got %d", batchesToSubmit[len(batchesToSubmit)-1].Batch.Index, lastBatch.Index)
-	}
-
 	var maxBlockHeight uint64
 	var totalGasUsed uint64
 	blobs := make([]*kzg4844.Blob, 0, len(batchesToSubmit))
@@ -1070,23 +1036,10 @@ func (r *Layer2Relayer) constructCommitBatchPayloadCodecV7(batchesToSubmit []*db
 		return nil, nil, 0, 0, fmt.Errorf("failed to pack commitBatches: %w", err)
 	}
 
-	if len(calldata) == 0 {
-		return nil, nil, 0, 0, fmt.Errorf("generated calldata is empty")
-	}
-
 	return calldata, blobs, maxBlockHeight, totalGasUsed, nil
 }
 
 func (r *Layer2Relayer) constructCommitBatchPayloadValidium(batch *dbBatchWithChunks) ([]byte, uint64, uint64, error) {
-	// Basic sanity checks
-	if batch == nil || batch.Batch == nil {
-		return nil, 0, 0, fmt.Errorf("batch is nil")
-	}
-
-	if len(batch.Chunks) == 0 {
-		return nil, 0, 0, fmt.Errorf("batch %d has no chunks", batch.Batch.Index)
-	}
-
 	// Check state root is not zero
 	stateRoot := common.HexToHash(batch.Batch.StateRoot)
 	if stateRoot == (common.Hash{}) {
@@ -1137,25 +1090,6 @@ func (r *Layer2Relayer) constructCommitBatchPayloadValidium(batch *dbBatchWithCh
 }
 
 func (r *Layer2Relayer) constructFinalizeBundlePayloadCodecV7(dbBatch *orm.Batch, endChunk *orm.Chunk, aggProof *message.OpenVMBundleProof) ([]byte, error) {
-	// Basic sanity checks
-	if dbBatch == nil {
-		return nil, fmt.Errorf("batch is nil")
-	}
-	if endChunk == nil {
-		return nil, fmt.Errorf("end chunk is nil")
-	}
-
-	// Check batch header
-	if len(dbBatch.BatchHeader) == 0 {
-		return nil, fmt.Errorf("batch %d header is empty", dbBatch.Index)
-	}
-
-	// Check state root is not zero
-	stateRoot := common.HexToHash(dbBatch.StateRoot)
-	if stateRoot == (common.Hash{}) {
-		return nil, fmt.Errorf("batch %d state root is zero", dbBatch.Index)
-	}
-
 	// Check proof if present
 	if aggProof != nil && len(aggProof.Proof()) == 0 {
 		return nil, fmt.Errorf("aggregate proof is empty")
@@ -1174,10 +1108,6 @@ func (r *Layer2Relayer) constructFinalizeBundlePayloadCodecV7(dbBatch *orm.Batch
 			return nil, fmt.Errorf("failed to pack finalizeBundlePostEuclidV2 with proof: %w", packErr)
 		}
 
-		if len(calldata) == 0 {
-			return nil, fmt.Errorf("generated calldata with proof is empty")
-		}
-
 		return calldata, nil
 	}
 
@@ -1195,27 +1125,10 @@ func (r *Layer2Relayer) constructFinalizeBundlePayloadCodecV7(dbBatch *orm.Batch
 		return nil, fmt.Errorf("failed to pack finalizeBundlePostEuclidV2NoProof: %w", packErr)
 	}
 
-	if len(calldata) == 0 {
-		return nil, fmt.Errorf("generated calldata without proof is empty")
-	}
-
 	return calldata, nil
 }
 
 func (r *Layer2Relayer) constructFinalizeBundlePayloadValidium(dbBatch *orm.Batch, endChunk *orm.Chunk, aggProof *message.OpenVMBundleProof) ([]byte, error) {
-	// Basic sanity checks
-	if dbBatch == nil {
-		return nil, fmt.Errorf("batch is nil")
-	}
-	if endChunk == nil {
-		return nil, fmt.Errorf("end chunk is nil")
-	}
-
-	// Check batch header is not empty
-	if len(dbBatch.BatchHeader) == 0 {
-		return nil, fmt.Errorf("batch %d header is empty", dbBatch.Index)
-	}
-
 	// Check proof if present
 	if aggProof != nil && len(aggProof.Proof()) == 0 {
 		return nil, fmt.Errorf("aggregate proof is empty")
@@ -1238,10 +1151,6 @@ func (r *Layer2Relayer) constructFinalizeBundlePayloadValidium(dbBatch *orm.Batc
 		return nil, fmt.Errorf("failed to pack validium finalizeBundle: %w", packErr)
 	}
 
-	if len(calldata) == 0 {
-		return nil, fmt.Errorf("generated calldata is empty for batch %d", dbBatch.Index)
-	}
-
 	return calldata, nil
 }