feat(migrations): added table an initial version (#261)

Co-authored-by: Gabriel Guerra <[email protected]>
resonatehq · Mar 25, 2024 · ea29973 · ea29973
1 parent 19b8fe3
commit ea29973
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 3 deletions.
diff --git a/internal/app/subsystems/aio/store/postgres/postgres.go b/internal/app/subsystems/aio/store/postgres/postgres.go
@@ -124,7 +124,14 @@ const (
 		time         BIGINT,
 		attempt      INTEGER,
 		PRIMARY KEY(id, promise_id)
-	);`
+	);
+	
+	CREATE TABLE IF NOT EXISTS migrations (
+		id    INTEGER,
+		PRIMARY KEY(id) 
+	);
+	
+	INSERT INTO migrations (id) VALUES (1);`
 
 	DROP_TABLE_STATEMENT = `
 	DROP TABLE notifications;
@@ -133,7 +140,8 @@ const (
 	DROP TABLE timeouts;
 	DROP TABLE promises;
 	DROP TABLE locks;
-	DROP TABLE tasks;`
+	DROP TABLE tasks;
+	DROP TABLE migrations;`
 
 	PROMISE_SELECT_STATEMENT = `
 	SELECT

diff --git a/internal/app/subsystems/aio/store/sqlite/sqlite.go b/internal/app/subsystems/aio/store/sqlite/sqlite.go
@@ -120,7 +120,13 @@ const (
 		time         INTEGER,
 		attempt      INTEGER,
 		PRIMARY KEY(id, promise_id)
-	);`
+	);
+	
+	CREATE TABLE IF NOT EXISTS migrations (
+		id    INTEGER PRIMARY KEY
+	);
+	
+	INSERT INTO migrations (id) VALUES (1);`
 
 	PROMISE_SELECT_STATEMENT = `
 	SELECT