Debug webhook job

2025-09-23 23:44:36 +02:00
1 changed files with 11 additions and 3 deletions
@@ -5,18 +5,20 @@ 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';
+import { Logger } from '@nestjs/common';

@Processor(MessageQueue.webhookQueue)
 export class CallWebhookJobsJob {
+  private readonly logger = new Logger(CallWebhookJobsJob.name);
  constructor(
    @InjectMessageQueue(MessageQueue.webhookQueue)
    private readonly messageQueueService: MessageQueueService,
@@ -32,6 +34,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(