Automations - bugfix when processing activities (#1822)

Author: Uros Marolt

services/apps/automations_worker/src/repos/data.repo.ts

@@ -93,8 +93,8 @@ export class DataRepository extends RepositoryBase<DataRepository> {
 
       // load members and object members
       let memberIds = results.filter((r) => r.memberId).map((r) => r.memberId)
-      memberIds = memberIds.concat(
-        results.filter((r) => r.objectMemberId).map((r) => r.objectMemberId),
+      memberIds = distinct(
+        memberIds.concat(results.filter((r) => r.objectMemberId).map((r) => r.objectMemberId)),
       )
       if (memberIds.length > 0) {
         promises.push(
@@ -184,7 +184,8 @@ export class DataRepository extends RepositoryBase<DataRepository> {
         m."manuallyCreated",
         m."createdAt",
         m."tenantId",
-        m."createdById"
+        m."createdById",
+        m.score
     from members m
     where m.id in ($(memberIds:csv))
       and m."deletedAt" is null;

services/apps/automations_worker/src/repos/types.ts

@@ -5,6 +5,7 @@ export interface IMemberData {
   tenantId: string
   attributes: any
 
+  score: number
   username: Record<string, string[]>
   identities: string[]
   segments: unknown[]