[DDING-000] SSE 비동기 전송 시 Spring Security AccessDeniedException 발생 문제 해결 (#337)

Author: KoSeonJe

src/main/java/ddingdong/ddingdongBE/common/config/SecurityConfig.java

@@ -7,6 +7,7 @@
 import ddingdong.ddingdongBE.common.filter.JwtAuthenticationFilter;
 import ddingdong.ddingdongBE.common.handler.CustomAccessDeniedHandler;
 import ddingdong.ddingdongBE.common.handler.RestAuthenticationEntryPoint;
+import jakarta.servlet.DispatcherType;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.security.config.annotation.web.builders.HttpSecurity;
@@ -32,6 +33,7 @@ public SecurityFilterChain filterChain(HttpSecurity http, JwtAuthService authSer
             throws Exception {
         http
                 .authorizeHttpRequests(auth -> auth
+                        .dispatcherTypeMatchers(DispatcherType.ASYNC).permitAll()
                         .requestMatchers(API_PREFIX + "/auth/**",
                                 API_PREFIX + "/events/**")
                         .permitAll()

src/main/java/ddingdong/ddingdongBE/domain/feed/service/FacadeClubFeedServiceImpl.java

@@ -19,10 +19,12 @@
 import java.time.LocalDateTime;
 import java.util.List;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.data.domain.Slice;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+@Slf4j
 @Service
 @RequiredArgsConstructor
 @Transactional(readOnly = true)
@@ -88,6 +90,7 @@ public MyFeedPageQuery getMyFeedPage(User user, int size, Long currentCursorId)
     private void checkVodProcessingJobAndNotify(Feed feed) {
         VodProcessingJob vodProcessingJob = vodProcessingJobService.findByVideoFeedId(feed.getId());
         if (vodProcessingJob != null && vodProcessingJob.isPossibleNotify()) {
+            log.info("피드 생성이 뒤늦게 완료되어 알람 전송 {} : {}", feed.getClub().getName(), feed.getId());
             SseEvent<SseVodProcessingNotificationDto> sseEvent = SseEvent.of(
                     "vod-processing",
                     new SseVodProcessingNotificationDto(

src/main/java/ddingdong/ddingdongBE/domain/vodprocessing/service/FacadeVodProcessingJobServiceImpl.java

@@ -14,11 +14,13 @@
 import java.time.LocalDateTime;
 import java.util.Optional;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 @Service
 @Transactional(readOnly = true)
+@Slf4j
 @RequiredArgsConstructor
 public class FacadeVodProcessingJobServiceImpl implements FacadeVodProcessingJobService {
 
@@ -40,6 +42,7 @@ public Long create(CreatePendingVodProcessingJobCommand command) {
     @Override
     @Transactional
     public void updateVodProcessingJobStatus(UpdateVodProcessingJobStatusCommand command) {
+        log.info("vod상태 업데이트 메서드 호출 {} : {}", command.convertJobId(), command.status());
         VodProcessingJob vodProcessingJob = vodProcessingJobService.getByConvertJobId(command.convertJobId());
         vodProcessingJob.updateConvertJobStatus(command.status());
         checkVodProcessingJobStatus(vodProcessingJob);
@@ -54,10 +57,12 @@ private void checkVodProcessingJobStatus(VodProcessingJob vodProcessingJob) {
     private void checkExistingFeedAndNotify(VodProcessingJob vodProcessingJob) {
         Long entityId = vodProcessingJob.getFileMetaData().getEntityId();
         if(entityId == null) {
+            log.info("현재 피드 업로드가 완료되지 않아 알림 보내지 않고 종료");
             return;
         }
         Optional<Feed> optionalFeed = feedService.findById(entityId);
         if (optionalFeed.isPresent()) {
+            log.info("피드 업로드가 완료된 상태로, 알람 전송");
             SseEvent<SseVodProcessingNotificationDto> sseEvent = SseEvent.of(
                     "vod-processing",
                     new SseVodProcessingNotificationDto(

src/main/java/ddingdong/ddingdongBE/sse/service/SseConnectionService.java

@@ -61,7 +61,7 @@ public void sendVodProcessingNotification(VodProcessingJob vodProcessingJob, Sse
                 sseEmitter.send(SseEmitter.event()
                         .name("sse")
                         .data(data));
-                log.debug("SSE Event sent to user {}: {}", sseId, "sse");
+                log.info("SSE Event 사용자에게 전송완료 userid:{}: {}", sseId, "sse");
             } catch (IOException e) {
                 log.error("Error sending SSE event to user: {}", sseId, e);
                 sseEmitter.complete();