File: //opt/alt/python37/lib/python3.7/site-packages/dns/__pycache__/resolver.cpython-37.pyc
B
��f�� � @ s� U d Z ddlmZmZmZmZmZmZ ddlm Z ddl
Z
ddl Z ddl Z ddl
Z
ddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Zddl Zddl Zddl Ze j dkr�ddl!ZG dd� dej"j#�Z$G dd � d ej"j#�Z%eee& e'e(ee)e&f eej*j+ f Z,ee, ee& d
�d d �Z-G d
d� dej"j.�Z/e/Z.G dd� dej"j#�Z0G dd� dej"j#�Z1G dd� dej"j#�Z2G dd� dej"j#�Z3G dd� dej"j#�Z4G dd� dej"j#�Z5G dd � d �Z6G d d � d �Z7G d d � d �Z8eej9j:ej;j<ej=j>f Z?G d!d"� d"e8�Z@G d#d$� d$�ZAG d%d&� d&e8�ZBG d'd(� d(�ZCG d)d*� d*�ZDG d+d,� d,eD�ZEdaFeeE eGd-< eEd.�d/d0�ZHd1d2� ZIej;jJej=jKd3dd4dddfeej9j:e&f eej;j<e&f eej=j>e&f e'ee& e'e(eeL ee' e6d5�
d6d7�ZMej;jJej=jKd3dd4ddfeej9j:e&f eej;j<e&f eej=j>e&f e'ee& e'e(eeL e6d8� d9d:�ZNe&eee6d;�d<d=�ZOeej9j:e&f ej9j:d>�d?d@�ZPej=jKd3ddfeej9j:e&f ej=j>e'eeE eeL ej9j:dA�dBdC�ZQe jRe jSge jTe jUgiZVdaWe jXZYe jZZ[e j\Z]e j^Z_e j`Zae jbZcdde jddddfdDdE�ZedUdFdG�ZfdVdHdI�ZgdJdK� ZhdLdM� ZidNdO� ZjdWeeE ddP�dQdR�Zkdd.�dSdT�ZldS )XzDNS stub resolver.� )�Any�Dict�List�Optional�Tuple�Union)�urlparseN�win32c sn e Zd ZdZddhZdZ� fdd�Zddd�Z� fd d
�Ze d d � �Z
d
d� Z dd� Z dd� Z
dd� Z� ZS )�NXDOMAINz"The DNS query name does not exist.�qnames� responsesNc s t � j||� d S )N)�super�__init__)�self�args�kwargs)� __class__� �=/opt/alt/python37/lib/python3.7/site-packages/dns/resolver.pyr < s zNXDOMAIN.__init__c C s\ t |tttf�std��t|�dkr,td��|d kr:i }nt |t�sLtd��t||d�}|S )Nz#qnames must be a list, tuple or setr z(qnames must contain at least one elementz(responses must be a dict(qname=response))r r )�
isinstance�list�tuple�set�AttributeError�len�dict)r r r r r r r �
_check_kwargs? s
zNXDOMAIN._check_kwargsc sP d| j krt� �� S | j d }t|�dkr0d}nd}d�tt|��}d�||�S )Nr � z None of DNS query names existz!The DNS query name does not existz, z{}: {})r r
�__str__r �join�map�str�format)r r �msg)r r r r K s
zNXDOMAIN.__str__c C sp d| j krtd��xN| j d D ]@}| j d | }y|�� }||krF|S W q tk
r\ Y q X q W | j d d S )z%Return the unresolved canonical name.r z parametrized exception requiredr r )r � TypeError�canonical_name� Exception)r �qname�response�cnamer r r r% V s
zNXDOMAIN.canonical_namec C s| t | j�dg ��}t| j�di ��}|j�di �}x<|j�dg �D ]*}||krX|�|� ||krB|| ||< qBW t||d�S )z3Augment by results from another NXDOMAIN exception.r r )r r )r r �getr �appendr
)r Ze_nxZqnames0Z
responses0Z
responses1Zqname1r r r �__add__g s
zNXDOMAIN.__add__c C s
| j d S )zXAll of the names that were tried.
Returns a list of ``dns.name.Name``.
r )r )r r r r r s s zNXDOMAIN.qnamesc C s
| j d S )z�A map from queried names to their NXDOMAIN responses.
Returns a dict mapping a ``dns.name.Name`` to a
``dns.message.Message``.
r )r )r r r r r z s zNXDOMAIN.responsesc C s | j d | S )zTThe response for query *qname*.
Returns a ``dns.message.Message``.
r )r )r r' r r r r( � s zNXDOMAIN.response)N)�__name__�
__module__� __qualname__�__doc__� supp_kwargs�fmtr r r �propertyr% r, r r r( �
__classcell__r r )r r r
2 s
r
c @ s e Zd ZdZdS )�YXDOMAINz8The DNS query name is too long after DNAME substitution.N)r- r. r/ r0 r r r r r5 � s r5 )�errors�returnc
C sD g }x:| D ]2}|� d�|d |d r(dnd|d |d �� q
W |S )z3Turn a resolution errors trace into a list of text.z Server {} {} port {} answered {}r r ZTCPZUDP� � )r+ r" )r6 Ztexts�errr r r �_errors_to_text� s
*r; c sH e Zd ZdZdZdedd� ZddhZ� fdd�Z� fd d
�Z� Z S ) �LifetimeTimeoutz The resolution lifetime expired.z(%s after {timeout:.3f} seconds: {errors}N����timeoutr6 c s t � j||� d S )N)r
r )r r r )r r r r � s zLifetimeTimeout.__init__c s& t |d �}t� j|d d�|�d�S )Nr6 r> z; )r> r6 )r; r
� _fmt_kwargsr )r r �srv_msgs)r r r r? � s zLifetimeTimeout._fmt_kwargs)
r- r. r/ r0 r# r2 r1 r r? r4 r r )r r r< � s r< c s> e Zd ZdZdZdhZ� fdd�Z� fdd�Zdd � Z� Z S )
�NoAnswerz<The DNS response does not contain an answer to the question.zDThe DNS response does not contain an answer to the question: {query}r( c s t � j||� d S )N)r
r )r r r )r r r r � s zNoAnswer.__init__c s t � j|d jd�S )Nr( )�query)r
r? �question)r r )r r r r? � s zNoAnswer._fmt_kwargsc C s
| j d S )Nr( )r )r r r r r( � s zNoAnswer.response)
r- r. r/ r0 r2 r1 r r? r( r4 r r )r r rA � s rA c sH e Zd ZdZdZdedd� ZddhZ� fdd �Z� fd
d �Z� Z S ) �
NoNameserversz�All nameservers failed to answer the query.
errors: list of servers and respective errors
The type of errors is
[(server IP address, any object convertible to string)].
Non-empty errors list will add explanatory message ()
z+All nameservers failed to answer the query.z%s {query}: {errors}Nr= �requestr6 c s t � j||� d S )N)r
r )r r r )r r r r � s zNoNameservers.__init__c s( t |d �}t� j|d jd�|�d�S )Nr6 rE z; )rB r6 )r; r
r? rC r )r r r@ )r r r r? � s zNoNameservers._fmt_kwargs)
r- r. r/ r0 r# r2 r1 r r? r4 r r )r r rD � s rD c @ s e Zd ZdZdS )� NotAbsolutezEAn absolute domain name is required but a relative name was provided.N)r- r. r/ r0 r r r r rF � s rF c @ s e Zd ZdZdS )� NoRootSOAzBThere is no SOA RR at the DNS root name. This should never happen!N)r- r. r/ r0 r r r r rG � s rG c @ s e Zd ZdZdS )�
NoMetaqueriesz DNS metaqueries are not allowed.N)r- r. r/ r0 r r r r rH � s rH c @ s e Zd ZdZdS )�NoResolverConfigurationzEResolver configuration could not be read or specified no nameservers.N)r- r. r/ r0 r r r r rI � s rI c @ sj e Zd ZdZdejjejjej j
ej j e
e e
e d�dd�Zdd� Zdd � Zd
d � Zd d
� Zdd� ZdS )�Answera& DNS stub resolver answer.
Instances of this class bundle up the result of a successful DNS
resolution.
For convenience, the answer object implements much of the sequence
protocol, forwarding to its ``rrset`` attribute. E.g.
``for a in answer`` is equivalent to ``for a in answer.rrset``.
``answer[i]`` is equivalent to ``answer.rrset[i]``, and
``answer[i:j]`` is equivalent to ``answer.rrset[i:j]``.
Note that CNAMEs or DNAMEs in the response may mean that answer
RRset's name might not be the query name.
N)r' �rdtype�rdclassr( �
nameserver�portc C sX || _ || _|| _|| _|| _|| _|�� | _| jj| _| jj | _
t � � | jj | _
d S )N)r' rK rL r( rM rN Zresolve_chainingZchaining_resultr% �answer�rrset�timeZ minimum_ttl�
expiration)r r' rK rL r( rM rN r r r r s
zAnswer.__init__c C s\ |dkr| j jS |dkr | j jS |dkr0| j jS |dkr@| j jS |dkrP| j jS t|��d S )N�name�ttl�coversrL rK )rP rS rT rU rL rK r )r �attrr r r � __getattr__ s zAnswer.__getattr__c C s | j rt| j �pdS )Nr )rP r )r r r r �__len__' s zAnswer.__len__c C s | j rt| j �ptt� �S )N)rP �iterr )r r r r �__iter__* s zAnswer.__iter__c C s | j d krt�| j | S )N)rP �
IndexError)r �ir r r � __getitem__- s
zAnswer.__getitem__c C s | j d krt�| j |= d S )N)rP r[ )r r\ r r r � __delitem__2 s
zAnswer.__delitem__)NN)r- r. r/ r0 �dnsrS �Name� rdatatype� RdataType�
rdataclass�
RdataClass�message� QueryMessager r! �intr rW rX rZ r] r^ r r r r rJ � s 2rJ c @ s0 e Zd ZdZd dd�Zdd� Zd d�dd �Zd
S ) �CacheStatisticszCache Statisticsr c C s || _ || _d S )N)�hits�misses)r ri rj r r r r ; s zCacheStatistics.__init__c C s d| _ d| _d S )Nr )ri rj )r r r r �reset? s zCacheStatistics.reset)r7 c C s t | j| j�S )N)rh ri rj )r r r r �cloneC s zCacheStatistics.cloneN)r r )r- r. r/ r0 r rk rl r r r r rh 8 s
rh c @ sL e Zd Zdd� Zdd�dd�Zed�dd�Zed�d d
�Zed�d d �Z dS )
� CacheBasec C s t �� | _t� | _d S )N)� threading�Lock�lockrh �
statistics)r r r r r H s
zCacheBase.__init__N)r7 c C s | j � | j�� W dQ R X dS )z Reset all statistics to zero.N)rp rq rk )r r r r �reset_statisticsL s zCacheBase.reset_statisticsc C s | j �
| jjS Q R X dS )z How many hits has the cache had?N)rp rq ri )r r r r ri Q s zCacheBase.hitsc C s | j �
| jjS Q R X dS )z"How many misses has the cache had?N)rp rq rj )r r r r rj V s zCacheBase.missesc C s | j � | j�� S Q R X dS )z�Return a consistent snapshot of all the statistics.
If running with multiple threads, it's better to take a
snapshot than to call statistics methods such as hits() and
misses() individually.
N)rp rq rl )r r r r �get_statistics_snapshot[ s z!CacheBase.get_statistics_snapshot)
r- r. r/ r rr rg ri rj rh rs r r r r rm G s
rm c sr e Zd ZdZded�� fdd�
Zdd�dd �Zeee d
�d d �Z
ee dd
�dd�Z dee dd
�dd�Z � Z
S )�Cachez$Simple thread-safe DNS answer cache.� �r@)�cleaning_intervalc s* t � �� i | _|| _t�� | j | _dS )zf*cleaning_interval*, a ``float`` is the number of seconds between
periodic cleanings.
N)r
r �datarv rQ �
next_cleaning)r rv )r r r r l s
zCache.__init__N)r7 c C sp t � � }| j|krlg }x*| j�� D ] \}}|j|kr"|�|� q"W x|D ] }| j|= qHW t � � }|| j | _dS )z&Clean the cache if it's time to do so.N)rQ rx rw �itemsrR r+ rv )r �nowZkeys_to_delete�k�vr r r � _maybe_cleanv s
zCache._maybe_clean)�keyr7 c C sd | j �T | �� | j�|�}|dks2|jt�� krF| j jd7 _dS | j jd7 _|S Q R X dS )aK Get the answer associated with *key*.
Returns None if no answer is cached for the key.
*key*, a ``(dns.name.Name, dns.rdatatype.RdataType, dns.rdataclass.RdataClass)``
tuple whose values are the query name, rdtype, and rdclass respectively.
Returns a ``dns.resolver.Answer`` or ``None``.
Nr ) rp r} rw r* rR rQ rq rj ri )r r~ r| r r r r* � s z Cache.get)r~ �valuer7 c C s( | j � | �� || j|< W dQ R X dS )a Associate key and value in the cache.
*key*, a ``(dns.name.Name, dns.rdatatype.RdataType, dns.rdataclass.RdataClass)``
tuple whose values are the query name, rdtype, and rdclass respectively.
*value*, a ``dns.resolver.Answer``, the answer.
N)rp r} rw )r r~ r r r r �put� s z Cache.putc C sH | j �8 |dk r$|| jkr:| j|= ni | _t�� | j | _W dQ R X dS )a2 Flush the cache.
If *key* is not ``None``, only that item is flushed. Otherwise the entire cache
is flushed.
*key*, a ``(dns.name.Name, dns.rdatatype.RdataType, dns.rdataclass.RdataClass)``
tuple whose values are the query name, rdtype, and rdclass respectively.
N)rp rw rQ rv rx )r r~ r r r �flush� s
z Cache.flush)ru )N)r- r. r/ r0 �floatr r} �CacheKeyr rJ r* r� r� r4 r r )r r rt i s
rt c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � LRUCacheNodezLRUCache node.c C s" || _ || _d| _| | _| | _d S )Nr )r~ r ri �prev�next)r r~ r r r r r � s
zLRUCacheNode.__init__c C s || _ |j| _| |j_ | |_d S )N)r� r� )r �noder r r �
link_after� s zLRUCacheNode.link_afterc C s | j | j_ | j| j _d S )N)r� r� )r r r r �unlink� s
zLRUCacheNode.unlinkN)r- r. r/ r0 r r� r� r r r r r� � s r� c s� e Zd ZdZded�� fdd�
Zedd�dd �Zeee d
�d d �Z
eed
�d
d�Z ee dd�dd�Z dee dd
�dd�Z
� ZS )�LRUCachea` Thread-safe, bounded, least-recently-used DNS answer cache.
This cache is better than the simple cache (above) if you're
running a web crawler or other process that does a lot of
resolutions. The LRUCache has a maximum number of nodes, and when
it is full, the least-recently used node is removed to make space
for a new one.
順 )�max_sizec s> t � �� i | _| �|� tdd�| _| j| j_| j| j_dS )zl*max_size*, an ``int``, is the maximum number of nodes to cache;
it must be greater than 0.
N)r
r rw � set_max_sizer� �sentinelr� r� )r r� )r r r r � s
zLRUCache.__init__N)r� r7 c C s |dk r d}|| _ d S )Nr )r� )r r� r r r r� � s zLRUCache.set_max_size)r~ r7 c C s� | j �� | j�|�}|dkr0| j jd7 _dS |�� |jjt�� krf| j|j = | j jd7 _dS |�
| j � | j j d7 _ | j d7 _ |jS Q R X dS )aK Get the answer associated with *key*.
Returns None if no answer is cached for the key.
*key*, a ``(dns.name.Name, dns.rdatatype.RdataType, dns.rdataclass.RdataClass)``
tuple whose values are the query name, rdtype, and rdclass respectively.
Returns a ``dns.resolver.Answer`` or ``None``.
Nr )
rp rw r* rq rj r� r rR rQ r~ r� r� ri )r r~ r� r r r r* � s
z LRUCache.getc C sD | j �4 | j�|�}|dks,|jjt�� kr0dS |jS W dQ R X dS )zBReturn the number of cache hits associated with the specified key.Nr )rp rw r* r rR rQ ri )r r~ r� r r r �get_hits_for_key s
zLRUCache.get_hits_for_key)r~ r r7 c C s� | j �| | j�|�}|dk r.|�� | j|j= x.t| j�| jkr\| jj}|�� | j|j= q0W t ||�}|�
| j� || j|< W dQ R X dS )a Associate key and value in the cache.
*key*, a ``(dns.name.Name, dns.rdatatype.RdataType, dns.rdataclass.RdataClass)``
tuple whose values are the query name, rdtype, and rdclass respectively.
*value*, a ``dns.resolver.Answer``, the answer.
N) rp rw r* r� r~ r r� r� r� r� r� )r r~ r r� �gnoder r r r�
s
z LRUCache.putc C sv | j �f |dk r8| j�|�}|dk rh|�� | j|j= n0| jj}x || jkr`|j}|�� |}qBW i | _W dQ R X dS )a2 Flush the cache.
If *key* is not ``None``, only that item is flushed. Otherwise the entire cache
is flushed.
*key*, a ``(dns.name.Name, dns.rdatatype.RdataType, dns.rdataclass.RdataClass)``
tuple whose values are the query name, rdtype, and rdclass respectively.
N)rp rw r* r� r~ r� r� )r r~ r� r� r� r r r r� # s
zLRUCache.flush)r� )N)r- r. r/ r0 rg r r� r� r rJ r* r� r� r� r4 r r )r r r� � s r� c @ s� e Zd ZdZdeejjef eej j
ef eej j ef e
e
ee
d�dd�Zeeejj ee f d�dd�Zeeee
ef d�d d
�Zeejj ee eee e
f d �d d
�ZdS )� _Resolutiona Helper class for dns.resolver.Resolver.resolve().
All of the "business logic" of resolution is encapsulated in this
class, allowing us to have multiple resolve() implementations
using different I/O schemes without copying all of the
complicated logic.
This class is a "friend" to dns.resolver.Resolver and manipulates
resolver data structures directly.
� BaseResolver)�resolverr' rK rL �tcp�raise_on_no_answer�searchc
C s� t |t�rtj�|d �}tjj�|�}tj�|�r6t �tj
j �|�} tj
� | �rTt �|| _
|�||�| _| jd d � | _|| _| | _|| _|| _i | _tjj| _g | _g | _g | _d | _d| _ d| _ d| _ d | _ d| _ d S )Nr Fg )!r r! r_ rS � from_textra rb �makeZ is_metatyperH rc rd Z is_metaclassr� �_get_qnames_to_try�
qnames_to_tryr rK rL r� r� �nxdomain_responses�emptyr' � nameservers�current_nameserversr6 rM rN � tcp_attempt�retry_with_tcprE �backoff)
r r� r' rK rL r� r� r� Z
the_rdtypeZ the_rdclassr r r r H s4
z_Resolution.__init__)r7 c C s� �x�t | j�dk�r�| j�d�| _| jjr�| jj�| j| j| jf�}|dk rr|j dkrj| j
rjt |j d��nd|fS | jj�| jt
jj| jf�}|dk r�|j �� t
jjkr�|j | j| j< qt
j�| j| j| j�}| jjdk r�|j| jj| jj| jjd� |j| jj| jj| jj | jj d� | jj dk �r0| jj |_ | jj dd� | _ | jj �rXt!�"| j � | j dd� | _#g | _$d| _%d| _&d| _'|| _(d| _)|dfS W t| j*| jd��dS ) z�Get the next request to send, and check the cache.
Returns a (request, answer) tuple. At most one of request or
answer will not be None.
r N)r( )� algorithm)�optionsFg�������?)r r )+r r �popr' r� �cacher* rK rL rP r� rA r( r_ ra �ANY�rcoder
r� re Z
make_query�keyname�use_tsig�keyring� keyalgorithm�use_edns�edns� ednsflags�payload� ednsoptions�flagsr� �rotate�random�shuffler� r6 rM r� r� rE r� r� )r rO rE r r r � next_requestn sN
z_Resolution.next_requestc C s� | j r0| jd k st�d| _d| _ | j| jddfS d}| js�t| j�dkrXt| j | j
d��| jd d � | _| j }t | j d d�| _ | j�
d�| _| jj�| j| jj�| _| j| _| j| j| j|fS )NTFr g )rE r6 r8 )r� rM �AssertionErrorr� rN r� r r� rD rE r6 r� �minr� r� �nameserver_portsr* r� )r r� r r r �next_nameserver� s" z_Resolution.next_nameserver)r( �exr7 c
C s� | j d k st�|r�|d ks t�| j�| j | j| j||f� t|tjj �sft|t
�sft|t �sft|t �rv| j
�| j � n*t|tjj�r�| jr�| j
�| j � nd| _dS |d k s�t�t|tjj�s�t�|�� }|tjjk�r�y t| j| j| j|| j | j�}W nN tk
�rF } z.| j�| j | j| j||f� | j
�| j � dS d }~X Y nX | jj�rn| jj� | j| j| jf|� |j d k�r�| j �r�t |j d��|dfS |tjj!k�rHy t| jtj"j#tj$j%|�}W nN tk
�r } z.| j�| j | j| j||f� | j
�| j � dS d }~X Y nX || j&| j< | jj�rD| jj� | jtj"j#| jf|� dS |tjj'k�r~t'� }| j�| j | j| j||f� |�nN|tjj(k�s�| jj)�s�| j
�| j � | j�| j | j| jtj�*|�|f� dS d S )NT)NF)r( )NT)+rM r� r6 r+ r� rN r r_ � exceptionZ FormError�EOFError�OSError�NotImplementedErrorr� �removere Z Truncatedr� rf r� ZNOERRORrJ r' rK rL r& r� r� r� rP r� rA r( r
ra r� rc �INr� r5 ZSERVFAIL�retry_servfail�to_text)r r( r� r� rO �eZyexr r r � query_result� s�
z_Resolution.query_resultN)r- r. r/ r0 r r_ rS r` r! ra rb rc rd �boolr r r re rf rJ r� rg r� r� �Messager& r� r r r r r� < s
"Er� c @ s$ e Zd ZU dZejjed< ee e
f ed< e
ed< e ejj ed< e ed< e
ed< e
ed< ee ed < eeejje f ed
< eejje f ed < e
ed < e
ed
< ee ejj ed< e
ed< eed< ee
ed< e ed< e ed< ee
ed< d7e e d�dd�Zdd� Zed d �d d �Zd d �d!d"�Zd8e
ee
ee e e
d#�d$d%�Zejjee e ejj d&�d'd(�Zd ejjfeeeejje f eejje f d d)�d*d+�Z d,d,ej j d feee
e f e
e
ee ejj d d-�d.d/�Z e
d d0�d1d2�Z e!e e d �d3d4��Z"e"j#e e d d5�d6d4��Z"d S )9r� zDNS stub resolver.�domainr� rN r� �use_search_by_defaultr> �lifetimer� r� r� r� r� r� r� r� r� r� r� �ndots�/etc/resolv.confT)�filename� configurec C s2 | � � |r.tjdkr | �� n|r.| �|� dS )a� *filename*, a ``str`` or file object, specifying a file
in standard /etc/resolv.conf format. This parameter is meaningful
only when *configure* is true and the platform is POSIX.
*configure*, a ``bool``. If True (the default), the resolver
instance is configured in the normal fashion for the operating
system the resolver is running on. (I.e. by reading a
/etc/resolv.conf file on POSIX systems and from the registry
on Windows systems.)
r N)rk �sys�platform�
read_registry�read_resolv_conf)r r� r� r r r r L s
zBaseResolver.__init__c C s� t j�t j�t�� �dd� �| _t| j�dkr:t jj| _g | _ i | _
d| _ g | _ d| _
d| _d| _d| _d| _t jj| _d| _d| _d| _d| _d| _d| _d| _d| _ d| _ dS ) z1Reset all resolver configuration to the defaults.r Nr �5 Fg @g @r= ) r_ rS r` r� �socket� gethostnamer� r �rootr� r� rN r� r� r> r� r� r� �tsig�default_algorithmr� r� r� r� r� r� r� r� r� r� )r r r r rk _ s, "
zBaseResolver.resetN)�fr7 c C s t |t�r<y t|�}W qF tk
r8 td|� ���Y qFX n
t�|�}|���}�x�|D �]�}t|�dksV|d dksV|d dkr�qV|�� }t|�dk r�qV|d dkr�| j �
|d � qV|d dkr�t j �
|d �| _g | _qV|d d k�r g | _x�|dd
� D ]}| j�
t j �
|�� � q�W qV|d d krVx�|dd
� D ]�}|d k�rNd
| _n�|dk�rb| �� n~d|k�r�yt|�d�d �| _W n ttfk
�r� Y nX n>d|k�r8yt|�d�d �| _W n ttfk
�r� Y nX �q8W qVW W d
Q R X t| j �dk�r td��d
S )a� Process *f* as a file in the /etc/resolv.conf format. If f is
a ``str``, it is used as the name of the file to open; otherwise it
is treated as the file itself.
Interprets the following items:
- nameserver - name server IP address
- domain - local domain name
- search - search list for host-name lookup
- options - supported options are rotate, timeout, edns0, and ndots
z cannot open r �#�;r8 rM r r� r� Nr� r� TZedns0r> �:r� zno nameservers)r r! �openr� rI �
contextlib� nullcontextr �splitr� r+ r_ rS r� r� r� r� r� rg r> �
ValueErrorr[ r� )r r� �cm�l�tokens�suffix�optr r r r� y sP
$
z BaseResolver.read_resolv_conf)r7 c C sN y0t j�� }|jdk r |j| _|j| _|j| _W n tk
rH t�Y nX dS )z9Extract resolver configuration from the Windows registry.N)r_ Z win32utilZ get_dns_infor� r� r� r r� )r �infor r r r� � s
zBaseResolver.read_registry)�startr� r6 r7 c C st |d kr| j n|}t�� }|| }|d kr.g }|dk rP|dk rLt||d��nd}||krdt||d��t|| | j�S )Nr r= )r> r6 )r� rQ r< r� r> )r r� r� r6 rz �durationr r r �_compute_timeout� s z BaseResolver._compute_timeout)r' r� r7 c C s� |d kr| j }g }|�� r&|�|� n�|�tjj�}|r�t| j�dkrV| jd d � }n&| j tjjkrx| j d k rx| j g}ng }| j
d kr�d}n| j
}x|D ]}|�|| � q�W t|�|kr�|� d|� q�|�|� n
|�|� |S )Nr r ) r� � is_absoluter+ Z concatenater_ rS r� r r� r� r� �insert)r r' r� r� Z abs_qnameZ search_listr� r� r r r r� � s,
z BaseResolver._get_qnames_to_try)r� r� r� r7 c C s || _ || _|| _dS )z�Add a TSIG signature to each query.
The parameters are passed to ``dns.message.Message.use_tsig()``;
see its documentation for details.
N)r� r� r� )r r� r� r� r r r r� s zBaseResolver.use_tsigr )r� r� r� r� r7 c C s> |dks|dkrd}n |dkr"d}|| _ || _|| _|| _dS )a� Configure EDNS behavior.
*edns*, an ``int``, is the EDNS level to use. Specifying
``None``, ``False``, or ``-1`` means "do not use EDNS", and in this case
the other parameters are ignored. Specifying ``True`` is
equivalent to specifying 0, i.e. "use EDNS0".
*ednsflags*, an ``int``, the EDNS flag values.
*payload*, an ``int``, is the EDNS sender's payload field, which is the
maximum size of UDP datagram the sender can handle. I.e. how big
a response to this message can be.
*options*, a list of ``dns.edns.Option`` objects or ``None``, the EDNS
options.
NFr= Tr )r� r� r� r� )r r� r� r� r� r r r r� s zBaseResolver.use_edns)r� r7 c C s
|| _ dS )zkOverrides the default flags with your own.
*flags*, an ``int``, the message flags to use.
N)r� )r r� r r r � set_flags9 s zBaseResolver.set_flagsc C s | j S )N)� _nameservers)r r r r r� A s zBaseResolver.nameservers)r� r7 c C s~ t |t�rhxT|D ]L}tj�|�syt|�jdkr4t�W q tk
rZ t d|� d���Y qX qW || _
nt d� t |����dS )z�
*nameservers*, a ``list`` of nameservers.
Raises ``ValueError`` if *nameservers* is anything other than a
``list``.
�httpsz nameserver z( is not an IP address or valid https URLz%nameservers must be a list (not a {})N)
r r r_ �inet�
is_addressr �schemer� r& r� r� r" �type)r r� rM r r r r� E s
)r� T)NN)$r- r. r/ r0 r_ rS r` �__annotations__r r! rg r r� r� r r r r� �Optionr rk r� r� �
ErrorTupler� r� r� r� r� re ZDEFAULT_EDNS_PAYLOADr� r� r3 r� �setterr r r r r� 1 sT
C **
$r� c @ s e Zd ZdZejjejjddddddfe ej
j e f e ejj
e f e ejje f eee eeee ee ed�
dd�Zejjejjdddddfe ej
j e f e ejj
e f e ejje f eee eeee ed � d
d �Ze eeed �d
d�Ze ej
j e f ej
j d�dd�ZdS )�ResolverzDNS stub resolver.FNTr )
r' rK rL r� �sourcer� � source_portr� r� r7 c
C s: t | |||||| �}
t�� } �x|
�� \} }
|
dk r8|
S | dk sDt�d}x�|�s0|
�� \}}}}|rnt�|� | �| ||
j�}y\tj �
|�r�|r�tj j | |||||d�}q�tj j
| |||||dd�}ntj j| ||d�}W n6 tk
�r } z|
�d|�\}}wJW dd}~X Y nX |
�|d�\}
}|
dk rJ|
S qJW q W dS )a� Query nameservers to find the answer to the question.
The *qname*, *rdtype*, and *rdclass* parameters may be objects
of the appropriate type, or strings that can be converted into objects
of the appropriate type.
*qname*, a ``dns.name.Name`` or ``str``, the query name.
*rdtype*, an ``int`` or ``str``, the query type.
*rdclass*, an ``int`` or ``str``, the query class.
*tcp*, a ``bool``. If ``True``, use TCP to make the query.
*source*, a ``str`` or ``None``. If not ``None``, bind to this IP
address when making queries.
*raise_on_no_answer*, a ``bool``. If ``True``, raise
``dns.resolver.NoAnswer`` if there's no answer to the question.
*source_port*, an ``int``, the port from which to send the message.
*lifetime*, a ``float``, how many seconds a query should run
before timing out.
*search*, a ``bool`` or ``None``, determines whether the
search list configured in the system's resolver configuration
are used for relative names, and whether the resolver's domain
may be added to relative names. The default is ``None``,
which causes the value of the resolver's
``use_search_by_default`` attribute to be used.
Raises ``dns.resolver.LifetimeTimeout`` if no answers could be found
in the specified lifetime.
Raises ``dns.resolver.NXDOMAIN`` if the query name does not exist.
Raises ``dns.resolver.YXDOMAIN`` if the query name is too long after
DNAME substitution.
Raises ``dns.resolver.NoAnswer`` if *raise_on_no_answer* is
``True`` and the query name exists but has no RRset of the
desired type and class.
Raises ``dns.resolver.NoNameservers`` if no non-broken
nameservers are available to answer the question.
Returns a ``dns.resolver.Answer`` instance.
NF)r> rN r� r� T)r> rN r� r� Zraise_on_truncation)r> )r� rQ r� r� r� �sleepr� r6 r_ r� r� rB r� �udpr� r& r� )r r' rK rL r� r� r� r� r� r� �
resolutionr� rE rO �donerM rN r� r> r( r� �_r r r �resolveb sN ?
zResolver.resolve) r' rK rL r� r� r� r� r� r7 c C s* t jdtdd� | �||||||||d� S )a$ Query nameservers to find the answer to the question.
This method calls resolve() with ``search=True``, and is
provided for backwards compatibility with prior versions of
dnspython. See the documentation for the resolve() method for
further details.
z2please use dns.resolver.Resolver.resolve() insteadr8 )�
stacklevelT)�warnings�warn�DeprecationWarningr� ) r r' rK rL r� r� r� r� r� r r r rB � s zResolver.query)�ipaddrr r r7 c O s@ i }|� |� tjj|d< tjj|d< | jtj�|�f|�|�S )a� Use a resolver to run a reverse query for PTR records.
This utilizes the resolve() method to perform a PTR lookup on the
specified IP address.
*ipaddr*, a ``str``, the IPv4 or IPv6 address you want to get
the PTR record for.
All other arguments that can be passed to the resolve() function
except for rdtype and rdclass are also supported by this
function.
rK rL ) �updater_ ra �PTRrc r� r� � reversename� from_address)r r r r Zmodified_kwargsr r r �resolve_address� s
zResolver.resolve_address)rS r7 c
C sJ y| j |dd�}|j}W n, tjjk
rD } z
|j}W dd}~X Y nX |S )a� Determine the canonical name of *name*.
The canonical name is the name the resolver uses for queries
after all CNAME and DNAME renamings have been applied.
*name*, a ``dns.name.Name`` or ``str``, the query name.
This method can raise any exception that ``resolve()`` can
raise, other than ``dns.resolver.NoAnswer`` and
``dns.resolver.NXDOMAIN``.
Returns a ``dns.name.Name``.
F)r� N)r� r% r_ r� r
)r rS rO r% r� r r r r% s
zResolver.canonical_name)r- r. r/ r0 r_ ra �Arc r� r rS r` r! rb rd r� r rg r� rJ r� rB r r r% r r r r r� _ s( Fm@r� �default_resolver)r7 c C s t dkrt� t dk st�t S )z7Get the default resolver, initializing it if necessary.N)r �reset_default_resolverr� r r r r �get_default_resolver0 s r
c C s
t � adS )z�Re-initialize default resolver.
Note that the resolver configuration (i.e. /etc/resolv.conf on UNIX
systems) will be re-read immediately.
N)r� r r r r r r 8 s r FT)
r' rK rL r� r� r� r� r� r� r7 c C s t � �| ||||||||� S )z�Query nameservers to find the answer to the question.
This is a convenience function that uses the default resolver
object to make the query.
See ``dns.resolver.Resolver.resolve`` for more information on the
parameters.
)r
r� ) r' rK rL r� r� r� r� r� r� r r r r� C s r� ) r' rK rL r� r� r� r� r� r7 c
C s( t jdtdd� t| |||||||d� S )a Query nameservers to find the answer to the question.
This method calls resolve() with ``search=True``, and is
provided for backwards compatibility with prior versions of
dnspython. See the documentation for the resolve() method for
further details.
z)please use dns.resolver.resolve() insteadr8 )r T)r r r r� )r' rK rL r� r� r� r� r� r r r rB e s rB )r r r r7 c O s t � j| f|�|�S )z�Use a resolver to run a reverse query for PTR records.
See ``dns.resolver.Resolver.resolve_address`` for more information on the
parameters.
)r
r )r r r r r r r � s r )rS r7 c C s t � �| �S )z�Determine the canonical name of *name*.
See ``dns.resolver.Resolver.canonical_name`` for more information on the
parameters and possible exceptions.
)r
r% )rS r r r r% � s r% )rS rL r� r� r� r7 c
C s� t | t�r tj�| tjj�} |dkr*t� }| �� s:t| ��t � � }|dk rT|| }nd}�x>y\|r||t � � }|dkr�d}nd}|j
| tj j |||d�}|j
dk s�t�|j
j| kr�| S W n� tjjtjjfk
�rh } z�t | tjj�r�| �� �| �}
n| �� }
|
�rXxR|
jD ]H} | jtj j k�r | j|k�r | j�| �\} }
}
| tjjk�r | jS �q W W dd} ~ X Y nX y | �� } W q\ tjjk
�r� t �Y q\X q\W dS )a� Find the name of the zone which contains the specified name.
*name*, an absolute ``dns.name.Name`` or ``str``, the query name.
*rdclass*, an ``int``, the query class.
*tcp*, a ``bool``. If ``True``, use TCP to make the query.
*resolver*, a ``dns.resolver.Resolver`` or ``None``, the resolver to use.
If ``None``, the default, then the default resolver is used.
*lifetime*, a ``float``, the total time to allow for the queries needed
to determine the zone. If ``None``, the default, then only the individual
query limits of the resolver apply.
Raises ``dns.resolver.NoRootSOA`` if there is no SOA RR at the DNS
root. (This is only likely to happen if you're using non-default
root servers in your network and they are misconfigured.)
Raises ``dns.resolver.LifetimeTimeout`` if the answer could not be
found in the allotted lifetime.
Returns a ``dns.name.Name``.
Nr )r� ) r r! r_ rS r� r� r
r� rF rQ r� ra ZSOArP r� r� r
rA r r* r( � authorityrK rL Z fullcompareZNAMERELN_SUPERDOMAIN�parentZNoParentrG )rS rL r� r� r� r� rR Z rlifetimerO r� r( Zrrs�nrr� r r r �
zone_for_name� sH
r c
C s� |t j@ dkr t| |||||�S |t jt jB @ dkrBt �t jd��| d kr`|d kr`t �t jd��g }g }d }| d kr�t| |||||�S y tj �
| � t| |||||�S t k
r� Y nX y�|t j ks�|t j
k�r"tj| tjjdd�} | j} | j�d�}| jd k �r"x | jD ]}
|�|
j� �q W |t jk�s:|t j
k�r�tj| tjjdd�} | j�d�}| jd k �r�x | jD ]}
|�|
j� �qnW W nJ tjjk
�r� t �t jd��Y n$ t k
�r� t �t j d��Y nX d } y |d k�r�d} nt |�} W nL t k
�r> |t j @ dk�r:yt � |�} W n t k
�r8 Y nX Y nX | d k�rXt �t jd��g }
|dk�rtt j t j!g}n|g}|t j"@ dk�r�|}nd}|t j k�s�|t j
k�r�xP|D ]H}x@|D ]8}x0t#| D ]$}|
�t j ||||| ddff� �q�W �q�W �q�W |t jk�s|t j
k�rdxL|D ]D}x<|D ]4}x,t#| D ] }|
�t j||||| ff� �q4W �q&W �q W t$|
�dk�r�t �t jd��|
S ) Nr z*Non-recoverable failure in name resolutionzName or service not knownF)r� Tz$Temporary failure in name resolution� )%r� �AI_NUMERICHOST�_original_getaddrinfo�
AI_ADDRCONFIG� AI_V4MAPPED�gaierror�EAI_FAIL�
EAI_NONAMEr_ r� Zaf_for_addressr& �AF_INET6� AF_UNSPEC� _resolverr� ra ZAAAAr' r% r� rP r+ �address�AF_INETr
r� r
� EAI_AGAINrg �AI_NUMERICSERV�
getservbyname�
SOCK_DGRAM� SOCK_STREAM� AI_CANONNAME�_protocols_for_socktyper )�host�service�family�socktype�protor� Zv6addrsZv4addrsr% Zv6ZrdataZv4rN �tuplesZ socktypesr) �addrr r r � _getaddrinfo s�
,
(r- c
C sh | d }| d }t | �dkr,| d }tj}n
d }tj}t|||tjtjd�}t |�dkrbt�d��|d d d }|tj@ r�d}nd}t j
� |�} |tj @ dk�r y"t
�| d�}
|
jd j�d �} W nX t jjt jjfk
�r |tj@ r�t�tjd
��|} |d k �r| d t|� 7 } Y nX n |} |d k �r>| d t|� 7 } |tj@ �rTt|�} n t�||�} | | fS ) Nr r � r9 z'sockaddr resolved to multiple addressesr� r� r TzName or service not known�%)r r� r r r- r# �SOL_TCP�error�NI_DGRAMr_ r r �NI_NUMERICHOSTr r� rP �targetr� r� r
rA � NI_NAMEREQDr r r! �NI_NUMERICSERV�
getservbyport)
�sockaddrr� r& rN Zscoper( r+ r, Zpnamer' rO �hostnamer' r r r � _getnameinfoo s@
r: c C s< | d krt �� } yt| �\} }}W n tk
r6 Y nX | S )N)r� r� �_gethostbyaddrr& )rS r� r r r �_getfqdn� s r< c C s t | �d d S )Nr8 r )�_gethostbyname_ex)rS r r r �_gethostbyname� s r> c C sX g }g }t | dtjtjtjtj�}|d d }x |D ]}|�|d d � q4W |||fS )Nr r9 r. )r- r� r r# r0 r$ r+ )rS �aliases� addressesr+ � canonical�itemr r r r= � s
r= c
C s y"t j�| � | dddf}tj}W nV tk
rx yt j�| � W n" tk
rd t�tjd��Y nX | df}tj }Y nX t
|tj �\}}g }g }t |d|tj
tjtj�}|d d }t j�|| �} x8|D ]0}
|
d d } t j�|| �} | | kr�|�| � q�W |||fS )N�P r zName or service not knownr9 r. )r_ Zipv6� inet_atonr� r r& Zipv4r r r r: r5 r- r# r0 r$ r� � inet_ptonr+ )
�ipr8 r( rS r� r? r@ r+ rA Zbin_iprB r, Zbin_addrr r r r; � s0
r; )r� r7 c C s: | dkrt � } | att_tt_tt_t t_
t t_ t
t_dS )a� Override the system resolver routines in the socket module with
versions which use dnspython's resolver.
This can be useful in testing situations where you want to control
the resolution behavior of python code without having to change
the system's resolver settings (e.g. /etc/resolv.conf).
The resolver to use may be specified; if it's not, the default
resolver will be used.
resolver, a ``dns.resolver.Resolver`` or ``None``, the resolver to use.
N)r
r r- r� � getaddrinfor: � getnameinfor< �getfqdnr> �
gethostbynamer= �gethostbyname_exr; �
gethostbyaddr)r� r r r �override_system_resolver� s rM c C s, da tt_tt_tt_tt_ t
t_ t t_
dS )z5Undo the effects of prior override_system_resolver().N)r r r� rG �_original_getnameinforH �_original_getfqdnrI �_original_gethostbynamerJ �_original_gethostbyname_exrK �_original_gethostbyaddrrL r r r r �restore_system_resolver� s rS )r )N)N)mr0 �typingr r r r r r � urllib.parser r� r� r� rn rQ r� r Z
dns.exceptionr_ Zdns.ednsZ dns.flagsZdns.inetZdns.ipv4Zdns.ipv6Z dns.messageZdns.nameZ dns.queryZ dns.rcodeZdns.rdataclassZ
dns.rdatatypeZdns.reversenameZdns.tsigr� Z
dns.win32utilr� Z DNSExceptionr
r5 r! r� rg r& re r� r� r; �Timeoutr< rA rD rF rG rH rI rJ rh rm rS r` ra rb rc rd r� rt r� r� r� r� r� r r� r
r r
r� r� r� rB r r% r r" �SOL_UDPr# r0 r% r rG r rH rN rI rO rJ rP rK rQ rL rR r r- r: r< r> r= r; rM rS r r r r �<module> s�
X$ E Oo v 0 O
F@
&U
l
'