Deciding primary org id on memberCount fixes (#2875)

Author: epipav

services/apps/nango_worker/src/activities/nangoActivities.ts

@@ -11,7 +11,7 @@ import {
   getNangoCloudRecords,
   initNangoCloudClient,
 } from '@crowd/nango'
-import { AuthProvider, IntegrationResultType } from '@crowd/types'
+import { IntegrationResultType } from '@crowd/types'
 
 import { svc } from '../main'
 import { IProcessNangoWebhookArguments } from '../types'

services/libs/data-access-layer/src/old/apps/data_sink_worker/repo/memberAffiliation.repo.ts

@@ -1,7 +1,11 @@
 import { DbStore, RepositoryBase } from '@crowd/database'
 import { Logger } from '@crowd/logging'
 
-import { IManualAffiliationData, IWorkExperienceData } from './memberAffiliation.data'
+import {
+  IManualAffiliationData,
+  IOrganizationMemberCount,
+  IWorkExperienceData,
+} from './memberAffiliation.data'
 
 export default class MemberAffiliationRepository extends RepositoryBase<MemberAffiliationRepository> {
   private BLACKLISTED_TITLES = ['Investor', 'Mentor', 'Board Member']
@@ -67,12 +71,12 @@ export default class MemberAffiliationRepository extends RepositoryBase<MemberAf
 
   public async findMemberCountEstimateOfOrganizations(
     organizationIds: string[],
-  ): Promise<IWorkExperienceData | null> {
-    const result = await this.db().oneOrNone(
+  ): Promise<IOrganizationMemberCount[] | null> {
+    const result = await this.db().manyOrNone(
       `
         SELECT
           osa."organizationId",
-          sum(osa."memberCount") AS total_count
+          sum(osa."memberCount") AS "memberCount
       FROM "organizationSegmentsAgg" osa
       WHERE osa."segmentId" IN (
           SELECT id