Feature: chat result hanlder

ProjectVG.Api/Models/Chat/Request/ChatRequest.cs

@@ -26,6 +26,9 @@ public class ChatRequest
         [JsonPropertyName("instruction")]
         public string? Instruction { get; set; }
 
+        [JsonPropertyName("use_tts")]
+        public bool UseTTS { get; set; } = true;
+
         public ProcessChatCommand ToProcessChatCommand()
         {
             return new ProcessChatCommand
@@ -36,7 +39,8 @@ public ProcessChatCommand ToProcessChatCommand()
                 RequestedAt = this.RequestedAt,
                 Action = this.Action,
                 Instruction = this.Instruction,
-                UserId = this.UserId
+                UserId = this.UserId,
+                UseTTS = this.UseTTS
             };
         }
     }

ProjectVG.Application/ApplicationServiceCollectionExtensions.cs

@@ -2,9 +2,11 @@
 using ProjectVG.Application.Services.Character;
 using ProjectVG.Application.Services.User;
 using ProjectVG.Application.Services.Chat;
+using ProjectVG.Application.Services.Chat.CostTracking;
 using ProjectVG.Application.Services.Chat.Preprocessors;
 using ProjectVG.Application.Services.Chat.Processors;
 using ProjectVG.Application.Services.Chat.Validators;
+using ProjectVG.Application.Services.Chat.Handlers;
 using ProjectVG.Application.Services.WebSocket;
 using ProjectVG.Application.Services.Conversation;
 using ProjectVG.Application.Services.Session;
@@ -27,11 +29,19 @@ public static IServiceCollection AddApplicationServices(this IServiceCollection
             services.AddScoped<UserInputAnalysisProcessor>();
             services.AddScoped<UserInputActionProcessor>();
             services.AddScoped<MemoryContextPreprocessor>();
+            services.AddScoped<ChatFailureHandler>();
 
             services.AddScoped<IWebSocketManager, WebSocketManager>();
             services.AddScoped<IChatService, ChatService>();
             services.AddScoped<IConversationService, ConversationService>();
             services.AddSingleton<IConnectionRegistry, ConnectionRegistry>();
+
+            services.AddScoped<IChatMetricsService, ChatMetricsService>();
+
+            // 비용 추적 데코레이터 등록
+            services.AddCostTrackingDecorator<ChatLLMProcessor>("LLM_Processing");
+            services.AddCostTrackingDecorator<ChatTTSProcessor>("TTS_Processing");
+            services.AddCostTrackingDecorator<UserInputAnalysisProcessor>("User_Input_Analysis");
 
             return services;
         }

ProjectVG.Application/Models/Chat/ChatMessageSegment.cs

@@ -13,51 +13,6 @@ public class ChatMessageSegment
         public bool HasAudio => AudioData != null && AudioData.Length > 0;
         public bool IsEmpty => !HasText && !HasAudio;
 
-        public override string ToString()
-        {
-            var parts = new List<string>();
-
-            parts.Add($"Order: {Order}");
-
-            if (HasText)
-            {
-                parts.Add($"Text: \"{Text}\"");
-            }
-
-            if (HasAudio)
-            {
-                parts.Add($"Audio: {AudioData!.Length} bytes, {AudioContentType}, {AudioLength:F2}s");
-            }
-
-            if (!string.IsNullOrEmpty(Emotion))
-            {
-                parts.Add($"Emotion: {Emotion}");
-            }
-
-            return $"Segment({string.Join(", ", parts)})";
-        }
-
-        public string ToShortString()
-        {
-            var parts = new List<string>();
-
-            if (HasText)
-            {
-                parts.Add($"\"{Text}\"");
-            }
-
-            if (HasAudio)
-            {
-                parts.Add($"[Audio: {AudioLength:F1}s]");
-            }
-
-            return string.Join(" ", parts);
-        }
-
-        public string ToDebugString()
-        {
-            return $"Segment[Order={Order}, Text={HasText}, Audio={HasAudio}, Emotion={Emotion ?? "none"}, AudioSize={AudioData?.Length ?? 0} bytes, AudioLength={AudioLength:F2}s]";
-        }
 
         public static ChatMessageSegment CreateTextOnly(string text, int order = 0)
         {
@@ -67,29 +22,14 @@ public static ChatMessageSegment CreateTextOnly(string text, int order = 0)
                 Order = order
             };
         }
-        
-        public static ChatMessageSegment CreateAudioOnly(byte[] audioData, string contentType, float? audioLength, int order = 0)
+
+        public void SetAudioData(byte[]? audioData, string? audioContentType, float? audioLength)
         {
-            return new ChatMessageSegment
-            {
-                AudioData = audioData,
-                AudioContentType = contentType,
-                AudioLength = audioLength,
-                Order = order
-            };
+            AudioData = audioData;
+            AudioContentType = audioContentType;
+            AudioLength = audioLength;
         }
 
