Verbose

.env

@@ -2,4 +2,5 @@ DB_HOST=opal2.opalstack.com
 DB_USER=moibe
 mariadb_c=Qaonrr_182
 DB_NAME=imagen_log
-DB_PORT=3306
+DB_PORT=3306
+DB_CHARSET=utf8

funciones.py

@@ -1,9 +1,12 @@
 """Funciones de lógica de negocio"""
 
+import logging
 from datetime import datetime
 from connection import get_connection
 from models import RegistroRequest, RegistroResponse
 
+# Configurar logging
+logger = logging.getLogger(__name__)
 
 def crear_registro(datos: RegistroRequest) -> dict:
     """
@@ -19,12 +22,14 @@ def crear_registro(datos: RegistroRequest) -> dict:
     conn = get_connection()
     
     if not conn:
+        logger.error("❌ No se pudo conectar a la base de datos")
         return {
             "success": False,
             "error": "No se pudo conectar a la base de datos"
         }
     
     try:
+        logger.info(f"🔗 Conexión establecida a BD")
         # Preparar datos
         uid = datos.uid
         display_name = datos.display_name
@@ -36,6 +41,8 @@ def crear_registro(datos: RegistroRequest) -> dict:
         proveedor = datos.proveedor
         seed = datos.seed
         
+        logger.info(f"📊 Datos a insertar - UID: {uid}, Usuario: {display_name}, País: {pais}, Email: {correo}, Prompt: {prompt}, Proveedor: {proveedor}")
+        
         # Insertar en la BD
         cursor = conn.cursor()
         
@@ -53,8 +60,11 @@ def crear_registro(datos: RegistroRequest) -> dict:
         cursor.execute(sql, valores)
         conn.commit()
         
+        logger.info(f"✅ Registro insertado en BD")
+        
         # Obtener el ID del registro recién creado
         nuevo_id = cursor.lastrowid
+        logger.info(f"🔑 ID generado: {nuevo_id}")
         
         # Recuperar el registro creado
         cursor.execute(
@@ -72,6 +82,7 @@ def crear_registro(datos: RegistroRequest) -> dict:
         conn.close()
         
         if registro:
+            logger.info(f"✅ Registro recuperado exitosamente - ID: {registro[0]}")
             return {
                 "success": True,
                 "data": {
@@ -89,12 +100,14 @@ def crear_registro(datos: RegistroRequest) -> dict:
                 }
             }
         else:
+            logger.error("❌ No se pudo recuperar el registro creado")
             return {
                 "success": False,
                 "error": "No se pudo recuperar el registro creado"
             }
         
     except Exception as e:
+        logger.error(f"❌ Error al crear registro: {str(e)}")
         return {
             "success": False,
             "error": f"Error al crear registro: {str(e)}"
@@ -116,17 +129,20 @@ def obtener_registros(limit: int = 10, offset: int = 0) -> dict:
     conn = get_connection()
     
     if not conn:
+        logger.error("❌ No se pudo conectar a la base de datos")
         return {
             "success": False,
             "error": "No se pudo conectar a la base de datos"
         }
     
     try:
+        logger.info(f"🔗 Obteniendo registros - Limit: {limit}, Offset: {offset}")
         cursor = conn.cursor()
         
         # Obtener total de registros
         cursor.execute("SELECT COUNT(*) FROM `registro`")
         total = cursor.fetchone()[0]
+        logger.info(f"📊 Total de registros en BD: {total}")
         
         # Obtener registros con paginación
         cursor.execute(
@@ -141,6 +157,7 @@ def obtener_registros(limit: int = 10, offset: int = 0) -> dict:
         )
         
         registros = cursor.fetchall()
+        logger.info(f"✅ Se obtuvieron {len(registros)} registros de la BD")
         cursor.close()
         conn.close()
         
@@ -161,6 +178,7 @@ def obtener_registros(limit: int = 10, offset: int = 0) -> dict:
                 "created_at": reg[10]
             })
         
+        logger.info(f"📈 Retornando {len(datos)} registros")
         return {
             "success": True,
             "data": datos,
@@ -170,6 +188,7 @@ def obtener_registros(limit: int = 10, offset: int = 0) -> dict:
         }
         
     except Exception as e:
+        logger.error(f"❌ Error al obtener registros: {str(e)}")
         return {
             "success": False,
             "error": f"Error al obtener registros: {str(e)}"

main.py

@@ -2,12 +2,20 @@
 Aplicación FastAPI - Endpoints
 """
 
+import logging
 from fastapi import FastAPI, HTTPException, Query
 from fastapi.responses import JSONResponse
 from models import RegistroRequest, RegistroResponse
 from funciones import crear_registro, obtener_registros
 from datetime import datetime
 
+# Configurar logging
+logging.basicConfig(
+    level=logging.INFO,
+    format='%(asctime)s - %(name)s - %(levelname)s - %(message)s'
+)
+logger = logging.getLogger(__name__)
+
 app = FastAPI(
     title="API Imagen Log",
     description="API para gestionar registro de usuarios",
@@ -18,6 +26,7 @@ app = FastAPI(
 @app.get("/", tags=["General"])
 async def root():
     """Endpoint raíz de bienvenida"""
+    logger.info("📍 Llamado a endpoint raíz /")
     return {
         "mensaje": "Bienvenido a la API de Imagen Log",
         "version": "1.0.0",
@@ -28,6 +37,7 @@ async def root():
 @app.get("/health", tags=["General"])
 async def health():
     """Verifica el estado de la API"""
+    logger.info("✅ Health check")
     return {
         "status": "healthy",
         "timestamp": datetime.now().isoformat()
@@ -55,15 +65,19 @@ async def registrar(datos: RegistroRequest):
     **Respuesta:** Retorna los datos del registro creado con su ID único
     """
     
+    logger.info(f"📝 Nuevo registro - UID: {datos.uid}, Email: {datos.correo}, Prompt: {datos.prompt}")
+    
     resultado = crear_registro(datos)
     
     if resultado["success"]:
+        logger.info(f"✅ Registro creado exitosamente - ID: {resultado['data']['id']}, UID: {datos.uid}")
         return {
             "success": True,
             "message": "Registro creado exitosamente",
             "data": resultado["data"]
         }
     else:
+        logger.error(f"❌ Error al crear registro: {resultado['error']}")
         raise HTTPException(
             status_code=400,
             detail=resultado["error"]
@@ -85,9 +99,12 @@ async def obtener_todos_registros(
     **Respuesta:** Lista de registros con información de paginación
     """
     
+    logger.info(f"📚 Obteniendo registros - Limit: {limit}, Offset: {offset}")
+    
     resultado = obtener_registros(limit, offset)
     
     if resultado["success"]:
+        logger.info(f"✅ Se obtuvieron {len(resultado['data'])} registros (Total: {resultado['total']})")
         return {
             "success": True,
             "data": resultado["data"],
@@ -99,6 +116,7 @@ async def obtener_todos_registros(
             }
         }
     else:
+        logger.error(f"❌ Error al obtener registros: {resultado['error']}")
         raise HTTPException(
             status_code=500,
             detail=resultado["error"]
@@ -108,3 +126,8 @@ async def obtener_todos_registros(
 if __name__ == "__main__":
     import uvicorn
     uvicorn.run("main:app", host="0.0.0.0", port=8000, reload=True)
+
+
+if __name__ == "__main__":
+    import uvicorn
+    uvicorn.run("main:app", host="0.0.0.0", port=8000, reload=True)