File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/__pycache__/ssh.cpython-310.pyc
Back
o ;j=v � @ sZ d Z ddlZddlZddlZddlZddlZddlZddlmZm Z m Z m Z m Z m Z ddlmZ ddlmZ ddlmZmZ ddlmZ dZzddlZd Zed d � ej�d �D ��Z W n e yf d Z Y nw g d�Z dZ ej �!dd��"� dv Z#d�$� Z%G dd� de&�Z'G dd� d�Z(G dd� de(�Z)G dd� de(�Z*G d d � d e(�Z+e)Z,es�e+Z,dS dS ) z. Wraps multiple ways to communicate over SSH. � N)�List�Type�Tuple�Union�Optional�cast)�join)�split)�StringIO�b)�ExtraLogFormatterFTc c � � | ]}t |�V qd S �N��int)�.0�x� r �H/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/ssh.py� <genexpr>( � � r �.r )� BaseSSHClient�ParamikoSSHClient�ShellOutSSHClient�SSHCommandTimeoutErrorzahttps://libcloud.readthedocs.io/en/latest/compute/deployment.html#supported-private-ssh-key-types�-LIBCLOUD_PARAMIKO_SHA2_BACKWARD_COMPATIBILITY�true)r �1a$ Received authentication error from the server. Disabling SHA-2 variants of RSA key verification algorithm for backward compatibility reasons and trying connecting again. You can disable this behavior by setting LIBCLOUD_PARAMIKO_SHA2_BACKWARD_COMPATIBILITY environment variable to "false". c s2 e Zd ZdZd � fdd� Zdd� Zdd� Z� ZS ) r zB Exception which is raised when an SSH command times out. Nc s4 || _ || _|| _|| _d| | _t� �| j� d S )Nz#Command didn't finish in %s seconds)�cmd�timeout�stdout�stderr�message�super�__init__)�selfr r r! r" �� __class__r r r% W s z SSHCommandTimeoutError.__init__c C s d� | j| j�S )Nz.<SSHCommandTimeoutError: cmd="{}",timeout={})>)�formatr r �r& r r r �__repr__a s �z SSHCommandTimeoutError.__repr__c C s | � � S r )r+ r* r r r �__str__g s z SSHCommandTimeoutError.__str__�NN)�__name__� __module__� __qualname__�__doc__r% r+ r, � __classcell__r r r' r r R s r c @ sd e Zd ZdZ ddd�Zdd� Zdd d �Zdd d �Zdd� Zddd�Z dd� Z dd� Z dS )r zM Base class representing a connection over SSH/SCP to a remote node. � �rootNc C sL |durd}t �|t� |s|n|}|| _|| _|| _|| _|| _|| _dS )a� :type hostname: ``str`` :keyword hostname: Hostname or IP address to connect to. :type port: ``int`` :keyword port: TCP port to communicate on, defaults to 22. :type username: ``str`` :keyword username: Username to use, defaults to root. :type password: ``str`` :keyword password: Password to authenticate with or a password used to unlock a private key if a password protected key is used. :param key: Deprecated in favor of ``key_files`` argument. :type key_files: ``str`` or ``list`` :keyword key_files: A list of paths to the private key files to use. NzYYou are using deprecated "key" argument which has been replaced with "key_files" argument) �warnings�warn�DeprecationWarning�hostname�port�username�password� key_filesr ) r& r8 r9 r: r; �keyr< r r# r r r r% p s � zBaseSSHClient.__init__c C � t d��)z� Connect to the remote node over SSH. :return: True if the connection has been successfully established, False otherwise. :rtype: ``bool`` z+connect not implemented for this ssh client��NotImplementedErrorr* r r r �connect� � zBaseSSHClient.connect�wc C r> )a� Upload a file to the remote node. :type path: ``str`` :keyword path: File path on the remote node. :type contents: ``str`` :keyword contents: File Contents. :type chmod: ``int`` :keyword chmod: chmod file to this after creation. :type mode: ``str`` :keyword mode: Mode in which the file is opened. :return: Full path to the location where a file has been saved. :rtype: ``str`` z'put not implemented for this ssh clientr? )r& �path�contents�chmod�moder r r �put� s zBaseSSHClient.putc C r> )a� Upload file like object to the remote server. :param path: Path to upload the file to. :type path: ``str`` :param fo: File like object to read the content from. :type fo: File handle or file like object. :type chmod: ``int`` :keyword chmod: chmod file to this after creation. :return: Full path to the location where a file has been saved. :rtype: ``str`` z)putfo not implemented for this ssh clientr? )r& rD �forF r r r �putfo� s zBaseSSHClient.putfoc C r> )a Delete/Unlink a file on the remote node. :type path: ``str`` :keyword path: File path on the remote node. :return: True if the file has been successfully deleted, False otherwise. :rtype: ``bool`` z*delete not implemented for this ssh clientr? )r& rD r r r �delete� s zBaseSSHClient.deletec C r> )z� Run a command on a remote node. :type cmd: ``str`` :keyword cmd: Command to run. :return ``list`` of [stdout, stderr, exit_status] z'run not implemented for this ssh clientr? �r& r r r r r �run� s zBaseSSHClient.runc C r> )z� Shutdown connection to the remote node. :return: True if the connection has been successfully closed, False otherwise. :rtype: ``bool`` z)close not implemented for this ssh clientr? r* r r r �close� rB zBaseSSHClient.closec C sH t �d�}t�d�}|r"t �|�}|�t� � |�|� |�t j � |S )Nzlibcloud.compute.sshZLIBCLOUD_DEBUG) �logging� getLogger�os�getenv� FileHandler� setFormatterr � addHandler�setLevel�DEBUG)r& �loggerrD �handlerr r r �_get_and_setup_logger� s z#BaseSSHClient._get_and_setup_logger�r3 r4 NNNN�NNrC r- r ) r. r/ r0 r1 r% rA rH rJ rK rM rN rZ r r r r r k s �/ r c s� e Zd ZdZdZdZ d'� fdd � Zd d � Zd(d d�Zd)dd�Z dd� Z d*dd�Z dd� Z dd� Z dd� Zdd � Zd*d d �Zd d � Zd!d"� Zd#d$� Zd%d&� Z� ZS )+r z+ A SSH Client powered by Paramiko. i g�������?r3 r4 NFc sj |r|rt d��t� j|||||||d� || _| | _| | _t�� | _| j� t� � � | � � | _ d| _ dS )a� Authentication is always attempted in the following order: - The key passed in (if key is provided) - Any key we can find through an SSH agent (only if no password and key is provided) - Any "id_rsa" or "id_dsa" key discoverable in ~/.ssh/ (only if no password and key is provided) - Plain username/password auth, if a password was given (if password is provided) :param keep_alive: Optional keep alive internal (in seconds) to use. :type keep_alive: ``int`` :param use_compression: True to use compression. :type use_compression: ``bool`` z;key_files and key_material arguments are mutually exclusive�r8 r9 r: r; r= r< r N)� ValueErrorr$ r% � key_material� keep_alive�use_compression�paramiko� SSHClient�clientZset_missing_host_key_policyZ AutoAddPolicyrZ rX � sftp_client) r& r8 r9 r: r; r= r< r_ r r` ra r' r r r% s$ � zParamikoSSHClient.__init__c C s | j | j| jddd�}| jr| j|d< | jr| j|d< | jr)| j| j| jd�|d< | js:| js:| js:d|d< d|d < | jrB| j|d < | jr�t| jt t f�s�t j � | j�r�t| j�� }|�� }W d � n1 shw Y z | j|| jd�}W n tjjy� } z|�d }~w ty� Y nw |d= ||d< | j | j| j| jd �}| jr�d|d < n d |d < | jr�| j|d< | jjd|d� z | jjdi |�� W dS tjjy� } z'tdkr�tr�| j�t � dddgi|d< | jjdi |�� n|�W Y d }~dS d }~ww )NF)r8 r9 r: � allow_agent� look_for_keysr; Z key_filename)r= r; �pkeyTrf rg r )Z _hostnameZ_portZ _username�_timeoutZ _auth_method�key_fileZ _key_filezConnecting to server��extra)� � r Zpubkeysz rsa-sha2-256z rsa-sha2-512Zdisabled_algorithmsr ) r8 r9 r: r; r< r_ �_get_pkey_objectr � isinstance�list�tuplerQ rD �isfile�open�readrb � ssh_exception�PasswordRequiredException� ExceptionrX �debugrd rA ZAuthenticationException�PARAMIKO_VERSION_TUPLEr r6 �(SHA2_PUBKEY_NOT_SUPPORTED_AUTH_ERROR_MSG)r& Zconninfo�fpr_ rh �erl r r r rA J s| � �� � �� �� � � ���zParamikoSSHClient.connectrC c C s� |||d�}| j jd|d� | �� }t|�\}}|d dkr$|�d� n|�d� |�d�D ] } | dkrJz|�| � W n tyD Y nw |�| � q.|�� } | j | d�} |j ||d �} | � |� |d urj| � |� | � � | j| |d �} | S ) N)�_path�_mode�_chmod�Uploading filerk r �/r � ��cwd)rG �r� � file_path)rX ry �_get_sftp_client�psplit�chdirr �mkdir�OSError�getcwd� _sanitize_cwd�file�writerF rN �_sanitize_file_path) r& rD rE rF rG rl �sftp�head�tail�partr� �akr� r r r rH � s2 � � zParamikoSSHClient.putc C s� ||d�}| j jd|d� | �� }t|�\}}|d dkr#|�d� n|�d� |�d�D ] }|dkrIz|�|� W n tyC Y nw |�|� q-|�� } | j | d�} |� ||� |d url|� |�} | � |� | � � | j| |d �} | S ) z� Upload file like object to the remote server. Unlike put(), this method operates on file objects and not directly on file content which makes it much more efficient for large files since it utilizes pipelining. )r~ r� r� rk r r� r r� r� Nr� )rX ry r� r� r� r r� r� r� r� rJ r� rF rN r� ) r& rD rI rF rl r� r� r� r� r� r� r� r r r rJ � s2 � � zParamikoSSHClient.putfoc C s8 d|i}| j jd|d� | j�� }|�|� |�� dS )Nr~ z Deleting filerk T)rX ry rd � open_sftp�unlinkrN )r& rD rl r� r r r rK � s zParamikoSSHClient.deletec C sb d|i}| j jd|d� d}| �� }|�� }t�� }|�|� t� }t� } |�d|�} | �� |� � } | rI|� | � |�� � � | � | � |�� � � | s�t�� } | | } |rm| |krm|�� |� � }| � � }t||||d��|� | � |�� � � | � | � |�� � � |� � } | r�nt�| j� | rK|�� }|� � }| � � }|||d�}| j jd|d� |||f}|S ) z� Note: This function is based on paramiko's exec_command() method. :param timeout: How long to wait (in seconds) for the command to finish (optional). :type timeout: ``float`` Z_cmdzExecuting commandrk ����wb)r r r! r" )Z_statusZ_stdout�_stderrzCommand finished)rX ry �_get_transportZ open_session�timeZ exec_commandr �makefilerN �exit_status_readyr� �_consume_stdout�getvalue�_consume_stderrr �sleep� SLEEP_DELAYZrecv_exit_status)r& r r Zextra1�bufsize� transport�chanZ start_timer! r" �stdinr� Z current_timeZ elapsed_time� stdout_str� stderr_str�statusZextra2�resultr r r rM � sN � � zParamikoSSHClient.runc C s0 | j �d� | jr| j�� | jr| j�� dS )NzClosing server connectionT)rX ry rd rN re r* r r r rN S s zParamikoSSHClient.closec C � | j ||j|jd�}|S )zM Try to consume stdout data from chan if it's receive ready. �r� � recv_method�recv_ready_method)�_consume_data_from_channel�recvZ recv_ready)r& r� r! r r r r� ^ s �z!ParamikoSSHClient._consume_stdoutc C r� )zM Try to consume stderr data from chan if it's receive ready. r� )r� Z recv_stderrZrecv_stderr_ready)r& r� r" r r r r� g s �z!ParamikoSSHClient._consume_stderrc C sj t � }t� }|� r)|| j�}|t|�7 }|r)|� }|s n || j�}|t|�7 }|s|�|jddd�� |S )z� Try to consume data from the provided channel. Keep in mind that data is only consumed if the channel is receive ready. zutf-8�ignore)�errors)r � bytearray� CHUNK_SIZEr r� �decode)r& r� r� r� r� Z result_bytes�data�readyr r r r� r s � z,ParamikoSSHClient._consume_data_from_channelc C sT t jdft jdft jdfg}tt dd�}tdd� |�d�D ��}|d kr-|�t jj d f� |D ]p\}}|� � � � }|d d krW|d dkrWd| |d < d| |d < d� |�}n|}z |� t|�|�}W | S t jjyv } z| �d} ~ w t jjtfy� } zdt| ��� v r�dt| � } t j�| ��W Y d} ~ q/d} ~ ww dt } t j�| ��)z� Try to detect private key type and return paramiko.PKey object. # NOTE: Paramiko only supports key in PKCS#1 PEM format. ZRSAZDSAZEC� __version__z0.0.0c s r r r )r �cr r r r � r z5ParamikoSSHClient._get_pkey_object.<locals>.<genexpr>r )rm rm r ZEd25519r z-----BEGIN PRIVATE KEY-----r� z-----END PRIVATE KEY-----z -----BEGIN %s PRIVATE KEY-----z -----END %s PRIVATE KEY-----� Nz'private key file checkints do not matchz?Invalid password provided for encrypted key. Original error: %sz�Invalid or unsupported key type (only RSA, DSS, ECDSA and Ed25519 keys in PEM format are supported). For more information on supported key file types, see %s)rb ZRSAKeyZDSSKeyZECDSAKey�getattrrr r �appendZ ed25519keyZ Ed25519Key�strip� splitlinesr Zfrom_private_keyr rv rw Z SSHException�AssertionError�str�lower�SUPPORTED_KEY_TYPES_URL) r& r= r; Z key_typesZparamiko_version�clsZkey_typeZ key_split� key_valuer} �msgr r r ro � sH � ��� ���� z"ParamikoSSHClient._get_pkey_objectc C s$ t �dt|��rt|dd � �}|S )Nz ^\/\w\:.*$� )�re�matchr� )r& r� r r r r� � s z ParamikoSSHClient._sanitize_cwdc C sH |d dv s t �d|�r |S t �d|�r |d | }|S t||�}|S )z� Sanitize the provided file path and ensure we always return an absolute path, even if relative path is passed to to this function. r )r� �\z^\w\:.*$r� )r� r� �pjoin)r& r� r� r r r r� � s � �z%ParamikoSSHClient._sanitize_file_pathc C s2 | j �� }| jr|�| j� | jr|jdd� |S )z� Return transport object taking into account keep alive and compression options passed to the constructor. T)�compress)rd Z get_transportr` Z set_keepalivera )r& r� r r r r� � s z ParamikoSSHClient._get_transportc C s� | j s | j�� | _ | j }z |�d� W | j S tyK } z*dt|��� v r,| j�� | _ n dt|��� v r5n |�W Y d}~| j S W Y d}~| j S d}~ww )a Create SFTP client from the underlying SSH client. This method tries to reuse the existing self.sftp_client (if it exists) and it also tries to verify the connection is opened and if it's not, it will try to re-establish it. r zsocket is closedz no such fileN)re rd r� �listdirr� r� r� )r& re r} r r r r� � s$ � � ���z"ParamikoSSHClient._get_sftp_client) r3 r4 NNNNNNFr\ r- r )r. r/ r0 r1 r� r� r% rA rH rJ rK rM rN r� r� r� ro r� r� r� r� r2 r r r' r r s8 �9 Y %, V > r c st e Zd ZdZ d� fdd� Zdd� Zdd d �Zdd d �Zddd�Zdd� Z dd� Z dd� Z dd� Z � Z S ) r z� This client shells out to "ssh" binary to run commands on the remote server. Note: This client should not be used in production. r3 r4 Nc sf t � j|||||||d� | jrtd��tjdgtjtjd�}|�� |jdkr,td��| � � | _ d S )Nr] z(ShellOutSSHClient only supports key auth�ssh�r! r" � zssh client is not available) r$ r% r; r^ � subprocess�Popen�PIPE� communicate� returncoderZ rX ) r& r8 r9 r: r; r= r< r �childr' r r r% # s � zShellOutSSHClient.__init__c C � dS )z� This client doesn't support persistent connections establish a new connection every time "run" method is called. Tr r* r r r rA A s zShellOutSSHClient.connectc C s | � |g�S r ��_run_remote_shell_commandrL r r r rM H s zShellOutSSHClient.runrC c C sF |dkrd}n |dkrd}nt d| ��d�|||�g}| �|� |S )NrC �>�az>>zInvalid mode: zecho "{}" {} {})r^ r) r� )r& rD rE rF rG Zredirectr r r r rH K s zShellOutSSHClient.putc C s |� � }| j|||d�S )N)rD rE rF )ru rH )r& rD rI rF �contentr r r rJ W s zShellOutSSHClient.putfoc C s dd|g}| � |� dS )NZrmz-rfTr� )r& rD r r r r rK [ s zShellOutSSHClient.deletec C r� )NTr r* r r r rN ` s zShellOutSSHClient.closec C sX dg}| j rtt| j �| _ |d| j g7 }| jr |d| j g7 }|d�| j| j�g7 }|S )Nr� z-iz-oConnectTimeout=%sz{}@{})r< r r� r r) r: r8 )r& r r r r �_get_base_ssh_commandc s z'ShellOutSSHClient._get_base_ssh_commandc C sn | � � }|d�|�g }| j�dd�|� � tj|tjtjd�}|�� \}}tt |�}tt |�}|||j fS )z� Run a command on a remote server. :param cmd: Command to run. :type cmd: ``list`` of ``str`` :return: Command stdout, stderr and status code. :rtype: ``tuple`` � zExecuting command: "%s"r� ) r� r rX ry r� r� r� r� r r� r� ) r& r Zbase_cmdZfull_cmdr� r! r" r� r� r r r r� r s z+ShellOutSSHClient._run_remote_shell_commandr[ r r\ r- )r. r/ r0 r1 r% rA rM rH rJ rK rN r� r� r2 r r r' r r s" � r c @ s e Zd ZdS )� MockSSHClientN)r. r/ r0 r r r r r� � s r� )-r1 rQ r� r� rO r5 r� �typingr r r r r r Zos.pathr r� r r� Zlibcloud.utils.py3r r Zlibcloud.utils.loggingr Z have_paramikorb rr r� rz � ImportError�__all__r� �environ�getr� r r� r{ rx r r r r r� rc r r r r �<module> sX � ��� p�
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings