Merge pull request #126 from TaskFlow-CLAP/CLAP-150

CLAP-150 시스템과 외부 푸시 알림 기능 구현

Author: starboxxxx

build.gradle

@@ -90,6 +90,9 @@ dependencies {
     // Email Sender
     implementation 'org.springframework.boot:spring-boot-starter-mail'
 
+    // Thymeleaf
+    implementation 'org.springframework.boot:spring-boot-starter-thymeleaf'
+
     // Spring aop
     implementation 'org.springframework.boot:spring-boot-starter-aop'
 

src/main/java/clap/server/adapter/inbound/web/dto/notification/SseRequest.java

@@ -0,0 +1,11 @@
+package clap.server.adapter.inbound.web.dto.notification;
+
+import clap.server.adapter.outbound.persistense.entity.notification.constant.NotificationType;
+
+public record SseRequest(
+        String taskTitle,
+        NotificationType notificationType,
+        Long receiverId,
+        String message
+) {
+}

src/main/java/clap/server/adapter/inbound/web/notification/SubscribeEmitterController.java

@@ -0,0 +1,31 @@
+package clap.server.adapter.inbound.web.notification;
+
+
+import clap.server.adapter.inbound.security.SecurityUserDetails;
+import clap.server.application.port.inbound.notification.SubscribeSseUsecase;
+import clap.server.common.annotation.architecture.WebAdapter;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.MediaType;
+import org.springframework.security.core.annotation.AuthenticationPrincipal;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
+
+@Tag(name = "SSE 관리 - 회원 등록(최초 접속시)")
+@WebAdapter
+@RestController
+@RequestMapping("/api/sse")
+@RequiredArgsConstructor
+public class SubscribeEmitterController {
+
+    private final SubscribeSseUsecase subscribeSseUsecase;
+
+    @Operation(summary = "회원이 최초 접속 시 SSE(실시간 알림)에 연결하는 API")
+    @GetMapping(value = "/subscribe", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
+    public SseEmitter subscribe(@AuthenticationPrincipal SecurityUserDetails userInfo) {
+        return subscribeSseUsecase.subscribe(userInfo.getUserId());
+    }
+}

src/main/java/clap/server/adapter/outbound/api/AgitClient.java

@@ -0,0 +1,53 @@
+package clap.server.adapter.outbound.api;
+
+import clap.server.adapter.outbound.api.dto.SendAgitRequest;
+import clap.server.adapter.outbound.persistense.entity.notification.constant.NotificationType;
+import clap.server.application.port.outbound.webhook.SendAgitPort;
+import clap.server.common.annotation.architecture.PersistenceAdapter;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.web.client.RestTemplate;
+
+
+@PersistenceAdapter
+@RequiredArgsConstructor
+public class AgitClient implements SendAgitPort {
+
+    @Value("${agit.url}")
+    private String AGITWEBHOOK_URL;
+
+    @Override
+    public void sendAgit(SendAgitRequest request) {
+        RestTemplate restTemplate = new RestTemplate();
+
+        String message = null;
+        if (request.notificationType() == NotificationType.TASK_REQUESTED) {
+            message = request.taskName() + " 작업이 요청되었습니다.";
+        }
+        else if (request.notificationType() == NotificationType.COMMENT) {
+            message = request.taskName() + " 작업에 " + request.commenterName() + "님이 댓글을 남기셨습니다.";
+        }
+        else if (request.notificationType() == NotificationType.PROCESSOR_ASSIGNED) {
+            message = request.taskName() + " 작업에 담당자(" + request.message() + ")가 배정되었습니다.";
+        }
+        else if (request.notificationType() == NotificationType.PROCESSOR_CHANGED) {
+            message = request.taskName() + " 작업의 담당자가 " + request.message() + "로 변경되었습니다.";
+        }
+        else {
+            message = request.taskName() + " 작업의 상태가 "  + request.message() + "로 변경되었습니다";
+        }
+
+        String payload = "{\"text\":\"" + message + "\"}";
+
+        HttpHeaders headers = new HttpHeaders();
+        headers.add("Content-Type", "application/json");
+
+        HttpEntity<String> entity = new HttpEntity<>(payload, headers);
+
+        // Post 요청
+        restTemplate.exchange(AGITWEBHOOK_URL, HttpMethod.POST, entity, String.class);
+    }
+}

src/main/java/clap/server/adapter/outbound/api/EmailClient.java

@@ -0,0 +1,86 @@
+package clap.server.adapter.outbound.api;
+
+import clap.server.adapter.outbound.api.dto.SendWebhookRequest;
+import clap.server.adapter.outbound.persistense.entity.notification.constant.NotificationType;
+import clap.server.application.port.outbound.webhook.SendEmailPort;
+import clap.server.common.annotation.architecture.PersistenceAdapter;
+import clap.server.exception.ApplicationException;
+import clap.server.exception.code.NotificationErrorCode;
+import jakarta.mail.internet.MimeMessage;
+import lombok.RequiredArgsConstructor;
+import org.springframework.mail.javamail.JavaMailSender;
+import org.springframework.mail.javamail.MimeMessageHelper;
+import org.thymeleaf.context.Context;
+import org.thymeleaf.spring6.SpringTemplateEngine;
+
+@PersistenceAdapter
+@RequiredArgsConstructor
+public class EmailClient implements SendEmailPort {
+
+    private final SpringTemplateEngine templateEngine;
+    private final JavaMailSender mailSender;
+
+    @Override
+    public void sendEmail(SendWebhookRequest request) {
+        try {
+            MimeMessage mimeMessage = mailSender.createMimeMessage();
+            MimeMessageHelper helper = new MimeMessageHelper(mimeMessage, true, "UTF-8");
+            String body;
+            Context context = new Context();
+
+            if (request.notificationType() == NotificationType.TASK_REQUESTED) {
+                helper.setTo(request.email());
+                helper.setSubject("[TaskFlow 알림] 신규 작업이 요청되었습니다.");
+
+                context.setVariable("receiverName", request.senderName());
+                context.setVariable("title", request.taskName());
+
+                body = templateEngine.process("task-request", context);
+            }
+            else if (request.notificationType() == NotificationType.STATUS_SWITCHED) {
+                helper.setTo(request.email());
+                helper.setSubject("[TaskFlow 알림] 작업 상태가 변경되었습니다.");
+
+                context.setVariable("status", request.message());
+                context.setVariable("title", request.taskName());
+
+                body = templateEngine.process("status-switch", context);
+            }
+
+            else if (request.notificationType() == NotificationType.PROCESSOR_CHANGED) {
+                helper.setTo(request.email());
+                helper.setSubject("[TaskFlow 알림] 작업 담당자가 변경되었습니다.");
+
+                context.setVariable("processorName", request.message());
+                context.setVariable("title", request.taskName());
+
+                body = templateEngine.process("processor-change", context);
+            }
+
+            else if (request.notificationType() == NotificationType.PROCESSOR_ASSIGNED) {
+                helper.setTo(request.email());
+                helper.setSubject("[TaskFlow 알림] 작업 담당자가 지정되었습니다.");
+
+                context.setVariable("processorName", request.message());
+                context.setVariable("title", request.taskName());
+
+                body = templateEngine.process("processor-assign", context);
+            }
+
+            else {
+                helper.setTo(request.email());
+                helper.setSubject("[TaskFlow 알림] 댓글이 작성되었습니다.");
+
+                context.setVariable("comment", request.message());
+                context.setVariable("title", request.taskName());
+
+                body = templateEngine.process("comment", context);
+            }
+
+            helper.setText(body, true);
+            mailSender.send(mimeMessage);
+        } catch (Exception e) {
+            throw new ApplicationException(NotificationErrorCode.EMAIL_SEND_FAILED);
+        }
+    }
+}

src/main/java/clap/server/adapter/outbound/api/KakaoWorkClient.java

@@ -0,0 +1,68 @@
+package clap.server.adapter.outbound.api;
+
+import clap.server.adapter.outbound.api.dto.SendKakaoWorkRequest;
+import clap.server.adapter.outbound.persistense.entity.notification.constant.NotificationType;
+import clap.server.application.port.outbound.webhook.SendKaKaoWorkPort;
+import clap.server.common.annotation.architecture.PersistenceAdapter;
+import clap.server.exception.ApplicationException;
+import clap.server.exception.code.NotificationErrorCode;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.web.client.RestTemplate;
+
+@PersistenceAdapter
+@RequiredArgsConstructor
+public class KakaoWorkClient implements SendKaKaoWorkPort {
+
+    @Value("${kakaowork.url}")
+    private String kakaworkUrl;
+
+    @Value("${kakaowork.auth}")
+    private String kakaworkAuth;
+
+    private final ObjectBlockService makeObjectBlock;
+
+    @Override
+    public void sendKakaoWord(SendKakaoWorkRequest request) {
+        RestTemplate restTemplate = new RestTemplate();
+
+        // Payload 생성
+        String payload = null;
+        if (request.notificationType() == NotificationType.TASK_REQUESTED) {
+            payload = makeObjectBlock.makeTaskRequestBlock(request);
+        }
+        else if (request.notificationType() == NotificationType.PROCESSOR_ASSIGNED) {
+            payload = makeObjectBlock.makeNewProcessorBlock(request);
+        }
+        else if (request.notificationType() == NotificationType.PROCESSOR_CHANGED) {
+            payload = makeObjectBlock.makeProcessorChangeBlock(request);
+        }
+        else if (request.notificationType() == NotificationType.STATUS_SWITCHED) {
+            payload = makeObjectBlock.makeTaskStatusBlock(request);
+        }
+        else {
+            payload = makeObjectBlock.makeCommentBlock(request);
+        }
+
+        // HTTP 요청 헤더 설정
+        HttpHeaders headers = new HttpHeaders();
+        headers.add("Content-Type", "application/json");
+        headers.add("Authorization", kakaworkAuth);
+
+        // HTTP 요청 엔터티 생성
+        HttpEntity<String> entity = new HttpEntity<>(payload, headers);
+
+        try {
+            // Post 요청 전송
+            restTemplate.exchange(
+                    kakaworkUrl, HttpMethod.POST, entity, String.class
+            );
+
+        } catch (Exception e) {
+            throw new ApplicationException(NotificationErrorCode.KAKAO_SEND_FAILED);
+        }
+    }
+}