7417 workflows i can send emails using the email account

packages/twenty-emails/src/index.ts

@@ -3,4 +3,3 @@ export * from './emails/delete-inactive-workspaces.email';
 export * from './emails/password-reset-link.email';
 export * from './emails/password-update-notify.email';
 export * from './emails/send-invite-link.email';
-export * from './emails/workflow-action.email';

packages/twenty-server/src/engine/core-modules/auth/strategies/google-apis-oauth-common.auth.strategy.ts

@@ -23,6 +23,7 @@ export class GoogleAPIsOauthCommonStrategy extends PassportStrategy(
       'email',
       'profile',
       'https://www.googleapis.com/auth/gmail.readonly',
+      'https://www.googleapis.com/auth/gmail.send',
       'https://www.googleapis.com/auth/calendar.events',
       'https://www.googleapis.com/auth/profile.emails.read',
     ];

packages/twenty-server/src/modules/mail-sender/exceptions/mail-sender.exception.ts

@@ -0,0 +1,12 @@
+import { CustomException } from 'src/utils/custom-exception';
+
+export class MailSenderException extends CustomException {
+  code: MailSenderExceptionCode;
+  constructor(message: string, code: MailSenderExceptionCode) {
+    super(message, code);
+  }
+}
+
+export enum MailSenderExceptionCode {
+  PROVIDER_NOT_SUPPORTED = 'PROVIDER_NOT_SUPPORTED',
+}

packages/twenty-server/src/modules/mail-sender/workflow-actions/send-email.workflow-action.ts

@@ -2,24 +2,64 @@ import { Injectable, Logger } from '@nestjs/common';
 
 import { z } from 'zod';
 import Handlebars from 'handlebars';
-import { JSDOM } from 'jsdom';
-import DOMPurify from 'dompurify';
-import { WorkflowActionEmail } from 'twenty-emails';
-import { render } from '@react-email/components';
 
 import { WorkflowActionResult } from 'src/modules/workflow/workflow-executor/types/workflow-action-result.type';
 import { WorkflowSendEmailStep } from 'src/modules/workflow/workflow-executor/types/workflow-action.type';
 import { EnvironmentService } from 'src/engine/core-modules/environment/environment.service';
 import { EmailService } from 'src/engine/core-modules/email/email.service';
