⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.24
Server IP:
50.6.168.112
Server:
Linux server-617809.webnetzimbabwe.com 5.14.0-570.25.1.el9_6.x86_64 #1 SMP PREEMPT_DYNAMIC Wed Jul 9 04:57:09 EDT 2025 x86_64
Server Software:
Apache
PHP Version:
8.4.10
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3.9
/
site-packages
/
dns
/
__pycache__
/
View File Name :
query.cpython-39.pyc
a Me0 @ s^ d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z m Z mZmZmZ ddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Zddl Zddl Zdd Z dd Z ej!"dZ#e#r>ddl$Z%ddl&Z&e%j'Z(e%j)j*j+Z,G d d d e(Z-G d d d e&j.Z/nG d d d Z/e#Z0z ddl1Z1W n" e2y~ G dd dZ1Y n0 ejZ3G dd dej4j5Z6G dd dej4j7Z8G dd dej4j5Z9G dd dej4j5Z:ej;j<Z<dd Z=dd Z>d d Z?e@ed r ejAaBnejCaBd d ZDd!d" ZEd#d$ ZFd%d& ZGdhd(d)ZHdid*d+ZIdd,ddd-d-dd.d'dd'dejJf ejKjLeMeeN eOeeM eOePePee eMePeeM eePeMf ed/ eeO ejKjLd0d1d2ZQd3d4 ZRd5d6 ZSdje eejKjLeTf e eeN eeOeNf d7d8d9ZUdke ee eeN ePePee ejVjWejXjYf eeT ePePePeejKjL e d; d<d=ZZdlejKjLeMeeN eOeeM eOePePePePee ePejKjLd? d@dAZ[dmejKjLeMeeN eOeeM eOePePePee ee ePeejKjLePf dB dCdDZ\dEdF Z]dGdH Z^dne eejKjLeTf eeN eeOeNf dIdJdKZ_doe eeN ePee ejVjWejXjYf eeT ePeejKjLeNf dLdMdNZ`dOdP ZadpejKjLeMeeN eOeeM eOePePee ejKjLdQ dRdSZbdTdU ZceeM eePeMf e1jddVdWdXZedqejKjLeMeeN eOeeM eOePePee1jf ee1jd eeM eePeMf ejKjLdZ d[d\ZgdrejKjLeMeeN eOeeM eOePePeejhji eePeMf eeM ejKjLd] d^d_Zhejjjkejljmdd>ddd'ddddd-ejXjnf eMeejVjWeMf eejjjoeMf eejljpeMf eeN eOee ejVjWejXjYf eeejVjWeMf ePeeN eeM eOeOePeejVjWeMf e d`dadbZ;G dcdd ddejqZrdd>dddderjsfeMejtjueejKjL eOeeN eeN eeM eOerdde dfdgZvdS )szTalk to a DNS server. N)AnyDictOptionalTupleUnionc C s, | d u r d S | t }|dkr(tjj|S )N )timedns exceptionTimeout) expirationtimeout r -/usr/lib/python3.9/site-packages/dns/query.py _remaining/ s r c C s |d u r d S t t | |S N)minr )r r r r r _expiration_for_this_attempt8 s r Zdohc s0 e Zd Z fddZdddZd ddZ ZS ) _NetworkBackendc s& t || _|| _|| _|| _d S r )super__init__ _local_port _resolver_bootstrap_address_family)selfresolver local_portbootstrap_addressfamily __class__r r r G s z_NetworkBackend.__init__Nc C s g }t |\}}tj|r(|| nP| jd ur@|| j n8t|}| j} |r^tj|} | j j || |d} | }|D ]} tj| } |d us| j dkrtj || j f| } nd } t| tj| }td|}z(t|tj | |f| | t|W S ty Y q|0 q|tjd S )N)r lifetimer g @)_compute_timesr inet is_addressappendr r r af_for_addressr resolve_name addressesr low_level_address_tuple _make_socketsocket SOCK_STREAMr _connect_CoreSyncStream ExceptionhttpcoreZ ConnectError)r hostportr local_addresssocket_optionsr) _r r ZanswersaddressafsourcesockZattempt_expirationr r r connect_tcpN sB z_NetworkBackend.connect_tcpc C s t d S r NotImplementedError)r pathr r5 r r r connect_unix_socketu s z#_NetworkBackend.connect_unix_socket)N)N)__name__ __module__ __qualname__r r; r? __classcell__r r r r r F s ( r c s* e Zd Zdddejd fdd Z ZS )_HTTPTransportr N)r r r r c sB |d u rdd l }|j }t j|i | t||||| j_d S Nr )Z dns.resolverr ZResolverr r r Z_poolZ_network_backend)r r r r r argskwargsr r r r r { s z_HTTPTransport.__init__)r@ rA rB r, AF_UNSPECr rC r r r r rD z s rD c @ s e Zd Zdd ZdS )rD c C s t d S r r< )r r2 r3 r r4 r r r r; s z_HTTPTransport.connect_tcpN)r@ rA rB r; r r r r rD s c @ sX e Zd ZdZG dd deZG dd deZG dd dZG dd d Ze d d Z d S ) sslr c @ s e Zd ZdS )zssl.WantReadExceptionNr@ rA rB r r r r WantReadException s rK c @ s e Zd ZdS )zssl.WantWriteExceptionNrJ r r r r WantWriteException s rL c @ s e Zd ZdS )zssl.SSLContextNrJ r r r r SSLContext s rM c @ s e Zd ZdS )z ssl.SSLSocketNrJ r r r r SSLSocket s rN c O s t dd S )Nzno ssl support)r0 )clsrF rG r r r create_default_context s zssl.create_default_contextN) r@ rA rB CERT_NONEr0 rK rL rM rN classmethodrP r r r r rI s rI c @ s e Zd ZdZdS )UnexpectedSourcez=A DNS query response came from an unexpected address or port.Nr@ rA rB __doc__r r r r rS s rS c @ s e Zd ZdZdS ) BadResponsez<A DNS query response does not respond to the question asked.NrT r r r r rV s rV c @ s e Zd ZdZdS )NoDOHzMDNS over HTTPS (DOH) was requested but the httpx module is not available.NrT r r r r rW s rW c @ s e Zd ZdZdS )NoDOQzNDNS over QUIC (DOQ) was requested but the aioquic module is not available.NrT r r r r rX s rX c C s( t }| d u r|d fS ||| fS d S r )r )r Znowr r r r# s r# c C s |r t | tjr | dkr dS t }d}|r8|tjO }|rF|tjO }|rV|| | |d u rdd }n |t }|dkrt j j | |st j j d S )Nr Tr ) isinstancerI rN pending_selector_class selectorsZ EVENT_READZ EVENT_WRITEregisterr r r r Zselect)fdreadablewritabler6 r ZselZeventsr r r r _wait_for s" ra c C s | a d S r )r[ )Zselector_classr r r _set_selector_class s rb PollSelectorc C s t | ddd| d S )NTFra sr r r r _wait_for_readable s rg c C s t | ddd| d S )NFTrd re r r r _wait_for_writable s rh c C sb z(t j| |d }t j| |d }W n t jjy@ Y dS 0 ||ko`|dd |dd kS )Nr F )r r$ Z inet_ptonr SyntaxError)r8 Za1Za2Zn1Zn2r r r _addresses_equal s rk c C s` |sdS t | ||s<tj|d r@|dd |dd kr@dS |rHdS td| d| d S )NTr ri Fzgot a response from z instead of )rk r r$ Z is_multicastrS )r8 from_address destinationignore_unexpectedr r r _matches_destination s ro Tc C s d }d }zt j| }| }W n ty4 |r0 Y n0 |r`t j|}|r\||kr`tdn|}|r|szt j|}W n ty tdY n0 |rt j||f|}|rt j||f|}|||fS )Nz5different address families for source and destinationz3source_port specified but address family is unknown)r r$ r' r0 ValueErrorZ any_for_afr* )wherer3 r9 source_portZwhere_must_be_addressr8 rm Zsafr r r _destination_and_source& s4 rs c C sh t | |}z<|d |d ur(|| |r>|j|d|dW S |W S W n tyb | Y n0 d S )NF)Zdo_handshake_on_connectserver_hostname)socket_factoryZ setblockingZbindZ wrap_socketr0 close)r8 typer9 ssl_contextrt rf r r r r+ R s r+ i Fz /dns-queryzdns.resolver.Resolver)qrq r r3 r9 rr one_rr_per_rrsetignore_trailingsessionr> postr verifyr r returnc C s t st|r t|tjs td| }t||||d\}}}d}ddi}|durtj |r|t j krxd ||| }q|t jkrd ||| }n|}|du rd}d}n|d }|d }t|d d | || | |d }|rt|}ntjd d | |d }|p}| r*|dtt|d |j||||d}n.t|d}| }|j|||d|id}W d n1 sn0 Y |jdk s|jdkrtd ||j|j tj j |j | j | j ||d}|j!" |_#| $|st%|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://<IP-address>:<port>/<path>. *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.ClientFNZacceptzapplication/dns-messagezhttps://{}:{}{}zhttps://[{}]:{}{}r ri T)r4 http1http2r~ r r r r )r r r~ transport)z content-typezcontent-length)headerscontentr =r )r r params i+ z2{} responded with status code {} Response body: {}keyring request_macrz r{ )&have_dohrW rY httpxZClientrp to_wirers r r$ r% r, ZAF_INETformatZAF_INET6rD contextlib nullcontextupdatestrlenr} base64Zurlsafe_b64encoderstripdecodegetZ status_coder message from_wirer r elapsedZ total_secondsr is_responserV ) ry rq r r3 r9 rr rz r{ r| r> r} r r~ r r wirer8 r6 Z the_sourcer r urlr4 r cmresponseZtwirerr r r httpsf s D & r c C s0 z | |W S ty( t| | Y q 0 q dS )zReads a datagram from the socket. A Timeout exception will be raised if the operation is not completed by the expiration time. N)ZrecvfromBlockingIOErrorrg )r: Zmax_sizer r r r _udp_recv s r c C sF z"|r| ||W S | |W S W q ty> t| | Y q 0 q dS )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. N)Zsendtosendr rh )r: datarm r r r r _udp_send s r )r: whatrm r r c C s4 t |tjjr| }t }t| |||}||fS )a Send 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. )rY r r Messager r r )r: r rm r sent_timenr r r send_udp s r ) r: rm r rn rz r r r{ raise_on_truncation ignore_errorsqueryr c C s d} t | d|\} } t| j| ||s&qt } z tjj| |||||d}W nn tjjy } z6| r| dur| | sW Y d}~qn W Y d}~n&d}~0 t y | rY qn Y n0 | r| dur| |sq|r|| fS || | fS qdS )a Read 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. r )r r rz r{ r N) r ro r r r r r Truncatedr r0 )r: rm r rn rz r r r{ r r r r rl received_timer er r r receive_udp2 sD > r 5 ) ry rq r r3 r9 rr rn rz r{ r r: r r c C s | } t||||\} }}t|\}}| r8t| }nt| tj|}|b}t|| || t |||||| j | j || | | \}}|| |_ | s| |st|W d S 1 s0 Y dsJ dS )a Return 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``. NF)r rs r# r r r+ r, SOCK_DGRAMr r r macr r rV )ry rq r r3 r9 rr rn rz r{ r r: r r r8 rm begin_timer r rf r r r r r udp s: 8 "r ) ry rq r r3 r9 rr rn rz r{ udp_socktcp_sockr r c C sd z(t | ||||||||d| | } | dfW S tjjy^ t| |||||||| } | df Y S 0 dS )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. TFN)r r r r tcp) ry rq r r3 r9 rr rn rz r{ r r r r r r r udp_with_fallback s: 9 r c C s d}|dkr|z.| |}|dkr$t|t|8 }||7 }W q ttjfy\ t| | Y q tjyx t| | Y q0 q|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. r r ) ZrecvEOFErrorr r rI SSLWantReadErrorrg SSLWantWriteErrorrh )r: countr rf r r r r _net_readO s r c C st d}t |}||k rpz|| ||d 7 }W q ttjfyP t| | Y q tjyl t| | Y q 0 q dS )zWrite the specified data to the socket. A Timeout exception will be raised if the operation is not completed by the expiration time. r N)r r r rI r rh r rg )r: r r currentlr r r _net_writed s r )r: r r r c C sP t |tjjr |jdd}nt|dd| }t }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)Zprepend_length Zbig) rY r r r r r to_bytesr r )r: r r tcpmsgr r r r send_tcpt s r )r: r rz r r r{ r c C sL t | d|}td|\}t | ||}t } tjj|||||d} | | fS )a Read 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 )r structunpackr r r r ) r: r rz r r r{ ldatar r r r r r r receive_tcp s ! r c C s` | |}|dkrd S |tjtjtjfv rDt| | | tjtj }|dkr\t |t |d S rE ) Z connect_exerrnoZ EINPROGRESSZ EWOULDBLOCKZEALREADYrh Z getsockoptr, Z SOL_SOCKETZSO_ERROROSErrorosstrerror)rf r7 r errr r r r. s r. ) ry rq r r3 r9 rr rz r{ r: r c C s | } t|\} } |r$t|} n"t||||\} }}t| tj|} | b}|s\t||| t || | t || || j | j |\}}|| |_ | |st|W d S 1 s0 Y dsJ dS )a Return 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``. NF)r r# r r rs r+ r, r- r. r r r r r r rV )ry rq r r3 r9 rr rz r{ r: r r r r r8 rm rf r r r r r r s* + "r c C sP z| W d S tjy, t| | Y q tjyH t| | Y q 0 q d S r )Z do_handshakerI r rg r rh re r r r _tls_handshake s r )rt r~ r c C s d }d }t |tr>tj|r$|}ntj|r6|}ntdtj||d}tj j |_ | d u rdd|_ | dg |du rtj|_|S )Nzinvalid verify string)cafilecapathFdot)rY r r r> isfileisdirrp rI rP Z TLSVersionZTLSv1_2Zminimum_versionZcheck_hostnameZset_alpn_protocolsrQ verify_mode)rt r~ r r rx r r r _make_dot_ssl_context s r U ) ry rq r r3 r9 rr rz r{ r: rx rt r~ r c C s |r t | |||||||| S | } t|\} }t||||\}}}| du rZ|sZt| | } t|tj|| | dh}t||| t || t || | t |||| j | j |\}}|| |_| |st|W d S 1 s0 Y dsJ dS )ak Return 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)rx rt F)r r r# rs r r+ r, r- r. r r r r r r r rV )ry rq r r3 r9 rr rz r{ r: rx rt r~ r r r r8 rm rf r r r r r tls1 sN = "r ) ry rq r r3 r9 rr rz r{ connectionr~ rt r c C s t jjstdd| _| } |r2td} |} nt jj| | d} | }| | |s`| ||||} t |\}}| |*}| | d | t|} W d n1 s0 Y t }W d n1 s0 Y t jj| | j| j||d}t|| d|_| |st|S )a Return 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. *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. Returns a ``dns.message.Message``. z DNS-over-QUIC is not available.r N)r Z server_nameTr r )r quicZ have_quicrX idr r r ZSyncQuicManagerZconnectr# Z make_streamr Zreceiver r r r r r maxr rV )ry rq r r3 r9 rr rz r{ r r~ rt r ZmanagerZthe_connectionZ the_managerstartr streamZfinishr r r r r s< 2 ,& r )rq zonerdtyperdclassr r3 r keyname relativizer" r9 rr serialuse_udp keyalgorithmr c ' c s t |trtj|}tjj|}tj |||}|tjj krdtj |dddd| }|j | |dur||j|||d | }t| || | \}}} | r|tjj krtd| rtjntj}t||| }t| \}}t||| t|}| rt||d| n td|| }t ||| d }d }d } d} |rF|} tjj } nd} |} d} |st|\}}!|!du s|dur|!|kr|}!| rt |d |!\}}n&t |d |!}"t d|"\}t |||!}|tjj k}#tjj!||j"|j#d | | d |#d }$|$$ }%|%tj$j%krt&|%|$j'} d}&| du r|$j(r<|$j(d j| krHtj)*d|$j(d }|j+tjj,krntj)*dd}&|- } |tjj krtj./| d j.| krd }nd } |$j(|&d D ]}|rtj)*d|j+tjj,krX|j| krX| r|d j.| kr tj)*dd } n|tjj kr&| }|| krj|tjj0ksR|tjj krj|rjd }n| rtjj0}d } q|r|j"r|$j1stj)*d|$V qRW d n1 s0 Y dS )a Return 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. r INSOAz. . %u 0 0 0 0N) algorithmzcannot do a UDP AXFRr FTr r r r xfrorigintsig_ctxZmultirz z No answer or RRset not for qnamezfirst RRset is not an SOAri zanswers after final SOAzIXFR base serial mismatch missing TSIG)2rY r r nameZ from_text rdatatype RdataTypeZmaker make_queryIXFRrrsetZ authorityr& Zuse_tsigr rs rp r, r r- r+ r# r. r r r packr emptyr r r r r r rcodeZNOERROR TransferErrorr Zanswerr FormErrorr r copyr ZSerialAXFRhad_tsig)'rq r r r r r3 r r r r" r9 rr r r r ry r r r8 rm sock_typerf r6 r r r doneZ delete_modeZ expecting_SOAZ soa_rrsetr Zonamer mexpirationr is_ixfrr r Z answer_indexr r r r s E r c @ s e Zd ZdZdZdZdZdS )UDPModea How 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" r ri r N)r@ rA rB rU NEVERZ TRY_FIRSTONLYr r r r r s r ) rq txn_managerr r3 r r" r9 rr udp_moder c C sh |du rt j|\}} n t j|} |jd j} | t jjk} | } | } t | |||\}}}t |\}}d}|rdd}| r|t j krtj}d}n tj}d}t|||}t||| |rt|| d| n tdt| | }t||| t j|| | |,}d}d}|s t |\}}|du s>|durB||krB|}|rZt|d|\}}n&t|d|} td| \} t|| |}t j j ||j |j d| || | d} z| | }W nD t jj!y |sJ |t j"kr܂ d}d}t j }Y qY n0 | j#}q|s"|j r"| j$s"t j%&d W d n1 s80 Y W d qr1 sX0 Y qrdS ) a Conduct 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 TFr r r r r )'r r r Zextract_serial_from_queryZquestionr r r Zfrom_wire_originr rs r# r r r, r r- r+ r. r r r r r ZInboundr r r r r r r Zprocess_messageZUseTCPr r r r r ) rq r r r3 r r" r9 rr r r r r r r r8 rm r6 r Zretryr Zis_udprf r Zinboundr r r Zrwirer r r r r r inbound_xfr s / r )T)NN)N) NNFFNr FFFN) Nr Nr FFFFNF) Nr Nr FFFNNF)N)NFNr F)Nr Nr FFN) Nr Nr FFNNNT) Nr Nr FFNTN)wrU r r enumr r Zos.pathr\ r, r r typingr r r r r Z dns._featuresr Z dns.exceptionZdns.inetZ dns.messageZdns.nameZdns.quicZ dns.rcodeZdns.rdataclassZ dns.rdatatypeZ dns.serialZdns.transactionZdns.tsigZdns.xfrr r Z _featuresZhaveZ _have_httpxZhttpcore._backends.syncr1 r ZNetworkBackendZ_CoreNetworkBackendZ _backendssyncZ SyncStreamr/ r Z HTTPTransportrD r rI ImportErrorru r Z DNSExceptionrS r rV rW rX r r r# ra rb hasattrrc r[ ZSelectSelectorrg rh rk ro rs r+ rH r r r floatintboolr r r bytesr r NameZtsigZKeyr r r r r r r r. r r rM r rN r r ZSyncQuicConnectionr r Z rdataclassr Zdefault_algorithmr Z RdataClassIntEnumr r Z transactionZTransactionManagerr r r r r <module> s 4 , m ^ X / D n Z ;