§ øžyj¾3ãó$—UdZddlmZddlZddlZddlZddlZddlmZm Z ddl Z eje¦«Z dZdZdedd œid œdedd œdd id œgZded<ddgZded<d/d0d„ZGd„de j¦«Zd1d„Zd2d„Zd3d„Zd4d$„Zd5d%„Zd6d*„Zd7d.„ZdS)8aYTelegram-specific network helpers. Provides a hostname-preserving fallback transport for networks where api.telegram.org resolves to an endpoint that is unreachable from the current host. The transport keeps the logical request host and TLS SNI as api.telegram.org while retrying the TCP connection against one or more fallback IPv4 addresses. é)ÚannotationsN)ÚIterableÚOptionalzapi.telegram.orgg@zhttps://dns.google/resolveÚA)ÚnameÚtype)ÚurlÚparamsÚheadersz$https://cloudflare-dns.com/dns-queryÚAcceptzapplication/dns-jsonz list[dict]Ú_DOH_PROVIDERSz149.154.166.110z149.154.167.220ú list[str]Ú_SEED_FALLBACK_IPSÚreturnú str | Nonecó(—ddlm}|d|¬¦«S)Nr)Úresolve_proxy_urlÚTELEGRAM_PROXY©Útarget_hosts)Úgateway.platforms.baser)rrs úQ/home/ragecks/.hermes/hermes-agent/plugins/platforms/telegram/telegram_network.pyÚ_resolve_proxy_urlr.s+€à8Ð8Ð8Ð8Ð8Ð8ØÐÐ-¸LÐIÑIÔIÐIócóf—eZdZdZejdd¬¦«Zdd„Zdd„Zdd„Z dd„Z dd„Zdd„ZdS)ÚTelegramFallbackTransportadRetry Telegram Bot API requests via fallback IPs while preserving TLS/SNI. Requests continue to target https://api.telegram.org/... logically, but on connect failures the underlying TCP connection is retried against a known reachable IP. This is effectively the programmatic equivalent of ``curl --resolve api.telegram.org:443:``. éé)Úmax_connectionsÚmax_keepalive_connectionsÚfallback_ipsú Iterable[str]cóò—tt t|¦«¦«¦«|_ttg|j¢¬¦«}|r d|vr||d<| d|j¦«||_ tjdi|¤Ž|_tj¦«|_d|_i|_tj¦«|_d|_tj¦«|_dS)NrÚproxyÚlimitsF©)ÚlistÚdictÚfromkeysÚ_normalize_fallback_ipsÚ _fallback_ipsrÚ_TELEGRAM_API_HOSTÚ setdefaultÚ_POOL_LIMITSÚ_transport_kwargsÚhttpxÚAsyncHTTPTransportÚ_primaryÚasyncioÚLockÚ _primary_lockÚ_primary_closedÚ _fallbacksÚ_fallback_lockÚ _sticky_ipÚ_sticky_lock)Úselfr!Útransport_kwargsÚ proxy_urls rÚ__init__z"TelegramFallbackTransport.__init__Bsá€Ý!¥$§-¢-Õ0GÈÑ0UÔ0UÑ"VÔ"VÑWÔWˆÔÝ&Õ5GÐ4]È$ÔJ\Ð4]Ð^Ñ^Ô^ˆ Øð 2˜Ð(8Ð8Ð8Ø(1Ð˜WÑ%Ø×#Ò# H¨dÔ.?Ñ@Ô@Ð@Ø!1ˆÔÝÔ0ÐDÐDÐ3CÐDÐDˆŒ Ý$œ\™^œ^ˆÔØ$ˆÔà?AˆŒÝ%œl™nœnˆÔØ)-ˆŒÝ#œL™NœNˆÔÐÐrÚipÚstrrúhttpx.AsyncHTTPTransportcƒóèK—|j4ƒd{V—†|j |¦«}|€ tjdi|j¤Ž}||j|<|cddd¦«ƒd{V—†S#1ƒd{V—†swxYwYdS)Nr&)r8r7Úgetr0r1r/)r;r?Ú transports rÚ _get_fallbackz'TelegramFallbackTransport._get_fallbackRsèè€ØÔ&ð ð ð ð ð ð ð ð Øœ×+Ò+¨BÑ/Ô/ˆIØÐ Ý!Ô4ÐNÐN°tÔ7MÐNÐN Ø&/” Ñ#Øð ð ð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð ð ð s>A!Á! A+Á.A+rDÚNonecƒó†K—|j4ƒd{V—†|js ||jur ddd¦«ƒd{V—†dStjdi|j¤Ž|_ddd¦«ƒd{V—†n#1ƒd{V—†swxYwY | ¦«ƒd{V—†dS#t$r&}t d|¦«Yd}~dSd}~wwxYw)Nz.[Telegram] Error closing primary transport: %sr&) r5r6r2r0r1r/ÚacloseÚ ExceptionÚloggerÚdebug)r;rDÚexcs rÚ_reset_primaryz(TelegramFallbackTransport._reset_primaryZsèèè€ðÔ%ð Oð Oð Oð Oð Oð Oð Oð OØÔ#ð y¸¼ Ð'EÐ'EØð Oð Oð Oñ Oô Oð Oð Oð Oð Oð Oð Oð Oð Oð Oõ"Ô4ÐNÐN°tÔ7MÐNÐNˆDŒMð Oð Oð Oñ Oô Oð Oð Oð Oð Oð Oð Oð Oð Oð Oð Oð Oð Oð Oð Oð Oð Oð Oð Oøøøð Oð Oð Oð Oð PØ×"Ò"Ñ$Ô$Ð$Ð$Ð$Ð$Ð$Ð$Ð$Ð$Ð$øÝð Pð Pð PÝLŠLÐIÈ3ÑOÔOÐOÐOÐOÐOÐOÐOÐOøøøøð Pøøøs.A"µA"Á" A,Á/A,Á4BÂ CÂB;Â;CcƒóHK—|j4ƒd{V—†|j |d¦«}ddd¦«ƒd{V—†n#1ƒd{V—†swxYwY|€dS | ¦«ƒd{V—†dS#t$r'}t d||¦«Yd}~dSd}~wwxYw)a|Discard a failed fallback pool so its dead sockets are released. A connect that reaches ESTABLISHED and is then closed by the peer leaves its socket in CLOSE_WAIT inside the pool. 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)r8r7ÚpoprHrIrJrK)r;r?rDrLs rÚ_reset_fallbackz)TelegramFallbackTransport._reset_fallbackfs_èè€ðÔ&ð 6ð 6ð 6ð 6ð 6ð 6ð 6ð 6Øœ×+Ò+¨B°Ñ5Ô5ˆIð 6ð 6ð 6ñ 6ô 6ð 6ð 6ð 6ð 6ð 6ð 6ð 6ð 6ð 6ð 6ð 6ð 6ð 6ð 6ð 6ð 6ð 6ð 6øøøð 6ð 6ð 6ð 6àÐØˆFð XØ×"Ò"Ñ$Ô$Ð$Ð$Ð$Ð$Ð$Ð$Ð$Ð$Ð$øÝð Xð Xð XÝLŠLÐMÈrÐSVÑWÔWÐWÐWÐWÐWÐWÐWÐWøøøøð Xøøøs'>¾ AÁAÁA0Á0 B!Á:BÂB!Úrequestú httpx.Requestúhttpx.Responsec ƒóK—|jjtks|js |j |¦«ƒd{V—†S|j}|r|gndg}|r| d¦«|jD]}||kr| |¦«Œd}|D]è}|€|nt||¦«}|€|jn| |¦«ƒd{V—†} | |¦«ƒd{V—†}|i|j|kr^|j 4ƒd{V—†|j|kr"||_t d|¦«ddd¦«ƒd{V—†n#1ƒd{V—†swxYwY|cS#t$r} | }t| ¦«s‚|i||jkr^|j 4ƒd{V—†|j|kr"d|_t d|¦«ddd¦«ƒd{V—†n#1ƒd{V—†swxYwY|€U| |¦«ƒd{V—†t d| d |j¦«¦«Yd} ~ Œ¥t d|| ¦«| |¦«ƒd{V—†Yd} ~ Œâd} ~ wwxYw|€t%d¦«‚|‚)NzQ[Telegram] Primary api.telegram.org path unreachable; using sticky fallback IP %szF[Telegram] Sticky fallback IP %s failed; resetting to primary DNS pathzR[Telegram] Primary api.telegram.org connection failed (%s); trying fallback IPs %sú, z$[Telegram] Fallback IP %s failed: %sz=All Telegram fallback IPs exhausted but no error was recorded)r Úhostr,r+r2Úhandle_async_requestr9ÚappendÚ_rewrite_request_for_iprEr:rJÚwarningrIÚ_is_retryable_connect_errorrMÚjoinrPÚRuntimeError) r;rQÚ sticky_ipÚ attempt_orderr?Ú last_errorÚ candidaterDÚresponserLs rrWz.TelegramFallbackTransport.handle_async_requestws4èè€ØŒ;ÔÕ1Ò1Ð1¸Ô9KÐ1Øœ×;Ò;¸GÑDÔDÐDÐDÐDÐDÐDÐDÐDà”Oˆ Ø d¤o¸Ò&;Ð&;Ø#Ô0ððððððððØœ?¨bÒ0Ð0Ø.0˜DœOÝ"ŸNšNØ sØ "ñôððððñôððððððððððððððððððøøøððððð øÝð ñ ð Ø Ý2°3Ñ7Ô7ðØØ> b¨D¬OÒ&;Ð&;Ø#Ô0ððððððððØœ?¨bÒ0Ð0Ø.2˜DœOÝ"ŸNšNØ hØ "ñôððððñôððððððððððððððððððøøøððððð:Ø×-Ò-¨iÑ8Ô8Ð8Ð8Ð8Ð8Ð8Ð8Ð8Ý—N’NØlØØŸ š $Ô"4Ñ5Ô5ñôðð HHH‘HÝ—’ÐEÀrÈ3ÑOÔOÐOØ×*Ò*¨2Ñ.Ô.Ð.Ð.Ð.Ð.Ð.Ð.Ð.Ø‘øøøøð- øøøð0ÐÝÐ^Ñ_Ô_Ð_ØÐsgÃ 5EÃ?.D?Ä-EÄ? E Å EÅE Å EÅI5Å,I0Æ.GÆ9I0Ç GÇI0ÇGÇAI0È37I0É0I5cƒóÚK—|j4ƒd{V—†d|_|j}ddd¦«ƒd{V—†n#1ƒd{V—†swxYwY| ¦«ƒd{V—†|j4ƒd{V—†t|j ¦«¦«}|j ¦«ddd¦«ƒd{V—†n#1ƒd{V—†swxYwY|D]}| ¦«ƒd{V—†ŒdS)NT) r5r6r2rHr8r'r7ÚvaluesÚclear)r;ÚprimaryÚ transportsrDs rrHz TelegramFallbackTransport.aclose®sèè€ØÔ%ð $ð $ð $ð $ð $ð $ð $ð $Ø#'ˆDÔ Ø”mˆGð $ð $ð $ñ $ô $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $øøøð $ð $ð $ð $ðnŠnÑÔÐÐÐÐÐÐÐØÔ&ð $ð $ð $ð $ð $ð $ð $ð $Ý˜dœo×4Ò4Ñ6Ô6Ñ7Ô7ˆJØŒO×!Ò!Ñ#Ô#Ð#ð $ð $ð $ñ $ô $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $øøøð $ð $ð $ð $ð$ð %ð %ˆIØ×"Ò"Ñ$Ô$Ð$Ð$Ð$Ð$Ð$Ð$Ð$Ð$ð %ð %s1± ;¾;Á)AB;Â; CÃCN)r!r")r?r@rrA)rDrArrF)r?r@rrF)rQrRrrS)rrF) Ú__name__Ú __module__Ú__qualname__Ú__doc__r0ÚLimitsr.r>rErMrPrWrHr&rrrr4s·€€€€€ððð 5”<°ÈQÐOÑOÔO€Lð+ð+ð+ð+ð ðððð Pð Pð Pð PðXðXðXðXð"5ð5ð5ð5ðn %ð %ð %ð %ð %ð %rrrdr"cóà—g}|D]è}t|¦« ¦«}|sŒ& tj|¦«}n+#t$rt d|¦«YŒcwxYw|jdkrt d|¦«ŒŽ|js|j s|j s|jrt d|¦«ŒÆ| t|¦«¦«Œé|S)Nz)Ignoring invalid Telegram fallback IP: %rrz*Ignoring non-IPv4 Telegram fallback IP: %sz2Ignoring private/internal Telegram fallback IP: %s) r@ÚstripÚ ipaddressÚ ip_addressÚ ValueErrorrJrZÚversionÚ is_privateÚis_loopbackÚ is_link_localÚis_unspecifiedrX)rdÚ normalizedÚvalueÚrawÚaddrs rr*r*ºs€Ø€JØð%ð%ˆÝ%‰jŒj×ÒÑ Ô ˆØð Øð ÝÔ'¨Ñ,Ô,ˆDˆDøÝð ð ð ÝNŠNÐFÈÑLÔLÐLØˆHð øøøðŒ<˜1ÒÐÝNŠNÐGÈÑMÔMÐMØØŒ?ð ˜dÔ.ð °$Ô2Dð ÈÔH[ð ÝNŠNÐOÐQTÑUÔUÐUØØ×Ò#˜d™)œ)Ñ$Ô$Ð$Ð$ØÐs¬AÁ%A)Á(A)rxcóf—|sgSd„| d¦«D¦«}t|¦«S)Ncó6—g|]}| ¦«‘ŒSr&)rn)Ú.0Úparts rú z)parse_fallback_ip_env..Òs €Ð7Ð7Ð7˜dˆTZŠZ‰\Œ\Ð7Ð7Ð7rÚ,)Úsplitr*)rxÚpartss rÚparse_fallback_ip_envrƒÏs<€ØðØˆ Ø7Ð7 e§k¢k°#Ñ&6Ô&6Ð7Ñ7Ô7€EÝ" 5Ñ)Ô)Ð)rúset[str]có¢— tjtdtj¦«}d„|D¦«S#t$rt¦«cYSwxYw)zJReturn the IPv4 addresses that the OS resolver gives for api.telegram.org.i»có*—h|]}|dd’ŒS)rrr&)r}rzs rú z&_resolve_system_dns..Ús €Ð/Ð/Ð/˜tQ”˜” Ð/Ð/Ð/r)ÚsocketÚgetaddrinfor,ÚAF_INETrIÚset)Úresultss rÚ_resolve_system_dnsrÖsZ€ðÝÔ$Õ%7¸½f¼nÑMÔMˆØ/Ð/ wÐ/Ñ/Ô/Ð/øÝðððÝ‰uŒuˆˆˆðøøøs‚03³AÁ AÚclientúhttpx.AsyncClientÚproviderr(cƒó`K— | |d|d|d¬¦«ƒd{V—†}| ¦«| ¦«}g}| dg¦«D]~}| d¦«dkrŒ| d d ¦« ¦«} t j|¦«| |¦«Œo#t$rYŒ{wxYw|S#t$r.}t d|d|¦«gcYd}~Sd}~wwxYw)z/Query one DoH provider and return A-record IPs.r r r)r rNÚAnswerréÚdataÚzDoH query to %s failed: %s)rCÚraise_for_statusÚjsonrnrorprXrqrIrJrK)rŽrÚrespr”ÚipsÚanswerryrLs rÚ_query_doh_providerr›ßsgèè€ðØ—Z’ZØUŒO H¨XÔ$6ÀÈÔ@Sð ñ ô ð ð ð ð ð ð ˆð ×ÒÑÔÐØyŠy‰{Œ{ˆØˆØ—h’h˜x¨Ñ,Ô,ð ð ˆFØzŠz˜&Ñ!Ô! QÒ&Ð&ØØ—*’*˜V RÑ(Ô(×.Ò.Ñ0Ô0ˆCð ÝÔ$ SÑ)Ô)Ð)Ø— ’ ˜3‘”øÝð ð ð Øð øøøàˆ øÝðððÝŠÐ1°8¸E´?ÀCÑHÔHÐHØˆ ˆ ˆ ˆ ˆ ˆ øøøøðøøøsB„B4C5Â9)C#Ã"C5Ã# C0Ã-C5Ã/C0Ã0C5Ã5 D-Ã?#D(Ä"D-Ä(D-cƒór‡K—tjtjt¦«¬¦«4ƒd{V—†Šˆfd„tD¦«}tjtjt¦«¦«}tj |ddiŽƒd{V—†}ddd¦«ƒd{V—†n#1ƒd{V—†swxYwYt¦«} tj|t¬¦«ƒd{V—†}t|t¦«r|}n0#t$r#t dt ¦«YnwxYwg}|D],}t|t"¦«r| |¦«Œ-t¦«}g}|D]0} | |vr*| | ¦«| | ¦«Œ1t+|¦«} | r0t dd | ¦«¦«| St d d |¦«pd d t0¦«¦«t#t0¦«S)a-Auto-discover Telegram API IPs via DNS-over-HTTPS. Resolves api.telegram.org through Google and Cloudflare DoH and returns all unique A records. IPs that match the local system resolver are kept rather than excluded: in many networks the system-DNS IP is the most reliable path to api.telegram.org and a transient primary-path failure should be retried against the same address via the IP-rewrite path before the seed list is consulted (#14520). Falls back to a hardcoded seed list only when DoH yields no usable answers. )ÚtimeoutNcó0•—g|]}t‰|¦«‘ŒSr&)r›)r}ÚprŽs €rrz)discover_fallback_ips..s$ø€ÐLÐLÐL¸Õ(¨°Ñ3Ô3ÐLÐLÐLrÚreturn_exceptionsTz5System-DNS resolution for %s did not complete in timez,Discovered Telegram fallback IPs via DoH: %srUzPDoH discovery yielded no usable IPs (system DNS: %s); using seed fallback IPs %sÚunknown)r0ÚAsyncClientÚTimeoutÚ_DOH_TIMEOUTr r3Ú ensure_futureÚ to_threadrÚgatherr‹Úwait_forÚ isinstancerIrJrKr,r'ÚextendÚaddrXr*r\Úinfor)Ú doh_tasksÚsystem_dns_taskrŒÚ system_ipsÚ system_resultÚdoh_ipsÚrÚseenÚ candidatesr?Ú validatedrŽs @rÚdiscover_fallback_ipsr¶ùsîøèè€õÔ ¬µ|Ñ)DÔ)DÐEÑEÔEðKðKðKðKðKðKðKÈØLÐLÐLÐL½^ÐLÑLÔLˆ Ý!Ô/µÔ0AÕBUÑ0VÔ0VÑWÔWˆÝœ¨ ÐJÀTÐJÐJÐJÐJÐJÐJÐJÐJˆðKðKðKñKôKðKðKðKðKðKðKðKðKðKðKðKðKðKðKðKðKðKðKøøøðKðKðKðKõ™5œ5€JðbÝ%Ô.¨ÍÐUÑUÔUÐUÐUÐUÐUÐUÐUˆ Ým¥SÑ)Ô)ð 'Ø&ˆJøøÝðbðbðbÝŠÐLÕN`ÑaÔaÐaÐaÐaðbøøøð€GØ ððˆÝaÑÔð ØNŠN˜1ÑÔÐøõ‘U”U€DØ€JØð"ð"ˆØ Tˆ>ˆ>ØHŠHR‰LŒLˆLØ×Ò˜bÑ!Ô!Ð!øõ(¨ Ñ3Ô3€IàðÝŠÐCÀTÇYÂYÈyÑEYÔEYÑZÔZÐZØÐå ‡K‚KØZØ Š *ÑÔÐ* Ø Š Õ$Ñ%Ô%ñôðõ Õ"Ñ#Ô#Ð#s$¶ABÂ B(Â+B(Â>8C7Ã7*D$Ä#D$rQrRr?r@có—|jjpt}|j |¬¦«}|j ¦«}||d<t |j¦«}||d<tj |j |||j|¬¦«S)N)rVrVÚsni_hostname)Úmethodr rÚstreamÚ extensions)r rVr,Ú copy_withrÚcopyr(r»r0ÚRequestr¹rº)rQr?Ú original_hostr rr»s rrYrY2sŒ€Ø”KÔ$Ð:Õ(:€MØ Œ+× Ò RÐ Ñ (Ô (€CØŒo×"Ò"Ñ$Ô$€GØ#€GˆFOÝgÔ(Ñ)Ô)€JØ!.€Jˆ~ÑÝŒ=ØŒ~ØØØŒ~ØðñôðrrLrIÚboolcóN—t|tjtjf¦«S©N)r©r0ÚConnectTimeoutÚConnectError)rLs rr[r[Bs€ÝcEÔ0µ%Ô2DÐEÑFÔFÐFrrÂ)rr)rdr"rr)rxrrr)rr„)rŽrrr(rr)rr)rQrRr?r@rrR)rLrIrrÀ)rkÚ __future__rr3roÚloggingrˆÚtypingrrr0Ú getLoggerrhrJr,r¤r Ú__annotations__rrÚAsyncBaseTransportrr*rƒrr›r¶rYr[r&rrúrËsõððððð#Ð"Ð"Ð"Ð"Ð"à€€€ØÐÐÐØ€€€Ø € € € Ø%Ð%Ð%Ð%Ð%Ð%Ð%Ð%à€€€à ˆÔ ˜8Ñ $Ô $€à'Ðð€ð,Ø-°sÐ;Ð;Øððð6Ø-°sÐ;Ð;ØÐ4Ð5ððð €ðððñð"3Ð4EÐ FÐÐFÐFÐFÑFðJðJðJðJðJðC%ðC%ðC%ðC%ðC% Ô 8ñC%ôC%ðC%ðLðððð**ð*ð*ð*ððððððððð46$ð6$ð6$ð6$ðr ð ð ð ð GðGðGðGðGðGr