fix: don't report groups/endpoints w/o progress

flashbots · Mar 18, 2024 · d8e279b · d8e279b
1 parent 7ff4c0f
commit d8e279b
Show file tree

Hide file tree

Showing 3 changed files with 22 additions and 3 deletions.
diff --git a/server/handlers.go b/server/handlers.go
@@ -64,6 +64,11 @@ func (s *Server) handleHealthcheck(w http.ResponseWriter, r *http.Request) {
 
 func (s *Server) handleEventPrometheusObserve(_ context.Context, o metric.Observer) error {
 	s.state.IterateELGroupsRO(func(gname string, g *state.ELGroup) {
+		// don't report groups that did't progress yet
+		if g.HighestBlock().Sign() == 0 {
+			return
+		}
+
 		attrs := []attribute.KeyValue{
 			{Key: keyTargetName, Value: attribute.StringValue(groupVirtualEndpoint)},
 			{Key: keyTargetGroup, Value: attribute.StringValue(normalisedGroup(gname))},
@@ -78,6 +83,11 @@ func (s *Server) handleEventPrometheusObserve(_ context.Context, o metric.Observ
 		o.ObserveFloat64(s.metrics.timeSinceLastBlock, tsBlockGroup.Seconds(), metric.WithAttributes(attrs...))
 
 		g.IterateEndpointsRO(func(ename string, e *state.ELEndpoint) {
+			// don't report endpoints that did't progress yet
+			if e.HighestBlock().Sign() == 0 {
+				return
+			}
+
 			attrs := []attribute.KeyValue{
 				{Key: keyTargetName, Value: attribute.StringValue(ename)},
 				{Key: keyTargetGroup, Value: attribute.StringValue(normalisedGroup(gname))},

diff --git a/state/el_endpoint.go b/state/el_endpoint.go
@@ -24,6 +24,13 @@ func newELEndpoint(name string) *ELEndpoint {
 	}
 }
 
+func (e *ELEndpoint) HighestBlock() *big.Int {
+	e.mx.RLock()
+	defer e.mx.RUnlock()
+
+	return big.NewInt(0).Set(e.highestBlock)
+}
+
 func (e *ELEndpoint) RegisterBlock(
 	block *big.Int,
 	ts time.Time,

diff --git a/state/el_group.go b/state/el_group.go
@@ -54,9 +54,11 @@ func (g *ELGroup) registerEndpoint(name string) error {
 	return nil
 }
 
-func (g *ELGroup) Name() string {
-	// constant, no need for mutex
-	return g.name
+func (g *ELGroup) HighestBlock() *big.Int {
+	g.mx.RLock()
+	defer g.mx.RUnlock()
+
+	return big.NewInt(0).Set(g.highestBlock)
 }
 
 func (g *ELGroup) Endpoint(name string) *ELEndpoint {