♻️ refactor: Slack 비동기 처리

Author: rlawngjs0313

src/main/java/com/example/Veco/domain/external/service/ExternalService.java

@@ -15,9 +15,6 @@
 import com.example.Veco.domain.external.repository.ExternalCustomRepository;
 import com.example.Veco.domain.external.repository.ExternalRepository;
 import com.example.Veco.domain.github.service.GitHubIssueService;
-import com.example.Veco.domain.goal.converter.GoalConverter;
-import com.example.Veco.domain.goal.dto.request.GoalReqDTO;
-import com.example.Veco.domain.goal.dto.response.GoalResDTO;
 import com.example.Veco.domain.goal.entity.Goal;
 import com.example.Veco.domain.goal.repository.GoalRepository;
 import com.example.Veco.domain.mapping.Assignment;
@@ -28,9 +25,7 @@
 import com.example.Veco.domain.member.error.MemberErrorStatus;
 import com.example.Veco.domain.member.error.MemberHandler;
 import com.example.Veco.domain.member.repository.MemberRepository;
-import com.example.Veco.domain.slack.exception.SlackException;
-import com.example.Veco.domain.slack.exception.code.SlackErrorCode;
-import com.example.Veco.domain.slack.util.SlackUtil;
+import com.example.Veco.domain.slack.service.SlackCommandService;
 import com.example.Veco.domain.team.dto.NumberSequenceResponseDTO;
 import com.example.Veco.domain.team.entity.Team;
 import com.example.Veco.domain.team.exception.TeamException;
@@ -51,7 +46,6 @@
 import java.time.format.DateTimeParseException;
 import java.util.ArrayList;
 import java.util.List;
-import java.util.Optional;
 import java.util.stream.Collectors;
 
 @Slf4j
@@ -72,11 +66,11 @@ public class ExternalService {
     private final AssigneeRepository assigneeRepository;
 
     // 유틸
-    private final SlackUtil slackUtil;
     private final CommentRoomRepository commentRoomRepository;
     private final GitHubIssueService gitHubIssueService;
     private final GitHubInstallationRepository githubInstallationRepository;
     private final CommentRepository commentRepository;
+    private final SlackCommandService slackCommandService;
 
     @Transactional
     public ExternalResponseDTO.CreateResponseDTO createExternal(Long teamId,
@@ -124,22 +118,7 @@ public ExternalResponseDTO.CreateResponseDTO createExternal(Long teamId,
         if(request.getExtServiceType() == ExtServiceType.GITHUB){
             gitHubIssueService.createGitHubIssue(request);
         } else if (request.getExtServiceType() == ExtServiceType.SLACK){
-            // accessToken, DefaultChannelId, message
-            // 연동 정보 조회
-            com.example.Veco.domain.external.entity.ExternalService externalService =
-                    linkRepository.findLinkByWorkspaceAndExternalService_ServiceType(
-                    team.getWorkSpace(), ExtServiceType.SLACK)
-                    .orElseThrow(() -> new SlackException(SlackErrorCode.NOT_LINKED))
-                    .getExternalService();
-
-            String message = team.getName() + "에서 " +
-                    external.getTitle() + "을(를) 생성했습니다.";
-
-            slackUtil.PostSlackMessage(
-                    externalService.getAccessToken(),
-                    externalService.getSlackDefaultChannelId(),
-                    message
-            );
+            slackCommandService.sendSlackMessage(team, external);
         }
 
         return ExternalConverter.createResponseDTO(external);

src/main/java/com/example/Veco/domain/slack/service/SlackCommandService.java

@@ -1,6 +1,7 @@
 package com.example.Veco.domain.slack.service;
 
 import com.example.Veco.domain.external.converter.ExternalServiceConverter;
+import com.example.Veco.domain.external.entity.External;
 import com.example.Veco.domain.external.entity.ExternalService;
 import com.example.Veco.domain.external.repository.ExternalServiceRepository;
 import com.example.Veco.domain.mapping.converter.LinkConverter;
@@ -14,6 +15,7 @@
 import com.example.Veco.domain.slack.exception.SlackException;
 import com.example.Veco.domain.slack.exception.code.SlackErrorCode;
 import com.example.Veco.domain.slack.util.SlackUtil;
+import com.example.Veco.domain.team.entity.Team;
 import com.example.Veco.domain.workspace.entity.WorkSpace;
 import com.example.Veco.global.auth.jwt.util.JwtUtil;
 import com.example.Veco.global.enums.ExtServiceType;
@@ -163,4 +165,34 @@ public Long installApp(
         // 기본 팀 ID로 리다이렉트
         return workspace.getTeams().getFirst().getId();
     }
+
+    // Slack 메시지 전송
+    public void sendSlackMessage(
+            Team team,
+            External external
+    ) {
+        // accessToken, DefaultChannelId, message
+        // 연동 정보 조회
+        com.example.Veco.domain.external.entity.ExternalService externalService =
+                linkRepository.findLinkByWorkspaceAndExternalService_ServiceType(
+                                team.getWorkSpace(), ExtServiceType.SLACK)
+                        .orElseThrow(() -> new SlackException(SlackErrorCode.NOT_LINKED))
+                        .getExternalService();
+
+        String message = team.getName() + "에서 " +
+                external.getTitle() + "을(를) 생성했습니다.";
+
+        SlackResDTO.PostSlackMessage result = slackUtil.PostSlackMessage(
+                externalService.getAccessToken(),
+                externalService.getSlackDefaultChannelId(),
+                message
+        );
+
+        if (!result.ok()){
+
+            // 로그
+            log.error(result.error());
+            throw new SlackException(SlackErrorCode.MESSAGE_POST_FAILED);
+        }
+    }
 }

src/main/java/com/example/Veco/domain/slack/util/SlackUtil.java

@@ -64,7 +64,7 @@ public SlackResDTO.JoinChannel joinChannel(
                 .block();
     }
 
-    // 메시지 전송
+    // 메시지 전송: Service에 따로 지정 -> 비동기
     public SlackResDTO.PostSlackMessage PostSlackMessage(
             String accessToken, String slackDefaultChannelId, String content
     ){