rustploy 0.1.13

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
53
54

//! `Command::RecentDeployments`: deployments recentes de todos os serviços, com
//! o Live velho corrigido e nomes resolvidos.

use crate::bootstrap::state::AppState;
use shared::{DeploymentSummary, Response as RpResponse};
use std::collections::HashMap;

pub async fn handle(state: AppState, limit: usize) -> RpResponse {
    let deps = match crate::store::deployments::list_recent(&state.db, limit).await {
        Ok(d) => d,
        Err(e) => return RpResponse::err("DatabaseError", e.to_string()),
    };

    // Reconcile before building summaries — corrects stale Live entries in DB.
    let deps = super::reconcile::fix_stale_live(&state, deps).await;

    // Resolve service and project names with a small cache to avoid N+1 queries.
    let mut svc_cache: HashMap<String, (String, String)> = HashMap::new(); // id → (name, project_id)
    let mut proj_cache: HashMap<String, String> = HashMap::new(); // id → name
    let mut summaries = Vec::with_capacity(deps.len());

    for dep in deps {
        let (service_name, project_name) = if let Some(cached) = svc_cache.get(&dep.service_id) {
            cached.clone()
        } else {
            let (sname, pid) = match crate::store::services::get(&state.db, &dep.service_id).await {
                Ok(Some(s)) => (s.spec.name.clone(), s.spec.project_id.clone()),
                _ => (dep.service_id.clone(), String::new()),
            };
            let pname = if pid.is_empty() {
                String::new()
            } else if let Some(p) = proj_cache.get(&pid) {
                p.clone()
            } else {
                let name = match crate::store::projects::get(&state.db, &pid).await {
                    Ok(Some(p)) => p.name.clone(),
                    _ => pid.clone(),
                };
                proj_cache.insert(pid.clone(), name.clone());
                name
            };
            svc_cache.insert(dep.service_id.clone(), (sname.clone(), pname.clone()));
            (sname, pname)
        };

        summaries.push(DeploymentSummary {
            deployment: dep,
            service_name,
            project_name,
        });
    }

    RpResponse::DeploymentSummaries(summaries)
}