Fix supabase_client error

supabase_client.py

@@ -6,6 +6,7 @@ import json
 import logging
 
 from utils.classes import Order
+
 # Configurar logging
 logging.basicConfig(level=logging.INFO)
 logger = logging.getLogger(__name__)
@@ -26,13 +27,26 @@ class SupabaseOrderManager:
         self.supabase_url = url or os.getenv("SUPABASE_URL")
         self.supabase_key = key or os.getenv("SUPABASE_KEY")
         
+        # Validar que las credenciales existan
         if not self.supabase_url or not self.supabase_key:
-            raise ValueError("SUPABASE_URL y SUPABASE_KEY deben estar definidos como variables de entorno o proporcionados como parámetros")
+            error_msg = (
+                "SUPABASE_URL y SUPABASE_KEY deben estar definidos como variables de entorno "
+                "o proporcionados como parámetros. "
+                f"URL encontrada: {'✓' if self.supabase_url else '✗'}, "
+                f"KEY encontrada: {'✓' if self.supabase_key else '✗'}"
+            )
+            logger.error(error_msg)
+            raise ValueError(error_msg)
         
-        # Inicializar cliente
-        self.supabase = create_client(self.supabase_url, self.supabase_key)
-        logger.info("Cliente Supabase inicializado correctamente")
-    
+        try:
+            # Inicializar cliente
+            self.supabase = create_client(self.supabase_url, self.supabase_key)
+            logger.info("Cliente Supabase inicializado correctamente")
+                 
+        except Exception as e:
+            logger.error(f"Error al inicializar cliente Supabase: {e}")
+            raise
+         
     async def send_order(self, order: Order) -> Dict[str, Any]:
         """
         Envía una orden a Supabase.
@@ -47,6 +61,8 @@ class SupabaseOrderManager:
             # Convertir el objeto Order a un diccionario
             order_dict = order.to_dict()
             
+            logger.info(f"Iniciando envío de orden {order_dict['order_id']} a Supabase")
+            
             # 1. Insertar la orden principal
             order_data = {
                 "order_id": order_dict["order_id"],
@@ -56,13 +72,15 @@ class SupabaseOrderManager:
             }
             
             # Realizar la inserción de la orden
+            logger.debug(f"Insertando orden principal: {order_data}")
             order_response = self.supabase.table("orders").insert(order_data).execute()
             
             if not order_response.data:
-                raise Exception("Error al insertar orden en Supabase")
+                raise Exception("Error al insertar orden en Supabase - respuesta vacía")
             
             # Obtener el ID de la orden insertada
             db_order_id = order_response.data[0]["id"]
+            logger.info(f"Orden insertada con ID de base de datos: {db_order_id}")
             
             # 2. Insertar los elementos de la orden
             items_to_insert = []
@@ -76,18 +94,23 @@ class SupabaseOrderManager:
             
             # Realizar la inserción de los elementos
             if items_to_insert:
+                logger.debug(f"Insertando {len(items_to_insert)} elementos de la orden")
                 items_response = self.supabase.table("order_items").insert(items_to_insert).execute()
                 
                 if not items_response.data:
                     # Si falla la inserción de items, eliminamos la orden para mantener consistencia
+                    logger.error("Fallo al insertar elementos, eliminando orden para mantener consistencia")
                     self.supabase.table("orders").delete().eq("id", db_order_id).execute()
                     raise Exception("Error al insertar elementos de la orden en Supabase")
+                
+                logger.info(f"Insertados {len(items_response.data)} elementos correctamente")
             
             logger.info(f"Orden {order_dict['order_id']} enviada correctamente a Supabase")
             return {
                 "success": True,
                 "order_id": order_dict["order_id"],
-                "database_id": db_order_id
+                "database_id": db_order_id,
+                "items_count": len(items_to_insert)
             }
             
         except Exception as e:

tools.py

@@ -10,12 +10,35 @@ from utils.classes import Order
 
 from supabase_client import SupabaseOrderManager
 import asyncio
+import os
+from dotenv import load_dotenv
 
-try:
-    supabase = SupabaseOrderManager()
-except Exception as e:
-    log_error(f"Error al inicializar el cliente de Supabase: {e}")
-    supabase = None
+# Cargar variables de entorno
+load_dotenv()
+
+# Intentar inicializar Supabase de forma segura
+def init_supabase_client():
+    """Inicializa el cliente de Supabase de forma segura."""
+    try:
+        # Verificar si las variables de entorno están disponibles
+        supabase_url = os.getenv("SUPABASE_URL")
+        supabase_key = os.getenv("SUPABASE_KEY")
+        
+        if not supabase_url or not supabase_key:
+            log_warn("Variables de entorno de Supabase no encontradas. Funcionando sin base de datos.")
+            return None
+            
+        supabase = SupabaseOrderManager()
+        log_info("Cliente de Supabase inicializado correctamente")
+        return supabase
+        
+    except Exception as e:
+        log_error(f"Error al inicializar el cliente de Supabase: {e}")
+        log_warn("Continuando sin funcionalidad de base de datos")
+        return None
+
+# Inicializar cliente
+supabase = init_supabase_client()
 
 
 def create_menu_info_tool(retriever: VectorStoreRetriever) -> Tool:
@@ -52,19 +75,19 @@ def create_menu_info_tool(retriever: VectorStoreRetriever) -> Tool:
             return "Lo siento, no tengo información sobre eso."
     
     return Tool(
-    name="guest_info_tool",
-    description="""Herramienta para consultar información detallada del menú del restaurante.
-        Úsala cuando necesites:
-        - Buscar platos específicos y verificar su disponibilidad
-        - Consultar precios exactos de productos
-        - Obtener información sobre ingredientes, alérgenos o composición de platos
-        - Explorar secciones del menú (entrantes, principales, postres, bebidas, etc.)
-        - Verificar la existencia de productos antes de recomendarlos
-        - Responder preguntas específicas sobre la carta del restaurante
-        
-        Esta herramienta accede al contenido completo del menú para proporcionar información precisa y actualizada.""",
-    func=extract_text,
-)
+        name="guest_info_tool",
+        description="""Herramienta para consultar información detallada del menú del restaurante.
+            Úsala cuando necesites:
+            - Buscar platos específicos y verificar su disponibilidad
+            - Consultar precios exactos de productos
+            - Obtener información sobre ingredientes, alérgenos o composición de platos
+            - Explorar secciones del menú (entrantes, principales, postres, bebidas, etc.)
+            - Verificar la existencia de productos antes de recomendarlos
+            - Responder preguntas específicas sobre la carta del restaurante
+            
+            Esta herramienta accede al contenido completo del menú para proporcionar información precisa y actualizada.""",
+        func=extract_text,
+    )
 
 def create_send_to_kitchen_tool(llm: ChatOpenAI) -> Tool:
     """
