use pgsql db

Author: skwowet

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

@@ -8,7 +8,7 @@ export async function getSegmentMembers(
   limit: number,
   offset: number,
 ): Promise<string[]> {
-  const memberRepo = new MemberRepository(svc.questdbSQL, svc.log)
+  const memberRepo = new MemberRepository(svc.postgres.reader.connection(), svc.log)
   return memberRepo.getSegmentMembers(segmentId, limit, offset)
 }
 

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

@@ -1,4 +1,4 @@
-import { DbConnOrTx, DbConnection, DbTransaction } from '@crowd/database'
+import { DbConnection, DbTransaction } from '@crowd/database'
 import { Logger } from '@crowd/logging'
 import { IndexedEntityType } from '@crowd/opensearch/src/repo/indexing.data'
 import { IMember } from '@crowd/types'
@@ -9,7 +9,6 @@ class MemberRepository {
   constructor(
     private readonly connection: DbConnection | DbTransaction,
     private readonly log: Logger,
-    private readonly questdbSQL?: DbConnOrTx,
   ) {}
 
   async findMembersWithSameVerifiedEmailsInDifferentPlatforms(
@@ -174,7 +173,7 @@ class MemberRepository {
   }
 
   public async getSegmentMembers(segmentId: string, limit = 200, offset = 0): Promise<string[]> {
-    const results = await this.questdbSQL.any(
+    const results = await this.connection.query(
       `
       select distinct "memberId"
       from activities