a }3e@sUddlZddlZddlmZmZmZmZmZmZddl m Z ddl m Z dZ z ddlZWneypdZYn0dZGdd d e ZGd d d e ZeeeefZereneZeed <dS) N)AnyDictListOptionalTypeUnion)AbstractResolver)get_running_loop)ThreadedResolver AsyncResolverDefaultResolverFc@s^eZdZdZd eejddddZdej fe e e e e e efddd Zdd d d ZdS)r zThreaded resolver. Uses an Executor for synchronous getaddrinfo() calls. concurrent.futures.ThreadPoolExecutor is used by default. N)loopreturncCst||_dSN)r _loop)selfrrC/home/pi/bot/my_env/lib/python3.9/site-packages/aiohttp/resolver.py__init__szThreadedResolver.__init__r)hostnameportfamilyrc s|jj||tj|tjdIdH}g}|D]\}}}}}|tjkrt|dkrNq(|drxt|tjtj B\} } t | }q|dd\} }n|tj ksJ|\} }| || |||tj tjBdq(|S)N)typerflagsrhostrrprotor)r getaddrinfosocket SOCK_STREAM AI_ADDRCONFIGAF_INET6len getnameinfoNI_NUMERICHOSTNI_NUMERICSERVintAF_INETappendAI_NUMERICHOSTAI_NUMERICSERV) rrrrinfoshosts_raddressrZ_portrrrresolves<       zThreadedResolver.resolvercsdSrrrrrrcloseJszThreadedResolver.close)N)__name__ __module__ __qualname____doc__rasyncioAbstractEventLooprr!r*strr)rrrr2r5rrrrr s ,r c@seZdZdZdeejeeddddZde j fe e e e ee efddd Zde j fe e e e ee efdd d Zdd d dZdS)r z9Use the `aiodns` package to make asynchronous DNS lookupsN)rargskwargsrcOsHtdurtdt||_tj|d|i||_t|jdsD|j|_dS)Nz Resolver requires aiodns libraryr gethostbyname) aiodns RuntimeErrorr rZ DNSResolver _resolverhasattr_resolve_with_queryr2)rrr=r>rrrrQs   zAsyncResolver.__init__r)rrrrc sz|j||IdH}WnNtjjyf}z2t|jdkrD|jdnd}t||WYd}~n d}~00g}|jD]$}| ||||dt j t j Bdqr|std|S)NrDNS lookup failedrr) rBr?r@errorDNSErrorr%r=OSError addressesr+r!r,r-) rrrrrespexcmsgr/r1rrrr2as&    zAsyncResolver.resolvec s|tjkrd}nd}z|j||IdH}WnNtjjyz}z2t|jdkrX|jdnd}t ||WYd}~n d}~00g}|D] } | || j ||dtj dq|st d|S)NZAAAAArrErr) r!r$rBqueryr@rFrGr%r=rHr+rr,) rrrrZqtyperJrKrLr/rrrrrrD{s,   z!AsyncResolver._resolve_with_queryr3cs|jdSr)rBcancelr4rrrr5szAsyncResolver.close)N)r6r7r8r9rr:r;rrr!r*r<r)rrr2rDr5rrrrr Ns&   r r )r:r!typingrrrrrrabcr Zhelpersr __all__r@ ImportErrorZaiodns_defaultr r Z _DefaultTyper __annotations__rrrrs       :Q