add time partition to home api response

Author: nikhilsinhaparseable

src/prism/home/mod.rs

@@ -40,8 +40,15 @@ use crate::{
     users::{dashboards::DASHBOARDS, filters::FILTERS},
 };
 
-type StreamMetadataResponse =
-    Result<(String, Vec<ObjectStoreFormat>, TelemetryType), PrismHomeError>;
+type StreamMetadataResponse = Result<
+    (
+        String,
+        Vec<ObjectStoreFormat>,
+        TelemetryType,
+        Option<String>,
+    ),
+    PrismHomeError,
+>;
 
 #[derive(Debug, Serialize, Default)]
 pub struct DatedStats {
@@ -55,6 +62,8 @@ pub struct DatedStats {
 pub struct DataSet {
     title: String,
     dataset_type: TelemetryType,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    time_partition: Option<String>,
 }
 
 #[derive(Debug, Serialize)]
@@ -120,7 +129,7 @@ pub async fn generate_home_response(
 
     for result in stream_metadata_results {
         match result {
-            Ok((stream, metadata, dataset_type)) => {
+            Ok((stream, metadata, dataset_type, time_partition)) => {
                 // Skip internal streams if the flag is false
                 if !include_internal
                     && metadata
@@ -133,6 +142,7 @@ pub async fn generate_home_response(
                 datasets.push(DataSet {
                     title: stream,
                     dataset_type,
+                    time_partition,
                 });
             }
             Err(e) => {
@@ -204,7 +214,15 @@ fn get_top_5_streams_by_ingestion(
 
 async fn get_stream_metadata(
     stream: String,
-) -> Result<(String, Vec<ObjectStoreFormat>, TelemetryType), PrismHomeError> {
+) -> Result<
+    (
+        String,
+        Vec<ObjectStoreFormat>,
+        TelemetryType,
+        Option<String>,
+    ),
+    PrismHomeError,
+> {
     let path = RelativePathBuf::from_iter([&stream, STREAM_ROOT_DIRECTORY]);
     let obs = PARSEABLE
         .storage
@@ -234,8 +252,9 @@ async fn get_stream_metadata(
     }
 
     let dataset_type = stream_jsons[0].telemetry_type;
+    let time_partition = stream_jsons[0].time_partition.clone();
 
-    Ok((stream, stream_jsons, dataset_type))
+    Ok((stream, stream_jsons, dataset_type, time_partition))
 }
 
 async fn stats_for_date(