Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/dns/__pycache__/query.cpython-39.pyc
Ðазад
a h�h�� � @ s d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddlmZmZmZmZmZmZ ddlZddlZddlZddlZddlZddlZddl Zddl Zddl Zddl Zddl Zddl!Zddl"Zdd� Z#dd� Z$ej%�&d�Z'e'�rRddl(Z)ddl*Z*e)j+Z,e)j-j.j/Z0G d d � d e,�Z1G d d � d e*j2�Z3nG d d � d �Z3e'Z4z ddl5Z5W n" e6�y� G dd� d�Z5Y n0 e j Z7G dd� dej8j9�Z:G dd� dej8j;�Z<G dd� dej8j9�Z=G dd� dej8j9�Z>ej?j@Z@dd� ZAdd� ZBd d � ZCd d � ZDd d!� ZEd"d#� ZFdvd%d&�ZGdwd'd(�ZHed) d)d*�d+d,�ZIG d-d.� d.ejJ�ZKdd/ddd0d0dd1d$dd$de jLeKjMfejNjOePeeQ eReeP eReSeSee ePeSeeP eeSePf ed) eReKejNjOd2�d3d4�ZTejUjVeWeWd5�d6d7�ZXejUjVePeWdd8�d9d:�ZYdxejNjOePePeeQ eReeP eReSeSeeSePf eeP eSejNjOd<� d=d>�ZZd?d@� Z[dAdB� Z\dyeeejNjOeWf eeeQ eeReQf dC�dDdE�Z]dzeee eeQ eSeSeeej^j_ej`jaf eeW eSeSeSeejNjO edG� dHdI�Zbd{ejNjOePeeQ eReeP eReSeSeSeSee eSejNjOdK� dLdM�Zcd|ejNjOePeeQ eReeP eReSeSeSee ee eSeejNjOeSf dN� dOdP�ZddQdR� ZedSdT� Zfd}eeejNjOeWf eeQ eeReQf dU�dVdW�Zgd~eeeQ eSeeej^j_ej`jaf eeW eSeejNjOeQf dX�dYdZ�Zhd[d\� ZidejNjOePeeQ eReeP eReSeSee ejNjOd]� d^d_�Zjd`da� ZkeeP eeSePf e5jldb�dcdd�Zmd�ejNjOePeeQ eReeP eReSeSee5jn ee5jl eeP eeSePf ejNjOde� dfdg�Zod�ejNjOePeeQ eReeP eReSeSeejUjp eeSePf eeP eeP ejNjOdh� didj�ZUG dkdl� dlejJ�Zqejrjse j ejNjOeeR eeQ eQedm�dndo�ZtejujvejwjxddJddd$ddddd0ej`jyf ePeej^j_ePf eejujzePf eejwj{ePf eeQ eReeej^j_ej`jaf eeej^j_ePf eSeeQ eeP eReReSeej^j_ePf edp�dqdr�Z?ddJddddeqj|fePejrjseejNjO eReeQ eeQ eeP eReqdds� dtdu�Z}dS )�zTalk to a DNS server.� N)�Any�Dict�Optional�Tuple�Union�castc C s, | d u r d S | t � � }|dkr(tjj�|S )N� )�time�dns� exception�Timeout)� expiration�timeout� r �y/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/dns/query.py� _remaining1 s r c C s |d u r d S t t�� | |�S �N)�minr )r r r r r � _expiration_for_this_attempt: 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 I 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 dkr�tj� || j f| �} nd } t| tj| �}td|�}z(t|tj� | |f| �|� t|�W S t�y Y q|0 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 �answers�address�af�source�sockZattempt_expirationr r r � connect_tcpP sB � � �z_NetworkBackend.connect_tcpc C s t �d S r ��NotImplementedError)r �pathr r6 r r r �connect_unix_socketw s z#_NetworkBackend.connect_unix_socket)N)N)�__name__� __module__� __qualname__r r= rA � __classcell__r r r! r r H s � ( �r c s* e Zd Zdddejd�� fdd� Z� ZS )�_HTTPTransportr N)r r r r c sJ |d u r"|d u r"dd l }|j�� }t� j|i |�� t||||�| j_d S �Nr )� dns.resolverr �Resolverr r r �_poolZ_network_backend)r r r r r �args�kwargsr r! r r r } s �z_HTTPTransport.__init__)rB rC rD r- � AF_UNSPECr rE r r r! r rF | s �rF c @ s e Zd Zdd� ZdS )rF c C s t �d S r r> )r r3 r4 r r5 r r r r= � s z_HTTPTransport.connect_tcpN)rB rC rD r= r r r r rF � 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�rB rC rD r r r r �WantReadException� s rP c @ s e Zd ZdS )zssl.WantWriteExceptionNrO r r r r �WantWriteException� s rQ c @ s e Zd ZdS )zssl.SSLContextNrO r r r r � SSLContext� s rR c @ s e Zd ZdS )z ssl.SSLSocketNrO r r r r � SSLSocket� s rS c O s t d��d S )Nzno ssl support)r1 )�clsrK rL r r r �create_default_context� s zssl.create_default_contextN) rB rC rD � CERT_NONEr1 rP rQ rR rS � classmethodrU r r r r rN � s rN c @ s e Zd ZdZdS )�UnexpectedSourcez=A DNS query response came from an unexpected address or port.N�rB rC rD �__doc__r r r r rX � s rX c @ s e Zd ZdZdS )� BadResponsez<A DNS query response does not respond to the question asked.NrY r r r r r[ � s r[ c @ s e Zd ZdZdS )�NoDOHzMDNS over HTTPS (DOH) was requested but the httpx module is not available.NrY r r r r r\ � s r\ c @ s e Zd ZdZdS )�NoDOQzNDNS over QUIC (DOQ) was requested but the aioquic module is not available.NrY r r r r r] � s r] c C s( t � � }| d u r|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}|r:|tjO }|rH|tjO }|rX|�| |� |d u rfd }n |t � � }|dkr�t j j �|� |�s�t j j �d S )Nr Tr )� isinstancerN rS �pending� selectors�DefaultSelector� EVENT_READ� EVENT_WRITE�registerr r r r �select)�fd�readable�writabler7 r �sel�eventsr r r r � _wait_for� s" rl c C s t | ddd|� d S )NTF�rl ��sr r r r �_wait_for_readable� s rp c C s t | ddd|� d S )NFTrm rn r r r �_wait_for_writable� s rq 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% � inet_ptonr � SyntaxError)r: Za1Za2Zn1Zn2r r r �_addresses_equal� s ru c C s` |sdS t | ||�s<tj�|d �r@|dd � |dd � kr@dS |rHdS td|� d|� ���d S )NTr rr Fzgot a response from z instead of )ru r r% � is_multicastrX )r: � from_address� destination�ignore_unexpectedr r r �_matches_destination s ���rz Tc C s� d }d }zt j�| �}| }W n ty4 |r0� Y n0 |r`t j�|�}|r\||kr`td��n|}|r�|s�zt j�|�}W n ty� td��Y n0 |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( r1 � ValueErrorZ any_for_afr+ )�wherer4 r; � source_portZwhere_must_be_addressr: rx Zsafr r r �_destination_and_source s4 � r~ c C sh t | |�}z<|�d� |d ur(|�|� |r>|j|d|d�W S |W S W n tyb |�� � Y n0 d S )NF)�do_handshake_on_connect�server_hostname)�socket_factory� setblocking�bind� wrap_socketr1 �close)r: �typer; � ssl_contextr� ro r r r r, @ s � r, zdns.resolver.Resolver)r �returnc C s | d u rdd l }|j�� } | S rG )rH r rI )r r r r r �_maybe_get_resolverT s r� c @ s, e Zd ZdZdZdZdZdZdZdZ dZ dS )� HTTPVersionz�Which version of HTTP should be used? DEFAULT will select the first version from the list [2, 1.1, 3] that is available. r rr � � N) rB rC rD rZ �DEFAULTZHTTP_1�H1ZHTTP_2�H2ZHTTP_3�H3r r r r r� b s r� i� Fz /dns-query)�qr| r r4 r; r} �one_rr_per_rrset�ignore_trailing�sessionr@ �postr �verifyr r � http_versionr� c " C s� t ||||d�\}}}|durjtj�|�rj|tjkrJd|� d|� | � �}qn|tjkrnd|� d|� | � �}n|}i }| du r�tj� |�}|j du r�t d��tj�|j �r�|j } |j |d< |j dur�|j }|t jks�|t jk�rBt�sB| du �r$t| �} |j du�sJ �| �|j |�}t�t|�� ��} t| | |||||||| | d � S t�sLt�|�rht|tj��sht d ��| � � }d d i}|t j t jfv }|t j t jfv }|du �r�d}d } n|d }|d } |�r�t � |�} n*t!|||| | | | |d�} tj||| | d�} | �t}| �r2|�"d t#t$|��d�� |j%|||||d�} n0t&�'|��(d�}|�)� } |j*|||d| i|d�} W d � n1 �sx0 Y | j+dk �s�| j+dk�r�t |� d| j+� d| j,� ���tj-j.| j,| j/| j0||d�}!| j1�2� |!_3| �4|!��s�t5�|!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. *http_version*, a ``dns.query.HTTPVersion``, indicating which HTTP version to use. Returns a ``dns.message.Message``. FNzhttps://�:z https://[z]:zno hostname in URLZ sni_hostname)r� r� z)session parameter must be an httpx.Client�acceptzapplication/dns-messager rr )r5 �http1�http2r� r r r r )r� r� r� � transport)z content-typezcontent-length)�headers�contentr � extensions� =r )r� r �paramsr� �� �+ � responded with status code z Response body: ��keyring� request_macr� r� )6r~ r r% r& r- �AF_INET�AF_INET6�urllib�parse�urlparse�hostnamer{ r4 r� r� r� �have_dohr� r) �random�choice�listr* �_http3r\ r_ �httpxZClient�to_wirer� r� � contextlib� nullcontextrF �update�str�lenr� �base64�urlsafe_b64encode�rstrip�decode�get� status_coder� �message� from_wirer� r� �elapsed� total_secondsr � is_responser[ )"r� r| r r4 r; r} r� r� r� r@ r� r r� r r r� r: r7 Z the_source�urlr� �parsedr8 �wirer� Zh1Zh2r5 r �cmr� �responseZtwire�rr r r �httpsr s� G � �� � � ����& ��� r� )r� �namer� c C s2 | d u r t �| D ]\}}||kr| S qt �d S r )�KeyError)r� r� �header�valuer r r � _find_header9 s r� )r� �peerr� r� c C s� t | d�}|d u rtd��t|�}|dk r2td��|dk sB|dkr�d}t|�dkrvzd|�� }W n tyt Y n0 t|� d |� |� ���d S ) Ns :statusz no :status header in responser zstatus is negativer� r� � z: r� )r� rt �intr� r� r1 r{ )r� r� r� r� �status�errorr r r � _check_statusB s r� �U ) r� r| r� r r4 r; r} r� r� r� r� r� r� c C s. t jjstd��tj�|�} | j} | jd ur2| j}d| _ | � � } t jj | | dd�}|�� |� ||||�}t |�\}}|�|��<}|�|| | � |�t|��} t|�� || � W d � n1 s�0 Y t�� }W d � n1 s�0 Y t jj| | j| j||d�}t|| d�|_| �|��s*t�|S )Nz DNS-over-HTTP3 is not available.r T)� verify_mode� server_nameZh3r� r ) r �quic� have_quicr\ r� r� r� r� r4 �idr� �SyncQuicManager�connectr$ � make_streamZsend_h3�receiver r� r� r r� r� r� r� �maxr� r[ )r� r| r� r r4 r; r} r� r� r� r� r� Z url_partsr� �manager� connection�startr �stream�finishr� r r r r� S s< � .&� r� c C s0 z | � |�W S ty( t| |� Y q 0 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�BlockingIOErrorrp )r< �max_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 )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� rq )r< �datarx r r r r � _udp_send� s r� )r< �whatrx 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� rx r � sent_time�nr r r �send_udp� s r� � ) r< rx r ry r� r� r� r� �raise_on_truncation� ignore_errors�queryr� c C s� d} t | d|�\} } t| j| ||�s&qt�� } z tjj| |||||d�}W nn tjjy� } z6| r�| dur�| �|�� �s�W Y d}~qn� W Y d}~n&d}~0 t y� | r�Y qn� Y n0 | r�| dur�| �|�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� rz r r r r� r� � Truncatedr� r1 )r< rx r ry r� r� r� r� r� r� r� r� rw � received_timer� �er r r � receive_udp� sD > �� �� � r� �5 ) r� r| r r4 r; r} ry r� r� r� r< r� r� c C s� | � � } t||||�\} }}t|�\}}| r8t�| �}nt| tj|�}|�b}t|| ||� t |||||| j | j || | | � \}}|| |_ | s�| � |�s�t�|W d � S 1 s�0 Y ds�J �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� r~ r$ r� r� r, r- � SOCK_DGRAMr� r� r� �macr r� r[ )r� r| r r4 r; r} ry r� r� r� r< r� r� r: rx � begin_timer r� ro r� r� r r r �udp& s: 8� � "�r ) r� r| r r4 r; r} ry r� r� �udp_sock�tcp_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) r� r| r r4 r; r} ry r� r� r r r� r� r r r �udp_with_fallback� s: 9� � r c C s� d}|dkr�z2| � |�}|dkr(td��|t|�8 }||7 }W q ttjfy` t| |� Y q tjy| t| |� Y q0 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 ZEOF) �recv�EOFErrorr� r� rN �SSLWantReadErrorrp �SSLWantWriteErrorrq )r< �countr ro r� r r r � _net_read� s r c C st d}t |�}||k rpz|| �||d� �7 }W q ttjfyP t| |� Y q tjyl t| |� Y q 0 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� rN r rq r rp )r< r� r �current�lr r r � _net_write� 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_lengthr� �big) r_ r r� r� r� r� �to_bytesr r )r< r� r �tcpmsgr� r r r �send_tcp� 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 |tjtjtjfv rDt| |� | �tjtj �}|dkr\t |t � |���d S rG ) � connect_ex�errnoZ EINPROGRESS� EWOULDBLOCKZEALREADYrq � getsockoptr- � SOL_SOCKET�SO_ERROR�OSError�os�strerror)ro r9 r �errr r r r/ K s r/ ) r� r| r r4 r; r} r� r� r< r� c C s� | � � } t|�\} } |r$t�|�} n"t||||�\} }}t| tj|�} | �b}|s\t||| � t || | � t || || j | j |�\}}|| |_ | �|�s�t�|W d � S 1 s�0 Y ds�J �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� r~ r, r- r. r/ r r r� r� r r� r[ )r� r| r r4 r; r} r� r� r< r� r r r� r: rx ro r� r� r r r r V s* + � � "�r c C sP z| � � W d S tjy, t| |� Y q tjyH t| |� Y q 0 q d S r )� do_handshakerN r rp r rq rn 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 u rdd|_ |� dg� |du r�tj|_|S )Nzinvalid verify string)�cafile�capathF�dot)r_ r� r r@ �isfile�isdirr{ rN rU � TLSVersion�TLSv1_2�minimum_version�check_hostname�set_alpn_protocolsrV r� )r� r� r$ r% r� r r r �_make_dot_ssl_context� s r. ) r� r| r r4 r; r} r� r� r< r� r� r� r� c C s� |r t | ||||||||� S | �� } t|�\} }t||||�\}}}| du rZ|sZt| | �} t|tj|| | d��h}t|||� t ||� t || |� t |||| j | j |�\}}|| |_| �|�s�t�|W d � S 1 s�0 Y ds�J �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� r[ )r� r| r r4 r; r} r� r� r< r� r� r� r� r r r: rx ro r� r� r r r �tls� sN =� � � � "�r/ ) r� r| r r4 r; r} r� r� r� r� r� r� r� c C s( t jjstd��| dur$| du r$| } d| _| �� } |rFt�d�} |}nt jj| | d�} | }| �| |st|� ||||�}t |�\}}|� |��*}|� | d� |� t|��} W d � n1 s�0 Y t�� }W d � n1 s�0 Y 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. *hostname*, a ``str`` containing the server's hostname or ``None``. The default is ``None``, which means that no hostname is known, and if an SSL context is created, hostname checking will be disabled. This value is ignored if *url* is not ``None``. *server_hostname*, a ``str`` or ``None``. This item is for backwards compatibility only, and has the same meaning as *hostname*. Returns a ``dns.message.Message``. z DNS-over-QUIC is not available.Nr )r� r� Tr� r )r r� r� r] r� r� r� r� r� r� r$ r� r� r� r r r� r� r� r� r� r� r[ )r� r| r r4 r; r} r� r� r� r� r� r� r� r� Zthe_connectionZ the_managerr� r r� r� r� r r r r� ' s< 7 ,&� 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 rr r� N)rB rC rD rZ �NEVERZ TRY_FIRST�ONLYr r r r r0 � s r0 )� txn_managerro r� �serialr r r� c c sh |j d j}|tjjk}| �� }|�� } |jtj k} | rHt || d|� n t � dt | ��| } t|| |� tj�| ||| ���} d} d}| �s(t|�\}}|du s�|dur�||kr�|}| r�t|d|�\}}n&t|d|�}t �d|�\}t|||�}tjj||j|jd||| |d�}| �|�} |V |j}q�|j�rD|j�sDtj � d ��W d � n1 �sZ0 Y dS ) z'Given a socket, does the zone transfer.r Nr Fr� r� T)r� r� �xfr�origin�tsig_ctx�multir� z missing TSIG) �question�rdtyper � rdatatype�IXFRZfrom_wire_originr� r� r- r� r� r �packr� r r5 ZInboundr$ r� r r r� r� r� r� Zprocess_messager7 Zhad_tsigr � FormError)r3 ro r� r4 r r r: Zis_ixfrr6 r� Zis_udpr Zinbound�doner7 r7 Z mexpirationZrwirer r r� r r r � _inbound_xfr� sP �� � r@ )r| �zoner: �rdclassr r4 r� �keyname� relativizer# r; r} r4 �use_udp� keyalgorithmr� c c sR G dd� dt jj�}t|t�r*t j�|�}t jj� |�}t j � |||�}|t jj kr�|j |j|t jjt jjdd�}t j�ddd| �}|�|d� |d ur�|j|||d � t| || | �\}}} t| �\}}|||�}| r�|t jj kr�td ��| r�tjntj}t||| ��4}t |||� t |||| ||�E d H W d � n1 �sD0 Y d S ) 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. c @ sL e Zd Zdd� Zdd� Zejjd�dd�Zdd � Z de ej j d �d d �Z dS )z$xfr.<locals>.DummyTransactionManagerc S s |||rt jjn|f| _d S r )r r� �empty�info)r r6 rD r r r r s z-xfr.<locals>.DummyTransactionManager.__init__c S s | j S r )rH �r r r r �origin_information s z7xfr.<locals>.DummyTransactionManager.origin_information)r� c S s t �d S r r> rI r r r � get_class s z.xfr.<locals>.DummyTransactionManager.get_classc S s t �d S r r> rI r r r �reader s z+xfr.<locals>.DummyTransactionManager.readerF)� replacementr� c S s G dd� d�}t tjj|� �S )Nc @ s e Zd Zdd� Zdd� ZdS )zExfr.<locals>.DummyTransactionManager.writer.<locals>.DummyTransactionc _ s d S r r )r rK �kwr r r �nop s zIxfr.<locals>.DummyTransactionManager.writer.<locals>.DummyTransaction.nopc S s | j S r )rO )r r7 r r r � __getattr__ s zQxfr.<locals>.DummyTransactionManager.writer.<locals>.DummyTransaction.__getattr__N)rB rC rD rO rP r r r r �DummyTransaction s rQ )r r � transaction� Transaction)r rM rQ r r r �writer s z+xfr.<locals>.DummyTransactionManager.writerN)F)rB rC rD r rJ r � rdataclass� RdataClassrK rL �boolrR rS rT r r r r �DummyTransactionManager s rX T)�create�IN�SOAz. . %u 0 0 0 0r N)� algorithmzcannot do a UDP AXFR) r rR �TransactionManagerr_ r� r� Z from_textr; � RdataType�maker� � make_queryr< Z find_rrset� authorityrU rZ r[ Zrdata�addZuse_tsigr~ r$ r{ r- r� r. r, r/ r@ )r| rA r: rB r r4 r� rC rD r# r; r} r4 rE rF rX r� ZrrsetZsoar: rx r7 r �tmZ sock_typero r r r r5 � s0 E � � r5 ) r| r3 r� r4 r r# r; r} �udp_moder� c C sF |du rt j�|�\}} n t j�|�} t| |||�\} } }t|�\} } |jd jt jj kr�|t j kr�t | t j|��j}t|| | � z*t|||| || �D ]} q�W W d � dS t jjy� |t jkrȂ Y n0 W d � n1 s�0 Y t | t j|��6}t|| | � t|||| || �D ]} �qW d � n1 �s80 Y 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 )r r5 r` Zextract_serial_from_queryr~ r$ r9 r: r; r< r0 r1 r, r- r� r/ r@ ZUseTCPr2 r. )r| r3 r� r4 r r# r; r} rd r4 r: rx r7 r ro r r r � inbound_xfr9 s. / � � & re )T)NN) Nr� Nr FFTNT)N) NNFFNr� FFFN) Nr� Nr FFFFNF) Nr� Nr FFFNNF)N)NFNr� F)Nr� Nr FFN) Nr� Nr FFNNNT) Nr� Nr FFNTNN)~rZ r� r� �enumr r �os.pathr� ra r- r r � urllib.parser� �typingr r 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.syncr2 r� ZNetworkBackendZ_CoreNetworkBackendZ _backends�syncZ SyncStreamr0 r Z HTTPTransportrF r� rN � ImportErrorr� r Z DNSExceptionrX r> r[ r\ r] r5 Z TransferErrorr$ rl rp rq ru rz r~ r, r� �IntEnumr� rM r� r� r� r� �floatr� rW r� r� ZHeaders�bytesr� r� r� r� r� r� r� �NameZtsig�Keyr� r r r r r r r/ r r# rR r. rS r/ ZSyncQuicConnectionr0 rR r] r@ r; ZAXFRrU rZ Zdefault_algorithmr^ rV r1 re r r r r �<module> s� 4 � , � � � H � � 1 � � � � m �� ^ �� X � � �� / �� E � � � n � � ]� 6�� x� �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка