[BE] refactor: 리스너 수집 시작용 publish 추가 (#98)

Signed-off-by: EunJiJung <[email protected]>

Author: bianbbc87

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

@@ -44,12 +44,20 @@ public void handleAnswer(KurentoOfferRequest message, StompHeaderAccessor access
     @MessageMapping("/candidate")
     public void handleIceCandidate(KurentoOfferRequest message, StompHeaderAccessor accessor) {
 
-        System.out.println("addCandidate 접근 합니다 !!!!!!!!!!!!!!!!!!!!.");
-
         // Kurento에 ICE Candidate 전달
         kurentoManager.addIceCandidates(message, accessor);
     }
 
+    /**
+     * ICE Candidate 수집 시작
+     */
+    @MessageMapping("/gather/candidate")
+    public void handleIceGetherCandidate(KurentoOfferRequest message, StompHeaderAccessor accessor) {
+
+        // Kurento에 ICE Candidate 전달
+        kurentoManager.GetherICECandidate(message, accessor);
+    }
+
     /**
      * 미디어 토글 (AUDIO, MEDIA, DATA)
      */

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

@@ -78,8 +78,6 @@ public synchronized void getOrCreateEndpoint(String roomId, String userId, JoinR
 
                 startIceCandidateListenerAuto(roomId, userId);
 
-                // ICE Candidate 수집 시작
-                endpoint.gatherCandidates();
 
                 // log.info("users topic을 전송하려고 합니다..");
                 // 자동으로 토픽 전송
@@ -121,6 +119,20 @@ public void sendKurentoOffer(String roomId, String userId) {
         log.info("🎬 Kurento가 클라이언트에게 Offer 전송 완료: {}", sdpOffer);
     }
 
+    /**
+     * ice 수집을 시작하는 메서드
+     */
+    public void GetherICECandidate(KurentoOfferRequest message, StompHeaderAccessor accessor) {
+        log.info("message {}", message);
+        String userId = (String) accessor.getSessionAttributes().get("userId");
+        log.warn("⚠️ user id : {}, roomId: {}", userId, message.data().roomId());
+        WebRtcEndpoint endpoint = getUserEndpoint(message.data().roomId(), userId);
+
+        log.info("Gether ICE Candidate candidate kurento가 수집을 시작합니다 와하하~~" + endpoint);
+        // ICE Candidate 수집 시작
+        endpoint.gatherCandidates();
+    }
+
     /**
      * SDP Offer를 처리하고 Answer를 반환
      */