Merge pull request #71 from sgdevcamp2025/be/feat/30-media

[BE] feat: media 서버 구현

Author: bianbbc87

.github/actions/ecr-push/action.yml

@@ -243,6 +243,23 @@ runs:
               echo "    restart: unless-stopped" >> docker-compose.yml
             fi
 
+            if [ "${{ inputs.container_name }}" == "signaling-server" ]; then
+              echo "  mongodb:" >> docker-compose.yml
+              echo "    image: mongo:latest" >> docker-compose.yml
+              echo "    container_name: mongodb" >> docker-compose.yml
+              echo "    ports:" >> docker-compose.yml
+              echo "      - \"27017:27017\"" >> docker-compose.yml
+              echo "    restart: unless-stopped" >> docker-compose.yml
+              echo "    volumes:" >> docker-compose.yml
+              echo "      - mongo_data:/data/db" >> docker-compose.yml
+              echo "  redis:" >> docker-compose.yml
+              echo "    image: redis:latest" >> docker-compose.yml
+              echo "    container_name: redis" >> docker-compose.yml
+              echo "    ports:" >> docker-compose.yml
+              echo "      - \"6379:6379\"" >> docker-compose.yml
+              echo "    restart: unless-stopped" >> docker-compose.yml
+            fi
+
             echo "volumes:" >> docker-compose.yml
             echo "  mongo_data:" >> docker-compose.yml
 

config/signaling_server.yml config/signaling-server.ymlconfig/signaling_server.yml renamed to config/signaling-server.yml

@@ -2,7 +2,7 @@ eureka:
   instance:
     prefer-ip-address: true
     hostname: signaling-server
-    ip-address: '{cipher}52869f07a616cbb703d228900597bd2d08f7138667e0e839737cf0cad27e2913'
+    ip-address: '{cipher}814f08466ab03c2cafb04104dc5c07690891d44daae88cb9caf1605849c201d2'
   client:
     service-url:
       defaultZone: '{cipher}c10802fde605ba30df72871d3dfc9c765a71c43b3f6326fd0f9169b52210c582fe3aa81f882e05c08ffcfdb402f7949a'

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

@@ -82,13 +82,32 @@ spring:
             - RemoveRequestHeader=Cookie
             - 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: lb://SIGNALING-SERVER
+          predicates:
+            - Path=/signalings/signal
+          filters:
+            - RemoveRequestHeader=Cookie
+            - RewritePath=/signalings/(?<segment>.*), /$\{segment}   
+
       default-filters:
         - DedupeResponseHeader=Access-Control-Allow-Origin Access-Control-Allow-Credentials
       globalcors:
         cors-configurations:
           '[/**]':
             allowed-origins:
               - 'http://localhost:5173'
+              - 'https://localhost:5173'
             allow-credentials: true
             allowed-headers: '*'
             allowed-methods:

src/backend/config-server/src/main/java/com/asyncgate/configserver/config/ConfigPrinter.java

@@ -24,7 +24,7 @@ public ApplicationRunner printConfigs() {
             // config 폴더에 있는 모든 서비스 리스트
             String[] services = {
                     "apigateway-server", "chat-server", "guild-server",
-                    "notification-server", "signaling_server", "state-server", "user-server"
+                    "notification-server", "signaling-server", "state-server", "user-server"
             };
 
             for (String service : services) {

src/backend/signaling-server/build.gradle

@@ -29,8 +29,10 @@ ext {
 
 dependencies {
 	implementation 'org.springframework.boot:spring-boot-starter-web'
+	// implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
 	implementation 'org.springframework.boot:spring-boot-starter-actuator'
 
+	implementation 'org.springframework.cloud:spring-cloud-starter'
 	implementation 'org.springframework.cloud:spring-cloud-starter-config'
 	implementation 'org.springframework.cloud:spring-cloud-starter-bootstrap'
 
@@ -39,11 +41,52 @@ dependencies {
 
 	compileOnly 'org.projectlombok:lombok'
 	annotationProcessor 'org.projectlombok:lombok'
+
 	testImplementation 'org.springframework.boot:spring-boot-starter-test'
 	testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
 
+	// Security
+	implementation 'org.springframework.boot:spring-boot-starter-security'
+	implementation 'org.springframework.security:spring-security-oauth2-client'
+
+	// JWT
+	implementation 'io.jsonwebtoken:jjwt-api:0.11.5'
+	implementation 'jakarta.xml.bind:jakarta.xml.bind-api:4.0.0'
+	runtimeOnly 'io.jsonwebtoken:jjwt-impl:0.11.5'
+	runtimeOnly 'io.jsonwebtoken:jjwt-jackson:0.11.5'
+
+	// Validation
+	implementation 'org.springframework.boot:spring-boot-starter-validation'
+
 	// AWS
 	implementation 'org.springframework.cloud:spring-cloud-starter-aws:2.2.6.RELEASE'
+
+	// mysql
+	// runtimeOnly 'com.mysql:mysql-connector-j'
+
+	// mongo db
+	implementation 'org.springframework.boot:spring-boot-starter-data-mongodb'
+
+	// WebSocket
+	implementation 'org.springframework.boot:spring-boot-starter-websocket'
+
+	// sockjs
+	implementation 'org.webjars:sockjs-client:1.5.1'
+	// stomp
+	implementation 'org.webjars:stomp-websocket:2.3.4'
+	// gson
+	implementation 'com.google.code.gson:gson:2.9.0'
+
+	/* Kurento 미디어 서버 관련 2개 */
+	// https://mvnrepository.com/artifact/org.kurento/kurento-client
+	implementation group: 'org.kurento', name: 'kurento-client', version: '6.18.0'
+
+	// thymeleaf
+	implementation 'org.springframework.boot:spring-boot-starter-thymeleaf'
+
+	// aop
+	implementation 'org.springframework.boot:spring-boot-starter-aop'
+
 }
 
 dependencyManagement {

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

@@ -0,0 +1,44 @@
+package com.asyncgate.signaling_server.config;
+
+import lombok.AccessLevel;
+import lombok.NoArgsConstructor;
+import org.springframework.web.cors.CorsConfiguration;
+import org.springframework.web.cors.CorsConfigurationSource;
+import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
+
+import java.util.ArrayList;
+import java.util.Collections;
+
+@NoArgsConstructor(access = AccessLevel.PRIVATE)
+public class CorsConfig {
+
+    public static CorsConfigurationSource corsConfigurationSource() {
+        CorsConfiguration configuration = new CorsConfiguration();
+
+        //리소스를 허용
+        ArrayList<String> allowedOriginPatterns = new ArrayList<>();
+        allowedOriginPatterns.add("*");
+        configuration.setAllowedOrigins(allowedOriginPatterns);
+
+        //허용하는 HTTP METHOD
+        ArrayList<String> allowedHttpMethods = new ArrayList<>();
+        allowedHttpMethods.add("GET");
+        allowedHttpMethods.add("POST");
+        allowedHttpMethods.add("PUT");
+        allowedHttpMethods.add("PATCH");
+        allowedHttpMethods.add("DELETE");
+        allowedHttpMethods.add("OPTIONS");
+        configuration.setAllowedMethods(allowedHttpMethods);
+
+        configuration.setAllowedHeaders(Collections.singletonList("*"));
+//        configuration.setAllowedHeaders(List.of(HttpHeaders.AUTHORIZATION, HttpHeaders.CONTENT_TYPE));
+
+        //인증, 인가를 위한 credentials 를 TRUE로 설정
+        configuration.setAllowCredentials(true);
+
+        UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
+        source.registerCorsConfiguration("/**", configuration);
+
+        return source;
+    }
+}

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

@@ -0,0 +1,48 @@
+package com.asyncgate.signaling_server.config;
+
+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.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;
+
+@Configuration
+@EnableWebSocket
+public class KurentoConfig implements WebSocketConfigurer {
+
+    @Value("${kms.url}")
+    private String kmsUrl;
+
+    @Bean
+    public KurentoClient kurentoClient() {
+        return KurentoClient.create(kmsUrl);
+    }
+
+    @Bean
+    public KurentoManager kurentoManager(KurentoClient kurentoClient) {
+        return new KurentoManager(kurentoClient);
+    }
+
+    @Bean
+    public KurentoHandler kurentoHandler(KurentoManager kurentoManager) {
+        return new KurentoHandler(kurentoManager);
+    }
+
+    @Override
+    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
+        registry.addHandler(kurentoHandler(kurentoManager(kurentoClient())), "/signal").setAllowedOrigins("*");
+    }
+
+    @Bean
+    public ServletServerContainerFactoryBean createWebSocketContainer() {
+        ServletServerContainerFactoryBean container = new ServletServerContainerFactoryBean();
+        container.setMaxTextMessageBufferSize(32768);
+        container.setMaxBinaryMessageBufferSize(32768);
+        return container;
+    }
+}

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

@@ -0,0 +1,32 @@
+package com.asyncgate.signaling_server.config;
+
+import lombok.Getter;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@Getter
+public class WebRTCConfig {
+
+    @Value("${stun.server.urls}")
+    private String stunServer;
+
+    @Value("${turn.server.urls}")
+    private String turnServer;
+
+    @Value("${turn.server.username}")
+    private String turnUsername;
+
+    @Value("${turn.server.credential}")
+    private String turnPassword;
+
+    // TURN 서버 URL 반환
+    public String getTurnUrl() {
+        return String.format("turn:%s", turnServer);
+    }
+
+    // TURN 서버 인증 정보 반환
+    public String getTurnCredential() {
+        return turnPassword;
+    }
+}

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

@@ -0,0 +1,46 @@
+package com.asyncgate.signaling_server.controller;
+
+import com.asyncgate.signaling_server.dto.response.GetUsersInChannelResponse;
+import com.asyncgate.signaling_server.security.annotation.MemberID;
+import com.asyncgate.signaling_server.usecase.GetUsersInRoomUseCase;
+import com.asyncgate.signaling_server.usecase.JoinRoomUseCase;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.*;
+import com.asyncgate.signaling_server.support.response.SuccessResponse;
+
+@RestController
+@RequestMapping("/room")
+@RequiredArgsConstructor
+public class ChatRoomCommandController {
+
+    private final JoinRoomUseCase joinRoomUseCase;
+    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 + "가 참여하였습니다.");
+    }
+
+    /**
+     * 채널에 참여 중인 유저 조회
+     */
+    @GetMapping("/{room_id}/users")
+    public SuccessResponse<GetUsersInChannelResponse> getUsersInRoom(@PathVariable("room_id") String roomId) {
+        return SuccessResponse.ok(getUsersInRoomUseCase.execute(roomId));
+    }
+
+    /**
+     *
+     * kurento room 제거 method
+     */
+    @DeleteMapping("/{roomId}")
+    public SuccessResponse<String> deleteRoom(@PathVariable("roomId") String roomId) {
+        return SuccessResponse.ok("room: " + roomId + "가 삭제되었습니다.");
+    }
+}

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

@@ -0,0 +1,13 @@
+package com.asyncgate.signaling_server.controller;
+
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+public class TestQueryController {
+
+    @GetMapping("/health")
+    public String healthCheck() {
+        return "OK";
+    }
+}