feat: track flashbots submission duration

Author: Evalir

src/metrics.rs

@@ -51,6 +51,10 @@ const FLASHBOTS_EMPTY_BLOCKS_HELP: &str = "Number of empty blocks skipped";
 const FLASHBOTS_SUBMISSIONS: &str = "signet.builder.flashbots.submissions";
 const FLASHBOTS_SUBMISSIONS_HELP: &str = "Number of submission attempts to Flashbots";
 
+const FLASHBOTS_SUBMISSION_DURATION_MS: &str = "signet.builder.flashbots.submission_duration_ms";
+const FLASHBOTS_SUBMISSION_DURATION_MS_HELP: &str =
+    "Duration of Flashbots bundle submission requests in milliseconds";
+
 // -- Block Building --
 const BUILT_BLOCKS: &str = "signet.builder.built_blocks";
 const BUILT_BLOCKS_HELP: &str = "Number of blocks built by the simulator";
@@ -89,6 +93,7 @@ static DESCRIBE: LazyLock<()> = LazyLock::new(|| {
     describe_counter!(FLASHBOTS_BUNDLE_PREP_FAILURES, FLASHBOTS_BUNDLE_PREP_FAILURES_HELP);
     describe_counter!(FLASHBOTS_EMPTY_BLOCKS, FLASHBOTS_EMPTY_BLOCKS_HELP);
     describe_counter!(FLASHBOTS_SUBMISSIONS, FLASHBOTS_SUBMISSIONS_HELP);
+    describe_histogram!(FLASHBOTS_SUBMISSION_DURATION_MS, FLASHBOTS_SUBMISSION_DURATION_MS_HELP);
 
     // Block building
     describe_counter!(BUILT_BLOCKS, BUILT_BLOCKS_HELP);
@@ -162,6 +167,12 @@ pub fn flashbots_submissions() -> Counter {
     counter!(FLASHBOTS_SUBMISSIONS)
 }
 
+/// Histogram for Flashbots bundle submission duration in milliseconds.
+pub fn flashbots_submission_duration_ms() -> Histogram {
+    LazyLock::force(&DESCRIBE);
+    histogram!(FLASHBOTS_SUBMISSION_DURATION_MS)
+}
+
 // -- Block Building --
 
 /// Counter for blocks built by the simulator.

src/tasks/submit/flashbots.rs

@@ -14,6 +14,7 @@ use alloy::{
 };
 use eyre::OptionExt;
 use init4_bin_base::utils::signer::LocalOrAws;
+use std::time::Instant;
 use tokio::{sync::mpsc, task::JoinHandle};
 use tracing::{Instrument, debug, debug_span};
 
@@ -196,13 +197,17 @@ impl FlashbotsTask {
             let signer = self.signer.clone();
 
             tokio::spawn(async move {
+                let start = Instant::now();
                 let response = flashbots
                     .send_mev_bundle(bundle.clone())
                     .with_auth(signer.clone())
                     .into_future()
                     .instrument(submit_span.clone())
                     .await;
 
+                metrics::flashbots_submission_duration_ms()
+                    .record(start.elapsed().as_millis() as f64);
+
                 match response {
                     Ok(resp) => {
                         metrics::flashbots_bundles_submitted().increment(1);