rustploy 0.1.19

Rustploy PaaS daemon — lightweight self-hosted deployment platform
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

//! `Command::ServiceCreate`: cria um serviço, alocando a porta externa
//! automática e liberando-a no firewall.

use crate::features::services::ServicesContext;
use shared::{Response as RpResponse, ServiceSource, ServiceSpec};
use tracing::info;

pub async fn handle(state: ServicesContext, mut spec: ServiceSpec) -> RpResponse {
    if let Some(reason) = crate::platform::env_validation::validate(&spec.env_vars) {
        return RpResponse::err("InvalidInput", reason);
    }
    // Sentinela 0 → aloca porta externa da faixa configurada; porta manual
    // duplicada → erro antes de persistir.
    if let Err(e) =
        crate::features::ingress::external_ports::resolve_host_port(&state.db, &mut spec, None)
            .await
    {
        return RpResponse::err("PortAllocationError", e);
    }

    info!(
        name = %spec.name,
        project_id = %spec.project_id,
        source = match &spec.source {
            ServiceSource::Registry { image } => format!("registry:{image}"),
            ServiceSource::Git(g) => format!("git:{}", g.url),
            ServiceSource::Archive(a) => format!("archive:{}", a.archive_id),
            ServiceSource::Compose(c) => format!("compose:{}", c.content),
        },
        port = spec.port,
        env_vars = spec.env_vars.len(),
        volumes = spec.volumes.len(),
        "service_create: criando serviço"
    );

    match crate::store::services::create(&state.db, spec).await {
        Ok(s) => {
            info!(service_id = %s.id, name = %s.spec.name, "service_create: serviço criado no banco");
            if let Some(port) = s.spec.host_port {
                crate::features::ingress::firewall::ensure_allowed_bg(port);
            }
            RpResponse::Service(Box::new(s))
        }
        Err(e) => {
            tracing::error!(error = %e, "service_create: falha ao criar serviço");
            RpResponse::err(
                "DatabaseError",
                crate::platform::errors::humanize_db_error(&e, "serviço"),
            )
        }
    }
}