forklaunch 1.27.0

Launch faster with forklaunch
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 std::io::Write;

use anyhow::{Context, Result, bail};
use clap::{Arg, ArgMatches, Command};
use termcolor::{Color, ColorChoice, ColorSpec, StandardStream, WriteColor};

use crate::{
    CliCommand,
    constants::get_observability_api_url,
    core::{command::command, http_client::put},
};

/// `notifiers update` — the route existed and NO surface called it: the CLI
/// could create and delete a notifier config, the dashboard could list them,
/// and nothing could edit one. Rotating a Slack webhook meant delete + create.
#[derive(Debug)]
pub(crate) struct UpdateCommand;

impl UpdateCommand {
    pub(crate) fn new() -> Self {
        Self
    }
}

impl CliCommand for UpdateCommand {
    fn command(&self) -> Command {
        command("update", "Update an existing notifier config")
            .arg(
                Arg::new("id")
                    .required(true)
                    .help("The notifier config ID to update"),
            )
            .arg(
                Arg::new("slack_webhook_url")
                    .long("slack-webhook")
                    .help("New Slack incoming webhook URL"),
            )
            .arg(
                Arg::new("email")
                    .long("email")
                    .help("New email address to notify"),
            )
            .arg(
                Arg::new("service_name")
                    .long("service-name")
                    .help("Re-scope this config to a different service name"),
            )
    }

    fn handler(&self, matches: &ArgMatches) -> Result<()> {
        let id = matches
            .get_one::<String>("id")
            .context("notifier config id is required")?;
        let slack = matches.get_one::<String>("slack_webhook_url");
        let email = matches.get_one::<String>("email");
        let service_name = matches.get_one::<String>("service_name");

        if slack.is_none() && email.is_none() && service_name.is_none() {
            bail!(
                "Nothing to update. Pass at least one of --slack-webhook, --email or --service-name."
            );
        }

        let mut body = serde_json::json!({});
        if let Some(s) = service_name {
            body["serviceName"] = serde_json::Value::String(s.clone());
        }
        if let Some(s) = slack {
            body["slackWebhookUrl"] = serde_json::Value::String(s.clone());
        }
        if let Some(e) = email {
            body["email"] = serde_json::Value::String(e.clone());
        }

        let url = format!(
            "{}/notifier-configs/{}",
            get_observability_api_url(),
            urlencoding::encode(id)
        );
        let response = put(&url, body).with_context(|| "Failed to reach observability API")?;

        let status = response.status();
        if !status.is_success() {
            bail!(
                "Failed to update notifier config ({}): {}",
                status,
                response.text().unwrap_or_default()
            );
        }

        let mut stdout = StandardStream::stdout(ColorChoice::Always);
        stdout.set_color(ColorSpec::new().set_fg(Some(Color::Green)).set_bold(true))?;
        write!(stdout, "  Updated")?;
        stdout.reset()?;
        writeln!(stdout, "  notifier config {}", id)?;

        Ok(())
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    fn cmd() -> Command {
        UpdateCommand::new().command().version("0.0.0-test")
    }

    #[test]
    fn command_definition_is_valid() {
        cmd().debug_assert();
    }

    #[test]
    fn requires_an_id() {
        assert!(cmd().try_get_matches_from(["update"]).is_err());
        assert!(
            cmd()
                .try_get_matches_from(["update", "cfg-1", "--email", "a@b.c"])
                .is_ok()
        );
    }
}