fix: validate step

integration/integration.test.ts

@@ -76,7 +76,7 @@ describe('Echo Server', () => {
 
     // Simulate flood of requests and check for rate-limited responses
     it('Rate limiting', async () => {
-      const url = `${BASE_URL}/health`
+      const url = `${BASE_URL}/rate_limit_test`
       const requests_to_send = 100;
       const promises = [];
       for (let i = 0; i < requests_to_send; i++) {
@@ -85,7 +85,7 @@ describe('Echo Server', () => {
         );
       }
       const results = await Promise.allSettled(promises);
-      
+
       let ok_statuses_counter = 0;
       let rate_limited_statuses_counter = 0;
       results.forEach((result) => {

src/handlers/mod.rs

@@ -40,6 +40,7 @@ pub mod delete_tenant;
 #[cfg(feature = "multitenant")]
 pub mod get_tenant;
 pub mod health;
+pub mod rate_limit_test;
 #[cfg(feature = "multitenant")]
 pub mod update_apns;
 #[cfg(feature = "multitenant")]

src/handlers/rate_limit_test.rs

@@ -0,0 +1,5 @@
+use axum::{http::StatusCode, response::IntoResponse};
+
+pub async fn handler() -> impl IntoResponse {
+    StatusCode::OK.into_response()
+}

src/lib.rs

@@ -234,6 +234,9 @@ pub async fn bootstap(mut shutdown: broadcast::Receiver<()>, config: Config) ->
 
         Router::new()
             .route("/health", get(handlers::health::handler))
+            .route("/rate_limit_test", get(handlers::rate_limit_test::handler).layer(
+                axum::middleware::from_fn_with_state(state_arc.clone(), rate_limit_middleware),
+            ))
             .nest("/tenants", tenancy_routes.layer(
                 axum::middleware::from_fn_with_state(state_arc.clone(), rate_limit_middleware),
             ))
@@ -260,6 +263,9 @@ pub async fn bootstap(mut shutdown: broadcast::Receiver<()>, config: Config) ->
     #[cfg(not(feature = "multitenant"))]
     let app = Router::new()
         .route("/health", get(handlers::health::handler))
+        .route("/rate_limit_test", get(handlers::rate_limit_test::handler).layer(
+            axum::middleware::from_fn_with_state(state_arc.clone(), rate_limit_middleware),
+        ))
         .route(
             "/clients",
             post(handlers::single_tenant_wrappers::register_handler).layer(