athena_rs 3.26.1

Hyper performant polyglot Database driver
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

//! `/debug/schema` handler output-handoff assembly helpers.
//!
//! This module owns handing authorized debug-schema requests into route
//! response orchestration.

use actix_web::HttpResponse;

use crate::AppState;

use super::debug_response::debug_schema_response;

/// Builds one `/debug/schema` handler response after authorization succeeds.
pub(super) async fn build_debug_schema_handler_response(app_state: &AppState) -> HttpResponse {
    debug_schema_response(app_state).await
}

#[cfg(test)]
mod tests {
    use actix_web::http::StatusCode;

    use super::*;
    use crate::api::schema::debug_response_test_helpers::{
        assert_error_payload_for_tests, response_json_for_tests,
    };

    #[actix_web::test]
    /// Ensures authorized handler handoff reports missing logging-store configuration consistently.
    async fn handler_output_handoff_returns_service_unavailable_when_logging_client_missing() {
        let app_state = AppState::default();

        let response = build_debug_schema_handler_response(&app_state).await;
        assert_eq!(response.status(), StatusCode::SERVICE_UNAVAILABLE);
        let body =
            response_json_for_tests(response, "handler output handoff missing logging client")
                .await;

        assert_error_payload_for_tests(
            &body,
            "Logging store unavailable",
            &["No athena logging client is configured."],
            "handler output handoff missing logging client",
        );
    }

    #[actix_web::test]
    /// Ensures authorized handler handoff reports disconnected logging-store clients consistently.
    async fn handler_output_handoff_returns_service_unavailable_when_logging_client_disconnected() {
        let mut app_state = AppState::default();
        app_state.logging_client_name = Some("athena_logging".to_string());

        let response = build_debug_schema_handler_response(&app_state).await;
        assert_eq!(response.status(), StatusCode::SERVICE_UNAVAILABLE);
        let body = response_json_for_tests(
            response,
            "handler output handoff disconnected logging client",
        )
        .await;

        assert_error_payload_for_tests(
            &body,
            "Logging store unavailable",
            &["Logging client 'athena_logging' is not connected."],
            "handler output handoff disconnected logging client",
        );
    }
}