chore: remove unused affiliation recalculation schedules and workflows (#3838)

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/main.ts

@@ -7,7 +7,6 @@ import {
   scheduleRefreshMemberDisplayAggregates,
   scheduleRefreshOrganizationDisplayAggregates,
 } from './schedules/refreshDisplayAggregates'
-import { scheduleRecalculateAffiliationsOfNewRoles } from './schedules/triggerRecalculateAffiliationsOfNewRoles'
 
 const config: Config = {
   producer: {
@@ -38,8 +37,6 @@ export const svc = new ServiceWorker(config, options)
 setImmediate(async () => {
   await svc.init()
 
-  await scheduleRecalculateAffiliationsOfNewRoles()
-
   // Aggregate calculation schedules
   if (IS_DEV_ENV) {
     await scheduleCalculateLeafSegmentAggregates() // Every 5 minutes - calculates leaf/subproject aggregates

services/apps/profiles_worker/src/schedules/triggerRecalculateAffiliationsOfNewRoles.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/types/member.ts

@@ -4,9 +4,7 @@ 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 { triggerRecalculateAffiliations } from './workflows/member/triggerRecalculateAffiliations'
 import { calculateProjectGroupOrganizationAggregates } from './workflows/organization/calculateProjectGroupOrganizationAggregates'
 import { calculateProjectOrganizationAggregates } from './workflows/organization/calculateProjectOrganizationAggregates'
 import { organizationUpdate } from './workflows/organization/organizationUpdate'
@@ -15,8 +13,6 @@ import { refreshOrganizationDisplayAggregates } from './workflows/organization/r
 export {
   memberUpdate,
   organizationUpdate,
-  recalculateAffiliationsForNewRoles,
-  triggerRecalculateAffiliations,
   refreshMemberDisplayAggregates,
   refreshOrganizationDisplayAggregates,
   processMemberBotAnalysisWithLLM,