@@ -167,6 +190,28 @@ def create_send_to_kitchen_tool(llm: ChatOpenAI) -> Tool:
             log_info(f"Procesando resumen para enviar pedido a cocina...")
             log_debug(f"Resumen recibido: {conversation_summary}")
             
+            # Verificar si Supabase está disponible
+            if supabase is None:
+                log_warn("Supabase no está configurado. Simulando envío de pedido.")
+                
+                # Extraer el pedido para mostrarlo en logs aunque no se envíe
+                order = extract_order_from_summary(conversation_summary)
+                
+                # Verificar si hay un error en el procesamiento
+                if hasattr(order, 'error') and order.error:
+                    return "Lo siento, ha ocurrido un problema al procesar su pedido. Por favor, inténtelo de nuevo."
+                
+                # Verificar si hay elementos en el pedido
+                if not order.items:
+                    return "No se pudo identificar ningún artículo en el pedido. ¿Podría repetir su pedido, por favor?"
+                
+                # Simular el procesamiento del pedido
+                order_dict = order.to_dict()
+                log_info(f"PEDIDO PROCESADO (MODO SIMULACIÓN): {json.dumps(order_dict, indent=2, ensure_ascii=False)}")
+                
+                # Devolver confirmación simulada
+                return f"Su pedido ha sido procesado correctamente. Mesa: {order.table_number}, Artículos: {len(order.items)} elemento(s). (Modo simulación - Supabase no configurado)"
+            
             # Extraer el pedido a partir del resumen
             order = extract_order_from_summary(conversation_summary)
             
@@ -187,12 +232,11 @@ def create_send_to_kitchen_tool(llm: ChatOpenAI) -> Tool:
                 log_warn("No se identificaron artículos en el pedido")
                 return "No se pudo identificar ningún artículo en el pedido. ¿Podría repetir su pedido, por favor?"
             
-            # Simular envío a la cocina
+            # Enviar a la cocina usando Supabase
             order_dict = order.to_dict()
             log_info(f"ENVIANDO PEDIDO A COCINA: {json.dumps(order_dict, indent=2, ensure_ascii=False)}")
             
-            # Aquí iría la integración real con el sistema de la cocina
-            # Por ejemplo, enviar a una API, base de datos, etc.
+            # Envío real con Supabase
             async def async_send_and_get_result(order):
                 return await supabase.send_order(order)
             
@@ -211,16 +255,32 @@ def create_send_to_kitchen_tool(llm: ChatOpenAI) -> Tool:
             log_debug(traceback.format_exc())
             return "Lo siento, hubo un problema al procesar su pedido. ¿Podría intentarlo de nuevo?"
     
-    # Retornar la herramienta configurada con la función send_to_kitchen
-    return Tool(
-        name="send_to_kitchen_tool",
-        description="""
+    # Determinar la descripción basada en si Supabase está disponible
+    if supabase is None:
+        description = """
+        Procesa y confirma el pedido del cliente (MODO SIMULACIÓN - Sin base de datos).
+        
+        Usa esta herramienta SOLAMENTE cuando el cliente haya terminado de hacer su pedido 
+        completo y esté listo para confirmarlo.
+        
+        NOTA: Supabase no está configurado, por lo que el pedido será procesado pero no se 
+        enviará a una base de datos real.
+        
+        Esta herramienta espera recibir un RESUMEN de la conversación que describe los elementos del pedido.
+        """
+    else:
+        description = """
         Envía el pedido completo a la cocina. Usa esta herramienta SOLAMENTE cuando el cliente haya terminado de hacer su pedido 
         completo y esté listo para enviarlo.
         
         Esta herramienta espera recibir un RESUMEN de la conversación que describe los elementos del pedido.
         No envíes la conversación completa, solo un resumen claro de lo que el cliente ha pedido, la mesa, 
         y cualquier instrucción especial relevante.
-        """,
+        """
+    
+    # Retornar la herramienta configurada con la función send_to_kitchen
+    return Tool(
+        name="send_to_kitchen_tool",
+        description=description,
         func=send_to_kitchen,
-    )
+    )