[BE] refactor: filter에서 users 반환 취소 (#98)

Signed-off-by: EunJiJung <bianbbc87@gmail.com>

Author: bianbbc87

src/backend/signaling-server/src/main/java/com/asyncgate/signaling_server/config/KurentoConfig.java

@@ -36,13 +36,17 @@ public class KurentoConfig implements WebSocketMessageBrokerConfigurer {
     private final FilterChannelInterceptor filterChannelInterceptor;
     private final WebSocketHandshakeInterceptor webSocketHandshakeInterceptor;
 
+    @Lazy
+    private final SimpMessagingTemplate messagingTemplate;
     private final WebClientUtil webClientUtil;
 
     public KurentoConfig(FilterChannelInterceptor filterChannelInterceptor,
                          WebSocketHandshakeInterceptor webSocketHandshakeInterceptor,
+                         @Lazy SimpMessagingTemplate messagingTemplate,
                          WebClientUtil webClientUtil) {
         this.filterChannelInterceptor = filterChannelInterceptor;
         this.webSocketHandshakeInterceptor = webSocketHandshakeInterceptor;
+        this.messagingTemplate = messagingTemplate;
         this.webClientUtil = webClientUtil;
     }
 
@@ -56,12 +60,10 @@ public MemberServiceClient memberServiceClient() {
         return new MemberServiceClient(webClientUtil);
     }
 
-    /*
     @Bean
     public KurentoManager kurentoManager(KurentoClient kurentoClient, MemberServiceClient memberServiceClient) {
         return new KurentoManager(kurentoClient, memberServiceClient, messagingTemplate);
     }
-     */
 
     @Bean
     public KurentoHandler kurentoHandler(KurentoManager kurentoManager) {

src/backend/signaling-server/src/main/java/com/asyncgate/signaling_server/security/filter/FilterChannelInterceptor.java

@@ -2,11 +2,9 @@
 
 import com.asyncgate.signaling_server.security.constant.Constants;
 import com.asyncgate.signaling_server.security.utility.JsonWebTokenUtil;
-import com.asyncgate.signaling_server.signaling.KurentoManager;
 import io.jsonwebtoken.Claims;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.context.annotation.Lazy;
 import org.springframework.http.HttpStatus;
 import org.springframework.messaging.Message;
 import org.springframework.messaging.MessageChannel;
@@ -21,17 +19,11 @@ public class FilterChannelInterceptor implements ChannelInterceptor {
 
     private static final Logger log = LoggerFactory.getLogger(FilterChannelInterceptor.class);
     private static final String AUTHORIZATION_HEADER = "Authorization";
-
-    private static final String ROOM_HEADER = "room-id";
     private static final String BEARER_PREFIX = "Bearer ";
     private final JsonWebTokenUtil jsonWebTokenUtil;
 
-    @Lazy  // ✅ Circular Dependency 방지
-    private final KurentoManager kurentoManager;
-
-    public FilterChannelInterceptor(JsonWebTokenUtil jsonWebTokenUtil, KurentoManager kurentoManager) {
+    public FilterChannelInterceptor(JsonWebTokenUtil jsonWebTokenUtil) {
         this.jsonWebTokenUtil = jsonWebTokenUtil;
-        this.kurentoManager = kurentoManager;
     }
 
     private String extractToken(String headerValue) {
@@ -59,18 +51,8 @@ public Message<?> preSend(Message<?> message, MessageChannel channel) {
             if(headerAccessor.getSessionAttributes().get("userId") == null) {
                 throw new ResponseStatusException(HttpStatus.UNAUTHORIZED, "userId is missing");
             }
-
-            // ✅ roomId 가져오기
-            String roomId = headerAccessor.getFirstNativeHeader(ROOM_HEADER);
-            log.info("🔑 [STOMP] Room ID: {}", roomId);
-            if (roomId == null || roomId.isEmpty()) {
-                log.error("🚨 [STOMP] Room ID is missing!");
-                throw new ResponseStatusException(HttpStatus.BAD_REQUEST, "Room ID is missing");
-            }
-
-            log.info("✅ [STOMP] CONNECT 요청 처리 완료 - Room ID: {}", roomId);
-
-            kurentoManager.getUsersInChannel(roomId);
+            
+            log.info("✅ [STOMP] CONNECT 요청 처리 완료");
         }
         return message;
     }

src/backend/signaling-server/src/main/java/com/asyncgate/signaling_server/signaling/KurentoManager.java

@@ -154,6 +154,8 @@ public void processSdpOffer(KurentoOfferRequest message, StompHeaderAccessor acc
 
         System.out.println("sdp 처리 및 sdp answer 생성" + sdpAnswer);
 
+        getUsersInChannel(message.data().roomId());
+
         // 클라이언트에게 SDP Answer 전송
         messagingTemplate.convertAndSend("/topic/answer/" + message.data().roomId() + "/" + userId,
                 new KurentoAnswerResponse("sdpAnswer", sdpAnswer));