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

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/common/SliceResponse.java

@@ -0,0 +1,12 @@
+package clap.server.adapter.inbound.web.dto.common;
+
+
+import java.util.List;
+
+public record SliceResponse<T> (
+        List<T> content,
+        boolean hasNext,
+        boolean isFirst,
+        boolean isLast
+) {
+}

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/FindNotificationController.java

@@ -1,6 +1,7 @@
 package clap.server.adapter.inbound.web.notification;
 
 import clap.server.adapter.inbound.security.SecurityUserDetails;
+import clap.server.adapter.inbound.web.dto.common.SliceResponse;
 import clap.server.adapter.inbound.web.dto.notification.FindNotificationListResponse;
 import clap.server.application.port.inbound.notification.FindNotificationListUsecase;
 import clap.server.common.annotation.architecture.WebAdapter;
@@ -9,7 +10,6 @@
 import io.swagger.v3.oas.annotations.Parameters;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.RequiredArgsConstructor;
-import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.data.domain.Pageable;
 import org.springframework.http.ResponseEntity;
@@ -34,7 +34,7 @@ public class FindNotificationController {
             @Parameter(name = "size", description = "조회할 목록 페이지 당 개수", example = "5", required = false)
     })
     @GetMapping
-    public ResponseEntity<Page<FindNotificationListResponse>> findNotificationList(
+    public ResponseEntity<SliceResponse<FindNotificationListResponse>> findNotificationList(
             @AuthenticationPrincipal SecurityUserDetails securityUserDetails,
             @RequestParam(defaultValue = "0") int page,
             @RequestParam(defaultValue = "5") int size) {

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

@@ -1,12 +1,14 @@
 package clap.server.adapter.inbound.web.notification;
 
+import clap.server.adapter.inbound.security.SecurityUserDetails;
 import clap.server.application.port.inbound.notification.UpdateNotificationUsecase;
 import clap.server.common.annotation.architecture.WebAdapter;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.enums.ParameterIn;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.RequiredArgsConstructor;
+import org.springframework.security.core.annotation.AuthenticationPrincipal;
 import org.springframework.web.bind.annotation.PatchMapping;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -27,4 +29,10 @@ public class ManagementNotificationController {
     public void updateNotificationIsRead(@PathVariable Long notificationId) {
         updateNotificationUsecase.updateNotification(notificationId);
     }
+
+    @Operation(summary = "알림 목록에서 전체 읽음 버튼을 눌렀을 때 전체 읽음 처리")
+    @PatchMapping
+    public void updateAllNotificationIsRead(@AuthenticationPrincipal SecurityUserDetails userInfo) {
+        updateNotificationUsecase.updateAllNotification(userInfo.getUserId());
+    }
 }

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);
+        }
+    }
+}