feat(prover): add --oracleProofSubmissionDelay flag (#320)

cmd/flags/prover.go

@@ -63,6 +63,12 @@ var (
 		Usage:    "Private key of oracle prover",
 		Category: proverCategory,
 	}
+	OracleProofSubmissionDelay = &cli.Uint64Flag{
+		Name:     "oracleProofSubmissionDelay",
+		Usage:    "Oracle proof submission delay in seconds",
+		Value:    0,
+		Category: proverCategory,
+	}
 	Graffiti = &cli.StringFlag{
 		Name:     "graffiti",
 		Usage:    "When string is passed, adds additional graffiti info to proof evidence",

prover/config.go

@@ -30,6 +30,7 @@ type Config struct {
 	Dummy                           bool
 	OracleProver                    bool
 	OracleProverPrivateKey          *ecdsa.PrivateKey
+	OracleProofSubmissionDelay      time.Duration
 	Graffiti                        string
 	RandomDummyProofDelayLowerBound *time.Duration
 	RandomDummyProofDelayUpperBound *time.Duration
@@ -114,6 +115,7 @@ func NewConfigFromCliContext(c *cli.Context) (*Config, error) {
 		Dummy:                           c.Bool(flags.Dummy.Name),
 		OracleProver:                    c.Bool(flags.OracleProver.Name),
 		OracleProverPrivateKey:          oracleProverPrivKey,
+		OracleProofSubmissionDelay:      time.Duration(c.Uint64(flags.OracleProofSubmissionDelay.Name)) * time.Second,
 		Graffiti:                        c.String(flags.Graffiti.Name),
 		RandomDummyProofDelayLowerBound: randomDummyProofDelayLowerBound,
 		RandomDummyProofDelayUpperBound: randomDummyProofDelayUpperBound,

prover/proof_producer/special_proof_producer.go

@@ -6,6 +6,7 @@ import (
 	"errors"
 	"fmt"
 	"math/big"
+	"time"
 
 	"github.com/ethereum/go-ethereum/common"
 	"github.com/ethereum/go-ethereum/core/types"
@@ -28,6 +29,7 @@ type SpecialProofProducer struct {
 	proverPrivKey     *ecdsa.PrivateKey
 	anchorTxValidator *anchorTxValidator.AnchorTxValidator
 	graffiti          [32]byte
+	delay             time.Duration
 }
 
 // NewSpecialProofProducer creates a new NewSpecialProofProducer instance, which can be either
@@ -38,6 +40,7 @@ func NewSpecialProofProducer(
 	taikoL2Address common.Address,
 	protocolSpecialProverAddress common.Address,
 	graffiti string,
+	delay time.Duration,
 ) (*SpecialProofProducer, error) {
 	proverAddress := crypto.PubkeyToAddress(proverPrivKey.PublicKey)
 	if proverAddress != protocolSpecialProverAddress {
@@ -54,6 +57,7 @@ func NewSpecialProofProducer(
 		proverPrivKey,
 		anchorValidator,
 		rpc.StringToBytes32(graffiti),
+		delay,
 	}, nil
 }
 
@@ -123,13 +127,15 @@ func (p *SpecialProofProducer) RequestProof(
 		return fmt.Errorf("failed to sign evidence: %w", err)
 	}
 
-	resultCh <- &ProofWithHeader{
-		BlockID: blockID,
-		Header:  header,
-		Meta:    meta,
-		ZkProof: proof,
-		Opts:    opts,
-	}
+	time.AfterFunc(p.delay, func() {
+		resultCh <- &ProofWithHeader{
+			BlockID: blockID,
+			Header:  header,
+			Meta:    meta,
+			ZkProof: proof,
+			Opts:    opts,
+		}
+	})
 
 	return nil
 }

prover/prover.go

@@ -177,6 +177,7 @@ func InitFromConfig(ctx context.Context, p *Prover, cfg *Config) (err error) {
 			p.cfg.TaikoL2Address,
 			specialProverAddress,
 			p.cfg.Graffiti,
+			p.cfg.OracleProofSubmissionDelay,
 		); err != nil {
 			return err
 		}