From 110fe3df4ea286bdb95d64413c41f11881e8982d Mon Sep 17 00:00:00 2001
From: bosiraphael <raphael.bosi@gmail.com>
Date: Wed, 18 Sep 2024 17:38:54 +0200
Subject: [PATCH] fix job

---
 .../messaging-settings-manager-reimport-messages.job.ts    | 3 +--
 .../messaging-settings-manager-message-channel.listener.ts | 7 +++++--
 2 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/packages/twenty-server/src/modules/messaging/settings-manager/jobs/messaging-settings-manager-reimport-messages.job.ts b/packages/twenty-server/src/modules/messaging/settings-manager/jobs/messaging-settings-manager-reimport-messages.job.ts
index a3986187b..f48355c1f 100644
--- a/packages/twenty-server/src/modules/messaging/settings-manager/jobs/messaging-settings-manager-reimport-messages.job.ts
+++ b/packages/twenty-server/src/modules/messaging/settings-manager/jobs/messaging-settings-manager-reimport-messages.job.ts
@@ -4,7 +4,6 @@ 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 { MessageChannelSyncStatusService } from 'src/modules/messaging/common/services/message-channel-sync-status.service';
-import { MessagingCleanCacheJob } from 'src/modules/messaging/message-import-manager/jobs/messaging-clean-cache';
 
 export type MessagingSettingsManagerReimportMessagesJobData = {
   workspaceId: string;
@@ -21,7 +20,7 @@ export class MessagingSettingsManagerReimportMessagesJob {
     private readonly messageChannelSyncStatusService: MessageChannelSyncStatusService,
   ) {}
 
-  @Process(MessagingCleanCacheJob.name)
+  @Process(MessagingSettingsManagerReimportMessagesJob.name)
   async handle(
     data: MessagingSettingsManagerReimportMessagesJobData,
   ): Promise<void> {
diff --git a/packages/twenty-server/src/modules/messaging/settings-manager/listeners/messaging-settings-manager-message-channel.listener.ts b/packages/twenty-server/src/modules/messaging/settings-manager/listeners/messaging-settings-manager-message-channel.listener.ts
index 6785d94f1..d76687b45 100644
--- a/packages/twenty-server/src/modules/messaging/settings-manager/listeners/messaging-settings-manager-message-channel.listener.ts
+++ b/packages/twenty-server/src/modules/messaging/settings-manager/listeners/messaging-settings-manager-message-channel.listener.ts
@@ -8,7 +8,10 @@ import { MessageQueue } from 'src/engine/core-modules/message-queue/message-queu
 import { MessageQueueService } from 'src/engine/core-modules/message-queue/services/message-queue.service';
 import { WorkspaceEventBatch } from 'src/engine/workspace-event-emitter/workspace-event.type';
 import { MessageChannelWorkspaceEntity } from 'src/modules/messaging/common/standard-objects/message-channel.workspace-entity';
-import { MessagingSettingsManagerReimportMessagesJob } from 'src/modules/messaging/settings-manager/jobs/messaging-settings-manager-reimport-messages.job';
+import {
+  MessagingSettingsManagerReimportMessagesJob,
+  MessagingSettingsManagerReimportMessagesJobData,
+} from 'src/modules/messaging/settings-manager/jobs/messaging-settings-manager-reimport-messages.job';
 
 @Injectable()
 export class MessagingSettingsManagerMessageChannelListener {
@@ -38,7 +41,7 @@ export class MessagingSettingsManagerMessageChannelListener {
       .map((eventPayload) => eventPayload.properties.after.id);
 
     if (messageChannelsToReimport.length) {
-      await this.messageQueueService.add(
+      await this.messageQueueService.add<MessagingSettingsManagerReimportMessagesJobData>(
         MessagingSettingsManagerReimportMessagesJob.name,
         {
           workspaceId: payload.workspaceId,