Merge pull request #218 from prgrms-web-devcourse-final-project/fix/SSE-connection

fix: SSE connection 문제 해결

Author: premierbell

src/main/java/devut/buzzerbidder/domain/notification/service/SseEmitterPool.java

@@ -38,7 +38,11 @@ public SseEmitter subscribe(String channel) {
         emitter.onError((e) -> removeEmitter(channel, emitter));
 
         try {
-            emitter.send(SseEmitter.event().comment("connected"));
+            emitter.send(
+                SseEmitter.event()
+                    .name("connect")
+                    .data("connected")
+            );
         } catch (IOException e) {
             removeEmitter(channel, emitter);
         }
@@ -48,29 +52,18 @@ public SseEmitter subscribe(String channel) {
 
     @Scheduled(fixedRate = HEARTBEAT_INTERVAL)
     public void heartbeat() {
-        List<SseEmitter> deadEmitters = new ArrayList<>();
-
-        channelEmitters.values().forEach(emitters ->
-            emitters.forEach(emitter -> {
+        channelEmitters.forEach((channel, emitters) -> {
+            for (SseEmitter emitter : emitters) {
                 try {
-                    emitter.send(SseEmitter.event().comment("ping"));
+                    emitter.send(
+                        SseEmitter.event()
+                            .name("heartbeat")
+                            .data("ping")
+                    );
                 } catch (Exception e) {
-                    deadEmitters.add(emitter);
+                    emitter.complete();
+                    removeEmitter(channel, emitter);
                 }
-            })
-        );
-
-        deadEmitters.forEach(emitter -> {
-            emitter.complete();
-            removeEmitterByEmitter(emitter);
-        });
-    }
-
-    private void removeEmitterByEmitter(SseEmitter emitter) {
-        channelEmitters.forEach((channel, emitters) -> {
-            emitters.remove(emitter);
-            if (emitters.isEmpty()) {
-                channelEmitters.remove(channel);
             }
         });
     }

src/main/java/devut/buzzerbidder/global/security/CustomAuthenticationFilter.java

@@ -73,14 +73,13 @@ private void authenticate(HttpServletRequest request, HttpServletResponse respon
             return;
         }
 
-        // 허용된 API 경로들 (회원가입, 로그인, 토큰 재발급, 이메일 인증, SSE 구독)
+        // 허용된 API 경로들 (회원가입, 로그인, 토큰 재발급, 이메일 인증)
         if(requestURI.equals("/api/v1/users/signup") ||
             requestURI.equals("/api/v1/users/signin") ||
             requestURI.equals("/api/v1/users/refresh") ||
             requestURI.equals("/api/v1/users/oauth/signin") ||
             requestURI.equals("/api/v1/users/email/verification") ||
-            requestURI.equals("/api/v1/users/email/verification/verify") ||
-            requestURI.equals("/api/v1/notifications/subscribe")) {
+            requestURI.equals("/api/v1/users/email/verification/verify")) {
             filterChain.doFilter(request, response);
             return;
         }