inapt 0.3.3

A minimal Debian/Ubuntu APT repository proxy written in Rust. Exposes a valid APT repo structure over HTTP, sourcing .deb packages from GitHub Releases.
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

use axum::extract::State;
use axum::http::StatusCode;

use crate::adapter_http_server::{HealthCheck, ServerState};

/// Health check handler for load balancers and Kubernetes probes.
///
/// Returns 200 OK if all dependencies (database, etc.) are healthy.
/// Returns 503 Service Unavailable if any dependency check fails.
pub async fn handler<AR, APK, HC>(State(state): State<ServerState<AR, APK, HC>>) -> StatusCode
where
    AR: crate::domain::prelude::AptRepositoryReader + Clone,
    APK: crate::domain::prelude::ApkRepositoryReader + Clone,
    HC: HealthCheck + Clone,
{
    match state.health_checker.health_check().await {
        Ok(()) => StatusCode::OK,
        Err(err) => {
            tracing::warn!(error = ?err, "health check failed");
            StatusCode::SERVICE_UNAVAILABLE
        }
    }
}

#[cfg(test)]
mod tests {
    use axum::extract::State;
    use axum::http::StatusCode;

    use crate::adapter_http_server::{HealthCheck, ServerState};
    use crate::domain::prelude::{MockApkRepositoryService, MockAptRepositoryService};

    #[derive(Clone)]
    struct MockHealthyChecker;

    impl HealthCheck for MockHealthyChecker {
        async fn health_check(&self) -> anyhow::Result<()> {
            Ok(())
        }
    }

    #[derive(Clone)]
    struct MockUnhealthyChecker;

    impl HealthCheck for MockUnhealthyChecker {
        async fn health_check(&self) -> anyhow::Result<()> {
            Err(anyhow::anyhow!("database connection failed"))
        }
    }

    #[tokio::test]
    async fn should_return_ok_when_healthy() {
        let apt_repository = MockAptRepositoryService::new();
        let state = ServerState {
            apt_repository,
            apk_repository: MockApkRepositoryService::new(),
            health_checker: MockHealthyChecker,
        };
        let result = super::handler(State(state)).await;
        assert_eq!(result, StatusCode::OK);
    }

    #[tokio::test]
    async fn should_return_service_unavailable_when_unhealthy() {
        let apt_repository = MockAptRepositoryService::new();
        let state = ServerState {
            apt_repository,
            apk_repository: MockApkRepositoryService::new(),
            health_checker: MockUnhealthyChecker,
        };
        let result = super::handler(State(state)).await;
        assert_eq!(result, StatusCode::SERVICE_UNAVAILABLE);
    }
}