list filters by users

server/src/handlers/http/users/filters.rs

@@ -17,7 +17,7 @@
  */
 
 use crate::{
-    handlers::{http::ingest::PostError, STREAM_NAME_HEADER_KEY},
+    handlers::http::ingest::PostError,
     option::CONFIG,
     storage::{object_storage::filter_path, ObjectStorageError},
     users::filters::{Filter, CURRENT_FILTER_VERSION, FILTERS},
@@ -33,15 +33,7 @@ pub async fn list(req: HttpRequest) -> Result<impl Responder, FiltersError> {
         .match_info()
         .get("user_id")
         .ok_or(FiltersError::Metadata("No User Id Provided"))?;
-    let stream_name = req
-        .headers()
-        .iter()
-        .find(|&(key, _)| key == STREAM_NAME_HEADER_KEY)
-        .ok_or_else(|| FiltersError::Metadata("Stream Name Not Provided"))?
-        .1
-        .to_str()
-        .map_err(|_| FiltersError::Metadata("Non ASCII Stream Name Provided"))?;
-    let filters = FILTERS.list_filters_by_user_and_stream(user_id, stream_name);
+    let filters = FILTERS.list_filters_by_user(user_id);
 
     Ok((web::Json(filters), StatusCode::OK))
 }

server/src/users/filters.rs

@@ -106,12 +106,12 @@ impl Filters {
             .cloned()
     }
 
-    pub fn list_filters_by_user_and_stream(&self, user_id: &str, stream_name: &str) -> Vec<Filter> {
+    pub fn list_filters_by_user(&self, user_id: &str) -> Vec<Filter> {
         self.0
             .read()
             .expect(LOCK_EXPECT)
             .iter()
-            .filter(|f| f.user_id == user_id && f.stream_name == stream_name)
+            .filter(|f| f.user_id == user_id)
             .cloned()
             .collect()
     }