rustploy 0.1.21

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

//! Tabela `build_log`: linhas do log de build de cada deployment.

use super::Db;
use anyhow::Result;
use chrono::{DateTime, Utc};
use shared::protocol::{BuildLogLine, LogStream};

pub async fn append(
    db: &Db,
    deployment_id: &str,
    line: &str,
    timestamp: DateTime<Utc>,
) -> Result<()> {
    sqlx::query("INSERT INTO build_log (deployment_id, line, ts) VALUES (?, ?, ?)")
        .bind(deployment_id)
        .bind(line)
        .bind(timestamp)
        .execute(db.pool())
        .await?;
    Ok(())
}

pub async fn delete_for_deployment(db: &Db, deployment_id: &str) -> Result<()> {
    sqlx::query("DELETE FROM build_log WHERE deployment_id = ?")
        .bind(deployment_id)
        .execute(db.pool())
        .await?;
    Ok(())
}

pub async fn get_for_deployment(db: &Db, deployment_id: &str) -> Result<Vec<BuildLogLine>> {
    let rows = sqlx::query_as::<_, (String, DateTime<Utc>)>(
        "SELECT line, ts FROM build_log WHERE deployment_id = ? ORDER BY ts ASC",
    )
    .bind(deployment_id)
    .fetch_all(db.pool())
    .await?;
    Ok(rows
        .into_iter()
        .map(|(line, ts)| BuildLogLine {
            stream: LogStream::Stdout,
            line,
            timestamp: ts,
        })
        .collect())
}