scottk/twenty
1
0
Fork 0
mirror of https://github.com/lingble/twenty.git synced 2025-10-30 20:27:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix job

Browse Source
This commit is contained in:
bosiraphael
2024-09-18 17:38:54 +02:00
parent ee630e04ce
commit 110fe3df4e
2 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
packages/twenty-server/src/modules/messaging/settings-manager/jobs/messaging-settings-manager-reimport-messages.job.ts
View File

@@ -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 { Processor } from 'src/engine/core-modules/message-queue/decorators/processor.decorator';
import { MessageQueue } from 'src/engine/core-modules/message-queue/message-queue.constants'; 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 { 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 = { export type MessagingSettingsManagerReimportMessagesJobData = {
workspaceId: string; workspaceId: string;
@@ -21,7 +20,7 @@ export class MessagingSettingsManagerReimportMessagesJob {
private readonly messageChannelSyncStatusService: MessageChannelSyncStatusService, private readonly messageChannelSyncStatusService: MessageChannelSyncStatusService,
) {} ) {}
@Process(MessagingCleanCacheJob.name) @Process(MessagingSettingsManagerReimportMessagesJob.name)
async handle( async handle(
data: MessagingSettingsManagerReimportMessagesJobData, data: MessagingSettingsManagerReimportMessagesJobData,
): Promise<void> { ): Promise<void> {

7
packages/twenty-server/src/modules/messaging/settings-manager/listeners/messaging-settings-manager-message-channel.listener.ts
View File

@@ -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 { MessageQueueService } from 'src/engine/core-modules/message-queue/services/message-queue.service';
import { WorkspaceEventBatch } from 'src/engine/workspace-event-emitter/workspace-event.type'; 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 { 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() @Injectable()
export class MessagingSettingsManagerMessageChannelListener { export class MessagingSettingsManagerMessageChannelListener {
@@ -38,7 +41,7 @@ export class MessagingSettingsManagerMessageChannelListener {
.map((eventPayload) => eventPayload.properties.after.id); .map((eventPayload) => eventPayload.properties.after.id);
if (messageChannelsToReimport.length) { if (messageChannelsToReimport.length) {
await this.messageQueueService.add( await this.messageQueueService.add<MessagingSettingsManagerReimportMessagesJobData>(
MessagingSettingsManagerReimportMessagesJob.name, MessagingSettingsManagerReimportMessagesJob.name,
{ {
workspaceId: payload.workspaceId, workspaceId: payload.workspaceId,