+import { InjectObjectMetadataRepository } from 'src/engine/object-metadata-repository/object-metadata-repository.decorator';
+import { ConnectedAccountWorkspaceEntity } from 'src/modules/connected-account/standard-objects/connected-account.workspace-entity';
+import { ConnectedAccountRepository } from 'src/modules/connected-account/repositories/connected-account.repository';
+import {
+  WorkflowStepExecutorException,
+  WorkflowStepExecutorExceptionCode,
+} from 'src/modules/workflow/workflow-executor/exceptions/workflow-step-executor.exception';
+import { ScopedWorkspaceContextFactory } from 'src/engine/twenty-orm/factories/scoped-workspace-context.factory';
+import {
+  MailSenderException,
+  MailSenderExceptionCode,
+} from 'src/modules/mail-sender/exceptions/mail-sender.exception';
+import { GmailClientProvider } from 'src/modules/messaging/message-import-manager/drivers/gmail/providers/gmail-client.provider';
 
 @Injectable()
 export class SendEmailWorkflowAction {
   private readonly logger = new Logger(SendEmailWorkflowAction.name);
   constructor(
     private readonly environmentService: EnvironmentService,
     private readonly emailService: EmailService,
+    private readonly gmailClientProvider: GmailClientProvider,
+    private readonly scopedWorkspaceContextFactory: ScopedWorkspaceContextFactory,
+    @InjectObjectMetadataRepository(ConnectedAccountWorkspaceEntity)
+    private readonly connectedAccountRepository: ConnectedAccountRepository,
   ) {}
 
+  private async getEmailClient(step: WorkflowSendEmailStep) {
+    const { workspaceId } = this.scopedWorkspaceContextFactory.create();
+
+    if (!workspaceId) {
+      throw new WorkflowStepExecutorException(
+        'Scoped workspace not found',
+        WorkflowStepExecutorExceptionCode.SCOPED_WORKSPACE_NOT_FOUND,
+      );
+    }
+
+    const connectedAccount =
+      await this.connectedAccountRepository.getByIdOrFail(
+        step.settings.connectedAccountId,
+        workspaceId,
+      );
+
+    switch (connectedAccount.provider) {
+      case 'google':
+        return await this.gmailClientProvider.getGmailClient(connectedAccount);
+      default:
+        throw new MailSenderException(
+          `Provider ${connectedAccount.provider} is not supported`,
+          MailSenderExceptionCode.PROVIDER_NOT_SUPPORTED,
+        );
+    }
+  }
+
   async execute({
     step,
     payload,
@@ -30,6 +70,8 @@ export class SendEmailWorkflowAction {
       [key: string]: string;
     };
   }): Promise<WorkflowActionResult> {
+    const emailProvider = await this.getEmailClient(step);
+
     try {
       const emailSchema = z.string().trim().email('Invalid email');
 
@@ -43,30 +85,22 @@ export class SendEmailWorkflowAction {
 
       const mainText = Handlebars.compile(step.settings.template)(payload);
 
-      const window = new JSDOM('').window;
-      const purify = DOMPurify(window);
-      const safeHTML = purify.sanitize(mainText || '');
+      const message = [
+        `To: ${payload.email}`,
+        `Subject: ${step.settings.subject || ''}`,
+        'MIME-Version: 1.0',
+        'Content-Type: text/plain; charset="UTF-8"',
+        '',
+        mainText,
+      ].join('\n');
 
-      const email = WorkflowActionEmail({
-        dangerousHTML: safeHTML,
-        title: step.settings.title,
-        callToAction: step.settings.callToAction,
-      });
-      const html = render(email, {
-        pretty: true,
-      });
-      const text = render(email, {
-        plainText: true,
-      });
+      const encodedMessage = Buffer.from(message).toString('base64');
 
-      await this.emailService.send({
-        from: `${this.environmentService.get(
-          'EMAIL_FROM_NAME',
-        )} <${this.environmentService.get('EMAIL_FROM_ADDRESS')}>`,
-        to: payload.email,
-        subject: step.settings.subject || '',
-        text,
-        html,
+      await emailProvider.users.messages.send({
+        userId: 'me',
+        requestBody: {
+          raw: encodedMessage,
+        },
       });
 
       return { result: { success: true } };

packages/twenty-server/src/modules/messaging/message-import-manager/drivers/gmail/messaging-gmail-driver.module.ts

@@ -46,6 +46,10 @@ import { MessageParticipantManagerModule } from 'src/modules/messaging/message-p
     GmailGetMessageListService,
     GmailHandleErrorService,
   ],
-  exports: [GmailGetMessagesService, GmailGetMessageListService],
+  exports: [
+    GmailGetMessagesService,
+    GmailGetMessageListService,
+    GmailClientProvider,
+  ],
 })
 export class MessagingGmailDriverModule {}

packages/twenty-server/src/modules/workflow/workflow-executor/types/workflow-step-settings.type.ts

@@ -14,6 +14,7 @@ export type WorkflowCodeStepSettings = BaseWorkflowStepSettings & {
 };
 
 export type WorkflowSendEmailStepSettings = BaseWorkflowStepSettings & {
+  connectedAccountId: string;
   subject?: string;
   template?: string;
   title?: string;

packages/twenty-server/src/modules/workflow/workflow-executor/workflow-executor.module.ts

@@ -7,9 +7,14 @@ import { CodeWorkflowAction } from 'src/modules/serverless/workflow-actions/code
 import { SendEmailWorkflowAction } from 'src/modules/mail-sender/workflow-actions/send-email.workflow-action';
 import { ServerlessFunctionModule } from 'src/engine/metadata-modules/serverless-function/serverless-function.module';
 import { ScopedWorkspaceContextFactory } from 'src/engine/twenty-orm/factories/scoped-workspace-context.factory';
+import { MessagingGmailDriverModule } from 'src/modules/messaging/message-import-manager/drivers/gmail/messaging-gmail-driver.module';
 
 @Module({
-  imports: [WorkflowCommonModule, ServerlessFunctionModule],
+  imports: [
+    WorkflowCommonModule,
+    ServerlessFunctionModule,
+    MessagingGmailDriverModule,
+  ],
   providers: [
     WorkflowExecutorWorkspaceService,
     ScopedWorkspaceContextFactory,