refactor

Author: nikhilsinhaparseable

src/handlers/http/modal/query/querier_logstream.rs

@@ -44,7 +44,7 @@ use crate::{
     },
     hottier::HotTierManager,
     parseable::{StreamNotFound, PARSEABLE},
-    stats::{self, Stats},
+    stats,
     storage::{ObjectStoreFormat, StreamType, STREAM_ROOT_DIRECTORY},
 };
 
@@ -178,12 +178,7 @@ pub async fn get_stats(
 
             let stats = fetch_daily_stats(date_value, &stream_jsons)?;
 
-            let total_stats = Stats {
-                events: stats.events,
-                ingestion: stats.ingestion,
-                storage: stats.storage,
-            };
-            let stats = serde_json::to_value(total_stats)?;
+            let stats = serde_json::to_value(stats)?;
 
             return Ok((web::Json(stats), StatusCode::OK));
         }

src/prism/home/mod.rs

@@ -220,7 +220,7 @@ async fn stats_for_date(
     // Process each stream concurrently
     let stream_stats_futures = stream_wise_meta
         .values()
-        .map(|meta| get_stream_stats_for_date(date.clone(), meta.clone()));
+        .map(|meta| get_stream_stats_for_date(date.clone(), meta));
 
     let stream_stats_results = futures::future::join_all(stream_stats_futures).await;
 
@@ -244,9 +244,9 @@ async fn stats_for_date(
 
 async fn get_stream_stats_for_date(
     date: String,
-    meta: Vec<ObjectStoreFormat>,
+    meta: &[ObjectStoreFormat],
 ) -> Result<(u64, u64, u64), PrismHomeError> {
-    let stats = fetch_daily_stats(&date, &meta)?;
+    let stats = fetch_daily_stats(&date, meta)?;
 
     Ok((stats.events, stats.ingestion, stats.storage))
 }