Merge pull request #14 from getsentry/sqlx-migrations

feat(store): Use sqlx migrations

Author: john-z-yang

build.rs

@@ -0,0 +1,5 @@
+// generated by `sqlx migrate build-script`
+fn main() {
+    // trigger recompilation when a new migration is added
+    println!("cargo:rerun-if-changed=migrations");
+}

migrations/0001_create_inflight_taskactivations.sql

@@ -0,0 +1,10 @@
+CREATE TABLE IF NOT EXISTS inflight_taskactivations (
+    id UUID NOT NULL PRIMARY KEY,
+    activation BLOB NOT NULL,
+    offset BIGINTEGER NOT NULL,
+    added_at DATETIME NOT NULL,
+    deadletter_at DATETIME,
+    processing_deadline_duration INTEGER NOT NULL,
+    processing_deadline DATETIME,
+    status INTEGER NOT NULL
+);

migrations/1730926801-initial.sql

@@ -80,20 +80,7 @@ impl InflightTaskStore {
         }
         let sqlite_pool = SqlitePool::connect(url).await?;
 
-        sqlx::query(
-            "CREATE TABLE IF NOT EXISTS inflight_taskactivations (
-                    id UUID NOT NULL PRIMARY KEY,
-                    activation BLOB NOT NULL,
-                    offset BIGINTEGER NOT NULL,
-                    added_at DATETIME NOT NULL,
-                    deadletter_at DATETIME,
-                    processing_deadline_duration INTEGER NOT NULL,
-                    processing_deadline DATETIME,
-                    status INTEGER NOT NULL
-                );",
-        )
-        .execute(&sqlite_pool)
-        .await?;
+        sqlx::migrate!("./migrations").run(&sqlite_pool).await?;
 
         Ok(Self { sqlite_pool })
     }