From a942cb18969e49e0b4c741be64a5d6b9ab32653b Mon Sep 17 00:00:00 2001
From: Nikhil Sinha <nikhil.sinha@parseable.com>
Date: Thu, 27 Mar 2025 05:52:16 -0400
Subject: [PATCH] fix: home api

get log_source from memory map
instead of checking stream.json from storage
as there may be stream.json of an ingestor which is offline
and has never migrated to a newer version
---
 src/prism/home/mod.rs | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/prism/home/mod.rs b/src/prism/home/mod.rs
index 238a1a9cf..854727a14 100644
--- a/src/prism/home/mod.rs
+++ b/src/prism/home/mod.rs
@@ -204,7 +204,10 @@ pub async fn generate_home_response(key: &SessionKey) -> Result<HomeResponse, Pr
         }
         stream_wise_stream_json.insert(stream.clone(), stream_jsons.clone());
 
-        let log_source = &stream_jsons[0].clone().log_source;
+        let log_source = PARSEABLE
+            .get_stream(&stream)
+            .map_err(|e| PrismHomeError::Anyhow(e.into()))?
+            .get_log_source();
 
         // if log_source_format is otel-metrics, set DataSetType to metrics
         //if log_source_format is otel-traces, set DataSetType to traces