debug error

Author: skwowet

services/apps/script_executor_worker/src/activities.ts

@@ -15,7 +15,6 @@ import {
   calculateMemberAffiliations,
   createActivities,
   findActivitiesPg,
-  getActivities,
   getMembersWithDeletedOrgAffilations,
 } from './activities/fix-deleted-member-org-affilations'
 import {
@@ -68,7 +67,7 @@ export {
   deleteIndexedEntities,
   markEntitiesIndexed,
   getMembersWithDeletedOrgAffilations,
-  getActivities,
+  // getActivities,
   findActivitiesPg,
   createActivities,
   addOrgIdToRedisCache,

services/apps/script_executor_worker/src/activities/fix-deleted-member-org-affilations/index.ts

@@ -21,25 +21,25 @@ export async function getMembersWithDeletedOrgAffilations(
   }
 }
 
-export async function getActivities(memberId: string, organizationId: string): Promise<number> {
-  const result = await queryActivities(svc.questdbSQL, {
-    countOnly: true,
-    filter: {
-      and: [
-        {
-          memberId: {
-            eq: memberId,
-          },
-          organizationId: {
-            eq: organizationId,
-          },
-        },
-      ],
-    },
-  })
+// export async function getActivities(memberId: string, organizationId: string): Promise<number> {
+//   const result = await queryActivities(svc.questdbSQL, {
+//     countOnly: true,
+//     filter: {
+//       and: [
+//         {
+//           memberId: {
+//             eq: memberId,
+//           },
+//           organizationId: {
+//             eq: organizationId,
+//           },
+//         },
+//       ],
+//     },
+//   })
 
-  return result.count
-}
+//   return result.count
+// }
 
 export async function findActivitiesPg(memberId: string, orgId: string): Promise<IDbActivity[]> {
   const repo = new ActivityRepository(svc.postgres.reader.connection(), svc.log, svc.questdbSQL)

services/apps/script_executor_worker/src/workflows/fixDeletedMemberOrgAffilations.ts

@@ -26,30 +26,33 @@ export async function fixDeletedMemberOrgAffilations(
   // 1. Find affected memberId and orgId
   const affectedMembers = await activity.getMembersWithDeletedOrgAffilations(BATCH_SIZE, args.date)
 
-  for (const { memberId, organizationId } of affectedMembers) {
-    // 2. Check if they have activity in questDb
-    const activityCount = await activity.getActivities(memberId, organizationId)
-
-    // 2.1 If no activities found, we need to get and insert them
-    if (activityCount === 0) {
-      console.log(
-        `No activities found for member ${memberId} and org ${organizationId}, creating from postgres!`,
-      )
-      const activities = await activity.findActivitiesPg(memberId, organizationId)
-      await activity.createActivities(activities)
-    }
-
-    // 3. Calculate affiliation
-    console.log(`Calculating member affiliations for ${memberId}`)
-    await activity.calculateMemberAffiliations(memberId)
-
-    // 4. sync member
-    await syncActivity.syncMembersBatch([memberId], true)
-
-    // 5. Add organizationId to redisCache for sync
-    console.log(`Adding org ${organizationId} to redisCache for sync`)
-    await activity.addOrgIdToRedisCache(organizationId)
-  }
+  // todo: rm this
+  console.log('affected members length', affectedMembers.length)
+
+  // for (const { memberId, organizationId } of affectedMembers) {
+  //   // 2. Check if they have activity in questDb
+  //   const activityCount = await activity.getActivities(memberId, organizationId)
+
+  //   // 2.1 If no activities found, we need to get and insert them
+  //   if (activityCount === 0) {
+  //     console.log(
+  //       `No activities found for member ${memberId} and org ${organizationId}, creating from postgres!`,
+  //     )
+  //     const activities = await activity.findActivitiesPg(memberId, organizationId)
+  //     await activity.createActivities(activities)
+  //   }
+
+  //   // 3. Calculate affiliation
+  //   console.log(`Calculating member affiliations for ${memberId}`)
+  //   await activity.calculateMemberAffiliations(memberId)
+
+  //   // 4. sync member
+  //   await syncActivity.syncMembersBatch([memberId], true)
+
+  //   // 5. Add organizationId to redisCache for sync
+  //   console.log(`Adding org ${organizationId} to redisCache for sync`)
+  //   await activity.addOrgIdToRedisCache(organizationId)
+  // }
 
   if (args.testRun) {
     console.log('Test run completed!')