feat: add last triggered timestamp to alerts (parseablehq#1419)

Author: parmesant

src/alerts/alert_structs.rs

@@ -316,6 +316,7 @@ impl AlertRequest {
             notification_config: self.notification_config,
             created: Utc::now(),
             tags: self.tags,
+            last_triggered_at: None,
         };
         Ok(config)
     }
@@ -342,6 +343,7 @@ pub struct AlertConfig {
     pub notification_config: NotificationConfig,
     pub created: DateTime<Utc>,
     pub tags: Option<Vec<String>>,
+    pub last_triggered_at: Option<DateTime<Utc>>,
 }
 
 #[derive(Debug, serde::Serialize, serde::Deserialize, Clone)]
@@ -367,6 +369,7 @@ pub struct AlertConfigResponse {
     pub notification_config: NotificationConfig,
     pub created: DateTime<Utc>,
     pub tags: Option<Vec<String>>,
+    pub last_triggered_at: Option<DateTime<Utc>>,
 }
 
 impl AlertConfig {
@@ -405,6 +408,7 @@ impl AlertConfig {
             notification_config: self.notification_config,
             created: self.created,
             tags: self.tags,
+            last_triggered_at: self.last_triggered_at,
         }
     }
 }

src/alerts/alert_types.rs

@@ -62,6 +62,7 @@ pub struct ThresholdAlert {
     pub created: DateTime<Utc>,
     pub tags: Option<Vec<String>>,
     pub datasets: Vec<String>,
+    pub last_triggered_at: Option<DateTime<Utc>>,
 }
 
 #[async_trait]
@@ -192,6 +193,11 @@ impl AlertTrait for ThresholdAlert {
             // update state in memory
             self.state = new_state;
 
+            // if new state is `Triggered`, change triggered at
+            if new_state.eq(&AlertState::Triggered) {
+                self.last_triggered_at = Some(Utc::now());
+            }
+
             // update on disk
             store.put_alert(self.id, &self.to_alert_config()).await?;
             // The task should have already been removed from the list of running tasks
@@ -220,6 +226,11 @@ impl AlertTrait for ThresholdAlert {
         // update state in memory
         self.state = new_state;
 
+        // if new state is `Triggered`, change triggered at
+        if new_state.eq(&AlertState::Triggered) {
+            self.last_triggered_at = Some(Utc::now());
+        }
+
         // update on disk
         store.put_alert(self.id, &self.to_alert_config()).await?;
 
@@ -367,6 +378,7 @@ impl From<AlertConfig> for ThresholdAlert {
             created: value.created,
             tags: value.tags,
             datasets: value.datasets,
+            last_triggered_at: value.last_triggered_at,
         }
     }
 }
@@ -389,6 +401,7 @@ impl From<ThresholdAlert> for AlertConfig {
             created: val.created,
             tags: val.tags,
             datasets: val.datasets,
+            last_triggered_at: val.last_triggered_at,
         }
     }
 }

src/alerts/mod.rs

@@ -134,6 +134,7 @@ impl AlertConfig {
             notification_config: NotificationConfig::default(),
             created: Utc::now(),
             tags: None,
+            last_triggered_at: None,
         };
 
         // Save the migrated alert back to storage