feat(driver): add proof reward metric (#273)

taikoxyz · Jun 8, 2023 · 1e00560 · 1e00560
1 parent ffcfb53
commit 1e00560
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/driver/state/state.go b/driver/state/state.go
@@ -4,6 +4,7 @@ import (
 	"bytes"
 	"context"
 	"fmt"
+	"math"
 	"math/big"
 	"sync/atomic"
 
@@ -173,6 +174,11 @@ func (s *State) startSubscriptions(ctx context.Context) {
 				}
 			case e := <-s.blockVerifiedCh:
 				log.Info("📈 Block verified", "blockID", e.Id, "hash", common.Hash(e.BlockHash), "reward", e.Reward)
+				if e.Reward > math.MaxInt64 {
+					metrics.DriverProofRewardGauge.Update(math.MaxInt64)
+				} else {
+					metrics.DriverProofRewardGauge.Update(int64(e.Reward))
+				}
 			case e := <-s.crossChainSynced:
 				// Verify the protocol synced block, check if it exists in
 				// L2 execution engine.

diff --git a/metrics/metrics.go b/metrics/metrics.go
@@ -21,6 +21,7 @@ var (
 	DriverL1CurrentHeightGauge  = metrics.NewRegisteredGauge("driver/l1Current/height", nil)
 	DriverL2HeadIDGauge         = metrics.NewRegisteredGauge("driver/l2Head/id", nil)
 	DriverL2VerifiedHeightGauge = metrics.NewRegisteredGauge("driver/l2Verified/id", nil)
+	DriverProofRewardGauge      = metrics.NewRegisteredGauge("driver/proofReward", nil)
 
 	// Proposer
 	ProposerProposeEpochCounter    = metrics.NewRegisteredCounter("proposer/epoch", nil)