Feat/taggame

src/main/java/kutaverse/game/taggame/domain/TagGameUser.java

@@ -0,0 +1,35 @@
+package kutaverse.game.taggame.domain;
+
+import kutaverse.game.map.domain.Status;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.relational.core.mapping.Table;
+
+@Getter
+@NoArgsConstructor
+public class TagGameUser {
+
+    private String userId;
+
+    private Double positionX;
+
+    private Double positionY;
+
+    private Double positionZ;
+
+    private Double rotationPitch;
+
+    private Double rotationYaw;
+
+    private Double rotationRoll;
+
+    private Status status;
+
+    private Double velocityX;
+
+    private Double velocityY;
+
+    private Double velocityZ;
+}
+

src/main/java/kutaverse/game/websocket/WebsocketConfig.java

@@ -5,6 +5,7 @@
 import kutaverse.game.websocket.chat.ChatWebSocketHandler;
 import kutaverse.game.websocket.map.MapWebSocketHandler;
 import kutaverse.game.websocket.minigame.MiniGameWebsocketHandler;
+import kutaverse.game.websocket.taggame.TagGameWebSocketHandler;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.web.reactive.handler.SimpleUrlHandlerMapping;
@@ -30,17 +31,27 @@ public MiniGameWebsocketHandler miniGameWebsocketHandler() {
 	public ChatWebSocketHandler chatWebSocketHandler(ChatService chatService) {
 		return new ChatWebSocketHandler(chatService);
 	}
+
+	@Bean
+	public TagGameWebSocketHandler tagGameWebSocketHandler() {
+		return new TagGameWebSocketHandler();
+	}
+
 	@Bean
 	public ChatService chatService(ChatRepository chatRepository) {
 		return new ChatService(chatRepository);
 	}
 
 	@Bean
-	public SimpleUrlHandlerMapping handlerMapping(MapWebSocketHandler mapWsh, MiniGameWebsocketHandler miniWsh, ChatWebSocketHandler chatWsh) {
+	public SimpleUrlHandlerMapping handlerMapping(MapWebSocketHandler mapWsh,
+												  MiniGameWebsocketHandler miniWsh,
+												  ChatWebSocketHandler chatWsh,
+												  TagGameWebSocketHandler tagGameWsh) {
 		return new SimpleUrlHandlerMapping(Map.of(
 				"/map", mapWsh,
 				"/game", miniWsh,
-				"/chat", chatWsh
+				"/chat", chatWsh,
+				"/taggame", tagGameWsh
 		), 1);
 	}
 

src/main/java/kutaverse/game/websocket/taggame/TagGameWebSocketHandler.java

@@ -0,0 +1,37 @@
+package kutaverse.game.websocket.taggame;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import kutaverse.game.websocket.taggame.handler.CustomHandler;
+import kutaverse.game.websocket.taggame.handler.CustomHandlerMapping;
+import kutaverse.game.websocket.taggame.util.TagGameRequestUtil;
+import org.springframework.stereotype.Component;
+import org.springframework.web.reactive.socket.WebSocketHandler;
+import org.springframework.web.reactive.socket.WebSocketMessage;
+import org.springframework.web.reactive.socket.WebSocketSession;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+@Component
+public class TagGameWebSocketHandler implements WebSocketHandler {
+
+    private final ObjectMapper objectMapper = new ObjectMapper();
+
+    /**
+     * request로 반환후 handler를 실행한다.
+     * @param session the session to handle
+     * @return
+     */
+    @Override
+    public Mono<Void> handle(WebSocketSession session) {
+        session.receive()
+            .map(message -> {
+                String payloadAsText = message.getPayloadAsText();
+                return TagGameRequestUtil.fromWebsocketMessage(payloadAsText);
+            })
+            .doOnNext(tagGameRequest->{
+                CustomHandler customHandler = CustomHandlerMapping.getHandler(tagGameRequest.getTagGameStatus());
+                customHandler.handler(tagGameRequest,session);
+            }).subscribe();
+        return Mono.never();
+    }
+}

src/main/java/kutaverse/game/websocket/taggame/dto/TagGameMatchRequest.java

@@ -0,0 +1,17 @@
+package kutaverse.game.websocket.taggame.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.ToString;
+
+@Getter
+@NoArgsConstructor
+@AllArgsConstructor
+@ToString
+public class TagGameMatchRequest {
+
+    private String userId;
+
+    private String text;
+}

src/main/java/kutaverse/game/websocket/taggame/dto/TagGameMatchResponse.java

@@ -0,0 +1,31 @@
+package kutaverse.game.websocket.taggame.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import org.springframework.web.reactive.socket.WebSocketSession;
+
+import java.util.Map;
+
+@AllArgsConstructor
+@Builder
+public class TagGameMatchResponse {
+
+    private String roomId;
+
+    private String taggerId;
+
+    public static TagGameMatchResponse toDto(String roomId, Map.Entry<String, WebSocketSession> tagger) {
+        return TagGameMatchResponse.builder()
+                .roomId(roomId)
+                .taggerId(tagger.getKey())
+                .build();
+    }
+
+    @Override
+    public String toString() {
+        return "{" +
+                "roomId='" + roomId + '\'' +
+                ", taggerId='" + taggerId + '\'' +
+                '}';
+    }
+}

src/main/java/kutaverse/game/websocket/taggame/dto/TagGameRequest.java

@@ -0,0 +1,17 @@
+package kutaverse.game.websocket.taggame.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.ToString;
+
+@Getter
+@AllArgsConstructor
+@NoArgsConstructor
+@ToString
+public class TagGameRequest<T> {
+
+    private TagGameStatus tagGameStatus;
+
+    private T request;
+}

src/main/java/kutaverse/game/websocket/taggame/dto/TagGameStatus.java

@@ -0,0 +1,11 @@
+package kutaverse.game.websocket.taggame.dto;
+
+public enum TagGameStatus {
+
+    //매칭 중
+    WAITING_FOR_PLAYERS,
+    //게임 중
+    IN_PROGRESS,
+    //게임 종료
+    FINISHED
+}

src/main/java/kutaverse/game/websocket/taggame/handler/CustomHandler.java

@@ -0,0 +1,8 @@
+package kutaverse.game.websocket.taggame.handler;
+
+import org.springframework.web.reactive.socket.WebSocketSession;
+
+public interface CustomHandler {
+
+    void handler(Object o, WebSocketSession session);
+}

src/main/java/kutaverse/game/websocket/taggame/handler/CustomHandlerMapping.java

@@ -0,0 +1,22 @@
+package kutaverse.game.websocket.taggame.handler;
+
+import jakarta.annotation.PostConstruct;
+import kutaverse.game.websocket.map.handler.WebSocketHandler;
+import kutaverse.game.websocket.taggame.dto.TagGameStatus;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class CustomHandlerMapping {
+
+    private static final Map<TagGameStatus, CustomHandler> map=new HashMap<>();
+
+
+    static {
+        map.put(TagGameStatus.WAITING_FOR_PLAYERS,new TagGameMatchingHandler());
+    }
+
+    public static CustomHandler getHandler(TagGameStatus tagGameStatus){
+        return map.get(tagGameStatus);
+    }
+}

src/main/java/kutaverse/game/websocket/taggame/handler/TagGameMatchingHandler.java

@@ -0,0 +1,18 @@
+package kutaverse.game.websocket.taggame.handler;
+
+import kutaverse.game.websocket.taggame.dto.TagGameMatchRequest;
+import kutaverse.game.websocket.taggame.dto.TagGameRequest;
+import kutaverse.game.websocket.taggame.util.TagGameMatchingQueue;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.reactive.socket.WebSocketSession;
+
+@RequiredArgsConstructor
+public class TagGameMatchingHandler implements CustomHandler{
+
+    @Override
+    public void handler(Object object, WebSocketSession webSocketSession) {
+        TagGameRequest tagGameRequest =(TagGameRequest) object;
+        TagGameMatchRequest tagGameMatchRequest = (TagGameMatchRequest) tagGameRequest.getRequest();
+        TagGameMatchingQueue.addPlayer(tagGameMatchRequest.getUserId(),webSocketSession);
+    }
+}

src/main/java/kutaverse/game/websocket/taggame/util/TagGameMatchingQueue.java

@@ -0,0 +1,109 @@
+package kutaverse.game.websocket.taggame.util;
+
+import kutaverse.game.websocket.minigame.GameRoom;
+import kutaverse.game.websocket.minigame.GameRoomManager;
+import kutaverse.game.websocket.minigame.MatchingQueue;
+import kutaverse.game.websocket.taggame.dto.TagGameMatchResponse;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import org.springframework.web.reactive.socket.WebSocketMessage;
+import org.springframework.web.reactive.socket.WebSocketSession;
+import reactor.core.publisher.Mono;
+
+import java.util.*;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ThreadLocalRandom;
+
+@Component
+@Slf4j
+public class TagGameMatchingQueue {
+    private static final ArrayDeque<Map.Entry<String, WebSocketSession>> queueing = new ArrayDeque<>();
+    private static final Map<String, WebSocketSession> sessionMap = new ConcurrentHashMap<>();
+    private static final Random random = new Random();
+    public static void addPlayer(String userId, WebSocketSession webSocketSession){
+        if(!sessionMap.containsKey(userId)) {
+            queueing.offer(new AbstractMap.SimpleEntry<>(userId,webSocketSession));
+            sessionMap.put(userId,webSocketSession);
+            webSocketSession.send(Mono.just(webSocketSession.textMessage("매칭 대기 중 입니다."))).subscribe();
+        }
+
+    }
+
+    private static Map.Entry<String, WebSocketSession> getPlayer(){
+        return queueing.poll();
+    }
+
+    public static int getQueuePlayers(){
+        return queueing.size();
+    }
+
+    private String createGameRoom(List<Map.Entry<String, WebSocketSession>> players) {
+        StringBuilder stringBuilder = new StringBuilder();
+        for (Map.Entry<String, WebSocketSession> player : players) {
+            stringBuilder.append(player.getKey());
+            stringBuilder.append(" ");
+        }
+        String roomId = stringBuilder.toString();
+        TagGameRoom tagGameRoom = new TagGameRoom(roomId,players);
+        TagGameRoomManager.addGameRoom(tagGameRoom);
+        return roomId;
+    }
+
+    @Scheduled(fixedRate = 1000)
+    public void matchPlayers(){
+        while(queueing.size() >= 4){
+            Map.Entry<String, WebSocketSession> player1 = TagGameMatchingQueue.getPlayer();
+            Map.Entry<String, WebSocketSession> player2 = TagGameMatchingQueue.getPlayer();
+            Map.Entry<String, WebSocketSession> player3 = TagGameMatchingQueue.getPlayer();
+            Map.Entry<String, WebSocketSession> player4 = TagGameMatchingQueue.getPlayer();
+
+            // 세션 값 확인
+            if(player1.getValue().isOpen() && player2.getValue().isOpen()
+            && player3.getValue().isOpen() && player4.getValue().isOpen()){
+                List<Map.Entry<String, WebSocketSession>> players = List.of(player1, player2, player3, player4);
+                String gameRoom = createGameRoom(players);
+                Map.Entry<String, WebSocketSession> tagger = selectTagger(players);
+
+                //플레이어들에게 gamerood 공지
+                for (Map.Entry<String, WebSocketSession> player : players) {
+                    WebSocketSession webSocketSession = player.getValue();
+                    TagGameMatchResponse tagGameMatchResponse = TagGameMatchResponse.toDto(gameRoom, tagger);
+
+                    WebSocketMessage webSocketMessage = webSocketSession.textMessage(tagGameMatchResponse.toString());
+                    webSocketSession.send(Mono.just(webSocketMessage)).subscribe();
+                }
+
+
+
+            }
+            else{
+                if(player1.getValue().isOpen()){
+                    MatchingQueue.requeue(player1);
+                }
+                if(player2.getValue().isOpen()){
+                    MatchingQueue.requeue(player2);
+                }
+                if(player3.getValue().isOpen()){
+                    MatchingQueue.requeue(player3);
+                }
+                if(player4.getValue().isOpen()){
+                    MatchingQueue.requeue(player4);
+                }
+            }
+
+        }
+    }
+
+    /**
+     * 술래를 정한다
+     * @param players
+     * @return
+     */
+    private Map.Entry<String, WebSocketSession> selectTagger(List<Map.Entry<String, WebSocketSession>> players) {
+
+        int randomIndex = random.nextInt(players.size()); // 4는 상한값으로, 0~3 사이의 값이 생성됩니다.
+
+        return players.get(randomIndex);
+    }
+}