admin/twenty
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix CreateCompaniesAndContactsAfterSyncJobData import (#3979)

Browse Source
This commit is contained in:
Weiko
2024-02-14 18:58:49 +01:00
committed by GitHub
parent 4613f64910
commit 2055f64acd
2 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
packages/twenty-server/src/workspace/messaging/jobs/create-companies-and-contacts-after-sync.job.ts
View File

@ -1,7 +1,5 @@
import { Injectable, Logger } from '@nestjs/common'; 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 { 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'; 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( async handle(
data: CreateContactsAndCompaniesAfterSyncJobData, data: CreateCompaniesAndContactsAfterSyncJobData,
): Promise<void> { ): Promise<void> {
this.logger.log( this.logger.log(
`create contacts and companies after sync for workspace ${data.workspaceId} and messageChannel ${data.messageChannelId}`, `create contacts and companies after sync for workspace ${data.workspaceId} and messageChannel ${data.messageChannelId}`,

9
packages/twenty-server/src/workspace/messaging/listeners/is-contact-auto-creation-enabled-listener.ts
View File

@ -1,14 +1,15 @@
import { Injectable, Inject } from '@nestjs/common'; import { Injectable, Inject } from '@nestjs/common';
import { OnEvent } from '@nestjs/event-emitter'; 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 { ObjectRecordUpdateEvent } from 'src/integrations/event-emitter/types/object-record-update.event';
import { MessageQueue } from 'src/integrations/message-queue/message-queue.constants'; import { MessageQueue } from 'src/integrations/message-queue/message-queue.constants';
import { MessageQueueService } from 'src/integrations/message-queue/services/message-queue.service'; 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 { 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 { 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() @Injectable()
export class IsContactAutoCreationEnabledListener { export class IsContactAutoCreationEnabledListener {
@ -28,7 +29,7 @@ export class IsContactAutoCreationEnabledListener {
).includes('isContactAutoCreationEnabled') && ).includes('isContactAutoCreationEnabled') &&
payload.updatedRecord.isContactAutoCreationEnabled payload.updatedRecord.isContactAutoCreationEnabled
) { ) {
this.messageQueueService.add<CreateContactsAndCompaniesAfterSyncJobData>( this.messageQueueService.add<CreateCompaniesAndContactsAfterSyncJobData>(
CreateCompaniesAndContactsAfterSyncJob.name, CreateCompaniesAndContactsAfterSyncJob.name,
{ {
workspaceId: payload.workspaceId, workspaceId: payload.workspaceId,