[telemetry] Add structured logging

Cargo.toml

@@ -43,7 +43,8 @@ tabled = "0.16"
 anyhow = "1.0.98"
 toml = "0.9.2"
 futures = "0.3.31"
-tracing-subscriber = { version = "0.3.19", features = ["env-filter"] }
+tracing-subscriber = { version = "0.3.19", features = ["env-filter", "json"] }
+crossterm = { version = "0.28", default-features = false }
 age = { version = "0.11", features = ["cli-common", "plugin"] }
 rust-embed = { version = "8", features = ["deterministic-timestamps"] }
 rustls = { version = "0.23.29", default-features = false, features = ["ring"] }

crates/e2e-tests/Cargo.toml

@@ -33,6 +33,7 @@ colored.workspace = true
 rand.workspace = true
 nix = { version = "0.26.4", features = ["signal"] }
 tracing-subscriber.workspace = true
+hashi-telemetry = { path = "../hashi-telemetry" }
 
 [[bin]]
 name = "hashi-localnet"

crates/e2e-tests/src/main.rs

@@ -279,13 +279,10 @@ async fn cmd_start(
         tracing::level_filters::LevelFilter::OFF
     };
 
-    tracing_subscriber::fmt()
-        .with_env_filter(
-            tracing_subscriber::EnvFilter::builder()
-                .with_default_directive(default_level.into())
-                .from_env_lossy(),
-        )
+    let _guard = hashi_telemetry::TelemetryConfig::new()
+        .with_default_level(default_level)
         .with_target(false)
+        .with_env()
         .init();
 
     use std::io::Write;

crates/hashi-guardian/Cargo.toml

@@ -11,6 +11,7 @@ serde.workspace = true
 serde_json.workspace = true
 tracing.workspace = true
 tracing-subscriber.workspace = true
+hashi-telemetry = { path = "../hashi-telemetry" }
 tonic.workspace = true
 hashi-types = { path = "../hashi-types" }
 

crates/hashi-guardian/src/main.rs

@@ -102,7 +102,11 @@ pub struct EphemeralKeyPairs {
 /// SETUP_MODE=false: all endpoints except setup_new_key are enabled.
 #[tokio::main]
 async fn main() -> Result<()> {
-    init_tracing_subscriber(true);
+    let _guard = hashi_telemetry::TelemetryConfig::new()
+        .with_file_line(true)
+        .with_service_name("hashi-guardian")
+        .with_env()
+        .init();
 
     // Check if SETUP_MODE is enabled (defaults to false)
     let setup_mode = std::env::var("SETUP_MODE")
@@ -537,27 +541,6 @@ impl Enclave {
     }
 }
 
-// ---------------------------------
-//    Tracing utilities
-// ---------------------------------
-
-/// Initialize tracing subscriber with optional file/line number logging
-pub fn init_tracing_subscriber(with_file_line: bool) {
-    let mut builder = tracing_subscriber::FmtSubscriber::builder().with_env_filter(
-        tracing_subscriber::EnvFilter::builder()
-            .with_default_directive(tracing::level_filters::LevelFilter::INFO.into())
-            .from_env_lossy(),
-    );
-
-    if with_file_line {
-        builder = builder.with_file(true).with_line_number(true);
-    }
-
-    let subscriber = builder.finish();
-    tracing::subscriber::set_global_default(subscriber)
-        .expect("unable to initialize tracing subscriber");
-}
-
 // ---------------------------------
 //    Tests and related utilities
 // ---------------------------------

crates/hashi-monitor/Cargo.toml

@@ -22,6 +22,7 @@ tokio.workspace = true
 tonic.workspace = true
 tracing.workspace = true
 tracing-subscriber.workspace = true
+hashi-telemetry = { path = "../hashi-telemetry" }
 
 [dev-dependencies]
 e2e-tests = { path = "../e2e-tests" }

crates/hashi-monitor/src/main.rs

@@ -51,7 +51,11 @@ enum Command {
 
 #[tokio::main]
 async fn main() -> anyhow::Result<()> {
-    init_tracing_subscriber(false);
+    let _guard = hashi_telemetry::TelemetryConfig::new()
+        .with_service_name("hashi-monitor")
+        .with_target(false)
+        .with_env()
+        .init();
 
     let cli = Cli::parse();
 
@@ -78,22 +82,3 @@ async fn main() -> anyhow::Result<()> {
 
     Ok(())
 }
-
-pub fn init_tracing_subscriber(with_file_line: bool) {
-    let mut builder = tracing_subscriber::FmtSubscriber::builder().with_env_filter(
-        tracing_subscriber::EnvFilter::builder()
-            .with_default_directive(tracing::level_filters::LevelFilter::INFO.into())
-            .from_env_lossy(),
-    );
-
-    if with_file_line {
-        builder = builder
-            .with_file(true)
-            .with_line_number(true)
-            .with_target(false);
-    }
-
-    let subscriber = builder.finish();
-    tracing::subscriber::set_global_default(subscriber)
-        .expect("unable to initialize tracing subscriber");
-}

crates/hashi-screener/Cargo.toml

@@ -11,6 +11,7 @@ thiserror.workspace = true
 tokio.workspace = true
 tracing.workspace = true
 tracing-subscriber.workspace = true
+hashi-telemetry = { path = "../hashi-telemetry" }
 prometheus.workspace = true
 axum.workspace = true
 sui-http.workspace = true

crates/hashi-screener/src/main.rs

@@ -226,20 +226,6 @@ impl ScreenerService for ScreenerServiceImpl {
     }
 }
 
-fn init_tracing_subscriber() {
-    let subscriber = tracing_subscriber::FmtSubscriber::builder()
-        .with_env_filter(
-            tracing_subscriber::EnvFilter::builder()
-                .with_default_directive(tracing::level_filters::LevelFilter::INFO.into())
-                .from_env_lossy(),
-        )
-        .with_file(true)
-        .with_line_number(true)
-        .finish();
-    tracing::subscriber::set_global_default(subscriber)
-        .expect("unable to initialize tracing subscriber");
-}
-
 fn start_metrics_server(registry: prometheus::Registry) -> sui_http::ServerHandle {
     let addr: SocketAddr = "0.0.0.0:9184".parse().unwrap();
     info!("Prometheus metrics server listening on {}", addr);
@@ -266,7 +252,11 @@ async fn metrics_handler(
 
 #[tokio::main]
 async fn main() -> Result<()> {
-    init_tracing_subscriber();
+    let _guard = hashi_telemetry::TelemetryConfig::new()
+        .with_file_line(true)
+        .with_service_name("hashi-screener")
+        .with_env()
+        .init();
 
     let api_key = env::var("MERKLE_SCIENCE_API_KEY")
         .map_err(|_| anyhow::anyhow!("MERKLE_SCIENCE_API_KEY environment variable is not set"))?;

crates/hashi-telemetry/Cargo.toml

@@ -0,0 +1,10 @@
+[package]
+name = "hashi-telemetry"
+version = "0.1.0"
+edition = "2024"
+publish = false
+
+[dependencies]
+tracing.workspace = true
+tracing-subscriber.workspace = true
+crossterm.workspace = true