inapt 0.1.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
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90

use anyhow::Context;
use tower_http::trace::TraceLayer;

mod handler;

const DEFAULT_ADDRESS: std::net::IpAddr = std::net::IpAddr::V4(std::net::Ipv4Addr::UNSPECIFIED);
const DEFAULT_PORT: u16 = 3000;

pub struct Config {
    address: std::net::IpAddr,
    port: u16,
}

impl Config {
    pub fn from_env() -> anyhow::Result<Config> {
        Ok(Self {
            address: crate::with_env_as_or("ADDRESS", DEFAULT_ADDRESS)?,
            port: crate::with_env_as_or("PORT", DEFAULT_PORT)?,
        })
    }

    pub fn builder<AR>(self) -> anyhow::Result<ServerBuilder<AR>> {
        Ok(ServerBuilder {
            address: std::net::SocketAddr::from((self.address, self.port)),
            apt_repository: None,
        })
    }
}

#[derive(Debug)]
pub struct ServerBuilder<AR> {
    address: std::net::SocketAddr,
    apt_repository: Option<AR>,
}

impl<AR> ServerBuilder<AR>
where
    AR: Clone + crate::domain::prelude::AptRepositoryReader,
{
    pub fn with_apt_repository(self, value: AR) -> Self {
        Self {
            address: self.address,
            apt_repository: Some(value),
        }
    }
}

impl<AR> ServerBuilder<AR>
where
    AR: Clone + crate::domain::prelude::AptRepositoryReader,
{
    pub fn build(self) -> anyhow::Result<Server> {
        let router = handler::build()
            .layer(TraceLayer::new_for_http())
            .with_state(ServerState {
                apt_repository: self
                    .apt_repository
                    .ok_or_else(|| anyhow::anyhow!("apt_repository service not defined"))?,
            });
        Ok(Server {
            address: self.address,
            router,
        })
    }
}

#[derive(Debug)]
pub struct Server {
    address: std::net::SocketAddr,
    router: axum::Router,
}

impl Server {
    pub async fn run(self) -> anyhow::Result<()> {
        let listener = tokio::net::TcpListener::bind(self.address).await?;
        tracing::info!(address = ?self.address, "starting server");
        axum::serve(listener, self.router)
            .await
            .context("server crashed")
    }
}

#[derive(Clone)]
struct ServerState<AR>
where
    AR: Clone + crate::domain::prelude::AptRepositoryReader,
{
    #[allow(unused, reason = "early")]
    apt_repository: AR,
}