fix wrong payload

twentyhq · Aug 20, 2024 · 3ef6831 · 3ef6831
1 parent a63706f
commit 3ef6831
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 16 deletions.
diff --git a/...r/src/engine/api/graphql/workspace-query-runner/listeners/entity-events-to-db.listener.ts b/...r/src/engine/api/graphql/workspace-query-runner/listeners/entity-events-to-db.listener.ts
@@ -50,21 +50,16 @@ export class EntityEventsToDbListener {
   }
 
   private async handle(payload: WorkspaceEventBatch<ObjectRecordBaseEvent>) {
-    for (const eventPayload of payload.events) {
-      if (!eventPayload.objectMetadata?.isAuditLogged) {
-        continue;
-      }
+    payload.events = payload.events.filter(
+      (event) => event.objectMetadata?.isAuditLogged,
+    );
 
-      await Promise.all([
-        this.messageQueueService.add<ObjectRecordBaseEvent>(
-          CreateAuditLogFromInternalEvent.name,
-          eventPayload,
-        ),
-        this.messageQueueService.add<ObjectRecordBaseEvent>(
-          UpsertTimelineActivityFromInternalEvent.name,
-          eventPayload,
-        ),
-      ]);
-    }
+    await this.messageQueueService.add<
+      WorkspaceEventBatch<ObjectRecordBaseEvent>
+    >(CreateAuditLogFromInternalEvent.name, payload);
+
+    await this.messageQueueService.add<
+      WorkspaceEventBatch<ObjectRecordBaseEvent>
+    >(UpsertTimelineActivityFromInternalEvent.name, payload);
   }
 }
diff --git a/packages/twenty-server/src/engine/workspace-event-emitter/workspace-event-emitter.ts b/packages/twenty-server/src/engine/workspace-event-emitter/workspace-event-emitter.ts
@@ -8,6 +8,10 @@ export class WorkspaceEventEmitter {
   constructor(private readonly eventEmitter: EventEmitter2) {}
 
   public emit(eventName: string, events: any[], workspaceId: string) {
+    if (!events.length) {
+      return;
+    }
+
     return this.eventEmitter.emit(eventName, {
       name: eventName,
       workspaceId,

diff --git a/...c/modules/calendar/calendar-event-import-manager/services/calendar-save-events.service.ts b/...c/modules/calendar/calendar-event-import-manager/services/calendar-save-events.service.ts
@@ -145,7 +145,7 @@ export class CalendarSaveEventsService {
       [
         {
           workspaceMemberId: connectedAccount.accountOwnerId,
-          calendarEventParticipants: savedCalendarEventParticipantsToEmit,
+          participants: savedCalendarEventParticipantsToEmit,
         },
       ],
       workspaceId,