feat: rolling vouchers daily purge

backend/src/main.rs

@@ -10,6 +10,7 @@ use tracing_subscriber::EnvFilter;
 use backend::{
     environment::{ENVIRONMENT, Environment},
     handlers::*,
+    tasks::run_daily_purge,
     unifi_api::{UNIFI_API, UnifiAPI},
 };
 
@@ -60,6 +61,11 @@ async fn main() {
         }
     }
 
+    // =================================
+    // Start scheduled tasks
+    // =================================
+    tokio::spawn(run_daily_purge(environment.timezone));
+
     // =================================
     // Setup Axum server
     // =================================

backend/src/tasks.rs

@@ -0,0 +1,41 @@
+use chrono::Utc;
+use chrono_tz::Tz;
+use tokio::time::sleep;
+use tracing::{error, info};
+
+use crate::handlers::delete_expired_rolling_handler;
+
+pub async fn run_daily_purge(timezone: Tz) {
+    loop {
+        let now = Utc::now().with_timezone(&timezone);
+        let next_midnight = now
+            .date_naive()
+            .succ_opt()
+            .expect("Next day is not representable")
+            .and_hms_opt(0, 0, 0)
+            .expect("Could not get next midnight")
+            .and_local_timezone(timezone)
+            .latest()
+            .expect("Could not convert next midnight time to local timezone");
+
+        let delta = next_midnight - now;
+        let duration = delta
+            .to_std()
+            .expect("Duration to next midnight is less than 0");
+
+        info!(
+            "Next purge of expired rolling vouchers at midnight ({}), in {} hours and {} minutes...",
+            timezone,
+            delta.num_hours(),
+            delta.num_minutes() % 60
+        );
+
+        sleep(duration).await;
+
+        info!("Purging expired rolling vouchers...");
+        match delete_expired_rolling_handler().await {
+            Ok(response) => info!("Deleted {} rolling vouchers", response.vouchers_deleted),
+            Err(code) => error!("Failed to delete rolling vouchers: {}", code),
+        };
+    }
+}