df!dZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z m Z m Z mZmZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZdZdZdZdZ ddl!Z!ddl"Z!ddl#Z#e!jHZ%e!jLjNjPZ)dZ e#jTd5dZ dddGd d e%Z,Gd d e#jZZ.eZ0 ddl1Z1ejZ2GddejfjhZ5GddejfjlZ7GddejfjhZ8GddejfjhZ9ejtjvZ;dZe?edr ejaAn ejaAdZCdZDdZEdZF dcd ZGddd!ZHdd"dddddd#ddddejf d$ejjd%eLd&e eMd'eNd(e eLd)eNd*eOd+eOd,e e d-eLd.eOd/e eLd0eeOeLfd1e d2d3e eNd4ejjf d5ZPd6ZQd7ZR ded8e d9eejjeSfd:e d;e eMd4eeNeMff d<ZT dfd8e d:e e d;e eMd=eOd*eOd>e e ejjejjfd?e eSd+eOd@eOd4e fdAZY dgd$ejjd%eLd&e eMd'eNd(e eLd)eNd=eOd*eOd+eOd@eOd8e e d4ejjfdCZZ dhd$ejjd%eLd&e eMd'eNd(e eLd)eNd=eOd*eOd+eOdDe e dEe e d4eejjeOffdFZ[dGZ\dHZ] ded8e d9eejjeSfd;e eMd4eeNeMffdIZ^ did8e d;e eMd*eOd>e e ejjejjfd?e eSd+eOd4eejjeMffdJZ_dKZ` djd$ejjd%eLd&e eMd'eNd(e eLd)eNd*eOd+eOd8e e d4ejjfdLZadMZb dkd$ejjd%eLd&e eMd'eNd(e eLd)eNd*eOd+eOd8e e1jdNe e1jdOe eLd4ejjfdPZe dld$ejjd%eLd&e eMd'eNd(e eLd)eNd*eOd+eOdQe ejjd0eeOeLfdOe eLd4ejjfdRZfejjejjddBddddddddejjf d%eLdSeejjeLfdTeejjeLfdUeejjeLfd&e eMd'eNd>e e ejjejjfdVe eejjeLfdWeOdXe eMd(e eLd)eNdYeNdZeOd[eejjeLfd4e f d\Z:Gd]d^ejZpddBddddepjfd%eLd_ejjd`e ejjd'eNd&e eMdXe eMd(e eLd)eNdaepd4dfdbZty#1swYCxYw#e+$rYNwxYw#e/$rGd d Z.YDwxYw#e/$rGddZ1YSwxYw)mzTalk to a DNS server.N)AnyDictOptionalTupleUnioncx|y|tjz }|dkrtjj|S)N)timedns exceptionTimeout) expirationtimeouts B/home/api-vastappli/venv/lib/python3.12/site-packages/dns/query.py _remainingr-s7499;&G#~mm### NcJ|yttj|z|SN)minr )rrs r_expiration_for_this_attemptr6s# tyy{W$j 11rFT)http2c2eZdZfdZ ddZ ddZxZS)_NetworkBackendcZt|||_||_||_||_yr)super__init__ _local_port _resolver_bootstrap_address_family)selfresolver local_portbootstrap_addressfamily __class__s rrz_NetworkBackend.__init__Os, G  )D %DN&7D #!DLrclg}t|\}}tjj|r|j |n|j |j |j nft |}|j} |rtjj|} |jj|| |} | j}|D]} tjj| } ||jdk7r-tjj||jf| } nd} t| tj | }t#d|} t%|tjj| |f| |t'|cSt*j,#t($rYwxYw)N)r%lifetimerg@)_compute_timesr inet is_addressappendrrr af_for_addressr resolve_name addressesrlow_level_address_tuple _make_socketsocket SOCK_STREAMr_connect_CoreSyncStream Exceptionhttpcore ConnectError)r!hostportr local_addresssocket_optionsr/_rr%answersaddressafsourcesockattempt_expirations r connect_tcpz_NetworkBackend.connect_tcpVsI*73MAzxx""4(  &((4  !8!89$Z0  XX44]CF..55'6$--/ $ XX,,W5 ,0@0@A0E XX==&(8(892F"F#B(:(:FC%A#z%R"88'4"M* +400! &'' '!s7F'' F32F3ctrNotImplementedError)r!pathrr<s rconnect_unix_socketz#_NetworkBackend.connect_unix_socket}s & %rr)__name__ __module__ __qualname__rrDrI __classcell__r&s@rrrNs "FJ% (P15 &rrc>eZdZdddejdfd ZxZS)_HTTPTransportrN)r#r$r"r%c|ddl}|jj}t||i|t |||||j _yNr) dns.resolverr"Resolverrrr_pool_network_backend) r!r#r$r"r%argskwargsr r&s rrz_HTTPTransport.__init__sM#<<002 G d -f -*9*&7+DJJ 'r)rJrKrLr2 AF_UNSPECrrMrNs@rrPrPs!"##   rrPceZdZdZy)rPctrrF)r!r9r:rr;s rrDz_HTTPTransport.connect_tcps% %rN)rJrKrLrDrrrPrPs &rcpeZdZGddeZGddeZGddZGddZed Z y ) sslc eZdZy)ssl.WantReadExceptionNrJrKrLr\rrWantReadExceptionr` rrbc eZdZy)ssl.WantWriteExceptionNrar\rrWantWriteExceptionrercrrfc eZdZy)ssl.SSLContextNrar\rr SSLContextrhrcrric eZdZy) ssl.SSLSocketNrar\rr SSLSocketrkrcrrlctd)Nzno ssl support)r6)clsrWrXs rcreate_default_contextzssl.create_default_contexts,- -rN) rJrKrLr6rbrfrirl classmethodror\rrr^r^sB           .  .rr^ceZdZdZy)UnexpectedSourcez=A DNS query response came from an unexpected address or port.NrJrKrL__doc__r\rrrrrrsGrrrceZdZdZy) BadResponsez--'' ' ::g mm### rc|ayr)r)selector_classs r_set_selector_classrs %Or PollSelectorc"t|ddd|y)NTFrsrs r_wait_for_readablers audJ/rc"t|ddd|y)NFTrrs r_wait_for_writabler s adJ/rc tjj||d}tjj||d}||k(xr |dd|ddk(S#tjj$rYywxYw)NrF)r r* inet_ptonr SyntaxError)r@a1a2n1n2s r_addresses_equalrs{ XX  BqE * XX  BqE * 8 (12"QR&(( == $ $sAAA:9A:c|syt|||s-tjj|dr |dd|ddk(ry|ryt d|d|)NTrrFzgot a response from z instead of )rr r* is_multicastrr)r@ from_address destinationignore_unexpecteds r_matches_destinationrsh L+6 k!n-,qr2BkRSRTo2U   |nL[MJ rcd}d} tjj|}|}|r3tjj|}|r||k7r t d|}|r"|s tjj |}|r"tjj ||f|}|r"tjj ||f|}|||fS#t$r|rYwxYw#t$r t dwxYw)Nz5different address families for source and destinationz3source_port specified but address family is unknown)r r*r-r6 ValueError any_for_afr0)wherer:rA source_portwhere_must_be_addressr@rsafs r_destination_and_sourcer,s  BK XX $ $U + hh%%f- by K B6 TXX((,F hh66 T7JBO  116;2GL  V $$?   !, TRS S Ts!C !C CCC4ct||} |jd||j||r|j|d|S|S#t$r|j wxYw)NF)do_handshake_on_connectserver_hostname)socket_factory setblockingbind wrap_socketr6close)r@typerA ssl_contextrrs rr1r1Xsvr4 A e   FF6N **(- /+  H    s9A A A%iz /dns-queryqrrr:rArone_rr_per_rrsetignore_trailingsessionrHpostr$verifyr"zdns.resolver.Resolverr%returnc &tst|r%t|tjs t d|j }t||||d\}}}d}ddi}|mtjj|rN|tjk(rdj||| }n)|tjk(rdj||| }n|}|d}d}n |d}|d }t|d t | || | | }|rt#j$|}ntjd t | | }|5}| r<|j'dt)t+|d |j-|||}nKt/j0|j3d}|j5}|j7||d|i}dddj8dks|j8dkDr0t dj||j8|j:tj<j?|j:|j@|jB||}|jDjG|_$|jK|stL|S#1swYxYw)aReturn 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. Returns a ``dns.message.Message``. z)session parameter must be an httpx.ClientFNacceptzapplication/dns-messagezhttps://{}:{}{}zhttps://[{}]:{}{}rrT)r;http1rrr#r$r"r%)rrr transport)z content-typezcontent-length)headerscontentr=r )rrparamsi+z2{} responded with status code {} Response body: {}keyring request_macrr)'have_dohrxrhttpxClientrto_wirerr r*r+r2AF_INETformatAF_INET6rP _have_http2 contextlib nullcontextupdatestrlenrbase64urlsafe_b64encoderstripdecodeget status_codermessage from_wirerrelapsed total_secondsr is_responserv)rrrr:rArrrrrHrr$rr"r%wirer@r= the_sourcerrurlr;r#cmresponsetwirers rhttpsrlsH  z'5<<8DEE 99;D1 tV[%RJI23G ~#((--e4  #**5$=C 6?? "%,,UD$?C  "1 ] #+ I0:0F0Fw0O \\k&I  w  NN$=&)#d)n  ||C$PW|XH++D188>DKKME{{Wguen#H(c!X%9%9C%? ""(&0D0DhFVFV"W    MM)'  A   + + -AF ==  HGs -B JJc` |j|S#t$rt||YnwxYw.)zReads a datagram from the socket. A Timeout exception will be raised if the operation is not completed by the expiration time. )recvfromBlockingIOErrorr)rBmax_sizers r _udp_recvrs9  1==* * 1 tZ 0 1 s ,,c |r|j||S|j|S#t$rt||YnwxYwB)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. )sendtosendrr)rBdatarrs r _udp_sendrsL  1{{455yy& 1 tZ 0 1 s((AArBwhatrrct|tjjr|j }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 r)rBrrr sent_timens rsend_udprsH,$ ++,||~ I$k:6A y>rrrrraise_on_truncationc d} t|d|\} } t|j| ||rn*tj} tj j | |||||} |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. r)rrrrr)rrr%r r rr) rBrrrrrrrrrr received_timers r receive_udpr:sh D (ujA|  KK{4E    IIKM  )'/  A=!!=,//r5c |j} t||||\} } }t|\}}| rtj| }nt | t j|}|5}t|| | |t|| ||||j|j|| \}}||z |_ |j|st|cdddS#1swYnxYw J)aLReturn 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. Returns a ``dns.message.Message``. N)rrr)rrr1r2 SOCK_DGRAMrrrmacr rrv)rrrr:rArrrrrrBrr@r begin_timerrrrrs rudprsf 99;D 7 tV[!Rf .g6Z 0:0F0Ft0L "f// 8 qD+z2(     II EE    M+}}Q !$ s &AC  Cudp_socktcp_sockc  t|||||||||d| } | dfS#tjj$rt ||||||||| } | dfcYSwxYw)aReturn 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. Returns a (``dns.message.Message``, tcp) tuple where tcp is ``True`` if and only if TCP was used. TF)rr r Truncatedtcp) rrrr:rArrrrrrrs rudp_with_fallbackr sn             %  ;;            $  s4AAcd}|dkDr6 |j|}|dk(rt|t|z}||z }|dkDr6|S#ttj f$rt ||Y/tj$rt||YOwxYw)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. rr) recvEOFErrorrrr^SSLWantReadErrorrSSLWantWriteErrorr)rBcountrrrs r _net_readr+s A !) 1 % ACx SVOE FA !) H  !5!56 1 tZ 0$$ 1 tZ 0 1s/A%B'BBcd}t|}||kr ||j||dz }||kryy#ttjf$rt ||Y/tj $rt||YOwxYw)zWrite the specified data to the socket. A Timeout exception will be raised if the operation is not completed by the expiration time. rN)rrrr^rrrr)rBrrcurrentls r _net_writer@s~ G D A A+ 1 tyygh0 0G A+ !6!67 1 tZ 0## 1 tZ 0 1s3%A;A;:A;ct|tjjr|j }n|}t |}t jd||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. !H) rr rrrrstructpackr r)rBrrrrtcpmsgrs rsend_tcprPsn$$ ++,||~ D A[[q !D (F ItVZ( K ##rct|d|}tjd|\}t|||}tj} tj j |||||} | | 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. rr)rrunpackr r rr) rBrrrrrldatarrrrs r receive_tcpr"pssB dAz *E ==u %DQ T1j )DIIKM  )'  A } rcP|j|}|dk(ry|tjtjtjfvr:t |||j tjtj}|dk7rt|tj|yrR) connect_exerrno EINPROGRESS EWOULDBLOCKEALREADYr getsockoptr2 SOL_SOCKETSO_ERROROSErrorosstrerror)rr?rerrs rr4r4s ,,w C ax u  %"3"3U^^DD1j)ll6,,foo> axc2;;s+,,rc |j} t|\} } |rtj|} n-t ||||\} }}t | t j|} | 5}|s t|| t|| | t|| ||j|j|\}}|| z |_ |j|st|cdddS#1swYnxYw 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)rrrr1r2r3r4rr"rrr rrv)rrrr:rArrrrBrrrrr@rrrrs rr r sV 99;D-g6Z 0:0F0Ft0L$; 4% ![&"f00& 9 q Q Z 0D*%( z+QYY M+}}Q     s &A&CCc |jy#tj$rt||Yn$tj$rt ||YnwxYwXr) do_handshaker^rrrrrs r_tls_handshaker3sS  . NN  ## . q* -$$ . q* - . sAAArrc Z|rt||||||||| S|j} t|\} } t||||\}}}| >|sr>as_d 88  566 AD 99;D5?5K5KD5Q#((**O+  (00fkRN,W5  ' ' 0 :F KKd #>>*Z"89D :   MM)'  A% %AF ==  H : : s$<6E42-E(E4(E1 -E44E=zonerdtyperdclasskeyname relativizer(serialuse_udp keyalgorithmc # Kt|trtjj |}tj j j|}tjj|||}|tj jk(rAtjj |dddd| z}|jj|||j||||j}t!||| | \}}} | r(|tj jk7r t#d| rt$j&nt$j(}t+||| 5}t-| \}}t/|||t1|}| rt3||d|n&t5j6d||z}t9|||d }d }d }d}|r|}tjj:}nd}|}d} |sgt-|\}}!|!||!|kDr|}!| rt=|d |!\}}n2t?|d |!}"t5j@d|"\}t?|||!}|tj jk(}#tjjC||jD|jFd || d |# }$|$jI}%|%tjHjJk7r tM|%|$jN} d}&||$jPr|$jPdj|k7rtjRjUd|$jPd}|jVtj jXk7rtjRjUdd}&|j[}|tj jk(r4tj\j_|dj\| krd }nd }|$jP|&dD]}|rtjRjUd|jVtj jXk(r|j|k(r|r4|dj\| k7rtjRjUdd }n |tj jk(r| }||k(s|tj j`k(s!|tj jk(s|sd }|stj j`}d }|r7|jDr+|$jbstjRjUd|$|sgdddy#1swYyxYww)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. rINSOAz. . %u 0 0 0 0N) algorithmzcannot do a UDP AXFRrFTrrrrxfrorigintsig_ctxmultirz No answer or RRset not for qnamezfirst RRset is not an SOArzanswers after final SOAzIXFR base serial mismatch missing TSIG)2rrr name from_text rdatatype RdataTypemaker make_queryIXFRrrset authorityr,use_tsigrrrr2rr3r1r)r4rrrrremptyrrr rrrrcodeNOERROR TransferErrorr[answerr FormErrorrMrVcopyrQSerialAXFRhad_tsig)'rrLrMrNrr:rrOrPr(rArrQrRrSrrerr@r sock_typerr=rrrdone delete_mode expecting_SOA soa_rrsetrZonamer[ mexpirationr!is_ixfrrri answer_indexs' rrYrYsJ$xx!!$' ]] $ $ ) )& 1F tVW5A ### ##D!T5:JV:ST 5! 7G| < 99;D 7 tV[!Rf6S]]////00%,!!&2D2DI b)V ,b(2JK, I  atZ 0[[q)D0F q&* -   FHHNNEFE-g6 Q "&;+C( %a < q!!Q 4}}T51 A{3 2 22G %% EE!!(& AGGIE )))#E**zzHL xx188A;#3#3u#<--112TUU <<3==#4#44--112MNN !JJL S]]///zz((1)<)<=G $(, ,-0 *--112KLL<<3==#4#44u9L$ 8??f4"%--"9"9:U"VV(- 3==#5#55*5o  )#--"4"44"cmm&8&88[#" !]]//F$)M7 *8 !**mm--n==G])bbbs8E)U5+MU)<:U)7U):U)AU) U5)U2.U5ceZdZdZdZdZdZy)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)rJrKrLrtNEVER TRY_FIRSTONLYr\rrr|r|rs EI Drr| txn_managerqueryudp_modec |#tjj|\}} ntjj|} |jdj } | tj jk(} |j} |j} t||||\}}}t|\}}d}|rd}| r&|tjk7rtj}d}ntj }d}t#|||5}t%||||rt'|| d|n/t)j*dt-| | z}t/|||tjj1|| | |5}d}d}|st|\}}||||kDr|}|rt3|d|\}}n2t5|d|}t)j6d|\}t5|||}tj8j;||j<|j>d| || | } |jA|}|jF}|s|s7|j<r+jHstjJjMd dddddd|ryy#tjjB$r0|sJ|tjDk(rd}d}tj}YXwxYw#1swYgxYw#1swYkxYw) 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. NrTFrrrrXr])'r rYrcextract_serial_from_queryquestionrMr`rdfrom_wire_originrrr)r|r}r2rr3r1r4rrrrrInboundrrr rrrrprocess_messageUseTCPrr[rqr rm)rrrr:rr(rArrrQrMryrZrr@rr=rretryrris_udprrinboundrsr[rxrwirer!rrs r inbound_xfrrs^ }'',,[92259 ^^A  % %F ***G  ) ) +F ==?D 7 tV[!Rf%X.OQ E  x7==0))IF**IF "i 0, BA Q Z 0!T44T3t95<1fj1fffE% B'5g'>$Q "*".;3K&0 %.q%%E  )!Q <%}}T59 )!Q < -- % $)II %!)#)z)0. A !&66q9 !zzHABqzz--11.AAK% B, B T77>>!% #w||3!# $#*== !7% B% B, B, BsQ A0K&9B!KJ ,K;9K4K& A KKKKK# K&&K/)T)NNr)NNFFNrFF) NrNrFFFFN) NrNrFFFNN)NFNrF)NrNrFFN) NUNrFFNNN) NrNrFFNTN)urtrrenumr%r-rr2rr typingrrrrr dns.exceptionr dns.inet dns.messagedns.namedns.quic dns.rcodedns.rdataclass dns.rdatatype dns.serialdns.transactiondns.tsigdns.xfrrr _have_httpxrr7httpcore._backends.syncrNetworkBackend_CoreNetworkBackend _backendssync SyncStreamr5rr6r HTTPTransportrP ImportErrorrr^rr DNSExceptionrrrmrvrxr{rYrkr)rrhasattrrrSelectSelectorrrrrrr1rYrrrfloatintboolrrrbytesrr^NametsigKeyrrr rrrr"r4r r3rlrir9r>SyncQuicConnectionr`rp rdataclassrUdefault_algorithmra RdataClassIntEnumr|r} transactionTransactionManagerrr\rrrs| $   442   \&""11((--88OK U\\ % K  2&-2&h,,6 ..Hs}}11HG#--))GCMM & & CMM & & %% $$8% 9n% ,,O..O00 ) "=A)%X. $ "!!'+#26",,S  {{S S e_S   S SM S  S S S c]S  S  S  }S  $) S ./S  SMS  [[!S l 1 1&#'    ##U* +   3: >"&"&#";?#&! %G0 G0#G0G0 G0  G0 d388==#((,,67 8 G0%G0G0G0 G0Z $ #"! %O {{O Oe_O  O SM O  OOOOO 3-O [[Oj $ #"!""R  {{R R e_R   R SM R  R R R R smR smR  3;;   $%R j * 1&#'$ $  ##U* +$$ 3: $D#'";?#&! , ,,,d388==#((,,67 8 , % ,  , 3;;   %&,^- $ "!A {{A Ae_A  A SM A  AAA 3-A [[AH. $ "!$(,0%)e {{e ee_e  e SM e  eee 3== !e#..)ec]e [[eV $ "!8<#%)T  {{T T e_T   T SM T  T T T 445T  $) T c]T  [[T t36--2D2D58^^5F5F#;?37 $ .1hh.H.Hw w  s" #w #--))3. /w3>>,,c1 2 w e_ w  wd388==#((,,67 8weCHHMM3./ 0wwuow SMww ww s*+w  !wt  dll  ,0# $  pB pB33pB CKK'' (pB  pB e_ pB uo pB SMpBpBpB pBm)      V&&&&....s`0:\+\>\\ \,\1\ \\\\\\.-\.1]]