editoast: add enabled window for stdcm search env table

Signed-off-by: Florian Amsallem <[email protected]>

editoast/editoast_models/src/tables.rs

@@ -671,6 +671,8 @@ diesel::table! {
         search_window_begin -> Timestamptz,
         search_window_end -> Timestamptz,
         temporary_speed_limit_group_id -> Nullable<Int8>,
+        enabled_from -> Timestamptz,
+        enabled_to -> Timestamptz,
     }
 }
 

editoast/migrations/2025-02-19-173042_adapt_search_environment_adding_enabled_window/down.sql

@@ -0,0 +1,2 @@
+ALTER TABLE stdcm_search_environment DROP COLUMN enabled_from,
+    DROP COLUMN enabled_to;

editoast/migrations/2025-02-19-173042_adapt_search_environment_adding_enabled_window/up.sql

@@ -0,0 +1,3 @@
+ALTER TABLE stdcm_search_environment
+ADD COLUMN enabled_from TIMESTAMP WITH TIME ZONE DEFAULT '1970-01-01 00:00:00' NOT NULL,
+    ADD COLUMN enabled_to TIMESTAMP WITH TIME ZONE DEFAULT '1970-01-02 00:00:00' NOT NULL;

editoast/openapi.yaml

@@ -11355,10 +11355,22 @@ components:
       - timetable_id
       - search_window_begin
       - search_window_end
+      - enabled_from
+      - enabled_to
       properties:
         electrical_profile_set_id:
           type: integer
           format: int64
+        enabled_from:
+          type: string
+          format: date-time
+          description: The time window start point where the environment is enabled.
+        enabled_to:
+          type: string
+          format: date-time
+          description: |-
+            The time window end point where the environment is enabled.
+            This value is usually lower than the `search_window_begin`, since a search is performed before the train rolls.
         id:
           type: integer
           format: int64
@@ -11368,9 +11380,13 @@ components:
         search_window_begin:
           type: string
           format: date-time
+          description: |-
+            The start of the search time window.
+            Usually, trains schedules from the `timetable_id` runs within this window.
         search_window_end:
           type: string
           format: date-time
+          description: The end of the search time window.
         temporary_speed_limit_group_id:
           type: integer
           format: int64
@@ -11387,11 +11403,19 @@ components:
       - timetable_id
       - search_window_begin
       - search_window_end
+      - enabled_from
+      - enabled_to
       properties:
         electrical_profile_set_id:
           type: integer
           format: int64
           nullable: true
+        enabled_from:
+          type: string
+          format: date-time
+        enabled_to:
+          type: string
+          format: date-time
         infra_id:
           type: integer
           format: int64

editoast/src/client/stdcm_search_env_commands.rs

@@ -2,6 +2,7 @@ use crate::models::electrical_profiles::ElectricalProfileSet;
 use crate::models::stdcm_search_environment::StdcmSearchEnvironment;
 use crate::models::timetable::Timetable;
 use crate::models::work_schedules::WorkScheduleGroup;
+use crate::models::Create;
 use crate::models::Infra;
 use crate::models::Scenario;
 use crate::CliError;
