feat(prover): add oracle proof submission delay (#199)

prover/proof_producer/oracle_proof_producer.go

@@ -5,6 +5,7 @@ import (
 	"crypto/ecdsa"
 	"fmt"
 	"math/big"
+	"time"
 
 	"github.com/ethereum/go-ethereum/common"
 	"github.com/ethereum/go-ethereum/core/types"
@@ -22,20 +23,22 @@ type OracleProducer struct {
 	rpc               *rpc.Client
 	proverPrivKey     *ecdsa.PrivateKey
 	anchorTxValidator *anchorTxValidator.AnchorTxValidator
+	proofTimeTarget   time.Duration
 }
 
 // NewOracleProducer creates a new NewOracleProducer instance.
 func NewOracleProducer(
 	rpc *rpc.Client,
 	proverPrivKey *ecdsa.PrivateKey,
 	taikoL2Address common.Address,
+	proofTimeTarget time.Duration,
 ) (*OracleProducer, error) {
 	anchorValidator, err := anchorTxValidator.New(taikoL2Address, rpc.L2ChainID, rpc)
 	if err != nil {
 		return nil, err
 	}
 
-	return &OracleProducer{rpc, proverPrivKey, anchorValidator}, nil
+	return &OracleProducer{rpc, proverPrivKey, anchorValidator, proofTimeTarget}, nil
 }
 
 // RequestProof implements the ProofProducer interface.
@@ -100,12 +103,14 @@ func (d *OracleProducer) RequestProof(
 		return fmt.Errorf("failed to sign evidence: %w", err)
 	}
 
-	resultCh <- &ProofWithHeader{
-		BlockID: blockID,
-		Header:  header,
-		Meta:    meta,
-		ZkProof: proof,
-	}
+	time.AfterFunc(d.proofTimeTarget, func() {
+		resultCh <- &ProofWithHeader{
+			BlockID: blockID,
+			Header:  header,
+			Meta:    meta,
+			ZkProof: proof,
+		}
+	})
 
 	return nil
 }

prover/prover.go

@@ -130,6 +130,7 @@ func InitFromConfig(ctx context.Context, p *Prover, cfg *Config) (err error) {
 			p.rpc,
 			p.cfg.L1ProverPrivKey,
 			p.cfg.TaikoL2Address,
+			time.Duration(p.protocolConfigs.ProofTimeTarget)*time.Second,
 		); err != nil {
 			return err
 		}