dfe!z dZddlZddlZddlZddlZddlZddlmZmZm Z m Z m Z ddl Z ddlZ ddlZ ddlZ ddlZ ddlZ ddlZ ddlZ ddlZ ddlZ ddlmZddlmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#e"rddl$Z$e jJjLZ'dZ(d=dZ) d=de jTjVd e e jXjZe.fd ed e e/d e e0e/ff d Z1 d>de jTjVd e ed e e/de2de2de ee jfjhe jjjlfde e.de2de2d efdZ7 d?de jXjZde8de e/de0de e8de0de2de2de2de2de e jTjVde e jTjrd e jXjZfdZ: d@de jXjZde8de e/de0de e8de0de2de2de2de e jTjVd e e jTjvde e jTjrd e e jXjZe2ffd!Z< d=de jTjvd e e jXjZe.fd e e/d e e0e/ffd"Z=d#Z> dAde jTjvd e e/de2de ee jfjhe jjjlfde e.de2d e e jXjZe/ffd$Z? dBde jXjZde8de e/de0de e8de0de2de2de e jTjvde e jTjrd e jXjZfd%Z@ dCde jXjZde8de e/de0de e8de0de2de2de e jTjvde e jTjrd&e e#jd'e e8d e jXjZfd(ZBdd)dddddd*d+d+ddejf de jXjZde8de e/de0de e8de0de2de2d,e d-d.e8d/e2d0e e2e8fd1e e8d2e d3d4e e0d e jXjZf d5ZDddddddejdfde8d6e jjd7e e jXjZde0de e/d8e e/de e8de0d9ede e jTjrd dfd:ZH dDde jXjZde8de e/de0de e8de0de2de2d;e e jjd0e e2e8fde e jTjrd'e e8d e jXjZfd<ZIy)EzTalk to a DNS server.N)AnyDictOptionalTupleUnion) NullContext) BadResponseNoDOHNoDOQUDPMode_compute_times _have_http2_matches_destination _remaininghave_dohsslc|s|rF|@|tjk(rd}||fS|tjk(rd}||fStd|||fSy)Nz0.0.0.0z::zunknown address family )socketAF_INETAF_INET6NotImplementedError)afaddressports G/home/api-vastappli/venv/lib/python3.12/site-packages/dns/asyncquery.py _source_tupler:sl$ ?V^^##  v&*,CB4*HIIcR|%|stj}t||z dSy)Nr)timemax) expirationnows r_timeoutr#Js+))+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_wirersendtor#)r$r%r&r! sent_timens rsend_udpr1Ss^.$ ++,||~ Ikk$ Xj)-LMMA y> NsA)A6+A4, A6Fignore_unexpectedone_rr_per_rrsetkeyring request_macignore_trailingraise_on_truncationc Kd} |jdt|d{\} } t|j| ||rn@t j} t j j| |||||} | | | fS7_w)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)r4r5r3r6r7)recvfromr#rfamilyrr*r+ from_wire) r$r&r!r2r3r4r5r6r7wire from_address received_timers r receive_udprAqs, D %)]]5(::N%OO|  KK{4E   IIKM  )'/  A }l ++ Ps"BBA B5qwheretimeoutrsource 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 |_|j'|st(|cdddd{S777o7B7 #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-r r*inetaf_for_address_lltupler asyncbackendget_default_backendrdatagram_connection_required make_socketr SOCK_DGRAMr1rAr4macr is_responser )rCrDrErrFrGr2r3r6r7r$rHr= begin_timer!rr&cmstupledtuplesr@r?_s rudprZsm6 99;D-g6Z   'BE4="-K 5@5F&&:: ??? K ##@sBB%B#B%cKd}|dkDrG|j|t|d{}|dk(rt|t|z }||z}|dkDrG|S7*w)z|Read the specified number of bytes from stream. Keep trying until we either get the desired amount, or we hit EOF. rrN)recvr#EOFErrorrd)r$countr!rXr0s r _read_exactlyro4sc A !)))E8J#78 8 8NA 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. Nrcr4r5r3r6)roreunpackrr*r+r<) r$r!r3r4r5r6ldatarhr=r?r@s r receive_tcpruBs  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*rJrKrrMrNrPr SOCK_STREAMrjrur4rRrrSr )rCrDrErrFrGr3r6r$rHr=rTr!rUrrVrWrXr@r?s rr_r_`s_4 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( ssl_contextserver_hostnamec Kt|\} } |r t|}n|  E!E"E%#EE #E, E8E9EEEEE E EEiz /dns-queryTclientzhttpx.AsyncClientpathpostverifybootstrap_addressresolverzdns.asyncresolver.Resolverr;c @Ktst|r%t|tjs t d|j } tjj|}d}ddi}|mtjj|rN|tjk(rdj||| }n)|tjk(rdj||| }n|}tjj!}|d}d}n|}|}|j#|dt$| || | | }|r t'|}ntjdt$| | }|4d{}| rS|j)dt+t-|d |j/|j1|| |d{}nbt3j4|j7d }|j9}|j/|j;|d|i|d{}dddd{j<dks|j<dkDr0t dj||j<|j>tj@jC|j>|jD|jF||}|jHjK|_&|jO|stP|S#t $rd}YwxYw77U77#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. z.session parameter must be an httpx.AsyncClientNacceptzapplication/dns-messagezhttps://{}:{}{}zhttps://[{}]:{}{}rT) local_addresshttp1http2r local_portrrr;)rrr transport)z content-typezcontent-length)headerscontent=r*)rparamsi+z4{} responded with status code {} Response body: {!r}rr))rr r)httpx AsyncClient ValueErrorr-r*rJrK is_addressrrformatrrMrNget_transport_classrrupdatestrrdwait_forrbase64urlsafe_b64encoderstripdecodeget status_coderr+r<r4r5elapsed total_secondsrrSr )rCrDrErrFrGr3r6rrrrrrr;r=rrrurlrHrrrU the_clientr`twirer@s rhttpsrs:   j):):;IJJ 99;D XX $ $U +I23G ~#((--e4  #**5$=C 6?? "%,,UD$?C224G ~    -++-#+ I5@5H   k&I Z  NN$=&)#d)n  %--WdCWH++D188>DKKME$--sGUENKWH!,c!X%9%9C%? $$*Fx++X-=-=%   MM)'  A   + + -AF ==  H[  L !sALK-&C3LK?LAL -L.A"L LL  L L!C L- K<8L;K<<LL L L LL LL txn_managerquerylifetimeudp_modec K|#tjj|\}} ntjj|} |jdj } | tj jk(} |j} |j}tjj|}t|||}||f}t|\}}d}|rd}| r&|tjk7rt j"}d}nt j$}d}| stj&j)} | j+||d||t-|d{}|4d{|r%|j/||t-|d{nrtrhr@s# r inbound_xfrrVs* }'',,[92259 ^^A  % %F ***G  ) ) +F ==?D   'B 2v{ 3FT]F$X.OQ E  x7==0))IF**IF&&::$Q "*".;3K&0 &.t}b&A "&.{&;G:;**UG:T4T1UL3 "L+t !& #'4Aq+&F F%}}T59&3Aq+&F F$ (:(::G -- % $)II %!)#)z)0. A !&66q9 !zzHQRqzz--11.AA[- B 3 B3 B  3 BB45U !G F77>>!% #w||3!# $#*== !G- B- B 3 B3 B3 B3 BsEO8M1 O8)M4*O8-"O#M7>F D Dkk$---#^^Jz,BCC D DYY[F ! ! KK ! ! II -+ "   &% %AF ==  H-  ! ? D-C D D D D ! ! ! !    sB#H>%G+&H>)H)9G.:H)=9H6G17 HG3 HG;G5 !G;=G7 >G; H G9H& H)1H29H':2H>.H)1H3H5G;7G;9H;H HH HH)H$ HH$ H)'H>)H;/H2 0H;7H>)N)NNFFNrFF) NrBNrFFFFNN) NrBNrFFFNNN)NFNrF)NrBNrFFNN) NUNrFFNNNN) NrNrFFNTNN)K__doc__r contextlibrrertypingrrrrrdns.asyncbackendr* dns.exceptiondns.inet dns.messagedns.namedns.quic dns.rcodedns.rdataclass dns.rdatatypedns.transactiondns._asyncbackendr dns.queryr r r r r rrrrrrrJlow_level_address_tuplerLrr#rMDatagramSocketr+r,bytesfloatintr1boolnameNametsigKeyrArBackendrZ StreamSocketrarjrorur_ SSLContextr AF_UNSPECrr transactionTransactionManagerrrAsyncQuicConnectionrrrs $  44)     88 + +  #'    ) )  ##U* +   3: @"&"&#";?#&! %&,   ) )&,#&,&, &,  &, d388==#((,,67 8 &,%&,&,&, &,X $ #"! %6:26: {{: :e_:  : SM :  ::::: 3##22 3:c&&.. /: [[:@ $ #"!:>8<26?  {{? ? e_?   ? SM ?  ? ? ? ? s''667? s''445? c&&.. /?  3;;   $%? J#'$   ' '$  ##U* +$$ 3: $6  #'";?#&!    ' 'd388==#((,,67 8  %    3;;   %&B $ "!48265 {{5 5e_5  5 SM 5  555 3##00 15c&&.. /5 [[5v $ "!4826,0%)F {{F Fe_F  F SM F  FFF 3##00 1Fc&&.. /F#..)Fc]F [[FX $ "!,0#'+7;",,r  {{r r e_r   r SM r  r r r  ( )r  r  r  $) r  }r 34r  SMr  [[!r p,0# $  26bB bB33bB CKK'' (bB  bB e_ bB uo bB SMbBbBbBc&&.. /bB bBP $ "!9=#26%);  {{; ; e_;   ; SM ;  ; ; ; 556;  $) ; c&&.. /; c];  [[; r