bestool 1.6.1

BES Deployment tooling
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
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

use std::collections::HashMap;

use miette::{IntoDiagnostic, Result, WrapErr};
use reqwest::Url;
use tera::Tera;
use tracing::debug;

use crate::actions::tamanu::alerts::{
	InternalContext, definition::AlertDefinition, templates::TemplateField,
};

/// Parameters for sending a Slack alert
pub struct SlackSendParams<'a> {
	pub alert: &'a AlertDefinition,
	pub ctx: &'a InternalContext,
	pub subject: &'a str,
	pub body: &'a str,
	pub tera: &'a Tera,
	pub tera_ctx: &'a tera::Context,
	pub dry_run: bool,
}

#[derive(serde::Deserialize, Clone, Debug)]
#[serde(rename_all = "snake_case")]
pub struct TargetSlack {
	pub webhook: Url,

	#[serde(default = "SlackField::default_set")]
	pub fields: Vec<SlackField>,
}

#[derive(serde::Deserialize, Clone, Debug)]
#[serde(untagged, rename_all = "snake_case")]
pub enum SlackField {
	Fixed { name: String, value: String },
	Field { name: String, field: TemplateField },
}

impl SlackField {
	pub fn default_set() -> Vec<Self> {
		vec![
			Self::Field {
				name: "hostname".into(),
				field: TemplateField::Hostname,
			},
			Self::Field {
				name: "filename".into(),
				field: TemplateField::Filename,
			},
			Self::Field {
				name: "subject".into(),
				field: TemplateField::Subject,
			},
			Self::Field {
				name: "message".into(),
				field: TemplateField::Body,
			},
		]
	}
}

impl TargetSlack {
	pub async fn send(&self, params: SlackSendParams<'_>) -> Result<()> {
		let SlackSendParams {
			alert,
			ctx,
			subject,
			body,
			tera,
			tera_ctx,
			dry_run,
		} = params;
		if dry_run {
			println!("-------------------------------");
			println!("Alert: {}", alert.file.display());
			println!("Recipients: slack");
			println!("Subject: {subject}");
			println!("Body: {body}");
			return Ok(());
		}

		let payload: HashMap<&String, String> = self
			.fields
			.iter()
			.map(|field| match field {
				SlackField::Fixed { name, value } => (name, value.clone()),
				SlackField::Field { name, field } => (
					name,
					tera.render(field.as_str(), tera_ctx)
						.ok()
						.or_else(|| {
							tera_ctx.get(field.as_str()).map(|v| match v.as_str() {
								Some(t) => t.to_owned(),
								None => v.to_string(),
							})
						})
						.unwrap_or_default(),
				),
			})
			.collect();

		debug!(?self.webhook, ?payload, "posting to slack webhook");
		ctx.http_client
			.post(self.webhook.clone())
			.json(&payload)
			.send()
			.await
			.into_diagnostic()
			.wrap_err("posting to slack webhook")
			.map(drop)
	}
}