+ kHjg:a0t$Rt^RIHt^RIt^RIt^RIt^RIt^RIH t H t ^RI t ^RI H t ]P!]4tRtRRlt^t^ t^tRR ltR tR R R R]RR/R//R RR R]RR/RRR//.tR]R&RR.tR]R&]!4tR-RRllt!RR] P<4tRR lt R!R"lt!R#R$lt"R%R&lt#R'R(lt$R)R*lt%R+R,lt&R#).zTelegram network helpers: a hostname-preserving fallback transport (Host + SNI stay api.telegram.org while TCP retries known IPv4 literals) plus DoH-based IP discovery.) annotationsN)IterableOptional)platform_ssl_contextapi.telegram.orgc V^8dQhRRRR/#)error Exceptionreturnstr)formats"P/home/ubuntu/.hermes/hermes-agent/plugins/platforms/telegram/telegram_network.py __annotate__rs$$Y$3$c^RIHpV!\V4RR7# \d\ T4P u#i;i)zIReturn a non-empty, secret-safe exception representation for diagnostics.)redact_sensitive_textT)force) agent.redactrreprr type__name__)r rs& r_describe_transport_errorrs:$6$T%[== $E{###$s  >>cV^8dQhRR/#)rr zlist[tuple[int, int, int]]r )rs"rrr's  &@ rch\P\P^3.p\\RR4;'g\\RR4pV\3\\RR4\ 3\\RR4\ 33F,wr#VfK VP\PW#34K. V#)z``setsockopt`` tuples for httpx ``socket_options``: always SO_KEEPALIVE, plus idle/interval/count when the interpreter exposes those option names. TCP_KEEPIDLEN TCP_KEEPALIVE TCP_KEEPINTVL TCP_KEEPCNT) socket SOL_SOCKET SO_KEEPALIVEgetattr_TCP_KEEPALIVE_IDLE_S_TCP_KEEPALIVE_INTERVAL_S_TCP_KEEPALIVE_COUNTappend IPPROTO_TCP)optionsidleoptvalues rtcp_keepalive_socket_optionsr-'s-3,=,=v?R?RTU+V*WG 6>4 0 Z ZGFOUY4ZD34wvX\7]_x6y t<>RSU  ? NNF..; <U Nrg@urlzhttps://dns.google/resolveparamsnamerAheadersz$https://cloudflare-dns.com/dns-queryAcceptzapplication/dns-jsonz list[dict]_DOH_PROVIDERSz149.154.166.110z149.154.167.220 list[str]SEED_FALLBACK_IPScV^8dQhRR/#)rr str | Noner )rs"rrrAsJJZJrc"^RIHpV!RVR7#))resolve_proxy_urlTELEGRAM_PROXY target_hosts)gateway.platforms.baser;)r>r;s& r_resolve_proxy_urlr@As8 -L IIrc]tRt^FtRt]P !^^R7tRRltRRlt RRlt R R lt R R lt R Rlt RRltRtR#)TelegramFallbackTransportzReach the Bot API via known IPv4 literals first, dual-stack hostname last. Host + SNI stay on api.telegram.org (like ``curl --resolve``) so a blackholed IPv6 AAAA can't pin initialize().)max_connectionsmax_keepalive_connectionscV^8dQhRR/#)r fallback_ips Iterable[str]r )rs"rr&TelegramFallbackTransport.__annotate__Ns::]:rc H\\P\V444Vn\ \ .VPOR7pV'd RV9dW2R&VPRVP4VPR\44W n \P!R/VBVn \P!4VnRVn/Vn\P!4Vn\(Vn\P!4VnRVnR#)r=proxylimitssocket_optionsFNr )listdictfromkeys_normalize_fallback_ips _fallback_ipsr@_TELEGRAM_API_HOST setdefault _POOL_LIMITSr-_transport_kwargshttpxAsyncHTTPTransport_primaryasyncioLock _primary_lock_primary_closed _fallbacks_fallback_lock_UNSET _sticky_ip _sticky_lock _last_failure)selfrFtransport_kwargs proxy_urls&&, r__init__"TelegramFallbackTransport.__init__Ns!$--0G 0U"VW&5G4]$J\J\4]^ (88(1W %##Hd.?.?@##$46R6TU!100D3CD $\\^$?A%lln"(#LLN59rc V^8dQhRRRR/#)ripr r httpx.AsyncHTTPTransportr )rs"rrrHasc.Frc H"VP;_uu_4GRjxL VPPV4pVf/\P!R/VP BpW PV&TuuRRR4GRjxL #LeL +GRjxL 'giR#;i5i)Nr )r^r]getrVrWrU)rcri transports&& r _get_fallback'TelegramFallbackTransport._get_fallbackasm&&&&++B/I !44Nt7M7MN &/# '&&&&&&sKB"BB"AB. B";B<B"B"B B B B  B"c V^8dQhRRRR/#)rrmrjr Noner )rs"rrrHis P P.F P4 Prc "VP;_uu_4GRjxL VP'gWPJdRRR4GRjxL R#\P!R/VP BVnRRR4GRjxL VP 4GRjxL R#LLXL# +GRjxL 'giL:;iL( \d"p\PRT4Rp?R#Rp?ii;i5i)Nz.[Telegram] Error closing primary transport: %sr ) r[r\rXrVrWrUacloser loggerdebug)rcrmexcs&& r_reset_primary(TelegramFallbackTransport._reset_primaryis%%%%###y 'E&%%"44Nt7M7MNDM&% P""$ $ $ &%%% % P LLI3 O O PsC7B$C7#B* C7 B&C7%B*9 C7B(C7 CCC"C7&C7(C7*C 0B31 C <C >C7C C4C/)C7/C44C7c V^8dQhRRRR/#)rrir r rqr )rs"rrrHtsXXXXrc "VP;_uu_4GRjxL VPPVR4pRRR4GRjxL XfR#VP4GRjxL R#LQL' +GRjxL 'giL>;iL& \d"p\ P RY4Rp?R#Rp?ii;i5i)a+Discard a failed fallback pool: a peer-closed connect leaves a CLOSE_WAIT socket in it, and the poisoned pool would leak one fd per retry. Retaining the poisoned pool leaks one descriptor per retry until the process hits its file limit and can no longer accept connections or resolve DNS (#63311). Nz2[Telegram] Error closing fallback transport %s: %s)r^r]poprsr rtru)rcrirmrvs&& r_reset_fallback)TelegramFallbackTransport._reset_fallbackts&&&&++B5I'&    X""$ $ $ '&&& % X LLMr W W XsB>A-B>A1 B>A/ B>B&B 'B+B>/B>1B 7A:8 B B B> B B;B60B>6B;;B>cV^8dQhRR/#)rr zlist[Optional[str]]r )rs"rrrHs   3 rc a.oVP\Jd5SPVPfRM\VP44SP V3RlVP 44RS9dSPR4S#)uSticky path first, then IPv4 literals, dual-stack hostname last (a blackholed IPv6 path never errors — Happy Eyeballs waits on AAAA until the OS TCP timeout and can pin the loop).Nc38<"TFqS9gK VxK R#5iNr ).0riorders& r ;TelegramFallbackTransport._attempt_order..sH"4B%RR"4s )r`r_r'r extendrQ)rcrs&@r_attempt_order(TelegramFallbackTransport._attempt_ordersg&( ??& ( LL!8c$//>R S H$"4"4HH u  LL  rc V^8dQhRRRR/#)rrequest httpx.Requestr zhttpx.Responser )rs"rrrHs11-1N1rc "VPP\8wgVP'g$VPP V4GRjxL #RpVP 4EFPpVfTM \W4pVf VPMVPV4GRjxL pVP V4GRjxL pVPe<VPwrxRVn \PRT;'g\VV4VP\JgVPV8wdVP;_uu_4GRjxL VP\JgVPV8wd8W0n Ve.Ve\PM\Pp V !RV4RRR4GRjxL Vu# Vf \+R4hVhEL}EL0ELLL& +GRjxL 'giL=;i \ Edkp T p\#T 4'ghT;'g\p \%T 4pY3Tn TP\JdY0P8XdTP;_uu_4GRjxL TP\Jd9TPT8Xd(\Tn \PRTeTMR4RRR4GRjxL M +GRjxL 'giM;iTf8TP'T4GRjxL \PRT4Rp ? EK\PRY84TP)T4GRjxL Rp ? EKRp ? ii;i5i)NzF[Telegram] Telegram API transport recovered via %s after %s failed: %su][Telegram] Using sticky IPv4 Telegram API path %s (dual-stack hostname tried last — #87015)zW[Telegram] Sticky Telegram path %s failed; re-walking IPv4 literals before the hostnamerz7[Telegram] Dual-stack api.telegram.org path failed (%s)z-[Telegram] IPv4 Telegram API IP %s failed: %sz=All Telegram fallback IPs exhausted but no error was recorded)r.hostrRrQrXhandle_async_requestr_rewrite_request_for_iprnrbrtinfor`r_rawarningr _is_retryable_connect_errorrrwr| RuntimeError) rcr last_errorri candidatermresponse failed_pathfailurelogrvpaths && rr.TelegramFallbackTransport.handle_async_requests ;;  1 19K9K9K;;GDD D'+ %%'B#%:3J73WI)+ t?Q?QRT?U9UI' !*!?!? !JJ%%1+/+=+=(K)-D&KK`000#  ??f,20E#0000??f428M.0O!~8B8NfnnTZT_T_ #%DFH!I 10  +(V  ^_ __E:VJ 1000  2377///3C8&*_"??&0R??5J#0000??&8T__PR=R.4DO"NN y&(n:LN 100000 :--i888NN#\^efNPR\**2...) s)1M1M1GAM1"G#M1(G8<G=?G8=A G8G G8 AG( G83G4G89M1M1G8G8G8G5 "G%# G5 .G5 0G88 M.M)!AM)7I: 8M)D5 D,D D,D* D,*D,,D 2C53 D >D D, D, D,D' D D' D' " D,) rQr^r]rbrXr\r[r`rarUN)r __module__ __qualname____firstlineno____doc__rVLimitsrTrfrnrwr|rrrs__static_attributes__r rrrBrBFsEd <<QOL:& PX 1f % %rrBc V^8dQhRRRR/#)rrrGr r5r )rs"rrrsMirc(.pVFp\V4P4pV'gK&\P!V4pTP^8wd\ P RT4KfTP'g7TP'g%TP'gTP'd\ P RT4KTP\T44K V# \d\ P RT4EK i;i)z)Ignoring invalid Telegram fallback IP: %rz*Ignoring non-IPv4 Telegram fallback IP: %sz2Ignoring private/internal Telegram fallback IP: %s) r strip ipaddress ip_address ValueErrorrtrversion is_private is_loopback is_link_localis_unspecifiedr')r normalizedr,rawaddrs& rrPrPsJ%j   '',D <<1  NNG M ___ 0 0 0D4F4F4F$J]J]J] NNOQT U   c$i (   NNF L  sC++!DDc V^8dQhRRRR/#)rr,r8r r5r )rs"rrrs___ _rcXV'd"\RVPR444#.#)c3@"TFqP4xK R#5ir)r)rparts& rr(parse_fallback_ip_env..s"M< H H IH%H>:I=H>> Ic$V^8dQhRRRRRR/#)rrrrir r r )rs"rrr(s&xx]xx xrcLVPP;'g\pVPPVR7pVPP 4pW$R&\ VP4pW%R&\P!VPW4VPVR7#))rr sni_hostname)methodr.r2stream extensions) r.rrR copy_withr2copyrNrrVRequestrr)rri original_hostr.r2rs&& rrr(sKK$$::(:M ++  R  (Coo""$G#FOg(()J!.~ ==CQXQ_Q_lv wwrc V^8dQhRRRR/#)rrvr r boolr )rs"rrr2sGGYG4GrcV\V\P\P34#r)rrVConnectTimeout ConnectError)rvs&rrr2s cE00%2D2DE FFrr)'__conditional_annotations__r __future__rrYrloggingr typingrrrVagent.ssl_verifyr getLoggerrrtrRrr$r%r&r-rr4__annotations__r6objectr_r@AsyncBaseTransportrBrPrrrrrr)rs@rrsX# % 1   8 $'$   ((V=OQWY\4]_hjlm 5x&J\^dfiAjH457 !23DE9E J E% 8 8E%P(_, #FxGr