File: //usr/lib/python3/dist-packages/duplicity/backends/__pycache__/ssh_paramiko_backend.cpython-310.pyc
o
�&�`tO � @ s d dl mZ d dlmZ d dlmZ d dlmZ d dlZd dlZd dlZd dl Z d dl
Z
d dl Z d dl Z d dl
mZ d dlZd dlmZ d dlmZ d d lmZ d d
lmZ d ZG d d
� d
ejj�Zej�de� ej�de� ej�de� ej�de� ejj� g d�� dS )� )�division)�input)�oct)�zipN)�hexlify)�progress)�config)�util)�BackendExceptionic c @ sJ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zddd�Z dd� Z
dS )�SSHParamikoBackenda� This backend accesses files using the sftp or scp protocols.
It does not need any local client programs, but an ssh server and the sftp
program must be installed on the remote side (or with scp, the programs
scp, ls, mkdir, rm and a POSIX-compliant shell).
Authentication keys are requested from an ssh agent if present, then
~/.ssh/id_rsa/dsa are tried. If -oIdentityFile=path is present in
--ssh-options, then that file is also tried. The passphrase for any of
these keys is taken from the URI or FTP_PASSWORD. If none of the above are
available, password authentication is attempted (using the URI or
FTP_PASSWORD).
Missing directories on the remote side will be created.
If scp is active then all operations on the remote side require passing
arguments through a shell, which introduces unavoidable quoting issues:
directory and file names that contain single quotes will not work.
This problem does not exist with sftp.
c s� t jj�| |� d| _|jrt�dd|jd�| _nd| _t �
� � t � d� zdd l a W n t
y4 � w W d � n1 s?w Y G � fdd �d t j�}G d
d � d t j�� t �� | _| j�|� � | j�d � t j�d �}t�tj�}|�t�d
�� |� |� t� d�� � }|dkr�tj }n|dkr�tj }n|dkr�tj!}n |dkr�tj"}ntj#}|�$|� d}t�%dt&j'tj(�}|d ur�|�)d�r�|�)d�n|�)d�}zt*j�+|�r�| j�,|� W n t-y� } zt.d|� d���d } ~ ww t*j�/d�}
t�%dt&j'tj(�}|d u�r|�)d��r|�)d�n|�)d�}
zt*j�+|
��r&| j�0|
� n|
| j_1W n t-�y@ } zt.d|
� d���d } ~ ww d|j2i| _&| j&�3| �4d|j2�� | j&�3| �4d|j2�� |j5�rk| j&�3d |j5i� d | j&v�r{| j&�3d t6�7� i� |j8�r�| j&�3d |j8i� d | j&v �r�| j&�3d t9| j&d �i� n| j&�3d d i� t�%d t&j'tj(�}|d u�r�|�)d��r�|�)d�n|�)d�} | �:d �| j&d!< d!| j&v �r�t;| j&d! t<��s�| j&d! g| j&d!< d"d#� | j&d! D �| j&d!< nd | j&d!< t&j=| _>| j&d |_5| j&d |_2| �?� } z| jj@| j&d | j&d | j&d | d$d$| j&d! d%� W n t-�yD } zt.d&| j&d | j&d | j&d | f ��d } ~ ww | j�A� �Bt9t&jCd' �� t j�D|jEd(�| _E| jEd)k| _F| jF�r~t�%d*| j��rqt.d+��| �Gd,| jf d-d.� d S z| j�H� | _IW n t-�y� } zt.d/| ��d } ~ ww | j�Jt*jK�}
tL|
�dk�r>|
d dk�r�d0|
d< |
D ]�}|dk�r��q�z| jI�M|�}W nP tN�y } zC| jOtOjPk�r�z| jI�Q|� W n- t-�y� } zt.d1| jI�Rd�d0 | | f ��d } ~ ww t.d2| jI�Rd�d0 | | f ��W Y d } ~ nd } ~ ww z | jI�S|� W �q� t-�y= } zt.d3| jI�Rd�d0 | | f ��d } ~ ww d S d S )4N�
z^/� � �.�ignorer c s e Zd ZdZ� fdd�ZdS )z4SSHParamikoBackend.__init__.<locals>.AgreedAddPolicyz�
Policy for showing a yes/no prompt and adding the hostname and new
host key to the known host file accordingly.
This class simply extends the AutoAddPolicy class with a yes/no
prompt.
c
s� t |�� �}d�dd� tt|d d d� |dd d� ��D ��}d||�� �� |f } tj� |� t
� � � }|dv rEt j
�| |||� d S |d v rM� |��d
}q+) N�:c s s � | ] \}}t || �V qd S )N)�str)�.0�a�b� r �I/usr/lib/python3/dist-packages/duplicity/backends/ssh_paramiko_backend.py� <genexpr>i s � zXSSHParamikoBackend.__init__.<locals>.AgreedAddPolicy.missing_host_key.<locals>.<genexpr>� r z�The authenticity of host '%s' can't be established.
%s key fingerprint is %s.
Are you sure you want to continue connecting (yes/no)? T)�yes�y)�no�nzPlease type 'yes' or 'no': )r �get_fingerprint�join�listr �get_name�upper�sys�stdout�writer �lower�paramiko�
AutoAddPolicy�missing_host_key)�self�client�hostname�key�fp� fingerprint�question�choice��AuthenticityExceptionr r r) g s( 2
��
��zESSHParamikoBackend.__init__.<locals>.AgreedAddPolicy.missing_host_keyN)�__name__�
__module__� __qualname__�__doc__r) r r2 r r �AgreedAddPolicy_ s r8 c @ s e Zd Zdd� ZdS )z:SSHParamikoBackend.__init__.<locals>.AuthenticityExceptionc S s t j�| d| � d S )Nz+Host key verification for server %s failed.)r' � SSHException�__init__)r* r, r r r r: | s
��zCSSHParamikoBackend.__init__.<locals>.AuthenticityException.__init__N)r4 r5 r6 r: r r r r r3 { s r3 �
sshbackendzssh: %(message)s� duplicity� � � z/etc/ssh/ssh_known_hostsa;
^(?:.+\s+)?
(?:-oGlobalKnownHostsFile=)
(
([\"'])
([^\\2]+)
\\2
|
[\S]+
)
� zcould not load z, maybe corrupt?z~/.ssh/known_hostsa9
^(?:.+\s+)?
(?:-oUserKnownHostsFile=)
(
([\"'])
([^\\2]+)
\\2
|
[\S]+
)
r, z/etc/ssh/ssh_configz
~/.ssh/config�user�port� a
^(?:.+\s+)?
(?:-oIdentityFile=|-i\s+)
(([\"'])
(
[^\\2]+)\\2
|
[\S]+
)
z'"� identityfilec S s g | ]}t j�|��qS r )�os�path�
expanduser)r �ir r r �
<listcomp> s �z/SSHParamikoBackend.__init__.<locals>.<listcomp>T)r, rB �username�password� allow_agent�
look_for_keys� key_filenamez%ssh connection to %s@%s:%d failed: %sr r' �scp�'z9cannot handle directory names with single quotes with scpz
mkdir -p '%s'Fz
scp mkdir zsftp negotiation failed: %s�/zsftp mkdir %s failed: %szsftp stat %s failed: %szsftp chdir to %s failed: %s)Tr< �backend�Backendr: � retry_delayrF �re�sub�
remote_dir�warnings�catch_warnings� simplefilterr' � ImportErrorr( r9 � SSHClientr+ �set_missing_host_key_policy�set_log_channelr �
get_logger�logging�
StreamHandlerr# �stderr� setFormatter� Formatter�
addHandler� getLogger�getEffectiveLevel�DEBUG�INFO�WARNING�ERROR�CRITICAL�setLevel�searchr � ssh_options�VERBOSE�grouprE �isfile�load_system_host_keys� Exceptionr
rG �load_host_keys�_host_keys_filenamer, �update�
gethostconfigrJ �getpass�getuserrB �int�strip�
isinstancer � ssh_askpass� use_getpass� get_password�connect�
get_transport�
set_keepalive�timeout� strip_prefix�scheme�use_scp� runremote� open_sftp�sftp�split�sep�len�stat�IOError�errno�ENOENT�mkdir� normalize�chdir)r* �
parsed_urlr8 �ours�dest�plevel�wanted�global_known_hosts�m�e�user_known_hosts� keyfilenamerK �dirs�d�attrsr r2 r r: G sH
�� �
� ��� �
��� � �
�
�
�
���
� ��
���� ���
����zSSHParamikoBackend.__init__c
C s� t �|�}| jr�t|jd�}z| j�� �� }|�t j
� |� d| j � W n t
y7 } ztd| ��d }~ww |�d�}|dkrJtd|�d� ��t�|j�}|�dt|j�d d � |j|f � |�d�}|dkrttd|�d� ��d
}|j} || k r�|�|�d �� |�� }t�|| � || k s}|�d� |�� |�d�}|dkr�td |�d� ��|�� d S | j j |j|tjd
� d S )N�rbz scp -t '%s'�scp execution failed: %sr � s scp remote error: %b���z
C%s %d %s
���r i @ zscp remote error: %s)�callback) r �fsdecoder� �open�namer+ r� � open_session�
settimeoutr r� � exec_commandrW rt r
�recvrE r� �sendr �st_mode�st_size�sendall�read�tellr �report_transfer�closer� �put)
r* � source_path�remote_filename�f�chanr� �response�fstat�file_pos� file_sizer r r �_putK sF
��
�
�
zSSHParamikoBackend._putc
C s� t �|�}| jr�z| j�� �� }|�tj� |� d| j
|f � W n t y3 } zt d| ��d }~ww |�
d� |�d�}t|t�rG|�� }t�d|�}|d u sX|�d�|kr`t d||f ��|�d� t|�d ��}|}t|jd
�} |�
d� z#|d kr�|tkr�t}
n|}
|�|
�} | �| � |t| �8 }|d ks~W n t y� } zt d ||f ��d }~ww |�d�}|d
kr�t d ||�d�f ��| �� |�
d� |�� d S | j � ||j� d S )Nzscp -f '%s/%s'r� � r� z C([0-7]{4})\s+(\d+)\s+(\S.*)$r@ z*scp get %s failed: incorrect response '%s'r r �wbr zscp get %s failed: %sr� ) r r� r� r+ r� r� r� r r� r� rW rt r
r� r� r} �bytes�decoderU �matchrq r{ r� r� �read_blocksizer% r� r� r� �get) r* r� �
local_pathr� r� �msgr� �size�togor� � blocksize�buffr r r �_getr sb
� ��
�
����
�
zSSHParamikoBackend._getc C s, | j r| �d| j dd�}|�� S | j�� S )Nz
ls -1 '%s'Fzscp dir listing )r� r� rW �
splitlinesr� �listdir)r* �outputr r r �_list� s �
zSSHParamikoBackend._listc C s< t �|�}| jr| �d| j|f dd� d S | j�|� d S )Nz
rm '%s/%s'Fzscp rm )r r� r� r� rW r� �remove)r* �filenamer r r �_delete� s
�zSSHParamikoBackend._deleteFr
c
C sl z| j �|dtj�\}}}|�d�}|W S ty5 } z|s*td||t�|�f ��W Y d}~dS d}~ww )z�small convenience function that opens a shell channel, runs remote
command and returns stdout of command. throws an exception if exit
code!=0 and not ignoredr� z%sfailed: %s
%sN) r+ r� r r� r� rt r
r �uexc) r* �cmd�ignoreexitcode� errorprefix�ch_in�ch_out�ch_errr� r� r r r r� � s
����z SSHParamikoBackend.runremotec
C sf t j�|�}t j�|�si S t�� }z |�t|�� W n ty- } zt d| ��d }~ww |�
|�S )Nz#could not load '%s', maybe corrupt?) rE rF rG rr r' � SSHConfig�parser� rt r
�lookup)r* �file�host� sshconfigr� r r r rx � s ��
z SSHParamikoBackend.gethostconfigN)Fr
) r4 r5 r6 r7 r: r� r� r� r� r� rx r r r r r 3 s '0
r r� rO �
paramiko+sftp� paramiko+scp)r� rO r� r� ) �
__future__r �builtinsr r r r� ry r` rE rU r# rX �binasciir �duplicity.backendr< r r r �duplicity.errorsr
r� rR rS r �register_backend� uses_netloc�extendr r r r �<module> s6 "