CLAP-257 Fix : template builder 클래스로 agit template 생성 기능 분리

Author: starboxxxx

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

@@ -2,14 +2,13 @@
 
 import clap.server.adapter.outbound.api.dto.PushNotificationTemplate;
 import clap.server.adapter.outbound.persistense.entity.notification.constant.NotificationType;
-import clap.server.application.port.outbound.task.CommandTaskPort;
 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 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.http.ResponseEntity;
 import org.springframework.web.client.RestTemplate;
@@ -22,65 +21,22 @@ public class AgitClient implements SendAgitPort {
     @Value("${webhook.agit.url}")
     private String AGIT_WEBHOOK_URL;
 
-    private final CommandTaskPort commandTaskPort;
+    private final UpdateTaskService updateTaskService;
+    private final AgitTemplateBuilder agitTemplateBuilder;
 
     @Override
     public void sendAgit(PushNotificationTemplate request, Task task) {
 
-        HttpHeaders headers = new HttpHeaders();
-
-        headers.add("Content-Type", "application/json");
-        HttpEntity<String> entity = new HttpEntity<>(getPayLoad(request, task), headers);
+        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);
-            commandTaskPort.updateAgitPostId(responseEntity, task);
+            updateTaskService.updateAgitPostId(responseEntity, task);
         }
         else {
             restTemplate.exchange(AGIT_WEBHOOK_URL, HttpMethod.POST, entity, String.class);
         }
     }
-
-    private String getPayLoad(PushNotificationTemplate request, Task task) {
-
-        String payload;
-        if (request.notificationType() == NotificationType.TASK_REQUESTED) {
-            payload = "{"
-                    + "\"text\": \"" + getMessage(request) + "\","
-                    + "\"mrkdwn\": true" + "}";
-        }
-
-        else {
-            payload = "{"
-                    + "\"parent_id\": " + task.getAgitPostId() + ","
-                    + "\"text\": \"" + getMessage(request) + "\","
-                    + "\"mrkdwn\": true"
-                    + "}";
-        }
-        return payload;
-    }
-
-    private String getMessage(PushNotificationTemplate request) {
-        String taskUrl = "https://www.naver.com"; //Todo 작업 상세페이지 url 추가
-
-        return  switch (request.notificationType()) {
-            case TASK_REQUESTED -> "📌 *새 작업 요청:* `" + request.taskName() + "`\\n"
-                    + "\\t\\t*•요청자: " + request.senderName() + "*\\n"
-                    + "\\t\\t[OPEN](" + taskUrl + ")";
-            case STATUS_SWITCHED -> "⚙️ *작업 상태 변경:* `" + request.taskName() + "\\n"
-                    + "\\t\\t*•작업 상태: " + request.message() + "*\\n"
-                    + "\\t\\t[OPEN](" + taskUrl + ")";
-            case PROCESSOR_CHANGED -> "🔄 *담당자 변경:* `" + request.taskName() + "\\n"
-                    + "\\t\\t*•새 담당자: " + request.message() + "*\\n"
-                    + "\\t\\t[OPEN](" + taskUrl + ")";
-            case PROCESSOR_ASSIGNED -> "👤 *작업 담당자 배정:* `" + request.taskName() + "\\n"
-                    + "\\t\\t*•담당자: " + request.message() + "*\\n"
-                    + "\\t\\t[OPEN](" + taskUrl + ")";
-            default -> null;
-        };
-    }
 }

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

@@ -0,0 +1,62 @@
+package clap.server.adapter.outbound.api;
+
+import clap.server.adapter.outbound.api.dto.PushNotificationTemplate;
+import clap.server.adapter.outbound.persistense.entity.notification.constant.NotificationType;
+import clap.server.domain.model.task.Task;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.stereotype.Component;
+
+@Component
+public class AgitTemplateBuilder {
+
+    public HttpEntity<String> createAgitEntity(PushNotificationTemplate request, Task task) {
+        return new HttpEntity<>(createPayLoad(request, task), createHeaders());
+    }
+
+
+    public HttpHeaders createHeaders() {
+        HttpHeaders headers = new HttpHeaders();
+        headers.add("Content-Type", "application/json");
+        return headers;
+    }
+
+    public String createPayLoad(PushNotificationTemplate request, Task task) {
+
+        String payload;
+        if (request.notificationType() == NotificationType.TASK_REQUESTED) {
+            payload = "{"
+                    + "\"text\": \"" + createMessage(request) + "\","
+                    + "\"mrkdwn\": true" + "}";
+        }
+
+        else {
+            payload = "{"
+                    + "\"parent_id\": " + task.getAgitPostId() + ","
+                    + "\"text\": \"" + createMessage(request) + "\","
+                    + "\"mrkdwn\": true"
+                    + "}";
+        }
+        return payload;
+    }
+
+    public String createMessage(PushNotificationTemplate request) {
+        String taskUrl = "https://www.naver.com"; //Todo 작업 상세페이지 url 추가
+
+        return  switch (request.notificationType()) {
+            case TASK_REQUESTED -> "📌 *새 작업 요청:* `" + request.taskName() + "`\\n"
+                    + "\\t\\t*•요청자: " + request.senderName() + "*\\n"
+                    + "\\t\\t[OPEN](" + taskUrl + ")";
+            case STATUS_SWITCHED -> "⚙️ *작업 상태 변경:* `" + request.taskName() + "\\n"
+                    + "\\t\\t*•작업 상태: " + request.message() + "*\\n"
+                    + "\\t\\t[OPEN](" + taskUrl + ")";
+            case PROCESSOR_CHANGED -> "🔄 *담당자 변경:* `" + request.taskName() + "\\n"
+                    + "\\t\\t*•새 담당자: " + request.message() + "*\\n"
+                    + "\\t\\t[OPEN](" + taskUrl + ")";
+            case PROCESSOR_ASSIGNED -> "👤 *작업 담당자 배정:* `" + request.taskName() + "\\n"
+                    + "\\t\\t*•담당자: " + request.message() + "*\\n"
+                    + "\\t\\t[OPEN](" + taskUrl + ")";
+            default -> null;
+        };
+    }
+}