feat(prover): tracking for most recent block ID to ensure (relatively…

…) consecutive proving by notification system (#174)
taikoxyz · Mar 7, 2023 · e500039 · e500039
1 parent 4fab06a
commit e500039
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 0 deletions.
diff --git a/metrics/metrics.go b/metrics/metrics.go
@@ -29,6 +29,7 @@ var (
 
 	// Prover
 	ProverLatestVerifiedIDGauge       = metrics.NewRegisteredGauge("prover/latestVerified/id", nil)
+	ProverLatestProvenBlockIDGauge    = metrics.NewRegisteredGauge("prover/latestProven/id", nil)
 	ProverQueuedProofCounter          = metrics.NewRegisteredCounter("prover/proof/all/queued", nil)
 	ProverQueuedValidProofCounter     = metrics.NewRegisteredCounter("prover/proof/valid/queued", nil)
 	ProverQueuedInvalidProofCounter   = metrics.NewRegisteredCounter("prover/proof/invalid/queued", nil)

diff --git a/prover/proof_submitter/invalid_proof_submitter.go b/prover/proof_submitter/invalid_proof_submitter.go
@@ -195,6 +195,7 @@ func (s *InvalidProofSubmitter) SubmitProof(
 
 	metrics.ProverSentProofCounter.Inc(1)
 	metrics.ProverSentInvalidProofCounter.Inc(1)
+	metrics.ProverLatestProvenBlockIDGauge.Update(proofWithHeader.BlockID.Int64())
 
 	return nil
 }

diff --git a/prover/proof_submitter/valid_proof_submitter.go b/prover/proof_submitter/valid_proof_submitter.go
@@ -212,6 +212,7 @@ func (s *ValidProofSubmitter) SubmitProof(
 
 	metrics.ProverSentProofCounter.Inc(1)
 	metrics.ProverSentValidProofCounter.Inc(1)
+	metrics.ProverLatestProvenBlockIDGauge.Update(proofWithHeader.BlockID.Int64())
 
 	return nil
 }