Update StateTransition

Add `previous_alert_state` and `previous_alert_duration`
If not present at runtime, will get created using historical values

Author: parmesant

src/alerts/alert_structs.rs

@@ -757,6 +757,9 @@ pub struct StateTransition {
     pub state: AlertState,
     /// Timestamp when this state was set/updated
     pub last_updated_at: DateTime<Utc>,
+    pub previous_alert_state: Option<AlertState>,
+    /// Duration in seconds
+    pub previous_state_duration: Option<i64>,
 }
 
 #[derive(Debug, Clone, Serialize, Deserialize)]
@@ -768,10 +771,23 @@ pub struct AlertStateEntry {
 
 impl StateTransition {
     /// Creates a new state transition with the current timestamp
-    pub fn new(state: AlertState) -> Self {
+    pub fn new(
+        state: AlertState,
+        previous_alert_state: Option<AlertState>,
+        previous_alert_time: Option<DateTime<Utc>>,
+    ) -> Self {
+        let now = Utc::now();
+        // calculate duration if previous alert time is provided
+        let previous_state_duration = if let Some(alert_time) = previous_alert_time {
+            Some((now - alert_time).num_seconds())
+        } else {
+            None
+        };
         Self {
             state,
-            last_updated_at: Utc::now(),
+            last_updated_at: now,
+            previous_alert_state,
+            previous_state_duration,
         }
     }
 }
@@ -781,7 +797,7 @@ impl AlertStateEntry {
     pub fn new(alert_id: Ulid, initial_state: AlertState) -> Self {
         Self {
             alert_id,
-            states: vec![StateTransition::new(initial_state)],
+            states: vec![StateTransition::new(initial_state, None, None)],
         }
     }
 
@@ -792,7 +808,11 @@ impl AlertStateEntry {
             Some(last_transition) => {
                 if last_transition.state != new_state {
                     // State changed - add new transition
-                    self.states.push(StateTransition::new(new_state));
+                    self.states.push(StateTransition::new(
+                        new_state,
+                        Some(last_transition.state),
+                        Some(last_transition.last_updated_at),
+                    ));
                     true
                 } else {
                     // If state hasn't changed, do nothing - preserve the original timestamp
@@ -801,7 +821,8 @@ impl AlertStateEntry {
             }
             None => {
                 // No previous states - add the first one
-                self.states.push(StateTransition::new(new_state));
+                self.states
+                    .push(StateTransition::new(new_state, None, None));
                 true
             }
         }

src/handlers/http/alerts.rs

@@ -44,15 +44,15 @@ const MAX_LIMIT: usize = 1000;
 const DEFAULT_LIMIT: usize = 100;
 
 /// Query parameters for listing alerts
-struct ListQueryParams {
-    tags_list: Vec<String>,
-    offset: usize,
-    limit: usize,
-    other_fields_filters: HashMap<String, String>,
+pub struct ListQueryParams {
+    pub tags_list: Vec<String>,
+    pub offset: usize,
+    pub limit: usize,
+    pub other_fields_filters: HashMap<String, String>,
 }
 
 /// Parse and validate query parameters for listing alerts
-fn parse_list_query_params(
+pub fn parse_list_query_params(
     query_map: &HashMap<String, String>,
 ) -> Result<ListQueryParams, AlertError> {
     let mut tags_list = Vec::new();