Update server.py

server.py

@@ -14,6 +14,7 @@ import json
 import os
 import aiohttp  # Necesario para las peticiones HTTP asíncronas
 
+import asyncio
 
 
 
@@ -92,38 +93,37 @@ mcp = FastMCP("OnBase", port=port)
 @mcp.resource(
     uri="info://available_retrievers",
     name="AvailableRetrievers",
-    description="Lista de retrievers con metadatos (para uso interno)",
+    description="Lista de retrievers con metadatos",
     mime_type="application/json"
 )
-def _get_available_retrievers_internal() -> dict:
-    print("\n[DEBUG] Generando recursos disponibles...")
-    available = []
-    
-    # Verificación de datos de entrada
-    print(f"Metadata cargada: {retrievers_metadata.keys()}")
-    
-    for source, indexes in retrievers_metadata.items():
-        print(f"\nProcesando fuente: {source}")
-        for index_name, metadata in indexes.items():
-            print(f"  Procesando índice: {index_name}")
-            available.append({
-                "name": index_name,
-                "source": source,
-                "title": metadata.get("title", "Sin título"),
-                "description": metadata.get("description", "Sin descripción"),
-                "last_updated": metadata.get("last_updated", "Desconocido")
-            })
-    
-    print("\n[DEBUG] Resultado final:", available)
-    return {
-        "retrievers": available,
-        "count": len(available),
-        "status": "success",
-        "timestamp": datetime.datetime.now().isoformat()
-    }
-
-
-
+async def get_available_retrievers() -> dict:  # Ahora es async
+    try:
+        available = []
+        print("Metadata keys:", retrievers_metadata.keys())
+        
+        for source, indexes in retrievers_metadata.items():
+            for index_name, metadata in indexes.items():
+                available.append({
+                    "name": index_name,
+                    "source": source,
+                    "title": metadata.get("title", ""),
+                    "description": metadata.get("description", "")
+                })
+        
+        print("Retrievers disponibles:", available)
+        return {
+            "retrievers": available,
+            "count": len(available),
+            "status": "success"
+        }
+    except Exception as e:
+        print(f"Error generating retrievers: {str(e)}")
+        return {
+            "retrievers": [],
+            "count": 0,
+            "status": "error",
+            "error": str(e)
+        }
 
 @mcp.tool()
 async def list_retrievers(ctx: Context) -> dict:
@@ -144,41 +144,29 @@ async def list_retrievers(ctx: Context) -> dict:
         }
     """
     try:
-        print("\n[DEBUG] Iniciando list_retrievers...")
-        
-        # Verificar si el resource está registrado
-        resources = mcp.list_resources()
-        print("Resources registrados:", resources)
+        # Verificación de recursos registrados
+        resources = await mcp.list_resources()  # Ahora con await
         
         if "info://available_retrievers" not in resources:
             return {
                 "retrievers": [],
                 "count": 0,
                 "status": "error",
-                "error": "Resource no registrado"
-            }
-        
-        # Leer el resource
-        print("Leyendo resource...")
-        resource = await ctx.read_resource("info://available_retrievers")
-        print("Resource obtenido:", resource)
-        
-        if not resource or "retrievers" not in resource:
-            return {
-                "retrievers": [],
-                "count": 0,
-                "status": "error",
-                "error": "Formato de resource inválido"
+                "error": "Resource no encontrado"
             }
+
+        # Lectura del resource
+        resource_contents = await ctx.read_resource("info://available_retrievers")
+        resource = resource_contents[0].content  # Acceder al contenido real
         
         return {
-            "retrievers": resource["retrievers"],
-            "count": resource["count"],
+            "retrievers": resource.get("retrievers", []),
+            "count": resource.get("count", 0),
             "status": "success"
         }
         
     except Exception as e:
-        print(f"[ERROR] en list_retrievers: {str(e)}")
+        print(f"Error en list_retrievers: {str(e)}")
         return {
             "retrievers": [],
             "count": 0,