Member sync fixes (#2587)

CrowdDotDev · Aug 26, 2024 · ba44eea · ba44eea
1 parent a0308bb
commit ba44eea
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/services/apps/search_sync_worker/src/queue/index.ts b/services/apps/search_sync_worker/src/queue/index.ts
@@ -101,7 +101,9 @@ export class WorkerQueueReceiver extends SqsPrioritizedQueueReciever {
           case SearchSyncWorkerQueueMessageType.SYNC_MEMBER:
             if (data.memberId) {
               // await this.memberBatchProcessor.addToBatch(data.memberId)
-              await this.initMemberService().syncMembers(data.memberId)
+              await this.initMemberService().syncMembers(data.memberId, {
+                withAggs: data.withAggs ? data.withAggs : true,
+              })
             }
 
             break

diff --git a/services/libs/opensearch/src/service/member.sync.service.ts b/services/libs/opensearch/src/service/member.sync.service.ts
@@ -362,7 +362,7 @@ export class MemberSyncService {
 
   public async syncMembers(
     memberId: string,
-    opts: { withAggs?: boolean } = {},
+    opts: { withAggs?: boolean } = { withAggs: true },
   ): Promise<IMemberSyncResult> {
     const qx = repoQx(this.memberRepo)