Merge pull request #61 from Nexters/feature/discord-notification

feat: 디스코드 로그 알림 설정

Author: 1117mg

build.gradle

@@ -21,6 +21,7 @@ configurations {
 
 repositories {
     mavenCentral()
+    maven { url 'https://jitpack.io' }
 }
 
 dependencies {
@@ -49,6 +50,9 @@ dependencies {
 
     // ncp
     implementation 'com.amazonaws:aws-java-sdk-s3:1.12.470'
+
+    // discord
+    implementation 'com.github.napstr:logback-discord-appender:1.0.0'
 }
 
 tasks.named('test') {

docker-compose.dev.yaml

@@ -37,8 +37,12 @@ services:
       - JWT_SECRET_KEY=${JWT_SECRET_KEY}
       - OAUTH_AUTHORIZED_REDIRECT_URIS=${OAUTH_AUTHORIZED_REDIRECT_URIS:-http://localhost:5173/oauth2/redirect,https://holdy.kr/oauth2/redirect}
       - OAUTH_DEFAULT_REDIRECT_URI=${OAUTH_DEFAULT_REDIRECT_URI:-http://localhost:5173/oauth2/redirect}
-      - NCP_ACCESS_KEY=${NCP_ACCESS_KEY:-ncp_iam_BPAMKR621TrFvcw4G8ek}
-      - NCP_SECRET_KEY=${NCP_SECRET_KEY:-ncp_iam_BPKMKRW1ET86Hvx1z74EaVQRqjjfQSCcj4}
+      - NCP_ACCESS_KEY=${NCP_ACCESS_KEY}
+      - NCP_SECRET_KEY=${NCP_SECRET_KEY}
+      - SPRING_PROFILES_ACTIVE=${SPRING_PROFILE_ACTIVE}
+      - DISCORD_ENABLED=${DISCORD_ENABLED}
+      - DISCORD_ERROR_WEBHOOK_URL=${DISCORD_DEV_ERROR_WEBHOOK_URL}
+      - DISCORD_NOTIFICATION_WEBHOOK_URL=${DISCORD_DEV_NOTIFICATION_WEBHOOK_URL}
     ports:
       - "9090:9090"
     depends_on:

docker-compose.prod.yaml

@@ -39,6 +39,10 @@ services:
       - OAUTH_DEFAULT_REDIRECT_URI=${OAUTH_DEFAULT_REDIRECT_URI:-https://holdy.kr/oauth2/redirect}
       - NCP_ACCESS_KEY=${NCP_ACCESS_KEY}
       - NCP_SECRET_KEY=${NCP_SECRET_KEY}
+      - SPRING_PROFILES_ACTIVE=${SPRING_PROFILE_ACTIVE}
+      - DISCORD_ENABLED=${DISCORD_ENABLED}
+      - DISCORD_ERROR_WEBHOOK_URL=${DISCORD_DEV_ERROR_WEBHOOK_URL}
+      - DISCORD_NOTIFICATION_WEBHOOK_URL=${DISCORD_DEV_NOTIFICATION_WEBHOOK_URL}
     ports:
       - "9090:9090"
     depends_on:

src/main/java/com/climbup/climbup/attempt/controller/AttemptController.java

@@ -35,7 +35,7 @@
 import java.util.UUID;
 
 @RestController
-@RequestMapping("/attempts")
+@RequestMapping("/api/attempts")
 @Tag(name = "Attempts", description = "루트 미션 도전 관련 API")
 @RequiredArgsConstructor
 public class AttemptController {

src/main/java/com/climbup/climbup/auth/service/CustomOAuth2UserService.java

@@ -4,20 +4,20 @@
 import com.climbup.climbup.auth.dto.KakaoOAuth2UserInfo;
 import com.climbup.climbup.auth.exception.NicknameGenerationException;
 import com.climbup.climbup.auth.util.RandomNicknameGenerator;
+import com.climbup.climbup.global.discord.SignUpEvent;
 import com.climbup.climbup.user.entity.User;
 import com.climbup.climbup.user.repository.UserRepository;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.security.oauth2.client.userinfo.DefaultOAuth2UserService;
 import org.springframework.security.oauth2.client.userinfo.OAuth2UserRequest;
 import org.springframework.security.oauth2.core.OAuth2AuthenticationException;
 import org.springframework.security.oauth2.core.user.OAuth2User;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.util.concurrent.ThreadLocalRandom;
-
 @Service
 @RequiredArgsConstructor
 @Slf4j
@@ -27,6 +27,7 @@ public class CustomOAuth2UserService extends DefaultOAuth2UserService {
     private int maxRetries;
 
     private final UserRepository userRepository;
+    private final ApplicationEventPublisher eventPublisher;
 
     @Override
     @Transactional
@@ -65,7 +66,11 @@ private User createUser(KakaoOAuth2UserInfo userInfo) {
                 .gym(null)
                 .build();
 
-        return userRepository.save(user);
+        User savedUser = userRepository.save(user);
+
+        eventPublisher.publishEvent(new SignUpEvent(this, nickname, savedUser.getId()));
+
+        return savedUser;
     }
 
     private String generateUniqueNickname() {

src/main/java/com/climbup/climbup/common/exception/GlobalExceptionHandler.java

@@ -4,7 +4,9 @@
 import com.climbup.climbup.auth.exception.InvalidTokenException;
 import com.climbup.climbup.auth.exception.TokenExpiredException;
 import com.climbup.climbup.common.dto.ErrorResponse;
+import com.climbup.climbup.global.discord.DiscordService;
 import jakarta.servlet.http.HttpServletRequest;
+import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.http.ResponseEntity;
 import org.springframework.http.converter.HttpMessageNotReadableException;
@@ -18,13 +20,18 @@
 import org.springframework.web.method.annotation.MethodArgumentTypeMismatchException;
 import org.springframework.web.servlet.NoHandlerFoundException;
 
+import java.io.PrintWriter;
+import java.io.StringWriter;
 import java.util.HashMap;
 import java.util.Map;
 
 @Slf4j
 @RestControllerAdvice
+@RequiredArgsConstructor
 public class GlobalExceptionHandler {
 
+    private final DiscordService discordService;
+
     @ExceptionHandler(BusinessException.class)
     public ResponseEntity<ErrorResponse> handleBusinessException(
             BusinessException ex, HttpServletRequest request) {
@@ -139,6 +146,7 @@ public ResponseEntity<ErrorResponse> handleGenericException(
             Exception ex, HttpServletRequest request) {
 
         log.error("Unexpected exception occurred", ex);
+        sendDiscordErrorNotification(ex, "handleGenericException");
         return ResponseEntity
                 .status(ErrorCode.INTERNAL_SERVER_ERROR.getHttpStatus())
                 .body(ErrorResponse.of(ErrorCode.INTERNAL_SERVER_ERROR, request.getRequestURI()));
@@ -184,4 +192,39 @@ public ResponseEntity<ErrorResponse> handleAuthHeaderMissingException(
                 .status(ex.getHttpStatus())
                 .body(ErrorResponse.of(ex.getErrorCode(), request.getRequestURI(), ex.getMessageArgs()));
     }
+
+    private void sendDiscordErrorNotification(Exception ex, String methodName) {
+        if (discordService == null) {
+            return;
+        }
+
+        try {
+            String stackTrace = getStackTrace(ex);
+            String className = ex.getStackTrace().length > 0 ?
+                    ex.getStackTrace()[0].getClassName() : "Unknown";
+            String actualMethodName = ex.getStackTrace().length > 0 ?
+                    ex.getStackTrace()[0].getMethodName() : methodName;
+
+            discordService.sendErrorNotification(
+                    ex.getMessage() + "\n\n" + stackTrace,
+                    className,
+                    actualMethodName
+            );
+
+        } catch (Exception discordEx) {
+            log.error("Discord 알림 전송 중 오류 발생", discordEx);
+        }
+    }
+
+    private String getStackTrace(Exception ex) {
+        StringWriter sw = new StringWriter();
+        PrintWriter pw = new PrintWriter(sw);
+        ex.printStackTrace(pw);
+
+        String fullStackTrace = sw.toString();
+        if (fullStackTrace.length() > 1500) {
+            return fullStackTrace.substring(0, 1500) + "\n... (truncated)";
+        }
+        return fullStackTrace;
+    }
 }

src/main/java/com/climbup/climbup/global/config/AsyncConfig.java

@@ -0,0 +1,28 @@
+package com.climbup.climbup.global.config;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+import java.util.concurrent.Executor;
+
+@Configuration
+@EnableAsync
+@Slf4j
+public class AsyncConfig {
+
+    @Bean(name = "discordNotificationExecutor")
+    public Executor discordNotificationExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(2);
+        executor.setMaxPoolSize(5);
+        executor.setQueueCapacity(100);
+        executor.setThreadNamePrefix("Discord-Notification-");
+        executor.setRejectedExecutionHandler((r, exec) ->
+                log.warn("Discord 알림 작업이 거부되었습니다. 큐가 가득참."));
+        executor.initialize();
+        return executor;
+    }
+}

src/main/java/com/climbup/climbup/global/discord/DiscordConfig.java

@@ -0,0 +1,23 @@
+package com.climbup.climbup.global.discord;
+
+import lombok.Getter;
+import lombok.Setter;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@ConfigurationProperties(prefix = "discord")
+@Getter
+@Setter
+public class DiscordConfig {
+
+    private Webhook webhook = new Webhook();
+    private boolean enabled = false;
+
+    @Getter
+    @Setter
+    public static class Webhook {
+        private String errorUrl;
+        private String notificationUrl;
+    }
+}