File: //opt/alt/python37/lib/python3.7/site-packages/dns/__pycache__/query.cpython-37.pyc
B
��f� � @ s. d Z ddlmZmZmZmZmZ ddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl
Z
ddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Zddl Zddl Zy(ddl Z ddl m!Z! ddl"m#Z# dZ$W n e%k
�r dZ$Y nX dZ&dZ'yHddl(Z(dZ&y e(j)dd��
dZ'W dQ R X W n e*k
�r` Y nX W n e%k
�rz Y nX e$�p�e&Z+y ddl,Z,W n$ e%k
�r� G d d
� d
�Z,Y nX e
j
Z-G d d � d ej.j/�Z0G d
d� dej.j1�Z2G dd� dej.j/�Z3G dd� dej.j/�Z4ej5j6Z6dd� Z7dd� Z8dd� Z9e:e d��rBe j;a<ne j=a<dd� Z>d d � Z?d d � Z@d d!� ZAd]d"d#�ZBd^d$d%�ZCd_ejDjEeFeeG eHeeF eHeIeIee eFeIeeF eeIeFf ejDjEd(�d)d*�ZJd+d,� ZKd-d.� ZLd`eeejDjEeMf eeeG eeHeGf d/�d0d1�ZNdaeee eeG eIeIeeejOjPejQjRf eeM eIeIed3�
d4d5�ZSdbejDjEeFeeG eHeeF eHeIeIeIeIee ejDjEd7� d8d9�ZTdcejDjEeFeeG eHeeF eHeIeIeIee ee eejDjEeIf d:� d;d<�ZUd=d>� ZVd?d@� ZWddeeejDjEeMf eeG eeHeGf dA�dBdC�ZXdeeeeG eIeeejOjPejQjRf eeM eIeejDjEeGf dD�dEdF�ZYdGdH� ZZdfejDjEeFeeG eHeeF eHeIeIee ejDjEdI�
dJdK�Z[dLdM� Z\dgejDjEeFeeG eHeeF eHeIeIee,j] ee,j^ eeF ejDjEdO� dPdQ�Z_dhejDjEeFeeG eHeeF eHeIeIeej`ja eeIeFf ejDjEdR� dSdT�Z`ejbjcejdjedd6ddddddddejQjff
eFeejOjPeFf eejbjgeFf eejdjheFf eeG eHeeejOjPejQjRf eeejOjPeFf eIeeG eeF eHeHeIeejOjPeFf edU�dVdW�Z5G dXdY� dYe ji�Zjdd6ddddejjkfeFejljmeejDjE eHeeG eeG eeF eHejddZ�
d[d\�ZndS )izTalk to a DNS server.� )�Any�Dict�Optional�Tuple�UnionN)�SourceAddressAdapter)�HostHeaderSSLAdapterTF)�http2c @ sT e Zd ZG dd� de�ZG dd� de�ZG dd� d�ZG dd� d�Zed d
� �Z d S ) �sslc @ s e Zd ZdS )zssl.WantReadExceptionN)�__name__�
__module__� __qualname__� r r �:/opt/alt/python37/lib/python3.7/site-packages/dns/query.py�WantReadExceptionM s r c @ s e Zd ZdS )zssl.WantWriteExceptionN)r r r
r r r r �WantWriteExceptionP s r c @ s e Zd ZdS )zssl.SSLContextN)r r r
r r r r �
SSLContextS s r c @ s e Zd ZdS )z
ssl.SSLSocketN)r r r
r r r r � SSLSocketV s r c O s t d��d S )Nzno ssl support)� Exception)�cls�args�kwargsr r r �create_default_contextY s zssl.create_default_contextN)
r r r
r r r r r � classmethodr r r r r r
L s
r
c @ s e Zd ZdZdS )�UnexpectedSourcez=A DNS query response came from an unexpected address or port.N)r r r
�__doc__r r r r r c s r c @ s e Zd ZdZdS )� BadResponsez<A DNS query response does not respond to the question asked.N)r r r
r r r r r r g s r c @ s e Zd ZdZdS )�NoDOHzPDNS over HTTPS (DOH) was requested but the requests module is not
available.N)r r r
r r r r r r k s r c @ s e Zd ZdZdS )�NoDOQzNDNS over QUIC (DOQ) was requested but the aioquic module is not
available.N)r r r
r r r r r r p s r c C s( t � � }| d kr|d fS ||| fS d S )N)�time)�timeout�nowr r r �_compute_timesy s r" c C s� |r t | tj�r | �� dkr dS t� }d}|r8|tjO }|rF|tjO }|rV|�| |� |d krdd }n |t � � }|dkr�t
j j �|�
|�s�t
j j �d S )Nr Tg )�
isinstancer
r �pending�_selector_class� selectors�
EVENT_READ� EVENT_WRITE�registerr �dns� exception�Timeout�select)�fd�readable�writable�_�
expiration�sel�eventsr r r r � _wait_for� s"
r5 c C s | a d S )N)r% )Zselector_classr r r �_set_selector_class� s r6 � PollSelectorc C s t | ddd|� d S )NTF)r5 )�sr2 r r r �_wait_for_readable� s r9 c C s t | ddd|� d S )NFT)r5 )r8 r2 r r r �_wait_for_writable� s r: c C sb y(t j�| |d �}t j�| |d �}W n t jjk
r@ dS X ||ko`|dd � |dd � kS )Nr F� )r* �inet� inet_ptonr+ � SyntaxError)�afZa1Za2Zn1Zn2r r r �_addresses_equal� s r@ c C s` |sdS t | ||�s<tj�|d �r@|dd � |dd � kr@dS |rHdS td|� d|� ���d S )NTr r; Fzgot a response from z instead of )r@ r* r< � is_multicastr )r? � from_address� destination�ignore_unexpectedr r r �_matches_destination� s (rE c C s� d }d }yt j�| �}| }W n tk
r6 |r2� Y nX |rbt j�|�}|r^||krbtd��n|}|r�|s�|tjkrzd}n|tjkr�d}ntd��|r�t j�||f|�}|r�t j�||f|�}|||fS )Nz5different address families for source and destinationz0.0.0.0z::z3source_port specified but address family is unknown) r* r< Zaf_for_addressr �
ValueError�socket�AF_INET�AF_INET6Zlow_level_address_tuple)�where�port�source� source_portZwhere_must_be_addressr? rC Zsafr r r �_destination_and_source� s4
rN c C sf t | |�}y8|�d� |d k r(|�|� |r<|j|d|d�S |S W n tk
r` |�� � Y nX d S )NF)�do_handshake_on_connect�server_hostname)�socket_factory� setblocking�bind� wrap_socketr �close)r? �typerL � ssl_contextrP r8 r r r � _make_socket s
rX � �
/dns-query)�qrJ r rK rL rM �one_rr_per_rrset�ignore_trailing�session�path�post�bootstrap_address�verify�returnc
C s� t s td��t}
| �� }t||||d�\}}}d}d}ddi}|dk rz|tjkr`d�||| �}q�|tjkr�d�||| �}nR| dk r�d}
t j
� |�}|j dkr�t
d��|j |d < |�|j | �}tr�t� }n|}|dk �rtr�|d
kr�tj|d
| d �}nd}
t�rt|�}|�r<t�r"t|tj�}nd}|�r@|
�s@td ��n|
}|
�sTt�sTtd
��|�rft�|�}n$|�r�tjdt| |d�}n
tj�� }|��}|�r�|�s�|� ||� |
�r�|� dt t |��d�� |�r�|j ||||d�}n|j ||||| d�}nNt!�"|��#d�}|�r,|�$� }|j%|||d|id�}n|j%|||| d|id�}W dQ R X |j&dk �sf|j&dk�r|t
d�||j&|j'���t(j)j*|j'| j+| j,||d�}|j-�.� |_/| �0|��s�t1�|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`` or ``requests.session.Session``. 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 the system's DNS
resolver.
*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``.
z(Neither httpx nor requests is available.FN�acceptzapplication/dns-messagezhttps://{}:{}{}zhttps://[{}]:{}{}zDoH URL has no hostname�Hostr )Z
local_addressrb zGSession is httpx, but httpx cannot be used for the requested operation.zCCannot use httpx for this operation, and requests is not available.T)Zhttp1r rb � transport)z content-typezcontent-length)�headers�contentr )rg �datar rb � =r* )rg r �params)rg r rb rk �� i+ z2{} responded with status code {}
Response body: {})�keyring� request_macr\ r] )2�have_dohr � _have_httpx�to_wirerN rG rH �formatrI �urllib�parse�urlsplit�hostnamerF �replace�_have_requestsr �httpxZ
HTTPTransportr r# �Client�
contextlib� nullcontext� _have_http2�requests�sessions�Session�mount�update�str�lenr` �base64�urlsafe_b64encode�rstrip�decode�get� status_coderh r* �message� from_wirerm rn �elapsed�
total_secondsr � is_responser )r[ rJ r rK rL rM r\ r] r^ r_ r` ra rb Z _httpx_ok�wirer? r1 Ztransport_adapterrf rg �urlZ split_urlZ _is_httpx�cm�responseZtwire�rr r r �https s� :
r� c C s4 x.y
| � |�S tk
r* t| |� Y qX qW dS )z�Reads a datagram from the socket.
A Timeout exception will be raised if the operation is not completed
by the expiration time.
N)�recvfrom�BlockingIOErrorr9 )�sock�max_sizer2 r r r � _udp_recv� s
r� c C sH xBy |r| � ||�S | �|�S W q tk
r> t| |� Y qX qW dS )z�Sends 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)�sendto�sendr� r: )r� ri rC r2 r r r � _udp_send� s r� )r� �whatrC r2 rc c C s4 t |tjj�r|�� }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.
)r# r* r� �Messagerq r r� )r� r� rC r2 � sent_time�nr r r �send_udp� s
r� � )
r� rC r2 rD r\ rm rn r] �raise_on_truncationrc c
C sf d} x&t | d|�\} }
t| j|
||�rP qW t�� } tjj| |||||d�} |rX| | fS | | |
fS dS )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.
r� i�� )rm rn r\ r] r� N)r� rE �familyr r* r� r� )
r� rC r2 rD r\ rm rn r] r� r� rB �
received_timer� r r r � receive_udp� s" 4r� �5 ) r[ rJ r rK rL rM rD r\ r] r� r� rc c C s� | � � } t||||�\} }
}t|�\}}|
r8t�|
�}nt| tj|�}|�L}t|| |
|� t ||
|||| j
| j || � \}}|| |_ | �
|�s�t�|S Q R X ds�t�dS )aL 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.
Returns a ``dns.message.Message``.
NF)rq rN r" r{ r| rX rG �
SOCK_DGRAMr� r� rm �macr r� r �AssertionError)r[ rJ r rK rL rM rD r\ r] r� r� r� r? rC �
begin_timer2 r� r8 r� r� r r r �udpI s0 3
r� ) r[ rJ r rK rL rM rD r\ r] �udp_sock�tcp_sockrc c
C s^ y$t | ||||||||d| � } | dfS tjjk
rX t| ||||||||
� } | dfS X 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.
Returns a (``dns.message.Message``, tcp) tuple where tcp is ``True``
if and only if TCP was used.
TFN)r� r* r� Z Truncated�tcp) r[ rJ r rK rL rM rD r\ r] r� r� r� r r r �udp_with_fallback� s4 7r� c C s� d}x~|dkr�y.| � |�}|dkr&t�|t|�8 }||7 }W q ttjfk
r` t| |� Y q tjk
r~ t| |� Y qX qW |S )z�Read 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 ) �recv�EOFErrorr� r� r
�SSLWantReadErrorr9 �SSLWantWriteErrorr: )r� �countr2 r8 r� r r r � _net_read� s
r� c C s| d}t |�}xj||k rvy|| �||d� �7 }W q ttjfk
rT t| |� Y q tjk
rr t| |� Y qX qW dS )z�Write 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� r
r� r: r� r9 )r� ri r2 �current�lr r r �
_net_write s
r� )r� r� r2 rc c C sT t |tjj�r|�� }n|}t|�}t�d|�| }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.
z!H)
r# r* r� r� rq r� �struct�packr r� )r� r� r2 r� r� �tcpmsgr� r r r �send_tcp s
r� )r� r2 r\ rm rn r] rc c C sL t | d|�}t�d|�\}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.
� z!H)rm rn r\ r] )r� r� �unpackr r* r� r� ) r� r2 r\ rm rn r] �ldatar� r� r� r� r r r � receive_tcp5 s ! r� c C s` | � |�}|dkrd S |tjtjtjfkrDt| |� | �tjtj �}|dkr\t
|t � |���d S )Nr )
�
connect_ex�errnoZ EINPROGRESS� EWOULDBLOCKZEALREADYr: �
getsockoptrG �
SOL_SOCKET�SO_ERROR�OSError�os�strerror)r8 �addressr2 �errr r r �_connectd s
r� )
r[ rJ r rK rL rM r\ r] r� rc c C s� | � � } t|�\}
} |r$t�|�} n"t||||�\}
}}t|
tj|�} | �T}|s\t||| � t || | � t
|| || j | j |�\}}||
|_
| �|�s�t�|S Q R X ds�t�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)rq r" r{ r| rN rX rG � SOCK_STREAMr� r� r� rm r� r r� r r� )r[ rJ r rK rL rM r\ r] r� r� r� r2 r� r? rC r8 r� r� r r r r� o s$ +
r� c C sV xPy | � � d S tjk
r. t| |� Y q tjk
rL t| |� Y qX qW d S )N)� do_handshaker
r� r9 r� r: )r8 r2 r r r �_tls_handshake� s r� �U ) r[ rJ r rK rL rM r\ r] r� rW rP rc c
C s� |r t | ||||||||� S | �� } t|�\} }
t||||�\}}}| dkrp|spt�� } tjj| _|
dkrpd| _ t
|t j || |
d��Z}t
|||
� t||
� t|| |
� t||
|| j| j|�\}}|| |_| �|�s�t�|S Q R X ds�t�dS )a: 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.
Returns a ``dns.message.Message``.
NF)rW rP )r� rq r" rN r
r �
TLSVersion�TLSv1_2�minimum_version�check_hostnamerX rG r� r� r� r� r� rm r� r r� r r� )r[ rJ r rK rL rM r\ r] r� rW rP r� r� r2 r? rC r8 r� r� r r r �tls� sJ 7
r� ) r[ rJ r rK rL rM r\ r] �
connectionrb rc c
C s� t jjstd��d| _| �� }
|r2t�d�} |} nt jj| d�} | }
| �T |s^|
� ||||�} t
�
� }| � � � }|� |
d� |�
|�}
W dQ R X t
�
� }W dQ R X t jj|
| j| j||d�}t|| d�|_
| �|�s�t�|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.
Returns a ``dns.message.Message``.
z DNS-over-QUIC is not available.r N)� verify_modeT)rm rn r\ r] g )r* �quicZ have_quicr �idrq r{ r| ZSyncQuicManager�connectr Z make_streamr� Zreceiver� r� rm rn �maxr� r )r[ rJ r rK rL rM r\ r] r� rb r� �managerZthe_connectionZ the_manager�start�stream�finishr� r r r r� & s6 -
r� )rJ �zone�rdtype�rdclassr rK rm �keyname�
relativize�lifetimerL rM �serial�use_udp� keyalgorithmrc c ' c s� t |t�rtj�|�}tjj�|�}tj� |||�}|tjj
krdtj �|dddd| �}|j �
|� |dk r||j|||d� |�� }t| ||
| �\}}}
|
r�|tjj
kr�td��|
r�tjntj}t|||
����}t| �\}}t|||� t|�}|
�rt||d|� n t�d|�| }t |||� d }d
}d } d} |�rF|} tjj } nd} |} d} �xN|�s�t|�\}}!|!dk�s�|dk �r�|!|k�r�|}!|
�r�t |d |!�\}}n&t |d |!�}"t� d|"�\}t |||!�}|tjj
k}#tjj!||j"|j#d
| | d
|#d
�}$|$�$� }%|%tj$j%k�rt&|%��|$j'} d}&| dk�r�|$j(�r@|$j(d j| k�rLtj)�*d��|$j(d }|j+tjj,k�rrtj)�*d��d}&|�-� } |tjj
k�r�tj.�/| d j.�| k�r�d
}nd
} x�|$j(|&d� D ]�}|�r�tj)�*d��|j+tjj,k�r^|j| k�r^| �r|d j.| k�rtj)�*d��d } n|tjj
k�r,| }|| k�rp|tjj0k�sX|tjj
k�rp|�rpd
}n| �r�tjj0}d } �q�W |�r�|j"�r�|$j1�s�tj)�*d��|$V �qVW W dQ R X 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 �IN�SOAz. . %u 0 0 0 0N)� algorithmzcannot do a UDP AXFRz!HFTi�� r� )rm rn �xfr�origin�tsig_ctx�multir\ z No answer or RRset not for qnamezfirst RRset is not an SOAr; zanswers after final SOAzIXFR base serial mismatchz missing TSIG)2r# r� r* �nameZ from_text� rdatatype� RdataType�maker� �
make_query�IXFR�rrset� authority�appendZuse_tsigrq rN rF rG r� r� rX r" r� r� r� r� r� r� �emptyr� r� r� r� rm r� �rcodeZNOERROR�
TransferErrorr� Zanswerr+ � FormErrorr� r� �copyr� ZSerial�AXFR�had_tsig)'rJ r� r� r� r rK rm r� r� r� rL rM r� r� r� r[ r� r� r? rC � sock_typer8 r1 r2 r� r� �doneZ delete_modeZ
expecting_SOAZ soa_rrsetr� Zonamer� � mexpirationr� �is_ixfrr� r� Z answer_indexr r r r� v 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 r; r� N)r r r
r �NEVERZ TRY_FIRST�ONLYr r r r r 0 s r )
rJ � txn_manager�queryrK r r� rL rM �udp_moderc c C sF |dkrt j�|�\}} n t j�|�} |jd j}
|
t jjk} |�� } |� � }
t
| |||�\}}}t |�\}}d}�x�|�r@d}| r�|t j
kr�tj}d}n
tj}d}t|||����}t|||� |r�t||
d|� n t�dt|
��|
}t|||� t j�||
| |���&}d}d}x�|�st |�\}}|dk�sD|dk �rH||k�rH|}|�r`t|d|�\}}n&t|d|�} t�d| �\} t|| |�}t j j ||j |j d| || | d�} y|� | �}W nD t jj!k
�r� |�s�t"�|t j#k�r� d}d}t j
}�wY nX | j$}�qW |�s*|j �r*| j%�s*t j&�'d ��W dQ R X W dQ R X qvW dS )
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 TFz!Hi�� r� )rm rn r� r� r� r� r\ z missing TSIG)(r* r� r� Zextract_serial_from_queryZquestionr� r� r� Zfrom_wire_originrq rN r" r r rG r� r� rX r� r� r� r� r� r� ZInboundr� r� r� r� r� rm r� Zprocess_messageZUseTCPr� r r� r r+ r� ) rJ r r
rK r r� rL rM r r� r� r r� r� r? rC r1 r2 �retryr Zis_udpr8 r� Zinboundr r� r Zrwirer� r� r� r r r � inbound_xfr= sv /
r
)T)NN) NrY Nr FFNrZ TNT)N)NNFFNr� FF) Nr� Nr FFFFN) Nr� Nr FFFNN)N)NFNr� F)Nr� Nr FFN) Nr� Nr FFNNN)Nr� Nr FFNT)or �typingr r r r r r� r{ �enumr� r� r& rG r� r � urllib.parsers Z
dns.exceptionr* Zdns.inetZdns.nameZ dns.messageZdns.quicZ dns.rcodeZdns.rdataclassZ
dns.rdatatypeZ
dns.serialZdns.transactionZdns.tsigZdns.xfrr~ Z!requests_toolbelt.adapters.sourcer Z*requests_toolbelt.adapters.host_header_sslr rx � ImportErrorrp r} ry rz r ro r
rQ r+ Z DNSExceptionr r� r r r r� r� r" r5 r6 �hasattrr7 r% �SelectSelectorr9 r: r@ rE rN rX r� r� r� �float�int�boolr� r� r� �bytesr� r� �NameZtsigZKeyr� r� r� r� r� r� r� r� r� r� r r r� r� ZSyncQuicConnectionr� r Z
rdataclassr� Zdefault_algorithmr� Z
RdataClass�IntEnumr r Z transactionZTransactionManagerr
r r r r �<module> s\
,
8 $ 4C (I ,I *( $: 4_ 2H� +0