v0.4.1

src/db.rs

@@ -130,6 +130,21 @@ impl Db {
         self.delete_by_id("schedules", id)
     }
 
+    pub fn replace_schedules_for_zone(&self, zone_id: &str, schedules: &[Schedule]) -> Result<()> {
+        let mut conn = self.lock()?;
+        let tx = conn.transaction()?;
+        tx.execute(queries::DELETE_SCHEDULES_BY_ZONE_ID, [zone_id])?;
+        for schedule in schedules {
+            let payload = Self::to_json(schedule)?;
+            tx.execute(
+                queries::UPSERT_SCHEDULE,
+                params![schedule.id, schedule.zone_id, payload, schedule.updated_at.to_rfc3339()],
+            )?;
+        }
+        tx.commit()?;
+        Ok(())
+    }
+
     pub fn save_automation(&self, item: &Automation) -> Result<()> {
         let payload = Self::to_json(item)?;
         let conn = self.lock()?;