feat: add comprehensive Rust API tests (44 tests)

reference-apps/rust/src/main.rs

@@ -1,4 +1,4 @@
 use actix_web::{web, App, HttpResponse, HttpServer, Responder, middleware};
 use actix_cors::Cors;
 use serde::{Deserialize, Serialize};
 use std::env;
@@ -111,23 +111,23 @@
     message: String,
 }
 
 // Prometheus metrics
 lazy_static! {
     static ref REGISTRY: Registry = Registry::new();
 
     static ref HTTP_REQUESTS_TOTAL: CounterVec = CounterVec::new(
         Opts::new("http_requests_total", "Total HTTP requests"),
         &["method", "endpoint", "status"]
     ).unwrap();
 
     static ref HTTP_REQUEST_DURATION: HistogramVec = HistogramVec::new(
         prometheus::HistogramOpts::new("http_request_duration_seconds", "HTTP request latency"),
         &["method", "endpoint"]
     ).unwrap();
 }
 
 fn register_metrics() {
     REGISTRY.register(Box::new(HTTP_REQUESTS_TOTAL.clone())).ok();
     REGISTRY.register(Box::new(HTTP_REQUEST_DURATION.clone())).ok();
 }
 
@@ -203,7 +203,7 @@
 }
 
 async fn health_vault() -> impl Responder {
     let vault_addr = get_env_or("VAULT_ADDR", "http://vault:8200");
 
     match reqwest::get(format!("{}/v1/sys/health", vault_addr)).await {
         Ok(resp) if resp.status().is_success() => {
@@ -233,7 +233,7 @@
         Err(response) => HttpResponse::ServiceUnavailable().json(response),
     }
 }
 
 async fn check_postgres_health() -> Result<HealthResponse, HealthResponse> {
     // Get credentials from Vault
     let creds = get_vault_secret("postgres").await.map_err(|e| HealthResponse {
@@ -298,7 +298,7 @@
         Ok(response) => HttpResponse::Ok().json(response),
         Err(response) => HttpResponse::ServiceUnavailable().json(response),
     }
 }
 
 async fn check_mysql_health() -> Result<HealthResponse, HealthResponse> {
     let creds = get_vault_secret("mysql").await.map_err(|e| HealthResponse {
@@ -320,7 +320,7 @@
         .tcp_port(port)
         .user(Some(user))
         .pass(Some(password))
         .db_name(Some(database));
 
     match mysql_async::Conn::new(opts).await {
         Ok(mut conn) => {
@@ -372,7 +372,7 @@
         Ok(response) => HttpResponse::Ok().json(response),
         Err(response) => HttpResponse::ServiceUnavailable().json(response),
     }
 }
 
 async fn check_mongodb_health() -> Result<HealthResponse, HealthResponse> {
     let creds = get_vault_secret("mongodb").await.map_err(|e| HealthResponse {
@@ -1340,45 +1340,4 @@
 }
 
 #[cfg(test)]
-mod tests {
-    use super::*;
-    use actix_web::{test, App};
-
-    #[actix_web::test]
-    async fn test_root_endpoint() {
-        let app = test::init_service(App::new().route("/", web::get().to(root))).await;
-        let req = test::TestRequest::get().uri("/").to_request();
-        let resp = test::call_service(&app, req).await;
-
-        assert!(resp.status().is_success());
-
-        let body: ApiInfo = test::read_body_json(resp).await;
-        assert_eq!(body.name, "DevStack Core Reference API");
-        assert_eq!(body.version, "1.0.0");
-        assert_eq!(body.language, "Rust");
-        assert_eq!(body.framework, "Actix-web");
-    }
-
-    #[actix_web::test]
-    async fn test_health_endpoint() {
-        let app = test::init_service(App::new().route("/health/", web::get().to(health_simple))).await;
-        let req = test::TestRequest::get().uri("/health/").to_request();
-        let resp = test::call_service(&app, req).await;
-
-        assert!(resp.status().is_success());
-
-        let body: HealthResponse = test::read_body_json(resp).await;
-        assert_eq!(body.status, "healthy");
-        assert!(body.timestamp.is_some());
-    }
-
-    #[actix_web::test]
-    async fn test_metrics_endpoint() {
-        register_metrics();
-        let app = test::init_service(App::new().route("/metrics", web::get().to(metrics))).await;
-        let req = test::TestRequest::get().uri("/metrics").to_request();
-        let resp = test::call_service(&app, req).await;
-
-        assert!(resp.status().is_success());
-    }
-}
+mod tests;  // Comprehensive test suite in tests.rs