diff --git a/Cargo.lock b/Cargo.lock index cebc85a..50e9aa1 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -18,6 +18,18 @@ version = "2.0.1" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "320119579fcad9c21884f5c4861d16174d0e06250625266f50fe6898340abefa" +[[package]] +name = "ahash" +version = "0.8.12" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "5a15f179cd60c4584b8a8c596927aadc462e27f2ca70c04e0071964a73ba7a75" +dependencies = [ + "cfg-if", + "once_cell", + "version_check", + "zerocopy", +] + [[package]] name = "aho-corasick" version = "1.1.3" @@ -130,6 +142,12 @@ dependencies = [ "windows-link", ] +[[package]] +name = "base64" +version = "0.22.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "72b3254f16251a8381aa12e40e3c4d2f0199f8c6508fbecb9d91f575e0fbb8c6" + [[package]] name = "bitflags" version = "1.3.2" @@ -202,6 +220,16 @@ dependencies = [ "windows-link", ] +[[package]] +name = "chumsky" +version = "0.9.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "8eebd66744a15ded14960ab4ccdbfb51ad3b81f51f3f04a80adac98c985396c9" +dependencies = [ + "hashbrown 0.14.5", + "stacker", +] + [[package]] name = "clap" version = "4.5.48" @@ -274,6 +302,7 @@ dependencies = [ "cm-dashboard-shared", "futures", "gethostname", + "lettre", "rand", "serde", "serde_json", @@ -408,18 +437,51 @@ dependencies = [ "walkdir", ] +[[package]] +name = "displaydoc" +version = "0.2.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "97369cbbc041bc366949bc74d34658d6cda5621039731c6310521892a3a20ae0" +dependencies = [ + "proc-macro2", + "quote", + "syn", +] + [[package]] name = "either" version = "1.15.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "48c757948c5ede0e46177b7add2e67155f70e33c07fea8284df6576da70b3719" +[[package]] +name = "email-encoding" +version = "0.4.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "9298e6504d9b9e780ed3f7dfd43a61be8cd0e09eb07f7706a945b0072b6670b6" +dependencies = [ + "base64", + "memchr", +] + +[[package]] +name = "email_address" +version = "0.2.9" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e079f19b08ca6239f47f8ba8509c11cf3ea30095831f7fed61441475edd8c449" + [[package]] name = "equivalent" version = "1.0.2" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "877a4ace8713b0bcf2a4e7eec82529c029f1d0619886d18145fea96c3ffe5c0f" +[[package]] +name = "fastrand" +version = "2.3.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "37909eebbb50d72f9059c3b6d82c0463f2ff062c9e95845c43a6c9c0355411be" + [[package]] name = "find-msvc-tools" version = "0.1.4" @@ -432,6 +494,15 @@ version = "0.1.5" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "d9c4f5dac5e15c24eb999c26181a6ca40b39fe946cbe4c263c7209467bc83af2" +[[package]] +name = "form_urlencoded" +version = "1.2.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "cb4cb245038516f5f85277875cdaa4f7d2c9a0fa0468de06ed190163b1581fcf" +dependencies = [ + "percent-encoding", +] + [[package]] name = "futures" version = "0.3.31" @@ -560,6 +631,16 @@ version = "0.32.3" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "e629b9b98ef3dd8afe6ca2bd0f89306cec16d43d907889945bc5d6687f2f13c7" +[[package]] +name = "hashbrown" +version = "0.14.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e5274423e17b7c9fc20b6e7e208532f9b19825d82dfd615708b70edd83df41f1" +dependencies = [ + "ahash", + "allocator-api2", +] + [[package]] name = "hashbrown" version = "0.15.5" @@ -589,6 +670,12 @@ version = "0.5.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "2304e00983f87ffb38b55b444b5e3b60a884b5d30c0fca7d82fe33449bbe55ea" +[[package]] +name = "httpdate" +version = "1.0.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "df3b46402a9d5adb4c86a0cf463f42e19994e3ee891101b1841f30a545cb49a9" + [[package]] name = "iana-time-zone" version = "0.1.64" @@ -613,6 +700,113 @@ dependencies = [ "cc", ] +[[package]] +name = "icu_collections" +version = "2.0.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "200072f5d0e3614556f94a9930d5dc3e0662a652823904c3a75dc3b0af7fee47" +dependencies = [ + "displaydoc", + "potential_utf", + "yoke", + "zerofrom", + "zerovec", +] + +[[package]] +name = "icu_locale_core" +version = "2.0.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0cde2700ccaed3872079a65fb1a78f6c0a36c91570f28755dda67bc8f7d9f00a" +dependencies = [ + "displaydoc", + "litemap", + "tinystr", + "writeable", + "zerovec", +] + +[[package]] +name = "icu_normalizer" +version = "2.0.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "436880e8e18df4d7bbc06d58432329d6458cc84531f7ac5f024e93deadb37979" +dependencies = [ + "displaydoc", + "icu_collections", + "icu_normalizer_data", + "icu_properties", + "icu_provider", + "smallvec", + "zerovec", +] + +[[package]] +name = "icu_normalizer_data" +version = "2.0.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "00210d6893afc98edb752b664b8890f0ef174c8adbb8d0be9710fa66fbbf72d3" + +[[package]] +name = "icu_properties" +version = "2.0.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "016c619c1eeb94efb86809b015c58f479963de65bdb6253345c1a1276f22e32b" +dependencies = [ + "displaydoc", + "icu_collections", + "icu_locale_core", + "icu_properties_data", + "icu_provider", + "potential_utf", + "zerotrie", + "zerovec", +] + +[[package]] +name = "icu_properties_data" +version = "2.0.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "298459143998310acd25ffe6810ed544932242d3f07083eee1084d83a71bd632" + +[[package]] +name = "icu_provider" +version = "2.0.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "03c80da27b5f4187909049ee2d72f276f0d9f99a42c306bd0131ecfe04d8e5af" +dependencies = [ + "displaydoc", + "icu_locale_core", + "stable_deref_trait", + "tinystr", + "writeable", + "yoke", + "zerofrom", + "zerotrie", + "zerovec", +] + +[[package]] +name = "idna" +version = "1.1.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "3b0875f23caa03898994f6ddc501886a45c7d3d62d04d2d90788d47be1b1e4de" +dependencies = [ + "idna_adapter", + "smallvec", + "utf8_iter", +] + +[[package]] +name = "idna_adapter" +version = "1.2.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "3acae9609540aa318d1bc588455225fb2085b9ed0c4f6bd0d9d5bcd86f1a0344" +dependencies = [ + "icu_normalizer", + "icu_properties", +] + [[package]] name = "indexmap" version = "2.11.4" @@ -697,12 +891,40 @@ version = "1.5.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "bbd2bcb4c963f2ddae06a2efc7e9f3591312473c50c6685e1f298068316e66fe" +[[package]] +name = "lettre" +version = "0.11.19" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "9e13e10e8818f8b2a60f52cb127041d388b89f3a96a62be9ceaffa22262fef7f" +dependencies = [ + "base64", + "chumsky", + "email-encoding", + "email_address", + "fastrand", + "httpdate", + "idna", + "mime", + "nom", + "percent-encoding", + "quoted_printable", + "socket2", + "tokio", + "url", +] + [[package]] name = "libc" version = "0.2.177" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "2874a2af47a2325c2001a6e6fad9b16a53b802102b528163885171cf92b15976" +[[package]] +name = "litemap" +version = "0.8.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "241eaef5fd12c88705a01fc1066c48c4b36e0dd4377dcdc7ec3942cea7a69956" + [[package]] name = "lock_api" version = "0.4.14" @@ -742,6 +964,12 @@ version = "2.7.6" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "f52b00d39961fc5b2736ea853c9cc86238e165017a493d1d5c8eac6bdc4cc273" +[[package]] +name = "mime" +version = "0.3.17" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "6877bb514081ee2a7ff5ef9de3281f14a4dd4bceac4c09388074a6b5df8a139a" + [[package]] name = "miniz_oxide" version = "0.8.9" @@ -774,6 +1002,15 @@ dependencies = [ "windows-sys 0.59.0", ] +[[package]] +name = "nom" +version = "8.0.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "df9761775871bdef83bee530e60050f7e54b1105350d6884eb0fb4f46c2f9405" +dependencies = [ + "memchr", +] + [[package]] name = "nu-ansi-term" version = "0.50.3" @@ -848,6 +1085,12 @@ version = "1.0.15" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "57c0d7b74b563b49d38dae00a0c37d4d6de9b432382b2892f0574ddcae73fd0a" +[[package]] +name = "percent-encoding" +version = "2.3.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "9b4f627cb1b25917193a259e49bdad08f671f8d9708acfd5fe0a8c1455d87220" + [[package]] name = "pin-project-lite" version = "0.2.16" @@ -866,6 +1109,15 @@ version = "0.3.32" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "7edddbd0b52d732b21ad9a5fab5c704c14cd949e5e9a1ec5929a24fded1b904c" +[[package]] +name = "potential_utf" +version = "0.1.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "84df19adbe5b5a0782edcab45899906947ab039ccf4573713735ee7de1e6b08a" +dependencies = [ + "zerovec", +] + [[package]] name = "powerfmt" version = "0.2.0" @@ -890,6 +1142,15 @@ dependencies = [ "unicode-ident", ] +[[package]] +name = "psm" +version = "0.1.27" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e66fcd288453b748497d8fb18bccc83a16b0518e3906d4b8df0a8d42d93dbb1c" +dependencies = [ + "cc", +] + [[package]] name = "quote" version = "1.0.41" @@ -899,6 +1160,12 @@ dependencies = [ "proc-macro2", ] +[[package]] +name = "quoted_printable" +version = "0.5.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "640c9bd8497b02465aeef5375144c26062e0dcd5939dfcbb0f5db76cb8c17c73" + [[package]] name = "r-efi" version = "5.3.0" @@ -1151,6 +1418,25 @@ dependencies = [ "windows-sys 0.59.0", ] +[[package]] +name = "stable_deref_trait" +version = "1.2.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "6ce2be8dc25455e1f91df71bfa12ad37d7af1092ae736f3a6cd0e37bc7810596" + +[[package]] +name = "stacker" +version = "0.1.22" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e1f8b29fb42aafcea4edeeb6b2f2d7ecd0d969c48b4cf0d2e64aafc471dd6e59" +dependencies = [ + "cc", + "cfg-if", + "libc", + "psm", + "windows-sys 0.59.0", +] + [[package]] name = "strsim" version = "0.11.1" @@ -1190,6 +1476,17 @@ dependencies = [ "unicode-ident", ] +[[package]] +name = "synstructure" +version = "0.13.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "728a70f3dbaf5bab7f0c4b1ac8d7ae5ea60a4b5549c8a5914361c99147a709d2" +dependencies = [ + "proc-macro2", + "quote", + "syn", +] + [[package]] name = "system-deps" version = "6.2.2" @@ -1269,6 +1566,16 @@ dependencies = [ "time-core", ] +[[package]] +name = "tinystr" +version = "0.8.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "5d4f6d1145dcb577acf783d4e601bc1d76a13337bb54e6233add580b07344c8b" +dependencies = [ + "displaydoc", + "zerovec", +] + [[package]] name = "tokio" version = "1.47.1" @@ -1432,6 +1739,24 @@ version = "0.1.14" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "7dd6e30e90baa6f72411720665d41d89b9a3d039dc45b8faea1ddd07f617f6af" +[[package]] +name = "url" +version = "2.5.7" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "08bc136a29a3d1758e07a9cca267be308aeebf5cfd5a10f3f67ab2097683ef5b" +dependencies = [ + "form_urlencoded", + "idna", + "percent-encoding", + "serde", +] + +[[package]] +name = "utf8_iter" +version = "1.0.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "b6c140620e7ffbb22c2dee59cafe6084a59b5ffc27a8859a5f0d494b5d52b6be" + [[package]] name = "utf8parse" version = "0.2.2" @@ -1450,6 +1775,12 @@ version = "0.2.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "852e951cb7832cb45cb1169900d19760cfa39b82bc0ea9c0e5a14ae88411c98b" +[[package]] +name = "version_check" +version = "0.9.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0b928f33d975fc6ad9f86c8f283853ad26bdd5b10b7f1542aa2fa15e2289105a" + [[package]] name = "walkdir" version = "2.5.0" @@ -1870,6 +2201,36 @@ version = "0.46.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "f17a85883d4e6d00e8a97c586de764dabcc06133f7f1d55dce5cdc070ad7fe59" +[[package]] +name = "writeable" +version = "0.6.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ea2f10b9bb0928dfb1b42b65e1f9e36f7f54dbdf08457afefb38afcdec4fa2bb" + +[[package]] +name = "yoke" +version = "0.8.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "5f41bb01b8226ef4bfd589436a297c53d118f65921786300e427be8d487695cc" +dependencies = [ + "serde", + "stable_deref_trait", + "yoke-derive", + "zerofrom", +] + +[[package]] +name = "yoke-derive" +version = "0.8.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "38da3c9736e16c5d3c8c597a9aaa5d1fa565d0532ae05e27c24aa62fb32c0ab6" +dependencies = [ + "proc-macro2", + "quote", + "syn", + "synstructure", +] + [[package]] name = "zerocopy" version = "0.8.27" @@ -1890,6 +2251,27 @@ dependencies = [ "syn", ] +[[package]] +name = "zerofrom" +version = "0.1.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "50cc42e0333e05660c3587f3bf9d0478688e15d870fab3346451ce7f8c9fbea5" +dependencies = [ + "zerofrom-derive", +] + +[[package]] +name = "zerofrom-derive" +version = "0.1.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "d71e5d6e06ab090c67b5e44993ec16b72dcbaabc526db883a360057678b48502" +dependencies = [ + "proc-macro2", + "quote", + "syn", + "synstructure", +] + [[package]] name = "zeromq-src" version = "0.2.6+4.3.4" @@ -1900,6 +2282,39 @@ dependencies = [ "dircpy", ] +[[package]] +name = "zerotrie" +version = "0.2.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "36f0bbd478583f79edad978b407914f61b2972f5af6fa089686016be8f9af595" +dependencies = [ + "displaydoc", + "yoke", + "zerofrom", +] + +[[package]] +name = "zerovec" +version = "0.11.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e7aa2bd55086f1ab526693ecbe444205da57e25f4489879da80635a46d90e73b" +dependencies = [ + "yoke", + "zerofrom", + "zerovec-derive", +] + +[[package]] +name = "zerovec-derive" +version = "0.11.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "5b96237efa0c878c64bd89c436f661be4e46b2f3eff1ebb976f7ef2321d2f58f" +dependencies = [ + "proc-macro2", + "quote", + "syn", +] + [[package]] name = "zmq" version = "0.10.0" diff --git a/agent/Cargo.toml b/agent/Cargo.toml index 8424e6e..5193681 100644 --- a/agent/Cargo.toml +++ b/agent/Cargo.toml @@ -21,3 +21,4 @@ tokio = { version = "1.0", features = ["full", "process"] } futures = "0.3" rand = "0.8" gethostname = "0.4" +lettre = { version = "0.11", default-features = false, features = ["smtp-transport", "builder"] } diff --git a/agent/src/config.rs b/agent/src/config.rs index 5be68fb..8beb7b8 100644 --- a/agent/src/config.rs +++ b/agent/src/config.rs @@ -5,12 +5,15 @@ use tracing::info; use crate::collectors::CollectorError; use crate::discovery::AutoDiscovery; +use crate::notifications::NotificationConfig; #[derive(Debug, Clone, Deserialize, Serialize)] pub struct AgentConfig { pub agent: AgentSettings, pub zmq: ZmqSettings, pub collectors: CollectorsConfig, + #[serde(default)] + pub notifications: NotificationConfig, } #[derive(Debug, Clone, Deserialize, Serialize)] @@ -254,6 +257,13 @@ impl AgentConfig { info!("Backup monitoring disabled for this host"); } + // Auto-configure notifications + self.notifications.enabled = true; + self.notifications.from_email = format!("{}@cmtec.se", hostname); + self.notifications.to_email = "cm@cmtec.se".to_string(); + info!("Auto-configured notifications: {} -> {}", + self.notifications.from_email, self.notifications.to_email); + // Apply host-specific timing optimizations self.apply_host_timing_overrides(hostname); diff --git a/agent/src/main.rs b/agent/src/main.rs index f719bad..5e8b876 100644 --- a/agent/src/main.rs +++ b/agent/src/main.rs @@ -9,6 +9,7 @@ mod agent; mod collectors; mod config; mod discovery; +mod notifications; mod scheduler; use agent::MetricsAgent; diff --git a/agent/src/notifications.rs b/agent/src/notifications.rs new file mode 100644 index 0000000..a177ead --- /dev/null +++ b/agent/src/notifications.rs @@ -0,0 +1,182 @@ +use std::collections::HashMap; +use chrono::{DateTime, Utc}; +use lettre::{Message, SmtpTransport, Transport}; +use tracing::{info, error, warn}; + +#[derive(Debug, Clone)] +pub struct NotificationConfig { + pub enabled: bool, + pub smtp_host: String, + pub smtp_port: u16, + pub from_email: String, + pub to_email: String, + pub rate_limit_minutes: u64, +} + +impl Default for NotificationConfig { + fn default() -> Self { + Self { + enabled: false, + smtp_host: "localhost".to_string(), + smtp_port: 25, + from_email: "".to_string(), + to_email: "".to_string(), + rate_limit_minutes: 30, // Don't spam notifications + } + } +} + +#[derive(Debug, Clone, PartialEq)] +pub struct StatusChange { + pub component: String, + pub metric: String, + pub old_status: String, + pub new_status: String, + pub timestamp: DateTime, +} + +pub struct NotificationManager { + config: NotificationConfig, + last_status: HashMap, // key: "component.metric", value: status + last_notification: HashMap>, // Rate limiting +} + +impl NotificationManager { + pub fn new(config: NotificationConfig) -> Self { + Self { + config, + last_status: HashMap::new(), + last_notification: HashMap::new(), + } + } + + pub fn update_status(&mut self, component: &str, metric: &str, status: &str) -> Option { + let key = format!("{}.{}", component, metric); + let old_status = self.last_status.get(&key).cloned(); + + if let Some(old) = &old_status { + if old != status { + let change = StatusChange { + component: component.to_string(), + metric: metric.to_string(), + old_status: old.clone(), + new_status: status.to_string(), + timestamp: Utc::now(), + }; + + self.last_status.insert(key, status.to_string()); + + if self.should_notify(&change) { + return Some(change); + } + } + } else { + // First time seeing this metric - store but don't notify + self.last_status.insert(key, status.to_string()); + } + + None + } + + fn should_notify(&mut self, change: &StatusChange) -> bool { + if !self.config.enabled { + return false; + } + + // Only notify on transitions to warning/critical, or recovery to ok + match (change.old_status.as_str(), change.new_status.as_str()) { + (_, "warning") | (_, "critical") => true, + ("warning" | "critical", "ok") => true, + _ => false, + } + } + + fn is_rate_limited(&mut self, change: &StatusChange) -> bool { + let key = format!("{}.{}", change.component, change.metric); + + if let Some(last_time) = self.last_notification.get(&key) { + let minutes_since = Utc::now().signed_duration_since(*last_time).num_minutes(); + if minutes_since < self.config.rate_limit_minutes as i64 { + return true; + } + } + + self.last_notification.insert(key, Utc::now()); + false + } + + pub async fn send_notification(&mut self, change: StatusChange) { + if !self.config.enabled { + return; + } + + if self.is_rate_limited(&change) { + warn!("Rate limiting notification for {}.{}", change.component, change.metric); + return; + } + + let subject = self.format_subject(&change); + let body = self.format_body(&change); + + if let Err(e) = self.send_email(&subject, &body).await { + error!("Failed to send notification email: {}", e); + } else { + info!("Sent notification: {} {}.{} {} → {}", + change.component, change.component, change.metric, + change.old_status, change.new_status); + } + } + + fn format_subject(&self, change: &StatusChange) -> String { + let urgency = match change.new_status.as_str() { + "critical" => "🔴 CRITICAL", + "warning" => "🟡 WARNING", + "ok" => "✅ RESOLVED", + _ => "ℹī¸ STATUS", + }; + + format!("{}: {} {} on {}", + urgency, + change.component, + change.metric, + gethostname::gethostname().to_string_lossy()) + } + + fn format_body(&self, change: &StatusChange) -> String { + format!( + "Status Change Alert\n\ + \n\ + Host: {}\n\ + Component: {}\n\ + Metric: {}\n\ + Status Change: {} → {}\n\ + Time: {}\n\ + \n\ + --\n\ + CM Dashboard Agent\n\ + Generated at {}", + gethostname::gethostname().to_string_lossy(), + change.component, + change.metric, + change.old_status, + change.new_status, + change.timestamp.format("%Y-%m-%d %H:%M:%S UTC"), + Utc::now().format("%Y-%m-%d %H:%M:%S UTC") + ) + } + + async fn send_email(&self, subject: &str, body: &str) -> Result<(), Box> { + let email = Message::builder() + .from(self.config.from_email.parse()?) + .to(self.config.to_email.parse()?) + .subject(subject) + .body(body.to_string())?; + + let mailer = SmtpTransport::builder_dangerous(&self.config.smtp_host) + .port(self.config.smtp_port) + .build(); + + mailer.send(&email)?; + Ok(()) + } +} \ No newline at end of file