fix: moving insightsProjects organization on merge (#3862)

Author: ulemons

services/apps/entity_merging_worker/src/activities/organizations.ts

@@ -2,6 +2,7 @@ import { WorkflowIdConflictPolicy, WorkflowIdReusePolicy } from '@temporalio/wor
 
 import { DEFAULT_TENANT_ID } from '@crowd/common'
 import { moveActivityRelationsToAnotherOrganization } from '@crowd/data-access-layer/src/activityRelations'
+import { moveInsightsProjectsToAnotherOrganization } from '@crowd/data-access-layer/src/collections'
 import {
   deleteOrganizationById,
   deleteOrganizationSegments,
@@ -35,6 +36,7 @@ export async function finishOrganizationMergingUpdateActivities(
 ): Promise<void> {
   const qx = pgpQx(svc.postgres.writer.connection())
   await moveActivityRelationsToAnotherOrganization(qx, secondaryId, primaryId)
+  await moveInsightsProjectsToAnotherOrganization(qx, secondaryId, primaryId)
 }
 
 export async function recalculateActivityAffiliationsOfOrganizationAsync(

services/libs/data-access-layer/src/collections/index.ts

@@ -344,6 +344,23 @@ function prepareProject(project: Partial<ICreateInsightsProject>) {
   return toUpdate
 }
 
+export async function moveInsightsProjectsToAnotherOrganization(
+  qx: QueryExecutor,
+  fromId: string,
+  toId: string,
+) {
+  return qx.result(
+    `
+      UPDATE "insightsProjects"
+      SET "organizationId" = $(toId),
+          "updatedAt" = now()
+      WHERE "organizationId" = $(fromId)
+        AND "deletedAt" IS NULL
+    `,
+    { fromId, toId },
+  )
+}
+
 export async function findBySlug(qx: QueryExecutor, slug: string) {
   const collections = await queryCollections(qx, {
     filter: {