CLAP-294 Refactor: sse 알림 폼 및 전송을 담당하는 SendSseService 구현

<footer>
- 관련: #350

Author: joowojr

…d/infrastructure/sse/SendSseService.java …/infrastructure/sse/SseEventEmitter.javasrc/main/java/clap/server/adapter/outbound/infrastructure/sse/SendSseService.java renamed to src/main/java/clap/server/adapter/outbound/infrastructure/sse/SseEventEmitter.java src/main/java/clap/server/adapter/outbound/infrastructure/sse/SendSseService.java renamed to src/main/java/clap/server/adapter/outbound/infrastructure/sse/SseEventEmitter.java

@@ -11,7 +11,7 @@
 
 @InfrastructureAdapter
 @RequiredArgsConstructor
-public class SendSseService implements SendSsePort {
+public class SseEventEmitter implements SendSsePort {
 
     private final EmitterRepository emitterRepository;
 

src/main/java/clap/server/application/service/webhook/SendNotificationService.java

@@ -1,10 +1,8 @@
 package clap.server.application.service.webhook;
 
-import clap.server.adapter.inbound.web.dto.notification.request.SseRequest;
 import clap.server.adapter.outbound.api.dto.PushNotificationTemplate;
 import clap.server.adapter.outbound.persistense.entity.notification.constant.NotificationType;
 import clap.server.application.port.outbound.notification.CommandNotificationPort;
-import clap.server.application.port.outbound.webhook.SendSsePort;
 import clap.server.common.annotation.architecture.ApplicationService;
 import clap.server.domain.model.member.Member;
 import clap.server.domain.model.notification.Notification;
@@ -20,7 +18,7 @@
 @RequiredArgsConstructor
 public class SendNotificationService {
 
-    private final SendSsePort sendSsePort;
+    private final SendSseService sendSseService;
     private final SendAgitService sendAgitService;
     private final SendWebhookEmailService sendWebhookEmailService;
     private final SendKaKaoWorkService sendKaKaoWorkService;
@@ -35,13 +33,6 @@ public void sendPushNotification(Member receiver, NotificationType notificationT
 
         Notification notification = createTaskNotification(task, receiver, notificationType, message, taskTitle);
 
-        SseRequest sseRequest = new SseRequest(
-                taskTitle,
-                notificationType,
-                receiver.getMemberId(),
-                message
-        );
-
         PushNotificationTemplate pushNotificationTemplate = new PushNotificationTemplate(
                 email, notificationType, taskTitle, requesterNickname, message, commenterName
         );
@@ -51,7 +42,7 @@ public void sendPushNotification(Member receiver, NotificationType notificationT
         });
 
         CompletableFuture<Void> sendSseFuture = CompletableFuture.runAsync(() -> {
-            sendSsePort.send(sseRequest);
+            sendSseService.send(receiver, notificationType, task, message);
         });
 
         CompletableFuture<Void> sendEmailFuture = CompletableFuture.runAsync(() -> {

src/main/java/clap/server/application/service/webhook/SendSseService.java

@@ -0,0 +1,26 @@
+package clap.server.application.service.webhook;
+
+import clap.server.adapter.inbound.web.dto.notification.request.SseRequest;
+import clap.server.adapter.outbound.persistense.entity.notification.constant.NotificationType;
+import clap.server.application.port.outbound.webhook.SendSsePort;
+import clap.server.domain.model.member.Member;
+import clap.server.domain.model.task.Task;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor
+public class SendSseService {
+    private final SendSsePort sendSsePort;
+
+    public void send(Member receiver, NotificationType notificationType,
+                     Task task, String message) {
+        SseRequest sseRequest = new SseRequest(
+                task.getTitle(),
+                notificationType,
+                receiver.getMemberId(),
+                message
+        );
+        sendSsePort.send(sseRequest);
+    }
+}