From 843597656300a2f4af9e35641a4d1498add1791d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E3=81=8B=E3=81=A8=E3=82=8A?= <SarahADavisA@gmail.com>
Date: Wed, 20 Aug 2025 13:32:50 -0400
Subject: [PATCH] feat(optimism): add supervisor_revalidation_duration_seconds
 metrics (#17897)

---
 crates/optimism/txpool/src/maintain.rs | 15 +++++++++++++--
 1 file changed, 13 insertions(+), 2 deletions(-)

diff --git a/crates/optimism/txpool/src/maintain.rs b/crates/optimism/txpool/src/maintain.rs
index ce5b044b99..c071bf708e 100644
--- a/crates/optimism/txpool/src/maintain.rs
+++ b/crates/optimism/txpool/src/maintain.rs
@@ -14,11 +14,12 @@ use crate::{
 };
 use alloy_consensus::{conditional::BlockConditionalAttributes, BlockHeader};
 use futures_util::{future::BoxFuture, FutureExt, Stream, StreamExt};
-use metrics::Gauge;
+use metrics::{Gauge, Histogram};
 use reth_chain_state::CanonStateNotification;
 use reth_metrics::{metrics::Counter, Metrics};
 use reth_primitives_traits::NodePrimitives;
 use reth_transaction_pool::{error::PoolTransactionError, PoolTransaction, TransactionPool};
+use std::time::Instant;
 use tracing::warn;
 
 /// Transaction pool maintenance metrics
@@ -50,7 +51,8 @@ struct MaintainPoolInteropMetrics {
     /// Counter for interop transactions that became stale and need revalidation
     stale_interop_transactions: Counter,
     // TODO: we also should add metric for (hash, counter) to check number of validation per tx
-    // TODO: we should add some timing metric in here to check supervisor congestion
+    /// Histogram for measuring supervisor revalidation duration (congestion metric)
+    supervisor_revalidation_duration_seconds: Histogram,
 }
 
 impl MaintainPoolInteropMetrics {
@@ -67,6 +69,12 @@ impl MaintainPoolInteropMetrics {
     fn inc_stale_tx_interop(&self, count: usize) {
         self.stale_interop_transactions.increment(count as u64);
     }
+
+    /// Record supervisor revalidation duration
+    #[inline]
+    fn record_supervisor_duration(&self, duration: std::time::Duration) {
+        self.supervisor_revalidation_duration_seconds.record(duration.as_secs_f64());
+    }
 }
 /// Returns a spawnable future for maintaining the state of the conditional txs in the transaction
 /// pool.
@@ -179,6 +187,7 @@ pub async fn maintain_transaction_pool_interop<N, Pool, St>(
             if !to_revalidate.is_empty() {
                 metrics.inc_stale_tx_interop(to_revalidate.len());
 
+                let revalidation_start = Instant::now();
                 let revalidation_stream = supervisor_client.revalidate_interop_txs_stream(
                     to_revalidate,
                     timestamp,
@@ -211,6 +220,8 @@ pub async fn maintain_transaction_pool_interop<N, Pool, St>(
                         }
                     }
                 }
+
+                metrics.record_supervisor_duration(revalidation_start.elapsed());
             }
 
             if !to_remove.is_empty() {