Compare commits

...

2 Commits

Author SHA1 Message Date
Charles Bochet 390b873a2a Fix 2025-09-23 23:57:28 +02:00
Charles Bochet c16ff61cbc Debug webhook job 2025-09-23 23:44:36 +02:00
2 changed files with 23 additions and 12 deletions
@@ -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(
@@ -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(),