+\h[#hdZddlZddlZddlZddlZddlZddlZddlZejdk(Z dZ GddZ dZ Gdd ejjZGd d ejj Zej"j%d rgddlZddlZddlZddlZej.Zej2j&j4Zdd lmZmZmZGddeZ GddejBZ"nejjFZ"GddejjHZ$y)zasyncio library query supportNwin32cr tjS#t$rtjcYSwxYwN)asyncioget_running_loopAttributeErrorget_event_loopW/root/niggaflix-v3/playground/venv/lib/python3.12/site-packages/dns/_asyncio_backend.py_get_running_loopr s4('')) (%%''(s 66c0eZdZdZdZdZdZdZdZy)_DatagramProtocolc d|_d|_yr) transportrecvfromselfs r __init__z_DatagramProtocol.__init__s r c||_yr)r)rrs r connection_madez!_DatagramProtocol.connection_mades "r c|jr9|jjs|jj||fyyyr)rdone set_result)rdataaddrs r datagram_receivedz#_DatagramProtocol.datagram_received s5 ==!3!3!5 MM $ $dD\ 2"6=r c|jr7|jjs|jj|yyyr)rr set_exception)rexcs r error_receivedz _DatagramProtocol.error_received$s1 ==!3!3!5 MM ' ' ,"6=r c|jrE|jjs*| td|jj|yyy#t$r%}|jj|Yd}~yd}~wwxYw)NEOF)rrEOFErrorr)rr es r connection_lostz!_DatagramProtocol.connection_lost(sn ==!3!3!5{3"5/) ++C0"6=  3MM//223s A BA<<Bc8|jjyr)rclosers r r(z_DatagramProtocol.close3s r N) __name__ __module__ __qualname__rrrr!r&r(r r r rrs #3- 1r rcK| tj||d{S|d{S7#tj$r!tjj |wxYw7=w)N)timeout)rwait_for TimeoutErrordns exceptionTimeout) awaitabler-s r _maybe_wait_forr47sh 9 )))W== = >## 9--'''8 8 9s/A)0.0A)A'A)04A$$A)cBeZdZfdZdZdZdZdZdZdZ xZ S)DatagramSocketc^t||tj||_||_yr)superrsocket SOCK_DGRAMrprotocol)rfamilyrr; __class__s r rzDatagramSocket.__init__Bs& !2!23"  r cXK|jj||t|Swr)rsendtolen)rwhat destinationr-s r r?zDatagramSocket.sendtoGs$ dK04ys(*c(Ktj} |jjJ||j_t ||d{|j d|j_S7%#d|j_wxYwwr)r create_futurer;rr4result)rsizer-rs r rzDatagramSocket.recvfromLsw "002 *==))1 11%)DMM "!$0 0 0;;=%)DMM " 1&*DMM "s.B8A<A:A<(B:A<<BBc@K|jjywr)r;r(rs r r(zDatagramSocket.closeWs c@K|jjdSwNpeernamerget_extra_infors r getpeernamezDatagramSocket.getpeernameZ~~,,Z88rHc@K|jjdSwNsocknamerLrs r getsocknamezDatagramSocket.getsockname]rOrHcKtwrNotImplementedErrorrr-s r getpeercertzDatagramSocket.getpeercert`s !! ) r)r*r+rr?rr(rNrSrX __classcell__r=s@r r6r6As&!  *99"r r6cBeZdZfdZdZdZdZdZdZdZ xZ S) StreamSocketc^t||tj||_||_yr)r8rr9 SOCK_STREAMreaderwriter)rafr`rar=s r rzStreamSocket.__init__es& V//0  r cK|jj|t|jj|d{S7wr)rawriter4drain)rrAr-s r sendallzStreamSocket.sendalljs8 $$T[[%6%6%8'BBBBsAA A A chKt|jj||d{S7wr)r4r`read)rrFr-s r recvzStreamSocket.recvns($T[[%5%5d%;WEEEEs )202c@K|jjywr)rar(rs r r(zStreamSocket.closeqs rHc@K|jjdSwrJrarMrs r rNzStreamSocket.getpeernamet{{))*55rHc@K|jjdSwrQrlrs r rSzStreamSocket.getsocknamewrmrHc@K|jjdSw)NpeercertrlrWs r rXzStreamSocket.getpeercertzrmrH) r)r*r+rrfrir(rNrSrXrZr[s@r r]r]ds( CF666r r]doh)_compute_times_expiration_for_this_attempt _remainingc8eZdZfdZ ddZ ddZdZxZS)_NetworkBackendczt|||_||_||_||_|dk7r t dy)Nrz9the asyncio transport for HTTPX cannot set the local port)r8r _local_port _resolver_bootstrap_address_familyrV)rresolver local_portbootstrap_addressr<r=s r rz_NetworkBackend.__init__sH G  )D %DN&7D #!DLQ)Or cKg}t|\}}tjj|r|j |n|j |j |j nnt |}|j} |rtjj|} |jj|| |d{} | j}|D]d} td|} t | }tj|5tj| ||d{} dddt! cSt$j&77,#1swY+xYw#t"$rYwxYww)N)r<lifetimeg@) remote_host remote_port local_host)rrr0inet is_addressappendrzrtr{af_for_addressry resolve_name addressesrsanyio fail_after connect_tcp_CoreAnyIOStream Exceptionhttpcore ConnectError)rhostportr- local_addresssocket_optionsr_ expirationr<answersaddressattempt_expirationstreams r rz_NetworkBackend.connect_tcps`I*73MAzxx""4(  &((4  !8!89$Z0  XX44]CF $ ; ;'!<!$--/ $  )Ec:)V&();eZdZdddejdfd ZxZS)_HTTPTransportrN)r}r~r|r<c| |ddl}|jj}t||i|t |||||j _y)Nr)dns.asyncresolver asyncresolverResolverr8rrv_pool_network_backend) rr}r~r|r<argskwargsr0r=s r rz_HTTPTransport.__init__sU$5$=(,,557 G d -f -*9*&7+DJJ 'r )r)r*r+r9 AF_UNSPECrrZr[s@r rrs!"##   r rc>eZdZdZ ddZdZdZdZdZy) Backendcy)Nrr rs r namez Backend.namesr Nc Kt} |tjk(r[tr#|!tj j |df}| jt||||d{\} } t|| | S|tjk(rQ| tdttj|d|d||||||d{\} } t|| | St!dd|z77'w)Nr)r<proto remote_addrz'destination required for stream sockets)sslr<r local_addrserver_hostnamezunsupported socket ztype )r r9r: _is_win32r0r any_for_afcreate_datagram_endpointrr6r_ ValueErrorr4ropen_connectionr]rV)rrbsocktypersourcerBr- ssl_contextrlooprr;rws r make_socketzBackend.make_sockets!" v(( (V^((--b115(,(E(E!' )F)# Ix""i: : ++ +"!!JKK*''NN#%$3  FQ Aq) )! !eH:$6 6  5# s%A$C4&C0'A#C4 C2 &C42C4cJKtj|d{y7wr)rr)rintervals r rz Backend.sleep smmH%%%rcy)NFr rs r datagram_connection_requiredz$Backend.datagram_connection_required sr ctSr)rrs r get_transport_classzBackend.get_transport_classsr c6Kt||d{S7wr)r4)rr3r-s r r.zBackend.wait_fors$Y8888s )rNNNNN) r)r*r+rrrrrr.r r r rrs5- ^&9r r)%__doc__rr9sysdns._asyncbackendr0 dns._features dns.exceptiondns.inetplatformrr rr4 _asyncbackendr6r] _featureshaverrhttpcore._backends.anyiohttpxAsyncNetworkBackend_CoreAsyncNetworkBackend _backends AnyIOStreamr dns.queryrrrsrtrvAsyncHTTPTransportr NullTransportrr r r rs$  LLG # (> "S&&55 "F63$$1164==e#';;))//;;RR3'23'j11*&&44N=9c''=9r