Add segment id to automation processing (#1068)

CrowdDotDev · Jul 4, 2023 · 21caf52 · 21caf52
1 parent 6182517
commit 21caf52
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 4 deletions.
diff --git a/services/apps/data_sink_worker/src/service/activity.service.ts b/services/apps/data_sink_worker/src/service/activity.service.ts
@@ -74,8 +74,7 @@ export default class ActivityService extends LoggerBase {
 
         return id
       })
-
-      await this.nodejsWorkerEmitter.processAutomationForNewActivity(tenantId, id)
+      await this.nodejsWorkerEmitter.processAutomationForNewActivity(tenantId, id, segmentId)
       const affectedIds = await this.conversationService.processActivity(tenantId, id)
 
       if (fireSync) {

diff --git a/services/libs/sqs/src/instances/nodejsWorker.ts b/services/libs/sqs/src/instances/nodejsWorker.ts
@@ -26,8 +26,12 @@ export class NodejsWorkerEmitter extends SqsQueueEmitter {
   public async processAutomationForNewActivity(
     tenantId: string,
     activityId: string,
+    segmentId: string,
   ): Promise<void> {
-    await this.sendMessage(tenantId, new NewActivityAutomationQueueMessage(tenantId, activityId))
+    await this.sendMessage(
+      tenantId,
+      new NewActivityAutomationQueueMessage(tenantId, activityId, segmentId),
+    )
   }
 
   public async processAutomationForNewMember(tenantId: string, memberId: string): Promise<void> {

diff --git a/services/libs/types/src/queue/nodejs_worker/index.ts b/services/libs/types/src/queue/nodejs_worker/index.ts
@@ -9,7 +9,11 @@ export class NewActivityAutomationQueueMessage implements IQueueMessage {
   public readonly trigger = 'new_activity'
   public readonly service = 'automation'
 
-  constructor(public readonly tenant: string, public readonly activityId: unknown) {}
+  constructor(
+    public readonly tenant: string,
+    public readonly activityId: unknown,
+    public readonly segmentId: string,
+  ) {}
 }
 
 export class NewMemberAutomationQueueMessage implements IQueueMessage {