fix: WebSocket 메시지 조각화 처리 개선

- EndOfMessage 확인으로 완전한 메시지 수신 보장
- MemoryStream 사용한 프래그먼트 누적 처리
- 긴 메시지 손실 방지 및 데이터 무결성 보장
- ping/pong 메시지 처리 로직 개선 (JSON 구조 지원)

기존: 첫 번째 프래그먼트만 처리하여 메시지 손실 가능
개선: do-while 루프로 완전한 메시지 복원

Author: ImGdevel

ProjectVG.Api/Middleware/WebSocketMiddleware.cs

@@ -125,15 +125,23 @@ await socket.SendAsync(
                     true,
                     cancellationTokenSource.Token).ConfigureAwait(false);
 
-                while (socket.State == WebSocketState.Open && !cancellationTokenSource.Token.IsCancellationRequested) {
-                    var result = await socket.ReceiveAsync(
-                        new ArraySegment<byte>(buffer),
-                        cancellationTokenSource.Token).ConfigureAwait(false);
-
-                    if (result.MessageType == WebSocketMessageType.Close) {
-                        _logger.LogInformation("연결 종료 요청: {UserId}", userId);
-                        break;
-                    }
+                while (socket.State == WebSocketState.Open && !cancellationTokenSource.Token.IsCancellationRequested)
+                {
+                    WebSocketReceiveResult result;
+                    using var ms = new MemoryStream();
+                    do
+                    {
+                        result = await socket.ReceiveAsync(new ArraySegment<byte>(buffer), cancellationTokenSource.Token)
+                            .ConfigureAwait(false);
+                        if (result.MessageType == WebSocketMessageType.Close)
+                        {
+                            _logger.LogInformation("연결 종료 요청: {UserId}", userId);
+                            break;
+                        }
+                        ms.Write(buffer, 0, result.Count);
+                    } while (!result.EndOfMessage);
+
+                    if (result.MessageType == WebSocketMessageType.Close) break;
 
                     // WebSocket의 기본 제어 메시지들 처리
                     if (result.MessageType == WebSocketMessageType.Binary) {
@@ -143,8 +151,10 @@ await socket.SendAsync(
 
                     // Handle heartbeat/ping messages
                     if (result.MessageType == WebSocketMessageType.Text) {
-                        var message = System.Text.Encoding.UTF8.GetString(buffer, 0, result.Count);
-                        if (message.Contains("ping")) {
+                        var message = System.Text.Encoding.UTF8.GetString(ms.ToArray());
+                        // 매우 단순한 ping 판별 → 추후 JSON 파싱으로 교체 권장
+                        if (string.Equals(message, "ping", StringComparison.OrdinalIgnoreCase) ||
+                            message.Contains("\"type\":\"ping\"", StringComparison.OrdinalIgnoreCase)) {
                             var pongMessage = System.Text.Encoding.UTF8.GetBytes("{\"type\":\"pong\"}");
                             await socket.SendAsync(
                                 new ArraySegment<byte>(pongMessage),