ej?ej@ejAdZBGddZCdS)) annotationsN)CallableIterableIteratorSequence) TracebackType) TYPE_CHECKINGAnyLiteralTypeVaroverload)error)AresHostResultAresQueryAAAAResultAresQueryAResultAresQueryCAAResultAresQueryCNAMEResultAresQueryMXResultAresQueryNAPTRResultAresQueryNSResultAresQueryPTRResultAresQuerySOAResultAresQuerySRVResultAresQueryTXTResult QueryResultconvert_resultz4.0.4) DNSResolverr_Tzpaiodns needs a SelectorEventLoop on Windows. See more: https://github.com/aio-libs/aiodns#note-for-windows-users) AAAAAANYCAACNAMEMXNAPTRNSPTRSOASRVTXT)INCHAOSHSNONEr"cveZdZ dudvd Zdwd ZedxdZejdydZdzdZd{dZ d|dZ d}d!Z e j d~d#Ze ddd+Ze ddd.Ze ddd1Ze ddd4Ze ddd7Ze ddd:Ze ddd=Ze ddd@Ze dddCZe dddFZe dddIZ dddKZ dddMZddPZddSZejddTdTdTfddZZ ddd^ZddaZddbZddgZddhZddiZddjZddkZddlZddsZ ddtZ!dS)rN nameserversSequence[str] | Noneloop asyncio.AbstractEventLoop | Nonekwargsr returnNonec |d|_|ptj|_tr |jJ|dd|dd}||_|jdi|\|_|_ |r||_ t|_ t|_ d|_d|_dS)NT sock_state_cbtimeoutF)_closedasyncioget_event_loopr3r pop_timeout _make_channel _event_thread_channelr1set _read_fds _write_fds_timer)selfr1r3r5r:s @C:\Projects\Historical\venv\Lib\site-packages\aiodns/__init__.py__init__zDNSResolver.__init__Ls  4G244  )9((( ?D)))**Y-- ,>D,>,H,H,H,H)DM  +*D #&55$'EE26  tuple[bool, pycares.Channel]c ~ dtjdd|ji|fS#tj$rQ}tjdkrt d|nt d|Yd}~nd}~wwxYwtjdkrzt|j tj s[ ddl }t|j |j sttn'#t $r}tt|d}~wwxYwt#j|dfd }dtjd||jd|fS)NTr:linuxzFailed to create DNS resolver channel with automatic monitoring of resolver configuration changes. This usually means the system ran out of inotify watches. Falling back to socket state callback. Consider increasing the system inotify watch limit: %szFailed to create DNS resolver channel with automatic monitoring of resolver configuration changes. Falling back to socket state callback: %swin32rfdintreadableboolwritabler6r7cR}|||||dSdSN)_sock_state_cb)rPrRrTthis weak_selfs rIsock_state_cb_wrapperz8DNSResolver._make_channel..sock_state_cb_wrappers<9;;D##B(;;;;; rKF)r9r:r;rPrQrRrSrTrSr6r7)pycaresChannelr@ AresErrorsysplatform_LOGGERwarning isinstancer3r=SelectorEventLoopwinloopLoop RuntimeErrorWINDOWS_SELECTOR_ERR_MSGModuleNotFoundErrorweakrefref)rHr5ereexrZrYs @rIrAzDNSResolver._make_channelas III&III I    |w&&D  @  $ <7 " ": Iw0, , " E!$)W\::A&'?@@@A& E E E"#;<<"D E K%%  < < < < < <go /M      s-A=AA88A=02C## D-DD Sequence[str]c.d|jjDS)NcFg|]}|dddS):rr)rsplit).0ss rI z+DNSResolver.nameservers..s+CCCa  #CCCrKrCserversrHs rIr1zDNSResolver.nameserverssDCT]-BCCCCrKvalueIterable[str | bytes]c||j_dSrVrv)rHrys rIr1zDNSResolver.nameserverss % rKfutasyncio.Future[_T]resultrerrorno int | Nonec|rdS|G|tj|tj|dS||dSrV)done set_exceptionrDNSErrorr\errnostrerror set_result)rHr|r~rs rI _callbackzDNSResolver._callbacksz 88::  F     w (>(>w(G(GHH      NN6 " " " " "rK;tuple[asyncio.Future[_T], Callable[[_T, int | None], None]]c|j}|jr&tj|jj|j|}ntj|j|}||fS)z?Return a future and a callback to set the result of the future.)r3 create_futurerB functoolspartialcall_soon_threadsafer)rHfuturecbs rI_get_future_callbackz DNSResolver._get_future_callbacksf &*Y%<%<%>%>   ;" .BB "4>6::BrzrKasyncio.Future[QueryResult]qtyperQpycares.DNSResultct|rdS|G|tj|tj|dS t||}||dS#tj$r }||Yd}~dSd}~wwxYw)z>Callback for query that converts results to compatible format.N) rrrrr\rrrr)rHr|rr~r convertedexcs rI_query_callbackzDNSResolver._query_callbacks 88::  F     w (>(>w(G(GHH    F &&vu55I NN9 % % % % %~ # # #   c " " " " " " " " " #s!BB7B22B77tuple[asyncio.Future[QueryResult], Callable[..., None]]c|j}|jr'tj|jj|j||}ntj|j||}||fS)z>Return a future and callback for query with result conversion.)r3rrBrrrr)rHrrrs rI_get_query_future_callbackz&DNSResolver._get_query_future_callbacksn/3i.E.E.G.G   H" .$ BB"4#7GGBrzrKIterator[None]c #LK dVdS#tj$r}|rYd}~dS|jr |jdn tj}|t j|tj |Yd}~dSd}~wwxYw)Nr) r\r^rargsr ARES_EFORMERRrrrr)rHr|rrs rI_capture_ares_errorzDNSResolver._capture_ares_errors  EEEEE   xxzz $'8DCHQKK1DE   ugm&<& , AA  A A$$ B.BB6?DDD!asyncio.Future[pycares.DNSResult]c t|}n%#t$r}td||d}~wwxYwd}|4 t|}n%#t$r}td||d}~wwxYw|\}}||5||j||||n|j|||dddn #1swxYwY|S)z:Query DNS records, returning native pycares 5.x DNSResult.rNrrr)rrrrrrrCrrs rI query_dnszDNSResolver.query_dnsDs D&u-II D D D;E;;<.ps*HHH41,,..HHHrKr)namealiases addresses) rrrrr\rrnodescnamesrrr)rHr|rr~rrrs rI_gethostbyname_callbackz#DNSResolver._gethostbyname_callback^s 88::  F     w (>(>w(G(GHH     %%%HH6<HHHI,2MC6=#((tD NND" JJJ     rKfamilysocket.AddressFamilyctjdtd|j}|jr't j|jj|j ||}nt j|j ||}| |5|j |d||dddn #1swxYwY|S)z Resolve hostname to addresses. Deprecated: Use getaddrinfo() instead. This is implemented using getaddrinfo as pycares 5.x removed the gethostbyname method. z8gethostbyname() is deprecated, use getaddrinfo() insteadrrN)rr) rrrr3rrBrrrrrrC getaddrinfo)rHrrr|rs rI gethostbynamezDNSResolver.gethostbynamews&  F     /3i.E.E.G.G   L" ., BB"4#?dKKB  % %c * * N N M % %dD" % M M M N N N N N N N N N N N N N N N sB??CCrportprototypeflags&asyncio.Future[pycares.AddrInfoResult]c |\}}||5|j|||||||dddn #1swxYwY|S)N)rrrrr)rrrCr) rHrrrrrrr|rs rIrzDNSResolver.getaddrinfos++--R  % %c * *   M % % &                   s"AA"Asockaddr+tuple[str, int] | tuple[str, int, int, int]&asyncio.Future[pycares.NameInfoResult]c|\}}||5|j|||dddn #1swxYwY|SNr)rrrC getnameinfo)rHrrr|rs rIrzDNSResolver.getnameinfos ++--R  % %c * * D D M % %h % C C C D D D D D D D D D D D D D D D sAAAr"asyncio.Future[pycares.HostResult]c|\}}||5|j||dddn #1swxYwY|Sr)rrrC gethostbyaddr)rHrr|rs rIrzDNSResolver.gethostbyaddrs++--R  % %c * * ; ; M ' 'r ' : : : ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; sAAAc8|jdSrV)rCcancelrxs rIrzDNSResolver.cancels rKrPrRrSrTc|s|r|rK|j||jj|tj|j||rK|j||jjtj||j ||j | dSdS||jvr4|j ||j |||j vr4|j ||j||js0|j s+|j &|j d|_ dSdSdSdSrV)r3 add_readerrC process_fdr\ARES_SOCKET_BADrEadd add_writerrFrG _start_timerdiscard remove_reader remove_writerr)rHrPrRrTs rIrWzDNSResolver._sock_state_cbs  #x # ' $$ 0"g6M""2&&& ( $$ 0'2I2##B'''{"!!######"T^##&&r*** ''+++T_$$''+++ ''+++N # #K+ ""$$$"  # # # #,+rKc|js|jrE|jtjtj|dSd|_dSrV)rErFrCr r\r r rGrxs rI _timer_cbzDNSResolver._timer_cbs_ > T_  M $ $')@           DKKKrKc|j}| |dks|dkrd}n|dkrd}|j||j|_dS)Nrrg?)r@r3 call_laterrrG)rHr:s rIr zDNSResolver._start_timersR- ?gkkWq[[GG \\Gi**7DNCC rKc|jrdSd|_|j |jd|_|jD]}|j||jD]}|j||j|j|j dS)z:Cleanup timers and file descriptors when closing resolver.NT) r<rGrrEr3rrFrclearrCclose)rHrPs rI_cleanupzDNSResolver._cleanups <  F ; " K   DK. ( (B I # #B ' ' ' '/ ( (B I # #B ' ' ' '   rKcrK|js|j|dS)z Cleanly close the DNS resolver. This should be called to ensure all resources are properly released. After calling close(), the resolver should not be used again. N)r<rCrrrxs rIrzDNSResolver.closes7| # M " " " rKc K|S)z Enter the async context manager.r;rxs rI __aenter__zDNSResolver.__aenter__s  rKexc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | Nonec>K|d{VdS)zExit the async context manager.N)r)rHrrr s rI __aexit__zDNSResolver.__aexit__s.jjllrKcRt|dr|dSdS)z6Handle cleanup when the resolver is garbage collected.rCN)hasattrrrxs rI__del__zDNSResolver.__del__s1 4 $ $  MMOOOOO  rK)NN)r1r2r3r4r5r r6r7)r5r r6rL)r6rn)ryrzr6r7)r|r}r~rrrr6r7)r6r) r|rrrQr~rrrr6r7)rrQr6r)r|r}r6r).)rrrrrrr6r)rrrrrrr6r)rrrrrrr6r)rrrrrrr6r)rrrrrrr6r)rrrrrrr6r)rrrrrrr6r)rrrrrrr6r)rrrrrrr6r)rrrrrrr6r)rrrrrrr6rrV)rrrrrrr6r)rrrrrrr6r) r|rrrr~rrrr6r7)rrrrr6r)rrrrrrrrQrrQrrQr6rr)rrrrQr6r)rrr6r)r6r7r[)r6r)rrrrr r!r6r7)"__name__ __module__ __qualname__rJrApropertyr1setterrrrr contextlibcontextmanagerrr rrrrsocket AF_UNSPECrrrrrWrr rrrr#r&r;rKrIrrKs;-115*2 2 2 2 hDDDXD &&&& # # # # &&&&."$CF5555X5FI8888X8EH7777X7GJ3333X3DG6666X6GJ9999X9DG6666X6EH1111X1EH1111X1EH7777X7EH7777X7 ;?>;?42@(.'74     ####@DDDD*    rKr)D __future__rr=r,rloggingr.r_rrjcollections.abcrrrrtypesrtypingr r r r r r\rcompatrrrrrrrrrrrrrr __version____all__rrh getLoggerr'ra QUERY_TYPE_AQUERY_TYPE_AAAAQUERY_TYPE_ANYQUERY_TYPE_CAAQUERY_TYPE_CNAME QUERY_TYPE_MXQUERY_TYPE_NAPTR QUERY_TYPE_NSQUERY_TYPE_PTRQUERY_TYPE_SOAQUERY_TYPE_SRVQUERY_TYPE_TXTrQUERY_CLASS_INQUERY_CLASS_CHAOSQUERY_CLASS_HSQUERY_CLASS_NONEQUERY_CLASS_ANYrrr;rKrIrKsz"""""" BBBBBBBBBBBBAAAAAAAAAAAAAA"    WT]]@ ' H % %    #  !  !  %    %    !  !  !  !     &   $  " [[[[[[[[[[rK