-        public static ChatMessageSegment CreateIntegrated(string text, byte[] audioData, string contentType, float? audioLength, string? emotion = null, int order = 0)
-        {
-            return new ChatMessageSegment
-            {
-                Text = text,
-                AudioData = audioData,
-                AudioContentType = contentType,
-                AudioLength = audioLength,
-                Emotion = emotion,
-                Order = order
-            };
-        }
+
     }
 }

ProjectVG.Application/Models/Chat/ChatMetrics.cs

@@ -0,0 +1,25 @@
+namespace ProjectVG.Application.Models.Chat
+{
+    public class ChatMetrics
+    {
+        public string SessionId { get; set; } = string.Empty;
+        public string UserId { get; set; } = string.Empty;
+        public string CharacterId { get; set; } = string.Empty;
+        public DateTime StartTime { get; set; }
+        public DateTime EndTime { get; set; }
+        public List<ProcessMetrics> ProcessMetrics { get; set; } = new();
+        public decimal TotalCost { get; set; }
+        public TimeSpan TotalDuration { get; set; }
+    }
+
+    public class ProcessMetrics
+    {
+        public string ProcessName { get; set; } = string.Empty;
+        public DateTime StartTime { get; set; }
+        public DateTime EndTime { get; set; }
+        public TimeSpan Duration { get; set; }
+        public decimal Cost { get; set; }
+        public string? ErrorMessage { get; set; }
+        public Dictionary<string, object>? AdditionalData { get; set; }
+    }
+}

ProjectVG.Application/Models/Chat/ChatProcessContext.cs

@@ -0,0 +1,77 @@
+using ProjectVG.Application.Models.Character;
+using ProjectVG.Domain.Entities.ConversationHistorys;
+
+namespace ProjectVG.Application.Models.Chat
+{
+    public class ChatProcessContext
+    {
+        public string SessionId { get; private set; } = string.Empty;
+        public Guid UserId { get; private set; }
+        public Guid CharacterId { get; private set; }
+        public string UserMessage { get; private set; } = string.Empty;
+        public string MemoryStore { get; private set; } = string.Empty;
+        public bool UseTTS { get; private set; } = true;
+
+        public CharacterDto? Character { get; private set; }
+        public IEnumerable<string>? MemoryContext { get; private set; }
+        public IEnumerable<ConversationHistory>? ConversationHistory { get; private set; }
+
+        public string Response { get; private set; } = string.Empty;
+        public double Cost { get; private set; }
+        public List<ChatMessageSegment> Segments { get; private set; } = new List<ChatMessageSegment>();
+
+        public string FullText => string.Join(" ", Segments.Where(s => s.HasText).Select(s => s.Text));
+        public bool HasAudio => Segments.Any(s => s.HasAudio);
+        public bool HasText => Segments.Any(s => s.HasText);
+
+
+        public ChatProcessContext(ProcessChatCommand command)
+        {
+            SessionId = command.SessionId;
+            UserId = command.UserId;
+            CharacterId = command.CharacterId;
+            UserMessage = command.Message;
+            MemoryStore = command.UserId.ToString();
+            UseTTS = command.UseTTS;
+        }
+
+        public ChatProcessContext(
+            ProcessChatCommand command,
+            CharacterDto character,
+            IEnumerable<ConversationHistory> conversationHistory,
+            IEnumerable<string> memoryContext)
+        {
+            SessionId = command.SessionId;
+            UserId = command.UserId;
+            CharacterId = command.CharacterId;
+            UserMessage = command.Message;
+            MemoryStore = command.UserId.ToString();
+            UseTTS = command.UseTTS;
+
+            Character = character;
+            ConversationHistory = conversationHistory;
+            MemoryContext = memoryContext;
+        }
+
+        public void SetResponse(string response, List<ChatMessageSegment> segments, double cost)
+        {
+            Response = response;
+            Segments = segments;
+            Cost = cost;
+        }
+
+        public void AddCost(double additionalCost)
+        {
+            Cost += additionalCost;
+        }
+
+        public IEnumerable<string> ParseConversationHistory(int count = 5)
+        {
+            if (ConversationHistory == null) return Enumerable.Empty<string>();
+
+            return ConversationHistory
+                .Take(count)
+                .Select(h => $"{h.Role}: {h.Content}");
+        }
+    }
+}

ProjectVG.Application/Models/Chat/ProcessChatCommand.cs

@@ -18,6 +18,7 @@ public string RequestId
         public DateTime RequestedAt { get; set; }
         public string? Action { get; set; }
         public string? Instruction { get; set; }
+        public bool UseTTS { get; set; } = true;
 
         public CharacterDto? Character { get; private set; }