File: //home/arjun/projects/env/lib/python3.10/site-packages/dns/__pycache__/xfr.cpython-310.pyc
o
!we�3 � @ sr d dl mZmZmZmZmZ d dlZd dlZd dl Zd dl
Zd dl Zd dl Zd dl
Zd dlZd dlZd dlZG dd� dejj�ZG dd� dejj�ZG dd� dejj�ZG d d
� d
�Zd dddddddejjf d ejjd ee d
eee e f dee dee dee deeej j dedeej j! deej j!e"f deej#j$ee f fdd�Z%dej#j&dee fdd�Z'dS )� )�Any�List�Optional�Tuple�UnionNc s e Zd ZdZ� fdd�Z� ZS )�
TransferErrorz.A zone transfer response got a non-zero rcode.c s& dt j�|� }t� �|� || _d S )NzZone transfer error: %s)�dns�rcode�to_text�super�__init__)�selfr �message�� __class__� �@/home/arjun/projects/env/lib/python3.10/site-packages/dns/xfr.pyr # s
zTransferError.__init__)�__name__�
__module__� __qualname__�__doc__r �
__classcell__r r r r r s r c @ � e Zd ZdZdS )�SerialWentBackwardsz:The current serial number is less than the serial we know.N�r r r r r r r r r ) � r c @ r )�UseTCPz'This IXFR cannot be completed with UDP.Nr r r r r r - r r c @ sh e Zd ZdZejjddfdejjdejj de
e de fdd �Z
d
ejjd e fd d
�Zdd� Zdd� ZdS )�Inboundz+
State machine for zone transfers.
NF� txn_manager�rdtype�serial�is_udpc C st || _ d| _|| _|tjjkr|du rtd��n|r td��|| _|| _|� � \}}| _
d| _ d| _ d| _
d| _dS )aq Initialize an inbound zone transfer.
*txn_manager* is a :py:class:`dns.transaction.TransactionManager`.
*rdtype* can be `dns.rdatatype.AXFR` or `dns.rdatatype.IXFR`
*serial* is the base serial number for IXFRs, and is required in
that case.
*is_udp*, a ``bool`` indidicates if UDP is being used for this
XFR.
Nz,a starting serial must be supplied for IXFRszis_udp specified for AXFRF)r �txnr r � rdatatype�IXFR�
ValueErrorr r! �origin_information�origin� soa_rdataset�done�
expecting_SOA� delete_mode)r
r r r r! �_r r r r 6 s �
zInbound.__init__r �returnc C sT | j du r| jtjjk}| j�|�| _ |�� }|tjjkr!t |��t
|j �dkrF|j d j | j
kr7tj�d��|j d j| jkrFtj�d��d}| jdu r�|jrY|jd j | j
kr_tj�d��|jd }|}|jtjjkrstj�d��d}|�� | _| jtjjkr�| jd j| jkr�d| _n"tj�| jd j�| jk r�t�| jr�t
|j|d� �dkr�t�d| _|j|d� D ]�}|j }|}| jr�tj�d ��| j dus�J �|jtjjk�rj|| j
k�rj| jtjjkr�| j | _ || jk�r6| jtjjk�s| jtjjk�r6| j �r6| j�r tj�d
��| jtjjk�r#| j|d jk�r#tj�d ��| j � ||� | j � � d| _ d| _n3d | _| jtjjk�rc| j �rU|d j| jk�rTtj�d
��n|d j| _| j � ||� ntj�d��q�| j�r�tjj| _d | _d | _ | j � � | j�d�| _ | j �r�| j � ||� q�| j �!||� q�| j�r�| j�s�tj�d��| jS )aZ Process one message in the transfer.
The message should have the same relativization as was specified when
the `dns.xfr.Inbound` was created. The message should also have been
created with `one_rr_per_rrset=True` because order matters.
Returns `True` if the transfer is complete, and `False` otherwise.
Nr zwrong question namezwrong question rdatatypez&No answer or RRset not for zone originzfirst RRset is not an SOA� Tzanswers after final SOAzempty IXFR sequencez unexpected end of IXFR sequenceFzIXFR base serial mismatchz unexpected origin SOA in AXFRzunexpected end of UDP IXFR)"r" r r r# �AXFRr �writerr �NOERRORr �len�question�namer' � exception� FormErrorr( �answer�SOA�copyr$ r r) �Serialr r! r r* r+ �replace�commit�rollback� delete_exact�add)r
r � replacementr � answer_index�rrset�rdatasetr4 r r r �process_messageY s�
��
zInbound.process_messagec C s | S )Nr )r
r r r � __enter__� s zInbound.__enter__c C s | j r| j �� dS )NF)r" r= )r
�exc_type�exc_val�exc_tbr r r �__exit__� s
zInbound.__exit__)r r r r r r# r/ � transaction�TransactionManager� RdataTyper �int�boolr r �MessagerD rE rI r r r r r 1 s$ ����
�# r r r �use_edns� ednsflags�payload�request_payload�options�keyring�keyname� keyalgorithmr- c
C sP | � � \}
} } |
du rtd��|du rtjj}
nKt|t�s!td��|dkrR| �� � }|�| d�}|r<|d j }tjj
}
nd}tjj}
W d � n1 sLw Y n|dkr_|dk r_tjj
}
ntd��| � � }tj �
|
|
||d||||� }|dur�tj�|dd |� d
��}|j|j|
|tjjd d �}|�|d� |dur�|j||| d
� ||fS )a Make an AXFR or IXFR query.
*txn_manager* is a ``dns.transaction.TransactionManager``, typically a
``dns.zone.Zone``.
*serial* is an ``int`` or ``None``. If 0, then IXFR will be
attempted using the most recent serial number from the
*txn_manager*; it is the caller's responsibility to ensure there
are no write transactions active that could invalidate the
retrieved serial. If a serial cannot be determined, AXFR will be
forced. Other integer values are the starting serial to use.
``None`` forces an AXFR.
Please see the documentation for :py:func:`dns.message.make_query` and
:py:func:`dns.message.Message.use_tsig` for details on the other parameters
to this function.
Returns a `(query, serial)` tuple.
Nzno zone originzserial is not an integerr r8 l zserial out-of-rangeFz. . z 0 0 0 0T)�create)� algorithm)r& r% r r# r/ �
isinstancerM �reader�getr r$ � get_classr �
make_query�rdata� from_text�
find_rrset� authorityr8 r? �use_tsig)r r rP rQ rR rS rT rU rV rW � zone_originr, r' r r" rC �rdclass�qr_ rB r r r r^ � sT
� ��
� � r^ �queryc C sl t | tjj�s td��| jd }|jtjjkrdS |jtjj kr$td��| �
| j |j |j
tjj�}|d jS )a7 Extract the SOA serial number from query if it is an IXFR and return
it, otherwise return None.
*query* is a dns.message.QueryMessage that is an IXFR or AXFR request.
Raises if the query is not an IXFR or AXFR, or if an IXFR doesn't have
an appropriate SOA RRset in the authority section.
zquery not a QueryMessager Nz query is not an AXFR or IXFR)rZ r r � QueryMessager% r3 r r# r/ r$ ra rb r4 re r8 r )rg r3 �soar r r �extract_serial_from_queryD s
�
rj )(�typingr r r r r �
dns.exceptionr � dns.message�dns.name� dns.rcode� dns.rdataset�
dns.rdatatype�
dns.serial�dns.transaction�dns.tsig�dns.zoner5 � DNSExceptionr r6 r r r �tsig�default_algorithmrJ rK rM rN �edns�Optionr4 �Name�strr rh r^ rO rj r r r r �<module> sb L���������
�
�
� J