[BE] refactor: kurento, turn 세팅 및 media, signaling server 구현 완료

config/signaling-server-local.yml

@@ -22,4 +22,8 @@ cloud:
 
 spring:
   kafka:
-    bootstrap-servers: '{cipher}276ada73fdb90a68125e2dcce993b77384c8c80d672a78b26eefda56bf60f808f77d486f86d9f1de94e6cb342711bb6211dd8f6cbf98b01e4ece80b938b40acf1cfef75ec74c910f32e68873b06dd3d5'
+    bootstrap-servers: '{cipher}276ada73fdb90a68125e2dcce993b77384c8c80d672a78b26eefda56bf60f808f77d486f86d9f1de94e6cb342711bb6211dd8f6cbf98b01e4ece80b938b40acf1cfef75ec74c910f32e68873b06dd3d5'
+
+service:
+  member:
+    url: '{cipher}ee68f6c31f6db2e21b7e008c670634ed0cbb642a75ae18e6cb87794165e82bd3520c15c0a997eb0e049f7ed5ded02091a5543448fc14de697ea18023c61ec9c4'

config/signaling-server-prod.yml

@@ -26,4 +26,4 @@ spring:
 
 service:
   member:
-    url: '{cipher}cfc51ed26a533a9c2dea91e247fab25cd2b6d7487d51884ef835d030b9b38373a30bf3596005dbaf2bd82921ee1f85f5614e0e3e4ed0c658b38950b544ceb5c5'
+    url: '{cipher}ee68f6c31f6db2e21b7e008c670634ed0cbb642a75ae18e6cb87794165e82bd3520c15c0a997eb0e049f7ed5ded02091a5543448fc14de697ea18023c61ec9c4'

src/backend/apigateway-server/src/main/java/com/asyncgate/apigatewayserver/filter/AuthorizationHeaderFilter.java

