gasp-avs metrics

gasp-avs/Cargo.toml

@@ -41,6 +41,9 @@ tokio = { version = "1.37.0", features = ["full"] }
 tracing = "0.1.40"
 tracing-error = "0.2.0"
 tracing-subscriber = { version = "0.3.18", features = ["json", "env-filter"] }
+prometheus = { version = "0.13.3", default-features = false }
+lazy_static = "1.5.0"
+warp = "0.3.7"
 
 # Polkadot SDK
 
@@ -51,4 +54,4 @@ substrate-rpc-client = { git = "https://github.com/mangata-finance/polkadot-sdk"
 sc-rpc-api = { git = "https://github.com/mangata-finance/polkadot-sdk", branch = "eth-rollup-develop" }
 
 codec = { package = "parity-scale-codec", version = "3.6.1", default-features = false, features = ["derive"] }
-array-bytes = { version = "6.2.0" }
+array-bytes = { version = "6.2.0" }

gasp-avs/src/lib.rs

@@ -1,5 +1,6 @@
 use chainio::setup_deposits;
 use cli::CliArgs;
+use ethers::signers::Signer;
 use eyre::{eyre, Ok};
 use operator::Operator;
 use std::sync::Arc;
@@ -8,6 +9,7 @@ use tracing::{info, instrument, warn};
 mod chainio;
 mod cli;
 mod crypto;
+mod metrics;
 mod operator;
 mod rpc;
 
@@ -18,6 +20,16 @@ pub async fn start() -> eyre::Result<()> {
         serde_json::to_string_pretty(&cli)?
     );
     let operator = Operator::from_cli(&cli).await?;
+    let address = operator.signer().address();
+    let client = operator.client();
+
+    let _http_server = tokio::spawn(async move {
+        metrics::serve_metrics(80).await;
+    });
+
+    let _monitor_balance = tokio::spawn(async move {
+        metrics::report_account_balance(address, client).await;
+    });
 
     if let Some(cmd) = &cli.command {
         info!("Operator created with command '{:?}'", cmd);