chore: reuse the script

Author: skwowet

services/apps/merge_suggestions_worker/src/activities/memberMergeSuggestions.ts

@@ -267,18 +267,16 @@ export async function updateMemberMergeSuggestionsLastGeneratedAt(tenantId: stri
 export async function getMembers(
   tenantId: string,
   batchSize: number,
-  // afterMemberId?: string,
+  afterMemberId?: string,
   lastGeneratedAt?: string,
-  exactMemberId?: string,
 ): Promise<IMemberBaseForMergeSuggestions[]> {
   try {
     const qx = pgpQx(svc.postgres.reader.connection())
     const rows = await queryMembers(qx, {
       filter: {
         and: [
           { [MemberField.TENANT_ID]: { eq: tenantId } },
-          exactMemberId ? { [MemberField.ID]: { eq: exactMemberId } } : null,
-          // afterMemberId ? { [MemberField.ID]: { gt: afterMemberId } } : null,
+          afterMemberId ? { [MemberField.ID]: { gt: afterMemberId } } : null,
           // Include members updated after the last generation to cover both new and modified ones
           lastGeneratedAt ? { [MemberField.UPDATED_AT]: { gt: lastGeneratedAt } } : null,
         ],

services/apps/merge_suggestions_worker/src/types.ts

@@ -115,6 +115,6 @@ export interface ISimilarOrganizationOpensearchResult {
   _source: IOrganizationOpensearch
 }
 
-export interface ITestMemberOpenSearchResultsArgs {
-  memberId: string
+export interface ITestOrganizationOpenSearchResultsArgs {
+  organizationId: string
 }

services/apps/merge_suggestions_worker/src/workflows/testMemberOpenSearcResults.ts

@@ -1,41 +1,41 @@
 import { proxyActivities } from '@temporalio/workflow'
 
-import * as memberActivities from '../activities/memberMergeSuggestions'
-import { ITestMemberOpenSearchResultsArgs } from '../types'
+import * as organizationActivities from '../activities/organizationMergeSuggestions'
+import { ITestOrganizationOpenSearchResultsArgs } from '../types'
 
-const memberActivitiesProxy = proxyActivities<typeof memberActivities>({
+const organizationActivitiesProxy = proxyActivities<typeof organizationActivities>({
   startToCloseTimeout: '10 minute',
 })
 
-export async function testMemberOpenSearchResults(
-  args: ITestMemberOpenSearchResultsArgs,
+export async function testOrganizationOpenSearchResults(
+  args: ITestOrganizationOpenSearchResultsArgs,
 ): Promise<void> {
-  console.log(`Testing OpenSearch results for member: ${args.memberId}`)
+  console.log(`Testing OpenSearch results for organization: ${args.organizationId}`)
 
   const DEFAULT_TENANT_ID = '875c38bd-2b1b-4e91-ad07-0cfbabb4c49f'
 
-  // First get the member details
-  const results = await memberActivitiesProxy.getMembers(
+  // First get the organization details
+  const results = await organizationActivitiesProxy.getOrganizations(
     DEFAULT_TENANT_ID,
     1,
     null,
     null,
-    args.memberId,
+    [args.organizationId],
   )
 
   if (results.length === 0) {
-    console.log('Member not found!')
+    console.log('Organization not found!')
     return
   }
 
-  const member = results[0]
-  console.log('Member details:')
-  console.log(JSON.stringify(member, null, 2))
+  const organization = results[0]
+  console.log('Organization details:')
+  console.log(JSON.stringify(organization, null, 2))
 
   // Get merge suggestions for this member
-  const suggestions = await memberActivitiesProxy.getMemberMergeSuggestions(
+  const suggestions = await organizationActivitiesProxy.getOrganizationMergeSuggestions(
     DEFAULT_TENANT_ID,
-    member,
+    organization,
   )
 
   if (suggestions.length === 0) {