o *fj{*@sUddlZddlZddlZddlZddlmZmZmZddlm Z m Z dZ z ddl Z e e jdZWn ey>dZ dZYnwejejBZejejBZejZe edrXeejMZejd kZd ed efd d ZGddde ZGddde Z GdddZ!e"e eBZ#ere neZ$e#e%d<dS)N)AnyFinalOptional)AbstractResolver ResolveResult)ThreadedResolver AsyncResolverDefaultResolver getaddrinfoFAI_MASKwin32hostreturncCsto |ddkS)N. localhost) _IS_WINDOWSrstripcasefold)rrt/var/www/botplatforma_usr/data/www/botplatforma.ilyaolesya.ru/.venv/lib/python3.10/site-packages/aiohttp/resolver.py_is_windows_localhostsrc @s\eZdZdZddejdBddfddZdejfde d e d ej de e fd d Zdd dZdS)rzThreaded resolver. Uses an Executor for synchronous getaddrinfo() calls. concurrent.futures.ThreadPoolExecutor is used by default. NlooprcCs|pt|_dSN)asyncioget_running_loop_loop)selfrrrr__init__(szThreadedResolver.__init__rrportfamilyc sz|jj||tj|tdIdH}Wntjy0t|s|jj||tj|ddIdH}Ynwg}|D]I\}}}}}|tjkrft|dkrHq5|dr]|j |t IdH\} } t | }n|dd\} }n |tj ksmJ|\} }| t|| |||tdq5|S)N)typer flagsrhostnamerrr protor")rr socket SOCK_STREAM_AI_ADDRCONFIGgaierrorrAF_INET6len getnameinfo_NAME_SOCKET_FLAGSintAF_INETappendr_NUMERIC_SOCKET_FLAGS) rrrr infoshosts_r'address resolved_host_portrrrresolve+sX     zThreadedResolver.resolvecsdSrrrrrrclosebszThreadedResolver.closerrN)__name__ __module__ __qualname____doc__rAbstractEventLooprr(r1strr0 AddressFamilylistrr:r<rrrrr!s 7rc @seZdZdZ ddejdBdededdfddZd ej fd e d e d ej de efd dZd ej fd e d e d e de ee effddZdddZdS)r z9Use the `aiodns` package to make asynchronous DNS lookupsNrargskwargsrcOsxtdurtd|p t|_d|_|s|r!tj|i||_dSt|_|j ||j|_t |jds:|j |_ dSdS)Nz Resolver requires aiodns library gethostbyname) aiodns RuntimeErrorrrr_manager DNSResolver _resolver_DNSResolverManager get_resolverhasattr_resolve_with_queryr:)rrrFrGrrrris  zAsyncResolver.__init__rrrr c sz3z|jj||tj|tdIdH}Wntjjy2t|s!|jj||tj|ddIdH}YnwWn"tjjyV}zt |j dkrJ|j dnd}t d||d}~wwg}|j D]]}|j } |jtjkrt | dkr| dr|j| ddg| ddRtIdH} | j} n| dd} | d}n|jtjksJ| dd} | d}|t|| ||jdtdq\|st dd|S)N)rr!r r"rrDNS lookup failedr#asciir%)rMr r(r)r*rIerrorDNSErrorrr-rFOSErrornodesaddrr r,r.decoder/noder1r2rr3) rrrr respexcmsgr5rZr7resultr8rrrr:sn       zAsyncResolver.resolvec s|tjkrdnd}z |j||IdH}Wn"tjjy8}zt|jdkr,|jdnd}t d||d}~wwg}|D]} | || j ||dtj dq=|sUt dd|S)NAAAAArrRrr%) r(r,rMqueryrIrTrUr-rFrVr2rAI_NUMERICHOST) rrrr qtyper[r\r]r5rrrrrrQs.  z!AsyncResolver._resolve_with_querycsF|jr|j||jd|_d|_dS|jdur|jd|_dSr)rKrelease_resolverrrMcancelr;rrrr<s   zAsyncResolver.closerr=)r>r?r@rArrBrrr(r1rCr0rDrErr:dictrQr<rrrrr fsB  > r csneZdZUdZdZeded<dfdd ZdddZd d d e j dd fd dZ d d d e j ddfddZ Z S)rNzManager for aiodns.DNSResolver objects. This class manages shared aiodns.DNSResolver instances with no custom arguments across different event loops. N _instancercs(|jdurt||_|j|jSr)rhsuper__new___init)cls __class__rrrjs  z_DNSResolverManager.__new__cCst|_dSr)weakrefWeakKeyDictionary _loop_datar;rrrrksz_DNSResolverManager._initclientr rzaiodns.DNSResolvercCsJ||jvrtj|d}t}||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)rqrIrLroWeakSetadd)rrrrresolver client_setrrrrOs  z _DNSResolverManager.get_resolvercCsN|j|}|dur dS|\}}|||s%|dur||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)rqgetdiscardrf)rrrrcurrent_loop_datarurvrrrres   z$_DNSResolverManager.release_resolver)rrNr=)r>r?r@rArhr__annotations__rjrkrrBrOre __classcell__rrrmrrNs&   rNr )&rr(sysrotypingrrrabcrr__all__rIrPrLaiodns_default ImportErrorrbAI_NUMERICSERVr3NI_NUMERICHOSTNI_NUMERICSERVr/ AI_ADDRCONFIGr*r platformrrCboolrrr rNr! _DefaultTyper rzrrrrs6       E C