@@ -28,7 +28,7 @@ public class AuthorizationHeaderFilter extends AbstractGatewayFilterFactory<Auth
     private final ObjectMapper objectMapper;
 
     private static final List<String> NO_NEED_URLS = List.of(
-        "/sign-up", "/sign-in", "/validation/email", "/validation/authentication-code"
+        "/sign-up", "/sign-in", "/validation/email", "/validation/authentication-code", "/room/profile"
     );
 
     public AuthorizationHeaderFilter(

src/backend/apigateway-server/src/main/resources/application-prod.yml

@@ -91,30 +91,13 @@ spring:
             - RewritePath=/users/(?<segment>.*), /$\{segment}
             - AuthorizationHeaderFilter
 
-        - id: signaling-server
-          uri: lb://SIGNALING-SERVER
-          predicates:
-            - Path=/signalings/**
-          filters:
-            - RemoveRequestHeader=Cookie
-            - RewritePath=/signalings/(?<segment>.*), /$\{segment}
-            - AuthorizationHeaderFilter
-
-        - id: signaling-server
-          uri: ws://SIGNALING-SERVER
-          predicates:
-            - Path=/signalings/**
-          filters:
-            - RemoveRequestHeader=Cookie
-            - RewritePath=/signalings/(?<segment>.*), /$\{segment}
-
-        - id: signaling-server
-          uri: wss://SIGNALING-SERVER
+        - id: user-server
+          uri: lb://USER-SERVER
           predicates:
-            - Path=/signalings/**
+            - Path=/users/room/profile
           filters:
             - RemoveRequestHeader=Cookie
-            - RewritePath=/signalings/(?<segment>.*), /$\{segment}
+            - RewritePath=/users/(?<segment>.*), /$\{segment}
 
         - id: chat-server
           uri: lb://CHAT-SERVER

src/backend/signaling-server/build.gradle

@@ -87,6 +87,10 @@ dependencies {
 	// aop
 	implementation 'org.springframework.boot:spring-boot-starter-aop'
 
+	// webflux
+	implementation 'org.springframework.boot:spring-boot-starter-webflux'
+	implementation 'com.fasterxml.jackson.datatype:jackson-datatype-jsr310'
+
 }
 
 dependencyManagement {

src/backend/signaling-server/http/SignalingControllerHttpRequest.http

@@ -42,6 +42,9 @@ Content-Type: application/json
   "authentication_code": "{{user.API_1_2_AUTHENTICATION_CODE.authentication_code}}"
 }
 
+### 1.3 유저 룸 정보 조회
+GET {{host_url}}/room/profile?userId=595da97f-64b2-4851-8fe0-e99ec3af6015
+
 ### 2,0 채널 생성
 // @no-log
 POST {{host_url}}/room/create
@@ -58,6 +61,12 @@ POST {{host_url}}/room/{{signaling.API_2_0_CREATE_CHAT_ROOM.chat_room_id}}/join
 Content-Type: application/json
 Authorization: Bearer {{access_token}}
 
+{
+  "audio_enabled": true,
+  "media_enabled": true,
+  "data_enabled": true
+}
+
 
 ### 2.2 채널 참여 중인 유저 조회
 // @no-log

src/backend/signaling-server/src/main/java/com/asyncgate/signaling_server/config/WebRTCConfig.java → src/backend/signaling-server/src/main/java/com/asyncgate/signaling_server/config/ICEServerConfig.java

@@ -6,7 +6,7 @@
 
 @Configuration
 @Getter
-public class WebRTCConfig {
+public class ICEServerConfig {
 
     @Value("${stun.server.urls}")
     private String stunServer;
@@ -25,8 +25,7 @@ public String getTurnUrl() {
         return String.format("turn:%s", turnServer);
     }
 
-    // TURN 서버 인증 정보 반환
-    public String getTurnCredential() {
-        return turnPassword;
+    public String getStunUrl() {
+        return String.format("stun:%s", stunServer);
     }
 }

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

@@ -1,37 +1,68 @@
 package com.asyncgate.signaling_server.config;
 
 import com.asyncgate.signaling_server.infrastructure.client.MemberServiceClient;
+import com.asyncgate.signaling_server.infrastructure.utility.WebClientUtil;
+import com.asyncgate.signaling_server.security.filter.FilterChannelInterceptor;
+import com.asyncgate.signaling_server.security.filter.WebSocketHandshakeInterceptor;
+import com.asyncgate.signaling_server.security.utility.JsonWebTokenUtil;
 import com.asyncgate.signaling_server.signaling.KurentoManager;
 import com.asyncgate.signaling_server.support.handler.KurentoHandler;
 import org.kurento.client.KurentoClient;
 import org.springframework.beans.factory.annotation.Value;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.*;
+import org.springframework.messaging.simp.SimpMessagingTemplate;
 import org.springframework.web.socket.config.annotation.EnableWebSocket;
 import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
 import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;
 import org.springframework.web.socket.server.standard.ServletServerContainerFactoryBean;
 
+import org.kurento.client.KurentoClient;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.messaging.simp.config.ChannelRegistration;
+import org.springframework.messaging.simp.config.MessageBrokerRegistry;
+import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
+import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
+import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
+
 @Configuration
-@EnableWebSocket
-public class KurentoConfig implements WebSocketConfigurer {
+@EnableWebSocketMessageBroker
+public class KurentoConfig implements WebSocketMessageBrokerConfigurer {
 
     @Value("${kms.url}")
     private String kmsUrl;
 
+    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;
+    }
+
     @Bean
     public KurentoClient kurentoClient() {
         return KurentoClient.create(kmsUrl);
     }
 
     @Bean
     public MemberServiceClient memberServiceClient() {
-        return new MemberServiceClient();
+        return new MemberServiceClient(webClientUtil);
     }
 
     @Bean
     public KurentoManager kurentoManager(KurentoClient kurentoClient, MemberServiceClient memberServiceClient) {
-        return new KurentoManager(kurentoClient, memberServiceClient);
+        return new KurentoManager(kurentoClient, memberServiceClient, messagingTemplate);
     }
 
     @Bean
@@ -40,9 +71,23 @@ public KurentoHandler kurentoHandler(KurentoManager kurentoManager) {
     }
 
     @Override
-    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
-        System.out.println("🚀 WebSocketHandlerRegistry 등록");
-        registry.addHandler(kurentoHandler(kurentoManager(kurentoClient(), memberServiceClient())), "/signal").setAllowedOrigins("*");
+    public void registerStompEndpoints(StompEndpointRegistry registry) {
+        registry.addEndpoint("/signal")
+                .setAllowedOriginPatterns("*")
+                .addInterceptors(webSocketHandshakeInterceptor);
+    }
+
+    /*
+    @Override
+    public void configureMessageBroker(MessageBrokerRegistry registry) {
+        registry.setApplicationDestinationPrefixes("/kafka");
+        registry.enableSimpleBroker("/topic/");
+    }
+     */
+
+    @Override
+    public void configureClientInboundChannel(ChannelRegistration registration) {
+        registration.interceptors(filterChannelInterceptor);
     }
 
     @Bean

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

@@ -0,0 +1,13 @@
+package com.asyncgate.signaling_server.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.reactive.function.client.WebClient;
+
+@Configuration
+public class WebClientConfig {
+    @Bean
+    public WebClient.Builder webClientBuilder() {
+        return WebClient.builder();
+    }
+}

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

@@ -1,7 +1,9 @@
 package com.asyncgate.signaling_server.controller;
 
+import com.asyncgate.signaling_server.dto.request.JoinRoomRequest;
 import com.asyncgate.signaling_server.dto.response.GetUsersInChannelResponse;
 import com.asyncgate.signaling_server.security.annotation.MemberID;
+import com.asyncgate.signaling_server.usecase.ExitRoomUseCase;
 import com.asyncgate.signaling_server.usecase.GetUsersInRoomUseCase;
 import com.asyncgate.signaling_server.usecase.JoinRoomUseCase;
 import lombok.RequiredArgsConstructor;
@@ -14,26 +16,24 @@
 public class ChatRoomCommandController {
 
     private final JoinRoomUseCase joinRoomUseCase;
-    private final GetUsersInRoomUseCase getUsersInRoomUseCase;
+    private final ExitRoomUseCase exitRoomUseCase;
+    // private final GetUsersInRoomUseCase getUsersInRoomUseCase;
 
     /**
      * 채널 참여
      */
     @PostMapping("/{room_id}/join")
-    public SuccessResponse<String> joinRoom(@PathVariable("room_id") final String roomId, @MemberID final String memberId) {
-        System.out.println("member id");
-        System.out.println(memberId);
-        joinRoomUseCase.execute(roomId, memberId);
-        return SuccessResponse.ok("room: " + roomId + "에 user: " + memberId + "가 참여하였습니다.");
+    public SuccessResponse<String> joinRoom(@PathVariable("room_id") final String roomId, @MemberID final String memberId, @RequestBody JoinRoomRequest request) {
+        joinRoomUseCase.execute(roomId, memberId, request);
+        return SuccessResponse.ok("room: " + roomId + "에 참여하였습니다.");
     }
 
-    /**
-     * 채널에 참여 중인 유저 조회
-     */
+    /*
     @GetMapping("/{room_id}/users")
     public SuccessResponse<GetUsersInChannelResponse> getUsersInRoom(@PathVariable("room_id") String roomId) {
         return SuccessResponse.ok(getUsersInRoomUseCase.execute(roomId));
     }
+    */
 
     /**
      *
@@ -43,4 +43,13 @@ public SuccessResponse<GetUsersInChannelResponse> getUsersInRoom(@PathVariable("
     public SuccessResponse<String> deleteRoom(@PathVariable("roomId") String roomId) {
         return SuccessResponse.ok("room: " + roomId + "가 삭제되었습니다.");
     }
+
+    /**
+     * room 나가기 method
+     */
+    @DeleteMapping("/{roomId}/leave")
+    public SuccessResponse<String> leaveRoom(@PathVariable("roomId") String roomId, @MemberID final String memberId) {
+        exitRoomUseCase.execute(roomId, memberId);
+        return SuccessResponse.ok("room: " + roomId + "를 나갔습니다.");
+    }
 }

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

@@ -0,0 +1,26 @@
+package com.asyncgate.signaling_server.controller;
+
+import com.asyncgate.signaling_server.dto.response.GetICEUrlResponse;
+import com.asyncgate.signaling_server.support.response.SuccessResponse;
+import com.asyncgate.signaling_server.usecase.GetICEUrlUseCase;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/ice")
+@RequiredArgsConstructor
+public class ChatRoomQueryController {
+
+    private final GetICEUrlUseCase getICEUrlUseCase;
+
+    /**
+     * ICE 서버 URL 조회 (TURN/STURN)
+     */
+    @GetMapping
+    public SuccessResponse<GetICEUrlResponse> getICEServerUrl(@RequestParam("type") String type) {
+        return SuccessResponse.ok(getICEUrlUseCase.execute(type));
+    }
+}