Use a database and JSON file for persistent, multi-day, live metrics.

Cargo.toml

@@ -120,6 +120,7 @@ esplora_block = { version = "0.5.0", package = "esplora-client", default-feature
     "blocking",
 ] }
 inflate = "0.4.5"
+sled = "0.34.7"
 tower-http = { version = "0.4.4", features = ["cors"], optional = true }
 
 [target.'cfg(not(target_arch = "wasm32"))'.dev-dependencies]

src/bin/bitmaskd.rs

@@ -724,7 +724,8 @@ async fn send_coins(
 }
 
 async fn json_metrics() -> Result<impl IntoResponse, AppError> {
-    let metrics_json = metrics::json().await?;
+    let dir = env::var("CARBONADO_DIR").unwrap_or("/tmp/bitmaskd/carbonado".to_owned());
+    let metrics_json = fs::read_to_string(&format!("{dir}/metrics.json")).await?;
 
     Ok((
         StatusCode::OK,
@@ -734,14 +735,15 @@ async fn json_metrics() -> Result<impl IntoResponse, AppError> {
 }
 
 async fn csv_metrics() -> Result<impl IntoResponse, AppError> {
-    let metrics_csv = metrics::csv().await;
+    let dir = env::var("CARBONADO_DIR").unwrap_or("/tmp/bitmaskd/carbonado".to_owned());
+    let metrics_csv = fs::read_to_string(&format!("{dir}/metrics.csv")).await?;
 
     Ok((StatusCode::OK, [("content-type", "text/csv")], metrics_csv))
 }
 
 async fn init_metrics() -> Result<()> {
-    let path = env::var("CARBONADO_DIR").unwrap_or("/tmp/bitmaskd/carbonado".to_owned());
-    let dir = path::Path::new(&path);
+    let dir = env::var("CARBONADO_DIR").unwrap_or("/tmp/bitmaskd/carbonado".to_owned());
+    let dir = path::Path::new(&dir);
 
     info!("Starting metrics collection...");
     let duration = Instant::now();
@@ -822,7 +824,7 @@ async fn main() -> Result<()> {
     } else {
         tokio::spawn(async {
             if let Err(e) = init_metrics().await {
-                error!("Error in periodic metrics: {e}");
+                error!("Error in init metrics: {e}");
             }
         });
     }