mcp_client.py aktualisiert

mcp_client.py

@@ -1,25 +1,21 @@
-import asyncio
-from mcp import ClientSession, StreamableHTTPTransport
+import requests
+import os
+
+MCP_URL = os.getenv("MCP_URL")
 
 
 class MCPClient:
 
-    def __init__(self, url: str):
-
-        self.url = url
-
-    async def _call(self, tool, args):
-
-        transport = StreamableHTTPTransport(self.url)
-
-        async with ClientSession(transport) as session:
-
-            await session.initialize()
-
-            result = await session.call_tool(tool, args)
-
-            return result
+    def list_tools(self):
+        r = requests.get(f"{MCP_URL}/tools")
+        return r.json()
 
     def call_tool(self, tool, args):
-
-        return asyncio.run(self._call(tool, args))
+        r = requests.post(
+            f"{MCP_URL}/call",
+            json={
+                "tool": tool,
+                "arguments": args
+            }
+        )
+        return r.json()