feat: update member organization source rank handling

Signed-off-by: Yeganathan S <63534555+skwowet@users.noreply.github.com>

Author: skwowet

services/libs/common/src/member.ts

@@ -82,7 +82,7 @@ export const calculateReach = (oldReach: any, newReach: any): { total: number }
   return out
 }
 
-export function getMemberOrganizationSourceRank(source: string | undefined): number {
+export function getMemberOrganizationSourceRank(source: string | null | undefined): number {
   if (source === OrganizationSource.UI) return 0
   if (source === OrganizationSource.EMAIL_DOMAIN) return 1
   if (source?.startsWith('enrichment-')) return 2

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

@@ -1,4 +1,4 @@
-import { getLongestDateRange } from '@crowd/common'
+import { getLongestDateRange, getMemberOrganizationSourceRank } from '@crowd/common'
 import { IMemberOrganization } from '@crowd/types'
 
 import { BLACKLISTED_MEMBER_TITLES } from '../members/base'
@@ -22,6 +22,7 @@ export interface IWorkExperienceResolution {
   isPrimaryWorkExperience: boolean
   memberCount: number
   segmentId: string | null
+  source: string | null
 }
 
 /**
@@ -58,7 +59,8 @@ export async function findWorkExperiencesBulk(
         mo."createdAt",
         COALESCE(ovr."isPrimaryWorkExperience", false)      AS "isPrimaryWorkExperience",
         COALESCE(a.total_count, 0)                          AS "memberCount",
-        NULL::text                                          AS "segmentId"
+        NULL::text                                          AS "segmentId",
+        mo."source"
       FROM "memberOrganizations" mo
       JOIN organizations o ON mo."organizationId" = o.id
       LEFT JOIN "memberOrganizationAffiliationOverrides" ovr ON ovr."memberOrganizationId" = mo.id
@@ -92,7 +94,8 @@ export async function findManualAffiliationsBulk(
         NULL::timestamptz AS "createdAt",
         false             AS "isPrimaryWorkExperience",
         0                 AS "memberCount",
-        msa."segmentId"
+        msa."segmentId",
+        NULL              AS "source"
       FROM "memberSegmentAffiliations" msa
       JOIN organizations o ON msa."organizationId" = o.id
       WHERE msa."memberId" IN ($(memberIds:csv))
@@ -121,13 +124,21 @@ export function selectPrimaryWorkExperience(orgs: IWorkExperienceResolution[]) {
   const withDates = orgs.filter((r) => r.dateStart)
   if (withDates.length === 1) return withDates[0]
 
-  // 4. Org with strictly more members wins; if tied, fall through
+  // 4. Among dated rows, pick the best source tier (ui > email-domain > enrichment-*)
+  if (withDates.length > 1) {
+    const bestRank = Math.min(...withDates.map((r) => getMemberOrganizationSourceRank(r.source)))
+    const topSourceGroup = withDates.filter((r) => getMemberOrganizationSourceRank(r.source) === bestRank)
+    if (topSourceGroup.length === 1) return topSourceGroup[0]
+    orgs = topSourceGroup
+  }
+
+  // 5. Org with strictly more members wins; if tied, fall through
   const sorted = [...orgs].sort((a, b) => b.memberCount - a.memberCount)
   if (sorted.length >= 2 && sorted[0].memberCount > sorted[1].memberCount) {
     return sorted[0]
   }
 
-  // 5. Longest date range as final tiebreaker
+  // 6. Longest date range as final tiebreaker
   return getLongestDateRange(
     orgs as unknown as IMemberOrganization[],
   ) as unknown as IWorkExperienceResolution