feat(prover): eldfell proof skip size (#363)

cmd/flags/prover.go

@@ -104,6 +104,11 @@ var (
 		Usage:    "Gas limit will be used for TaikoL1.proveBlock transactions",
 		Category: proverCategory,
 	}
+	ProofSkipSize = &cli.Uint64Flag{
+		Name:     "prover.proofSkipSize",
+		Usage:    "Prove every Nth block",
+		Category: proverCategory,
+	}
 )
 
 // All prover flags.
@@ -127,4 +132,5 @@ var ProverFlags = MergeFlags(CommonFlags, []cli.Flag{
 	CheckProofWindowExpiredInterval,
 	ProveUnassignedBlocks,
 	ProveBlockTxGasLimit,
+	ProofSkipSize,
 })

prover/config.go

@@ -42,6 +42,7 @@ type Config struct {
 	RPCTimeout                      *time.Duration
 	WaitReceiptTimeout              time.Duration
 	ProveBlockGasLimit              *uint64
+	ProofSkipSize                   *uint64
 }
 
 // NewConfigFromCliContext creates a new config instance from command line flags.
@@ -116,6 +117,12 @@ func NewConfigFromCliContext(c *cli.Context) (*Config, error) {
 		proveBlockTxGasLimit = &gasLimit
 	}
 
+	var proofSkipSize *uint64
+	if c.IsSet(flags.ProofSkipSize.Name) {
+		skipSize := c.Uint64(flags.ProofSkipSize.Name)
+		proofSkipSize = &skipSize
+	}
+
 	return &Config{
 		L1WsEndpoint:                    c.String(flags.L1WSEndpoint.Name),
 		L1HttpEndpoint:                  c.String(flags.L1HTTPEndpoint.Name),
@@ -146,5 +153,6 @@ func NewConfigFromCliContext(c *cli.Context) (*Config, error) {
 		RPCTimeout:            timeout,
 		WaitReceiptTimeout:    time.Duration(c.Uint64(flags.WaitReceiptTimeout.Name)) * time.Second,
 		ProveBlockGasLimit:    proveBlockTxGasLimit,
+		ProofSkipSize:         proofSkipSize,
 	}, nil
 }

prover/prover.go

@@ -429,14 +429,26 @@ func (p *Prover) onBlockProposed(
 		)
 	}
 
+	metrics.ProverReceivedProposedBlockGauge.Update(event.BlockId.Int64())
+
+	if p.cfg.ProofSkipSize != nil && (event.BlockId.Uint64()%*p.cfg.ProofSkipSize != 0) {
+		log.Info("Skipping proposed block",
+			"L1Height", event.Raw.BlockNumber,
+			"L1Hash", event.Raw.BlockHash,
+			"SkipSize", *p.cfg.ProofSkipSize,
+			"BlockID", event.BlockId,
+			"Removed", event.Raw.Removed,
+		)
+		return nil
+	}
+
 	log.Info(
 		"Proposed block",
 		"L1Height", event.Raw.BlockNumber,
 		"L1Hash", event.Raw.BlockHash,
 		"BlockID", event.BlockId,
 		"Removed", event.Raw.Removed,
 	)
-	metrics.ProverReceivedProposedBlockGauge.Update(event.BlockId.Int64())
 
 	handleBlockProposedEvent := func() error {
 		defer func() { <-p.proposeConcurrencyGuard }()