tovuk 0.1.99

Deploy Rust workers, static frontends, and full-stack services to Tovuk.
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

use super::{
    super::{
        args::CliOptions,
        errors::{Result, print_json},
        project::nested_string,
        project_kind::ProjectKind,
    },
    types::WorkspaceDeployResult,
};
use serde_json::{Value, json};
use std::path::Path;

pub(super) fn print_deploy_result(response: &Value, cli: &CliOptions) -> Result<()> {
    if cli.output.json {
        return print_json(response);
    }
    if let Some(line) = deploy_status_line(response) {
        println!("{line}");
    }
    println!("service {}", service_field(response, "id"));
    println!("url {}", service_field(response, "url"));
    println!(
        "next tovuk logs --service {}",
        service_field(response, "id")
    );
    Ok(())
}

pub(super) fn print_workspace_deploy_results(
    project_dir: &Path,
    results: &[WorkspaceDeployResult],
    cli: &CliOptions,
) -> Result<()> {
    if cli.output.json {
        let deploys = results
            .iter()
            .map(|result| {
                json!({
                    "path": result.project.relative,
                    "kind": result.project.kind.map_or("invalid", ProjectKind::as_str),
                    "service": result.response.get("service").cloned().unwrap_or(Value::Null),
                    "build_job": result.response.get("build_job").cloned().unwrap_or(Value::Null),
                    "final_build": result.final_build.clone().unwrap_or(Value::Null),
                })
            })
            .collect::<Vec<_>>();
        return print_json(
            &json!({ "workspace": project_dir.display().to_string(), "deploys": deploys }),
        );
    }
    if let Some(first) = results.first() {
        println!(
            "next tovuk logs --service {}",
            service_field(&first.response, "id")
        );
    }
    Ok(())
}

fn service_field(response: &Value, field: &str) -> String {
    nested_string(response, &["service", field])
}

fn deploy_status_line(response: &Value) -> Option<String> {
    let build_id = nested_string(response, &["build_job", "id"]);
    let final_status = nested_string(response, &["final_build", "status"]);
    if !final_status.is_empty() {
        return None;
    }
    Some(format!("queued {build_id}"))
}

#[cfg(test)]
mod tests {
    use super::deploy_status_line;
    use serde_json::json;

    #[test]
    fn deploy_status_line_reports_queued_without_wait_result() {
        assert_eq!(
            deploy_status_line(&json!({ "build_job": { "id": "job_1" } })),
            Some("queued job_1".to_owned())
        );
    }

    #[test]
    fn deploy_status_line_omits_duplicate_final_build_after_wait() {
        assert_eq!(
            deploy_status_line(&json!({
                "build_job": { "id": "job_1" },
                "final_build": { "id": "job_1", "status": "succeeded" }
            })),
            None
        );
    }
}