From 67f586adf99e9e79766abca3b6acfff742972e4f Mon Sep 17 00:00:00 2001 From: Nikhil Sinha Date: Wed, 28 Jan 2026 18:33:52 +1100 Subject: [PATCH 1/3] update: ingestion=true/false in home api --- src/prism/home/mod.rs | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/src/prism/home/mod.rs b/src/prism/home/mod.rs index 611d4c84d..69b0fe865 100644 --- a/src/prism/home/mod.rs +++ b/src/prism/home/mod.rs @@ -44,6 +44,7 @@ type StreamMetadataResponse = Result< TelemetryType, Option, LogSource, + bool, ), PrismHomeError, >; @@ -56,6 +57,7 @@ pub struct DataSet { #[serde(skip_serializing_if = "Option::is_none")] time_partition: Option, dataset_format: LogSource, + ingestion: bool, } #[derive(Debug, Serialize, Deserialize, Default)] @@ -124,7 +126,7 @@ pub async fn generate_home_response( for result in stream_metadata_results { match result { - Ok((stream, metadata, dataset_type, time_partition, dataset_format)) => { + Ok((stream, metadata, dataset_type, time_partition, dataset_format, ingestion)) => { // Skip internal streams if the flag is false if !include_internal && metadata @@ -139,6 +141,7 @@ pub async fn generate_home_response( dataset_type, time_partition, dataset_format, + ingestion, }); } Err(e) => { @@ -149,7 +152,7 @@ pub async fn generate_home_response( } // Generate checklist and count triggered alerts - let data_ingested = !all_streams.is_empty(); + let data_ingested = datasets.iter().any(|d| d.ingestion); let user_count = users().len(); let user_added = user_count > 1; // more than just the default admin user @@ -195,6 +198,7 @@ async fn get_stream_metadata( TelemetryType, Option, LogSource, + bool, ), PrismHomeError, > { @@ -230,6 +234,7 @@ async fn get_stream_metadata( .unwrap_or_else(LogSourceEntry::default) .log_source_format .clone(); + let ingested = stream_jsons.iter().any(|s| s.first_event_at.is_some()); Ok(( stream, @@ -237,6 +242,7 @@ async fn get_stream_metadata( dataset_type, time_partition, dataset_format, + ingested, )) } From 428d3b42260bc0847105282d0b9c72736282b2f3 Mon Sep 17 00:00:00 2001 From: Nikhil Sinha Date: Wed, 28 Jan 2026 18:39:24 +1100 Subject: [PATCH 2/3] iterate all --- src/prism/home/mod.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/prism/home/mod.rs b/src/prism/home/mod.rs index 69b0fe865..aa8d29a9b 100644 --- a/src/prism/home/mod.rs +++ b/src/prism/home/mod.rs @@ -152,7 +152,7 @@ pub async fn generate_home_response( } // Generate checklist and count triggered alerts - let data_ingested = datasets.iter().any(|d| d.ingestion); + let data_ingested = datasets.iter().all(|d| d.ingestion); let user_count = users().len(); let user_added = user_count > 1; // more than just the default admin user @@ -234,7 +234,7 @@ async fn get_stream_metadata( .unwrap_or_else(LogSourceEntry::default) .log_source_format .clone(); - let ingested = stream_jsons.iter().any(|s| s.first_event_at.is_some()); + let ingested = stream_jsons.iter().all(|s| s.first_event_at.is_some()); Ok(( stream, From 9fb64ab619e16689db647cb232091db5be79bc37 Mon Sep 17 00:00:00 2001 From: Nikhil Sinha Date: Wed, 28 Jan 2026 19:48:45 +1100 Subject: [PATCH 3/3] update ingested logic to use stats in objectstoreformat --- src/prism/home/mod.rs | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/prism/home/mod.rs b/src/prism/home/mod.rs index aa8d29a9b..52b29e716 100644 --- a/src/prism/home/mod.rs +++ b/src/prism/home/mod.rs @@ -152,7 +152,7 @@ pub async fn generate_home_response( } // Generate checklist and count triggered alerts - let data_ingested = datasets.iter().all(|d| d.ingestion); + let data_ingested = datasets.iter().any(|d| d.ingestion); let user_count = users().len(); let user_added = user_count > 1; // more than just the default admin user @@ -234,7 +234,9 @@ async fn get_stream_metadata( .unwrap_or_else(LogSourceEntry::default) .log_source_format .clone(); - let ingested = stream_jsons.iter().all(|s| s.first_event_at.is_some()); + let ingested = stream_jsons + .iter() + .any(|s| s.stats.current_stats.events > 0); Ok(( stream,