Fix

Author: trueleo

server/src/handlers/http.rs

@@ -144,7 +144,11 @@ pub fn configure_routes(cfg: &mut web::ServiceConfig) {
                         .authorise_for_stream(Action::CreateStream),
                 )
                 // POST "/logstream/{logstream}" ==> Post logs to given log stream
-                .route(web::post().to(ingest::post_event).authorise(Action::Ingest))
+                .route(
+                    web::post()
+                        .to(ingest::post_event)
+                        .authorise_for_stream(Action::Ingest),
+                )
                 // DELETE "/logstream/{logstream}" ==> Delete log stream
                 .route(
                     web::delete()
@@ -249,7 +253,11 @@ pub fn configure_routes(cfg: &mut web::ServiceConfig) {
             // POST "/ingest" ==> Post logs to given log stream based on header
             .service(
                 web::resource("/ingest")
-                    .route(web::post().to(ingest::ingest).authorise(Action::Ingest))
+                    .route(
+                        web::post()
+                            .to(ingest::ingest)
+                            .authorise_for_stream(Action::Ingest),
+                    )
                     .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),
             )
             // GET "/liveness" ==> Liveness check as per https://kubernetes.io/docs/tasks/configure-pod-container/configure-liveness-readiness-startup-probes/#define-a-liveness-command