~tj{*UddlZddlZddlZddlZddlmZmZmZddlm Z m Z dZ ddl Z e e jdZn#e$rdZ dZYnwxYwejejzZejejzZejZe edr eejzZejd kZd ed efd ZGd de ZGdde Z GddZ!e"e ezZ#ere neZ$e#e%d<dS)N)AnyFinalOptional)AbstractResolver ResolveResult)ThreadedResolver AsyncResolverDefaultResolver getaddrinfoFAI_MASKwin32hostreturncfto*|ddkS)N. localhost) _IS_WINDOWSrstripcasefold)rs N/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/aiohttp/resolver.py_is_windows_localhostrs*  E4;;s++4466+EEc zeZdZdZd dejdzddfdZdejfde de d ej de e fd Zd d ZdS)r zThreaded resolver. Uses an Executor for synchronous getaddrinfo() calls. concurrent.futures.ThreadPoolExecutor is used by default. Nlooprc:|ptj|_dSN)asyncioget_running_loop_loop)selfrs r__init__zThreadedResolver.__init__(s7W577 rrrportfamilyc K |j||tj|td{V}nT#tj$rBt |s|j||tj|dd{V}YnwxYwg}|D]\}}}}}|tjkrct|dkr,|dr9|j |td{V\} } t| }n%|dd\} }n|tj ksJ|\} }| t|| |||t|S)N)typer$flagsrhostnamerr#r$protor')r r socket SOCK_STREAM_AI_ADDRCONFIGgaierrorrAF_INET6len getnameinfo_NAME_SOCKET_FLAGSintAF_INETappendr_NUMERIC_SOCKET_FLAGS) r!rr#r$infoshosts_r,address resolved_host_ports rresolvezThreadedResolver.resolve+s *00'$ 1EE   (.. *00' 1EEE &(,1   (FAua((w<ABB B7W577 48   6 #/@@@DN F+-- 33D$*EEt~77 43DLLL 4 4rrrr#r$c HK |j||tj|td{V}nY#t jj$rBt|s|j||tj|dd{V}YnwxYwnT#t jj$r=}t|j dkr |j dnd}td||d}~wwxYwg}|j D]}|j } |jtjkrt| dkr[| drS|j| ddg| ddRt$d{V} | j} n^| dd} | d}n:|jtjksJ| dd} | d}|t-|| ||jdt.|stdd|S)N)r#r&r$r'rrDNS lookup failedr(asciir*)rVr r-r.r/rRerrorDNSErrorrr2rNOSErrornodesaddrr$r1r3decoder4noder6r7rr8) r!rr#r$respexcmsgr:rdr<resultr=s rr?zAsyncResolver.resolves . !^77+!( 8<(   ,T22!^77+! 8 |$ . . .!$SX!!3!3#(1++9LC$$$# - .&(J  DGKyG{fo--w<#=#= **733BgabbkBB*$$F%+KMM$+AJ$5$5g$>$>M"1:DD{fn4444 ' 1 1' : : qz LL!&;/      5$ 344 4 s34:BAB BBBC%(8C  C%c K|tjkrdnd} |j||d{V}nT#tjj$r=}t|jdkr |jdnd}td||d}~wwxYwg}|D]-} | || j ||dtj d.|stdd|S)NAAAAArr\rr*) r-r1rVqueryrRr^r_r2rNr`r7rAI_NUMERICHOST) r!rr#r$qtypererfrgr:rrs rrZz!AsyncResolver._resolve_with_querys"(6?!:!:vv .--dE::::::::DD|$ . . .!$SX!!3!3#(1++9LC$$$# - .  B LL $G $#2      5$ 344 4 s!:B 8BB cK|jr0|j||jd|_d|_dS|j|jd|_dSr)rTrelease_resolverr rVcancelrBs rrCzAsyncResolver.closesd =  M * *4 < < < DM!DN F > % N ! ! # # #rrrD)rErFrGrHrrIrr"r-r6rJr5rKrLrr?dictrZrCrArrr r fsCC2644'$.44 4  44444&'v~;;;";060D; m ;;;;|&'fn"03 d38n :      rr ceZdZUdZdZeded<d fd ZddZddd e j dd fd Z ddd e j ddfd Z xZ S)rWzManager for aiodns.DNSResolver objects. This class manages shared aiodns.DNSResolver instances with no custom arguments across different event loops. N _instancerc|j?t||_|j|jSr)rusuper__new___init)cls __class__s rrxz_DNSResolverManager.__new__s> = !GGOOC00CM M   ! ! !}rc6tj|_dSr)weakrefWeakKeyDictionary _loop_datarBs rryz_DNSResolverManager._inits  % ' ' rclientr rzaiodns.DNSResolverc||jvr5tj|}tj}||f|j|<n|j|\}}|||S)a&Get or create the shared aiodns.DNSResolver instance for a specific event loop. Args: client: The AsyncResolver instance requesting the resolver. This is required to track resolver usage. loop: The event loop to use for the resolver. )r)rrRrUr}WeakSetadd)r!rrresolver client_sets rrXz _DNSResolverManager.get_resolversq t & &)t444H9@9J9JJ%-z$:DOD ! !$(?4#8 Hj vrc|j|}|dS|\}}|||s |||j|=dSdS)zRelease the resolver for an AsyncResolver client when it's closed. Args: client: The AsyncResolver instance to release. loop: The event loop the resolver was using. N)rgetdiscardrr)r!rrcurrent_loop_datarrs rrqz$_DNSResolverManager.release_resolvers{!O//55  $ F0*6""" &#!!!%%% & &r)rrWrD)rErFrGrHrur__annotations__rxryrrIrXrq __classcell__)r{s@rrWrWs 26Ix-.555 ((((%-4-F .&%&-4-F& &&&&&&&&rrWr )&rr-sysr}typingrrrabcrr__all__rRrYrUaiodns_default ImportErrorrmAI_NUMERICSERVr8NI_NUMERICHOSTNI_NUMERICSERVr4 AI_ADDRCONFIGr/r platformrrJboolrr r rWr& _DefaultTyper rrArrrs ''''''''''00000000 BMMMWV/??NN FNNN -0EE*V-BB% 769%fn$Nlg% FFFFFFB B B B B 'B B B J@@@@@$@@@F@&@&@&@&@&@&@&@&FM$445 1? U EUUUUUUs= A A