Merge pull request #27 from APSfurizon/email_sender

Email sender

Author: stranck

.gitignore

@@ -38,3 +38,5 @@ build/
 ### Configurations ###
 .env
 .env.local
+
+/jte-classes

application/pom.xml

@@ -112,7 +112,16 @@
             <artifactId>bcpkix-jdk18on</artifactId>
             <version>1.79</version>
         </dependency>
-
+        <dependency>
+            <groupId>gg.jte</groupId>
+            <artifactId>jte-spring-boot-starter-3</artifactId>
+            <version>3.1.15</version>
+        </dependency>
+        <dependency>
+            <groupId>gg.jte</groupId>
+            <artifactId>jte</artifactId>
+            <version>3.1.15</version>
+        </dependency>
     </dependencies>
     <dependencyManagement>
         <dependencies>

application/src/main/java/net/furizon/backend/infrastructure/configuration/ThreadConfig.java

@@ -5,6 +5,7 @@
 import org.springframework.boot.web.embedded.tomcat.TomcatProtocolHandlerCustomizer;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
 import org.springframework.core.task.AsyncTaskExecutor;
 import org.springframework.core.task.support.TaskExecutorAdapter;
 import org.springframework.scheduling.annotation.EnableAsync;
@@ -19,6 +20,7 @@
 )
 public class ThreadConfig {
     @Bean
+    @Primary
     public AsyncTaskExecutor applicationTaskExecutor() {
         final var executor = new TaskExecutorAdapter(Executors.newVirtualThreadPerTaskExecutor());
         executor.setTaskDecorator(new MdcTaskDecorator());

application/src/main/java/net/furizon/backend/infrastructure/email/EmailSender.java

@@ -0,0 +1,15 @@
+package net.furizon.backend.infrastructure.email;
+
+import jakarta.mail.MessagingException;
+import net.furizon.backend.infrastructure.email.model.MailRequest;
+import org.jetbrains.annotations.Blocking;
+import org.jetbrains.annotations.NonBlocking;
+import org.springframework.mail.MailException;
+
+public interface EmailSender {
+    @Blocking
+    void send(MailRequest request) throws MessagingException, MailException;
+
+    @NonBlocking
+    void fireAndForget(MailRequest request);
+}

application/src/main/java/net/furizon/backend/infrastructure/email/EmailSenderService.java

@@ -0,0 +1,65 @@
+package net.furizon.backend.infrastructure.email;
+
+import gg.jte.TemplateEngine;
+import gg.jte.TemplateOutput;
+import gg.jte.output.StringOutput;
+import jakarta.mail.MessagingException;
+import jakarta.mail.internet.MimeMessage;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import net.furizon.backend.infrastructure.email.model.MailRequest;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.core.task.AsyncTaskExecutor;
+import org.springframework.mail.MailException;
+import org.springframework.mail.javamail.JavaMailSender;
+import org.springframework.mail.javamail.MimeMessageHelper;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class EmailSenderService implements EmailSender {
+    private final JavaMailSender mailSender;
+
+    private final TemplateEngine templateEngine;
+
+    private final AsyncTaskExecutor asyncTaskExecutor;
+
+    @Value("${spring.mail.username}")
+    private String from;
+
+    @Override
+    public void send(MailRequest request) throws MessagingException, MailException {
+        MimeMessage mimeMessage = mailSender.createMimeMessage();
+        MimeMessageHelper mimeMessageHelper = new MimeMessageHelper(mimeMessage);
+
+        mimeMessageHelper.setFrom(from);
+        mimeMessageHelper.setTo(request.getTo());
+        mimeMessageHelper.setSubject(request.getSubject());
+
+        if (request.getTemplateMessage() != null) {
+            final var message = request.getTemplateMessage();
+            TemplateOutput output = new StringOutput();
+            templateEngine.render(message.getTemplate(), message.getParams(), output);
+            mimeMessageHelper.setText(output.toString(), true);
+        } else if (request.getMessage() != null) {
+            mimeMessageHelper.setText(request.getMessage(), false);
+        } else {
+            throw new RuntimeException("message or template is required");
+        }
+
+        mailSender.send(mimeMessage);
+    }
+
+    @Override
+    public void fireAndForget(MailRequest request) {
+        asyncTaskExecutor.execute(() -> {
+            try {
+                log.debug("Sending email in async mode");
+                send(request);
+            } catch (MessagingException ex) {
+                log.error("Couldn't send message", ex);
+            }
+        });
+    }
+}

application/src/main/java/net/furizon/backend/infrastructure/email/model/MailRequest.java

@@ -0,0 +1,24 @@
+package net.furizon.backend.infrastructure.email.model;
+
+import lombok.Builder;
+import lombok.Data;
+import lombok.RequiredArgsConstructor;
+import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
+
+@Data
+@Builder
+@RequiredArgsConstructor
+public class MailRequest {
+    @NotNull
+    private final String to;
+
+    @NotNull
+    private final String subject;
+
+    @Nullable
+    private final String message;
+
+    @Nullable
+    private final TemplateMessage templateMessage;
+}

application/src/main/java/net/furizon/backend/infrastructure/email/model/TemplateMessage.java

@@ -0,0 +1,30 @@
+package net.furizon.backend.infrastructure.email.model;
+
+import lombok.Data;
+import org.jetbrains.annotations.NotNull;
+
+import java.util.HashMap;
+import java.util.Map;
+
+
+@Data
+public class TemplateMessage {
+    @NotNull
+    private final String template;
+
+    @NotNull
+    private final Map<String, Object> params;
+
+    public TemplateMessage addParam(@NotNull String key, @NotNull Object value) {
+        params.put(key, value.toString());
+        return this;
+    }
+
+    public static TemplateMessage of(@NotNull String templatePath, @NotNull Map<String, Object> params) {
+        return new TemplateMessage(templatePath, params);
+    }
+
+    public static TemplateMessage of(@NotNull String templatePath) {
+        return of(templatePath, new HashMap<>());
+    }
+}

application/src/main/resources/application.yml

@@ -17,6 +17,24 @@ spring:
     driver-class-name: org.postgresql.Driver
   jooq:
     sql-dialect: postgres
+  mail:
+    host: ${MAIL_SENDER_PROVIDER_HOST:stmp.example.com}
+    port: ${MAIL_SENDER_PROVIDER_PORT:465}
+    username: ${MAIL_SENDER_PROVIDER_USERNAME:test@example.com}
+    password: ${MAIL_SENDER_PROVIDER_PASSWORD:changeme}
+    protocol: smtps
+    properties:
+      "mail.smtp.auth": true
+      "mail.smtp.starttls.enable": true
+      "mail.smtp.starttls.required": true
+      "mail.debug": ${MAIL_SENDER_PROVIDER_USE_DEBUG_PROP:true}
+
+gg:
+  jte:
+    development-mode: ${JTE_DEV_MODE:true}
+    templateLocation: templates/jte
+    templateSuffix: .jte
+    usePrecompiledTemplates: ${JTE_PROD_MODE:false}
 
 logbook:
   format:

templates/jte/old_template.jte

@@ -0,0 +1,31 @@
+@param String body
+@param String title
+
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="UTF-8">
+    <title>${title}</title>
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
+    <meta name="supported-color-schemes" content="light dark">
+    <style media="all" type="text/css">
+        * { color: #bbc6ce; }
+        .body { width: 100%; margin: 0; background-color: #11191f; }
+        .container { max-width: 40em; padding: 1em; margin: 0 auto; }
+        .title { font-size: 1.75em; margin-bottom: 1.2em; color: #e1e6eb; margin-top: 0; font-family: sans-serif; }
+        .main-content { margin-top: 0; font-style: normal; font-weight: 400; font-family: sans-serif;}
+        .con-logo { height:3em;}
+        .link { text-decoration: none; background-color: #1095c1; color: #fff; padding: 1em; border-radius: 5px; font-weight: 600; }
+    </style>
+</head>
+<div class="body">
+    <div class="container">
+        <img src="https://reg.furizon.net/res/furizon.png" alt="con_logo" title="con_logo" class="con-logo">
+        <div>
+            <h2 class="title">${title}</h2>
+            <p class="main-content">${body}</p>
+        </div>
+    </div>
+</div>
+</html>