o iZ @s|dZddlmZmZddlZgdZdZdZGdddeZ   dd e e e fdBd ej dBd ej dBd ej fd dZdS)z@Utilities for creating standardized httpx AsyncClient instances.)AnyProtocolN)create_mcp_http_clientMCP_DEFAULT_TIMEOUTMCP_DEFAULT_SSE_READ_TIMEOUTg>@gr@c @sHeZdZ   ddeeefdBdejdBdejdBdejfddZ dS) McpHttpClientFactoryNheaderstimeoutauthreturncCsdS)N)selfrr r r r K/home/ubuntu/.local/lib/python3.10/site-packages/mcp/shared/_httpx_utils.py__call__szMcpHttpClientFactory.__call__NNN) __name__ __module__ __qualname__dictstrhttpxTimeoutAuth AsyncClientrr r r rrsrrr r r cCs\ddi}|durtjttd|d<n||d<|dur||d<|dur&||d<tjdi|S) a Create a standardized httpx AsyncClient with MCP defaults. This function provides common defaults used throughout the MCP codebase: - follow_redirects=True (always enabled) - Default timeout of 30 seconds if not specified Args: headers: Optional headers to include with all requests. timeout: Request timeout as httpx.Timeout object. Defaults to 30 seconds if not specified. auth: Optional authentication handler. Returns: Configured httpx.AsyncClient instance with MCP defaults. Note: The returned AsyncClient must be used as a context manager to ensure proper cleanup of connections. Examples: # Basic usage with MCP defaults async with create_mcp_http_client() as client: response = await client.get("https://api.example.com") # With custom headers headers = {"Authorization": "Bearer token"} async with create_mcp_http_client(headers) as client: response = await client.get("/endpoint") # With both custom headers and timeout timeout = httpx.Timeout(60.0, read=300.0) async with create_mcp_http_client(headers, timeout) as client: response = await client.get("/long-request") # With authentication from httpx import BasicAuth auth = BasicAuth(username="user", password="pass") async with create_mcp_http_client(headers, timeout, auth) as client: response = await client.get("/protected-endpoint") follow_redirectsTN)readr rr r )rrrrr)rr r kwargsr r rrs/rr)__doc__typingrrr__all__rrrrrrrrrr r r rs&