Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/__pycache__/scp.cpython-39.pyc
Ðазад
a t�hyW � @ sb d Z dZddlZddlZddlZddlmZ dZe e fZ z ddl Z W n e yZ dZ Y n0 e e jf7 Z ze ef7 Z W n ey� Y n0 zTddlmZmZmZmZmZmZmZmZ er�ddlZddl Z e jZee e ef Z W n e y� Y n0 e� d�j Z dd � Z d d � Z!d d � Z"e!ej#j$�Z%dd� Z&G dd� de'�Z(G dd� de)�Z*ddd�Z+d dd�Z,dS ) z? Utilities for sending files over ssh using the scp1 protocol. z0.15.0� N)�timeouts scp)�IO� TYPE_CHECKING�AnyStr�Callable�Iterable�Optional�Tuple�Unions [^\w@%+=:,./~-]c C s, | sdS t | �du r| S d| �dd� d S )z1Return a shell-escaped version of the string `s`.� N� 's '"'"')� _find_unsafe�replace��s� r �s/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/scp.py� _sh_quote1 s r c C s4 t | t�r| S tr&t | tj�r&t| �S | �d�S dS )z=Turns unicode into bytes, if needed. Assumes UTF-8. �utf-8N)� isinstance�bytes�pathlib�PurePath�encoder r r r �asbytes? s r c C s t | t�r| �dd�S | S dS )z:Turns bytes into unicode, if needed. Uses UTF-8. r r N)r r �decoder r r r � asunicodeL s r c C s t | t�r| �t�� �S | S dS )z)Turns bytes into unicode, if needed. N)r r r �locale�getpreferredencodingr r r r � asunicode_win^ s r c @ s� e Zd ZdZddddedfdd�Zdd� Zd d � Zd7d d�Zd8dd�Z d9dd�Z dd� Z dd� Z dd� Z dd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Zd1d2� Zd3d4� Zd5d6� ZdS ):� SCPClienta� An scp1 implementation, compatible with openssh scp. Raises SCPException for all transport related errors. Local filesystem and OS errors pass through. Main public methods are .put and .get The get method is controlled by the remote scp instance, and behaves accordingly. This means that symlinks are resolved, and the transfer is halted after too many levels of symlinks are detected. The put method uses os.walk for recursion, and sends files accordingly. Since scp doesn't support symlinks, we send file symlinks as the file (matching scp behaviour), but we make no attempt at symlinked directories. i @ g $@Nc s� || _ || _|| _d| _d| _� dur8|dur8td��n.|durH|| _n � dur`� fdd�| _nd| _d| _d| _d| _ d| _ |du r�dd� | _ n|| _ i | _ | j � � | _t| _|r�| jd | 7 _dS ) a� Create an scp1 client. @param transport: an existing paramiko L{Transport} @type transport: L{Transport} @param buff_size: size of the scp send buffer. @type buff_size: int @param socket_timeout: channel socket timeout in seconds @type socket_timeout: float @param progress: callback - called with (filename, size, sent) during transfers @param progress4: callback - called with (filename, size, sent, peername) during transfers. peername is a tuple contains (IP, PORT) @param sanitize: function - called with filename, should return safe or escaped string. Uses _sh_quote by default. Set to ``False`` to disable. @type progress: function(string, int, int, tuple) @limit_bw: limits the bandwidth used on the connection in Kbps. Must be integer positive. the default value None does not limit the bandwidth. @type limit_bw: Optional[int] NFz+You may only set one of progress, progress4c s � | d d� � S )N� r )�a��progressr r �<lambda>� r z$SCPClient.__init__.<locals>.<lambda>r r c S s | S �Nr )�xr r r r% � r s -l %d)� transport� buff_size�socket_timeout�channel�preserve_times� TypeError� _progress� _recv_dir�_depth�_rename�_utime�sanitize� _dirtimes� getpeername�peername� SCP_COMMAND� scp_command)�selfr( r) r* r$ Z progress4r3 Zlimit_bwr r# r �__init__u s0 zSCPClient.__init__c C s | � � | _| S r& )�_openr+ �r9 r r r � __enter__� s zSCPClient.__enter__c C s | � � d S r& )�close)r9 �type�value� tracebackr r r �__exit__� s zSCPClient.__exit__� .Fc C s� || _ | �� | _d| _| j�| j� | jd d| }| j�|| �t |�� � | � � t |t �rj|g}nt |�}|r�| �|� n | �|� | �� dS )au Transfer files and directories to remote host. @param files: A single path, or a list of paths to be transferred. recursive must be True to transfer directories. @type files: string OR list of strings @param remote_path: path in which to receive the files on the remote host. defaults to '.' @type remote_path: str @param recursive: transfer files and directories recursively @type recursive: bool @param preserve_times: preserve mtime and atime of transferred files and directories. @type preserve_times: bool r � )s -t s -r -t N)r, r; r+ �_pushed� settimeoutr* r8 � exec_commandr3 r � _recv_confirmr � PATH_TYPES�list�_send_recursive� _send_filesr> )r9 �files� remote_path� recursiver, r8 r r r �put� s � z SCPClient.put�0644c C s� |du r8|� � }|�dtj� |� � | }|�|tj� | �� | _| j�| j� | j� | j d | � t |�� � | � � | j||||d� | �� dS )a� Transfer file-like object to remote host. @param fl: opened file or file-like object to copy @type fl: file-like object @param remote_path: full destination path @type remote_path: str @param mode: permissions (posix-style) for the uploaded file @type mode: str @param size: size of the file in bytes. If ``None``, the size will be computed using `seek()` and `tell()`. Nr s -t )�size)�tell�seek�os�SEEK_END�SEEK_SETr; r+ rF r* rG r8 r3 r rH � _send_filer> )r9 �flrN �moderR �posr r r �putfo� s �zSCPClient.putfo� c s t |t�r|g}nt|�}� fdd�|D �}|p6t�� � _d� _t|�dko`tj� tj� |�� � _ t|�dkr�tj� � j�s�t dt� j� ��n tj� � j�s�t dt� j� ��d| }d| }� �� � _d� _� j�� j� � j�� j| | d d �|� � � �� � �� d S ) af Transfer files and directories from remote host to localhost. @param remote_path: path to retrieve from remote host. Note that wildcards will be escaped unless you changed the `sanitize` function. @type remote_path: str @param local_path: path in which to receive files locally @type local_path: str @param recursive: transfer files and directories recursively @type recursive: bool @param preserve_times: preserve mtime and atime of transferred files and directories. @type preserve_times: bool c s g | ]}� � t|���qS r )r3 r )�.0�rr< r r � <listcomp> r z!SCPClient.get.<locals>.<listcomp>r � z Local path '%s' does not existz"Local path '%s' is not a directory)r s -r)r s -ps -f rD N)r rI rJ rU �getcwdr/ r0 �len�path�isdir�abspathr1 �exists� SCPExceptionr r; r+ rE rF r* rG r8 �join� _recv_allr> )r9 rN � local_pathrO r, ZrcsvZprsvr r< r �get� sD � �� ����z SCPClient.getc C s$ | j du s| j jr | j�� | _ | j S )zopen a scp channelN)r+ �closedr( Z open_sessionr< r r r r; ! s zSCPClient._openc C s | j dur| j �� d| _ dS )zclose scp channelN)r+ r> r< r r r r> ( s zSCPClient.closec C sT t jdkrt|�}t �|�}t|j�dd� }|j}t|j�}t|j �}||||fS )z)return just the file stats needed for scp�nt���N) rU �namer �stat�oct�st_mode�st_size�int�st_atime�st_mtime)r9 rp �statsrZ rR �atime�mtimer r r � _read_stats. s zSCPClient._read_statsc C sd |D ]Z}| � |�\}}}}| jr,| �||� t|d�}z | �||||� W |�� q|�� 0 qd S )N�rb)r{ r, � _send_time�openrX r> )r9 rM rp rZ rR rz ry rY r r r rL 9 s zSCPClient._send_filesc C s� t tj�|��}| j�d||f �d�|�dd� d � | �� d}| j rz|dkrh| � |dd| j � n| � ||d| j � | j }| j}||k r�|�|� |�� |� � }| j r�| � |||| j � q�|�d� | �� d S )NzC%s %d �ascii� � \^Jr ra � )r rU rd �basenamer+ �sendallr r rH r. r6 r) �readrS ) r9 rY rp rZ rR r� Zfile_posr) �chanr r r rX D s* �� zSCPClient._send_filec C s^ t j�|t |t g�}t j�|�}|�t�}||krPt j�|�d }| �� q.| �|� d S )Nr ) rU rd � commonprefix� bytes_sep�dirname�rstrip�split� _send_popd� _send_pushd)r9 Zfrom_dirZto_dir�commonZcur_dirr r r �_chdir] s � zSCPClient._chdirc s� |D ]�}t |�}tj�|�s*| �|g� qt |�}t�|�D ]H\� }}t � ��d�sd| �|t � �� | �� fdd�|D �� t � �}q<| jdkr| � � q�qd S )N� /c s g | ]}t j�� |��qS r )rU rd ri )r^ �f��rootr r r` { r z-SCPClient._send_recursive.<locals>.<listcomp>r ) r rU rd re rL �walk�endswithr� rE r� )r9 rM �baseZlast_dir�dirsZflsr r� r rK p s zSCPClient._send_recursivec C st | � |�\}}}}ttj�|��}| jr4| �||� | j�d| � d�|� dd� d � | � � | j d7 _ d S )NzD%s 0 r r� r� ra ) r{ r rU rd r� r, r} r+ r� r r rH rE )r9 � directoryrZ rR rz ry r� r r r r� � s ��zSCPClient._send_pushdc C s& | j �d� | �� | jd8 _d S )NzE ra )r+ r� rH rE r< r r r r� � s zSCPClient._send_popdc C s& | j �d||f �d�� | �� d S )Nz T%d 0 %d 0 r )r+ r� r rH )r9 rz ry r r r r} � s zSCPClient._send_timec C s� d}z| j �d�}W n ty. td��Y n0 |rH|dd� dkrHd S |rr|dd� dkrrtt|dd � ���n<| j �� r�| j �d�}tt|���n|s�td��n td |��d S ) Nr � z Timeout waiting for scp responser ra � � zNo response from serverz Invalid response from server)r+ �recv� SocketTimeoutrh r Zrecv_stderr_readyZ recv_stderr)r9 �msgr r r rH � s zSCPClient._recv_confirmc C s� | j | j| j| jd�}| jjs�| j�d� | j�d�}|s<q�|dd � dksPJ �|d d� }|dd� }||vr�tt |dd � ���|| |dd � � q| � � d S )N)� C� T� D� Er� i ���r� r ra ) � _recv_file� _set_time� _recv_pushd� _recv_popdr+ rm r� r� rh r � _set_dirtimes)r9 �commandr� �coder r r rj � s" � zSCPClient._recv_allc C sZ z*|� d�}t|d �}t|d �p&|}W n | j�d� td��Y n0 ||f| _d S )NrD r � r� zBad time format)r� ru r+ �sendrh r2 )r9 �cmd�timesrz ry r r r r� � s zSCPClient._set_timec C s� | j }|�� �dd�}z�t|d d�}t|d �}| jrF| j}d| _njtjdkr�|d �d�}tj � |�rnJ �tj � t | j�|�}n,|d }tj � |�r�J �tj � t | j�|�}W n& |�d � |�� td ��Y n0 zt|d �}W nH t�y0 } z.|�d t| ��d� � |�� � W Y d } ~ n d } ~ 0 0 | j�rj|dk�rX| �|dd| j� n| �||d| j� | j} d} |�d � z�z�| |k �r�|| | k�r�|| } |�| �} | �s�td��|�| � |�� } | j�r�| �||| | j� �q�|�d�} | �r | dd� d k�r tt| dd � ���|� � t� || j � d | _ t� ||� W n$ t �yn |�� td��Y n0 W |�� n |�� 0 d S )NrD r� r � ra Frn r �zBad file format�wbr� r� z Underlying channel was closedr� z Error receiving, socket.timeout)!r+ �stripr� ru r1 r/ rU rp r rd �isabsri r r r� r> rh r~ �IOError�strr r. r6 r) r� �writerS r �truncate�utimer2 �chmodr� )r9 r� r� �partsrZ rR rd rp Zfile_hdl�er) r[ �datar� r r r r� � sl zSCPClient._recv_filec C s� |� dd�}z�t|d d�}| jr0| j}d| _n�tjdkr||d �d�}tj�|�rXJ �tj� t | j�|�}| j d7 _ n:|d }tj�|�r�J �tj� t | j�|�}| j d7 _ W n | j �d � td ��Y n0 z^tj�|�s�t�||� n(tj�|��rt�||� n td | ��| j| j|< d | _|| _W nD ttf�y| } z&| j �d t t|�� � � W Y d }~n d }~0 0 d S ) NrD r� r r� Frn r ra r� zBad directory formatz%s: Not a directory)r� ru r1 r/ rU rp r rd r� ri r r0 r r+ r� rh rg �mkdirre r� r2 r4 �OSErrorr� )r9 r� r� rZ rd rp r� r r r r� s< zSCPClient._recv_pushdc G s0 | j dkr,| j d8 _ tj�| j�d | _d S )Nr ra )r0 rU rd r� r/ )r9 r� r r r r� - s zSCPClient._recv_popdc C s6 z(| j D ]}t�|| j | � qW i | _ ni | _ 0 d S r& )r4 rU r� )r9 �dr r r r� 2 s zSCPClient._set_dirtimes)rC FF)rQ N)r] FF) �__name__� __module__� __qualname__�__doc__r r: r= rB rP r\ rl r; r> r{ rL rX r� rK r� r� r} rH rj r� r� r� r� r� r r r r r g s< � 3 � ' � / C"r c @ s e Zd ZdZdS )rh zSCP exception classN)r� r� r� r� r r r r rh : s rh rC Fc C s< t | �� }|�||||� W d � n1 s.0 Y dS )a� Transfer files and directories to remote host. This is a convenience function that creates a SCPClient from the given transport and closes it at the end, useful for one-off transfers. @param files: A single path, or a list of paths to be transferred. recursive must be True to transfer directories. @type files: string OR list of strings @param remote_path: path in which to receive the files on the remote host. defaults to '.' @type remote_path: str @param recursive: transfer files and directories recursively @type recursive: bool @param preserve_times: preserve mtime and atime of transferred files and directories. @type preserve_times: bool N)r rP )r( rM rN rO r, �clientr r r rP ? s rP r] c C s< t | �� }|�||||� W d � n1 s.0 Y dS )a Transfer files and directories from remote host to localhost. This is a convenience function that creates a SCPClient from the given transport and closes it at the end, useful for one-off transfers. @param transport: an paramiko L{Transport} @type transport: L{Transport} @param remote_path: path to retrieve from remote host. Note that wildcards will be escaped unless you changed the `sanitize` function. @type remote_path: str @param local_path: path in which to receive files locally @type local_path: str @param recursive: transfer files and directories recursively @type recursive: bool @param preserve_times: preserve mtime and atime of transferred files and directories. @type preserve_times: bool N)r rl )r( rN rk rO r, r� r r r rl X s rl )rC FF)r] FF)-r� � __version__r rU �re�socketr r� r7 r� r rI r � ImportErrorr �unicode� NameError�typingr r r r r r r r Zparamiko.transportZparamikoZ PathTypes�compile�searchr r r r rd �sepr� r �objectr � Exceptionrh rP rl r r r r �<module> sT ( V � �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка