Merge pull request #163 from CSID-DGU/develop

[deploy] develop -> main

Author: saokiritoni

Dockerfile

@@ -1,9 +1,11 @@
-FROM openjdk:17-jdk-slim
+FROM eclipse-temurin:17-jre-jammy
 
 WORKDIR /app
 
 COPY build/libs/admin_be-0.0.1-SNAPSHOT.jar app.jar
 
 EXPOSE 8080
 
+ENV TZ=Asia/Seoul
+
 ENTRYPOINT ["java", "-jar", "app.jar"]

build.gradle

@@ -32,6 +32,7 @@ dependencies {
 	implementation 'org.springframework.boot:spring-boot-starter-validation'
 	testImplementation 'io.projectreactor:reactor-test'
 	implementation 'org.springframework.boot:spring-boot-starter-webflux'
+	testRuntimeOnly 'com.h2database:h2'
 
 	//spring security
 	implementation 'org.springframework.boot:spring-boot-starter-security'

src/main/java/DGU_AI_LAB/admin_be/domain/alarm/service/AlarmService.java

@@ -2,8 +2,6 @@
 
 import DGU_AI_LAB.admin_be.domain.requests.entity.Request;
 import DGU_AI_LAB.admin_be.domain.users.entity.User;
-import DGU_AI_LAB.admin_be.error.ErrorCode;
-import DGU_AI_LAB.admin_be.error.exception.BusinessException;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.log4j.Log4j2;
 import org.springframework.beans.factory.annotation.Value;
@@ -13,36 +11,35 @@
 import org.springframework.stereotype.Service;
 import org.springframework.web.client.RestTemplate;
 
-import java.util.List;
 import java.util.Map;
-import java.util.stream.Collectors;
 
+/**
+ * 사용자(이메일, DM) 및 관리자(Slack 채널)에게 알림을 전송하는 서비스
+ */
 @Service
 @RequiredArgsConstructor
 @Log4j2
 public class AlarmService {
 
+    // --- Slack Webhook (관리자 채널) ---
     @Value("${slack-webhook-url.monitoring}")
     private String defaultWebhookUrl;
     @Value("${slack-webhook-url.farm-admin}")
     private String farmAdminWebhookUrl;
     @Value("${slack-webhook-url.lab-admin}")
     private String labAdminWebhookUrl;
 
-
-    @Value("${slack.bot-token}")
-    private String botToken;
-    private final RestTemplate restTemplate = new RestTemplate();
-
+    // --- 외부 서비스 의존성 ---
     private final JavaMailSender mailSender;
+    private final SlackApiService slackApiService;
+    private final RestTemplate restTemplate = new RestTemplate();
 
     @Value("${spring.mail.username}")
     private String from;
 
-    public void sendSlackAlert(String message) {
-        sendSlackAlert(message, null);
-    }
-
+    /**
+     * Slack Webhook을 사용하여 특정 채널에 메시지를 전송합니다.
+     */
     public void sendSlackAlert(String message, String webhookUrl) {
         HttpHeaders headers = new HttpHeaders();
         headers.setContentType(MediaType.APPLICATION_JSON);
@@ -52,144 +49,80 @@ public void sendSlackAlert(String message, String webhookUrl) {
 
         String urlToUse = (webhookUrl != null && !webhookUrl.isEmpty()) ? webhookUrl : defaultWebhookUrl;
 
-        ResponseEntity<String> response = restTemplate.postForEntity(urlToUse, request, String.class);
-
-        if (!response.getStatusCode().is2xxSuccessful()) {
-            log.debug("Slack 알림 전송 실패: {}", response.getStatusCode());
-        } else {
-            log.debug("Slack 알림 전송 성공");
+        try {
+            ResponseEntity<String> response = restTemplate.postForEntity(urlToUse, request, String.class);
+            if (!response.getStatusCode().is2xxSuccessful()) {
+                log.warn("Slack 알림 전송 실패: {}", response.getStatusCode());
+            } else {
+                log.debug("Slack 알림 전송 성공");
+            }
+        } catch (Exception e) {
+            log.error("Slack 알림 전송 중 예외 발생: (URL: {})", urlToUse, e);
         }
     }
-    public void sendMailAlert(String to, String subject, String body) {
-        SimpleMailMessage message = new SimpleMailMessage();
-        message.setFrom(from);
-        message.setTo(to);
-        message.setSubject(subject);
-        message.setText(body);
-        mailSender.send(message);
-        System.out.printf("메일 전송 성공: 수신자=%s, 제목=%s%n", to, subject);
-    }
-
-    // slack dm 전송
-    public void sendDMAlert(String username, String email, String message) {
-        String userId = getSlackUser(username, email, botToken);
-        if (userId == null) {
-            throw new BusinessException(ErrorCode.SLACK_USER_NOT_FOUND);
-        }
-
-        String channelId = openDMChannel(userId, botToken);
-        if (channelId == null) {
-            throw new BusinessException(ErrorCode.SLACK_DM_CHANNEL_FAILED);
-        }
 
+    /**
+     * 사용자에게 이메일을 전송합니다.
+     */
+    public void sendMailAlert(String to, String subject, String body) {
         try {
-            sendMessageToSlackChannel(channelId, message, botToken);
+            SimpleMailMessage message = new SimpleMailMessage();
+            message.setFrom(from);
+            message.setTo(to);
+            message.setSubject(subject);
+            message.setText(body);
+            mailSender.send(message);
+            log.info("메일 전송 성공: 수신자={}, 제목={}", to, subject);
         } catch (Exception e) {
-            throw new BusinessException(ErrorCode.SLACK_SEND_FAILED);
+            log.error("메일 전송 실패: 수신자={}", to, e);
         }
     }
 
-    // 이름이 일치하는 사용자에게 dm 전송
-    // 이름이 같은 사용자가 있는 경우 email이 일치하는 사용자에게 dm 전송
-    private String getSlackUser(String username, String email, String token) {
-        String url = "https://slack.com/api/users.list";
-        HttpHeaders headers = new HttpHeaders();
-        headers.setBearerAuth(token);
-        HttpEntity<Void> request = new HttpEntity<>(headers);
-
-        ResponseEntity<Map> response = restTemplate.exchange(url, HttpMethod.GET, request, Map.class);
-        if (!Boolean.TRUE.equals(response.getBody().get("ok"))) {
-            throw new BusinessException(ErrorCode.SLACK_USER_NOT_FOUND);
-        }
-
-        List<Map<String, Object>> members = (List<Map<String, Object>>) response.getBody().get("members");
-
-        // 이름이 일치하는 사용자 목록 필터링
-        List<Map<String, Object>> matchedUsers = members.stream()
-                .filter(user -> {
-                    Map<String, Object> profile = (Map<String, Object>) user.get("profile");
-                    String displayName = (String) profile.get("display_name");
-                    String realName = (String) profile.get("real_name");
-                    String name = (String) user.get("name");
-
-                    return username.equals(name) || username.equals(displayName) || username.equals(realName);
-                })
-                .collect(Collectors.toList());
-
-        if (matchedUsers.isEmpty()) {
-            throw new BusinessException(ErrorCode.SLACK_USER_NOT_FOUND);
-        }
-
-        if (matchedUsers.size() == 1) {
-            return (String) matchedUsers.get(0).get("id");
-        }
-
-        Map<String, Object> selectedUser = matchedUsers.stream()
-                .filter(user -> {
-                    Map<String, Object> profile = (Map<String, Object>) user.get("profile");
-                    String userEmail = (String) profile.get("email");
-                    return userEmail != null && userEmail.equalsIgnoreCase(email);
-                })
-                .findFirst()
-                .orElseThrow(() -> new BusinessException(ErrorCode.SLACK_USER_EMAIL_NOT_MATCH));
-
-        return (String) selectedUser.get("id");
+    /**
+     * 사용자에게 Slack DM을 전송합니다.
+     */
+    public void sendDMAlert(String username, String email, String message) {
+        slackApiService.sendDM(username, email, message);
     }
 
-    private String openDMChannel(String userId, String token) {
-        String url = "https://slack.com/api/conversations.open";
-        HttpHeaders headers = new HttpHeaders();
-        headers.setBearerAuth(token);
-        headers.setContentType(MediaType.APPLICATION_JSON);
-
-        Map<String, Object> body = Map.of("users", userId);
-        HttpEntity<Map<String, Object>> request = new HttpEntity<>(body, headers);
-
-        ResponseEntity<Map> response = restTemplate.postForEntity(url, request, Map.class);
-        if (Boolean.TRUE.equals(response.getBody().get("ok"))) {
-            Map channel = (Map) response.getBody().get("channel");
-            return (String) channel.get("id");
+    /**
+     * 사용자에게 DM과 메일을 모두 전송합니다. (주로 사용자 대상 알림)
+     */
+    public void sendAllAlerts(String username, String email, String subject, String message) {
+        try {
+            sendMailAlert(email, subject, message);
+        } catch (Exception e) {
+            log.error("sendAllAlerts 중 메일 전송 실패: {}", email, e);
         }
-        return null;
-    }
-
-    private void sendMessageToSlackChannel(String channelId, String message, String token) {
-        String url = "https://slack.com/api/chat.postMessage";
-        HttpHeaders headers = new HttpHeaders();
-        headers.setBearerAuth(token);
-        headers.setContentType(MediaType.APPLICATION_JSON);
 
-        Map<String, Object> body = Map.of(
-                "channel", channelId,
-                "text", message
-        );
-        HttpEntity<Map<String, Object>> request = new HttpEntity<>(body, headers);
-
-        ResponseEntity<Map> response = restTemplate.postForEntity(url, request, Map.class);
-        if (!Boolean.TRUE.equals(response.getBody().get("ok"))) {
-            throw new BusinessException(ErrorCode.SLACK_SEND_FAILED);
+        try {
+            sendDMAlert(username, email, message);
+        } catch (Exception e) {
+            log.error("sendAllAlerts 중 DM 전송 실패: {}", username, e);
         }
     }
 
-    public void sendAllAlerts(String username, String email, String subject, String message) {
-        sendDMAlert(username, email, message);
-        sendMailAlert(email, subject, message);
-    }
-
-    public void sendNewRequestNotification(Request request) {
-        String serverName = request.getResourceGroup().getServerName();
-        String targetWebhookUrl;
-
-        // serverName에 따라 사용할 다른 채널로 전송
+    /**
+     * serverName에 따라 적절한 Webhook URL을 반환합니다.
+     */
+    private String getAdminWebhookUrl(String serverName) {
         if ("FARM".equalsIgnoreCase(serverName)) {
-            targetWebhookUrl = farmAdminWebhookUrl;
+            return farmAdminWebhookUrl;
         } else if ("LAB".equalsIgnoreCase(serverName)) {
-            targetWebhookUrl = labAdminWebhookUrl;
+            return labAdminWebhookUrl;
         } else {
-            // FARM이나 LAB이 아닌 잘못된 입력값이 있을 경우, 기본 모니터링 채널로 전송
+            // FARM이나 LAB이 아닌 잘못된 입력값이 있을 경우, 기본 모니토링 채널로 전송
             log.warn("알 수 없는 serverName '{}'에 대한 요청 알림입니다. 기본 채널로 전송합니다.", serverName);
-            targetWebhookUrl = defaultWebhookUrl;
+            return defaultWebhookUrl;
         }
+    }
+
+    /**
+     * 관리자 채널(FARM/LAB)로 신규 신청 알림을 보냅니다.
+     */
+    public void sendNewRequestNotification(Request request) {
+        String serverName = request.getResourceGroup().getServerName();
+        String targetWebhookUrl = getAdminWebhookUrl(serverName); // 중복 로직 제거
 
         // 슬랙 메시지 내용을 생성합니다.
         String message = String.format(
@@ -215,8 +148,7 @@ public void sendNewRequestNotification(Request request) {
     }
 
     /**
-     * 사용자에게 서버 사용 신청 승인 알림을 보냅니다.
-     * @param request 승인된 Request 엔티티
+     * 사용자에게 서버 사용 신청 승인 알림을 보냅니다. (DM + Email)
      */
     public void sendApprovalNotification(Request request) {
         User user = request.getUser();
@@ -248,4 +180,13 @@ public void sendApprovalNotification(Request request) {
         sendAllAlerts(user.getName(), user.getEmail(), subject, message);
     }
 
+    /**
+     * 서버 이름에 따라 적절한 관리자 채널로 메시지를 보냅니다.
+     * @param serverName "FARM", "LAB" 등
+     * @param message 보낼 메시지
+     */
+    public void sendAdminSlackNotification(String serverName, String message) {
+        String targetWebhookUrl = getAdminWebhookUrl(serverName);
+        sendSlackAlert(message, targetWebhookUrl);
+    }
 }