fix: connectionFactory 제거

과한 설계 connectionFactory 제거

Author: ImGdevel

ProjectVG.Api/Middleware/WebSocketMiddleware.cs

@@ -2,7 +2,7 @@
 using System.Net.WebSockets;
 using ProjectVG.Application.Services.WebSocket;
 using ProjectVG.Application.Services.Session;
-using ProjectVG.Common.Models.Session;
+using ProjectVG.Infrastructure.Realtime.WebSocketConnection;
 
 namespace ProjectVG.Api.Middleware
 {
@@ -12,20 +12,16 @@ public class WebSocketMiddleware
         private readonly ILogger<WebSocketMiddleware> _logger;
         private readonly IWebSocketManager _webSocketService;
         private readonly IConnectionRegistry _connectionRegistry;
-        private readonly IClientConnectionFactory _connectionFactory;
-
         public WebSocketMiddleware(
             RequestDelegate next,
             ILogger<WebSocketMiddleware> logger,
             IWebSocketManager webSocketService,
-            IConnectionRegistry connectionRegistry,
-            IClientConnectionFactory connectionFactory)
+            IConnectionRegistry connectionRegistry)
         {
             _next = next;
             _logger = logger;
             _webSocketService = webSocketService;
             _connectionRegistry = connectionRegistry;
-            _connectionFactory = connectionFactory;
         }
 
         public async Task InvokeAsync(HttpContext context)
@@ -51,7 +47,7 @@ public async Task InvokeAsync(HttpContext context)
                 }
 
                 // 3. 연결 생성 및 등록
-                var connection = _connectionFactory.Create(actualSessionId, socket, userId: null);
+                var connection = new WebSocketClientConnection(actualSessionId, socket, userId: null);
                 _connectionRegistry.Register(actualSessionId, connection);
 
                 // 4. 세션 생성 (이제 연결이 등록된 상태)

ProjectVG.Application/Services/Character/CharacterService.cs

@@ -25,11 +25,11 @@ public async Task<IEnumerable<CharacterDto>> GetAllCharactersAsync()
             return characterDtos;
         }
 
-        public async Task<CharacterDto?> GetCharacterByIdAsync(Guid id)
+        public async Task<CharacterDto> GetCharacterByIdAsync(Guid id)
         {
             var character = await _characterRepository.GetByIdAsync(id);
             if (character == null) {
-                return null;
+                throw new NotFoundException(ErrorCode.CHARACTER_NOT_FOUND, id);
             }
 
             var characterDto = new CharacterDto(character);

ProjectVG.Application/Services/Character/ICharacterService.cs

@@ -15,7 +15,7 @@ public interface ICharacterService
         /// </summary>
         /// <param name="id">캐릭터 ID</param>
         /// <returns>캐릭터 정보</returns>
-        Task<CharacterDto?> GetCharacterByIdAsync(Guid id);
+        Task<CharacterDto> GetCharacterByIdAsync(Guid id);
 
         /// <summary>
         /// 새 캐릭터를 생성합니다

ProjectVG.Application/Services/Character/TestCharacterService.cs

@@ -9,8 +9,7 @@
 using ProjectVG.Infrastructure.Persistence.Repositories.Conversation;
 using ProjectVG.Infrastructure.Persistence.Repositories.Users;
 using ProjectVG.Infrastructure.Persistence.Session;
-using ProjectVG.Infrastructure.Realtime.WebSocketConnection;
-using ProjectVG.Common.Models.Session;
+
 
 using Microsoft.EntityFrameworkCore;
 
@@ -26,7 +25,6 @@ public static IServiceCollection AddInfrastructureServices(this IServiceCollecti
             AddDatabaseServices(services, configuration);
             AddExternalApiClients(services, configuration);
             AddPersistenceServices(services);
-            AddRealtimeServices(services);
 
             return services;
         }
@@ -92,13 +90,5 @@ private static void AddPersistenceServices(IServiceCollection services)
             services.AddScoped<IUserRepository, SqlServerUserRepository>();
             services.AddSingleton<ISessionStorage, InMemorySessionStorage>();
         }
-
-        /// <summary>
-        /// 실시간 통신 서비스
-        /// </summary>
-        private static void AddRealtimeServices(IServiceCollection services)
-        {
-            services.AddSingleton<IClientConnectionFactory, WebSocketClientConnectionFactory>();
-        }
     }
 }

ProjectVG.Common/Models/Session/IClientConnectionFactory.cs

@@ -13,6 +13,14 @@ public class WebSocketClientConnection : IClientConnection
 		public DateTime ConnectedAt { get; set; } = DateTime.UtcNow;
 		public System.Net.WebSockets.WebSocket WebSocket { get; set; } = null!;
 
+		public WebSocketClientConnection(string sessionId, System.Net.WebSockets.WebSocket socket, string? userId = null)
+		{
+			SessionId = sessionId;
+			WebSocket = socket;
+			UserId = userId;
+			ConnectedAt = DateTime.UtcNow;
+		}
+
 		/// <summary>
 		/// 텍스트 메시지를 전송합니다
 		/// </summary>