| """Shared HTTP client factory for long-lived platform adapters. |
| |
| httpx's default ``keepalive_expiry`` (5s) lets peer-initiated FIN sit in |
| ``CLOSE_WAIT`` behind transparent proxies (macOS + Cloudflare Warp); across 7 |
| adapters plus LLM/MCP clients that walks into the default 256 fd limit. |
| ``platform_httpx_limits()`` returns tighter ``httpx.Limits``: 10 keepalive |
| connections (platform APIs rarely parallelise beyond this), 2.0s expiry. |
| Override via ``HERMES_GATEWAY_HTTPX_KEEPALIVE_EXPIRY`` / ``HERMES_GATEWAY_HTTPX_MAX_KEEPALIVE``. |
| """ |
|
|
| from __future__ import annotations |
|
|
| import os |
|
|
| try: |
| import httpx |
| except ImportError: |
| httpx = None |
|
|
|
|
| _DEFAULT_KEEPALIVE_EXPIRY_S = 2.0 |
| _DEFAULT_MAX_KEEPALIVE = 10 |
|
|
|
|
| def _positive_env(name: str, default, cast): |
| """``cast(env)`` when set, parseable and > 0; else *default*.""" |
| raw = os.environ.get(name, "").strip() |
| if not raw: |
| return default |
| try: |
| val = cast(raw) |
| except (TypeError, ValueError): |
| return default |
| return val if val > 0 else default |
|
|
|
|
| def platform_httpx_limits() -> "httpx.Limits | None": |
| """``httpx.Limits`` tuned for persistent platform-adapter clients; ``None`` without httpx.""" |
| if httpx is None: |
| return None |
| |
| return httpx.Limits( |
| max_keepalive_connections=_positive_env( |
| "HERMES_GATEWAY_HTTPX_MAX_KEEPALIVE", _DEFAULT_MAX_KEEPALIVE, int), |
| keepalive_expiry=_positive_env( |
| "HERMES_GATEWAY_HTTPX_KEEPALIVE_EXPIRY", _DEFAULT_KEEPALIVE_EXPIRY_S, float), |
| ) |
|
|
