railwayapp 4.10.1

Interact with Railway via CLI
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
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123

use crate::{
    queries::project::{ProjectProject, ProjectProjectEnvironmentsEdges},
    util::prompt::{fake_select, prompt_confirm_with_default},
};
use is_terminal::IsTerminal;

use super::*;

pub async fn push(
    environment: &ProjectProjectEnvironmentsEdges,
    project: ProjectProject,
    args: Push,
) -> Result<()> {
    let (id, path) = common::get_function_from_path(args.path.clone())?;
    let service = common::find_service(&project, environment, &id)
        .ok_or_else(|| anyhow::anyhow!("Couldn't find service"))?;
    let terminal = std::io::stdout().is_terminal();

    if should_watch(args, terminal)? {
        let info = new::format_function_info(
            &project,
            environment,
            &domain(&service),
            service.service_name,
            service.service_id,
            path.as_path(),
            service.cron_schedule,
        )?;
        new::watch_for_file_changes(project, id.clone(), environment, info, path, terminal).await?
    } else {
        println!("Updating function {}", service.service_name.blue().bold());

        let configs = Configs::new()?;
        let client = GQLClient::new_authorized(&configs)?;
        let new_cmd = common::get_start_cmd(&path)?;

        let diff_stats = common::calculate_diff(
            &common::extract_function_content(&service)?,
            &String::from_utf8(std::fs::read(&path)?)?,
        );

        update_function(&client, &configs, &environment.node.id, &id, new_cmd).await?;
        deploy_function(&client, &configs, &environment.node.id, &id).await?;

        println!("Function updated {diff_stats}");
    }
    Ok(())
}

async fn update_function(
    client: &reqwest::Client,
    configs: &Configs,
    environment_id: &str,
    service_id: &str,
    start_command: String,
) -> Result<()> {
    post_graphql_skip_none::<mutations::FunctionUpdate, _>(
        client,
        configs.get_backboard(),
        mutations::function_update::Variables {
            environment_id: environment_id.to_string(),
            service_id: service_id.to_string(),
            start_command: Some(start_command),
            cron_schedule: None,
            sleep_application: None,
        },
    )
    .await?;
    Ok(())
}

async fn deploy_function(
    client: &reqwest::Client,
    configs: &Configs,
    environment_id: &str,
    service_id: &str,
) -> Result<()> {
    post_graphql::<mutations::ServiceInstanceDeploy, _>(
        client,
        configs.get_backboard(),
        mutations::service_instance_deploy::Variables {
            environment_id: environment_id.to_string(),
            service_id: service_id.to_string(),
        },
    )
    .await?;
    Ok(())
}

fn should_watch(args: Push, terminal: bool) -> Result<bool> {
    Ok(if let Some(watch) = args.watch {
        fake_select(
            "Do you want to watch for changes and automatically redeploy?",
            if watch { "Yes" } else { "No" },
        );
        watch
    } else if terminal {
        prompt_confirm_with_default(
            "Do you want to watch for changes and automatically redeploy?",
            true,
        )?
    } else {
        false
    })
}

fn domain(
    service: &queries::project::ProjectProjectServicesEdgesNodeServiceInstancesEdgesNode,
) -> Option<String> {
    let mut domains = service
        .domains
        .custom_domains
        .iter()
        .map(|f| f.domain.clone())
        .chain(
            service
                .domains
                .service_domains
                .iter()
                .map(|f| f.domain.clone()),
        );
    domains.next()
}