feat(prover): prove block tx gas limit (#357)

cmd/flags/prover.go

@@ -85,6 +85,11 @@ var (
 		Category: proverCategory,
 		Value:    100_000_000,
 	}
+	ProveBlockTxGasLimit = &cli.Uint64Flag{
+		Name:     "prover.proveBlockTxGasLimit",
+		Usage:    "Gas limit will be used for TaikoL1.proveBlock transactions",
+		Category: proverCategory,
+	}
 )
 
 // All prover flags.
@@ -105,4 +110,5 @@ var ProverFlags = MergeFlags(CommonFlags, []cli.Flag{
 	SystemProverPrivateKey,
 	Graffiti,
 	ExpectedReward,
+	ProveBlockTxGasLimit,
 })

prover/config.go

@@ -38,6 +38,7 @@ type Config struct {
 	BackOffMaxRetrys                uint64
 	BackOffRetryInterval            time.Duration
 	RPCTimeout                      *time.Duration
+	ProveBlockGasLimit              *uint64
 }
 
 // NewConfigFromCliContext creates a new config instance from command line flags.
@@ -125,6 +126,12 @@ func NewConfigFromCliContext(c *cli.Context) (*Config, error) {
 		timeout = &duration
 	}
 
+	var proveBlockTxGasLimit *uint64
+	if c.IsSet(flags.ProveBlockTxGasLimit.Name) {
+		gasLimit := c.Uint64(flags.ProveBlockTxGasLimit.Name)
+		proveBlockTxGasLimit = &gasLimit
+	}
+
 	return &Config{
 		L1WsEndpoint:                    c.String(flags.L1WSEndpoint.Name),
 		L1HttpEndpoint:                  c.String(flags.L1HTTPEndpoint.Name),
@@ -149,5 +156,6 @@ func NewConfigFromCliContext(c *cli.Context) (*Config, error) {
 		BackOffMaxRetrys:                c.Uint64(flags.BackOffMaxRetrys.Name),
 		BackOffRetryInterval:            time.Duration(c.Uint64(flags.BackOffRetryInterval.Name)) * time.Second,
 		RPCTimeout:                      timeout,
+		ProveBlockGasLimit:              proveBlockTxGasLimit,
 	}, nil
 }

prover/proof_submitter/valid_proof_submitter.go

@@ -26,21 +26,22 @@ var _ ProofSubmitter = (*ValidProofSubmitter)(nil)
 // ValidProofSubmitter is responsible requesting zk proofs for the given valid L2
 // blocks, and submitting the generated proofs to the TaikoL1 smart contract.
 type ValidProofSubmitter struct {
-	rpc               *rpc.Client
-	proofProducer     proofProducer.ProofProducer
-	resultCh          chan *proofProducer.ProofWithHeader
-	anchorTxValidator *anchorTxValidator.AnchorTxValidator
-	proverPrivKey     *ecdsa.PrivateKey
-	proverAddress     common.Address
-	taikoL2Address    common.Address
-	l1SignalService   common.Address
-	l2SignalService   common.Address
-	mutex             *sync.Mutex
-	isOracleProver    bool
-	isSystemProver    bool
-	graffiti          [32]byte
-	expectedReward    uint64
-	retryInterval     time.Duration
+	rpc                  *rpc.Client
+	proofProducer        proofProducer.ProofProducer
+	resultCh             chan *proofProducer.ProofWithHeader
+	anchorTxValidator    *anchorTxValidator.AnchorTxValidator
+	proverPrivKey        *ecdsa.PrivateKey
+	proverAddress        common.Address
+	taikoL2Address       common.Address
+	l1SignalService      common.Address
+	l2SignalService      common.Address
+	mutex                *sync.Mutex
+	isOracleProver       bool
+	isSystemProver       bool
+	graffiti             [32]byte
+	expectedReward       uint64
+	retryInterval        time.Duration
+	proveBlockTxGasLimit *uint64
 }
 
 // NewValidProofSubmitter creates a new ValidProofSubmitter instance.
@@ -56,6 +57,7 @@ func NewValidProofSubmitter(
 	graffiti string,
 	expectedReward uint64,
 	retryInterval time.Duration,
+	proveBlockTxGasLimit *uint64,
 ) (*ValidProofSubmitter, error) {
 	anchorValidator, err := anchorTxValidator.New(taikoL2Address, rpcClient.L2ChainID, rpcClient)
 	if err != nil {
@@ -78,21 +80,22 @@ func NewValidProofSubmitter(
 	}
 
 	return &ValidProofSubmitter{
-		rpc:               rpcClient,
-		proofProducer:     proofProducer,
-		resultCh:          resultCh,
-		anchorTxValidator: anchorValidator,
-		proverPrivKey:     proverPrivKey,
-		proverAddress:     crypto.PubkeyToAddress(proverPrivKey.PublicKey),
-		l1SignalService:   l1SignalService,
-		l2SignalService:   l2SignalService,
-		taikoL2Address:    taikoL2Address,
-		mutex:             mutex,
-		isOracleProver:    isOracleProver,
-		isSystemProver:    isSystemProver,
-		graffiti:          rpc.StringToBytes32(graffiti),
-		expectedReward:    expectedReward,
-		retryInterval:     retryInterval,
+		rpc:                  rpcClient,
+		proofProducer:        proofProducer,
+		resultCh:             resultCh,
+		anchorTxValidator:    anchorValidator,
+		proverPrivKey:        proverPrivKey,
+		proverAddress:        crypto.PubkeyToAddress(proverPrivKey.PublicKey),
+		l1SignalService:      l1SignalService,
+		l2SignalService:      l2SignalService,
+		taikoL2Address:       taikoL2Address,
+		mutex:                mutex,
+		isOracleProver:       isOracleProver,
+		isSystemProver:       isSystemProver,
+		graffiti:             rpc.StringToBytes32(graffiti),
+		expectedReward:       expectedReward,
+		retryInterval:        retryInterval,
+		proveBlockTxGasLimit: proveBlockTxGasLimit,
 	}, nil
 }
 
@@ -252,6 +255,10 @@ func (s *ValidProofSubmitter) SubmitProof(
 		return err
 	}
 
+	if s.proveBlockTxGasLimit != nil {
+		txOpts.GasLimit = *s.proveBlockTxGasLimit
+	}
+
 	sendTx := func() (*types.Transaction, error) {
 		s.mutex.Lock()
 		defer s.mutex.Unlock()

prover/proof_submitter/valid_proof_submitter_test.go

@@ -50,6 +50,7 @@ func (s *ProofSubmitterTestSuite) SetupTest() {
 		"test",
 		0,
 		12*time.Second,
+		nil,
 	)
 	s.Nil(err)
 

prover/prover.go

@@ -210,6 +210,7 @@ func InitFromConfig(ctx context.Context, p *Prover, cfg *Config) (err error) {
 		p.cfg.Graffiti,
 		p.cfg.ExpectedReward,
 		p.cfg.BackOffRetryInterval,
+		p.cfg.ProveBlockGasLimit,
 	); err != nil {
 		return err
 	}