sova-observability 0.1.2

Request metrics (Prometheus), OpenTelemetry, and Elasticsearch logs for Sova
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
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90

//! Observability config: toml metrics_path vs builder override.

use sova_core::{App, Html, Request, TestClient};
use sova_observability::Observability;

#[tokio::test]
async fn metrics_path_from_toml() {
    let mut app = App::new();
    app.configure_from_str(
        r#"
[observability]
metrics_path = "/custom-metrics"
"#,
    )
    .unwrap();
    app.install(Observability::new());
    app.get("/ping", |_r: Request| async { Html("pong") });

    let c = TestClient::tracked(app).await.unwrap();
    let _ = c.get("/ping").await;
    let metrics = c.get("/custom-metrics").await;
    assert_eq!(metrics.status_code().as_u16(), 200);
    let body = String::from_utf8(metrics.body_bytes().unwrap().to_vec()).unwrap();
    assert!(body.contains("http_requests_total"), "body={body}");
}

#[tokio::test]
async fn builder_metrics_path_overrides_toml() {
    let mut app = App::new();
    app.configure_from_str(
        r#"
[observability]
metrics_path = "/from-toml"
"#,
    )
    .unwrap();
    app.install(Observability::new().metrics_path("/from-builder"));
    app.get("/ping", |_r: Request| async { Html("pong") });

    let c = TestClient::tracked(app).await.unwrap();
    let _ = c.get("/ping").await;

    let builder = c.get("/from-builder").await;
    assert_eq!(builder.status_code().as_u16(), 200);

    let toml_path = c.get("/from-toml").await;
    assert_eq!(
        toml_path.status_code().as_u16(),
        404,
        "toml path must not win over builder"
    );
}

/// When feature `otel` is on, `[observability] otel = true` is applied; missing
/// endpoint only warns (install still succeeds).
#[cfg(feature = "otel")]
#[tokio::test]
async fn otel_bool_from_toml_does_not_panic() {
    let mut app = App::new();
    app.configure_from_str(
        r#"
[observability]
otel = true
"#,
    )
    .unwrap();
    app.install(Observability::new());
    app.get("/ping", |_r: Request| async { Html("pong") });
    let c = TestClient::tracked(app).await.unwrap();
    assert_eq!(c.get("/ping").await.status_code().as_u16(), 200);
}

/// When feature `elasticsearch` is on, `[observability] elasticsearch = true`
/// is applied; missing URL only warns.
#[cfg(feature = "elasticsearch")]
#[tokio::test]
async fn elasticsearch_bool_from_toml_does_not_panic() {
    let mut app = App::new();
    app.configure_from_str(
        r#"
[observability]
elasticsearch = true
"#,
    )
    .unwrap();
    app.install(Observability::new());
    app.get("/ping", |_r: Request| async { Html("pong") });
    let c = TestClient::tracked(app).await.unwrap();
    assert_eq!(c.get("/ping").await.status_code().as_u16(), 200);
}