From 58e1a2261d3032037c1a52a2e43fa143021f809c Mon Sep 17 00:00:00 2001
From: Charles Bochet <charlesBochet@users.noreply.github.com>
Date: Wed, 24 Sep 2025 15:47:49 +0200
Subject: [PATCH] Debug webhook job (#14675)

---
 .../webhook/jobs/call-webhook-jobs.job.ts     | 15 +++++++++++---
 .../services/sync-message-folders.service.ts  | 20 ++++++++++---------
 2 files changed, 23 insertions(+), 12 deletions(-)

diff --git a/packages/twenty-server/src/engine/core-modules/webhook/jobs/call-webhook-jobs.job.ts b/packages/twenty-server/src/engine/core-modules/webhook/jobs/call-webhook-jobs.job.ts
index 743101e8c7c..2e33a8b92b2 100644
--- a/packages/twenty-server/src/engine/core-modules/webhook/jobs/call-webhook-jobs.job.ts
+++ b/packages/twenty-server/src/engine/core-modules/webhook/jobs/call-webhook-jobs.job.ts
@@ -1,3 +1,5 @@
+import { Logger } from '@nestjs/common';
+
 import { isDefined } from 'twenty-shared/utils';
 
 import { InjectMessageQueue } from 'src/engine/core-modules/message-queue/decorators/message-queue.decorator';
@@ -5,18 +7,19 @@ import { Process } from 'src/engine/core-modules/message-queue/decorators/proces
 import { Processor } from 'src/engine/core-modules/message-queue/decorators/processor.decorator';
 import { MessageQueue } from 'src/engine/core-modules/message-queue/message-queue.constants';
 import { MessageQueueService } from 'src/engine/core-modules/message-queue/services/message-queue.service';
-import { WebhookService } from 'src/engine/core-modules/webhook/webhook.service';
-import { type ObjectMetadataEntity } from 'src/engine/metadata-modules/object-metadata/object-metadata.entity';
-import { WorkspaceEventBatch } from 'src/engine/workspace-event-emitter/types/workspace-event.type';
 import {
   CallWebhookJob,
   type CallWebhookJobData,
 } from 'src/engine/core-modules/webhook/jobs/call-webhook.job';
 import { type ObjectRecordEventForWebhook } from 'src/engine/core-modules/webhook/types/object-record-event-for-webhook.type';
+import { WebhookService } from 'src/engine/core-modules/webhook/webhook.service';
+import { type ObjectMetadataEntity } from 'src/engine/metadata-modules/object-metadata/object-metadata.entity';
+import { WorkspaceEventBatch } from 'src/engine/workspace-event-emitter/types/workspace-event.type';
 import { removeSecretFromWebhookRecord } from 'src/utils/remove-secret-from-webhook-record';
 
 @Processor(MessageQueue.webhookQueue)
 export class CallWebhookJobsJob {
+  private readonly logger = new Logger(CallWebhookJobsJob.name);
   constructor(
     @InjectMessageQueue(MessageQueue.webhookQueue)
     private readonly messageQueueService: MessageQueueService,
@@ -32,6 +35,12 @@ export class CallWebhookJobsJob {
     // Also change the openApi schema for webhooks
     // packages/twenty-server/src/engine/core-modules/open-api/utils/computeWebhooks.utils.ts
 
+    this.logger.log(
+      'workspaceEventBatch',
+      workspaceEventBatch.name,
+      workspaceEventBatch.workspaceId,
+      workspaceEventBatch.events.length,
+    );
     const [nameSingular, operation] = workspaceEventBatch.name.split('.');
 
     const webhooks = await this.webhookService.findByOperations(
diff --git a/packages/twenty-server/src/modules/messaging/message-folder-manager/services/sync-message-folders.service.ts b/packages/twenty-server/src/modules/messaging/message-folder-manager/services/sync-message-folders.service.ts
index c7a2d959318..1f778e90dae 100644
--- a/packages/twenty-server/src/modules/messaging/message-folder-manager/services/sync-message-folders.service.ts
+++ b/packages/twenty-server/src/modules/messaging/message-folder-manager/services/sync-message-folders.service.ts
@@ -77,16 +77,18 @@ export class SyncMessageFoldersService {
       );
 
       if (existingFolder) {
-        await messageFolderRepository.update(
-          existingFolder.id,
-          {
-            name: folder.name,
-            externalId: folder.externalId,
-            isSentFolder: folder.isSentFolder,
-          },
-          manager,
-        );
+        // TODO: this code should be refactored to use the updateMany method and only on folders that need to be updated
+        // await messageFolderRepository.update(
+        //   existingFolder.id,
+        //   {
+        //     name: folder.name,
+        //     externalId: folder.externalId,
+        //     isSentFolder: folder.isSentFolder,
+        //   },
+        //   manager,
+        // );
       } else {
+        // TODO: this code should be refactored to use the create (many)
         await messageFolderRepository.save(
           {
             id: v4(),