feat: SMTP Driver Integration (#12993)

Co-authored-by: greptile-apps[bot] <165735046+greptile-apps[bot]@users.noreply.github.com>
Co-authored-by: Félix Malfait <felix.malfait@gmail.com>
Co-authored-by: Félix Malfait <felix@twenty.com>

packages/twenty-server/src/modules/messaging/message-import-manager/drivers/imap/providers/imap-client.provider.ts

@@ -64,14 +64,14 @@ export class ImapClientProvider {
       await client.connect();
 
       this.logger.log(
-        `Connected to IMAP server for ${connectionParameters.handle}`,
+        `Connected to IMAP server for ${connectedAccount.handle}`,
       );
 
       try {
         const mailboxes = await client.list();
 
         this.logger.log(
-          `Available mailboxes for ${connectionParameters.handle}: ${mailboxes.map((m) => m.path).join(', ')}`,
+          `Available mailboxes for ${connectedAccount.handle}: ${mailboxes.map((m) => m.path).join(', ')}`,
         );
       } catch (error) {
         this.logger.warn(`Failed to list mailboxes: ${error.message}`);

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

@@ -0,0 +1,9 @@
+import { Module } from '@nestjs/common';
+
+import { SmtpClientProvider } from './providers/smtp-client.provider';
+
+@Module({
+  providers: [SmtpClientProvider],
+  exports: [SmtpClientProvider],
+})
+export class MessagingSmtpDriverModule {}

packages/twenty-server/src/modules/messaging/message-import-manager/drivers/smtp/providers/smtp-client.provider.ts

@@ -0,0 +1,35 @@
+import { Injectable } from '@nestjs/common';
+
+import { createTransport, Transporter } from 'nodemailer';
+
+import { ConnectedAccountWorkspaceEntity } from 'src/modules/connected-account/standard-objects/connected-account.workspace-entity';
+
+@Injectable()
+export class SmtpClientProvider {
+  public async getSmtpClient(
+    connectedAccount: Pick<
+      ConnectedAccountWorkspaceEntity,
+      'connectionParameters' | 'handle'
+    >,
+  ): Promise<Transporter> {
+    const smtpParams = connectedAccount.connectionParameters?.SMTP;
+
+    if (!smtpParams) {
+      throw new Error('SMTP settings not configured for this account');
+    }
+
+    const transporter = createTransport({
+      host: smtpParams.host,
+      port: smtpParams.port,
+      auth: {
+        user: connectedAccount.handle,
+        pass: smtpParams.password,
+      },
+      tls: {
+        rejectUnauthorized: false,
+      },
+    });
+
+    return transporter;
+  }
+}

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

@@ -22,6 +22,7 @@ import { MessagingOngoingStaleCronJob } from 'src/modules/messaging/message-impo
 import { MessagingGmailDriverModule } from 'src/modules/messaging/message-import-manager/drivers/gmail/messaging-gmail-driver.module';
 import { MessagingIMAPDriverModule } from 'src/modules/messaging/message-import-manager/drivers/imap/messaging-imap-driver.module';
 import { MessagingMicrosoftDriverModule } from 'src/modules/messaging/message-import-manager/drivers/microsoft/messaging-microsoft-driver.module';
+import { MessagingSmtpDriverModule } from 'src/modules/messaging/message-import-manager/drivers/smtp/messaging-smtp-driver.module';
 import { MessagingAddSingleMessageToCacheForImportJob } from 'src/modules/messaging/message-import-manager/jobs/messaging-add-single-message-to-cache-for-import.job';
 import { MessagingCleanCacheJob } from 'src/modules/messaging/message-import-manager/jobs/messaging-clean-cache';
 import { MessagingMessageListFetchJob } from 'src/modules/messaging/message-import-manager/jobs/messaging-message-list-fetch.job';
@@ -48,6 +49,7 @@ import { MessagingMonitoringModule } from 'src/modules/messaging/monitoring/mess
     MessagingGmailDriverModule,
     MessagingMicrosoftDriverModule,
     MessagingIMAPDriverModule,
+    MessagingSmtpDriverModule,
     MessagingCommonModule,
     TypeOrmModule.forFeature(
       [Workspace, DataSourceEntity, ObjectMetadataEntity],

packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-send-message.service.ts

@@ -12,6 +12,7 @@ import {
 import { GmailClientProvider } from 'src/modules/messaging/message-import-manager/drivers/gmail/providers/gmail-client.provider';
 import { OAuth2ClientProvider } from 'src/modules/messaging/message-import-manager/drivers/gmail/providers/oauth2-client.provider';
 import { MicrosoftClientProvider } from 'src/modules/messaging/message-import-manager/drivers/microsoft/providers/microsoft-client.provider';
+import { SmtpClientProvider } from 'src/modules/messaging/message-import-manager/drivers/smtp/providers/smtp-client.provider';
 import { isAccessTokenRefreshingError } from 'src/modules/messaging/message-import-manager/drivers/microsoft/utils/is-access-token-refreshing-error.utils';
 import { mimeEncode } from 'src/modules/messaging/message-import-manager/utils/mime-encode.util';
 
@@ -27,6 +28,7 @@ export class MessagingSendMessageService {
     private readonly gmailClientProvider: GmailClientProvider,
     private readonly oAuth2ClientProvider: OAuth2ClientProvider,
     private readonly microsoftClientProvider: MicrosoftClientProvider,
+    private readonly smtpClientProvider: SmtpClientProvider,
   ) {}
 
   public async sendMessage(
@@ -120,7 +122,16 @@ export class MessagingSendMessageService {
         break;
       }
       case ConnectedAccountProvider.IMAP_SMTP_CALDAV: {
-        throw new Error('IMAP provider does not support sending messages');
+        const smtpClient =
+          await this.smtpClientProvider.getSmtpClient(connectedAccount);
+
+        await smtpClient.sendMail({
+          from: connectedAccount.handle,
+          to: sendMessageInput.to,
+          subject: sendMessageInput.subject,
+          text: sendMessageInput.body,
+        });
+        break;
       }
       default:
         assertUnreachable(