boh 0.1.1

A holder of many things
Documentation 
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

use anyhow::Context as _;

#[derive(clap::Subcommand)]
pub enum Subcommand {
    Restart { resource: String },
}

#[derive(clap::Parser)]
pub struct Args {
    #[clap(subcommand)]
    cmd: Subcommand,
}

fn parse_resource(resource: &str) -> anyhow::Result<(&str, &str)> {
    let ind = resource
        .find('/')
        .context("resource must be specified as <kind>/<name>")?;

    let kind = match &resource[..ind] {
        "deployment" => "deployments",
        other => anyhow::bail!("unknown resource kind '{other}'"),
    };

    anyhow::ensure!(
        ind + 1 < resource.len(),
        "the resource name was not provided"
    );

    Ok((kind, &resource[ind + 1..]))
}

pub(super) async fn run(client: super::K8sClient, args: Args) -> anyhow::Result<()> {
    match args.cmd {
        Subcommand::Restart { resource } => {
            let patch = serde_json::json!({
              "spec": {
                "template": {
                  "metadata": {
                    "annotations": {
                      "boh.kubernetes.io/restartedAt": time::OffsetDateTime::now_utc().format(&time::format_description::well_known::Rfc3339).context("failed to format timestamp")?,
                    }
                  }
                }
              }
            });

            let (kind, name) = parse_resource(&resource)?;

            let url = client.make_url(kind, name);

            let res = client
                .client
                .patch(url)
                .header(http::header::ACCEPT, "application/json")
                .header(http::header::CONTENT_TYPE, "application/merge-patch+json")
                .body(serde_json::to_vec(&patch).context("failed to write serialize json patch")?)
                .send()
                .await?;

            let code = res.status();
            let body = res.bytes().await?;

            if !code.is_success() {
                if let Ok(err_str) = String::from_utf8(body.into()) {
                    anyhow::bail!(err_str);
                } else {
                    anyhow::bail!("failed to retrieve error for {code}");
                }
            }

            use std::io::Write;
            let _ = std::io::stdout().write(&body);
        }
    }

    Ok(())
}