YEL-113 [feat] 500에러 슬랙 알람 추가

YEL-113 [feat] 500에러 슬랙 알람 추가

Author: Lee Euije

build.gradle

@@ -57,7 +57,7 @@ dependencies {
     // Swagger
     implementation 'org.springdoc:springdoc-openapi-ui:1.5.4'
 
-    //
+    // p6spy
     implementation 'com.github.gavlyukovskiy:p6spy-spring-boot-starter:1.5.7'
 
     // Http
@@ -81,6 +81,8 @@ dependencies {
     // rabbitmq
     implementation 'org.springframework.amqp:spring-rabbit:2.3.12'
 
+    // slack-webhook
+    implementation "net.gpedro.integrations.slack:slack-webhook:1.4.0"
 }
 
 tasks.named('test') {

src/main/java/com/yello/server/domain/purchase/controller/PurchaseController.java

@@ -48,11 +48,10 @@ public BaseResponse<AppleVerifyReceiptResponse> verifyReceipt(
             content = @Content(mediaType = "application/json", schema = @Schema(implementation = UserSubscribeNeededResponse.class))
         )
     })
-    @GetMapping("/subscribe_need")
+    @GetMapping("/subscribeNeed")
     public BaseResponse<UserSubscribeNeededResponse> getUserSubscribeNeeded(
         @AccessTokenUser User user) {
         val data = purchaseService.getUserSubscribe(user, LocalDateTime.now());
         return BaseResponse.success(USER_SUBSCRIBE_NEEDED_READ_SUCCESS, data);
     }
-
 }

src/main/java/com/yello/server/global/common/util/SlackUtil.java

@@ -0,0 +1,19 @@
+package com.yello.server.global.common.util;
+
+import net.gpedro.integrations.slack.SlackApi;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class SlackUtil {
+
+    @Value("${slack.token}")
+    String slackToken;
+
+    @Bean
+    SlackApi slackApi() {
+        System.out.println("slackToken = " + slackToken);
+        return new SlackApi("https://hooks.slack.com/services/" + slackToken);
+    }
+}

src/main/java/com/yello/server/global/configuration/ThreadPoolConfiguration.java

@@ -0,0 +1,19 @@
+package com.yello.server.global.configuration;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.task.TaskExecutor;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+@Configuration
+public class ThreadPoolConfiguration {
+
+    @Bean
+    public TaskExecutor threadPoolTaskExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(5);
+        executor.setMaxPoolSize(5);
+        executor.initialize();
+        return executor;
+    }
+}

src/main/java/com/yello/server/global/exception/ControllerExceptionAdvice.java

@@ -9,6 +9,7 @@
 import static org.springframework.http.HttpStatus.NOT_FOUND;
 import static org.springframework.http.HttpStatus.UNAUTHORIZED;
 
+import com.yello.server.domain.authorization.JwtTokenProvider;
 import com.yello.server.domain.authorization.exception.AuthBadRequestException;
 import com.yello.server.domain.authorization.exception.CustomAuthenticationException;
 import com.yello.server.domain.authorization.exception.ExpiredTokenException;
@@ -21,15 +22,32 @@
 import com.yello.server.domain.friend.exception.FriendNotFoundException;
 import com.yello.server.domain.group.exception.GroupNotFoundException;
 import com.yello.server.domain.question.exception.QuestionNotFoundException;
+import com.yello.server.domain.user.entity.User;
 import com.yello.server.domain.user.exception.UserBadRequestException;
 import com.yello.server.domain.user.exception.UserConflictException;
 import com.yello.server.domain.user.exception.UserException;
 import com.yello.server.domain.user.exception.UserNotFoundException;
+import com.yello.server.domain.user.repository.UserRepository;
 import com.yello.server.domain.vote.exception.VoteForbiddenException;
 import com.yello.server.domain.vote.exception.VoteNotFoundException;
 import com.yello.server.global.common.dto.BaseResponse;
 import com.yello.server.infrastructure.redis.exception.RedisException;
 import com.yello.server.infrastructure.redis.exception.RedisNotFoundException;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.List;
+import java.util.Optional;
+import javax.servlet.http.HttpServletRequest;
+import lombok.RequiredArgsConstructor;
+import net.gpedro.integrations.slack.SlackApi;
+import net.gpedro.integrations.slack.SlackAttachment;
+import net.gpedro.integrations.slack.SlackField;
+import net.gpedro.integrations.slack.SlackMessage;
+import org.springframework.core.task.TaskExecutor;
+import org.springframework.http.HttpHeaders;
 import org.springframework.http.ResponseEntity;
 import org.springframework.http.converter.HttpMessageConversionException;
 import org.springframework.http.converter.HttpMessageNotReadableException;
@@ -40,8 +58,59 @@
 import org.springframework.web.bind.annotation.RestControllerAdvice;
 
 @RestControllerAdvice
+@RequiredArgsConstructor
 public class ControllerExceptionAdvice {
 
+    private final TaskExecutor taskExecutor;
+    private final SlackApi slackApi;
+    private final UserRepository userRepository;
+    private final JwtTokenProvider jwtTokenProvider;
+
+    @ExceptionHandler(Exception.class)
+    void handleException(HttpServletRequest request, Exception exception) throws Exception {
+        SlackAttachment slackAttachment = new SlackAttachment();
+
+        slackAttachment.setFallback("Error");
+        slackAttachment.setColor("danger");
+        slackAttachment.setTitle("긴급 환자가 이송되었습니다");
+        slackAttachment.setTitleLink(request.getContextPath());
+        slackAttachment.setText(Arrays.toString(exception.getStackTrace()));
+        slackAttachment.setColor("danger");
+
+        List<SlackField> slackFieldList = new ArrayList<>();
+        slackFieldList.add(new SlackField().setTitle("Request URL").setValue(request.getRequestURL().toString()));
+        slackFieldList.add(new SlackField().setTitle("Request Method").setValue(request.getMethod()));
+        slackFieldList.add(new SlackField().setTitle("Request Time").setValue(
+            DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss").format(LocalDateTime.now())));
+        slackFieldList.add(new SlackField().setTitle("Request IP").setValue(request.getRemoteAddr()));
+        slackFieldList.add(
+            new SlackField().setTitle("Request User-Agent").setValue(request.getHeader(HttpHeaders.USER_AGENT)));
+        slackFieldList.add(
+            new SlackField().setTitle("인증/인가 정보 - Authorization")
+                .setValue(request.getHeader(HttpHeaders.AUTHORIZATION)));
+
+        final String token = request.getHeader(HttpHeaders.AUTHORIZATION).substring("Bearer ".length());
+        final Long userId = jwtTokenProvider.getUserId(token);
+        final Optional<User> user = userRepository.findById(userId);
+        String userInfo = "";
+        userInfo = user.map(value -> "userId : " + userId
+            + "\nyelloId : " + value.getYelloId()
+            + "\ndeviceToken : " + value.getDeviceToken()).orElseGet(() -> "userId : " + userId);
+        slackFieldList.add(
+            new SlackField().setTitle("인증/인가 정보 - 유저").setValue(userInfo));
+
+        slackAttachment.setFields(slackFieldList);
+
+        SlackMessage slackMessage = new SlackMessage();
+        slackMessage.setAttachments(Collections.singletonList(slackAttachment));
+        slackMessage.setText("긴급 환자가 이송되었습니다");
+        slackMessage.setUsername("옐로 소방서");
+
+        Runnable runnable = () -> slackApi.call(slackMessage);
+        taskExecutor.execute(runnable);
+        throw exception;
+    }
+
     /**
      * 400 BAD REQUEST
      */