v44

app.py

@@ -423,7 +423,7 @@ def convert_to_messages_format(chat_history):
     
     return messages
 
-async def stream_agent_response(question: str, chat_history: List[Tuple[str, str]]) -> str:
+async def stream_agent_response(question: str, chat_history: List[List[str]]) -> str:
     """Procesa la pregunta del usuario y devuelve la respuesta del agente con memoria de conversación."""
     global agent  # Make sure we can modify the agent's memory
     
@@ -432,11 +432,11 @@ async def stream_agent_response(question: str, chat_history: List[Tuple[str, str
     messages = []
     
     # Add previous chat history in the correct format for the agent
-    for user_msg, assistant_msg in chat_history:
-        if user_msg:
-            messages.append(HumanMessage(content=user_msg))
-        if assistant_msg:
-            messages.append(AIMessage(content=assistant_msg))
+    for msg_pair in chat_history:
+        if len(msg_pair) >= 1 and msg_pair[0]:  # User message
+            messages.append(HumanMessage(content=msg_pair[0]))
+        if len(msg_pair) >= 2 and msg_pair[1]:  # Assistant message
+            messages.append(AIMessage(content=msg_pair[1]))
     
     # Add current user's question
     user_message = HumanMessage(content=question)
@@ -812,12 +812,12 @@ def create_application():
         # Clear the input
         return "", chat_history
     
-    async def bot_response(chat_history: List[Tuple[str, str]]) -> List[Tuple[str, str]]:
+    async def bot_response(chat_history: List[List[str]]) -> List[List[str]]:
         """Get bot response and update chat history."""
         if not chat_history:
             return chat_history
             
-        # Get the last user message (first element of the last tuple if it exists)
+        # Get the last user message (first element of the last list if it exists)
         if not chat_history[-1][0] or chat_history[-1][1] is not None:
             return chat_history
             
@@ -829,7 +829,7 @@ def create_application():
             assistant_message = await stream_agent_response(question, chat_history[:-1])
             
             # Update the assistant's message in the chat history
-            chat_history[-1] = (question, assistant_message)
+            chat_history[-1] = [question, assistant_message]
             
             logger.info("Response generation complete")
             return chat_history
@@ -838,7 +838,7 @@ def create_application():
             error_msg = f"## ❌ Error\n\nError al procesar la solicitud:\n\n```\n{str(e)}\n```"
             logger.error(error_msg, exc_info=True)
             if chat_history and len(chat_history[-1]) == 2 and chat_history[-1][1] is None:
-                chat_history[-1] = (chat_history[-1][0], error_msg)
+                chat_history[-1] = [chat_history[-1][0], error_msg]
             return chat_history
     
     # Event handlers