chore: remove deprecated affiliation handling functions and workflows

Author: skwowet

services/apps/profiles_worker/src/activities.ts

@@ -3,12 +3,7 @@ import {
   calculateAllMemberLeafAggregates,
   calculateAllOrganizationLeafAggregates,
 } from './activities/calculateLeafSegmentAggregates'
-import {
-  getAffiliationsLastCheckedAt,
-  getLLMResult,
-  getMemberIdsForAffiliationUpdates,
-  updateAffiliationsLastCheckedAt,
-} from './activities/common'
+import { getLLMResult } from './activities/common'
 import {
   createMemberBotSuggestion,
   createMemberNoBot,
@@ -45,9 +40,6 @@ import {
 
 export {
   updateMemberAffiliations,
-  getAffiliationsLastCheckedAt,
-  getMemberIdsForAffiliationUpdates,
-  updateAffiliationsLastCheckedAt,
   syncMember,
   syncOrganization,
   findMembersInOrganization,

services/apps/profiles_worker/src/activities/common.ts

@@ -1,40 +1,9 @@
 import { LlmService } from '@crowd/common_services'
 import { pgpQx } from '@crowd/data-access-layer'
-import {
-  getAffiliationsLastCheckedAt as getAffiliationsLastCheckedAtDAL,
-  getAllMemberIdsPaginated,
-  getMemberIdsWithRecentRoleChanges,
-  updateAffiliationsLastCheckedAt as updateAffiliationsLastCheckedAtOfTenant,
-} from '@crowd/data-access-layer/src/old/apps/profiles_worker'
 import { ILlmResponse, LlmQueryType } from '@crowd/types'
 
 import { svc } from '../main'
 
-export async function getAffiliationsLastCheckedAt(): Promise<string> {
-  return getAffiliationsLastCheckedAtDAL(svc.postgres.writer)
-}
-
-export async function getMemberIdsForAffiliationUpdates(
-  affiliationsLastChecked: string,
-  limit: number,
-  offset: number,
-): Promise<string[]> {
-  if (!affiliationsLastChecked) {
-    return getAllMemberIdsPaginated(svc.postgres.writer, limit, offset)
-  }
-
-  return getMemberIdsWithRecentRoleChanges(
-    svc.postgres.writer,
-    affiliationsLastChecked,
-    limit,
-    offset,
-  )
-}
-
-export async function updateAffiliationsLastCheckedAt(): Promise<void> {
-  await updateAffiliationsLastCheckedAtOfTenant(svc.postgres.writer)
-}
-
 export async function getLLMResult(
   queryType: LlmQueryType,
   prompt: string,

services/apps/profiles_worker/src/types/member.ts

@@ -8,10 +8,6 @@ export interface MemberUpdateInput {
   syncToOpensearch?: boolean
 }
 
-export interface IRecalculateAffiliationsForNewRolesInput {
-  offset?: number
-}
-
 export interface ProcessMemberBotSuggestionWithLLMInput {
   memberId: string
 }

services/apps/profiles_worker/src/workflows.ts

@@ -4,7 +4,6 @@ import { calculateProjectGroupMemberAggregates } from './workflows/member/calcul
 import { calculateProjectMemberAggregates } from './workflows/member/calculateProjectMemberAggregates'
 import { memberUpdate } from './workflows/member/memberUpdate'
 import { processMemberBotAnalysisWithLLM } from './workflows/member/processMemberBotAnalysisWithLLM'
-import { recalculateAffiliationsForNewRoles } from './workflows/member/recalculateAffiliationsForNewRoles'
 import { refreshMemberDisplayAggregates } from './workflows/member/refreshMemberDisplayAggregates'
 import { calculateProjectGroupOrganizationAggregates } from './workflows/organization/calculateProjectGroupOrganizationAggregates'
 import { calculateProjectOrganizationAggregates } from './workflows/organization/calculateProjectOrganizationAggregates'
@@ -14,7 +13,6 @@ import { refreshOrganizationDisplayAggregates } from './workflows/organization/r
 export {
   memberUpdate,
   organizationUpdate,
-  recalculateAffiliationsForNewRoles,
   refreshMemberDisplayAggregates,
   refreshOrganizationDisplayAggregates,
   processMemberBotAnalysisWithLLM,