<0j~ TdZddlmZddlZ ddlZn #e$rdZYnwxYwdZdZd dZdS) u(Shared HTTP client factory for long-lived platform adapters. Gateway messaging platforms (QQ Bot, Feishu, WeCom, DingTalk, Signal, BlueBubbles, WeCom-callback) keep a persistent ``httpx.AsyncClient`` alive for the adapter's lifetime. That amortises TLS/connection setup across many API calls, but it also means the process's file-descriptor pressure is sensitive to how aggressively the pool recycles idle keep- alive connections. httpx's default ``keepalive_expiry`` is 5 seconds. On macOS behind Cloudflare Warp (and other transparent proxies), peer-initiated FIN can sit in ``CLOSE_WAIT`` longer than that before the local socket actually drains — which, multiplied across 7 long-lived adapters plus the LLM client and MCP clients, walks straight into the default 256 fd limit. See #18451. ``platform_httpx_limits()`` returns a tighter ``httpx.Limits`` the adapter factories use instead of the httpx default. The values chosen: * ``max_keepalive_connections=10`` — plenty for any single adapter; platform APIs rarely parallelise beyond this. * ``keepalive_expiry=2.0`` — close idle sockets aggressively so a proxy's lingering CLOSE_WAIT window can't starve the process. Override via ``HERMES_GATEWAY_HTTPX_KEEPALIVE_EXPIRY`` / ``HERMES_GATEWAY_HTTPX_MAX_KEEPALIVE`` env vars when tuning under load. ) annotationsNg@ return'httpx.Limits | None'ctdSd d}dd }|d t}|d t}tj|| S)zReturn ``httpx.Limits`` tuned for persistent platform-adapter clients. Returns ``None`` when httpx isn't importable, so callers can fall back to httpx's built-in default without a hard dependency on this helper being reachable. Nnamestrdefaultfloatrctj|d}|s|S t |}n#t t f$r|cYSwxYw|dkr|n|SNr)osenvirongetstripr TypeError ValueErrorrr rawvals K/home/rurouni/.hermes/hermes-agent/gateway/platforms/_http_client_limits.py _env_floatz)platform_httpx_limits.._env_float5s}jnnT2&&,,.. N **CC:&   NNN Aggss7*AAAintctj|d}|s|S t |}n#t t f$r|cYSwxYw|dkr|n|Sr )rrrrrrrrs r_env_intz'platform_httpx_limits.._env_int?s}jnnT2&&,,.. N c((CC:&   NNN Aggss7*r%HERMES_GATEWAY_HTTPX_KEEPALIVE_EXPIRY"HERMES_GATEWAY_HTTPX_MAX_KEEPALIVE)max_keepalive_connectionskeepalive_expiry)rr r r rr )rr r rrr)httpx_DEFAULT_KEEPALIVE_EXPIRY_S_DEFAULT_MAX_KEEPALIVELimits)rrr! max_keepalives rplatform_httpx_limitsr'+s }t++++++++"z/1LH,.DM <"/)   )rr) __doc__ __future__rrr" ImportErrorr#r$r'r(rr-s8#""""" LLLL EEE"))))))s