fundaia 0.53.0

Command line for the Fundaia deployment platform: projects, services, variables, deployments, logs and metrics
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
91
92
93
94
95
96
97
98
99

use anyhow::Result;
use owo_colors::OwoColorize;

use crate::api::client::ApiClient;
use crate::output::Format;
use crate::render::sanitise;
use crate::render::theme;

pub async fn exec(
    client: &ApiClient,
    project_reference: &str,
    service_reference: &str,
    command: &[String],
    format: Format,
) -> Result<()> {
    let (_, service) = client.locate(project_reference, service_reference).await?;
    let answer = client
        .run_in_service(&service.id, &command.join(" "))
        .await?;

    if format.answered_in_json(&answer.raw) {
        return Ok(());
    }

    let run = &answer.body.run;
    if !run.stdout.is_empty() {
        print!("{}", sanitise::with_colour(&run.stdout));
        if !run.stdout.ends_with('\n') {
            println!();
        }
    }
    if !run.stderr.is_empty() {
        eprint!("{}", sanitise::with_colour(&run.stderr));
        if !run.stderr.ends_with('\n') {
            eprintln!();
        }
    }

    let ended = if run.timed_out {
        "tiempo agotado (60 s)".to_owned()
    } else {
        format!("exit {}", run.exit_code)
    };
    let seconds = run.duration_millis as f64 / 1000.0;
    if run.exit_code == 0 && !run.timed_out {
        eprintln!(
            "  {}",
            format!("{ended} · {seconds:.1} s").style(theme::muted())
        );
    } else {
        eprintln!(
            "  {} {}",
            theme::CROSS.style(theme::danger()),
            format!("{ended} · {seconds:.1} s").style(theme::danger())
        );
    }
    if run.truncated {
        eprintln!(
            "  {}",
            "Salida recortada a 64 KB por flujo.".style(theme::warning())
        );
    }
    Ok(())
}

pub async fn pull(
    client: &ApiClient,
    project_reference: &str,
    service_reference: &str,
    format: Format,
) -> Result<()> {
    let (_, service) = client.locate(project_reference, service_reference).await?;
    let answer = client.pull_image(&service.id).await?;

    if format.answered_in_json(&answer.raw) {
        return Ok(());
    }

    let check = &answer.body.check;
    let image = sanitise::plain(&check.image);
    match check.outcome.as_str() {
        "updating" => println!(
            "  {} Hay una imagen nueva de {}: desplegándola. `fundaia watch` la sigue.",
            theme::CHECK.style(theme::success()),
            image.style(theme::strong())
        ),
        "deploying" => println!(
            "  {} Ya hay un despliegue en marcha; baja {} por su cuenta.",
            theme::PENDING.style(theme::muted()),
            image.style(theme::strong())
        ),
        _ => println!(
            "  {} {} ya es la última imagen de su etiqueta.",
            theme::CHECK.style(theme::success()),
            image.style(theme::strong())
        ),
    }
    Ok(())
}