Enforce email templating (#3355)

* Add react-email

* WIP

* Fix import error

* Rename services

* Update logging

* Update email template

* Update email template

* Add Base Email template

* Move to proper place

* Remove test files

* Update logo

* Add email theme

* Revert "Remove test files"

This reverts commit fe062dd05166b95125cf99f2165cc20efb6c275a.

* Add email theme 2

* Revert "Revert "Remove test files""

This reverts commit 6c6471273ad765788f2eaf5a5614209edfb965ce.

* Revert "Revert "Revert "Remove test files"""

This reverts commit f851333c24e9cfe3f425c9cbbd1e079efce5c3dd.

* Revert "Revert "Revert "Revert "Remove test files""""

This reverts commit 7838e19e88e269026e24803f26cd52b467b4ef36.

* Fix theme

packages/twenty-server/src/integrations/email/email-sender.job.ts

@@ -0,0 +1,18 @@
+import { Injectable } from '@nestjs/common';
+
+import { SendMailOptions } from 'nodemailer';
+
+import { MessageQueueJob } from 'src/integrations/message-queue/interfaces/message-queue-job.interface';
+
+import { EmailSenderService } from 'src/integrations/email/email-sender.service';
+
+@Injectable()
+export class EmailSenderJob implements MessageQueueJob<SendMailOptions> {
+  constructor(private readonly emailSenderService: EmailSenderService) {}
+
+  async handle(data: SendMailOptions): Promise<void> {
+    process.stdout.write(`Sending email to ${data.to} ...`);
+    await this.emailSenderService.send(data);
+    console.log(' done!');
+  }
+}

packages/twenty-server/src/integrations/email/email-sender.service.ts

@@ -0,0 +1,16 @@
+import { Inject, Injectable } from '@nestjs/common';
+
+import { SendMailOptions } from 'nodemailer';
+
+import { EmailDriver } from 'src/integrations/email/drivers/interfaces/email-driver.interface';
+
+import { EMAIL_DRIVER } from 'src/integrations/email/email.constants';
+
+@Injectable()
+export class EmailSenderService implements EmailDriver {
+  constructor(@Inject(EMAIL_DRIVER) private driver: EmailDriver) {}
+
+  async send(sendMailOptions: SendMailOptions): Promise<void> {
+    await this.driver.send(sendMailOptions);
+  }
+}

packages/twenty-server/src/integrations/email/email.module.ts

@@ -6,6 +6,7 @@ import { EMAIL_DRIVER } from 'src/integrations/email/email.constants';
 import { LoggerDriver } from 'src/integrations/email/drivers/logger.driver';
 import { SmtpDriver } from 'src/integrations/email/drivers/smtp.driver';
 import { EmailService } from 'src/integrations/email/email.service';
+import { EmailSenderService } from 'src/integrations/email/email-sender.service';
 
 @Global()
 export class EmailModule {
@@ -22,8 +23,8 @@ export class EmailModule {
 
     return {
       module: EmailModule,
-      providers: [EmailService, provider],
-      exports: [EmailService],
+      providers: [EmailSenderService, EmailService, provider],
+      exports: [EmailSenderService, EmailService],
     };
   }
 }

packages/twenty-server/src/integrations/email/email.service.ts

@@ -2,15 +2,22 @@ import { Inject, Injectable } from '@nestjs/common';
 
 import { SendMailOptions } from 'nodemailer';
 
-import { EmailDriver } from 'src/integrations/email/drivers/interfaces/email-driver.interface';
-
-import { EMAIL_DRIVER } from 'src/integrations/email/email.constants';
+import { MessageQueue } from 'src/integrations/message-queue/message-queue.constants';
+import { MessageQueueService } from 'src/integrations/message-queue/services/message-queue.service';
+import { EmailSenderJob } from 'src/integrations/email/email-sender.job';
 
 @Injectable()
-export class EmailService implements EmailDriver {
-  constructor(@Inject(EMAIL_DRIVER) private driver: EmailDriver) {}
+export class EmailService {
+  constructor(
+    @Inject(MessageQueue.emailQueue)
+    private readonly messageQueueService: MessageQueueService,
+  ) {}
 
   async send(sendMailOptions: SendMailOptions): Promise<void> {
-    await this.driver.send(sendMailOptions);
+    await this.messageQueueService.add<SendMailOptions>(
+      EmailSenderJob.name,
+      sendMailOptions,
+      { retryLimit: 3 },
+    );
   }
 }

packages/twenty-server/src/integrations/integrations.module.ts

@@ -6,8 +6,8 @@ import { exceptionHandlerModuleFactory } from 'src/integrations/exception-handle
 import { fileStorageModuleFactory } from 'src/integrations/file-storage/file-storage.module-factory';
 import { loggerModuleFactory } from 'src/integrations/logger/logger.module-factory';
 import { messageQueueModuleFactory } from 'src/integrations/message-queue/message-queue.module-factory';
-import { emailModuleFactory } from 'src/integrations/email/email.module-factory';
 import { EmailModule } from 'src/integrations/email/email.module';
+import { emailModuleFactory } from 'src/integrations/email/email.module-factory';
 
 import { EnvironmentModule } from './environment/environment.module';
 import { EnvironmentService } from './environment/environment.service';

packages/twenty-server/src/integrations/message-queue/jobs.module.ts

@@ -10,6 +10,7 @@ import { ObjectMetadataModule } from 'src/metadata/object-metadata/object-metada
 import { DataSourceModule } from 'src/metadata/data-source/data-source.module';
 import { TypeORMModule } from 'src/database/typeorm/typeorm.module';
 import { FetchWorkspaceMessagesModule } from 'src/workspace/messaging/services/fetch-workspace-messages.module';
+import { EmailSenderJob } from 'src/integrations/email/email-sender.job';
 
 @Module({
   imports: [
@@ -33,6 +34,10 @@ import { FetchWorkspaceMessagesModule } from 'src/workspace/messaging/services/f
       provide: CallWebhookJob.name,
       useClass: CallWebhookJob,
     },
+    {
+      provide: EmailSenderJob.name,
+      useClass: EmailSenderJob,
+    },
   ],
 })
 export class JobsModule {

packages/twenty-server/src/integrations/message-queue/message-queue.constants.ts

@@ -5,4 +5,5 @@ export enum MessageQueue {
   messagingQueue = 'messaging-queue',
   webhookQueue = 'webhook-queue',
   cronQueue = 'cron-queue',
+  emailQueue = 'email-queue',
 }