관리-도구
편집 파일: query.cpython-38.pyc
U /?�f0� � @ s` d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z m Z mZmZmZ ddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Zddl Zddl Zdd� Z dd� Z ej!�"d�Z#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$ e2k �r� G dd� d�Z1Y nX ejZ3G dd� dej4j5�Z6G dd� dej4j7�Z8G dd� dej4j5�Z9G dd� dej4j5�Z: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 ejKjLd0�d1d2�ZQd3d4� ZRd5d6� ZSdje eejKjLeTf e eeN eeOeNf d7�d8d9�ZUdke ee eeN ePePee ejVjWejXjYf eeT ePePePeejKjL e d;� d<d=�ZZdlejKjLeMeeN eOeeM eOePePePePee ePejKjLd?� d@dA�Z[dmejKjLeMeeN eOeeM eOePePePee ee ePeejKjLePf dB� dCdD�Z\dEdF� Z]dGdH� Z^dne eejKjLeTf eeN eeOeNf dI�dJdK�Z_doe eeN ePee ejVjWejXjYf eeT ePeejKjLeNf dL�dMdN�Z`dOdP� ZadpejKjLeMeeN eOeeM eOePePee ejKjLdQ� dRdS�ZbdTdU� ZceeM eePeMf e1jddV�dWdX�ZedqejKjLeMeeN 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`�dadb�Z;G dcdd� ddejq�Zrdd>dddderjsfeMejtjueejKjL eOeeN eeN eeM eOerdde� dfdg�ZvdS )szTalk to a DNS server.� N)�Any�Dict�Optional�Tuple�Unionc C s, | d kr d S | t � � }|dkr(tjj�|S )N� )�time�dns� exception�Timeout)� expiration�timeout� r �7/opt/hc_python/lib/python3.8/site-packages/dns/query.py� _remaining/ s r c C s |d kr d S t t�� | |�S �N)�minr )r r r r r � _expiration_for_this_attempt8 s r Zdohc s0 e Zd Z� fdd�Zddd�Zd dd�Z� ZS ) �_NetworkBackendc s& t � �� || _|| _|| _|| _d S r )�super�__init__� _local_port� _resolver�_bootstrap_address�_family)�self�resolver� local_port�bootstrap_address�family�� __class__r r r G s z_NetworkBackend.__init__Nc C s g }t |�\}}tj�|�r(|�|� nP| jd k r@|�| j� n8t|�}| j} |r^tj�|�} | j j || |d�} | � � }|D ]�} tj�| �} |d k s�| j dkr�tj� || j f| �} nd } t| tj| �}td|�}z(t|tj� | |f| �|� t|�W S tk �r Y q|X q|tj�d S )N)r �lifetimer g @)�_compute_timesr �inet� is_address�appendr r r �af_for_addressr � resolve_name� addressesr �low_level_address_tuple� _make_socket�socket� SOCK_STREAMr �_connect�_CoreSyncStream� Exception�httpcoreZ ConnectError)r �host�portr � local_address�socket_optionsr) �_r r Zanswers�address�af�source�sockZattempt_expirationr r r � connect_tcpN sH � � �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 s> |d krdd l }|j�� }t� j||� t||||�| j_d S �Nr )Z dns.resolverr �Resolverr r r �_poolZ_network_backend)r r r r r �args�kwargsr 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� de�ZG dd� de�ZG dd� d�ZG dd � d �Ze d d � �Z d S ) �sslr c @ s e Zd ZdS )zssl.WantReadExceptionN�r@ rA rB r r r r �WantReadException� s rM c @ s e Zd ZdS )zssl.WantWriteExceptionNrL r r r r �WantWriteException� s rN c @ s e Zd ZdS )zssl.SSLContextNrL r r r r � SSLContext� s rO c @ s e Zd ZdS )z ssl.SSLSocketNrL r r r r � SSLSocket� s rP c O s t d��d S )Nzno ssl support)r0 )�clsrH rI r r r �create_default_context� s zssl.create_default_contextN) r@ rA rB � CERT_NONEr0 rM rN rO rP � classmethodrR r r r r rK � s rK c @ s e Zd ZdZdS )�UnexpectedSourcez=A DNS query response came from an unexpected address or port.N�r@ rA rB �__doc__r r r r rU � s rU c @ s e Zd ZdZdS )� BadResponsez<A DNS query response does not respond to the question asked.NrV r r r r rX � s rX c @ s e Zd ZdZdS )�NoDOHzMDNS over HTTPS (DOH) was requested but the httpx module is not available.NrV r r r r rY � s rY c @ s e Zd ZdZdS )�NoDOQzNDNS over QUIC (DOQ) was requested but the aioquic module is not available.NrV r r r r rZ � s rZ c C s( t � � }| d kr|d fS ||| fS d S r )r )r �nowr r r r# � 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 Tr )� isinstancerK rP �pending�_selector_class� selectors� EVENT_READ� EVENT_WRITE�registerr r r r �select)�fd�readable�writabler6 r �sel�eventsr r r r � _wait_for� s" ri c C s | a d S r )r^ )Zselector_classr r r �_set_selector_class� s rj � PollSelectorc C s t | ddd|� d S )NTF�ri ��sr r r r �_wait_for_readable s ro c C s t | ddd|� d S )NFTrl rm r r r �_wait_for_writable s rp c C sd z(t j�| |d �}t j�| |d �}W n t jjk rB Y dS X ||kob|dd � |dd � kS )Nr F� )r r$ � inet_ptonr � SyntaxError)r8 Za1Za2Zn1Zn2r r r �_addresses_equal s rt c C s` |sdS t | ||�s<tj�|d �r@|dd � |dd � kr@dS |rHdS td|� d|� ���d S )NTr rq Fzgot a response from z instead of )rt r r$ � is_multicastrU )r8 � from_address� destination�ignore_unexpectedr r r �_matches_destination s ���ry Tc C s� d }d }zt j�| �}| }W n tk r6 |r2� Y nX |rbt j�|�}|r^||krbtd��n|}|r�|s�zt j�|�}W n tk r� td��Y nX |r�t j�||f|�}|r�t 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 rw Zsafr r r �_destination_and_source& s4 �r} c C sj t | |�}z<|�d� |d k r(|�|� |r>|j|d|d�W S |W S W n tk rd |�� � Y nX d S )NF)�do_handshake_on_connect�server_hostname)�socket_factory� setblocking�bind� wrap_socketr0 �close)r8 �typer9 � ssl_contextr rn r r r r+ R s � r+ i� Fz /dns-queryzdns.resolver.Resolver)�qr{ r r3 r9 r| �one_rr_per_rrset�ignore_trailing�sessionr> �postr �verifyr r �returnc C s� t st�|r t|tj�s td��| �� }t||||d�\}}}d}ddi}|dk r�tj � |�r�|t j krxd� ||| �}q�|t jkr�d� ||| �}n|}|dkr�d}d}n|d }|d }t|d d | || | |d �}|r�t�|�}ntjd d | |d �}|�f}| �r*|�dtt|��d �� |j||||d�}n.t�|��d�}|�� }|j|||d|id�}W 5 Q R X |jdk �sz|jdk�r�td� ||j|j ���tj j |j | j | j ||d�}|j!�"� |_#| �$|��s�t%�|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.ClientFN�acceptzapplication/dns-messagezhttps://{}:{}{}zhttps://[{}]:{}{}r rq T)r4 �http1�http2r� r r r r )r� r� r� � transport)z content-typezcontent-length)�headers�contentr � =r )r� r �params�� i+ z2{} responded with status code {} Response body: {}��keyring� request_macr� r� )&�have_dohrY r\ �httpxZClientrz �to_wirer} r r$ r% r, �AF_INET�format�AF_INET6rD � contextlib� nullcontext�update�str�lenr� �base64�urlsafe_b64encode�rstrip�decode�get� status_coder� �message� from_wirer� r� �elapsed� total_secondsr � is_responserX ) r� r{ r r3 r9 r| r� r� r� r> r� r r� r r �wirer8 r6 Z the_sourcer� r� �urlr4 r �cm�responseZtwire�rr r r �httpsf s� D � � �� � ��� r� c C s2 z | � |�W S tk r* t| |� Y q X q 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�BlockingIOErrorro )r: �max_sizer r r r � _udp_recv� s r� c C sH z"|r| � ||�W S | �|�W S W q tk r@ t| |� Y q X q 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� rp )r: �datarw r r r r � _udp_send s r� )r: �whatrw r r� 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� �Messager� r r� )r: r� rw r � sent_time�nr r r �send_udp s r� � ) r: rw r rx r� r� r� r� �raise_on_truncation� ignore_errors�queryr� c C s� d} t | d|�\} } t| j| ||�s&qt�� } z tjj| |||||d�}W nj tjjk r� } z*| r�| dk r�| �|�� �s�W Y � qn� W 5 d}~X Y n t k r� | r�Y qn� Y nX | r�| dk r�| �|�s�q|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� r� r� r� N) r� ry r r r r� r� � Truncatedr� r0 )r: rw r rx r� r� r� r� r� r� r� r� rv � received_timer� �er r r � receive_udp2 sJ > �� �� � r� �5 ) r� r{ r r3 r9 r| rx r� r� r� r: r� r� c C s� | � � } t||||�\} }}t|�\}}| r8t�| �}nt| tj|�}|�`}t|| ||� t |||||| j | j || | | � \}}|| |_ | s�| � |�s�t�|W 5 Q R � S Q R X ds�t�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``. FN)r� r} r# r� r� r+ r, � SOCK_DGRAMr� r� r� �macr r� rX �AssertionError)r� r{ r r3 r9 r| rx r� r� r� r: r� r� r8 rw � begin_timer r� rn r� r� r r r �udp� s@ 8 � � �r� ) r� r{ r r3 r9 r| rx r� r� �udp_sock�tcp_sockr� r� c C sf z(t | ||||||||d| | � } | dfW S tjjk r` t| |||||||| � } | df Y S 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. *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) r� r{ r r3 r9 r| rx r� 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 ttjfk r^ t| |� Y q tjk r| t| |� Y qX q|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� rK �SSLWantReadErrorro �SSLWantWriteErrorrp )r: �countr rn r� r r r � _net_readO s r� c C sx d}t |�}||k rtz|| �||d� �7 }W q ttjfk rR t| |� Y q tjk rp t| |� Y q X q 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� rK r� rp r� ro )r: r� r �current�lr r r � _net_writed s r� )r: r� r r� c C sP t |tjj�r |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� �big) r\ r r� r� r� r� �to_bytesr r� )r: r� r �tcpmsgr� r r r �send_tcpt s r� )r: r r� r� r� r� r� 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. r� �!Hr� )r� �struct�unpackr r r� r� ) r: r r� r� r� r� �ldatar� r� r� r� r r r � receive_tcp� s ! �r� c C s` | � |�}|dkrd S |tjtjtjfkrDt| |� | �tjtj �}|dkr\t |t � |���d S rE ) � connect_ex�errnoZ EINPROGRESS� EWOULDBLOCKZEALREADYrp � getsockoptr, � SOL_SOCKET�SO_ERROR�OSError�os�strerror)rn r7 r �errr r r r. � s r. ) r� r{ r r3 r9 r| r� r� r: r� c C s� | � � } t|�\} } |r$t�|�} n"t||||�\} }}t| tj|�} | �`}|s\t||| � t || | � t || || j | j |�\}}|| |_ | �|�s�t�|W 5 Q R � 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``. FN)r� r# r� r� r} r+ r, r- r. r� r� r� r� r r� rX r� )r� r{ r r3 r9 r| r� r� r: r� r� r r� r8 rw rn r� r� r r r r� � s: + � � �r� c C sT z| � � W d S tjk r. t| |� Y q tjk rL t| |� Y q X q d S r )� do_handshakerK r� ro r� rp rm r r r �_tls_handshake s r� )r r� r� c C s� d }d }t |t�r>tj�|�r$|}ntj�|�r6|}ntd��tj||d�}tj j |_ | d krdd|_ |� dg� |dkr�tj|_|S )Nzinvalid verify string)�cafile�capathF�dot)r\ r� r� r> �isfile�isdirrz rK rR � TLSVersion�TLSv1_2�minimum_version�check_hostname�set_alpn_protocolsrS � verify_mode)r r� r� r� r� r r r �_make_dot_ssl_context s r �U ) r� r{ r r3 r9 r| r� r� r: r� r r� r� c C s� |r t | ||||||||� S | �� } t|�\} }t||||�\}}}| dkrZ|sZt| | �} t|tj|| | d��f}t|||� t ||� t || |� t |||| j | j |�\}}|| |_| �|�s�t�|W 5 Q R � S Q R X ds�t�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)r� r F)r� r� r# r} r r+ r, r- r. r� r� r� r� r� r r� rX r� )r� r{ r r3 r9 r| r� r� r: r� r r� r� r� r r8 rw rn r� r� r r r �tls1 s^ =� � � � �r ) r� r{ r r3 r9 r| r� r� � connectionr� r r� c C s� t jjstd��d| _| �� } |r2t�d�} |} nt jj| | d�} | }| �^ |s`|� ||||�} t |�\}}| � |�� }|� | d� |� t|��} W 5 Q R X t�� }W 5 Q 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. *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_quicrZ �idr� r� r� ZSyncQuicManager�connectr# Z make_streamr� Zreceiver r r� r� r� r� �maxr� rX )r� r{ r r3 r9 r| r� r� r r� r r� �managerZthe_connectionZ the_manager�startr �stream�finishr� r r r r � s> 2 � � r )r{ �zone�rdtype�rdclassr r3 r� �keyname� relativizer" r9 r| �serial�use_udp� keyalgorithmr� 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} |�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�rHtj)�*d��|$j(d }|j+tjj,k�rntj)�*d��d}&|�-� } |tjj k�r�tj.�/| d j.�| k�r�d }nd } |$j(|&d� D ]�}|�r�tj)�*d��|j+tjj,k�rX|j| k�rX| �r|d j.| k�r tj)�*d��d } n|tjj k�r&| }|| k�rj|tjj0k�sR|tjj k�rj|�rjd }n| �r�tjj0}d } �q�|�r�|j"�r�|$j1�s�tj)�*d��|$V �qRW 5 Q 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 AXFRr� FTr� r� �r� r� �xfr�origin�tsig_ctx�multir� z No answer or RRset not for qnamezfirst RRset is not an SOArq zanswers after final SOAzIXFR base serial mismatch� missing TSIG)2r\ r� r �nameZ from_text� rdatatype� RdataType�maker� � make_query�IXFR�rrset� authorityr& Zuse_tsigr� r} rz r, r� r- r+ r# r. r� r� r� �packr� �emptyr� r� r� r� r� r� �rcodeZNOERROR� TransferErrorr Zanswerr � FormErrorr r �copyr ZSerial�AXFR�had_tsig)'r{ r r r r r3 r� r r r" r9 r| r r r r� r# r� r8 rw � sock_typern 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 rq r� N)r@ rA rB rW �NEVERZ TRY_FIRST�ONLYr r r r r1 � s r1 ) r{ � txn_managerr� r3 r r" r9 r| �udp_moder� c C s> |dkrt j�|�\}} n t j�|�} |jd j} | t jjk} |�� } |� � } t | |||�\}}}t |�\}}d}|�r:d}| r�|t j kr�tj}d}n tj}d}t|||����}t|||� |r�t|| d|� n t�dt| ��| }t|||� t j�|| | |���$}d}d}|�st |�\}}|dk�s>|dk �rB||k�rB|}|�rZt|d|�\}}n&t|d|�} t�d| �\} t|| |�}t j j ||j |j d| || | d�} z|� | �}W nF t jj!k �r� |�s�t"�|t j#k�rނ d}d}t j }Y �qY nX | j$}�q|�s$|j �r$| j%�s$t j&�'d ��W 5 Q R X W 5 Q R X 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_query�questionr r r" Zfrom_wire_originr� r} r# r1 r2 r, r� r- r+ r. r� r� r% r� r� ZInboundr� r� r� r� r� r� r� Zprocess_messageZUseTCPr� r3 r r, r r) ) r{ r4 r� r3 r r" r9 r| r5 r r r0 r r� r8 rw r6 r �retryr- Zis_udprn r� Zinboundr. r r/ Zrwirer� r� r� r r r � inbound_xfr� s� / � �� � r8 )T)NN)N) NNFFNr� FFFN) Nr� Nr FFFFNF) Nr� Nr FFFNNF)N)NFNr� F)Nr� Nr FFN) Nr Nr FFNNNT) Nr Nr FFNTN)wrW r� r� �enumr� r� �os.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 _backends�syncZ SyncStreamr/ r Z HTTPTransportrD r� rK � ImportErrorr� r Z DNSExceptionrU r) rX rY rZ r r( r# ri rj �hasattrrk r^ �SelectSelectorro rp rt ry r} r+ rJ r� r� r� �float�int�boolr� r� r� �bytesr� r �NameZtsig�Keyr� r� r� r� r� r� r� r. r� r� rO r rP r r ZSyncQuicConnectionr r+ Z rdataclassr Zdefault_algorithmr Z RdataClass�IntEnumr1 r2 Z transactionZTransactionManagerr8 r r r r �<module> s� 4 � , � � � � � � m �� ^ �� X � � �� / �� D � � � n � � Z�� ;� �