chore: cleanup

Signed-off-by: Uroš Marolt <uros@marolt.me>

Author: themarolt

services/apps/script_executor_worker/src/activities.ts

@@ -14,6 +14,7 @@ import {
   syncRemoveOrganization,
 } from './activities/cleanup/organization'
 import {
+  calculateMemberAffiliations,
   getWorkflowsCount,
   mergeMembers,
   mergeOrganizations,
@@ -26,7 +27,6 @@ import {
   findMemberIdentitiesGroupedByPlatform,
   findMemberMergeActions,
 } from './activities/dissect-member'
-import { calculateMemberAffiliations } from './activities/fix-activity-foreign-keys'
 import {
   getBotMembersWithOrgAffiliation,
   removeBotMemberOrganization,

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

@@ -1,5 +1,7 @@
 import axios from 'axios'
 
+import { pgpQx } from '@crowd/data-access-layer'
+import { refreshMemberOrganizationAffiliations } from '@crowd/data-access-layer/src/member-organization-affiliation'
 import { findOrganizationSegments } from '@crowd/data-access-layer/src/old/apps/entity_merging_worker'
 import {
   IMemberIdentity,
@@ -155,3 +157,12 @@ export async function getWorkflowsCount(workflowType: string, status: string): P
     throw error
   }
 }
+
+export async function calculateMemberAffiliations(memberId: string): Promise<void> {
+  try {
+    const qx = pgpQx(svc.postgres.writer.connection())
+    await refreshMemberOrganizationAffiliations(qx, memberId)
+  } catch (err) {
+    throw new Error(err)
+  }
+}