chore: idiomatic and optimized

Author: spuckhafte

src/handlers/http/logstream.rs

@@ -496,7 +496,7 @@ pub async fn delete_stream_hot_tier(
 }
 
 pub async fn get_affected_resources(
-    stream_name: Path<String>
+    stream_name: Path<String>,
 ) -> Result<impl Responder, StreamError> {
     let stream_name = stream_name.into_inner();
 
@@ -508,10 +508,8 @@ pub async fn get_affected_resources(
     }
 
     match LogstreamAffectedResources::load(&stream_name).await {
-        Ok(affected_resources) 
-            => Ok((web::Json(affected_resources), StatusCode::OK)),
-        Err(err) 
-            => Err(err.into())
+        Ok(affected_resources) => Ok((web::Json(affected_resources), StatusCode::OK)),
+        Err(err) => Err(err.into()),
     }
 }
 
@@ -531,13 +529,13 @@ pub mod error {
     use http::StatusCode;
 
     use crate::{
-        hottier::HotTierError, 
-        metastore::MetastoreError, 
-        parseable::StreamNotFound, 
-        storage::ObjectStorageError, 
+        hottier::HotTierError,
+        metastore::MetastoreError,
+        parseable::StreamNotFound,
+        storage::ObjectStorageError,
         validator::error::{
             AlertValidationError, HotTierValidationError, StreamNameValidationError,
-        }
+        },
     };
 
     #[allow(unused)]

src/handlers/http/modal/ingest_server.rs

@@ -273,12 +273,12 @@ impl IngestServer {
                     ),
                 )
                 .service(
-                        // GET "/logstream/{logstream}/affected-resources" ==> Get affected resources for given log stream
-                        web::resource("/affected-resources").route(
-                            web::get()
-                                .to(logstream::get_affected_resources)
-                                .authorize_for_resource(Action::GetLogstreamAffectedResources),
-                        ),
+                    // GET "/logstream/{logstream}/affected-resources" ==> Get affected resources for given log stream
+                    web::resource("/affected-resources").route(
+                        web::get()
+                            .to(logstream::get_affected_resources)
+                            .authorize_for_resource(Action::GetLogstreamAffectedResources),
+                    ),
                 )
                 .service(
                     web::scope("/retention").service(

src/handlers/http/modal/query_server.rs

@@ -313,14 +313,6 @@ impl QueryServer {
                                 .authorize_for_resource(Action::GetStats),
                         ),
                     )
-                    .service(
-                        // GET "/logstream/{logstream}/affected-resources" ==> Get affected resources for given log stream
-                        web::resource("/affected-resources").route(
-                            web::get()
-                                .to(logstream::get_affected_resources)
-                                .authorize_for_resource(Action::GetLogstreamAffectedResources),
-                        ),
-                    )
                     .service(
                         web::resource("/retention")
                             // PUT "/logstream/{logstream}/retention" ==> Set retention for given logstream