§ Pòmjd0ãó$—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/thesage/.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ó^—eZdZdZejdd¬¦«Zdd„Zdd„Zdd„Z dd„Z dd„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|¤Ž|_i|_ tj¦«|_d|_tj¦«|_dS)NrÚproxyÚlimits©)ÚlistÚdictÚfromkeysÚ_normalize_fallback_ipsÚ _fallback_ipsrÚ_TELEGRAM_API_HOSTÚ setdefaultÚ_POOL_LIMITSÚ_transport_kwargsÚhttpxÚAsyncHTTPTransportÚ_primaryÚ _fallbacksÚasyncioÚLockÚ_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&)r6r3Úgetr0r1r/)r9r=Ú transports rÚ _get_fallbackz'TelegramFallbackTransport._get_fallbackPsèè€ØÔ&ð ð ð ð ð ð ð ð Øœ×+Ò+¨BÑ/Ô/ˆIØÐ Ý!Ô4ÐNÐN°tÔ7MÐNÐN Ø&/” Ñ#Øð ð ð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð ð ð s>A!Á! A+Á.A+ÚNonecƒó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)r6r3ÚpopÚacloseÚ ExceptionÚloggerÚdebug)r9r=rBÚexcs rÚ_reset_fallbackz)TelegramFallbackTransport._reset_fallbackXs_èè€ðÔ&ð 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|€: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_requestr7ÚappendÚ_rewrite_request_for_iprCr8rIÚwarningrHÚ_is_retryable_connect_errorÚjoinrLÚRuntimeError) r9rMÚ sticky_ipÚ attempt_orderr=Ú last_errorÚ candidaterBÚresponserKs rrSz.TelegramFallbackTransport.handle_async_requestisèè€ØŒ;ÔÕ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Ø "ñôððððñôððððððððððððððððððøøøððððð:Ý—N’NØlØØŸ š $Ô"4Ñ5Ô5ñôðð HHH‘HÝ—’ÐEÀrÈ3ÑOÔOÐOØ×*Ò*¨2Ñ.Ô.Ð.Ð.Ð.Ð.Ð.Ð.Ð.Ø‘øøøøð+ øøøð.ÐÝÐ^Ñ_Ô_Ð_ØÐsfÃ 5EÃ?.D?Ä-EÄ? E Å EÅE Å EÅ IÅ,IÆ .G Æ8IÇ GÇIÇGÇ9IÈ7IÉIcƒófK—|j ¦«ƒd{V—†|j4ƒd{V—†t|j ¦«¦«}|j ¦«ddd¦«ƒd{V—†n#1ƒd{V—†swxYwY|D]}| ¦«ƒd{V—†ŒdS©N)r2rGr6r'r3ÚvaluesÚclear)r9Ú transportsrBs rrGz TelegramFallbackTransport.acloseŸsUèè€ØŒm×"Ò"Ñ$Ô$Ð$Ð$Ð$Ð$Ð$Ð$Ð$ØÔ&ð $ð $ð $ð $ð $ð $ð $ð $Ý˜dœo×4Ò4Ñ6Ô6Ñ7Ô7ˆJØŒO×!Ò!Ñ#Ô#Ð#ð $ð $ð $ñ $ô $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $ð $øøøð $ð $ð $ð $ð$ð %ð %ˆIØ×"Ò"Ñ$Ô$Ð$Ð$Ð$Ð$Ð$Ð$Ð$Ð$ð %ð %s¯ABÂ BÂBN)r!r")r=r>rr?)r=r>rrD)rMrNrrO)rrD)Ú__name__Ú __module__Ú__qualname__Ú__doc__r0ÚLimitsr.r<rCrLrSrGr&rrrr4sŸ€€€€€ððð 5”<°ÈQÐOÑOÔO€Lð+ð+ð+ð+ðððððXðXðXðXð"4ð4ð4ð4ðl%ð%ð%ð%ð%ð%rrrar"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Ú ValueErrorrIrVÚversionÚ is_privateÚis_loopbackÚ is_link_localÚis_unspecifiedrT)raÚ 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)rtcóf—|sgSd„| d¦«D¦«}t|¦«S)Ncó6—g|]}| ¦«‘ŒSr&)rj)Ú.0Úparts rú z)parse_fallback_ip_env..Às €Ð7Ð7Ð7˜dˆTZŠZ‰\Œ\Ð7Ð7Ð7rú,)Úsplitr*)rtÚ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&)ryrvs rú z&_resolve_system_dns..Ès €Ð/Ð/Ð/˜tQ”˜” Ð/Ð/Ð/r)ÚsocketÚgetaddrinfor,ÚAF_INETrHÚ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)rAÚraise_for_statusÚjsonrjrkrlrTrmrHrIrJ)rŠrŒÚresprÚipsÚanswerrurKs 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—)ryÚprŠs €rr{z)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: %srQzPDoH discovery yielded no usable IPs (system DNS: %s); using seed fallback IPs %sÚunknown)r0ÚAsyncClientÚTimeoutÚ_DOH_TIMEOUTr r4Ú ensure_futureÚ to_threadr‰Úgatherr‡Úwait_forÚ isinstancerHrIrJr,r'ÚextendÚaddrTr*rXÚ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$rMrNr=r>có—|jjpt}|j |¬¦«}|j ¦«}||d<t |j¦«}||d<tj |j |||j|¬¦«S)N)rRrRÚsni_hostname)Úmethodr rÚstreamÚ extensions)r rRr,Ú copy_withrÚcopyr(r·r0ÚRequestrµr¶)rMr=Ú original_hostr rr·s rrUrU sŒ€Ø”KÔ$Ð:Õ(:€MØ Œ+× Ò RÐ Ñ (Ô (€CØŒo×"Ò"Ñ$Ô$€GØ#€GˆFOÝgÔ(Ñ)Ô)€JØ!.€Jˆ~ÑÝŒ=ØŒ~ØØØŒ~ØðñôðrrKrHÚboolcóN—t|tjtjf¦«Sr`)r¥r0ÚConnectTimeoutÚConnectError)rKs rrWrW0s€ÝcEÔ0µ%Ô2DÐEÑFÔFÐFrr`)rr)rar"rr)rtrrr)rr€)rŠr‹rŒr(rr)rr)rMrNr=r>rrN)rKrHrr¼)rgÚ __future__rr4rkÚloggingr„Útypingrrr0Ú getLoggerrdrIr,r r Ú__annotations__rrÚAsyncBaseTransportrr*rr‰r—r²rUrWr&rrúrÆsõððððð#Ð"Ð"Ð"Ð"Ð"à€€€ØÐÐÐØ€€€Ø € € € Ø%Ð%Ð%Ð%Ð%Ð%Ð%Ð%à€€€à ˆÔ ˜8Ñ $Ô $€à'Ðð€ð,Ø-°sÐ;Ð;Øððð6Ø-°sÐ;Ð;ØÐ4Ð5ððð €ðððñð"3Ð4EÐ FÐÐFÐFÐFÑFðJðJðJðJðJðq%ðq%ðq%ðq%ðq% Ô 8ñq%ôq%ðq%ðhðððð**ð*ð*ð*ððððððððð46$ð6$ð6$ð6$ðr ð ð ð ð GðGðGðGðGðGr