fix: refresh affiliation on update (CM-1118)

services/apps/members_enrichment_worker/src/activities/enrichment.ts

@@ -8,6 +8,7 @@
   replaceDoubleQuotes,
   setAttributesDefaultValues,
 } from '@crowd/common'
+import { CommonMemberService } from '@crowd/common_services'
 import {
   changeMemberOrganizationAffiliationOverrides,
   checkOrganizationAffiliationPolicy,
@@ -287,7 +288,9 @@
   hasContributions: boolean,
   isHighConfidenceSourceSelectedForWorkExperiences: boolean,
 ): Promise<boolean> {
-  return await svc.postgres.writer.transactionally(async (tx) => {
+  const affectedOrgIds: string[] = []
+
+  const updated = await svc.postgres.writer.transactionally(async (tx) => {
     let updated = false
     const qx = dbStoreQx(tx)
 
@@ -460,6 +463,7 @@
       if (results.toDelete.length > 0) {
         for (const org of results.toDelete) {
           updated = true
+          affectedOrgIds.push(org.orgId)
           await deleteMemberOrgById(tx.transaction(), org.id)
         }
       }
@@ -470,6 +474,7 @@
             throw new Error('Organization ID is missing!')
           }
           updated = true
+          affectedOrgIds.push(org.organizationId)
 
           const newMemberOrgId = await insertWorkExperience(
             tx.transaction(),
@@ -493,6 +498,7 @@
       if (results.toUpdate.size > 0) {
         for (const [memberOrg, toUpdate] of results.toUpdate) {
           updated = true
+          affectedOrgIds.push(memberOrg.orgId)
           const updatedMemberOrgId = await updateMemberOrg(
             tx.transaction(),
             memberId,
@@ -538,6 +544,19 @@
 
     return updated
   })
+
+  if (affectedOrgIds.length > 0) {
+    const commonMemberService = new CommonMemberService(
+      pgpQx(svc.postgres.writer.connection()),
+      svc.temporal,
+      svc.log,
+    )
+    await commonMemberService.startAffiliationRecalculation(memberId, [
+      ...new Set(affectedOrgIds),
+    ])
+  }
+
+  return updated
 }
 
 export function doesIncomingOrgExistInExistingOrgs(