diff --git a/packages/twenty-server/src/workspace/messaging/jobs/create-companies-and-contacts-after-sync.job.ts b/packages/twenty-server/src/workspace/messaging/jobs/create-companies-and-contacts-after-sync.job.ts index efe6504ec..1071397d2 100644 --- a/packages/twenty-server/src/workspace/messaging/jobs/create-companies-and-contacts-after-sync.job.ts +++ b/packages/twenty-server/src/workspace/messaging/jobs/create-companies-and-contacts-after-sync.job.ts @@ -1,7 +1,5 @@ import { Injectable, Logger } from '@nestjs/common'; -import { CreateContactsAndCompaniesAfterSyncJobData } from 'packages/twenty-server/dist/src/workspace/messaging/jobs/create-contacts-and-companies-after-sync.job'; - import { MessageQueueJob } from 'src/integrations/message-queue/interfaces/message-queue-job.interface'; import { CreateCompaniesAndContactsService } from 'src/workspace/messaging/services/create-companies-and-contacts/create-companies-and-contacts.service'; @@ -27,7 +25,7 @@ export class CreateCompaniesAndContactsAfterSyncJob ) {} async handle( - data: CreateContactsAndCompaniesAfterSyncJobData, + data: CreateCompaniesAndContactsAfterSyncJobData, ): Promise { this.logger.log( `create contacts and companies after sync for workspace ${data.workspaceId} and messageChannel ${data.messageChannelId}`, diff --git a/packages/twenty-server/src/workspace/messaging/listeners/is-contact-auto-creation-enabled-listener.ts b/packages/twenty-server/src/workspace/messaging/listeners/is-contact-auto-creation-enabled-listener.ts index 72d5cee63..02c29283a 100644 --- a/packages/twenty-server/src/workspace/messaging/listeners/is-contact-auto-creation-enabled-listener.ts +++ b/packages/twenty-server/src/workspace/messaging/listeners/is-contact-auto-creation-enabled-listener.ts @@ -1,14 +1,15 @@ import { Injectable, Inject } from '@nestjs/common'; import { OnEvent } from '@nestjs/event-emitter'; -import { CreateContactsAndCompaniesAfterSyncJobData } from 'packages/twenty-server/dist/src/workspace/messaging/jobs/create-contacts-and-companies-after-sync.job'; - import { ObjectRecordUpdateEvent } from 'src/integrations/event-emitter/types/object-record-update.event'; import { MessageQueue } from 'src/integrations/message-queue/message-queue.constants'; import { MessageQueueService } from 'src/integrations/message-queue/services/message-queue.service'; import { MessageChannelObjectMetadata } from 'src/workspace/workspace-sync-metadata/standard-objects/message-channel.object-metadata'; import { objectRecordChangedProperties as objectRecordUpdateEventChangedProperties } from 'src/integrations/event-emitter/utils/object-record-changed-properties.util'; -import { CreateCompaniesAndContactsAfterSyncJob } from 'src/workspace/messaging/jobs/create-companies-and-contacts-after-sync.job'; +import { + CreateCompaniesAndContactsAfterSyncJob, + CreateCompaniesAndContactsAfterSyncJobData, +} from 'src/workspace/messaging/jobs/create-companies-and-contacts-after-sync.job'; @Injectable() export class IsContactAutoCreationEnabledListener { @@ -28,7 +29,7 @@ export class IsContactAutoCreationEnabledListener { ).includes('isContactAutoCreationEnabled') && payload.updatedRecord.isContactAutoCreationEnabled ) { - this.messageQueueService.add( + this.messageQueueService.add( CreateCompaniesAndContactsAfterSyncJob.name, { workspaceId: payload.workspaceId,