[MongoDB Storage] Duplicate migration to fix issues with migration ordering (#391)

* Duplicate migration to fix issues with migration ordering.

* Changeset.

Author: rkistner

.changeset/gorgeous-ligers-leave.md

@@ -0,0 +1,7 @@
+---
+'@powersync/service-module-mongodb-storage': patch
+'@powersync/service-core': patch
+'@powersync/service-image': patch
+---
+
+[MongoDB storage] Fix migration for indexes on connection_report_events.

modules/module-mongodb-storage/src/migrations/db/migrations/1752661449910-connection-reporting.ts

@@ -6,41 +6,7 @@ export const up: migrations.PowerSyncMigrationFunction = async (context) => {
   const {
     service_context: { configuration }
   } = context;
-  const db = storage.createPowerSyncMongo(configuration.storage as MongoStorageConfig);
-
-  try {
-    await db.createConnectionReportingCollection();
-
-    await db.connection_report_events.createIndex(
-      {
-        connected_at: 1,
-        jwt_exp: 1,
-        disconnected_at: 1
-      },
-      { name: 'connection_list_index' }
-    );
-
-    await db.connection_report_events.createIndex(
-      {
-        user_id: 1
-      },
-      { name: 'connection_user_id_index' }
-    );
-    await db.connection_report_events.createIndex(
-      {
-        client_id: 1
-      },
-      { name: 'connection_client_id_index' }
-    );
-    await db.connection_report_events.createIndex(
-      {
-        sdk: 1
-      },
-      { name: 'connection_index' }
-    );
-  } finally {
-    await db.client.close();
-  }
+  // No-op - moved to 1762790715147-connection-reporting2
 };
 
 export const down: migrations.PowerSyncMigrationFunction = async (context) => {

modules/module-mongodb-storage/src/migrations/db/migrations/1762790715147-connection-reporting2.ts

@@ -0,0 +1,58 @@
+import { migrations } from '@powersync/service-core';
+import * as storage from '../../../storage/storage-index.js';
+import { MongoStorageConfig } from '../../../types/types.js';
+
+export const up: migrations.PowerSyncMigrationFunction = async (context) => {
+  const {
+    service_context: { configuration }
+  } = context;
+  const db = storage.createPowerSyncMongo(configuration.storage as MongoStorageConfig);
+
+  try {
+    await db.createConnectionReportingCollection();
+
+    await db.connection_report_events.createIndex(
+      {
+        connected_at: 1,
+        jwt_exp: 1,
+        disconnected_at: 1
+      },
+      { name: 'connection_list_index' }
+    );
+
+    await db.connection_report_events.createIndex(
+      {
+        user_id: 1
+      },
+      { name: 'connection_user_id_index' }
+    );
+    await db.connection_report_events.createIndex(
+      {
+        client_id: 1
+      },
+      { name: 'connection_client_id_index' }
+    );
+    await db.connection_report_events.createIndex(
+      {
+        sdk: 1
+      },
+      { name: 'connection_index' }
+    );
+  } finally {
+    await db.client.close();
+  }
+};
+
+export const down: migrations.PowerSyncMigrationFunction = async (context) => {
+  const {
+    service_context: { configuration }
+  } = context;
+
+  const db = storage.createPowerSyncMongo(configuration.storage as MongoStorageConfig);
+
+  try {
+    await db.db.dropCollection('connection_report_events');
+  } finally {
+    await db.client.close();
+  }
+};