seperated migration for sdk

Author: EspressoTrip-v2

modules/module-postgres-storage/src/migrations/scripts/1684951997326-init.ts

@@ -128,28 +128,6 @@ export const up: migrations.PowerSyncMigrationFunction = async (context) => {
         CONSTRAINT unique_user_sync PRIMARY KEY (user_id, sync_rules_id)
       );
     `.execute();
-
-    await db.sql`
-      CREATE TABLE sdk_report_events (
-        id TEXT PRIMARY KEY,
-        user_agent TEXT NOT NULL,
-        client_id TEXT NOT NULL,
-        user_id TEXT NOT NULL,
-        sdk TEXT NOT NULL,
-        jwt_exp TIMESTAMP WITH TIME ZONE,
-        connect_at TIMESTAMP WITH TIME ZONE NOT NULL,
-        disconnect_at TIMESTAMP WITH TIME ZONE,
-        CONSTRAINT unique_user_client_connect UNIQUE (user_id, client_id, connect_at)
-      )
-    `.execute();
-
-    await db.sql` CREATE INDEX sdk_list_index ON sdk_report_events (connect_at, jwt_exp, disconnect_at) `.execute();
-
-    await db.sql` CREATE INDEX sdk_user_id_index ON sdk_report_events (user_id)`.execute();
-
-    await db.sql` CREATE INDEX sdk_client_id_index ON sdk_report_events (client_id)`.execute();
-
-    await db.sql` CREATE INDEX sdk_index ON sdk_report_events (sdk)`.execute();
   });
 };
 

modules/module-postgres-storage/src/migrations/scripts/1753871047719-sdk_report.ts

@@ -0,0 +1,45 @@
+import { migrations } from '@powersync/service-core';
+
+import { openMigrationDB } from '../migration-utils.js';
+
+export const up: migrations.PowerSyncMigrationFunction = async (context) => {
+  const {
+    service_context: { configuration }
+  } = context;
+  await using client = openMigrationDB(configuration.storage);
+
+  await client.transaction(async (db) => {
+    await db.sql`
+      CREATE TABLE IF NOT EXISTS sdk_report_events (
+        id TEXT PRIMARY KEY,
+        user_agent TEXT NOT NULL,
+        client_id TEXT NOT NULL,
+        user_id TEXT NOT NULL,
+        sdk TEXT NOT NULL,
+        jwt_exp TIMESTAMP WITH TIME ZONE,
+        connect_at TIMESTAMP WITH TIME ZONE NOT NULL,
+        disconnect_at TIMESTAMP WITH TIME ZONE,
+      )
+    `.execute();
+
+    await db.sql`
+      CREATE INDEX IF NOT EXISTS sdk_list_index ON sdk_report_events (connect_at, jwt_exp, disconnect_at)
+    `.execute();
+
+    await db.sql`CREATE INDEX IF NOT EXISTS sdk_user_id_index ON sdk_report_events (user_id)`.execute();
+
+    await db.sql`CREATE INDEX IF NOT EXISTS sdk_client_id_index ON sdk_report_events (client_id)`.execute();
+
+    await db.sql`CREATE INDEX IF NOT EXISTS sdk_index ON sdk_report_events (sdk)`.execute();
+  });
+};
+
+export const down: migrations.PowerSyncMigrationFunction = async (context) => {
+  const {
+    service_context: { configuration }
+  } = context;
+  await using client = openMigrationDB(configuration.storage);
+  client.lockConnection(async (db) => {
+    await db.sql`DROP TABLE IF EXISTS sdk_report_events`.execute();
+  });
+};