+\h!dZddlZddlZddlZddlZddlZddlZddlZejjdse ddZ ejjZGddej j"ZGdd ej j$Zejjd rcddlZddlZddlZej,Zej0jj2Zdd lmZmZmZGd d eZGddej@Z!nej jDZ!Gddej jFZ#y)z$trio async I/O library query supportNtrioztrio not found or too oldcl|tj|Stjj SN)r move_on_afterdns _asyncbackend NullContexttimeouts T/root/niggaflix-v3/playground/venv/lib/python3.12/site-packages/dns/_trio_backend.py_maybe_timeoutr s.!!'**  ,,..cBeZdZfdZdZdZdZdZdZdZ xZ S)DatagramSocketcdt||jtj||_yr)super__init__familysocket SOCK_DGRAM)selfsock __class__s r rzDatagramSocket.__init__!s# f&7&78 rc8Kt|5|,|jj|d{cdddS|jj||d{cdddS7:7#1swYnxYwtj j |wNr )r rsendsendtor exceptionTimeout)rwhat destinationr s r rzDatagramSocket.sendto%s G $ C"![[--d33 C C"[[//kBB  C C3B  C C mm##$  sH B!A.A*A. BA.A,A. B*A.,A..A73'BcKt|5|jj|d{cdddS7 #1swYnxYwtjj |wr)r rrecvfromrrrrsizer s r r#zDatagramSocket.recvfrom/Y G $ 4--d33 4 43 4 4mm##G#44% A)=;= A)=A'A)c@K|jjywr)rclosers r r)zDatagramSocket.close4s sc>K|jjSwr)r getpeernamer*s r r,zDatagramSocket.getpeername7{{&&((c>K|jjSwr)r getsocknamer*s r r0zDatagramSocket.getsockname:r-r.cKtwrNotImplementedErrorrr s r getpeercertzDatagramSocket.getpeercert=s !! ) __name__ __module__ __qualname__rrr#r)r,r0r5 __classcell__rs@r rr s& 5 ))"rrcDeZdZdfd ZdZdZdZdZdZdZ xZ S) StreamSocketc^t||tj||_||_yr)rrr SOCK_STREAMstreamtls)rrr@rArs r rzStreamSocket.__init__Bs& !3!34 rcKt|5|jj|d{cdddS7 #1swYnxYwtjj |wr)r r@send_allrrr)rr r s r sendallzStreamSocket.sendallGr&r'cKt|5|jj|d{cdddS7 #1swYnxYwtjj |wr)r r@ receive_somerrrr$s r recvzStreamSocket.recvLsY G $ 811$77 8 87 8 8mm##G#44r'cTK|jjd{y7wr)r@acloser*s r r)zStreamSocket.closeQskk  """s (&(cK|jr.|jjjj S|jjj Swr)rAr@transport_streamrr,r*s r r,zStreamSocket.getpeernameTE 88;;//66BBD D;;%%113 3AA!cK|jr.|jjjj S|jjj Swr)rAr@rKrr0r*s r r0zStreamSocket.getsocknameZrLrMcK|jrPt|5|jjd{ddd|jj St 7,#1swY+xYwwr)rAr r@ do_handshaker5r3r4s r r5zStreamSocket.getpeercert`s^ 88( 1kk..000 1;;**, ,% %1 1 1s+A3A'A%A'(A3%A''A0,A3)F) r7r8r9rrDrGr)r,r0r5r:r;s@r r=r=As& 5 5 #4 4 &rr=doh)_compute_times_expiration_for_this_attempt _remainingc8eZdZfdZ ddZ ddZdZxZS)_NetworkBackendcZt|||_||_||_||_yr)rr _local_port _resolver_bootstrap_address_family)rresolver local_portbootstrap_addressrrs r rz_NetworkBackend.__init__ts, G  )D %DN&7D #!DLrc ZKg}t|\}}tjj|r|j |n|j |j |j nnt |}|j} |rtjj|} |jj|| |d{} | j}|D]} tjj| } ||jdk7r||jf} nd} | |f}td|}t |}tj| t j"d| ||d{}t%|j&cSt*j,77.#t($rYwxYww)N)rlifetimerg@)rRrinet is_addressappendrZrTr[af_for_addressrY resolve_name addressesrXrSBackend make_socketrr?_CoreTrioStreamr@ Exceptionhttpcore ConnectError)rhostportr local_addresssocket_optionsrf_ expirationranswersaddressafsourcer!attempt_expirationrs r connect_tcpz_NetworkBackend.connect_tcp{sI*73MAzxx""4(  &((4  !8!89$Z0  XX44]CF $ ; ;'!<!$--/ $ 009B$0D4D4D4I"/1A1A!B!%#*D/K)Ec:)V&();eZdZdddejdfd ZxZS)_HTTPTransportrN)r]r^r\rc| |ddl}|jj}t||i|t |||||j _y)Nr)dns.asyncresolver asyncresolverResolverrrrV_pool_network_backend) rr]r^r\rargskwargsrrs r rz_HTTPTransport.__init__sU$5$=(,,557 G d -f -*9*&7+DJJ 'r)r7r8r9r AF_UNSPECrr:r;s@r rrs!"##   rrc8eZdZdZ ddZdZdZdZy)rgcy)Nrr*s r namez Backend.namesrNc 0Ktjj|||} d} |r#| jt||d{|tjk(s|]d} t |5| j t||d{d} ddd| s tjj||tjk(r t| S|tjk(rAtj| } d} |rd} tj| ||} t#|| | St%dd|z77#1swYxYw#t$r| jwxYw#t$r| j!d{7wxYww)NFTr )server_hostnamezunsupported socket ztype )rrbind_lltupler?r connectrrrrjr)rr SocketStream SSLStreamrIr=r3) rrusocktypeprotorvr!r ssl_contextrsr@ connectedrAs r rhzBackend.make_sockets KK  r8U 3 ffXfb12226---1H! #G,%))H["$=>>> $I%!--// '0 v(( (!!$ $ ++ +&&q)FC!^^ _F  FC0 0! !eH:$6 6  93?%%  GGI  ! --/))s}$F EE&E.E EE*E>A F E/#FEEE EE,,F/F F FFcJKtj|d{y7wrr})rintervals r r~z Backend.sleepsjj"""rctSr)rr*s r get_transport_classzBackend.get_transport_classsrcKt|5|d{cdddS7 #1swYnxYwtjj|wr)r rrr)r awaitabler s r wait_forzBackend.wait_forsP G $ #"? # #" # #mm##$  s# A$"$ A$-'A)rNNNNN)r7r8r9rrhr~rrrrr rgrgs0- ^# rrg)$__doc__rr trio.socketdns._asyncbackendr dns._features dns.exceptiondns.inet _featureshave ImportErrorr ralow_level_address_tuplerrrr=rkhttpcore._backends.triohttpxAsyncNetworkBackend_CoreAsyncNetworkBackend _backends TrioStreamri dns.queryrRrSrTrVAsyncHTTPTransportr NullTransportrgrrr rs+  }}&! 1 22/ 88 + + "S&&55"B%&3$$11%&P==e"';;((--88ORR2&22&h11*&&44N> c''> r