Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/conch/test/__pycache__/test_endpoints.cpython-39.pyc
Ðазад
a k�hP� � @ s� d Z ddlZddlmZ ddlmZ ddlmZ ddl m Z m Z ddl Z ddl mZmZmZ ddlmZ dd lmZ dd lmZ dd lmZ dd lmZmZm Z m Z dd l m Z m Z m!Z!m"Z" ddl#m$Z$m%Z% ddl&m'Z'm(Z( ddl)m*Z*m+Z+ ddl,m-Z- ddl.m/Z/ ddl0m1Z1 ddl2m3Z3 ddl4m5Z5 ddl6m7Z7m8Z8 ddl9m:Z: e5d��r"e5d��r"ddl;m<Z< ddl=m>Z>m?Z? dd l@mAZAmBZB dd lCmDZDmEZEmFZFmGZGmHZHmIZImJZJ dd lKmLZL dd lMmNZN dd lOmPZP dd!lQmRZR dd"lSmTZT dd#lUmVZV dd$lWmXZX dd%lYmZZZ dd&l[m\Z\m]Z]m^Z^m_Z_ n(d'Z`eaZTeaZZeaZReaZVeaZPeaZNeaZBeaZ?eaZ<dd(lbmcZcmdZd dd)l6meZe G d*d+� d+ec�ZfG d,d-� d-eP�ZgG d.d/� d/eP�ZhG d0d1� d1eP�ZiG d2d3� d3�ZjG d4d5� d5e'�ZkG d6d7� d7�ZlG d8d9� d9eZ�ZmG d:d;� d;eT�Znee$�G d<d=� d=��Zoee%�G d>d?� d?��ZpG d@dA� dA�ZqG dBdC� dCe:eq�ZrG dDdE� dEe:eq�ZsG dFdG� dGe:�ZtG dHdI� dI�ZuG dJdK� dKe:�ZvdS )Lz' Tests for L{twisted.conch.endpoints}. � N)�ENOSYS)�pack)� implementer)� verifyClass� verifyObject)� ConchError�HostKeyChanged�UserRejectedKey)� IConchUser)�'InMemoryUsernamePasswordDatabaseDontUse)�Portal)� IPv4Address)�CancelledError�Deferred�fail�succeed)�ConnectingCancelledError�ConnectionDone�ConnectionRefusedError�ProcessTerminated)�IAddress�IStreamClientEndpoint)�Factory�Protocol)�LogLevel�globalLogPublisher)� networkString)�Failure)�FilePath)�msg)� requireModule)�EventLoggingObserver�MemoryReactorClock)�TestCaseZ cryptographyz pyasn1.type)� ConchUser)�InMemorySSHKeyDB�SSHPublicKeyChecker)� ConsoleUI�KnownHostsFile)�AuthenticationFailed�SSHCommandAddress�SSHCommandClientEndpoint�_ExistingConnectionHelper�_ISSHConnectionCreator�_NewConnectionHelper� _ReadFile)�common)�SSHAgentServer)� SSHChannel)� SSHConnection)� SSHFactory)�Key)�SSHClientTransport)�SSHUserAuthServer)�privateDSA_openssh�privateRSA_openssh� privateRSA_openssh_encrypted_aes�publicRSA_opensshz%can't run w/o cryptography and pyasn1)� FakeTransport�connect)�StringTransportc @ s e Zd ZdZdZdd� ZdS )�AbortableFakeTransportzC A L{FakeTransport} with added C{abortConnection} support. Fc C s d| _ dS )z} Abort the connection in a fake manner. This should really be implemented in the underlying module. TN��aborted��self� rD ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/conch/test/test_endpoints.py�abortConnectionZ s z&AbortableFakeTransport.abortConnectionN)�__name__� __module__� __qualname__�__doc__rA rF rD rD rD rE r? S s r? c @ s e Zd ZdZdd� ZdS )�BrokenExecSessionzO L{BrokenExecSession} is a session on which exec requests always fail. c C s dS )z� Fail all exec requests. @param data: Information about what is being executed. @type data: L{bytes} @return: C{0} to indicate failure @rtype: L{int} r rD �rC �datarD rD rE � request_exech s z BrokenExecSession.request_execN�rG rH rI rJ rN rD rD rD rE rK c s rK c @ s e Zd ZdZdd� ZdS )�WorkingExecSessionzS L{WorkingExecSession} is a session on which exec requests always succeed. c C s dS )z� Succeed all exec requests. @param data: Information about what is being executed. @type data: L{bytes} @return: C{1} to indicate success @rtype: L{int} � rD rL rD rD rE rN z s z WorkingExecSession.request_execNrO rD rD rD rE rP u s rP c @ s e Zd ZdZdd� ZdS )�UnsatisfiedExecSessionz� L{UnsatisfiedExecSession} is a session on which exec requests are always delayed indefinitely, never succeeding or failing. c C s t � S )z� Delay all exec requests indefinitely. @param data: Information about what is being executed. @type data: L{bytes} @return: A L{Deferred} which will never fire. @rtype: L{Deferred} )r rL rD rD rE rN � s z#UnsatisfiedExecSession.request_execNrO rD rD rD rE rR � s rR c @ s e Zd Zdd� Zdd� ZdS )� TrivialRealmc C s i | _ d S �N)� channelLookuprB rD rD rE �__init__� s zTrivialRealm.__init__c G s t � }| j|_t|dd� fS )Nc S s d S rT rD rD rD rD rE �<lambda>� � z,TrivialRealm.requestAvatar.<locals>.<lambda>)r$ rU r )rC ZavatarIdZmindZ interfacesZavatarrD rD rE � requestAvatar� s zTrivialRealm.requestAvatarN)rG rH rI rV rY rD rD rD rE rS � s rS c @ s e Zd ZdZdd� ZdS )�AddressSpyFactoryNc C s || _ t�| |�S rT )�addressr � buildProtocol)rC r[ rD rD rE r\ � s z AddressSpyFactory.buildProtocol)rG rH rI r[ r\ rD rD rD rE rZ � s rZ c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�FixedResponseUIc C s || _ d S rT ��result)rC r_ rD rD rE rV � s zFixedResponseUI.__init__c C s t | j�S rT )r r_ �rC �textrD rD rE �prompt� s zFixedResponseUI.promptc C s d S rT rD r` rD rD rE �warn� s zFixedResponseUI.warnN)rG rH rI rV rb rc rD rD rD rE r] � s r] c @ s$ e Zd Zedd� �Zedd� �ZdS )�FakeClockSSHUserAuthServerc C s | j jjS )zy Use the C{attemptsBeforeDisconnect} value defined by the factory to make it easier to override. )� transport�factory�attemptsBeforeDisconnectrB rD rD rE rg � s z3FakeClockSSHUserAuthServer.attemptsBeforeDisconnectc C s | j jjS )z� Use the reactor defined by the factory, rather than the default global reactor, to simplify testing (by allowing an alternate implementation to be supplied by tests). )re rf �reactorrB rD rD rE �clock� s z FakeClockSSHUserAuthServer.clockN)rG rH rI �propertyrg ri rD rD rD rE rd � s rd c @ s2 e Zd Zedd� �Zedd� �Zeed�ZdZ dS )�CommandFactoryc C s dt jtd�iS �N� ssh-rsa)rM )r5 � fromStringr; rB rD rD rE � publicKeys� s zCommandFactory.publicKeysc C s dt jtd�iS rl )r5 rn r9 rB rD rD rE � privateKeys� s zCommandFactory.privateKeys)s ssh-userauths ssh-connectionr N) rG rH rI rj ro rp rd r3 Zservicesrg rD rD rD rE rk � s � rk c @ s e Zd ZdS )� MemoryAddressN)rG rH rI rD rD rD rE rq � s rq c @ s e Zd ZdZdd� Zdd� ZdS )�SingleUseMemoryEndpointa] L{SingleUseMemoryEndpoint} is a client endpoint which allows one connection to be set up and then exposes an API for moving around bytes related to that connection. @ivar pump: L{None} until a connection is attempted, then a L{IOPump} instance associated with the protocol which is connected. @type pump: L{IOPump} c C s d| _ || _dS )z� @param server: An L{IProtocol} provider to which the client will be connected. @type server: L{IProtocol} provider N)�pump�_server)rC �serverrD rD rE rV � s z SingleUseMemoryEndpoint.__init__c C sl | j d urtd��z|�t� �}W n ty: t� Y S 0 t| jt| jdd�|t|dd��| _ t |�S d S )Nz(SingleUseMemoryEndpoint was already usedT��isServerF) rs � Exceptionr\ rq � BaseExceptionr r= rt r? r )rC rf �protocolrD rD rE r= � s �z SingleUseMemoryEndpoint.connectN)rG rH rI rJ rV r= rD rD rD rE rr � s rr c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd*d#d$�Zd%d&� Zd'd(� Zd)S )+�"SSHCommandClientEndpointTestsMixina� Tests for L{SSHCommandClientEndpoint}, an L{IStreamClientEndpoint} implementations which connects a protocol with the stdin and stdout of a command running in an SSH session. These tests apply to L{SSHCommandClientEndpoint} whether it is constructed using L{SSHCommandClientEndpoint.existingConnection} or L{SSHCommandClientEndpoint.newConnection}. Subclasses must override L{create}, L{assertClientTransportState}, and L{finishConnection}. c C s� d| _ d| _d| _d| _t� | _t� | _t| j�| _ t � | _ | j � | j| j� | j � | j � t� | _| j| j_| j | j_ | j�� | �| jj� tddd�| _tddd �| _d S ) Ns ssh.example.comi&� s users passwordZTCPz10.0.0.1i90 z192.168.100.200i1� )�hostname�port�user�passwordr" rh rS �realmr �portalr ZpasswdDBZaddUser�registerCheckerrk rf ZdoStart� addCleanupZdoStopr � clientAddress� serverAddressrB rD rD rE �setUp s" z(SSHCommandClientEndpointTestsMixin.setUpc C s t | jj�d���dS )z� Create and return a new L{SSHCommandClientEndpoint} to be tested. Override this to implement creation in an interesting way the endpoint. z did not implement createN��NotImplementedError� __class__rG rB rD rD rE �create/ s �z)SSHCommandClientEndpointTestsMixin.createc C s t d| jjf ��dS )a� Make an assertion about the connectedness of the given protocol's transport. Override this to implement either a check for the connection still being open or having been closed as appropriate. @param client: The client whose state is being checked. @param immediateClose: Boolean indicating whether the connection was closed immediately or not. z/%r did not implement assertClientTransportStateNr� �rC �clientZimmediateCloserD rD rE �assertClientTransportState8 s ��z=SSHCommandClientEndpointTestsMixin.assertClientTransportStatec C s t | jj�d���dS )z� Do any remaining work necessary to complete an in-memory connection attempted initiated using C{self.reactor}. z# did not implement finishConnectionNr� rB rD rD rE �finishConnectionH s �z3SSHCommandClientEndpointTestsMixin.finishConnectionc C sT |� d�}|� d�}t|d| j| jd�}t|d| j| jd�}t||||�}|||fS )aw Set up an in-memory connection between protocols created by C{serverFactory} and C{clientFactory}. @return: A three-tuple. The first element is the protocol created by C{serverFactory}. The second element is the protocol created by C{clientFactory}. The third element is the L{IOPump} connecting them. NF)rw Z hostAddressZ peerAddressT)r\ r? r� r� r= )rC Z serverFactoryZ clientFactoryZclientProtocolZserverProtocolZclientTransportZserverTransportrs rD rD rE �connectedServerAndClientQ s ��z;SSHCommandClientEndpointTestsMixin.connectedServerAndClientc C s� | � � }t� }t|_|�|�}| �� \}}}| �t�}| �d|d j j |d j j f� | � dt |�� | � |�}|�t� | � d|j j � | �|d� dS )z� If a channel cannot be opened on the authenticated SSH connection, the L{Deferred} returned by L{SSHCommandClientEndpoint.connect} fires with a L{Failure} wrapping the reason given by the server. �unknown channelr rQ � unknown channelFN)r� r r rz r= r� �flushLoggedErrorsr �assertIn�valuerM � assertEqual�len�failureResultOf�trapr� ) rC �endpointrf � connectedru r� rs �errors�frD rD rE �test_channelOpenFailuren s z:SSHCommandClientEndpointTestsMixin.test_channelOpenFailurec C sl t | jjd< | �� }t� }t|_|�|�}| �� \}}}| � |�}|� t � | � d|j j � | �|d� dS )z� If execution of the command fails, the L{Deferred} returned by L{SSHCommandClientEndpoint.connect} fires with a L{Failure} wrapping the reason given by the server. � sessionzchannel request failedFN)rK r� rU r� r r rz r= r� r� r� r r� r� r� �rC r� rf r� ru r� rs r� rD rD rE �test_execFailure� s z3SSHCommandClientEndpointTestsMixin.test_execFailurec C sd t | jjd< | �� }t� }t|_|�|�}| �� \}}}|� � | � |�}|� t � | � |d� dS )z� If execution of the command is cancelled via the L{Deferred} returned by L{SSHCommandClientEndpoint.connect}, the connection is closed immediately. r� TN)rR r� rU r� r r rz r= r� �cancelr� r� r r� r� rD rD rE �test_execCancelled� s z5SSHCommandClientEndpointTestsMixin.test_execCancelledc C s� t | jjd< | �� }t� }t|_|�|� | �� \}}}| � |j t � | � |j �� |j j� | � | j|j j� | � d|j j� dS )aD Once the necessary SSH actions have completed successfully, L{SSHCommandClientEndpoint.connect} uses the factory passed to it to construct a protocol instance by calling its C{buildProtocol} method with an address object representing the SSH connection and command executed. r� � /bin/ls -lN)rP r� rU r� rZ r rz r= r� �assertIsInstancer[ r* r� re ZgetHostru r~ �username�command)rC r� rf ru r� rs rD rD rE �test_buildProtocol� s z5SSHCommandClientEndpointTestsMixin.test_buildProtocolc C sR t | jjd< | �� }t� }t|_|�|�}| �� \}}}| � |�}| � |j � dS )a L{SSHCommandClientEndpoint} establishes an SSH connection, creates a channel in it, runs a command in that channel, and uses the protocol's C{makeConnection} to associate it with a protocol representing that command's stdin and stdout. r� N) rP r� rU r� r r rz r= r� �successResultOf�assertIsNotNonere �rC r� rf r� ru r� rs rz rD rD rE �test_makeConnection� s z6SSHCommandClientEndpointTestsMixin.test_makeConnectionc C s� t | jjd< | �� }t� }t|_|�|�}| �� \}}}| � |�}g }|j |_ |j j } |jj| �d� |�� | �dd�|�� dS )z� After establishing the connection, when the command on the SSH server produces output, it is delivered to the protocol's C{dataReceived} method. r� � hello, worldrX N)rP r� rU r� r r rz r= r� r� �append� dataReceivedre �id�service�channels�writers r� �join) rC r� rf r� ru r� rs rz r� � channelIdrD rD rE �test_dataReceived� s z4SSHCommandClientEndpointTestsMixin.test_dataReceivedc C s� t | jjd< | �� }t� }t|_|�|�}| �� \}}}| � |�}g }|j |_ |j j } |jj| �� |�� |d �t� | �|d� dS )zq When the command closes the channel, the protocol's C{connectionLost} method is called. r� r FN)rP r� rU r� r r rz r= r� r� r� �connectionLostre r� r� r� �loseConnectionrs r� r r� ) rC r� rf r� ru r� rs rz r� r� rD rD rE �test_connectionLost� s z6SSHCommandClientEndpointTestsMixin.test_connectionLostc C s� t | jjd< | �� }t� }t|_|�|�}| �� \}}}| � |�} g } | j | _ | j j } |jj| } |j�| ||� | �� |�� | �|d� | d S )zJ Test handling of non-zero exit statuses or exit signals. r� Fr )rP r� rU r� r r rz r= r� r� r� r� re r� r� r� Z sendRequestr� rs r� ) rC �requestZ requestArgr� rf r� ru r� rs rz r� r� ZchannelrD rD rE �_exitStatusTest s z2SSHCommandClientEndpointTestsMixin._exitStatusTestc C s$ d}| � dtd|��}|�t� dS )�� When the command exits with a non-zero status, the protocol's C{connectionLost} method is called with a L{Failure} wrapping an exception which encapsulates that status. r � exit-status�>LN)r� r r� r )rC �exitCode�excrD rD rE �test_zeroExitCode0 s z4SSHCommandClientEndpointTestsMixin.test_zeroExitCodec C sH d}d}| � dtd|��}|�t� | �||jj� | �||jj� dS )r� �{ Nr� r� )r� r r� r r� r� r� �signal)rC r� r� r� rD rD rE �test_nonZeroExitStatus: s z9SSHCommandClientEndpointTestsMixin.test_nonZeroExitStatusc C s� t � }t�|� | �tj|� d}d}d�t�d�dt�d�t�d�g�}| �d|�}|� t � | � ||j j � | � ||j j� d }t�|t�t�t�tj�|dd d dd ���� dS ) a When the command exits with a non-zero signal, the protocol's C{connectionLost} method is called with a L{Failure} wrapping an exception which encapsulates that status. Additional packet contents are logged at the C{info} level. N� rX s TERM� s messages en-USs exit-signalz'twisted.conch.endpoints._CommandChannelT�message)Z log_levelZ log_namespaceZshortSignalNameZ coreDumpedZ errorMessageZ languageTag)r! r Z addObserverr� ZremoveObserverr� r0 ZNSr� r� r r� r� r� r� �hamcrestZ assert_thatZhas_itemZ has_entriesZequal_tor �info)rC Z logObserverr� r� �packetr� Z logNamespacerD rD rE �test_nonZeroExitSignalG s> �� ����z9SSHCommandClientEndpointTestsMixin.test_nonZeroExitSignalFc s< |j j}g � |r � fdd�}n� j}t|jj| ||� � S )a Hook into and record events which happen to C{protocol}. @param server: The SSH server protocol over which C{protocol} is running. @type server: L{IProtocol} provider @param protocol: @param event: @param noArgs: c s � � d �S rT )r� rD �ZrecorderrD rE rW � rX z;SSHCommandClientEndpointTestsMixin.record.<locals>.<lambda>)re r� r� �setattrr� r� )rC ru rz �event�noArgsr� r� rD r� rE �recordu s z)SSHCommandClientEndpointTestsMixin.recordc C sz t | jjd< | �� }t� }t|_|�|�}| �� \}}}| � |�}| � ||d�}|j � d� |� � | �dd�|�� dS )z� The transport connected to the protocol has a C{write} method which sends bytes to the input of the command executing on the SSH server. r� r� r� rX N)rP r� rU r� r r rz r= r� r� r� re r� rs r� r� � rC r� rf r� ru r� rs rz r� rD rD rE � test_write� s z-SSHCommandClientEndpointTestsMixin.test_writec C s| t | jjd< | �� }t� }t|_|�|�}| �� \}}}| � |�}| � ||d�}|j � dg� |� � | �dd�|�� dS )z� The transport connected to the protocol has a C{writeSequence} method which sends bytes to the input of the command executing on the SSH server. r� r� r� rX N)rP r� rU r� r r rz r= r� r� r� re Z writeSequencers r� r� r� rD rD rE �test_writeSequence� s z5SSHCommandClientEndpointTestsMixin.test_writeSequenceN)F)rG rH rI rJ r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rD rD rD rE r{ s( . r{ c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0S )1�NewConnectionTestsz` Tests for L{SSHCommandClientEndpoint} when using the C{newConnection} constructor. c C sh t �| � t| �� �| _t| j�| _| j�| j| j j d � | j�t | j j �| j j d � | j�� dS )� Configure an SSH server with password authentication enabled for a well-known (to the tests) account. rm N)r{ r� r �mktempZ hostKeyPathr( � knownHosts� addHostKeyr| rf ro r r� �host�saverB rD rD rE r� � s �zNewConnectionTests.setUpc C s* t j| jd| j| j| j| j| jtd�d�S )zu Create and return a new L{SSHCommandClientEndpoint} using the C{newConnection} constructor. r� F�r r� �ui) r+ � newConnectionrh r~ r| r} r r� r] rB rD rD rE r� � s �zNewConnectionTests.createc C s | � | j| jjd d �S )z} Establish the first attempted TCP connection using the SSH server which C{self.factory} can create. r � )r� rf rh � tcpClientsrB rD rD rE r� � s �z#NewConnectionTests.finishConnectionc C sH | j ||ddd�}|j�� |�� | �dg|� |�� |j�� dS )a� Lose the connection to a server and pump the L{IOPump} sufficiently for the client to handle the lost connection. Asserts that the client disconnects its transport. @param server: The SSH server protocol over which C{protocol} is running. @type server: L{IProtocol} provider @param client: The SSH client protocol over which C{protocol} is running. @type client: L{IProtocol} provider @param protocol: The protocol created by calling connect on the ssh endpoint under test. @type protocol: L{IProtocol} provider @param pump: The L{IOPump} connecting client to server. @type pump: L{IOPump} �closedT)r� N)r� re r� rs r� ZreportDisconnect)rC ru r� rz rs r� rD rD rE �loseConnectionToServer� s z)NewConnectionTests.loseConnectionToServerc C s& |r| � |jj� n| � |jj� dS )z� Assert that the transport for the given protocol has been disconnected. L{SSHCommandClientEndpoint.newConnection} creates a new dedicated SSH connection and cleans it up after the command exits. N)� assertTruere rA � disconnectingr� rD rD rE r� s z-NewConnectionTests.assertClientTransportStatec C s, t �| jdd| j| j�}| �tt|�� dS )zY L{SSHCommandClientEndpoint} instances provide L{IStreamClientEndpoint}. � dummy command� dummy userN)r+ r� rh r| r} r� r r �rC r� rD rD rE �test_interface s �z!NewConnectionTests.test_interfacec C s( t �| jdd| j�}| �d|jj� dS )z� L{SSHCommandClientEndpoint} uses the default port number for SSH when the C{port} argument is not specified. r� r� � N�r+ r� rh r| r� Z_creatorr} r� rD rD rE �test_defaultPort" s �z#NewConnectionTests.test_defaultPortc C s, t j| jdd| jdd�}| �d|jj� dS )zU L{SSHCommandClientEndpoint} uses the C{port} argument if specified. r� r� i� )r} Nr� r� rD rD rE �test_specifiedPort, s �z%NewConnectionTests.test_specifiedPortc C s� t j| jd| j| j| j| j| jtd�d�}t � }t |_ |� |� | jj d \}}}}}| �| jt|�� | �| j|� | �dt| jj �� dS )z� L{SSHCommandClientEndpoint} uses the L{IReactorTCP} passed to it to attempt a connection to the host/port address also passed to it. r� Fr� r rQ N)r+ r� rh r~ r| r} r r� r] r r rz r= r� r� r r� )rC r� rf r� r} �timeoutZ bindAddressrD rD rE �test_destination5 s" � z#NewConnectionTests.test_destinationc C sp t j| jdd| j| j| jtd�d�}t� }t|_ |� |�}| jj d d }|� dt t� �� | �|��t� dS )z� If a connection cannot be established, the L{Deferred} returned by L{SSHCommandClientEndpoint.connect} fires with a L{Failure} representing the reason for the connection setup failure. r� r� F�r� r� r r� N)r+ r� rh r| r} r� r] r r rz r= r� ZclientConnectionFailedr r r� r� �rC r� rf �drD rD rE �test_connectionFailedM s � z(NewConnectionTests.test_connectionFailedc C sx t j| jdd| j| jt| �� �td�d�}t� }t |_ |� |�}| � | j | jjd d �\}}}| �|�}|�t� dS )a" If the L{KnownHostsFile} instance used to construct L{SSHCommandClientEndpoint} rejects the SSH public key presented by the server, the L{Deferred} returned by L{SSHCommandClientEndpoint.connect} fires with a L{Failure} wrapping L{UserRejectedKey}. r� r� Fr� r r� N)r+ r� rh r| r} r( r� r] r r rz r= r� rf r� r� r� r r� rD rD rE �test_userRejectedHostKeye s" � � z+NewConnectionTests.test_userRejectedHostKeyc C s� t �t��� }tt| �� ��}|�t| j j �|� t jt dd��� }|�| j |� t d�}tj| jdd| j | jd||d�}t� }t|_|�|�}| �| j| jjd d �\}} } | �|�} | �t� d S ) ac If the SSH public key presented by the SSH server does not match the previously remembered key, as reported by the L{KnownHostsFile} instance use to construct the endpoint, for that server, the L{Deferred} returned by L{SSHCommandClientEndpoint.connect} fires with a L{Failure} wrapping L{HostKeyChanged}. s testxp)Z passphraseTr� r� � dummy passwordr� r r� N) r5 rn r9 �publicr( r r� r� r r� r� r: r| r] r+ r� rh r} r r rz r= r� rf r� r� r� r ) rC ZfirstKeyr� Z differentKeyr� r� rf r� ru r� rs r� rD rD rE �test_mismatchedHostKey� s4 � � � z)NewConnectionTests.test_mismatchedHostKeyc C s� t j| jdd| j| j| jtd�d�}t� }t|_ |� |�}t � }| jj d d }|� d�}|�|� |�tt� �� | �|��t� dS )aU If the connection closes at any point before the SSH transport layer has finished key exchange (ie, gotten to the point where we may attempt to authenticate), the L{Deferred} returned by L{SSHCommandClientEndpoint.connect} fires with a L{Failure} wrapping the reason for the lost connection. r� r� Fr� r r� N)r+ r� rh r| r} r� r] r r rz r= r> r� r\ �makeConnectionr� r r r� r� �rC r� rf r� re r� rD rD rE �!test_connectionClosedBeforeSecure� s$ � z4NewConnectionTests.test_connectionClosedBeforeSecurec C s� t j| jdd| j| j| jtd�d�}t� }t|_ |� |�}t ddd�}| jj d d }|� d�}|�|� |�� | �|��t� | �|j� |�tt� �� dS ) a[ If the connection is cancelled before the SSH transport layer has finished key exchange (ie, gotten to the point where we may attempt to authenticate), the L{Deferred} returned by L{SSHCommandClientEndpoint.connect} fires with a L{Failure} wrapping L{CancelledError} and the connection is aborted. r� r� Fr� Nrv r r� )r+ r� rh r| r} r� r] r r rz r= r? r� r\ r� r� r� r� r r� rA r� r r r� rD rD rE �$test_connectionCancelledBeforeSecure� s( � z7NewConnectionTests.test_connectionCancelledBeforeSecurec C sj t j| jdd| j| j| jtd�d�}t� }t|_ |� |�}|� � | � |�� t� | �| jjd j� dS )zz If the connection is cancelled before it finishes connecting, the connection attempt is stopped. r� r� Fr� r N)r+ r� rh r| r} r� r] r r rz r= r� r� r� r r� Z connectorsZstoppedConnectingr� rD rD rE �'test_connectionCancelledBeforeConnected� s � z:NewConnectionTests.test_connectionCancelledBeforeConnectedc C s� t j| jdd| j| jd| jtd�d�}t� }t|_ |� |�}| � | j | jj d d �\}}}| j�|jj� |�� | �|�}|�t� | �|d� dS ) z� If the SSH server rejects the password presented during authentication, the L{Deferred} returned by L{SSHCommandClientEndpoint.connect} fires with a L{Failure} wrapping L{AuthenticationFailed}. r� r� r� Fr� r r� N)r+ r� rh r| r} r� r] r r rz r= r� rf r� �advancer� Z passwordDelay�flushr� r� r) r� r� rD rD rE �"test_passwordAuthenticationFailure s* � � z5NewConnectionTests.test_passwordAuthenticationFailurec C s, dd� |� � D �}tt|��}|�|� dS )a� Create an L{ISSHPrivateKey} checker which recognizes C{users} and add it to C{portal}. @param portal: A L{Portal} to which to add the checker. @type portal: L{Portal} @param users: The users and their keys the checker will recognize. Keys are byte strings giving user names. Values are byte strings giving OpenSSH-formatted private keys. @type users: L{dict} c S s" i | ]\}}|t �|��� g�qS rD )r5 rn r� )�.0�k�vrD rD rE � <dictcomp>8 rX z6NewConnectionTests.setupKeyChecker.<locals>.<dictcomp>N)�itemsr& r% r� )rC r� Zusers�mapping�checkerrD rD rE �setupKeyChecker+ s z"NewConnectionTests.setupKeyCheckerc C s� t �t�}| �| j| jti� tj| j d| j| j | j |g| j t d�d�}t� }t|_|�|�}| �| j| j jd d �\}}}| �|�}|�t� | �|jj� dS )z� If the SSH server rejects the key pair presented during authentication, the L{Deferred} returned by L{SSHCommandClientEndpoint.connect} fires with a L{Failure} wrapping L{AuthenticationFailed}. r� F��keysr� r� r r� N)r5 rn r9 r r� r~ r8 r+ r� rh r| r} r� r] r r rz r= r� rf r� r� r� r) r� re r� ) rC �badKeyr� rf r� ru r� rs r� rD rD rE �#test_publicKeyAuthenticationFailure< s* � � z6NewConnectionTests.test_publicKeyAuthenticationFailurec C s t �t�}| �| j| jti� tj| j d| j| j | j |g| j | j td�d� }t� }t|_|�|�}| j jd7 _| �| j| j jd d �\}}}|�� | �t�}| �d|d jj |d jjf� | � dt |�� | � |�} | � t� | � d| jj� | �!|j"j#� d S ) z{ If the SSH server does not accept any of the specified SSH keys, the specified password is tried. r� F)r r r� r� rQ r r� r� r� N)$r5 rn r9 r r� r~ r8 r+ r� rh r| r} r r� r] r r rz r= rf rg r� r� rs r� r r� r� rM r� r� r� r� r� re r� ) rC r r� rf r� ru r� rs r� r� rD rD rE �test_authenticationFallbacka s8 � � z.NewConnectionTests.test_authenticationFallbackc C s� t �t�}| �| j| jti� t| jjd< t j | j d| j| j | j |g| jtd�d�}t� }t|_|�|�}| �| j| j jd d �\}}}| �|�}| �|j� dS )z� If L{SSHCommandClientEndpoint} is initialized with any private keys, it will try to use them to authenticate with the SSH server. r� r� Fr r r� N)r5 rn r8 r r� r~ rP r� rU r+ r� rh r| r} r� r] r r rz r= r� rf r� r� r� re ) rC �keyr� rf r� ru r� rs rz rD rD rE � test_publicKeyAuthentication� s* � � z/NewConnectionTests.test_publicKeyAuthenticationc C s� t j| jd| j| j| j| jtd�d�}t� }t |_ |� |�}| � | j | jjd d �\}}}|�� | �|�}|�t� | �|jj� dS )z� If the password is not specified, L{SSHCommandClientEndpoint} doesn't try it as an authentication mechanism. r� Fr� r r� N)r+ r� rh r~ r| r} r� r] r r rz r= r� rf r� rs r� r� r) r� re r� r� rD rD rE � test_skipPasswordAuthentication� s& � � z2NewConnectionTests.test_skipPasswordAuthenticationc C s t �t�}t� }t� |_|�� |dfi|j_| �| j | j ti� t |�}t j | jd| j | j| j| jtd�|d�}t| jjd< t� }t|_|�|�}| �| j| jjd d �\}}} td�D ]} |j � � | � � q�| � |�} | � | j � | � ||| | � | �!|j j"� | �!|j j#j"� d S ) a If L{SSHCommandClientEndpoint} is initialized with an L{SSHAgentClient}, the agent is used to authenticate with the SSH server. Once the connection with the SSH server has concluded, the connection to the agent is disconnected. rX r� F)r� r� � agentEndpointr� r r� � N)$r5 rn r9 r1 r rf Zblobr r r� r~ rr r+ r� rh r| r} r� r] rP r� rU r rz r= r� r� �rangers r� r� re r� r� r� ZclientIO) rC r Z agentServerr r� rf r� ru r� rs �irz rD rD rE �test_agentAuthentication� s> � � z+NewConnectionTests.test_agentAuthenticationc C sd t | jjd< | �� }t� }t|_|�|�}| �� \}}}| � |�}| � ||||� | � |j j � dS )z� The transport connected to the protocol has a C{loseConnection} method which causes the channel in which the command is running to close and the overall connection to be closed. r� N)rP r� rU r� r r rz r= r� r� r� r� re r� r� rD rD rE �test_loseConnection s z&NewConnectionTests.test_loseConnectionN)rG rH rI rJ r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r r r rD rD rD rE r� � s0 # , "(%0 !3r� c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) �ExistingConnectionTestsze Tests for L{SSHCommandClientEndpoint} when using the C{existingConnection} constructor. c C sz t �| � tt| �� ��}|�| j| jjd � |�t | j j �| jjd � t j | jd| j| j| j| j|td�d�| _dS )r� rm r� Fr� N)r{ r� r( r r� r� r| rf ro r r� r� r+ r� rh r~ r} r r] r� )rC r� rD rD rE r� ! s ��z ExistingConnectionTests.setUpc C s� t � }t|_| j�|�}| jj�� }zJt| jjd< | � | j | j j d d �\}}}W | jj� � | jj�|� n | jj� � | jj�|� 0 || _|| _|| _| �|�}|jj}t�|d�S )zz Create and return a new L{SSHCommandClientEndpoint} using the C{existingConnection} constructor. r� r r� r� )r r rz r� r= r� rU �copyrP r� rf rh r� �clear�updatert �_client�_pumpr� re �connr+ ZexistingConnection) rC rf r� rU ru r� rs rz � connectionrD rD rE r� 9 s& � � z ExistingConnectionTests.createc C s8 | j �� | j �� | j �� | j �� | j| j| j fS )z� Give back the connection established in L{create} over which the new command channel being tested will exchange data. )r rs rt r rB rD rD rE r� W s z(ExistingConnectionTests.finishConnectionc C s | � |jj� | � |jj� dS )a Assert that the transport for the given protocol is still connected. L{SSHCommandClientEndpoint.existingConnection} re-uses an SSH connected created by some other code, so other code is responsible for cleaning it up. N)� assertFalsere r� rA r� rD rD rE r� e s z2ExistingConnectionTests.assertClientTransportStateN)rG rH rI rJ r� r� r� r� rD rD rD rE r s r c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) � ExistingConnectionHelperTestsz1 Tests for L{_ExistingConnectionHelper}. c C s | � ttt�� dS )zT L{_ExistingConnectionHelper} implements L{_ISSHConnectionCreator}. N)r� r r- r, rB rD rD rE r� u s z,ExistingConnectionHelperTests.test_interfacec C s( t � }t|�}| �|| �|�� �� dS )z� L{_ExistingConnectionHelper.secureConnection} returns a L{Deferred} which fires with whatever object was fed to L{_ExistingConnectionHelper.__init__}. N)�objectr, �assertIsr� ZsecureConnection)rC r_ �helperrD rD rE �test_secureConnection{ s z3ExistingConnectionHelperTests.test_secureConnectionc C s t t� �}|�t� d� dS )z� L{_ExistingConnectionHelper.cleanupConnection} does nothing to the existing connection if called with C{immediate} set to C{False}. FN�r, r �cleanupConnection�rC r rD rD rE �$test_cleanupConnectionNotImmediately� s zBExistingConnectionHelperTests.test_cleanupConnectionNotImmediatelyc C s t t� �}|�t� d� dS )z� L{_ExistingConnectionHelper.cleanupConnection} does nothing to the existing connection if called with C{immediate} set to C{True}. TNr! r# rD rD rE �!test_cleanupConnectionImmediately� s z?ExistingConnectionHelperTests.test_cleanupConnectionImmediatelyN)rG rH rI rJ r� r r$ r% rD rD rD rE r p s r c @ s e Zd ZdZdd� Zdd� ZdS )�_PTYPathzk A L{FilePath}-like object which can be opened to create a L{_ReadFile} with certain contents. c C s || _ dS )zz @param contents: L{bytes} which will be the contents of the L{_ReadFile} this path can open. N)�contents)rC r' rD rD rE rV � s z_PTYPath.__init__c C s |dkrt | j�S ttd��dS )z� If the mode is r+, return a L{_ReadFile} with the contents given to this path's initializer. @raise OSError: If the mode is unsupported. @return: A L{_ReadFile} instance zrb+zFunction not implementedN)r/ r' �OSErrorr )rC �moderD rD rE �open� s z _PTYPath.openN)rG rH rI rJ rV r* rD rD rD rE r& � s r& c @ s` e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dd� Z dS )�NewConnectionHelperTestsz, Tests for L{_NewConnectionHelper}. c C s | � ttt�� dS )zO L{_NewConnectionHelper} implements L{_ISSHConnectionCreator}. N)r� r r- r. rB rD rD rE r� � s z'NewConnectionHelperTests.test_interfacec C s | � dtj� dS )zK The default I{known_hosts} path is I{~/.ssh/known_hosts}. z~/.ssh/known_hostsN)r� r. � _KNOWN_HOSTSrB rD rD rE �test_defaultPath� s z)NewConnectionHelperTests.test_defaultPathc sH t � � | �td� fdd�� tdddddddddd� }| �� |j� dS )z� L{_NewConnectionHelper._knownHosts} is used to create a L{KnownHostsFile} if one is not passed to the initializer. � _knownHostsc s � S rT rD )�clsr^ rD rE rW � rX zANewConnectionHelperTests.test_defaultKnownHosts.<locals>.<lambda>N)r �patchr. r r� r# rD r^ rE �test_defaultKnownHosts� s �z/NewConnectionHelperTests.test_defaultKnownHostsc C s� t � jd }t| �� �}t|�}|�d|� |�� td|j��� t j� d�}|j� |d�}| � t d|� td|��� t �� }| �|�d|�� dS )z� Existing entries in the I{known_hosts} file are reflected by the L{KnownHostsFile} created by L{_NewConnectionHelper} when none is supplied to it. rm s 127.0.0.1z Created known_hosts file at z~/r, zPatched _KNOWN_HOSTS with N)rk ro r r� r( r� r� r �path�os� expanduser�replacer0 r. r. r� Z hasHostKey)rC r r2 r� �home�defaultZloadedrD rD rE �test_readExisting� s z*NewConnectionHelperTests.test_readExistingc C s, t dddddddddd� }| �|jt� dS )zz If L{None} is passed for the C{ui} parameter to L{_NewConnectionHelper}, a L{ConsoleUI} is used. N)r. r� r� r' r# rD rD rE �test_defaultConsoleUI� s �z.NewConnectionHelperTests.test_defaultConsoleUIc C sD t d�}tdddddddddd|� }| �|j�d��}| �|� dS )z� If L{None} is passed for the C{ui} parameter to L{_NewConnectionHelper} and /dev/tty is available, the L{ConsoleUI} used is associated with /dev/tty. s yesNs does this work?)r& r. r� r� rb r� �rC �ttyr r_ rD rD rE �test_ttyConsoleUI� s �z*NewConnectionHelperTests.test_ttyConsoleUIc C sH t | �� �}tdddddddddd|� }| �|j�d��}| �|� dS )z� If L{None} is passed for the C{ui} parameter to L{_NewConnectionHelper} and /dev/tty is not available, the L{ConsoleUI} used is associated with some file which always produces a C{b"no"} response. Ns did this break?)r r� r. r� r� rb r r: rD rD rE � test_nottyUI s �z%NewConnectionHelperTests.test_nottyUIc C s0 t dddddddddd� }| �td�|j� dS )zy If not passed the name of a tty in the filesystem, L{_NewConnectionHelper} uses C{b"/dev/tty"}. Ns /dev/tty)r. r� r r; r# rD rD rE �test_defaultTTYFilename s �z0NewConnectionHelperTests.test_defaultTTYFilenamec C sF t dddddddddd� }t� }t� |_|�|d� | �|jj� dS )z� L{_NewConnectionHelper.cleanupConnection} closes the transport cleanly if called with C{immediate} set to C{False}. NF)r. r3 r> re r" r� r� )rC r r rD rD rE r$ s � z=NewConnectionHelperTests.test_cleanupConnectionNotImmediatelyc C s` G dd� d�}t dddddddddd� }t� }t� |_|� |j_|�|d� | �|jjj� dS )z� L{_NewConnectionHelper.cleanupConnection} closes the transport with C{abortConnection} if called with C{immediate} set to C{True}. c @ s e Zd ZdZdd� ZdS )zMNewConnectionHelperTests.test_cleanupConnectionImmediately.<locals>.AbortableFc S s d| _ dS )z7 Abort the connection. TNr@ rB rD rD rE rF 1 s z]NewConnectionHelperTests.test_cleanupConnectionImmediately.<locals>.Abortable.abortConnectionN)rG rH rI rA rF rD rD rD rE � Abortable. s r? NT)r. r3 r6 re r" r� rA )rC r? r r rD rD rE r% ( s � z:NewConnectionHelperTests.test_cleanupConnectionImmediatelyN)rG rH rI rJ r� r- r1 r8 r9 r< r= r> r$ r% rD rD rD rE r+ � s r+ )wrJ �os.pathr3 �errnor �structr Zzope.interfacer Zzope.interface.verifyr r r� Ztwisted.conch.errorr r r Ztwisted.conch.interfacesr Ztwisted.cred.checkersr Ztwisted.cred.portalr Ztwisted.internet.addressr Ztwisted.internet.deferr r r r Ztwisted.internet.errorr r r r Ztwisted.internet.interfacesr r Ztwisted.internet.protocolr r Ztwisted.loggerr r Ztwisted.python.compatr Ztwisted.python.failurer Ztwisted.python.filepathr Ztwisted.python.logr Ztwisted.python.reflectr Ztwisted.test.proto_helpersr! r" Ztwisted.trial.unittestr# Ztwisted.conch.avatarr$ Ztwisted.conch.checkersr% r& Z twisted.conch.client.knownhostsr' r( Ztwisted.conch.endpointsr) r* r+ r, r- r. r/ Ztwisted.conch.sshr0 Ztwisted.conch.ssh.agentr1 Ztwisted.conch.ssh.channelr2 Z twisted.conch.ssh.connectionr3 Ztwisted.conch.ssh.factoryr4 Ztwisted.conch.ssh.keysr5 Ztwisted.conch.ssh.transportr6 Ztwisted.conch.ssh.userauthr7 Ztwisted.conch.test.keydatar8 r9 r: r; �skipr Ztwisted.test.iosimr< r= r> r? rK rP rR rS rZ r] rd rk rq rr r{ r� r r r& r+ rD rD rD rE �<module> s� $ & 1 dU,
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка