Merge pull request #2 from urdego/Feature/#1

Feature/#1

build.gradle

@@ -29,8 +29,11 @@ dependencyManagement {
 dependencies {
     //Spring
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
+    testImplementation 'org.springframework.security:spring-security-test'
     testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
 
+    //WebSocket
+    implementation 'org.springframework.boot:spring-boot-starter-websocket'
 
     // spring cloud
     implementation 'org.springframework.cloud:spring-cloud-starter-gateway'

src/main/java/io/urdego/urdego_gateway_service/config/GatewayConfig.java

@@ -0,0 +1,25 @@
+package io.urdego.urdego_gateway_service.config;
+
+import org.springframework.cloud.gateway.route.RouteLocator;
+import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class GatewayConfig {
+
+    @Bean
+    public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
+        return builder.routes()
+                // 알림 서비스로 라우팅
+                .route("notification-websocket-route", r -> r.path("/ws/notifications/**")
+                        .uri("ws://notification-service:8081")) // 알림 서비스 URI
+
+                // 게임 서비스로 라우팅
+                .route("game-websocket-route", r -> r.path("/ws/games/**")
+                        .uri("ws://game-service:8082")) // 게임 서비스 URI
+
+                // 기타 WebSocket 요청 처리 (필요하면 추가)
+                .build();
+    }
+}

src/main/java/io/urdego/urdego_gateway_service/config/WebSocketConfig.java

@@ -0,0 +1,24 @@
+package io.urdego.urdego_gateway_service.config;
+
+import org.springframework.context.annotation.Configuration;
+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
+@EnableWebSocketMessageBroker
+public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
+
+    @Override
+    public void configureMessageBroker(MessageBrokerRegistry registry) {
+        registry.enableSimpleBroker("/urdego/sub");
+        registry.setApplicationDestinationPrefixes("/urdego/pub");
+    }
+
+    @Override
+    public void registerStompEndpoints(StompEndpointRegistry registry) {
+        registry.addEndpoint("/urdego/connect")
+                .setAllowedOrigins("*");
+    }
+}

src/main/java/io/urdego/urdego_gateway_service/controller/WebSocketController.java

@@ -0,0 +1,58 @@
+package io.urdego.urdego_gateway_service.controller;
+
+import io.urdego.urdego_gateway_service.dto.MessageInfo;
+import io.urdego.urdego_gateway_service.feign.game.dto.GameServiceFeignClient;
+import io.urdego.urdego_gateway_service.feign.notification.NotificationServiceFeignClient;
+import lombok.RequiredArgsConstructor;
+import org.springframework.messaging.handler.annotation.DestinationVariable;
+import org.springframework.messaging.handler.annotation.MessageMapping;
+import org.springframework.messaging.handler.annotation.SendTo;
+import org.springframework.messaging.simp.SimpMessagingTemplate;
+import org.springframework.stereotype.Controller;
+
+@Controller
+@RequiredArgsConstructor
+public class WebSocketController {
+
+    private final NotificationServiceFeignClient notificationServiceFeignClient;
+    private final GameServiceFeignClient gameServiceFeignClient;
+    private final SimpMessagingTemplate messagingTemplate;
+
+    @MessageMapping("/message")
+    @SendTo("/urdego/sub")
+    public void handleMessage(MessageInfo message) {
+        switch (message.type()) {
+            case "알림 전송 요청":
+                // 알림 서비스로 메시지 전달 각각 UserId
+                notificationServiceFeignClient.sendNotification(message.payload());
+                break;
+
+            case "안읽은 알림 불러오기":
+                // 알림 서비스로 메시지 전달
+                notificationServiceFeignClient.sendNotification(message.payload());
+                break;
+
+            case "JOIN_ROOM":
+                // 방에 넣어버리는 메서드
+                gameServiceFeignClient.processGameEvent(message.payload());
+                break;
+            case "START_GAME":
+                // 게임 생성 및 시작 메서드
+
+                break;
+//            case "CHAT":
+//                // 메시지를 직접 브로드캐스트
+                 //  notificationServiceFeignClient.sendNotification(message.payload());
+//                messagingTemplate.convertAndSend("/urdego/sub/" + message.payload().userId(), message);
+//                break;
+            default:
+                throw new IllegalArgumentException("Unsupported message type: " + message.type());
+        }
+    }
+
+    @MessageMapping("/message")
+    @SendTo("/urdego/sub/{userId}")
+    public void handleMessage2(MessageInfo message, @DestinationVariable String userId) {
+
+    }
+}

src/main/java/io/urdego/urdego_gateway_service/dto/MessageInfo.java

@@ -0,0 +1,8 @@
+package io.urdego.urdego_gateway_service.dto;
+
+public record MessageInfo<T>(
+        String type,
+        T payload,
+        String userId
+) {
+}

src/main/java/io/urdego/urdego_gateway_service/feign/game/dto/GameServiceFeignClient.java

@@ -0,0 +1,4 @@
+package io.urdego.urdego_gateway_service.feign.game.dto;
+
+public interface GameServiceFeignClient {
+}

src/main/java/io/urdego/urdego_gateway_service/feign/notification/NotificationServiceFeignClient.java

@@ -0,0 +1,11 @@
+package io.urdego.urdego_gateway_service.feign.notification;
+
+public interface NotificationServiceFeignClient {
+    //Notification의 모든 API
+
+    // 알림 전송
+
+    // 알림 확인 시 게임방으로 이동
+
+
+}