`gj~ PdZddlmZddlZ ddlZdZdZddZy#e$rdZYwxYw)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@ ctydd}dd}|dt}|dt}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. Nctjj|dj}|s|S t |}|dkDr|S|S#t t f$r|cYSwxYwNr)osenvirongetstripfloat TypeError ValueErrornamedefaultrawvals X/root/.hermes/venv/lib/python3.12/site-packages/gateway/platforms/_http_client_limits.py _env_floatz)platform_httpx_limits.._env_float5scjjnnT2&,,.N *CAgs*7*:& N  AAActjj|dj}|s|S t |}|dkDr|S|S#t t f$r|cYSwxYwr)r r r r intrrrs r_env_intz'platform_httpx_limits.._env_int?scjjnnT2&,,.N c(CAgs*7*:& N r%HERMES_GATEWAY_HTTPX_KEEPALIVE_EXPIRY"HERMES_GATEWAY_HTTPX_MAX_KEEPALIVE)max_keepalive_connectionskeepalive_expiry)rstrrr returnr )rrrrr r)httpx_DEFAULT_KEEPALIVE_EXPIRY_S_DEFAULT_MAX_KEEPALIVELimits)rrr max_keepalives rplatform_httpx_limitsr&+sT }++"/1L,.DM <<"/) )r z'httpx.Limits | None') __doc__ __future__rr r! ImportErrorr"r#r&r'rr,sC8#  ") Es %%