File: //usr/lib/python3/dist-packages/duplicity/backends/__pycache__/webdavbackend.cpython-310.pyc
o
�~�_O � @ s: d dl mZ e�� d dlmZ d dlmZ d dlZd dlZd dl Z d dl
Z
d dl Z d dl Z
d dlZ
d dlZ
d dlZd dlZd dlmZ d dlmZ d dlmZ d dlmZmZ G d d
� d
e
jj�Z G d d � d ej j �Z G d
d� dej j!�Z"ej �#de"� ej �#de"� ej �#de"� ej �#de"� ej j$�%g d�� dS )� )�standard_library)�str)�rangeN)�config)�log)�util)�BackendException�FatalBackendExceptionc @ s e Zd ZdZdd� Zdd� ZdS )�CustomMethodRequestz�
This request subclass allows explicit specification of
the HTTP request method. Basic urllib.request.Request class
chooses GET or POST depending on self.has_data()
c O s& || _ tjjj| g|�R i |�� d S �N)�method�urllib�request�Request�__init__)�selfr �args�kwargs� r �B/usr/lib/python3/dist-packages/duplicity/backends/webdavbackend.pyr 3 s z CustomMethodRequest.__init__c C s | j S r )r �r r r r �
get_method7 s z CustomMethodRequest.get_methodN)�__name__�
__module__� __qualname__�__doc__r r r r r r r
- s r
c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�VerifiedHTTPSConnectionc O s� z
dd l a dd laW n
ty ttd���w tjjj| g|�R i |�� t j
| _ g d�| _ | j sI| j D ]}t
j�|�}t
j�|�rH|| _ nq5| j r]t
�| j t
j�s_ttd�| j ��d S d S )Nr z%Missing socket or ssl python modules.)z~/.duplicity/cacert.pemz~/duplicity_cacert.pemz/etc/duplicity/cacert.pemz*Cacert database file '%s' is not readable.)�socket�ssl� ImportErrorr �_�http�client�HTTPSConnectionr r �ssl_cacert_file� cacert_file�cacert_candidates�os�path�
expanduser�isfile�access�R_OK)r r r r( r r r r < s* �
���z VerifiedHTTPSConnection.__init__c C s� t �| j| jf| j�}| jr|| _| �� dtt �v r2t j
t j j | j
tjd�}|j|| jd�| _d S tjr;ttd���| j
sJttd�d�| j� ��t j|t j| j
d�| _d S )N�create_default_context)�cafile�capath)�server_hostnamezHOption '--ssl-cacert-path' is not supported with python 2.7.8 and below.a For certificate verification with python 2.7.8 or earlier a cacert database
file is needed in one of these locations: %s
Hints:
Consult the man page, chapter 'SSL Certificate Verification'.
Consider using the options --ssl-cacert-file, --ssl-no-check-certificate .z, )� cert_reqs�ca_certs)r �create_connection�host�port�timeout� _tunnel_host�sock�tunnel�dirr r- �Purpose� SERVER_AUTHr% r �ssl_cacert_path� wrap_socketr r �joinr& �
CERT_REQUIRED)r r8 �contextr r r �connectW s0 �
��
� �z VerifiedHTTPSConnection.connectc
O sR zt jjj| g|�R i |��W S tjy( } z tdt�|� t j
j ��d }~ww )NzSSL failed: %s) r! r" r# r r �SSLErrorr r �uexcr � ErrorCode�
backend_error)r r r �er r r r { s ���z VerifiedHTTPSConnection.requestN)r r r r rB r r r r r r ; s $r c @ s� e Zd ZdZ dZ dd� Zdd� Zdd� Zd d
� Zd*d d
�Z dd� Z
d+dd�Z dd� Z dd� Z
dd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� ZdS ),�
WebDAVBackendz}Backend for accessing a WebDAV repository.
webdav backend contributed in 2006 by Jesper Zedlitz <jesper@zedlitz.de>
z_<?xml version="1.0"?><D:propfind xmlns:D="DAV:"><D:prop><D:resourcetype/></D:prop></D:propfind>c C s� t jj�| |� ddi| _|| _d | _d | _|j| _| � � | _
| � |j �| _
t�td�tjf � t�td�|j|jf � t�td�| j
f � d | _d S )N�
Connectionz
keep-alivezUsing WebDAV protocol %sz Using WebDAV host %s port %szUsing WebDAV directory %s)� duplicity�backend�Backendr �headers�
parsed_url�digest_challenge�digest_auth_handler�username� get_password�password�
sanitize_pathr( � directoryr �Infor r � webdav_proto�hostnamer5 �conn)r rN r r r r � s
�
zWebDAVBackend.__init__c C s" |rt �d�}|�d|d �S dS )Nz/+�/)�re�compile�sub)r r( �foldpathr r r rT � s
zWebDAVBackend.sanitize_pathc C s( d}|D ]
}|j |jkr||j }q|S )N� )�nodeType� TEXT_NODE�data)r �nodelist�rc�noder r r �getText� s
�zWebDAVBackend.getTextc C s | j dd� d S )NT)�forced)rB r r r r �_retry_cleanup� s z WebDAVBackend._retry_cleanupFc C s� |s| j r| j j| jjkrdS t�td�| jj � | �� | jjdv r2t j
� | jj| jj �| _ dS | jjdv rUt
jrIt j
�| jj| jj �| _ dS t| jj| jj �| _ dS ttd�| jj ��)z�
Connect or re-connect to the server, updates self.conn
# reconnect on errors as a precaution, there are errors e.g.
# "[Errno 32] Broken pipe" or SSl errors that render the connection unusable
Nz WebDAV create connection on '%s')�webdavr! )�webdavs�httpsz WebDAV Unknown URI scheme: %s)rY r4 rN rX r rV r �_close�schemer! r" �HTTPConnectionr5 r �ssl_no_check_certificater# r r )r rg r r r rB � s
zWebDAVBackend.connectc C s | j r
| j �� d S d S r )rY �closer r r r rl � s �zWebDAVBackend._closeNr c C s� | � � | �� tj�|d�}| jdur | �|�| jd< t� t
d�||| jf � t� t
d�t t |�� � | j
�|||| j� | j
�� }t� t
d�|j|jf � |jdv r�|dkr�|�d d�}|�� |r�t�t
d
�tj�|� � |d kr~tt
d ���tj�|�| _| �| jj �| _ | �|| j ||d
�S tt
d���|jdkr�|� � |�� | � ||�| jd< t� t
d�� t� t
d�||| jf � t� t
d�t t |�� � | j
�|||| j� | j
�� }t� t
d�|j|jf � |S )zi
Wraps the connection.request method to retry once if authentication is
required
z/:~N�
Authorizationz&WebDAV %s %s request with headers: %s zWebDAV data length: %s z+WebDAV response status %s with reason '%s'.)i- i. �PROPFIND�locationzWebDAV redirect to: %s �
z&WebDAV redirected 10 times. Giving up.� z4WebDAV missing location header in redirect response.i� z3WebDAV retry request with authentification headers.z'WebDAV %s %s request2 with headers: %s z,WebDAV response2 status %s with reason '%s'.) rl rB r
�parse�quoterO �get_digest_authorizationrM r rV r �lenr rY r � getresponse�status�reason� getheaderrp �Notice�unquoter rJ rK � ParsedUrlrN rT r( rU �read�get_authorization)r r r( rb �
redirected� quoted_path�response� redirect_urlr r r r � s@
zWebDAVBackend.requestc
C s� z|� dd�}|�dd�\}}W n
ty Y dS w |�d�d �� dkr^z| �� W S ty? t�td �� | � � Y S t
y] } zt�td
�| � | � � W Y d}~S d}~ww |�� d krh| � � S | � |�| _ | �
|�S ) zY
Fetches the auth header based on the requested method (basic or digest)
zwww-authenticater_ � ru N�,r � negotiatezkpython-kerberos needed to use kerberos authorization, falling back to basic auth.zWKerberos authorization failed: %s. Falling back to basic auth.�basic)r} �split�
ValueError�lower�get_kerberos_authorizationr r �Warnr �get_basic_authorization� Exception�parse_digest_challengerO rx )r r� r( �auth_hdr�token� challengerG r r r r� � s. �
���
z WebDAVBackend.get_authorizationc C s t j�t j�|��S r )r
r �parse_keqv_list�parse_http_list)r �challenge_stringr r r r� s z$WebDAVBackend.parse_digest_challengec C s< dd l }|�d| jj �\}}|�|d� |�|�}d| S )Nr zHTTP@%sr_ z Negotiate %s)�kerberos�authGSSClientInitrY r4 �authGSSClientStep�authGSSClientResponse)r r� r �ctx�tgtr r r r� s
z(WebDAVBackend.get_kerberos_authorizationc C s* d| j | jf }dt�|�� ��� �� S )z/
Returns the basic auth header
�%s:%szBasic %s)rQ rS �base64� b64encode�encode�strip�decode)r � auth_stringr r r r� s z%WebDAVBackend.get_basic_authorizationc C s� | j }| jdu r tj�� }|�d| jj| j| j � tj�
|�| _|j dkr'dp(d}|j r4d|j
|j f p6|j
}d|||f }t| jj|�}| j�|| j�}d| S )z0
Returns the digest auth header
Nrj rk r! r� z %s://%s%sz Digest %s)rN rP r
r � HTTPPasswordMgrWithDefaultRealm� add_passwordrY r4 rQ rS �HTTPDigestAuthHandlerrm r5 rX r
�_methodr� rO ) r r( �u�
pw_managerrm rX � dummy_url� dummy_reqr� r r r rx % s
�z&WebDAVBackend.get_digest_authorizationc
C s2 d }z�zd| j d< | �d| j| j�}| j d= |jdkr.|�� | �� g W W |r-|�� S S |jdv r<|�� }|�� n|j}|j}|�� t d||f ��t
� d|f � t j
j�|�}g }|�d�|�d � D ]}| �|�}|rw|�|� qi|W W |r�|�� S S ty� } z| �d } ~ ww |r�|�� w w )
N�1�Depthrr � )�� �� z Bad status code %s reason %s.z%szd:hrefzD:href)rM r rU �listbodyr{ rp �makedirr� r| r r �Debug�xml�dom�minidom� parseString�getElementsByTagName�
taste_href�appendr� )
r r� �documentr{ r| r� �result�href�filenamerG r r r �_list9 sL
�
�
�
����
�zWebDAVBackend._listc C s� | j �d�}|d dkr|dd� }tdt|��D ]N}d�|d|d � �d }d| jd< | �d|�}| jd= t�d ||j f � |j d
krgt�t
d �| � | �d |�}|j d
krgt t
d�||j |j f ��qdS )z(Make (nested) directories on the server.rZ ���r_ r ru r� r� rr z Checking existence dir %s: %dr� z Creating missing directory %s�MKCOL�� z WebDAV MKCOL %s failed: %s %sN)
rU r� r ry r? rM r r rV r{ r r r| )r �dirs�i�dr� �resr r r r� \ s$
���zWebDAVBackend.makedirc C s� | � |j��� }tj�tj�|��}|j}t� t
d�||f � |j dur9|j | j j ks9d|j | j j f }t
|��|�| j�rI|�| jdd�}|S dS )z�
Internal helper to taste the given href node and, if
it is a duplicity file, collect it as a result file.
@return: A matching filename, or None if the href did not match.
z.WebDAV path decoding and translation: %s -> %sNz�Received filename was in the form of a full url, but the hostname (%s) did not match that of the webdav backend url (%s) - aborting as a conservative safety measure. If this happens to you, please report the problemr_ ru )rf �
childNodesr� r
rv �urlparser r( r r� r rX rN r �
startswithrU �replace)r r� � raw_filenamerN r� �mr r r r� t s$
�
�� zWebDAVBackend.taste_hrefc
C s� | j t�|� }d }zQz7|�d�}| �d|�}|jdkr-t�||� |�� r(J �|�� n|j}|j }|�� t
t d�||f ��W n t yP } z|�d }~ww W |rZ|�� d S d S |rc|�� w w )N�wb�GETr� z(WebDAV GET Bad status code %s reason %s.)
rU r �fsdecode�openr r{ �shutil� copyfileobjrp r| r r r� ) r �remote_filename�
local_path�urlr� � target_filer{ r| rG r r r �_get� s4
�����
�
�zWebDAVBackend._getc
C s� | j t�|� }d }zLz2|�d�}| �d||�� �}|jdv r(|�� |�� n|j}|j}|�� t t
d�||f ��W n t yK } z|�d }~ww W |rU|�� d S d S |r^|�� w w )N�rb�PUT)r� r� �� z(WebDAV PUT Bad status code %s reason %s.) rU r r� r� r r� r{ rp r| r r r� ) r � source_pathr� r� r� � source_filer{ r| rG r r r �_put� s2
�����
�
�zWebDAVBackend._putc
C s� | j t�|� }d }zDz*| �d|�}|jdv r |�� |�� n|j}|j}|�� tt d�||f ��W n t
yC } z|�d }~ww W |rM|�� d S d S |rV|�� w w )N�DELETE)r� r� z(WebDAV DEL Bad status code %s reason %s.) rU r r� r r{ r� rp r| r r r� )r r� r� r� r{ r| rG r r r �_delete� s0
�����
�
�zWebDAVBackend._delete)F)Nr )r r r r r� r rT rf rh rB rl r r� r� r� r� rx r� r� r� r� r� r� r r r r rH � s.
,#% rH r! rk ri rj )r! rk ri rj )&�futurer �install_aliases�builtinsr r r� � http.clientr! r' r[ r� �urllib.requestr
� urllib.parse� urllib.error�xml.dom.minidomr� �duplicity.backendrJ r r r �duplicity.errorsr r r r r
r" r# r rK rL rH �register_backend� uses_netloc�extendr r r r �<module> s8 I \