*Gj&UddlZddlZddlZddlmZmZmZddlmZm Z dZ ddl Z e e j dZn#e$rdZ dZYnwxYwejejzZejejzZejZe edr eejzZGd d eZGd d eZGd dZeeezZereneZeed<dS)N)AnyFinalOptional)AbstractResolver ResolveResult)ThreadedResolver AsyncResolverDefaultResolver getaddrinfoFAI_MASKc 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. Nloopreturnc:|ptj|_dSN)asyncioget_running_loop_loop)selfrs X/home/rurouni/.hermes/hermes-agent/venv/lib/python3.11/site-packages/aiohttp/resolver.py__init__zThreadedResolver.__init__"s7W577 rhostportfamilyc K|j||tj|td{V}g}|D]\}}}}}|tjkrct |dkr,|dr9|j|td{V\} } t| }n%|dd\} }n|tj ksJ|\} }| t|| |||t|S)N)typerflagshostnamerrrprotor)rr socket SOCK_STREAM_AI_ADDRCONFIGAF_INET6len getnameinfo_NAME_SOCKET_FLAGSintAF_INETappendr_NUMERIC_SOCKET_FLAGS) rrrrinfoshosts_r$address resolved_host_ports rresolvezThreadedResolver.resolve%slj,,  # -        &(,1   (FAua((w<ABB B7W577 48   6 #/@@@DN F+-- 33D$*EEt~77 43DLLL 4 4rrrrrc K |j||tj|td{V}nT#t jj$r=}t|j dkr |j dnd}td||d}~wwxYwg}|j D]}|j } |j tjkrt| dkr[| drS|j| ddg| ddRt"d{V} | j} n^| dd} | d}n:|j tjksJ| dd} | d}|t+|| ||j dt,|stdd|S)N)rrrrrDNS lookup failedr rasciir")rMr r%r&r'rIerrorDNSErrorr)rEOSErrornodesaddrrr(r*decoder+noder-r.rr/) rrrrrespexcmsgr1r[r3resultr4s rr6zAsyncResolver.resolveqs  .33'$ 4DD|$ . . .!$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 s49B  8BB c K|tjkrdnd} |j||d{V}nT#tjj$r=}t|jdkr |jdnd}td||d}~wwxYwg}|D]-} | || j ||dtj d.|stdd|S)NAAAAArrSrr") r%r(rMqueryrIrUrVr)rErWr.rAI_NUMERICHOST) rrrrqtyper\r]r^r1rrs rrQz!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)rKrelease_resolverrrMcancelr9s rr:zAsyncResolver.closesd =  M * *4 < < < DM!DN F > % N ! ! # # #rrr;)r<r=r>r?rr@rrr%r-rAr,rBrCrr6dictrQr:r8rrr r UsCC2644'$.44 4  44444&'v~000"0060D0 m 0000f&'fn"03 d38n :      rr ceZdZUdZdZeded<d fd ZddZddd e j dd fd Z ddd e j ddfd Z xZ S)rNzManager 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)rlsuper__new___init)cls __class__s rroz_DNSResolverManager.__new__s> = !GGOOC00CM M   ! ! !}rc6tj|_dSr)weakrefWeakKeyDictionary _loop_datar9s rrpz_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)rvrIrLrtWeakSetadd)rrwrresolver client_sets rrOz _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)rvgetdiscardri)rrwrcurrent_loop_datar{r|s rrhz$_DNSResolverManager.release_resolvers{!O//55  $ F0*6""" &#!!!%%% & &r)rrNr;)r<r=r>r?rlr__annotations__rorprr@rOrh __classcell__)rrs@rrNrNs 26Ix-.555 ((((%-4-F .&%&-4-F& &&&&&&&&rrNr ) rr%rttypingrrrabcrr__all__rIrPrLaiodns_default ImportErrorrdAI_NUMERICSERVr/NI_NUMERICHOSTNI_NUMERICSERVr+ AI_ADDRCONFIGr'r r r rNr _DefaultTyper rr8rrrs ''''''''''00000000 BMMMWV/??NN FNNN -0EE*V-BB% 769%fn$N7 7 7 7 7 '7 7 7 tuuuuu$uuup@&@&@&@&@&@&@&@&FM$445 1? U EUUUUUUs9 AA