use custom method

Author: skwowet

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

@@ -1,4 +1,4 @@
-import { insertActivities, queryActivities } from '@crowd/data-access-layer'
+import { insertActivities } from '@crowd/data-access-layer'
 import {
   IDbActivity,
   IDbActivityCreateData,
@@ -22,28 +22,13 @@ 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,
-          },
-        },
-      ],
-    },
-  })
-
-  return result.count
+  const repo = new ActivityRepository(svc.postgres.reader.connection(), svc.log, svc.questdbSQL)
+  return repo.findActivitiesQuestDb(memberId, organizationId)
 }
 
 export async function findActivitiesPg(memberId: string, orgId: string): Promise<IDbActivity[]> {
   const repo = new ActivityRepository(svc.postgres.reader.connection(), svc.log, svc.questdbSQL)
-  return repo.findActivities(memberId, orgId)
+  return repo.findActivitiesPg(memberId, orgId)
 }
 
 export async function createActivities(activities: IDbActivityCreateData[]): Promise<void> {

services/libs/data-access-layer/src/old/apps/script_executor_worker/activity.repo.ts

@@ -10,7 +10,7 @@ class ActivityRepository {
     private readonly questdbSQL: DbConnOrTx,
   ) {}
 
-  findActivities(memberId: string, organizationId: string): Promise<IDbActivity[]> {
+  async findActivitiesPg(memberId: string, organizationId: string): Promise<IDbActivity[]> {
     return this.connection.query(
       `select * from activities where "memberId" = $(memberId) and "organizationId" = $(organizationId)`,
       {
@@ -19,6 +19,18 @@ class ActivityRepository {
       },
     )
   }
+
+  async findActivitiesQuestDb(memberId: string, organizationId: string): Promise<number> {
+    const result = await this.questdbSQL.query(
+      `select count(*) from activities where "memberId" = $(memberId) and "organizationId" = $(organizationId)`,
+      {
+        memberId,
+        organizationId,
+      },
+    )
+
+    return result.rows[0].count
+  }
 }
 
 export default ActivityRepository