Update mcp/clients.py

mcp/clients.py

@@ -1,5 +1,4 @@
 # mcp/clients.py
-```python
 import os, httpx
 from functools import lru_cache
 from typing import Any, Dict
@@ -10,7 +9,7 @@ class APIError(Exception):
 class BaseClient:
     def __init__(self, base_url: str, api_key_env: str = None):
         self.base = base_url.rstrip("/")
-        self.key = os.getenv(api_key_env) if api_key_env else None
+        self.key  = os.getenv(api_key_env) if api_key_env else None
         self._client = httpx.AsyncClient(timeout=10)
 
     async def request(self, method: str, path: str, **kwargs) -> Any:
@@ -18,13 +17,13 @@ class BaseClient:
         headers = kwargs.pop("headers", {})
         if self.key:
             headers["Authorization"] = f"Bearer {self.key}"
-        response = await self._client.request(method, url, headers=headers, **kwargs)
+        resp = await self._client.request(method, url, headers=headers, **kwargs)
         try:
-            response.raise_for_status()
+            resp.raise_for_status()
         except httpx.HTTPStatusError as e:
-            raise APIError(f"{response.status_code} @ {url}") from e
-        content_type = response.headers.get("Content-Type", "")
-        return response.json() if content_type.startswith("application/json") else response.text
+            raise APIError(f"{resp.status_code} @ {url}") from e
+        ct = resp.headers.get("Content-Type", "")
+        return resp.json() if ct.startswith("application/json") else resp.text
 
     async def close(self):
-        await self._client.aclose()
+        await self._client.aclose()