hI~#$dZddlZddlZddlZddlZddlZddlZddlZddl m Z m Z m Z m Z mZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlmZddlmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z' ddl(Z(e&rddl,Z,ejZj\Z/dZ0dFdZ1 dFdejdjfd ejhjje6zd e d e7dzd e e8e7ff d Z9 dGdejdjfd e dzd e7dzde:de:de ejvjxejzj|fdzde6dzde:de:de:dejhjjdzd e fdZ? dHdejhjjde@de7dzde8de@dzde8de:de:de:de:dejdjfdzdejdjdzde:d ejhjjfd ZB dIdejhjjde@de7dzde8de@dzde8de:de:de:d!ejdjfdzd"ejdjdzdejdjdzde:d e ejhjje:ffd#ZD dFdejdjd ejhjje6zd e7dzd e e8e7ffd$ZEd%ZF dJdejdjd e7dzde:de ejvjxejzj|fdzde6dzde:d e ejhjje7ffd&ZG dKdejhjjde@de7dzde8de@dzde8de:de:dejdjdzdejdjdzd ejhjjfd'ZH dLdejhjjde@de7dzde8de@dzde8de:de:dejdjdzdejdjdzd)e(jdzd*e@dzd+e:e@zd ejhjjfd,ZJd-e d.d d.fd/ZKdd0dddddd1d(d(ddejejfdejhjjde@de7dzde8de@dzde8de:de:d2e d3d4e@d5e:d+e:e@ze(jzd6e@dzd-e d.d7e8d8ed ejhjjf"d9ZN dMdejhjjde@d:e@de7dzde8de@dzde8de:de:d+e:e@ze(jzdejdjdzd5e:d;ejjdzd ejhjjfd<ZQ dNdejhjjde@de7dzde8de@dzde8de:de:d;ejjdzd+e:e@zdejdjdzd=e@dzd*e@dzd ejhjjfd>ZOd?ejjd@ejdjdejhjjdAe8dzde7dzd e7d e fdBZUdddddde!jdfde@d?ejjdejhjjdzde8de7dzdCe7dzde@dzde8dDe!dejdjdzd dfdEZWy#e)$r ddl*m+Z(YwxYw)OzTalk to a DNS server.N)AnyDictOptionalTuplecast) NullContext) BadResponse HTTPVersionNoDOHNoDOQUDPMode _check_status_compute_times_matches_destination _remaininghave_dohmake_ssl_contextc|s|rF|@|tjk(rd}||fS|tjk(rd}||fStd|||fSy)Nz0.0.0.0z::zunknown address family )socketAF_INETAF_INET6NotImplementedError)afaddressports L/var/www/html/eduruby.in/venv/lib/python3.12/site-packages/dns/asyncquery.py _source_tuplerBsl$ ?V^^##  v&*,CB4*HIIcR|%|stj}t||z dSyNr)timemax) expirationnows r_timeoutr%Rs+))+C:#Q''rsockwhat destinationr#returncKt|tjjr|j }t j }|j ||t||d{}||fS7w)aSend a DNS message to the specified UDP socket. *sock*, a ``dns.asyncbackend.DatagramSocket``. *what*, a ``bytes`` or ``dns.message.Message``, the message to send. *destination*, a destination tuple appropriate for the address family of the socket, specifying where to send the query. *expiration*, a ``float`` or ``None``, the absolute time at which a timeout exception should be raised. If ``None``, no timeout will occur. The expiration value is meaningless for the asyncio backend, as asyncio's transport sendto() never blocks. Returns an ``(int, float)`` tuple of bytes sent and the sent time. N) isinstancednsmessageMessageto_wirer!sendtor%)r&r'r(r# sent_timens rsend_udpr3[s^.$ ++,||~ Ikk$ Xj)-LMMA y> NsA)A6+A4, A6Fignore_unexpectedone_rr_per_rrsetkeyring request_macignore_trailingraise_on_truncation ignore_errorsqueryc Kd} |jdt|d{\} } t|j| ||s@t j} t j j| |||||}| r| | j|s|| | fS7u#t j j$r.}| r&| $| j|j sYd}~܂d}~wt$r| rYwxYww)ajRead a DNS message from a UDP socket. *sock*, a ``dns.asyncbackend.DatagramSocket``. See :py:func:`dns.query.receive_udp()` for the documentation of the other parameters, and exceptions. Returns a ``(dns.message.Message, float, tuple)`` tuple of the received message, the received time, and the address where the message arrived from. rN)r6r7r5r8r9) recvfromr%rfamilyr!r,r- from_wire Truncated is_response Exception)r&r(r#r4r5r6r7r8r9r:r;wire from_address received_timeres r receive_udprIys0 D %)]]5(::N%OO|# KK{4E     %%'!1 /$7 &A. U.u7H7H7K =,//A P{{$$ %))!))+6   sK"C7B4C7%B?C7C49#C"C7!C""C40C72C44C75qwheretimeoutrsource source_portbackendc K|j} t|\}}tjj |}t ||f|}| r t | }no| stjj} t|||}| jr||f}nd}| j|tjd||d{}|4d{}t|| ||d{t||||||j |j"|| | | d{\}}}||z |_| s|j'|st(|cdddd{S777s7D7 #1d{7swYyxYww)aFReturn the response obtained after sending a query via UDP. *sock*, a ``dns.asyncbackend.DatagramSocket``, or ``None``, the socket to use for the query. If ``None``, the default, a socket is created. Note that if a socket is provided, the *source*, *source_port*, and *backend* are ignored. *backend*, a ``dns.asyncbackend.Backend``, or ``None``. If ``None``, the default, then dnspython will use the default backend. See :py:func:`dns.query.udp()` for the documentation of the other parameters, exceptions, and return type of this method. Nr)r/rr,inetaf_for_address_lltupler asyncbackendget_default_backendrdatagram_connection_required make_socketr SOCK_DGRAMr3rIr6macr!rBr )rKrLrMrrNrOr4r5r8r9r&rPr:rD begin_timer#rr(cmstupledtuplesrGrF_s rudprasw8 99;D-g6Z   'BE4="-K 5@5F&&:: ??? K ##@sB B B BcKd}|dkDrL|j|t|d{}|dk(r td|t|z }||z}|dkDrL|S7/w)z|Read the specified number of bytes from stream. Keep trying until we either get the desired amount, or we hit EOF. rrNEOF)recvr%EOFErrorrl)r&countr#r_r2s r _read_exactlyrvUsh A !)))E8J#78 8 85/ !A E !) H 9s&AA,AAcKt|d|d{}tjd|\}t|||d{}tj} tj j |||||} | | fS7m7Bw)zRead a DNS message from a TCP socket. *sock*, a ``dns.asyncbackend.StreamSocket``. See :py:func:`dns.query.receive_tcp()` for the documentation of the other parameters, exceptions, and return type of this method. rjN!Hr6r7r5r8)rvstructunpackr!r,r-r@) r&r#r5r6r7r8ldatalrDrFrGs r receive_tcpr~cs  a4 4E ==u %DQtQ 3 3DIIKM  )'  A }  5 3s"BB,BBABBc K|j} t|\} } |r$|jd{t|} n|tj j |}t|||}||f}| stjj} | j|tjd|||d{} | 4d{}t|| | d{t|| ||j|j |d{\}}|| z |_|j%|st&|cdddd{S7777n7D7#1d{7swYyxYww)aOReturn the response obtained after sending a query via TCP. *sock*, a ``dns.asyncbacket.StreamSocket``, or ``None``, the socket to use for the query. If ``None``, the default, a socket is created. Note that if a socket is provided *where*, *port*, *source*, *source_port*, and *backend* are ignored. *backend*, a ``dns.asyncbackend.Backend``, or ``None``. If ``None``, the default, then dnspython will use the default backend. See :py:func:`dns.query.tcp()` for the documentation of the other parameters, exceptions, and return type of this method. Nr)r/r getpeernamerr,rRrSrrUrVrXr SOCK_STREAMrpr~r6rZr!rBr )rKrLrMrrNrOr5r8r&rPrDr[r#r\rr]r^r_rGrFs rreresc4 99;D-g6Z    5@5FXX $ $U +r6;7&&::E ? E( E  E( EE +E E )E4 E(EE( E( E( EEE(E%E E%!E(T ssl_contextserver_hostnameverifyc bKt|\} }|r t|}n| t| | dudg} tjj |}t |||}||f}| stjj} | j|tjd|||| | d{}|4d{}t|}t|||||||||| d{}tj}|| z |_|cdddd{S7g7^797 #1d{7swYyxYww)aReturn the response obtained after sending a query via TLS. *sock*, an ``asyncbackend.StreamSocket``, or ``None``, the socket to use for the query. If ``None``, the default, a socket is created. Note that if a socket is provided, it must be a connected SSL stream socket, and *where*, *port*, *source*, *source_port*, *backend*, *ssl_context*, and *server_hostname* are ignored. *backend*, a ``dns.asyncbackend.Backend``, or ``None``. If ``None``, the default, then dnspython will use the default backend. See :py:func:`dns.query.tls()` for the documentation of the other parameters, exceptions, and return type of this method. Ndotr)rrrr,rRrSrrUrVrXrrr%rer!)rKrLrMrrNrOr5r8r&rPrrrr[r#r\rr]r^r_rfend_times rtlsrsP< .g6Z 5@5F  *6?$3NQVPWXK XX $ $U +r6;7&&::tjfv}|tj@tjfv}tjBjE}|d}d }n|}|}|r tG|}n7|jI|||| || | |}t9j:||| |}|4d{}| rT|jKd tMtO|d|jQ|jS|||||d{}nctUjV|jYd}|j[} |jQ|j]||d| i||d{}dddd{j^dks|j^dkDr't|d|j^d|j`tjbje|j`|jf|jh||}!|jjjm|!_7|jq|!str|!S#t$rd}YwxYw7G777S77#1d{7swYxYww)aReturn the response obtained after sending a query via DNS-over-HTTPS. *client*, a ``httpx.AsyncClient``. If provided, the client to use for the query. Unlike the other dnspython async functions, a backend cannot be provided in this function because httpx always auto-detects the async backend. See :py:func:`dns.query.https()` for the documentation of the other parameters, exceptions, and return type of this method. Nzhttps://:z https://[z]:zno hostname in URL sni_hostnamez8client parameter must be a dns.quic.AsyncQuicConnection.)rr connectionz-client parameter must be an httpx.AsyncClientacceptzapplication/dns-messager) local_addresshttp1http2r local_portrrr?)rrr transport)z content-typezcontent-length)headerscontent extensions=r,)rparamsri+z responded with status code z Response body: ry):r,rRrS ValueError is_addressrrrurllibparseurlparsehostnamerr H3DEFAULTrr resolve_namerandomchoicelist addressesr+quicAsyncQuicConnection_http3r httpx AsyncClientr/H1H2rUrVrget_transport_classupdatestrrlwait_forrbase64urlsafe_b64encoderstripdecodeget status_coderr-r@r6r7elapsed total_secondsr!rBr )"rKrLrMrrNrOr5r8rrrrrrr?rrurlrparsedanswersrDrh1h2rPrrr\r the_clientrftwirerGs" rhttpsrs< XX $ $U + C ~#((--e4  UG1TF4&1C 6?? "eWBtfTF3CJ &&s+ ?? "12 2 88  v / & )/J~ & ;; ";;D{~~% +++H  $*84H??. ..$11G!' d73D3D3F.G H  * CHH00 WX X~FCHH4P4P!QQQ              j):):;HII 99;D23G +..+*=*=> >B +..+*=*=> >B224G ~     5@5H1G//1'!/    Bv Z  NN$=&)#d)n  %--# )   H++D188>DKKME$--#!5>)  H-Dc!X%9%9C%?g1(2F2F1G 0 03 5    MM)'  A   + + -AF ==  H[  8  n-sS)R2ES)=S>B#S)!S"DS)%S &S))AS:S ;A#SSS# S).S/CS)2 S=S)SS)S) S) SSS)S&S S&"S)rrc :Ktjjs tdtj j |} | j}|J| j | j}d|_ |j}| r5tjj}tjj}n"tjj| \}}|4d{}||| |d4d{}| r| }n|j||||}t|\}}|j|d{}|4d{|j!||| |j#t%|d{}t'|j)||dddd{t+j*}dddd{tj,j/||j0|j2||}dddd{t5z d_|j7|st8|S7^7L7777#1d{7swYxYw7#1d{7swYxYw7m#1d{7swY}xYww)Nz DNS-over-HTTP3 is not available.rT) verify_mode server_nameh3ry)r,r have_quicr rrrrridr/ null_factoryfactories_for_backendconnectr make_streamsend_h3receiverrrr!r-r@r6r7r"rBr )rKrLrrMrrNrOr5r8rrPrr url_partsrrDcfactorymfactorycontext the_managerthe_connectionstartr#streamfinishrGs rrrsM 88  677 %%c*I!!H   ~~!~~ AD 99;D88((88(("xx==gF8z  W X$  ! ! !+!,!4!44"#1"9 UJ)55g>>F = =sD$/#^^Jz,BCCfnn.t<  = = YY[F! ! !" KK ! ! II -+ " %  2% %AF ==  H9  !? =D = = = = ! ! ! !    sC(J*I+J.J?I J>F D Dkk$---#^^Jz,BCC D DYY[F ! ! KK ! ! II -+ " !  .% %AF ==  H5  !? D-C D D D D ! ! ! !    sB)I+G1,I/H/?G4H/9H<G7= HG9 H H!G; "!HG= H HG?H, H/7H8}|s|j8r-|+|j@stjBjEd dddy77\777#1swYyxYww) z'Given a socket, does the zone transfer.rNrxFr=rjT)r6r7xfrorigintsig_ctxmultir5z missing TSIG)#questionrdtyper, rdatatypeIXFRfrom_wire_originr/typerrYrrUDatagramSocketr0r% StreamSocketrzpackrlrnrInboundrr>rvr{r-r@r6rZprocess_messagerhad_tsig exception FormError)rr_r;rrMr#ris_ixfrrrDis_udprbrcroinbounddonerrGr` mexpirationrwirer|r}s r _inbound_xfrrHsB^^A  % %F ***G  ) ) +F ==?D VVv(( (F ((77;oodD(:*>???((55q9T3t9-4vz222 fff =:(,-g6 Q "&;+C( ";/#+#4#4UG#DD +HaEE}}T51+HaEE %% !II!!z!(& A**1-DGzzH34 ==Q]1::--)).9 9?:: @ 3EEE!::s{B9J ;I5> w||+,          s&DIF! I'F#(I+H-F;=F'F%F'F;0I7H8 IHIH2HHHH2!I#I%F''F;) I4F75I;1G/,H.G//H2 I=H>IH H HIIHH2 I+H.,I2I8H; 9II)N) NNFFNrFFFN) NrJNrFFFFNNF) NrJNrFFFNNNF)NFNrF)NrJNrFFNN) NUNrFFNNNNT) NrNrFFTNTN) Nr NrFFNTNNN)X__doc__r contextlibrrrzr! urllib.parsertypingrrrrrdns.asyncbackendr, dns.exceptiondns.inet dns.messagedns.namedns.quic dns.rdatatypedns.transactiondns.tsigdns.xfrdns._asyncbackendr dns.queryr r r r r rrrrrrssl ImportError dns._no_ssl_no_sslrrRlow_level_address_tuplerTrr%rUrr-r.bytesfloatintr3boolnameNametsigKeyrIrBackendrarrgrprvr~re SSLContextrr AF_UNSPECrrrrr transactionTransactionManagerSocketrrr rrr/s4 $  33)      88 + +   $    ) ) ++   %   3: @###"8< #! %(,:0   ) ):0t:0 :0 :0  :0 #((--- . 5 :0:0:0:0:0 ;;   %:0 :0@!#"! %37/3? {{? ?T\?  ? $J ?  ?????    ) )D 0?   % % ,?? [[?J!#"!7;59/3A  {{A A T\A   A $J A  A A A A --4A ++d2A    % % ,A A  3;;   $%A N $$   ' '$ ++   %$ $ 3: $2  $"8< #!    ' ' #((--- . 5      3;;   %&B!"!15/3: {{: :T\:  : $J :  :::    ' '$ .:   % % ,: [[:@!"!15/3)-"&C {{C CT\C  C $J C  CCC    ' '$ .C   % % ,C$&C4ZC 3JC [[CL 34 ! "!"!IM*.$(7;"" + 3 3!m  {{m m T\m   m $J m  m m m  E Fm  m  m  3J 'm Tzm 34m  m !m " [[#m h!"!*./36:=  {{= =  = T\ =  = $J = = = =  3J '=    % % ,=  = ,,t3=  [[= F!"!6:/3"&C  {{C C T\C   C $J C  C C C ,,t3C  3JC    % % ,C DjC 4ZC  [[C L4:334: 4: ;;  4: $J 4: T\ 4:  4: 4:t)- ! /3: :33: ;;   %:  : T\ : dl : $J:::   % % ,: :Os6\ \\