feat: event 기반 비동기 이메일 전송 기능 구현

Author: daeun084

src/main/java/com/gdg/poppet/email/application/event/EmailSendEvent.java

@@ -0,0 +1,16 @@
+package com.gdg.poppet.email.application.event;
+
+import com.gdg.poppet.chat.domain.model.ChatRoom;
+import com.gdg.poppet.user.domain.model.User;
+import lombok.Getter;
+
+@Getter
+public class EmailSendEvent {
+    private final User user;
+    private final ChatRoom chatRoom;
+
+    public EmailSendEvent(User user, ChatRoom chatRoom) {
+        this.user = user;
+        this.chatRoom = chatRoom;
+    }
+}

src/main/java/com/gdg/poppet/email/application/service/EmailService.java

@@ -16,4 +16,6 @@ public interface EmailService {
     List<EmailDto> postEmailAddress(String name, EmailRequestDto emailRequestDto);
     void patchEmailAddress(String name, Long emailId, EmailRequestDto emailRequestDto);
     void deleteEmailAddress(String name, Long emailId);
+
+    void sendEmail(String username);
 }

src/main/java/com/gdg/poppet/email/application/service/EmailServiceImpl.java

@@ -1,5 +1,9 @@
 package com.gdg.poppet.email.application.service;
 
+import com.gdg.poppet.chat.domain.model.ChatRoom;
+import com.gdg.poppet.chat.domain.repository.ChatRoomRepository;
+import com.gdg.poppet.email.application.event.EmailSendEvent;
+import com.gdg.poppet.email.infra.application.EmailSendService;
 import com.gdg.poppet.global.exception.GlobalException;
 import com.gdg.poppet.global.status.ErrorStatus;
 import com.gdg.poppet.email.application.dto.request.EmailRequestDto;
@@ -11,18 +15,24 @@
 import com.gdg.poppet.email.domain.repository.EmailRepository;
 import com.gdg.poppet.user.domain.repository.UserRepository;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
 import java.util.stream.Collectors;
 
+@Slf4j
 @Service
 @RequiredArgsConstructor
 public class EmailServiceImpl implements EmailService {
 
     private final UserRepository userRepository;
     private final EmailRepository emailRepository;
+    private final ChatRoomRepository chatRoomRepository;
+    private final EmailSendService emailSendService;
+    private final ApplicationEventPublisher applicationEventPublisher;
 
     /**
      * 사용자의 이메일 전송 주기를 반환한다.
@@ -131,6 +141,31 @@ public void deleteEmailAddress(String username, Long emailId) {
         emailRepository.delete(email);
     }
 
+    /**
+     * 유저의 이메일 전송 주기에 따라, 주기 내에 생성된 이메일의 요약 내용을 이메일로 전송한다.
+     */
+    @Transactional
+    @Override
+    public void sendEmail(String username) {
+        // TODO: user data 얻는 과정 수정
+        User user = getUser(username);
+
+        // 가장 최근 생성되고 메일을 보내지 않은 채팅방 조회
+        List<ChatRoom> chatRooms = chatRoomRepository.findByUsernameAndCreatedAtAndIsMailSent(username);
+        if (chatRooms.isEmpty()) return;
+
+        // 메일 보낼 채팅방 요약 내용 추출
+        ChatRoom chatRoom = chatRooms.get(0);
+        String chatSummary = chatRoom.getSummary();
+        if (chatSummary == null) return;
+
+        // 메일 보냄 여부 수정
+        chatRoom.updateIsMailSent();
+
+        // 메일 전송 이벤트 발행
+        applicationEventPublisher.publishEvent(new EmailSendEvent(user, chatRoom));
+    }
+
     private void validateIsUserAuthorizedForEmail(User user, Email email) {
         if (!email.getUser().equals(user)) {
             throw new GlobalException(ErrorStatus.USER_EMAIL_FORBIDDEN);

src/main/java/com/gdg/poppet/email/infra/application/EmailSendEventListener.java

@@ -0,0 +1,34 @@
+package com.gdg.poppet.email.infra.application;
+
+import com.gdg.poppet.email.application.event.EmailSendEvent;
+import com.gdg.poppet.email.domain.model.Email;
+import com.gdg.poppet.user.domain.model.User;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.event.TransactionPhase;
+import org.springframework.transaction.event.TransactionalEventListener;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class EmailSendEventListener {
+
+    private final EmailSendService emailSendService;
+
+    @Async
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    public void handleEmailSendEvent(EmailSendEvent event) {
+        User user = event.getUser();
+        String summary = event.getChatRoom().getSummary();
+
+        for (Email email : user.getEmails()) {
+            try {
+                emailSendService.sendEmail(email.getEmailAddress(), summary);
+            } catch (Exception e) {
+                log.error("[*] {}으로 이메일 전송 중 오류 발생", email.getEmailAddress(), e);
+            }
+        }
+    }
+}

src/main/java/com/gdg/poppet/email/infra/application/EmailSendService.java

@@ -0,0 +1,30 @@
+package com.gdg.poppet.email.infra.application;
+
+import jakarta.mail.MessagingException;
+import jakarta.mail.internet.MimeMessage;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.mail.javamail.JavaMailSender;
+import org.springframework.mail.javamail.MimeMessageHelper;
+import org.springframework.stereotype.Service;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class EmailSendService {
+
+    private final JavaMailSender mailSender;
+
+    public void sendEmail(String to, String body) throws MessagingException {
+        MimeMessage mimeMessage = mailSender.createMimeMessage();
+
+        String subject = "POPPET";
+
+        MimeMessageHelper mimeMessageHelper = new MimeMessageHelper(mimeMessage);
+        mimeMessageHelper.setTo(to);
+        mimeMessageHelper.setSubject(subject);
+        mimeMessageHelper.setText(body, true);
+
+        mailSender.send(mimeMessage);
+    }
+}

src/main/java/com/gdg/poppet/global/config/AsyncConfig.java

@@ -0,0 +1,10 @@
+package com.gdg.poppet.global.config;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableAsync;
+
+@Configuration
+@EnableAsync
+public class AsyncConfig {
+
+}