Fix

Author: trueleo

server/src/handlers/http.rs

@@ -141,19 +141,19 @@ pub fn configure_routes(cfg: &mut web::ServiceConfig) {
                 .route(
                     web::put()
                         .to(logstream::put_stream)
-                        .authorise_for_stream(Action::CreateStream),
+                        .authorize_for_stream(Action::CreateStream),
                 )
                 // POST "/logstream/{logstream}" ==> Post logs to given log stream
                 .route(
                     web::post()
                         .to(ingest::post_event)
-                        .authorise_for_stream(Action::Ingest),
+                        .authorize_for_stream(Action::Ingest),
                 )
                 // DELETE "/logstream/{logstream}" ==> Delete log stream
                 .route(
                     web::delete()
                         .to(logstream::delete)
-                        .authorise_for_stream(Action::DeleteStream),
+                        .authorize_for_stream(Action::DeleteStream),
                 )
                 .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),
         )
@@ -163,29 +163,29 @@ pub fn configure_routes(cfg: &mut web::ServiceConfig) {
                 .route(
                     web::put()
                         .to(logstream::put_alert)
-                        .authorise_for_stream(Action::PutAlert),
+                        .authorize_for_stream(Action::PutAlert),
                 )
                 // GET "/logstream/{logstream}/alert" ==> Get alert for given log stream
                 .route(
                     web::get()
                         .to(logstream::get_alert)
-                        .authorise_for_stream(Action::GetAlert),
+                        .authorize_for_stream(Action::GetAlert),
                 ),
         )
         .service(
             // GET "/logstream/{logstream}/schema" ==> Get schema for given log stream
             web::resource("/schema").route(
                 web::get()
                     .to(logstream::schema)
-                    .authorise_for_stream(Action::GetSchema),
+                    .authorize_for_stream(Action::GetSchema),
             ),
         )
         .service(
             // GET "/logstream/{logstream}/stats" ==> Get stats for given log stream
             web::resource("/stats").route(
                 web::get()
                     .to(logstream::get_stats)
-                    .authorise_for_stream(Action::GetStats),
+                    .authorize_for_stream(Action::GetStats),
             ),
         )
         .service(
@@ -194,13 +194,13 @@ pub fn configure_routes(cfg: &mut web::ServiceConfig) {
                 .route(
                     web::put()
                         .to(logstream::put_retention)
-                        .authorise_for_stream(Action::PutRetention),
+                        .authorize_for_stream(Action::PutRetention),
                 )
                 // GET "/logstream/{logstream}/retention" ==> Get retention for given logstream
                 .route(
                     web::get()
                         .to(logstream::get_retention)
-                        .authorise_for_stream(Action::GetRetention),
+                        .authorize_for_stream(Action::GetRetention),
                 ),
         );
 
@@ -209,19 +209,19 @@ pub fn configure_routes(cfg: &mut web::ServiceConfig) {
         .service(
             web::resource("/{username}")
                 // PUT /user/{username} => Create a new user
-                .route(web::put().to(rbac::put_user).authorise(Action::PutUser))
+                .route(web::put().to(rbac::put_user).authorize(Action::PutUser))
                 // DELETE /user/{username} => Delete a user
                 .route(
                     web::delete()
                         .to(rbac::delete_user)
-                        .authorise(Action::DeleteUser),
+                        .authorize(Action::DeleteUser),
                 )
-                .route(web::put().to(rbac::put_roles).authorise(Action::PutUser)),
+                .route(web::put().to(rbac::put_roles).authorize(Action::PutUser)),
         )
         .service(
             web::resource("/{username}/roles")
                 // PUT /user/{username}/roles => Put roles for user
-                .route(web::put().to(rbac::put_roles).authorise(Action::PutRoles)),
+                .route(web::put().to(rbac::put_roles).authorize(Action::PutRoles)),
         )
         .wrap_fn(|req, srv| {
             // The credentials set in the env vars (P_USERNAME & P_PASSWORD) are treated
@@ -247,7 +247,7 @@ pub fn configure_routes(cfg: &mut web::ServiceConfig) {
                 web::resource("/query").route(
                     web::post()
                         .to(query::query)
-                        .authorise_for_stream(Action::Query),
+                        .authorize_for_stream(Action::Query),
                 ),
             )
             // POST "/ingest" ==> Post logs to given log stream based on header
@@ -256,7 +256,7 @@ pub fn configure_routes(cfg: &mut web::ServiceConfig) {
                     .route(
                         web::post()
                             .to(ingest::ingest)
-                            .authorise_for_stream(Action::Ingest),
+                            .authorize_for_stream(Action::Ingest),
                     )
                     .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),
             )
@@ -269,7 +269,7 @@ pub fn configure_routes(cfg: &mut web::ServiceConfig) {
                     .service(
                         // GET "/logstream" ==> Get list of all Log Streams on the server
                         web::resource("")
-                            .route(web::get().to(logstream::list).authorise(Action::ListStream)),
+                            .route(web::get().to(logstream::list).authorize(Action::ListStream)),
                     )
                     .service(
                         // logstream API
@@ -292,19 +292,19 @@ pub fn metrics_path() -> String {
 }
 
 trait RouteExt {
-    fn authorise(self, action: Action) -> Self;
-    fn authorise_for_stream(self, action: Action) -> Self;
+    fn authorize(self, action: Action) -> Self;
+    fn authorize_for_stream(self, action: Action) -> Self;
 }
 
 impl RouteExt for Route {
-    fn authorise(self, action: Action) -> Self {
+    fn authorize(self, action: Action) -> Self {
         self.wrap(Authorization {
             action,
             stream: false,
         })
     }
 
-    fn authorise_for_stream(self, action: Action) -> Self {
+    fn authorize_for_stream(self, action: Action) -> Self {
         self.wrap(Authorization {
             action,
             stream: true,