1 files changed, 17 insertions, 2 deletions

diff --git a/src/database/mod.rs b/src/database/mod.rs
index e803da9..0674477 100644
--- a/src/database/mod.rs
+++ b/src/database/mod.rs
@@ -43,7 +43,7 @@ async fn run_migrations(pool: &DbPool) -> Result<()> {
 
     sqlx::query(
         "CREATE TABLE IF NOT EXISTS cron_jobs (
-            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            id INTEGER PRIMARY KEY,
             cron_expression TEXT NOT NULL,
             type TEXT NOT NULL CHECK(type IN ('audio', 'wiadomość')),
             channel_id INTEGER NOT NULL,
@@ -189,9 +189,24 @@ pub async fn add_cron_job(
     audio_filename: Option<&str>,
     message: Option<&str>,
 ) -> Result<i64> {
+    // Find the lowest unused ID to reuse freed slots
+    let existing: Vec<i64> = sqlx::query_scalar("SELECT id FROM cron_jobs ORDER BY id")
+        .fetch_all(pool)
+        .await?;
+
+    let next_id = existing.iter().enumerate().find_map(|(i, &id)| {
+        let expected = (i as i64) + 1;
+        if id != expected {
+            Some(expected)
+        } else {
+            None
+        }
+    }).unwrap_or(existing.len() as i64 + 1);
+
     let result = sqlx::query(
-        "INSERT INTO cron_jobs (cron_expression, type, channel_id, audio_filename, message) VALUES (?, ?, ?, ?, ?)",
+        "INSERT INTO cron_jobs (id, cron_expression, type, channel_id, audio_filename, message) VALUES (?, ?, ?, ?, ?, ?)",
     )
+    .bind(next_id)
     .bind(cron_expression)
     .bind(r#type)
     .bind(channel_id)