File: //usr/lib/python3/dist-packages/duplicity/backends/__pycache__/rsyncbackend.cpython-310.pyc
o
��@a � @ s� d dl mZ d dlmZ d dlZd dlZd dlZd dlZd dl m
Z
d dlm Z m Z m
Z
G dd� dejj�Zej�de� ejj�dg� dS ) � )�print_function)�mapN)�InvalidBackendURL)�config�tempdir�utilc @ sH e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dS )� RsyncBackendz�Connect to remote store using rsync
rsync backend contributed by Sebastian Wilhelmi <seppi@seppi.de>
rsyncd auth, alternate port support
Copyright 2010 by Edgar Soldin <edgar.soldin@web.de>
c C sX t jj�| |� |j}d}dtjv rtjd= | �� r2| �� \}}d||� d�f | _
|r1d| }n-|r8|d nd}|j � d�rLd||j � d �f | _
n d
||j � d �f | _
|j
r_d |j
}| j
d d krm| j
d 7 _
|jr�| �� r{|jtjd
< n |jd | j
| _
d| _| �� }|r�|tjd< | �� r�|}nd|tjf }tj}d||f | _dS )zrsyncBackend initializer� � RSYNC_RSHz%s::%sz/:z
--port=%s�:z//z%s/%s�/z%s%sz-p %s����USER�@F�RSYNC_PASSWORDz -e 'ssh %s -oBatchMode=yes %s'z rsync %s %sN)� duplicity�backend�Backend�__init__�hostname�os�environ� over_rsyncd�get_rsync_path�lstrip�
url_string�path�
startswith�port�username� use_getpass� get_passwordr � ssh_options�
rsync_options�cmd) �self�
parsed_url�hostr r � host_string�password�
portOption� rsyncOptions� r, �A/usr/lib/python3/dist-packages/duplicity/backends/rsyncbackend.pyr ( sB
�
zRsyncBackend.__init__c C s | j j}t�d|�r dS dS )Nz::[^:]*$TF)r& r �re�search)r% �urlr, r, r- r _ s zRsyncBackend.over_rsyncdc C sD | j j}t�d|�}|r|�d�|�d��d�fS td| �|� ��)Nz(:\d+|)?::([^:]*)$� � r z"Could not determine rsync path: %s)r& r r. r/ �groupr r �munge_password)r% r0 �mr, r, r- r f s �zRsyncBackend.get_rsync_pathc C s: t �|�}tj�| j|�}d| j|j|f }| �|� d S �Nz%s %s %s� r �fsdecoder r �joinr r$ �uc_name�subprocess_popen)r% � source_path�remote_filename� remote_path� commandliner, r, r- �_putn �
zRsyncBackend._putc C s: t �|�}tj�| j|�}d| j||jf }| �|� d S r6 r7 )r% r= �
local_pathr> r? r, r, r- �_gett rA zRsyncBackend._getc C sB dd� }d| j | jf }| �|�\}}}dd� t||�d��D �S )Nc S s, | � � }t|�dkr|d dkr|d S d S )N� �.)�split�len)�str�liner, r, r- rF { s z!RsyncBackend._list.<locals>.splitz%s %sc S s g | ] }|rt �|��qS r, )r �fsencode)�.0�xr, r, r- �
<listcomp>� s z&RsyncBackend._list.<locals>.<listcomp>�
)r$ r r; r rF )r% rF r? �result�stdout�stderrr, r, r- �_listz s zRsyncBackend._listc C s" |}g }| � � D ]}||v r|�|� q|�|� qt�� }t�� �� \}}|g}|D ]4}t� |�}t
j � ||�} |�| � zt
| d�}
W n tyT t||d� Y q+w t||d� |
�� q+|�� d| j||| jf } | �| � |D ]}z t�t
j|� W qu ty� Y quw t
�|� d S )N�w)�filez0%s --recursive --delete --exclude-from=%s %s/ %s)rR �remove�append�tempfile�mkdtempr �default� mkstemp_filer r8 r r r9 �open�IsADirectoryError�print�closer$ r r; �ignore_missing�unlink�rmdir) r% �
filename_list� delete_list�dont_delete_listrT �dir�exclude� exclude_name� to_deleter �fr? r, r, r- � _delete_list� sB
�
�
�zRsyncBackend._delete_listN) �__name__�
__module__� __qualname__�__doc__r r r r@ rC rR rj r, r, r, r- r ! s 7 r �rsync)�
__future__r �builtinsr r r. rW �duplicity.backendr �duplicity.errorsr r r r r r r �register_backend� uses_netloc�extendr, r, r, r- �<module> s