things3-core 1.0.1

Core library for Things 3 database access and data models
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
91
92
93
94

//! Tests for observability feature functionality
//!
//! These tests actually execute observability code to increase coverage

#[cfg(feature = "observability")]
#[tokio::test]
async fn test_observability_manager_creation() {
    use things3_core::ObservabilityConfig;

    let config = ObservabilityConfig {
        log_level: "info".to_string(),
        json_logs: false,
        enable_tracing: true,
        jaeger_endpoint: None,
        otlp_endpoint: None,
        enable_metrics: true,
        metrics_port: 9090,
        health_port: 8080,
        service_name: "test-service".to_string(),
        service_version: "1.0.0".to_string(),
    };

    // Verify config values
    assert_eq!(config.log_level, "info");
    assert!(!config.json_logs);
    assert!(config.enable_tracing);
    assert!(config.enable_metrics);
    assert_eq!(config.metrics_port, 9090);
    assert_eq!(config.health_port, 8080);
}

#[cfg(feature = "observability")]
#[test]
fn test_observability_config_default() {
    use things3_core::ObservabilityConfig;

    let config = ObservabilityConfig::default();

    assert_eq!(config.metrics_port, 9090);
    assert_eq!(config.health_port, 8080);
    assert!(config.enable_metrics);
}

#[cfg(feature = "observability")]
#[test]
fn test_observability_config_customization() {
    use things3_core::ObservabilityConfig;

    let config = ObservabilityConfig {
        log_level: "debug".to_string(),
        json_logs: true,
        metrics_port: 9091,
        ..ObservabilityConfig::default()
    };

    assert_eq!(config.log_level, "debug");
    assert!(config.json_logs);
    assert_eq!(config.metrics_port, 9091);
}

#[cfg(feature = "observability")]
#[test]
fn test_health_status_structure() {
    use std::collections::HashMap;
    use things3_core::HealthStatus;

    let status = HealthStatus {
        status: "healthy".to_string(),
        timestamp: chrono::Utc::now(),
        version: "1.0.0".to_string(),
        uptime: std::time::Duration::from_secs(100),
        checks: HashMap::new(),
    };

    assert_eq!(status.status, "healthy");
    assert_eq!(status.version, "1.0.0");
    assert_eq!(status.uptime.as_secs(), 100);
}

#[cfg(feature = "observability")]
#[test]
fn test_check_result_structure() {
    use things3_core::CheckResult;

    let check = CheckResult {
        status: "pass".to_string(),
        message: Some("All systems operational".to_string()),
        duration_ms: 100,
    };

    assert_eq!(check.status, "pass");
    assert!(check.message.is_some());
    assert_eq!(check.duration_ms, 100);
}