@@ -103,7 +104,9 @@ async fn set_stdcm_search_env_from_scenario(
         .timetable_id(scenario.timetable_id)
         .search_window_begin(begin)
         .search_window_end(end)
-        .overwrite(conn)
+        .enabled_from(Utc::now())
+        .enabled_to(Utc::now() + Duration::days(1000))
+        .create(conn)
         .await?;
 
     println!("✅ STDCM search environment set up successfully");
@@ -170,7 +173,9 @@ async fn set_stdcm_search_env_from_scratch(
         .timetable_id(args.timetable_id)
         .search_window_begin(begin)
         .search_window_end(end)
-        .overwrite(conn)
+        .enabled_from(Utc::now())
+        .enabled_to(Utc::now() + Duration::days(1000))
+        .create(conn)
         .await?;
 
     println!("✅ STDCM search environment set up successfully");
@@ -213,7 +218,7 @@ async fn resolve_search_window(
 async fn show_stdcm_search_env(
     conn: &mut DbConnection,
 ) -> Result<(), Box<dyn Error + Send + Sync>> {
-    let search_env = StdcmSearchEnvironment::retrieve_latest(conn).await;
+    let search_env = StdcmSearchEnvironment::retrieve_latest_enabled(conn).await;
     if let Some(search_env) = search_env {
         println!("{search_env:#?}");
 
@@ -389,7 +394,7 @@ mod tests {
         let result = set_stdcm_search_env_from_scenario(args, conn).await;
         assert!(result.is_ok());
 
-        let search_env = StdcmSearchEnvironment::retrieve_latest(conn).await;
+        let search_env = StdcmSearchEnvironment::retrieve_latest_enabled(conn).await;
 
         assert!(search_env.is_some());
         let search_env = search_env.unwrap();
@@ -433,7 +438,7 @@ mod tests {
         let result = set_stdcm_search_env_from_scratch(args, conn).await;
         assert!(result.is_ok());
 
-        let search_env = StdcmSearchEnvironment::retrieve_latest(conn).await;
+        let search_env = StdcmSearchEnvironment::retrieve_latest_enabled(conn).await;
 
         assert!(search_env.is_some());
         let search_env = search_env.unwrap();

editoast/src/models/stdcm_search_environment.rs

@@ -4,11 +4,9 @@ use diesel::ExpressionMethods;
 use diesel::QueryDsl;
 use diesel_async::RunQueryDsl;
 use editoast_derive::Model;
-use editoast_models::model;
 use editoast_models::DbConnection;
 use serde::Serialize;
 use std::ops::DerefMut;
-use std::result::Result;
 use utoipa::ToSchema;
 
 use crate::models::prelude::*;
@@ -30,46 +28,54 @@ pub struct StdcmSearchEnvironment {
     #[serde(skip_serializing_if = "Option::is_none")]
     pub work_schedule_group_id: Option<i64>,
     pub timetable_id: i64,
+    /// The start of the search time window.
+    /// Usually, trains schedules from the `timetable_id` runs within this window.
     pub search_window_begin: DateTime<Utc>,
+    /// The end of the search time window.
     pub search_window_end: DateTime<Utc>,
     #[schema(nullable = false)]
     #[serde(skip_serializing_if = "Option::is_none")]
     pub temporary_speed_limit_group_id: Option<i64>,
+    /// The time window start point where the environment is enabled.
+    pub enabled_from: DateTime<Utc>,
+    /// The time window end point where the environment is enabled.
+    /// This value is usually lower than the `search_window_begin`, since a search is performed before the train rolls.
+    pub enabled_to: DateTime<Utc>,
 }
 
 impl StdcmSearchEnvironment {
-    /// Retrieve the latest search environment. Returns None if no search environment is found.
-    pub async fn retrieve_latest(conn: &mut DbConnection) -> Option<Self> {
+    /// Retrieve the enabled search environment. If no env is enabled returns the most recent `enabled_to`.
+    /// In case of multiple enabled environments, the one with the highest `id` is returned.
+    pub async fn retrieve_latest_enabled(conn: &mut DbConnection) -> Option<Self> {
         use editoast_models::tables::stdcm_search_environment::dsl::*;
+        // Search for enabled env
+        let enabled_env = stdcm_search_environment
+            .order_by(id.desc())
+            .filter(enabled_from.le(diesel::dsl::now))
+            .filter(enabled_to.ge(diesel::dsl::now))
+            .first::<Row<StdcmSearchEnvironment>>(conn.write().await.deref_mut())
+            .await
+            .map(Into::into)
+            .ok();
+        if enabled_env.is_some() {
+            return enabled_env;
+        }
+
+        // Search for the most recent env
+        tracing::warn!("No STDCM search environment enabled");
         stdcm_search_environment
-            .order_by((search_window_end.desc(), search_window_begin.asc()))
+            .order_by((enabled_to.desc(), id.desc()))
             .first::<Row<StdcmSearchEnvironment>>(conn.write().await.deref_mut())
             .await
             .map(Into::into)
             .ok()
     }
-
-    pub async fn delete_all(conn: &mut DbConnection) -> Result<(), model::Error> {
-        use editoast_models::tables::stdcm_search_environment::dsl::*;
-        diesel::delete(stdcm_search_environment)
-            .execute(conn.write().await.deref_mut())
-            .await?;
-        Ok(())
-    }
-}
-
-impl StdcmSearchEnvironmentChangeset {
-    pub async fn overwrite(
-        self,
-        conn: &mut DbConnection,
-    ) -> Result<StdcmSearchEnvironment, model::Error> {
-        StdcmSearchEnvironment::delete_all(conn).await?;
-        self.create(conn).await
-    }
 }
 
 #[cfg(test)]
 pub mod tests {
+    use chrono::Duration;
+    use chrono::DurationRound;
     use chrono::TimeZone;
     use chrono::Utc;
     use pretty_assertions::assert_eq;
@@ -85,7 +91,7 @@ pub mod tests {
     use crate::models::timetable::Timetable;
     use crate::models::work_schedules::WorkScheduleGroup;
     use crate::models::Infra;
-    use crate::models::{Count, Model, SelectionSettings};
+    use crate::models::Model;
     use editoast_models::DbConnectionPoolV2;
 
     pub async fn stdcm_search_env_fixtures(
@@ -112,76 +118,10 @@ pub mod tests {
         )
     }
 
-    #[rstest]
-    async fn test_overwrite() {
-        let db_pool = DbConnectionPoolV2::for_tests();
-        let initial_env_count =
-            StdcmSearchEnvironment::count(&mut db_pool.get_ok(), Default::default())
-                .await
-                .expect("failed to count STDCM envs");
-        let (
-            infra,
-            timetable,
-            work_schedule_group,
-            temporary_speed_limit_group,
-            electrical_profile_set,
-        ) = stdcm_search_env_fixtures(&mut db_pool.get_ok()).await;
-
-        let changeset_1 = StdcmSearchEnvironment::changeset()
-            .infra_id(infra.id)
-            .electrical_profile_set_id(Some(electrical_profile_set.id))
-            .work_schedule_group_id(Some(work_schedule_group.id))
-            .temporary_speed_limit_group_id(Some(temporary_speed_limit_group.id))
-            .timetable_id(timetable.id)
-            .search_window_begin(Utc.with_ymd_and_hms(2024, 1, 1, 0, 0, 0).unwrap())
-            .search_window_end(Utc.with_ymd_and_hms(2024, 1, 15, 0, 0, 0).unwrap());
-
-        let begin = Utc.with_ymd_and_hms(2024, 1, 16, 0, 0, 0).unwrap();
-        let end = Utc.with_ymd_and_hms(2024, 1, 13, 0, 0, 0).unwrap();
-
-        let changeset_2 = changeset_1
-            .clone()
-            .search_window_begin(begin)
-            .search_window_end(end);
-
-        changeset_1
-            .create(&mut db_pool.get_ok())
-            .await
-            .expect("Failed to create first search environment");
-
-        assert_eq!(
-            StdcmSearchEnvironment::count(&mut db_pool.get_ok(), SelectionSettings::new())
-                .await
-                .expect("Failed to count"),
-            initial_env_count + 1
-        );
-
-        let _ = changeset_2
-            .overwrite(&mut db_pool.get_ok())
-            .await
-            .expect("Failed to overwrite search environment");
-
-        assert_eq!(
-            StdcmSearchEnvironment::count(&mut db_pool.get_ok(), SelectionSettings::new())
-                .await
-                .expect("Failed to count"),
-            1
-        );
-
-        let result = StdcmSearchEnvironment::retrieve_latest(&mut db_pool.get_ok())
-            .await
-            .expect("Failed to retrieve latest search environment");
-
-        assert_eq!(result.search_window_begin, begin);
-        assert_eq!(result.search_window_end, end);
-    }
-
     #[rstest]
     async fn test_retrieve_latest() {
         let db_pool = DbConnectionPoolV2::for_tests();
-        StdcmSearchEnvironment::delete_all(&mut db_pool.get_ok())
-            .await
-            .expect("failed to delete envs");
+
         let (
             infra,
             timetable,
@@ -197,43 +137,61 @@ pub mod tests {
             .temporary_speed_limit_group_id(Some(temporary_speed_limit_group.id))
             .timetable_id(timetable.id)
             .search_window_begin(Utc.with_ymd_and_hms(2024, 1, 1, 0, 0, 0).unwrap())
-            .search_window_end(Utc.with_ymd_and_hms(2024, 1, 15, 0, 0, 0).unwrap());
+            .search_window_end(Utc.with_ymd_and_hms(2024, 1, 2, 0, 0, 0).unwrap())
+            .enabled_from(Utc::now() - Duration::days(3))
+            .enabled_to(Utc::now() - Duration::days(2));
 
         let too_young = too_old
             .clone()
-            .search_window_begin(Utc.with_ymd_and_hms(2024, 1, 16, 0, 0, 0).unwrap())
-            .search_window_end(Utc.with_ymd_and_hms(2024, 1, 31, 0, 0, 0).unwrap());
+            .enabled_from(Utc::now() + Duration::days(2))
+            .enabled_to(Utc::now() + Duration::days(3));
 
-        let begin = Utc.with_ymd_and_hms(2024, 1, 7, 0, 0, 0).unwrap();
-        let end = Utc.with_ymd_and_hms(2024, 1, 31, 0, 0, 0).unwrap();
+        let enabled_but_not_last = too_old
+            .clone()
+            .enabled_from(Utc::now() - Duration::hours(1))
+            .enabled_to(Utc::now() + Duration::hours(1));
+
+        let enabled_from =
+            Utc::now().duration_trunc(Duration::seconds(1)).unwrap() - Duration::days(1);
+        let enabled_to =
+            Utc::now().duration_trunc(Duration::seconds(1)).unwrap() + Duration::days(1);
 
         let the_best = too_old
             .clone()
-            .search_window_begin(begin)
-            .search_window_end(end);
-
-        for changeset in [too_old, too_young.clone(), the_best, too_young] {
+            .enabled_from(enabled_from)
+            .enabled_to(enabled_to);
+
+        for changeset in [
+            too_old,
+            too_young.clone(),
+            enabled_but_not_last,
+            the_best,
+            too_young,
+        ] {
             changeset
                 .create(&mut db_pool.get_ok())
                 .await
                 .expect("Failed to create search environment");
         }
 
-        let result = StdcmSearchEnvironment::retrieve_latest(&mut db_pool.get_ok())
+        let result = StdcmSearchEnvironment::retrieve_latest_enabled(&mut db_pool.get_ok())
             .await
             .expect("Failed to retrieve latest search environment");
 
-        assert_eq!(result.search_window_begin, begin);
-        assert_eq!(result.search_window_end, end);
+        assert_eq!(result.enabled_from, enabled_from);
+        assert_eq!(result.enabled_to, enabled_to);
     }
 
     #[rstest]
     async fn test_retrieve_latest_empty() {
         let db_pool = DbConnectionPoolV2::for_tests();
-        StdcmSearchEnvironment::delete_all(&mut db_pool.get_ok())
+        use editoast_models::tables::stdcm_search_environment::dsl::*;
+        diesel::delete(stdcm_search_environment)
+            .execute(db_pool.get_ok().write().await.deref_mut())
             .await
-            .expect("failed to delete envs");
-        let result = StdcmSearchEnvironment::retrieve_latest(&mut db_pool.get_ok()).await;
+            .expect("Failed to delete all search environments");
+
+        let result = StdcmSearchEnvironment::retrieve_latest_enabled(&mut db_pool.get_ok()).await;
         assert_eq!(result, None);
     }
 }