[FEAT] 500에러 디스코드 알림 기능 구현

gss-api-app/src/main/java/com/devoops/exception/GlobalExceptionHandler.java

@@ -2,6 +2,7 @@
 
 import com.devoops.exception.custom.GssException;
 import com.devoops.exception.errorcode.ErrorCode;
+import com.devoops.domain.notifier.ErrorNotifier;
 import io.jsonwebtoken.ExpiredJwtException;
 import jakarta.validation.ConstraintViolationException;
 import lombok.RequiredArgsConstructor;
@@ -21,6 +22,8 @@
 @RequiredArgsConstructor
 public class GlobalExceptionHandler {
 
+    private final ErrorNotifier errorNotifier;
+
     @ExceptionHandler(BindException.class)
     public ResponseEntity<ErrorResponse> handleBindingException(BindException exception) {
         log.warn("Binding exception occurred", exception);
@@ -69,6 +72,7 @@ public ResponseEntity<ErrorResponse> handleNoResourceFoundException(NoResourceFo
     @ExceptionHandler(GssException.class)
     public ResponseEntity<ErrorResponse> handleGssException(GssException exception) {
         log.error("Custom GssException occurred: {}", exception.getMessage(), exception);
+        errorNotifier.notify(exception);
         return toResponse(exception.getErrorCode());
     }
 
@@ -80,6 +84,7 @@ public ResponseEntity<ErrorResponse> handleException(ExpiredJwtException excepti
     @ExceptionHandler(Exception.class)
     public ResponseEntity<ErrorResponse> handleException(Exception exception) {
         log.error("Unhandled exception occurred", exception);
+        errorNotifier.notify(exception);
         return toResponse(ErrorCode.INTERNAL_SERVER_ERROR);
     }
 

gss-api-app/src/main/java/com/devoops/service/auth/jwt/JwtProperties.java

@@ -24,7 +24,6 @@ public JwtProperties(String secretKey, Duration accessTokenExpiration, Duration
         this.refreshTokenExpiration = refreshTokenExpiration;
     }
 
-
     public Duration getExpirationByTokenType(TokenType type) {
         if(type == TokenType.ACCESS_TOKEN) {
             return accessTokenExpiration;

gss-api-app/src/test/java/com/devoops/notifier/adapter/ErrorNotifierTest.java

@@ -0,0 +1,20 @@
+package com.devoops.notifier.adapter;
+
+import com.devoops.BaseControllerTest;
+import com.devoops.domain.notifier.ErrorNotifier;
+import com.devoops.exception.GithubNotFoundException;
+import org.junit.jupiter.api.Disabled;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+
+@Disabled
+class ErrorNotifierTest extends BaseControllerTest {
+
+    @Autowired
+    private ErrorNotifier errorNotifier;
+
+    @Test
+    void sendMessage() {
+        errorNotifier.notify(new GithubNotFoundException("Github Not Found"));
+    }
+}

gss-api-app/src/test/resources/application.yml → gss-api-app/src/test/resources/application-test.yml

@@ -1,21 +1,4 @@
 spring:
-  profiles:
-    active: test
-
-jwt:
-  secret_key: testtesttesttesttesttesttesttest
-  access_token_expiration: 1h
-  refresh_token_expiration: 1d
-
-cors:
-  origin: http://localhost:8080
-
----
-
-spring:
-  config:
-    activate:
-      on-profile: test
   data:
     redis:
       host: localhost
@@ -36,6 +19,14 @@ spring:
   flyway:
     enabled: false
 
+jwt:
+  secret_key: testtesttesttesttesttesttesttest
+  access_token_expiration: 1h
+  refresh_token_expiration: 1d
+
+cors:
+  origin: http://localhost:8080
+
 dev-oops:
   mcp:
     webhook-url: https://test.dev-oops.kr/api/webhooks
@@ -44,3 +35,7 @@ dev-oops:
       url: https://api.github.com
       connect-timeout: 3000
       read-timeout: 3000
+
+discord:
+  token: testToken
+  channel-id: testChannel

gss-common/src/main/java/com/devoops/exception/errorcode/ErrorCode.java

@@ -41,7 +41,9 @@ public enum ErrorCode {
     GITHUB_CLIENT_ERROR(500, "깃허브 클라이언트 소통과정에 문제가 발생했습니다"),
     AI_RESPONSE_PARSING_ERROR(500, "AI로부터 온 질문 생성을 파싱하는 과정에 오류가 발생했습니다"),
     AI_CREATE_QUESTION_ERROR(500, "AI 질문 생성과정에 오류가 발생했습니다"),
-    AI_CHARGE_NOT_FOUND(500, "당월 AI 비용을 찾을 없습니다.")
+    AI_CHARGE_NOT_FOUND(500, "당월 AI 비용을 찾을 수 없습니다."),
+    DISCORD_PROPERTIES_EMPTY(500, "디스코드 채널 id와 키를 찾을 수 없습니다"),
+    DISCORD_JDA_EXCEPTION(500, "디스코드 JDA 초기화에 실패하였습니다"),
     ;
 
     private final int statusCode;

gss-common/src/main/java/com/devoops/exception/message/ErrorMessageResolver.java

@@ -0,0 +1,30 @@
+package com.devoops.exception.message;
+
+import java.util.Arrays;
+import java.util.stream.Collectors;
+
+public class ErrorMessageResolver {
+
+    private static final String NOTIFICATION_PREFIX = ":rotating_light:  [**Error 발생!**]\n";
+    private static final String STACK_TRACE_AFFIX = "\n```\n";
+    private static final String DISCORD_LINE_SEPARATOR = "\n";
+    private static final int STACK_TRACE_LENGTH = 10;
+
+    public static String resolve(Throwable throwable) {
+        String errorMessage = throwable.toString();
+        String stackTrace = getStackTraceAsString(throwable);
+
+        return NOTIFICATION_PREFIX
+                + errorMessage
+                + STACK_TRACE_AFFIX
+                + stackTrace
+                + STACK_TRACE_AFFIX;
+    }
+
+    private static String getStackTraceAsString(Throwable throwable) {
+        return Arrays.stream(throwable.getStackTrace())
+                .map(StackTraceElement::toString)
+                .limit(STACK_TRACE_LENGTH)
+                .collect(Collectors.joining(DISCORD_LINE_SEPARATOR));
+    }
+}

gss-common/src/main/java/com/devoops/exception/notifier/NotifyPort.java

@@ -0,0 +1,6 @@
+package com.devoops.exception.notifier;
+
+public interface NotifyPort {
+
+    void sendMessage(String message);
+}

gss-domain/build.gradle

@@ -20,6 +20,9 @@ dependencies {
 	implementation("com.fasterxml.jackson.core:jackson-databind")
 	implementation("com.fasterxml.jackson.datatype:jackson-datatype-jsr310")
 
+	//Discord
+	implementation 'net.dv8tion:JDA:5.0.0-beta.24'
+
 	// testFixtures
 	testFixturesImplementation 'org.springframework.boot:spring-boot-starter-data-jpa' // includes EntityManager, TX
 	testFixturesImplementation 'org.springframework.boot:spring-boot-starter-test' // includes SpringExtension, DataJpaTest, etc.
@@ -33,3 +36,8 @@ dependencies {
 	runtimeOnly 'com.h2database:h2'
 	runtimeOnly 'com.mysql:mysql-connector-j'
 }
+
+tasks.withType(JavaCompile) {
+	options.compilerArgs += "-parameters"
+}
+

gss-domain/src/main/java/com/devoops/config/NotifierConfig.java

@@ -0,0 +1,40 @@
+package com.devoops.config;
+
+import com.devoops.exception.notifier.NotifyPort;
+import com.devoops.domain.notifier.ConsoleNotifier;
+import com.devoops.domain.notifier.DiscordNotifier;
+import com.devoops.domain.notifier.DiscordProperties;
+import lombok.NoArgsConstructor;
+import lombok.RequiredArgsConstructor;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Profile;
+
+@NoArgsConstructor(access = lombok.AccessLevel.PRIVATE)
+public class NotifierConfig {
+
+    @Profile({"dev", "prod"})
+    @Configuration
+    @RequiredArgsConstructor
+    @EnableConfigurationProperties(DiscordProperties.class)
+    public static class DiscordNotifierConfig {
+
+        private final DiscordProperties discordProperties;
+
+        @Bean
+        public NotifyPort discordNotifier() {
+            return new DiscordNotifier(discordProperties);
+        }
+    }
+
+    @Profile({"test", "local"})
+    @Configuration
+    public static class ConsoleNotifierConfig {
+
+        @Bean
+        public NotifyPort consoleNotifier() {
+            return new ConsoleNotifier();
+        }
+    }
+}

gss-domain/src/main/java/com/devoops/domain/notifier/ConsoleNotifier.java

@@ -0,0 +1,12 @@
+package com.devoops.domain.notifier;
+
+
+import com.devoops.exception.notifier.NotifyPort;
+
+public class ConsoleNotifier implements NotifyPort {
+
+    @Override
+    public void sendMessage(String message) {
+        System.out.println("[메시지 발송] : " + message);
+    }
+}

gss-domain/src/main/java/com/devoops/domain/notifier/DiscordNotifier.java

@@ -0,0 +1,37 @@
+package com.devoops.domain.notifier;
+
+import com.devoops.exception.custom.GssException;
+import com.devoops.exception.errorcode.ErrorCode;
+import com.devoops.exception.notifier.NotifyPort;
+import lombok.extern.slf4j.Slf4j;
+import net.dv8tion.jda.api.JDA;
+import net.dv8tion.jda.api.JDABuilder;
+import net.dv8tion.jda.api.entities.channel.concrete.TextChannel;
+
+@Slf4j
+public class DiscordNotifier implements NotifyPort {
+
+    private final DiscordProperties properties;
+    private final JDA jda;
+
+    public DiscordNotifier(DiscordProperties discordProperties) {
+        this.properties = discordProperties;
+        this.jda = initializeJda(properties.getToken());
+    }
+
+    private JDA initializeJda(String token) {
+        try {
+            return JDABuilder.createDefault(token).build().awaitReady();
+        } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
+            throw new GssException(ErrorCode.DISCORD_JDA_EXCEPTION);
+        }
+    }
+
+    @Override
+    public void sendMessage(String message) {
+        TextChannel channel = jda.getTextChannelById(properties.getChannelId());
+        channel.sendMessage(message).queue();
+    }
+}
+

gss-domain/src/main/java/com/devoops/domain/notifier/DiscordProperties.java

@@ -0,0 +1,27 @@
+package com.devoops.domain.notifier;
+
+import com.devoops.exception.custom.GssException;
+import com.devoops.exception.errorcode.ErrorCode;
+import lombok.Getter;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+@Getter
+@ConfigurationProperties(prefix = "discord")
+public class DiscordProperties {
+
+    private final String token;
+    private final String channelId;
+
+    public DiscordProperties(String token, String channelId) {
+        validate(token);
+        validate(channelId);
+        this.token = token;
+        this.channelId = channelId;
+    }
+
+    private void validate(String element) {
+        if (element == null || element.isBlank()) {
+            throw new GssException(ErrorCode.DISCORD_PROPERTIES_EMPTY);
+        }
+    }
+}

gss-domain/src/main/java/com/devoops/domain/notifier/ErrorNotifier.java

@@ -0,0 +1,18 @@
+package com.devoops.domain.notifier;
+
+import com.devoops.exception.message.ErrorMessageResolver;
+import com.devoops.exception.notifier.NotifyPort;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class ErrorNotifier {
+
+    private final NotifyPort notifyPort;
+
+    public void notify(Throwable throwable) {
+        String message = ErrorMessageResolver.resolve(throwable);
+        notifyPort.sendMessage(message);
+    }
+}

gss-mcp-app/src/main/java/com/devoops/exception/ErrorResponse.java

@@ -0,0 +1,19 @@
+package com.devoops.exception;
+
+import com.devoops.exception.errorcode.ErrorCode;
+import org.springframework.http.HttpStatus;
+
+public record ErrorResponse(
+        String code,
+        String status,
+        String message
+) {
+
+    public ErrorResponse(ErrorCode errorCode) {
+        this(
+                errorCode.name(),
+                HttpStatus.valueOf(errorCode.getStatusCode()).name(),
+                errorCode.getMessage()
+        );
+    }
+}

gss-mcp-app/src/main/java/com/devoops/exception/GlobalExceptionHandler.java

@@ -0,0 +1,38 @@
+package com.devoops.exception;
+
+import com.devoops.domain.notifier.ErrorNotifier;
+import com.devoops.exception.custom.GssException;
+import com.devoops.exception.errorcode.ErrorCode;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+
+@Slf4j
+@RestControllerAdvice
+@RequiredArgsConstructor
+public class GlobalExceptionHandler {
+
+    private final ErrorNotifier errorNotifier;
+
+    @ExceptionHandler(GssException.class)
+    public ResponseEntity<ErrorResponse> handleGssException(GssException exception) {
+        log.error("Custom GssException occurred: {}", exception.getMessage(), exception);
+        errorNotifier.notify(exception);
+        return toResponse(exception.getErrorCode());
+    }
+
+    @ExceptionHandler(Exception.class)
+    public ResponseEntity<ErrorResponse> handleException(Exception exception) {
+        log.error("Unhandled exception occurred", exception);
+        errorNotifier.notify(exception);
+        return toResponse(ErrorCode.INTERNAL_SERVER_ERROR);
+    }
+
+    private ResponseEntity<ErrorResponse> toResponse(ErrorCode errorCode) {
+        ErrorResponse errorResponse = new ErrorResponse(errorCode);
+        return ResponseEntity.status(errorCode.getStatusCode())
+                .body(errorResponse);
+    }
+}