Merge pull request #4787 from bcgov/feat/4771

feat(4771): add data migration for Webhook URL duplication

.github/workflows/deploy-dev.yml

@@ -164,7 +164,7 @@ jobs:
   deploy:
     needs: [build-push-app, build-push-pre-prisma, build-push-pre-data-migrations, build-push-email, build-push-m365proxy, build-push-nats-provision]
     runs-on: ubuntu-22.04
-    timeout-minutes: 5
+    timeout-minutes: 10
     permissions:
       contents: read
     environment:

.github/workflows/deploy-dispatch.yml

@@ -15,7 +15,7 @@ on:
 jobs:
   deploy:
     runs-on: ubuntu-22.04
-    timeout-minutes: 5
+    timeout-minutes: 10
     permissions:
       contents: read
     environment:

.github/workflows/deploy-prod.yml

@@ -11,7 +11,7 @@ concurrency:
 jobs:
   deploy:
     runs-on: ubuntu-22.04
-    timeout-minutes: 5
+    timeout-minutes: 10
     permissions:
       contents: read
     environment:

.github/workflows/deploy-test.yml

@@ -131,7 +131,7 @@ jobs:
   deploy:
     needs: [set-tag, build-push-app, build-push-pre-prisma, build-push-pre-data-migrations, build-push-email]
     runs-on: ubuntu-22.04
-    timeout-minutes: 5
+    timeout-minutes: 10
     permissions:
       contents: read
     environment:

data-migrations/migrations/20250127191932-ag_ministry_webhook_duplicate.js

@@ -0,0 +1,40 @@
+export const up = async (db, client) => {
+  const session = client.startSession();
+
+  await session.withTransaction(async () => {
+    const PrivateCloudProductWebhook = db.collection('PrivateCloudProductWebhook');
+    const PrivateCloudProject = db.collection('PrivateCloudProject');
+
+    const baseWebhook = await PrivateCloudProductWebhook.findOne({ licencePlate: { $eq: 'e5ced5' } });
+    if (!baseWebhook) return;
+
+    const targetProducts = await PrivateCloudProject.find({
+      ministry: { $in: ['AG', 'PSSG', 'EMBC'] },
+      status: { $eq: 'ACTIVE' },
+    })
+      .project({ licencePlate: 1 })
+      .toArray();
+
+    const webhookDocsToCopy = targetProducts.map(({ licencePlate }) => {
+      return {
+        licencePlate,
+        url: baseWebhook.url,
+        secret: baseWebhook.secret ?? '',
+        username: baseWebhook.username ?? '',
+        password: baseWebhook.password ?? '',
+      };
+    });
+
+    if (webhookDocsToCopy.length === 0) return;
+
+    const targetLicensePlates = targetProducts.map(({ licencePlate }) => licencePlate);
+    await PrivateCloudProductWebhook.deleteMany({ licencePlate: { $in: targetLicensePlates } });
+
+    const result = await PrivateCloudProductWebhook.insertMany(webhookDocsToCopy, {});
+    console.log('renamag_ministry_webhook_duplicate:', result);
+  });
+
+  session.endSession();
+};
+
+export const down = async (db, client) => {};