test

app.py

@@ -3,8 +3,8 @@ from openai import OpenAI
 import os
 import asyncio
 from contextlib import AsyncExitStack
-from mcp import ClientSession, HttpServerParameters
-from mcp.client.http import http_client
+from mcp import ClientSession
+from mcp.client.streamable_http import streamablehttp_client  
 
 cle_api = os.environ.get("CLE_API_MISTRAL")
 
@@ -29,31 +29,30 @@ class MCPClientWrapper:
         
         self.exit_stack = AsyncExitStack()
         
-        # Paramètres HTTP MCP
-        server_params = HttpServerParameters(url=server_url)
+        # Utiliser le transport HTTP streamable ou SSE selon ce qui est disponible
+        streams = await self.exit_stack.enter_async_context(streamablehttp_client(url=server_url))
+        # streams va typiquement donner une paire (transport_read, transport_write) ou similaire
+        self.http_read, self.http_write = streams
         
-        http_transport = await self.exit_stack.enter_async_context(http_client(server_params))
-        self.http, self.write = http_transport
-        
-        self.session = await self.exit_stack.enter_async_context(ClientSession(self.http, self.write))
+        self.session = await self.exit_stack.enter_async_context(ClientSession(self.http_read, self.http_write))
         await self.session.initialize()
         
-        response = await self.session.list_tools()
-        self.tools = [{ 
-            "name": tool.name,
-            "description": tool.description,
-            "input_schema": tool.inputSchema
-        } for tool in response.tools]
-        
-        tool_names = [tool["name"] for tool in self.tools]
+        tools_response = await self.session.list_tools()
+        self.tools = [
+            {
+                "name": t.name,
+                "description": t.description,
+                "input_schema": t.inputSchema
+            }
+            for t in tools_response.tools
+        ]
+        tool_names = [t["name"] for t in self.tools]
         return f"Connecté au MCP {server_url}. Outils disponibles : {', '.join(tool_names)}"
 
-# Connexion au MCP HuggingFace
 clientMCP = MCPClientWrapper()
 print(clientMCP.connect("https://huggingface.co/spaces/HackathonCRA/mcp"))
 print(clientMCP.tools)
 
-
 # Chatbot
 def chatbot(message, history):
     # Préparer l’historique