From 7b5ed94d12b0982de46e5ed66b38cffcf9c0c0d4 Mon Sep 17 00:00:00 2001
From: David <david@taiko.xyz>
Date: Mon, 1 May 2023 03:39:25 +0800
Subject: [PATCH] feat(prover): add oracle proof submission delay (#199)
---
.../proof_producer/oracle_proof_producer.go | 19 ++++++++++++-------
prover/prover.go | 1 +
2 files changed, 13 insertions(+), 7 deletions(-)
diff --git a/prover/proof_producer/oracle_proof_producer.go b/prover/proof_producer/oracle_proof_producer.go
index db9abd60c..7a542f44f 100644
--- a/prover/proof_producer/oracle_proof_producer.go
+++ b/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,6 +23,7 @@ type OracleProducer struct {
rpc *rpc.Client
proverPrivKey *ecdsa.PrivateKey
anchorTxValidator *anchorTxValidator.AnchorTxValidator
+ proofTimeTarget time.Duration
}
// NewOracleProducer creates a new NewOracleProducer instance.
@@ -29,13 +31,14 @@ 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
}
diff --git a/prover/prover.go b/prover/prover.go
index e00bf68c7..400962589 100644
--- a/prover/prover.go
+++ b/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
}