diff --git a/src/core/src/overview.rs b/src/core/src/overview.rs index e946057e8d..cb94c79dbd 100644 --- a/src/core/src/overview.rs +++ b/src/core/src/overview.rs @@ -855,6 +855,7 @@ mod tests { total_fields: 0, pattern_associations: vec![], is_derived: None, + is_internal: false, } } diff --git a/src/stream/src/lib.rs b/src/stream/src/lib.rs index b2ea30942e..3744668d27 100644 --- a/src/stream/src/lib.rs +++ b/src/stream/src/lib.rs @@ -156,21 +156,6 @@ pub async fn try_get_streams( Ok(indices_res) } -/// Checks a stream against the caller's permitted object list, using the stream's own type. -fn is_stream_permitted( - permitted: &[String], - org_id: &str, - stream_type: StreamType, - stream_name: &str, -) -> bool { - let s_type = match stream_type { - StreamType::EnrichmentTables => "enrichment_table", - _ => stream_type.as_str(), - }; - permitted.contains(&format!("{s_type}:_all_{org_id}")) - || permitted.contains(&format!("{s_type}:{stream_name}")) -} - // org_id is only for pattern associations, which is ent only pub fn stream_res( org_id: &str,