File: //usr/lib/python3/dist-packages/twisted/conch/client/__pycache__/direct.cpython-310.pyc
o
�b� � @ s\ d dl mZ d dlmZ d dlmZmZmZ G dd� dej�Z G dd� dej
�Z
dd � Z d
S ) � )�error)� transport)�defer�protocol�reactorc @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�SSHClientFactoryc C s || _ || _|| _|| _d S �N)�d�options�
verifyHostKey�userAuthObject)�selfr r
r r � r �=/usr/lib/python3/dist-packages/twisted/conch/client/direct.py�__init__ s
zSSHClientFactory.__init__c C s | j d r |�� d S d S )N� reconnect)r
�connect)r
� connector�reasonr r r �clientConnectionLost s
�z%SSHClientFactory.clientConnectionLostc C s* | j d u rd S | j d }| _ |�|� d S r )r �errback)r
r r r r r r �clientConnectionFailed s
z'SSHClientFactory.clientConnectionFailedc C sh t | �}| jd r| jd |_| jd r| jd |_| jd r'dg|jdd�< | jd r2| jd |_|S )N�ciphers�macs�compress�zlibr � zhost-key-algorithms)�SSHClientTransportr
�supportedCiphers�
supportedMACs�supportedCompressions�supportedPublicKeys)r
�addr�transr r r �
buildProtocol s
z SSHClientFactory.buildProtocolN)�__name__�
__module__� __qualname__r r r r$ r r r r r
s
r c @ sL e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dS )r c C s || _ d | _d S r )�factory�
unixServer)r
r( r r r r ) s
zSSHClientTransport.__init__c s: �j r �j �� }d �_ nt�d �}|�� �fdd�� d S )Nc s t j��� �S r )r r �connectionLost)�x�r r
r r �<lambda>4 s z3SSHClientTransport.connectionLost.<locals>.<lambda>)r) �
stopListeningr �succeed� addCallback)r
r r r r, r r* - s
�z!SSHClientTransport.connectionLostc C s8 | j jd u rd S | j jd }| j _|�t�||�� d S r )r( r r r �
ConchError)r
�code�descr r r r � receiveError7 s z SSHClientTransport.receiveErrorc C sH | j jd u rd S | j jd }| j _tj�| ||� |�t�||�� d S r )r( r r r �sendDisconnectr r r1 )r
r2 r r r r r r5 = s
z!SSHClientTransport.sendDisconnectc C s( | j jd|||d� |rt|� d S d S )Nz!Received Debug Message: {message})�message�
alwaysDisplay�lang)�_log�debug�print)r
r7 r6 r8 r r r � receiveDebugD s � �z SSHClientTransport.receiveDebugc C s | j �| | j�� j||�S r )r( r r �getPeer�host)r
�pubKey� fingerprintr r r r N s �z SSHClientTransport.verifyHostKeyc C s\ | j jd|d� tj�| |� |jdkr*| jjd ur,| jjd }| j_|�d � d S d S d S )Nz"setting client server to {service})�servicez ssh-userauth) r9 �infor r �
setService�namer( r �callback)r
rA r r r r rC S s �z SSHClientTransport.setServicec C s | � | jj� d S r )�requestServicer( r )r
r r r �connectionSecureZ s z#SSHClientTransport.connectionSecureN) r% r& r' r r* r4 r5 r< r rC rG r r r r r ( s
r c C s( t �� }t||||�}t�| ||� |S r )r �Deferredr r �
connectTCP)r> �portr
r r r r( r r r r ^ s r N) �
twisted.conchr �twisted.conch.sshr �twisted.internetr r r �
ClientFactoryr r r r r r r �<module> s 6