fix

Author: colinlyguo

common/types/message/message.go

@@ -10,8 +10,8 @@ import (
 )
 
 const (
-	euclidFork   = "euclid"
-	euclidV2Fork = "euclidV2"
+	EuclidFork   = "euclid"
+	EuclidV2Fork = "euclidV2"
 )
 
 // ProofType represents the type of task.
@@ -95,9 +95,9 @@ type ChunkProof interface {
 
 // NewChunkProof creates a new ChunkProof instance.
 func NewChunkProof(hardForkName string) ChunkProof {
-	log.Info("NewChunkProof", "hardForkName", hardForkName, "euclidForkName", euclidFork, "euclidV2ForkName", euclidV2Fork)
+	log.Info("NewChunkProof", "hardForkName", hardForkName, "euclidForkName", EuclidFork, "euclidV2ForkName", EuclidV2Fork)
 	switch hardForkName {
-	case euclidFork, euclidV2Fork:
+	case EuclidFork, EuclidV2Fork:
 		return &OpenVMChunkProof{}
 	default:
 		return &Halo2ChunkProof{}
@@ -130,9 +130,9 @@ type BatchProof interface {
 
 // NewBatchProof creates a new BatchProof instance.
 func NewBatchProof(hardForkName string) BatchProof {
-	log.Info("NewBatchProof", "hardForkName", hardForkName, "euclidForkName", euclidFork, "euclidV2ForkName", euclidV2Fork)
+	log.Info("NewBatchProof", "hardForkName", hardForkName, "euclidForkName", EuclidFork, "euclidV2ForkName", EuclidV2Fork)
 	switch hardForkName {
-	case euclidFork, euclidV2Fork:
+	case EuclidFork, EuclidV2Fork:
 		return &OpenVMBatchProof{}
 	default:
 		return &Halo2BatchProof{}
@@ -188,9 +188,9 @@ type BundleProof interface {
 
 // NewBundleProof creates a new BundleProof instance.
 func NewBundleProof(hardForkName string) BundleProof {
-	log.Info("NewBundleProof", "hardForkName", hardForkName, "euclidForkName", euclidFork, "euclidV2ForkName", euclidV2Fork)
+	log.Info("NewBundleProof", "hardForkName", hardForkName, "euclidForkName", EuclidFork, "euclidV2ForkName", EuclidV2Fork)
 	switch hardForkName {
-	case euclidFork, euclidV2Fork:
+	case EuclidFork, EuclidV2Fork:
 		return &OpenVMBundleProof{}
 	default:
 		return &Halo2BundleProof{}

coordinator/internal/logic/provertask/chunk_prover_task.go

@@ -9,7 +9,6 @@ import (
 	"github.com/gin-gonic/gin"
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/prometheus/client_golang/prometheus/promauto"
-	"github.com/scroll-tech/da-codec/encoding"
 	"github.com/scroll-tech/go-ethereum/common"
 	"github.com/scroll-tech/go-ethereum/log"
 	"github.com/scroll-tech/go-ethereum/params"
@@ -181,15 +180,6 @@ func (cp *ChunkProverTask) Assign(ctx *gin.Context, getTaskParameter *coordinato
 	return taskMsg, nil
 }
 
-func (cp *ChunkProverTask) hardForkName(ctx *gin.Context, chunkTask *orm.Chunk) (string, error) {
-	l2Block, getBlockErr := cp.blockOrm.GetL2BlockByNumber(ctx.Copy(), chunkTask.StartBlockNumber)
-	if getBlockErr != nil {
-		return "", getBlockErr
-	}
-	hardForkName := encoding.GetHardforkName(cp.chainCfg, l2Block.Number, l2Block.BlockTimestamp)
-	return hardForkName, nil
-}
-
 func (cp *ChunkProverTask) formatProverTask(ctx context.Context, task *orm.ProverTask, chunk *orm.Chunk, hardForkName string) (*coordinatorType.GetTaskSchema, error) {
 	// Get block hashes.
 	blockHashes, dbErr := cp.blockOrm.GetL2BlockHashesByChunkHash(ctx, task.TaskID)
@@ -198,7 +188,7 @@ func (cp *ChunkProverTask) formatProverTask(ctx context.Context, task *orm.Prove
 	}
 
 	var taskDetailBytes []byte
-	if hardForkName == "euclidV2" {
+	if hardForkName == message.EuclidV2Fork {
 		taskDetail := message.EuclidV2ChunkTaskDetail{
 			BlockHashes:      blockHashes,
 			PrevMsgQueueHash: common.HexToHash(chunk.PrevL1MessageQueueHash),