rustploy 0.1.35

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

//! `Command::LogsHistory`: o log de runtime **persistido** do serviço (sobrevive à troca de
//! container no deploy e ao rollback). Plano: `docs/plano-log-de-runtime-persistido.md`.

use crate::bootstrap::state::AppState;
use chrono::{DateTime, Utc};
use shared::Response as RpResponse;

pub async fn handle(
    state: AppState,
    service_id: String,
    before: Option<DateTime<Utc>>,
    limit: usize,
    container_id: Option<String>,
) -> RpResponse {
    match crate::store::services::get(&state.db, &service_id).await {
        Ok(Some(_)) => {}
        Ok(None) => return RpResponse::err("NotFound", "serviço não encontrado"),
        Err(e) => return RpResponse::err("DatabaseError", e.to_string()),
    }
    let Some(store) = crate::platform::log_store::global() else {
        return RpResponse::err(
            "LogsDisabled",
            "o log persistido está desligado ([logs] enabled = false no config.toml)",
        );
    };
    let read = tokio::task::spawn_blocking(move || {
        store.read(&service_id, before, limit, container_id.as_deref())
    })
    .await;
    match read {
        Ok((entries, next_before)) => RpResponse::LogsHistory {
            entries,
            next_before,
        },
        Err(e) => RpResponse::err("InternalError", e.to_string()),
    }
}