railwayapp 4.59.0

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

use std::time::Duration;

use super::PatchEntry;
use crate::{
    GQLClient,
    config::Configs,
    consts::TICK_STRING,
    controllers::{
        config::environment::ServiceInstance,
        regions::{
            convert_hashmap_to_map, fetch_regions_for_project, prompt_for_regions_with_data,
        },
    },
};
use anyhow::Result;
use futures::executor::block_on;
use serde_json::Value;

pub fn parse_interactive(
    service_id: &str,
    _service_name: &str,
    existing: Option<&ServiceInstance>,
) -> Result<Vec<PatchEntry>> {
    let configs = Configs::new()?;
    let client = GQLClient::new_authorized(&configs)?;

    // Show spinner while loading regions
    let spinner = indicatif::ProgressBar::new_spinner()
        .with_style(
            indicatif::ProgressStyle::default_spinner()
                .tick_chars(TICK_STRING)
                .template("{spinner:.green} {msg}")?,
        )
        .with_message("Loading regions...");
    spinner.enable_steady_tick(Duration::from_millis(100));

    // Fetch regions (async, with spinner)
    let linked_project = block_on(configs.get_linked_project())?;
    let regions = block_on(fetch_regions_for_project(
        &client,
        &configs,
        Some(&linked_project.project),
    ))?;

    // Clear spinner before prompting
    spinner.finish_and_clear();

    // Extract existing multi-region config if available, otherwise use empty
    let existing_config = existing
        .and_then(|e| e.deploy.as_ref())
        .and_then(|d| d.multi_region_config.as_ref())
        .map(|config| serde_json::to_value(config).unwrap_or(Value::Object(serde_json::Map::new())))
        .unwrap_or_else(|| Value::Object(serde_json::Map::new()));

    // Prompt for regions (sync, no spinner)
    let updated = prompt_for_regions_with_data(regions, &existing_config)?;

    if updated.is_empty() {
        return Ok(vec![]);
    }

    let region_map = convert_hashmap_to_map(updated);

    // Convert to patch entries
    let mut entries: Vec<PatchEntry> = Vec::new();
    let base_path = format!("services.{}.deploy.multiRegionConfig", service_id);

    for (region, config) in region_map {
        entries.push((format!("{}.{}", base_path, region), config));
    }

    Ok(entries)
}