chore: add script to fix-members-activities-after-unaffilation (#3247)

Author: mbani01

backend/package.json

@@ -34,7 +34,8 @@
     "script:fix-missing-org-displayName": "SERVICE=script TS_NODE_TRANSPILE_ONLY=true tsx src/bin/scripts/fix-missing-org-displayName.ts",
     "script:syncActivities": "SERVICE=script TS_NODE_TRANSPILE_ONLY=true tsx src/bin/scripts/syncActivities.ts",
     "script:refreshGithubRepoSettings": "SERVICE=script TS_NODE_TRANSPILE_ONLY=true tsx src/bin/scripts/refresh-github-repo-settings.ts",
-    "script:fix-duplicate-members": "SERVICE=script TS_NODE_TRANSPILE_ONLY=true tsx src/bin/scripts/fix-duplicate-members.ts"
+    "script:fix-duplicate-members": "SERVICE=script TS_NODE_TRANSPILE_ONLY=true tsx src/bin/scripts/fix-duplicate-members.ts",
+    "script:fix-members-activities-after-unaffilation": "SERVICE=script TS_NODE_TRANSPILE_ONLY=true tsx src/bin/scripts/fix-members-activities-after-unaffilation.ts"
   },
   "lint-staged": {
     "**/*.ts": [

backend/src/bin/scripts/fix-members-activities-after-unaffilation.ts

@@ -0,0 +1,138 @@
+import commandLineArgs from 'command-line-args'
+import { randomUUID } from 'crypto'
+
+import { getDbConnection } from '@crowd/data-access-layer/src/database'
+import { getServiceLogger } from '@crowd/logging'
+import { getTemporalClient } from '@crowd/temporal'
+
+import { DB_CONFIG, TEMPORAL_CONFIG } from '@/conf'
+
+const log = getServiceLogger()
+
+const options = [
+  {
+    name: 'organizationId',
+    alias: 'o',
+    typeLabel: '{underline organizationId}',
+    type: String,
+    description: 'The organization ID to process members for.',
+  },
+  {
+    name: 'dryRun',
+    alias: 'd',
+    type: Boolean,
+    description: 'Run in dry-run mode (show what would be processed).',
+  },
+  {
+    name: 'help',
+    alias: 'h',
+    type: Boolean,
+    description: 'Print this usage guide.',
+  },
+]
+
+const parameters = commandLineArgs(options)
+
+setImmediate(async () => {
+  const organizationId = parameters.organizationId
+  const dryRun = parameters.dryRun ?? false
+
+  log.info({ organizationId, dryRun }, 'Running script with the following parameters!')
+
+  const db = await getDbConnection({
+    host: DB_CONFIG.readHost,
+    port: DB_CONFIG.port,
+    database: DB_CONFIG.database,
+    user: DB_CONFIG.username,
+    password: DB_CONFIG.password,
+  })
+  const temporal = await getTemporalClient(TEMPORAL_CONFIG)
+
+  try {
+    const memberIds = await db.any(
+      `
+      SELECT DISTINCT ar."memberId" AS id
+      FROM "activityRelations" ar
+      JOIN "memberOrganizations" mo
+        ON ar."memberId" = mo."memberId"
+        AND ar."organizationId" = mo."organizationId"
+      LEFT JOIN "memberOrganizationAffiliationOverrides" moao
+        ON mo."id" = moao."memberOrganizationId"
+      WHERE ar."organizationId" = $1
+        AND (
+          (
+            mo."deletedAt" IS NOT NULL
+            AND NOT EXISTS (
+              SELECT 1
+              FROM "memberOrganizations" mo2
+              WHERE mo2."memberId" = mo."memberId"
+                AND mo2."organizationId" = mo."organizationId"
+                AND mo2."deletedAt" IS NULL
+            )
+          )
+          OR (
+            mo."deletedAt" IS NULL
+            AND moao."allowAffiliation" = false
+          )
+        );
+      `,
+      [organizationId],
+    )
+
+    log.info(`Found ${memberIds.length} members to process`)
+
+    if (memberIds.length === 0) {
+      log.info('No members found. Implement the query to get actual memberIds.')
+      return
+    }
+
+    if (dryRun) {
+      log.info('DRY RUN - Would update affiliations for the following members:')
+      memberIds.forEach((member: { id: string }) => {
+        log.info(`  - Member ID: ${member.id}`)
+      })
+      return
+    }
+
+    let processedCount = 0
+    for (const member of memberIds) {
+      try {
+        log.info(`Processing member: ${member.id}`)
+
+        const uuid = randomUUID()
+
+        await temporal.workflow.start('memberUpdate', {
+          taskQueue: 'profiles',
+          workflowId: `member-update-fix-unaffiliation/${organizationId}/${member.id}/${uuid}`,
+          retry: {
+            maximumAttempts: 10,
+          },
+          args: [
+            {
+              member: {
+                id: member.id,
+              },
+              memberOrganizationIds: [organizationId],
+              syncToOpensearch: false,
+            },
+          ],
+          searchAttributes: {
+            TenantId: ['875c38bd-2b1b-4e91-ad07-0cfbabb4c49f'], // default tenantId
+          },
+        })
+
+        processedCount++
+        log.info(`Successfully triggered workflow for member: ${member.id}`)
+      } catch (error) {
+        log.error(`Failed to process member ${member.id}:`, error)
+      }
+    }
+
+    log.info(`Script completed. Processed ${processedCount}/${memberIds.length} members.`)
+  } catch (error) {
+    log.error('Script failed:', error)
+    throw error
+  }
+
+  process.exit(0)
+})

services/libs/data-access-layer/src/old/apps/profiles_worker/index.ts

@@ -349,8 +349,11 @@ export async function runMemberAffiliationsUpdate(
     qx,
     memberId,
   )
+  logger.info(`orgCase for member ${memberId}: ${orgCases}`)
+  logger.info(`fullCase for member ${memberId}: ${fullCase}`)
 
   const { minTimestamp, maxTimestamp } = await getMemberActivityTimestampRanges(qDb, memberId)
+  logger.info(`MemberActivityTimestampRanges ${minTimestamp} ${maxTimestamp}`)
 
   const { processed, duration } = await updateActivities(
     qDb,