4745 move common logic between messaging and calendar in packagestwenty serversrcmodulesconnected account (#4962)

Closes #4745

packages/twenty-server/src/modules/calendar-messaging-participant/jobs/match-participant.job.ts

@@ -0,0 +1,60 @@
+import { Injectable } from '@nestjs/common';
+import { InjectRepository } from '@nestjs/typeorm';
+
+import { Repository } from 'typeorm';
+
+import { MessageQueueJob } from 'src/engine/integrations/message-queue/interfaces/message-queue-job.interface';
+
+import {
+  FeatureFlagEntity,
+  FeatureFlagKeys,
+} from 'src/engine/core-modules/feature-flag/feature-flag.entity';
+import { CalendarEventParticipantService } from 'src/modules/calendar/services/calendar-event-participant/calendar-event-participant.service';
+import { MessageParticipantService } from 'src/modules/messaging/services/message-participant/message-participant.service';
+
+export type MatchParticipantJobData = {
+  workspaceId: string;
+  email: string;
+  personId?: string;
+  workspaceMemberId?: string;
+};
+
+@Injectable()
+export class MatchParticipantJob
+  implements MessageQueueJob<MatchParticipantJobData>
+{
+  constructor(
+    private readonly messageParticipantService: MessageParticipantService,
+    private readonly calendarEventParticipantService: CalendarEventParticipantService,
+    @InjectRepository(FeatureFlagEntity, 'core')
+    private readonly featureFlagRepository: Repository<FeatureFlagEntity>,
+  ) {}
+
+  async handle(data: MatchParticipantJobData): Promise<void> {
+    const { workspaceId, email, personId, workspaceMemberId } = data;
+
+    await this.messageParticipantService.matchMessageParticipants(
+      workspaceId,
+      email,
+      personId,
+      workspaceMemberId,
+    );
+
+    const isCalendarEnabled = await this.featureFlagRepository.findOneBy({
+      workspaceId,
+      key: FeatureFlagKeys.IsCalendarEnabled,
+      value: true,
+    });
+
+    if (!isCalendarEnabled || !isCalendarEnabled.value) {
+      return;
+    }
+
+    await this.calendarEventParticipantService.matchCalendarEventParticipants(
+      workspaceId,
+      email,
+      personId,
+      workspaceMemberId,
+    );
+  }
+}

packages/twenty-server/src/modules/calendar-messaging-participant/jobs/unmatch-participant.job.ts

@@ -0,0 +1,60 @@
+import { Injectable } from '@nestjs/common';
+import { InjectRepository } from '@nestjs/typeorm';
+
+import { Repository } from 'typeorm';
+
+import { MessageQueueJob } from 'src/engine/integrations/message-queue/interfaces/message-queue-job.interface';
+
+import {
+  FeatureFlagEntity,
+  FeatureFlagKeys,
+} from 'src/engine/core-modules/feature-flag/feature-flag.entity';
+import { CalendarEventParticipantService } from 'src/modules/calendar/services/calendar-event-participant/calendar-event-participant.service';
+import { MessageParticipantService } from 'src/modules/messaging/services/message-participant/message-participant.service';
+
+export type UnmatchParticipantJobData = {
+  workspaceId: string;
+  email: string;
+  personId?: string;
+  workspaceMemberId?: string;
+};
+
+@Injectable()
+export class UnmatchParticipantJob
+  implements MessageQueueJob<UnmatchParticipantJobData>
+{
+  constructor(
+    private readonly messageParticipantService: MessageParticipantService,
+    private readonly calendarEventParticipantService: CalendarEventParticipantService,
+    @InjectRepository(FeatureFlagEntity, 'core')
+    private readonly featureFlagRepository: Repository<FeatureFlagEntity>,
+  ) {}
+
+  async handle(data: UnmatchParticipantJobData): Promise<void> {
+    const { workspaceId, email, personId, workspaceMemberId } = data;
+
+    await this.messageParticipantService.unmatchMessageParticipants(
+      workspaceId,
+      email,
+      personId,
+      workspaceMemberId,
+    );
+
+    const isCalendarEnabled = await this.featureFlagRepository.findOneBy({
+      workspaceId,
+      key: FeatureFlagKeys.IsCalendarEnabled,
+      value: true,
+    });
+
+    if (!isCalendarEnabled || !isCalendarEnabled.value) {
+      return;
+    }
+
+    await this.calendarEventParticipantService.unmatchCalendarEventParticipants(
+      workspaceId,
+      email,
+      personId,
+      workspaceMemberId,
+    );
+  }
+}