CLAP-294 Refactor: agit post id 업데이트 로직 애플리케이션 단으로 이동

<footer>
- 관련: #350

Author: joowojr

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

@@ -2,12 +2,10 @@
 
 import clap.server.adapter.outbound.api.dto.PushNotificationTemplate;
 import clap.server.adapter.outbound.persistense.entity.notification.constant.NotificationType;
-import clap.server.application.port.inbound.domain.TaskService;
 import clap.server.application.port.outbound.webhook.SendAgitPort;
-import clap.server.application.service.task.UpdateTaskService;
 import clap.server.common.annotation.architecture.ExternalApiAdapter;
 import clap.server.domain.model.task.Task;
-import clap.server.exception.ApplicationException;
+import clap.server.exception.AdapterException;
 import clap.server.exception.code.NotificationErrorCode;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.JsonNode;
@@ -29,31 +27,30 @@ public class AgitClient implements SendAgitPort {
 
     private final AgitTemplateBuilder agitTemplateBuilder;
     private final ObjectMapper objectMapper;
-    private final TaskService taskService;
 
     @Override
-    public void sendAgit(PushNotificationTemplate request, Task task) {
+    public Long sendAgit(PushNotificationTemplate request, Task task) {
 
         HttpEntity<String> entity = agitTemplateBuilder.createAgitEntity(request, task);
 
         RestTemplate restTemplate = new RestTemplate();
         if (request.notificationType() == NotificationType.TASK_REQUESTED) {
             ResponseEntity<String> responseEntity = restTemplate.exchange(
                     AGIT_WEBHOOK_URL, HttpMethod.POST, entity, String.class);
-            updateAgitPostId(responseEntity, task);
+            return getAgitPostId(responseEntity);
         }
         else {
             restTemplate.exchange(AGIT_WEBHOOK_URL, HttpMethod.POST, entity, String.class);
+            return null;
         }
     }
 
-    private void updateAgitPostId(ResponseEntity<String> responseEntity, Task task) {
+    private Long getAgitPostId(ResponseEntity<String> responseEntity) {
         try {
             JsonNode jsonNode = objectMapper.readTree(responseEntity.getBody());
-            task.updateAgitPostId(jsonNode.get("id").asLong());
-            taskService.upsert(task);
+            return jsonNode.get("id").asLong();
         } catch (JsonProcessingException e) {
-            throw new ApplicationException(NotificationErrorCode.AGIT_SEND_FAILED);
+            throw new AdapterException(NotificationErrorCode.AGIT_SEND_FAILED);
         }
     }
 }

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

@@ -3,7 +3,9 @@
 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.inbound.domain.TaskService;
 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;
@@ -18,11 +20,12 @@
 @RequiredArgsConstructor
 public class SendNotificationService {
 
-    private final SendSseService sendSseService;
+    private final SendSsePort sendSsePort;
     private final SendAgitService sendAgitService;
     private final SendWebhookEmailService sendWebhookEmailService;
     private final SendKaKaoWorkService sendKaKaoWorkService;
     private final CommandNotificationPort commandNotificationPort;
+    private final TaskService taskService;
 
     @Async("notificationExecutor")
     public void sendPushNotification(Member receiver, NotificationType notificationType,
@@ -49,18 +52,18 @@ public void sendPushNotification(Member receiver, NotificationType notificationT
         });
 
         CompletableFuture<Void> sendSseFuture = CompletableFuture.runAsync(() -> {
-            sendSseService.send(sseRequest);
+            sendSsePort.send(sseRequest);
         });
 
         CompletableFuture<Void> sendEmailFuture = CompletableFuture.runAsync(() -> {
             if (receiver.getEmailNotificationEnabled()) {
-                sendWebhookEmailService.sendEmail(pushNotificationTemplate);
+                sendWebhookEmailService.send(pushNotificationTemplate);
             }
         });
 
         CompletableFuture<Void> sendKakaoWorkFuture = CompletableFuture.runAsync(() -> {
             if (receiver.getKakaoworkNotificationEnabled()) {
-                sendKaKaoWorkService.sendKaKaoWork(pushNotificationTemplate);
+                sendKaKaoWorkService.send(pushNotificationTemplate);
             }
         });
 
@@ -81,6 +84,11 @@ public void sendAgitNotification(NotificationType notificationType,
                 commenterName
         );
 
-        sendAgitService.sendAgit(pushNotificationTemplate, task);
+        if(notificationType.equals(NotificationType.TASK_REQUESTED)){
+            Long agitPostId = sendAgitService.sendAgit(pushNotificationTemplate, task);
+
+            task.updateAgitPostId(agitPostId);
+            taskService.upsert(task);
+        }
     }
 }