feat: add batcher accumulated cost metric (#1663)

Author: avilagaston9

batcher/aligned-batcher/src/lib.rs

@@ -1557,6 +1557,10 @@ impl Batcher {
                 {
                     warn!("Failed to send task status to telemetry: {:?}", e);
                 }
+                let gas_cost = Self::gas_cost_in_eth(receipt.effective_gas_price, receipt.gas_used);
+                self.metrics
+                    .batcher_gas_cost_create_task_total
+                    .inc_by(gas_cost);
                 Ok(receipt)
             }
             Err(RetryError::Permanent(BatcherError::ReceiptNotFoundError)) => {
@@ -1646,14 +1650,40 @@ impl Batcher {
         )
         .await
         {
-            Ok(_) => info!("createNewTask transaction successfully canceled"),
+            Ok(receipt) => {
+                info!("createNewTask transaction successfully canceled");
+                let gas_cost = Self::gas_cost_in_eth(receipt.effective_gas_price, receipt.gas_used);
+                self.metrics
+                    .batcher_gas_cost_cancel_task_total
+                    .inc_by(gas_cost);
+            }
             Err(e) => error!("Could not cancel createNewTask transaction: {e}"),
         };
         self.metrics
             .cancel_create_new_task_duration
             .set(start.elapsed().as_millis() as i64);
     }
 
+    fn gas_cost_in_eth(gas_price: Option<U256>, gas_used: Option<U256>) -> f64 {
+        if let (Some(gas_price), Some(gas_used)) = (gas_price, gas_used) {
+            let wei_gas_cost = gas_price
+                .checked_mul(gas_used)
+                .unwrap_or_else(U256::max_value);
+
+            // f64 is typically sufficient for transaction gas costs.
+            let max_f64_u256 = U256::from(f64::MAX as u64);
+            if wei_gas_cost > max_f64_u256 {
+                return f64::MAX;
+            }
+
+            let wei_gas_cost_f64 = wei_gas_cost.low_u128() as f64;
+            let eth_gas_cost = wei_gas_cost_f64 / 1e18;
+
+            return eth_gas_cost;
+        }
+        0.0
+    }
+
     /// Only relevant for testing and for users to easily use Aligned
     fn is_nonpaying(&self, addr: &Address) -> bool {
         self.non_paying_config

batcher/aligned-batcher/src/metrics.rs

@@ -2,8 +2,9 @@ use std::{thread, time::Duration};
 
 // Prometheus
 use prometheus::{
-    opts, register_int_counter, register_int_counter_vec, register_int_gauge, IntCounter,
-    IntCounterVec, IntGauge,
+    core::{AtomicF64, GenericCounter},
+    opts, register_counter, register_int_counter, register_int_counter_vec, register_int_gauge,
+    IntCounter, IntCounterVec, IntGauge,
 };
 
 use warp::{Filter, Rejection, Reply};
@@ -22,6 +23,8 @@ pub struct BatcherMetrics {
     pub s3_duration: IntGauge,
     pub create_new_task_duration: IntGauge,
     pub cancel_create_new_task_duration: IntGauge,
+    pub batcher_gas_cost_create_task_total: GenericCounter<AtomicF64>,
+    pub batcher_gas_cost_cancel_task_total: GenericCounter<AtomicF64>,
 }
 
 impl BatcherMetrics {
@@ -59,6 +62,17 @@ impl BatcherMetrics {
             "Cancel create New Task Duration"
         ))?;
 
+        let batcher_gas_cost_create_task_total: GenericCounter<AtomicF64> =
+            register_counter!(opts!(
+                "batcher_gas_cost_create_task_total",
+                "Batcher Gas Cost Create Task Total"
+            ))?;
+        let batcher_gas_cost_cancel_task_total: GenericCounter<AtomicF64> =
+            register_counter!(opts!(
+                "batcher_gas_cost_cancel_task_total",
+                "Batcher Gas Cost Cancel Task Total"
+            ))?;
+
         registry.register(Box::new(open_connections.clone()))?;
         registry.register(Box::new(received_proofs.clone()))?;
         registry.register(Box::new(sent_batches.clone()))?;
@@ -71,6 +85,8 @@ impl BatcherMetrics {
         registry.register(Box::new(s3_duration.clone()))?;
         registry.register(Box::new(create_new_task_duration.clone()))?;
         registry.register(Box::new(cancel_create_new_task_duration.clone()))?;
+        registry.register(Box::new(batcher_gas_cost_create_task_total.clone()))?;
+        registry.register(Box::new(batcher_gas_cost_cancel_task_total.clone()))?;
 
         let metrics_route = warp::path!("metrics")
             .and(warp::any().map(move || registry.clone()))
@@ -95,6 +111,8 @@ impl BatcherMetrics {
             s3_duration,
             create_new_task_duration,
             cancel_create_new_task_duration,
+            batcher_gas_cost_create_task_total,
+            batcher_gas_cost_cancel_task_total,
         })
     }