Eqg#dZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddlmZmZmZmZmZmZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Zddl!Zddl"ZdZ#dZ$ej%&dZ'e'rBddl(Z)ddl*Z*e)j+Z,e)j-j.j/Z0Gdde,Z1Gd d e*j2Z3n Gd d Z3e'Z4 ddl5Z5n#e6$rGd d Z5YnwxYwe j Z7Gddej8j9Z:Gddej8j;Z<Gddej8j9Z=Gddej8j9Z>ej?j@Z@dZAdZBdZCdZDdZEdZF dtdZGdudZHded d!d fd"ZIGd#d$ejJZKdd%ddd&d&dd'dddde jLeKjMfd(ejNjOd)ePd*eeQd+eRd,eePd-eRd.eSd/eSd0eed1ePd2eSd3eePd4eeSePfded d5eRd6eKd!ejNjOf"d7ZTd8ejUjVd9eWd!eWfd:ZXd8ejUjVd;ePdrseleventsrs r _wait_forrsJr3=11bjjllQ6F6Ft  # % %C F')&&()'' ! R   ty{{* c>>-' ' ::g  $m##$$rc,t|ddd|dS)NTFrsrs r_wait_for_readablers audJ/////rc,t|ddd|dS)NFTrrs r_wait_for_writablers adJ/////rc  tj||d}tj||d}n#tjj$rYdSwxYw||ko|dd|ddkS)NrF)r r+ inet_ptonr SyntaxError)rAa1a2n1n2s r_addresses_equalrs X  BqE * * X  BqE * * = $uu 8 (122"QRR&((sA AA'&A'c|sdSt|||s;tj|dr|dd|ddkrdS|rdSt d|d|)NTrrFzgot a response from z instead of )rr r+ is_multicastru)rA from_address destinationignore_unexpecteds r_matches_destinationrs tL+66 k!n--2>qrr2BkRSRTRTo2U2Ut u J|JJ[JJ  rTc d}d} tj|}|}n#t$r|rYnwxYw|r9tj|}|r||krt dn|}|r@|s> tj|}n#t$rt dwxYw|r"tj||f|}|r"tj||f|}|||fS)Nz5different address families for source and destinationz3source_port specified but address family is unknown)r r+r.r7 ValueError any_for_afr1)wherer;rB source_portwhere_must_be_addressrArsafs r_destination_and_sourcerse BK X $ $U + +       h%%f-- byy KBT6T TX((,,FF T T TRSS S T Ph66 T7JBOO  M116;2GLL  V $$s!( 88;BB5ct||} |d||||r||d|S|S#t$r|wxYw)NF)do_handshake_on_connectserver_hostname)socket_factory setblockingbind wrap_socketr7close)rAtyperB ssl_contextrrs rr2r2@sr4  A e   FF6NNN  **(- /+  H    sAAA A:r#zdns.resolver.ResolverreturncD|ddl}|j}|SrS)rTr#rU)r#r s r_maybe_get_resolverrTs. <((** Orc.eZdZdZdZdZdZdZdZdZ dZ dS) HTTPVersionzWhich version of HTTP should be used? DEFAULT will select the first version from the list [2, 1.1, 3] that is available. rrN) rKrLrMrwDEFAULTHTTP_1H1HTTP_2H2HTTP_3H3r^rrrrbs= G F B F B F BBBrriFz /dns-queryqrrr;rBrone_rr_per_rrsetignore_trailingsessionrIpostr%verifyr& http_versionc t||||d\}}}|Utj|r6|tjkr d|d|| }n|tjkr d|d|| }n|}i}| xtj |}|j tdtj|j r|j } |j |d<|j |j }|tjks|tjkrt s| ft#| } |j J| |j |}t'jt+|} t/|| |||||||| | St st0|r)t3|t4jstd |}d d i}|tjtjfv}|tjtjfv}|d}d }n|d }|d}|rt?j |}n/tC|||| || | |}t5j||| |}|5}| rM|"d tGtI|d|%|||||}nWtMj'|(d}|)} |*|||d| i|}dddn #1swxYwY|j+dks |j+dkr!t|d|j+d|j,tj-.|j,|j/|j0||}!|j12|!_3|4|!stj|!S)a Return the response obtained after sending a query via DNS-over-HTTPS. *q*, a ``dns.message.Message``, the query to send. *where*, a ``str``, the nameserver IP address or the full URL. If an IP address is given, the URL will be constructed using the following schema: https://:/. *timeout*, a ``float`` or ``None``, the number of seconds to wait before the query times out. If ``None``, the default, wait forever. *port*, a ``int``, the port to send the query to. The default is 443. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *session*, an ``httpx.Client``. If provided, the client session to use to send the queries. *path*, a ``str``. If *where* is an IP address, then *path* will be used to construct the URL to send the DNS query to. *post*, a ``bool``. If ``True``, the default, POST method will be used. *bootstrap_address*, a ``str``, the IP address to use to bypass resolution. *verify*, a ``bool`` or ``str``. If a ``True``, then TLS certificate verification of the server is done using the default CA bundle; if ``False``, then no verification is done; if a `str` then it specifies the path to a certificate file or directory which will be used for verification. *resolver*, a ``dns.resolver.Resolver`` or ``None``, the resolver to use for resolution of hostnames in URLs. If not specified, a new resolver with a default configuration will be used; note this is *not* the default resolver as that resolver might have been configured to use DoH causing a chicken-and-egg problem. This parameter only has an effect if the HTTP library is httpx. *family*, an ``int``, the address family. If socket.AF_UNSPEC (the default), both A and AAAA records will be retrieved. *http_version*, a ``dns.query.HTTPVersion``, indicating which HTTP version to use. Returns a ``dns.message.Message``. FNzhttps://:z https://[z]:zno hostname in URL sni_hostname)rrz)session parameter must be an httpx.Clientacceptzapplication/dns-messagerr)r<http1http2rr$r%r#r&)rrr transport)z content-typezcontent-length)headerscontentr extensions=r )rrparamsr+ responded with status code z Response body: keyring request_macrr)6rr r+r,r3AF_INETAF_INET6urllibparseurlparsehostnamerr;rrrhave_dohrr/randomchoicelistr0_http3r{rhttpxClientto_wirerr contextlib nullcontextrQupdatestrlenrbase64urlsafe_b64encoderstripdecodeget status_codermessage from_wirerrelapsed total_secondsr is_responsery)"rrrr;rBrrrrrIrr%rr#r&rrAr> the_sourceurlrparsedr?wirerh1h2r<r$cmrresponsetwirers" rhttpsrrsN2 tV[%RJ ~#(--e44~   1U11T1411CC 6? " "3e33t3T33CJ &&s++ ? "122 2 8  v / / 9 & )/J~ & ; ";D{~%% +++H+  $*844H?...++FOVDDG & d73D3D3F3F.G.G H H               Fz'5<88FDEEE 99;;D23G +.+*=> >B +.+*=> >B  "1 ] R0:0Fw0O0O"'!/    \"Vy Q Q Q w   NN$=&)#d))nn    ||% $HH+D1188>>DKKMME{{u~% #H)<c!!X%9C%?%? 3 3(2F 3 3 ( 0 3 3     M)'   A  + + - -AF ==   Hs:B'L--L14L1rnamecF|t|D]\}}||kr|cStr)KeyError)rrheadervalues r _find_headerr 9s;   T>>LLL  NrpeerrcPt|d}|tdt|}|dkrtd|dks|dkrTd}t|dkr) d|z}n#t $rYnwxYwt |d ||dS) Ns:statuszno :status header in responserzstatus is negativerrz: r)r rintrrr7r)rrrr statuserrors r _check_statusrBs * - -E }9::: ZZF zz./// ||v|| t99q== t{{}},    DMMfMeMMNNN$|s(B B  B Urrc tjjstdtj|} | j} | j| j}d|_ | } tj | | d}|5| ||||}t|\}}||5}||| | |t#|} t%||| dddn #1swxYwYt)j}dddn #1swxYwYtj| |j|j||}t3||z d|_||st6|S)Nz DNS-over-HTTP3 is not available.rT) verify_mode server_nameh3rr )r quic have_quicr{rrrrr;idrSyncQuicManagerconnectr* make_streamsend_h3receiverrrr rrrrmaxrry)rrrrr;rBrrrrrr url_partsrmanager connectionstartrstreamfinishrs rrrSs. 8 86777 %%c**I!H~!~ AD 99;;Dh&&T'G __UD&+FF ,W55  # #G , , 9 NN3d + + +>>*Z"8"899D &..**E4 8 8 8 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9   M)'   A% % %AF ==   Hs8AE'AD=1 E'=E E'E E''E+.E+cr ||S#t$rt||YnwxYw7)zReads a datagram from the socket. A Timeout exception will be raised if the operation is not completed by the expiration time. )recvfromBlockingIOErrorr)rCmax_sizers r _udp_recvr-sT 1 1==** * 1 1 1 tZ 0 0 0 0 0 11s 55c |r|||S||S#t$rt||YnwxYwO)zSends the specified datagram to destination over the socket. A Timeout exception will be raised if the operation is not completed by the expiration time. )sendtosendr+r)rCdatarrs r _udp_sendr2sn 1 1 '{{4555yy& 1 1 1 tZ 0 0 0 0 0 1 1s00A  A rCwhatrrct|tjjr|}t j}t ||||}||fS)aSend a DNS message to the specified UDP socket. *sock*, a ``socket``. *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. Returns an ``(int, float)`` tuple of bytes sent and the sent time. )rr rMessagerr r2)rCr3rr sent_timens rsend_udpr8sP,$ +,,||~~ I$k:66A y>rrrrrraise_on_truncation ignore_errorsqueryc d} t|d|\} } t|j| ||s-tj} tj| |||||}n[#tjj$r6}| r.| ,| |sYd}~d}~wt$r| rYwxYw| r| | |s|r|| fS|| | fS)aRead a DNS message from a UDP socket. *sock*, a ``socket``. *destination*, a destination tuple appropriate for the address family of the socket, specifying where the message is expected to arrive from. When receiving a response, this would be where the associated query was sent. *expiration*, a ``float`` or ``None``, the absolute time at which a timeout exception should be raised. If ``None``, no timeout will occur. *ignore_unexpected*, a ``bool``. If ``True``, ignore responses from unexpected sources. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *keyring*, a ``dict``, the keyring to use for TSIG. *request_mac*, a ``bytes`` or ``None``, the MAC of the request (for TSIG). *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *raise_on_truncation*, a ``bool``. If ``True``, raise an exception if the TC bit is set. Raises if the message is malformed, if network errors occur, of if there is a timeout. If *destination* is not ``None``, returns a ``(dns.message.Message, float)`` tuple of the received message and the received time. If *destination* is ``None``, returns a ``(dns.message.Message, float, tuple)`` tuple of the received message, the received time, and the address where the message arrived from. *ignore_errors*, a ``bool``. If various format errors or response mismatches occur, ignore them and keep listening for a valid response. The default is ``False``. *query*, a ``dns.message.Message`` or ``None``. If not ``None`` and *ignore_errors* is ``True``, check that the received message is a response to this query, and if not keep listening for a valid response. rT)rrrrr9N) r-rr&r r rr Truncatedrr7)rCrrrrrrrr9r:r;rr received_timeres r receive_udprAsS| D(4(ujAA|# K{4E       %%'!1 /$7 &AA{$    %))!))++66&        U.u7H7H7K7K.   4}% %}l3 3s$%A**C>+B/.B//CC5c |} t||||\} }}t|\}}| rtj| }nt | t j|}|5}t|| ||t||||||j |j || | | \}}||z |_ | s| |st|cdddS#1swxYwY J)aReturn the response obtained after sending a query via UDP. *q*, a ``dns.message.Message``, the query to send *where*, a ``str`` containing an IPv4 or IPv6 address, where to send the message. *timeout*, a ``float`` or ``None``, the number of seconds to wait before the query times out. If ``None``, the default, wait forever. *port*, an ``int``, the port send the message to. The default is 53. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *ignore_unexpected*, a ``bool``. If ``True``, ignore responses from unexpected sources. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *raise_on_truncation*, a ``bool``. If ``True``, raise an exception if the TC bit is set. *sock*, a ``socket.socket``, 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 nonblocking datagram socket, and the *source* and *source_port* are ignored. *ignore_errors*, a ``bool``. If various format errors or response mismatches occur, ignore them and keep listening for a valid response. The default is ``False``. Returns a ``dns.message.Message``. N)rrr*rrr2r3 SOCK_DGRAMr8rArmacr rry)rrrr;rBrrrrr9rCr:rrAr begin_timerrrrr?s rudprG&s^p 99;;D 7 tV[!!Rf .g66Z 90:0Ft0L0L "f/ 8 8 qD+z222(     I E       M+ q!1!1  ),  s1A"C  C$'C$udp_socktcp_sockc  t|||||||||d| | } | dfS#tjj$rt ||||||||| } | dfcYSwxYw)a|Return the response to the query, trying UDP first and falling back to TCP if UDP results in a truncated response. *q*, a ``dns.message.Message``, the query to send *where*, a ``str`` containing an IPv4 or IPv6 address, where to send the message. *timeout*, a ``float`` or ``None``, the number of seconds to wait before the query times out. If ``None``, the default, wait forever. *port*, an ``int``, the port send the message to. The default is 53. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *ignore_unexpected*, a ``bool``. If ``True``, ignore responses from unexpected sources. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *udp_sock*, a ``socket.socket``, or ``None``, the socket to use for the UDP query. If ``None``, the default, a socket is created. Note that if a socket is provided, it must be a nonblocking datagram socket, and the *source* and *source_port* are ignored for the UDP query. *tcp_sock*, a ``socket.socket``, or ``None``, the connected socket to use for the TCP query. If ``None``, the default, a socket is created. Note that if a socket is provided, it must be a nonblocking connected stream socket, and *where*, *source* and *source_port* are ignored for the TCP query. *ignore_errors*, a ``bool``. If various format errors or response mismatches occur while listening for UDP, ignore them and keep listening for a valid response. The default is ``False``. Returns a (``dns.message.Message``, tcp) tuple where tcp is ``True`` if and only if TCP was used. TF)rGr rr>tcp) rrrr;rBrrrrrHrIr:rs rudp_with_fallbackrLsr               %  ;               $  s /AAc@d}|dkr ||}|dkrtd|t|z}||z }nL#ttjf$rt ||Yn$tj$rt||YnwxYw|dk|S)zRead the specified number of bytes from sock. Keep trying until we either get the desired amount, or we hit EOF. A Timeout exception will be raised if the operation is not completed by the expiration time. rrEOF) recvEOFErrorrr+r`SSLWantReadErrorrSSLWantWriteErrorr)rCcountrrr7s r _net_readrTs A !)) 1 %  ACxxuoo% SVVOE FAA!56 1 1 1 tZ 0 0 0 0 0$ 1 1 1 tZ 0 0 0 0 0 1 !)) HsAA &B4BBc d}t|}||krv ||||dz }nL#ttjf$rt ||Yn$tj$rt||YnwxYw||ktdSdS)zWrite the specified data to the socket. A Timeout exception will be raised if the operation is not completed by the expiration time. rN)rr0r+r`rRrrQr)rCr1rcurrentls r _net_writerXs G D A A++ 1 tyyghh00 0GG!67 1 1 1 tZ 0 0 0 0 0# 1 1 1 tZ 0 0 0 0 0 1 A++++++s :&B"BBc$t|tjjr|d}n&t |dd|z}tj}t|||t ||fS)a{Send a DNS message to the specified TCP socket. *sock*, a ``socket``. *what*, a ``bytes`` or ``dns.message.Message``, the message to send. *expiration*, a ``float`` or ``None``, the absolute time at which a timeout exception should be raised. If ``None``, no timeout will occur. Returns an ``(int, float)`` tuple of bytes sent and the sent time. T)prepend_lengthrbig) rr rr5rrto_bytesr rX)rCr3rtcpmsgr6s rsend_tcpr^s$$ +,,5T22 T##Au--4 ItVZ((( KK ##rct|d|}tjd|\}t|||}tj} tj|||||} | | fS)aRead a DNS message from a TCP socket. *sock*, a ``socket``. *expiration*, a ``float`` or ``None``, the absolute time at which a timeout exception should be raised. If ``None``, no timeout will occur. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *keyring*, a ``dict``, the keyring to use for TSIG. *request_mac*, a ``bytes`` or ``None``, the MAC of the request (for TSIG). *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. Raises if the message is malformed, if network errors occur, of if there is a timeout. Returns a ``(dns.message.Message, float)`` tuple of the received message and the received time. r!Hr)rTstructunpackr r rr) rCrrrrrldatarWrr?rs r receive_tcprds}B dAz * *E =u % %DQ T1j ) )DIKKM  )'   A } rcN||}|dkrdS|tjtjtjfvr:t |||tjtj }|dkr"t|tj |dSrS) connect_exerrno EINPROGRESS EWOULDBLOCKEALREADYr getsockoptr3 SOL_SOCKETSO_ERROROSErrorosstrerror)rr@rerrs rr5r5Ks ,,w  C axx u %"3U^DDD1j)))ll6,fo>> axxc2;s++,,,xrc |} t|\} } |rtj|} n1t ||||\} }}t | t j|} | 5}|st||| t|| | t|| ||j |j |\}}|| z |_ ||st|cdddS#1swxYwY J)aReturn the response obtained after sending a query via TCP. *q*, a ``dns.message.Message``, the query to send *where*, a ``str`` containing an IPv4 or IPv6 address, where to send the message. *timeout*, a ``float`` or ``None``, the number of seconds to wait before the query times out. If ``None``, the default, wait forever. *port*, an ``int``, the port send the message to. The default is 53. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *sock*, a ``socket.socket``, or ``None``, the connected 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 nonblocking connected stream socket, and *where*, *port*, *source* and *source_port* are ignored. Returns a ``dns.message.Message``. N)rr*rrrr2r3r4r5r^rdrrEr rry)rrrr;rBrrrrCrrFrrrArrrr?s rrKrKVsZV 99;;D-g66Z :0:0Ft0L0L$; 4% % ![&"f0& 9 9 q 1 Q Z 0 0 0D*%%%( z+QY  M+}}Q                    s1A-C++C/2C/c |dS#tj$rt||Yn$tj$rt ||YnwxYw]r) do_handshaker`rQrrRrrs r_tls_handshakerus. . NN    F# . . . q* - - - - -$ . . . q* - - - - - . .sAAArcd}d}t|trStj|r|}n1tj|r|}nt dtj||}tj j |_ |d|_ | dg|durtj|_|S)Nzinvalid verify string)cafilecapathFdot)rrrorIisfileisdirrr`rq TLSVersionTLSv1_2minimum_versioncheck_hostnameset_alpn_protocolsrrr)rrrwrxrs r_make_dot_ssl_contextrs!F F&#6 7>>& ! ! 6FF W]]6 " " 6FF455 5,F6JJJK"%."8K%* """E7+++ "%-  rrc <|rt||||||||| S|} t|\} }t||||\}}}| |st | | } t |t j|| | 5}t|||t||t|| |t||||j |j |\}}|| z |_||st |cdddS#1swxYwY J)akReturn the response obtained after sending a query via TLS. *q*, a ``dns.message.Message``, the query to send *where*, a ``str`` containing an IPv4 or IPv6 address, where to send the message. *timeout*, a ``float`` or ``None``, the number of seconds to wait before the query times out. If ``None``, the default, wait forever. *port*, an ``int``, the port send the message to. The default is 853. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *sock*, an ``ssl.SSLSocket``, 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 nonblocking connected SSL stream socket, and *where*, *port*, *source*, *source_port*, and *ssl_context* are ignored. *ssl_context*, an ``ssl.SSLContext``, the context to use when establishing a TLS connection. If ``None``, the default, creates one with the default configuration. *server_hostname*, a ``str`` containing the server's hostname. The default is ``None``, which means that no hostname is known, and if an SSL context is created, hostname checking will be disabled. *verify*, a ``bool`` or ``str``. If a ``True``, then TLS certificate verification of the server is done using the default CA bundle; if ``False``, then no verification is done; if a `str` then it specifies the path to a certificate file or directory which will be used for verification. Returns a ``dns.message.Message``. N)rr)rKrr*rrr2r3r4r5rur^rdrrEr rry)rrrr;rBrrrrCrrrrrFrrArrrr?s rtlsrsz              99;;D-g66Z 7 tV[!!Rf4+OVDD  '     K,,,q*%%%D*%%%( z+QY  M+}}Q  !$  sA;DDDr%c @tjjstd| | | } d|_|} |rt jd} |}n#tj| | } | }| 5|s| ||||}t|\}}| |5}| | d| t|} dddn #1swxYwYtj}dddn #1swxYwYtj| |j|j||}t)||z d|_||st,|S)aReturn the response obtained after sending a query via DNS-over-QUIC. *q*, a ``dns.message.Message``, the query to send. *where*, a ``str``, the nameserver IP address. *timeout*, a ``float`` or ``None``, the number of seconds to wait before the query times out. If ``None``, the default, wait forever. *port*, a ``int``, the port to send the query to. The default is 853. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *connection*, a ``dns.quic.SyncQuicConnection``. If provided, the connection to use to send the query. *verify*, a ``bool`` or ``str``. If a ``True``, then TLS certificate verification of the server is done using the default CA bundle; if ``False``, then no verification is done; if a `str` then it specifies the path to a certificate file or directory which will be used for verification. *hostname*, a ``str`` containing the server's hostname or ``None``. The default is ``None``, which means that no hostname is known, and if an SSL context is created, hostname checking will be disabled. This value is ignored if *url* is not ``None``. *server_hostname*, a ``str`` or ``None``. This item is for backwards compatibility only, and has the same meaning as *hostname*. Returns a ``dns.message.Message``. zDNS-over-QUIC is not available.Nr)rrTrr )r rrr~rrrrrrr*rr0r!rr rrrrr"rry)rrrr;rBrrrr%rrrrr$the_connection the_managerr&rr'r(rs rrr'sn 8 75666"x'7" AD 99;;D5?5KD5Q5Q#(**v8*TT  S(00fkRRN,W55  ' ' 0 0 :F KKd # # #>>*Z"8"899D : : : : : : : : : : : : : : :   M)'   A% % %AF ==   Hs7AD19D; D1D D1D D11D58D5ceZdZdZdZdZdZdS)UDPModeaHow should UDP be used in an IXFR from :py:func:`inbound_xfr()`? NEVER means "never use UDP; always use TCP" TRY_FIRST means "try to use UDP but fall back to TCP if needed" ONLY means "raise ``dns.xfr.UseTCP`` if trying UDP does not succeed" rrrN)rKrLrMrwNEVER TRY_FIRSTONLYr^rrrrs) EI DDDrr txn_managerrserialc #K|jdj}|tjjk}|}|} |jtj k} | rt|| d|n6tj dt| | z} t|| |tj|||| 5} d} d}| st#|\}}||||kr|}| rt%|d|\}}n9t'|d|}tjd|\}t'|||}tj||j|jd||| |}| |} |V|j}| |jr&|jstjd ddddS#1swxYwYdS) z'Given a socket, does the zone transfer.rNr`Fr=rT)rrxfrorigintsig_ctxmultirz missing TSIG)questionrdtyper rdatatypeIXFRfrom_wire_originrrr3rDr2rapackrrXrInboundr*r-rTrbrrrrEprocess_messagerhad_tsigr FormError)rrr;rrrris_ixfrrris_udpr]inbounddonerr> mexpirationrwirercrWrs r _inbound_xfrrsB^A  %F **G  ) ) + +F ==??D Vv( (F *!T4,,,,T3t99--41fj))) fff = =: "-g66 Q "&;+C+C(  5&q%== !!Q 44}T511!!Q 44 %% !I!!z!(&  A**1--DGGGzH1 "2 = : :-)).99 9;::::::::::::::::::sC6GGGzonerrdclasskeyname relativizer)use_udp keyalgorithmc #KGddtjj}t|trtj|}tjj |}tj |||}|tjj krw| |j|tjjtjjd}tjddd| z}||d||||| t+||| | \}}} t-| \}}|||}| r$|tjj krt/d | r t0jn t0j}t7||| 5}t9|||t;|||| ||Ed {Vd d d d S#1swxYwYd S) aReturn a generator for the responses to a zone transfer. *where*, a ``str`` containing an IPv4 or IPv6 address, where to send the message. *zone*, a ``dns.name.Name`` or ``str``, the name of the zone to transfer. *rdtype*, an ``int`` or ``str``, the type of zone transfer. The default is ``dns.rdatatype.AXFR``. ``dns.rdatatype.IXFR`` can be used to do an incremental transfer instead. *rdclass*, an ``int`` or ``str``, the class of the zone transfer. The default is ``dns.rdataclass.IN``. *timeout*, a ``float``, the number of seconds to wait for each response message. If None, the default, wait forever. *port*, an ``int``, the port send the message to. The default is 53. *keyring*, a ``dict``, the keyring to use for TSIG. *keyname*, a ``dns.name.Name`` or ``str``, the name of the TSIG key to use. *relativize*, a ``bool``. If ``True``, all names in the zone will be relativized to the zone origin. It is essential that the relativize setting matches the one specified to ``dns.zone.from_xfr()`` if using this generator to make a zone. *lifetime*, a ``float``, the total number of seconds to spend doing the transfer. If ``None``, the default, then there is no limit on the time the transfer may take. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *serial*, an ``int``, the SOA serial number to use as the base for an IXFR diff sequence (only meaningful if *rdtype* is ``dns.rdatatype.IXFR``). *use_udp*, a ``bool``. If ``True``, use UDP (only meaningful for IXFR). *keyalgorithm*, a ``dns.name.Name`` or ``str``, the TSIG algorithm to use. Raises on errors, and so does the generator. Returns a generator of ``dns.message.Message`` objects. cfeZdZdZdZdejjfdZdZ d de dej j fdZ d S) $xfr..DummyTransactionManagerc@|||rtjjn|f|_dSr)r remptyinfo)r"rrs rrz-xfr..DummyTransactionManager.__init__ s!z-USX^^vVDIIIrc|jSr)rr"s rorigin_informationz7xfr..DummyTransactionManager.origin_information s 9 rrctrrGrs r get_classz.xfr..DummyTransactionManager.get_classr]rctrrGrs rreaderz+xfr..DummyTransactionManager.readerr]rF replacementcjGdd}ttjj|S)NceZdZdZdZdS)Exfr..DummyTransactionManager.writer..DummyTransactioncdSrr^)r"rXkws rnopzIxfr..DummyTransactionManager.writer..DummyTransaction.nopsDrc|jSr)r)r"r>s r __getattr__zQxfr..DummyTransactionManager.writer..DummyTransaction.__getattr__s 8OrN)rKrLrMrrr^rrDummyTransactionrs2$$$$$rr)rr transaction Transaction)r"rrs rwriterz+xfr..DummyTransactionManager.writersK $ $ $ $ $ $ $ $35E5E5G5GHH HrN)F)rKrLrMrrr rdataclass RdataClassrrboolrrrr^rrDummyTransactionManagerr s W W W    &s~8 & & & & & & & I Id Is7R I I I I I IrrT)createINSOAz. . %u 0 0 0 0rN) algorithmzcannot do a UDP AXFR)r rTransactionManagerrrr from_textr RdataTypemaker make_queryr find_rrset authorityrrrrdataadduse_tsigrr*rr3rDr4r2r5r)rrrrrr;rrrr)rBrrrrrrrrsetsoarArr>rtm sock_typers rrrskJIIIII#/"DIII.$(x!!$'' ] $ ) )& 1 1F tVW55A ### Ks~0#-2CD  i!!$/?&/HII #q 7G| <<< 7 tV[!!Rf%X..OQ z 2 2B16S]////000%,D!!&2DI b)V , ,GK,,,Aq&':FFFFFFFFFGGGGGGGGGGGGGGGGGGs,G==HHudp_modec .|#tj|\}} ntj|} t ||||\} } }t |\} } |jdjtjj kr|tj krt| tj|5}t|| |  t!|||| || D]}  ddddS#tjj$r|tjkrYnwxYw dddn #1swxYwYt| tj|5}t|| | t!|||| || D]}  ddddS#1swxYwYdS)aConduct an inbound transfer and apply it via a transaction from the txn_manager. *where*, a ``str`` containing an IPv4 or IPv6 address, where to send the message. *txn_manager*, a ``dns.transaction.TransactionManager``, the txn_manager for this transfer (typically a ``dns.zone.Zone``). *query*, the query to send. If not supplied, a default query is constructed using information from the *txn_manager*. *port*, an ``int``, the port send the message to. The default is 53. *timeout*, a ``float``, the number of seconds to wait for each response message. If None, the default, wait forever. *lifetime*, a ``float``, the total number of seconds to spend doing the transfer. If ``None``, the default, then there is no limit on the time the transfer may take. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *udp_mode*, a ``dns.query.UDPMode``, determines how UDP is used for IXFRs. The default is ``dns.UDPMode.NEVER``, i.e. only use TCP. Other possibilities are ``dns.UDPMode.TRY_FIRST``, which means "try UDP but fallback to TCP if needed", and ``dns.UDPMode.ONLY``, which means "try UDP and raise ``dns.xfr.UseTCP`` if it does not succeed. Raises on errors. Nr)r rrextract_serial_from_queryrr*rrrrrrr2r3rDr5rUseTCPrr4)rrr;r;rr)rBrrrrArr>rrs r inbound_xfrr9sU^ }',,[9922599 7 tV[!!Rf%X..OQ  ~a3=#555(gm:S:S "f/ 8 8 A Q Z 0 0 0 %E67JA        7>   w|++,+ +                b&,f 5 5K,,,k1eVWjQQ  A  sB=D-C55%DD-DD--D14D1)F  FF)T)NN) NrNrFFTNTr) NNFFNrFFFN) NrBNrFFFFNF) NrBNrFFFNNF)NFNrF)NrBNrFFN) NrNrFFNNNT) NrNrFFNTNN)~rwrrenumrgroos.pathrrr3rar urllib.parsertypingrrrrrr dns._featuresr dns.exceptiondns.inet dns.messagedns.namedns.quic dns.rcodedns.rdataclass dns.rdatatype dns.serialdns.transactiondns.tsigdns.xfrrr _featureshave _have_httpxhttpcore._backends.syncr8rNetworkBackend_CoreNetworkBackend _backendssync SyncStreamr6r HTTPTransportrQrr` ImportErrorrr DNSExceptionrurryr{r~r TransferErrorr*rrrrrrr2rIntEnumrrZrrr5rfloatrrrrHeadersbytesr rrr-r2r8rNametsigKeyrArGrLrTrXr^rdr5rKrurkrrnrSyncQuicConnectionrrrrrAXFRrrdefault_algorithmrrrrr^rrrs$    ::::::::::::::::222 m  '' S&""""LLL"1(-8O2&2&2&2&2&-2&2&2&h,,&&&&&&&& .JJJJ..............0HHHHHs}1HHHGGGGG#-)GGGCM & CM & % $$$$$$8000000 ) ) )   "=A)%)%)%)%X( ./           $,    & $ "!!'+#26" + 3!D D  {D D e_D   D SM D  D D D c]D  D  D  }D  $) D ./D  D !D " [#D D D D N#(*%EO38+O3OeOOOOO* $ "!#". .  {. .  . e_ .  . SM . . . .  $) . sm.  .  [. . . . b 1 1 1 1 1 1&#'    #U* +   3: >"&"&#";?#&! %+/g4g4 g4#g4g4 g4  g4 d38=#(,67 8 g4%g4g4g4g4 CK' (g4 g4g4g4g4Z $ #"! %XX {X Xe_X  X SM X  XXXXX 3-XX [XXXX| $ #"!""U U  {U U e_U   U SM U  U U U U smU smU U  3;  $%U U U U p   * 1 1 1&#'$$ $  #U* +$$ 3: $$$$@#'";?#&! ,, ,,,d38=#(,67 8 , % ,  , 3;  %&,,,,^--- $ "!BB {B Be_B  B SM B  BBB 3-B [BBBBJ...c],1$),<^2 $ "!$(,0%)#hh {h he_h  h SM h  hhh 3= !h#.)hc]h $) h [hhhh\ $ "!8<#"%)Z Z  {Z Z e_Z   Z SM Z  Z Z Z 45Z  $) Z smZ c]Z  [Z Z Z Z z      dl    0:30: }0: ; 0: SM 0: e_ 0:  0: 0:0:0:0:l36-2D58^5F#;?37 $ .1h.HrGrG rG  s" #rG #-)3. /rG3>,c1 2 rG e_ rG  rGd38=#(,67 8rGeCHM3./ 0rGrGuorG SMrGrG rGrG s*+rG  !rGrGrGrGp,0# $  HH H3H CK' (H  H e_ H uo H SMHHH HHHHHHs+C00DD