Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/internet/test/__pycache__/test_endpoints.cpython-39.pyc
Ðазад
a k�h�D � @ sR d Z ddlmZ ddlmZmZmZmZmZ ddl m Z ddl m Z ddl mZ ddlmZmZmZ ddlmZ dd lmZmZ dd lmZ dd lmZm Z m Z m Z m Z m Z m!Z!m"Z" dd l#m$Z$ dd l%m&Z&m'Z'm(Z(m)Z)m*Z* ddl+m,Z, ddl-m.Z. ddl/m0Z0m1Z1m2Z2m3Z3m4Z4 ddl5m6Z6m7Z7m8Z8 ddl9m:Z: ddl;m<Z< ddl=m>Z?m@Z@mAZAmBZB ddlCmDZDmEZE ddlFmGZG ddlHmIZImJZJ ddlKmLZL ddlMmNZN ddlOmPZP ddlQmRZR dd lSmTZT dd lUmVZV dd lWmXZX dd lYmZZZm[Z[ dd l\m Z eVd!�j]�^d"�Z_eVd!�j]�^d#�Z`eVd!�j]�^d$�ZaeVeb�j]�^d%�Zcec�dd&�Zee �fe_jg�Zhe �fe`jg�Zie �feajg�Zje �fecjg�Zke �feejg�Zlztdd'lmmnZompZpmqZqmrZr dd(lsmtZtmuZumvZvmwZwmxZx dd)lymzZz dd*l{m|Z| et�}e_�~� �Zex�}e_�~� �Z�d+Z�d,Z�W n2 e��y Z� zd-Z�e�e��Z�W Y d.Z�[�n d.Z�[�0 0 G d/d0� d0e8�Z�ee j��G d1d2� d2e���Z�ee j��G d3d4� d4e���Z�ee j��G d5d6� d6e���Z�G d7d8� d8e6�Z�G d9d:� d:e6�Z�G d;d<� d<e j��Z�G d=d>� d>�Z�G d?d@� d@�Z�G dAdB� dBe�e��Z�G dCdD� dDe7�Z�G dEdF� dF�Z�G dGdH� dHe j��Z�G dIdJ� dJe j8�Z�ee j��G dKdL� dLeB��Z�ee j0e�� ee j2e�� ee j�e�� ee j��G dMdN� dN��Z�G dOdP� dPe j��Z�G dQdR� dRe j��Z�G dSdT� dTe j��Z�G dUdV� dVe�e j��Z�G dWdX� dXe�e j��Z�G dYdZ� dZe�e j��Z�G d[d\� d\e@e<�Z�d�d^d_�Z�G d`da� dae j��Z�G dbdc� dce j��Z�G ddde� dee��Z�G dfdg� dge�e j��Z�G dhdi� die�e j��Z�G djdk� dke�e j��Z�G dldm� dme�e j��Z�G dndo� doe j��Z�G dpdq� dqe j��Z�G drds� dse j��Z�G dtdu� due j��Z�ee�e��G dvdw� dwe�e j���Z�G dxdy� dye�e j��Z�G dzd{� d{e j��Z�G d|d}� d}e j��Z�d�dd��Z�G d�d�� d�e j��Z�ee�e��G d�d�� d�e j���Z�G d�d�� d�e�e j��Z�G d�d�� d�e j��Z�G d�d�� d�e j��Z�G d�d�� d�e j��Z�G d�d�� d�e j��Z�G d�d�� d�eJj��Z�G d�d�� d�eJj��Z�G d�d�� d�eIj��Z�G d�d�� d�eZ�G d�d�� d�e j��Z�d�d�� Z�ee�e��G d�d�� d�e j���Z�d�d�� Z�G d�d�� d�e j��Z�d.S )�z� Test the C{I...Endpoint} implementations that wrap the L{IReactorTCP}, L{IReactorSSL}, and L{IReactorUNIX} interfaces found in L{twisted.internet.endpoints}. � )�EPERM)�AF_INET�AF_INET6� IPPROTO_TCP� SOCK_STREAM�gaierror)� FunctionType)� normalize)�skipIf)� implementer� providedBy�provider)�InterfaceClass)� verifyClass� verifyObject)�plugins)�defer� endpoints�error� interfaces�protocol�reactor�stdio�threads)� isIPv6Address)�HostnameAddress� IPv4Address� IPv6Address� UNIXAddress�_ProcessAddress)�StandardErrorBehavior)�ConnectingCancelledError)� IConsumer�IHostnameResolver� IPushProducer� IReactorPluggableNameResolver� ITransport)� ClientFactory�Factory�Protocol)� PipeAddress)�Clock)�MemoryReactorClock�RaisingMemoryReactor�StringTransport� StringTransportWithDisconnection)� ILogObserver�globalLogPublisher)� getPlugins)�basic�policies)�log)� nativeString)�proxyForInterface)�Failure)�FilePath)� getModule)� ListenFDs)�connectableEndpoint�connectedServerAndClient)�unittestz twisted.testz server.pemzkey.pem.no_trailing_newlinez cert.pem.no_trailing_newlineZfake_CAsz chain.pem)�Context� OP_NO_SSLv3� SSLv23_METHOD� TLSv1_METHOD)� Certificate�CertificateOptions�DiffieHellmanParameters�KeyPair�PrivateCertificate��TLSMemoryBIOFactory)�makeCertificateF� TNc @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) � TestProtocolzx Protocol whose only function is to callback deferreds on the factory when it is connected or disconnected. c C s g | _ g | _d| _d S �Nr )�data�connectionsLost�connectionMadeCalls��self� rS ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/internet/test/test_endpoints.py�__init__| s zTestProtocol.__init__c C s dS )N�A Test ProtocolrS rQ rS rS rT � logPrefix� s zTestProtocol.logPrefixc C s | j d7 _ d S �N� )rP rQ rS rS rT �connectionMade� s zTestProtocol.connectionMadec C s | j �|� d S �N)rN �append�rR rN rS rS rT � dataReceived� s zTestProtocol.dataReceivedc C s | j �|� d S r[ )rO r\ �rR �reasonrS rS rT �connectionLost� s zTestProtocol.connectionLostN) �__name__� __module__� __qualname__�__doc__rU rW rZ r^ ra rS rS rS rT rL v s rL c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �TestHalfCloseableProtocolab A Protocol that implements L{IHalfCloseableProtocol} and records whether its C{readConnectionLost} and {writeConnectionLost} methods are called. @ivar readLost: A C{bool} indicating whether C{readConnectionLost} has been called. @ivar writeLost: A C{bool} indicating whether C{writeConnectionLost} has been called. c C s t �| � d| _d| _d S )NF)rL rU �readLost� writeLostrQ rS rS rT rU � s z"TestHalfCloseableProtocol.__init__c C s d| _ d S �NT)rg rQ rS rS rT �readConnectionLost� s z,TestHalfCloseableProtocol.readConnectionLostc C s d| _ d S ri )rh rQ rS rS rT �writeConnectionLost� s z-TestHalfCloseableProtocol.writeConnectionLostN)rb rc rd re rU rj rk rS rS rS rT rf � s rf c @ s e Zd ZdZdd� Zdd� ZdS )�"TestFileDescriptorReceiverProtocola A Protocol that implements L{IFileDescriptorReceiver} and records how its C{fileDescriptorReceived} method is called. @ivar receivedDescriptors: A C{list} containing all of the file descriptors passed to C{fileDescriptorReceived} calls made on this instance. c C s t �| � g | _d S r[ )rL rZ �receivedDescriptorsrQ rS rS rT rZ � s z1TestFileDescriptorReceiverProtocol.connectionMadec C s | j �|� d S r[ )rm r\ )rR Z descriptorrS rS rT �fileDescriptorReceived� s z9TestFileDescriptorReceiverProtocol.fileDescriptorReceivedN)rb rc rd re rZ rn rS rS rS rT rl � s rl c @ s e Zd ZdZdd� Zdd� ZdS )�TestHandshakeListenera A Protocol that implements L{IHandshakeListener} and records the number of times its C{handshakeCompleted} method has been called. @ivar handshakeCompletedCalls: The number of times C{handshakeCompleted} @type handshakeCompletedCalls: L{int} c C s t �| � d| _d S rM )rL rU �handshakeCompletedCallsrQ rS rS rT rU � s z TestHandshakeListener.__init__c C s | j d7 _ dS )zk Called when a TLS handshake has completed. Implemented per L{IHandshakeListener} rY N)rp rQ rS rS rT �handshakeCompleted� s z(TestHandshakeListener.handshakeCompletedN)rb rc rd re rU rq rS rS rS rT ro � s ro c @ s e Zd ZdZeZdS )� TestFactoryz� Simple factory to be used both when connecting and listening. It contains two deferreds which are called back when my protocol connects and disconnects. N)rb rc rd re rL r rS rS rS rT rr � s rr c @ s e Zd ZdZdd� ZdS )� NoneFactoryzC A one off factory whose C{buildProtocol} returns L{None}. c C s d S r[ rS �rR �addrrS rS rT � buildProtocol� s zNoneFactory.buildProtocolN�rb rc rd re rv rS rS rS rT rs � s rs 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,S )-�WrappingFactoryTestszS Test the behaviour of our ugly implementation detail C{_WrappingFactory}. c C s* t � }t�|�}|�� | �d|j� dS )z� L{_WrappingFactory.doStart} passes through to the wrapped factory's C{doStart} method, allowing application-specific setup and logging. rY N)r' r �_WrappingFactoryZdoStart� assertEqual�numPorts�rR �factory�wfrS rS rT � test_doStart� s z!WrappingFactoryTests.test_doStartc C s0 t � }d|_t�|�}|�� | �d|j� dS )z� L{_WrappingFactory.doStop} passes through to the wrapped factory's C{doStop} method, allowing application-specific cleanup and logging. � � N)r' r{ r ry ZdoStoprz r| rS rS rT � test_doStop� s z WrappingFactoryTests.test_doStopc sJ G dd� dt �}t�|� �}|�d� � �|jt�}|�� fdd�� |S )z� An exception raised in C{buildProtocol} of our wrappedFactory results in our C{onConnection} errback being fired. c @ s e Zd ZdZdd� ZdS )zCWrappingFactoryTests.test_failedBuildProtocol.<locals>.BogusFactoryzZ A one off factory whose C{buildProtocol} raises an C{Exception}. c S s t d��d S )N� My protocol is poorly defined.)� ValueErrorrt rS rS rT rv s zQWrappingFactoryTests.test_failedBuildProtocol.<locals>.BogusFactory.buildProtocolNrw rS rS rS rT � BogusFactory s r� Nc s � � | jd�S )N)r� )rz �args)�erQ rS rT �<lambda> � z?WrappingFactoryTests.test_failedBuildProtocol.<locals>.<lambda>)r' r ry rv � assertFailure� _onConnectionr� � addCallback)rR r� r~ �drS rQ rT �test_failedBuildProtocol� s �z-WrappingFactoryTests.test_failedBuildProtocolc C s* t �t� �}|�d� | �|jtj� dS )z� If the wrapped factory's C{buildProtocol} returns L{None} the C{onConnection} errback fires with L{error.NoProtocol}. N)r ry rs rv �failureResultOfr� r � NoProtocol�rR ZwrappingFactoryrS rS rT �test_buildNoneProtocol s z+WrappingFactoryTests.test_buildNoneProtocolc C s0 t �t� �}|j�dd� � | �|�d�� dS )z� If the wrapped factory's C{buildProtocol} returns L{None} then L{endpoints._WrappingFactory.buildProtocol} returns L{None}. c S s d S r[ rS �r` rS rS rT r� & r� zDWrappingFactoryTests.test_buildProtocolReturnsNone.<locals>.<lambda>N)r ry rs r� � addErrback� assertIsNonerv r� rS rS rT � test_buildProtocolReturnsNone s z2WrappingFactoryTests.test_buildProtocolReturnsNonec C s* t �t� �}|�d�}| �|�� d� dS )z� If the wrapped protocol provides L{ILoggingContext}, whatever is returned from the wrapped C{logPrefix} method is returned from L{_WrappingProtocol.logPrefix}. NrV )r ry rr rv rz rW )rR r~ �wprS rS rT �test_logPrefixPassthrough* s z.WrappingFactoryTests.test_logPrefixPassthroughc C sB G dd� d�}t � }||_t�|�}|�d�}| �|�� d� dS )z� If the wrapped protocol does not provide L{ILoggingContext}, the wrapped protocol's class name is returned from L{_WrappingProtocol.logPrefix}. c @ s e Zd ZdS )z>WrappingFactoryTests.test_logPrefixDefault.<locals>.NoProtocolN�rb rc rd rS rS rS rT r� ; s r� N)rr r r ry rv rz rW )rR r� r} r~ r� rS rS rT �test_logPrefixDefault4 s z*WrappingFactoryTests.test_logPrefixDefaultc C s^ t �t� �}|�d�}|�d� |�d� | �|jjdg� |�d� | �|jjddg� dS )z� The wrapped C{Protocol}'s C{dataReceived} will get called when our C{_WrappingProtocol}'s C{dataReceived} gets called. Ns foos bar) r ry rr rv �makeConnectionr^ rz �_wrappedProtocolrN )rR r~ �prS rS rT � test_wrappedProtocolDataReceivedD s z5WrappingFactoryTests.test_wrappedProtocolDataReceivedc C sH t �t� �}|�d�}t� }|�|� | �|j|� | �|jj|� dS )zo Our transport is properly hooked up to the wrappedProtocol when a connection is made. N) r ry rr rv �objectr� rz � transportr� )rR r~ r� ZdummyTransportrS rS rT � test_wrappedProtocolTransportS s z2WrappingFactoryTests.test_wrappedProtocolTransportc C s: t � }t�|�}|�d�}|�d� | �|jjdg� dS )z� Our wrappedProtocol's connectionLost method is called when L{_WrappingProtocol.connectionLost} is called. N�fail)rr r ry rv ra rz r� rO )rR �tfr~ r� rS rS rT �"test_wrappedProtocolConnectionLostc s z7WrappingFactoryTests.test_wrappedProtocolConnectionLostc sV t �t� �}ttjdd��}|�d|� g � � fdd�}|j�|� | � � |g� dS )z� Calls to L{_WrappingFactory.clientConnectionLost} should errback the L{_WrappingFactory._onConnection} L{Deferred} r� ��stringNc s � � | � d S r[ �r\ ��f��errorsrS rT �gotError| s zBWrappingFactoryTests.test_clientConnectionFailed.<locals>.gotError) r ry rr r8 r � ConnectError�clientConnectionFailedr� r� rz )rR r~ ZexpectedFailurer� rS r� rT �test_clientConnectionFailedp s z0WrappingFactoryTests.test_clientConnectionFailedc C s> d}t � }t�||�}| �tj�|�� | �ttj|�� dS )zv Our L{_WrappingProtocol} should be an L{IFileDescriptorReceiver} if the wrapped protocol is. N)rl r �_WrappingProtocol� assertTruer �IFileDescriptorReceiverr r )rR ZconnectedDeferredZapplicationProtocol�wrapperrS rS rT �+test_wrappingProtocolFileDescriptorReceiver� s z@WrappingFactoryTests.test_wrappingProtocolFileDescriptorReceiverc C s( t � }t�d|�}| �tj�|�� dS )z~ Our L{_WrappingProtocol} does not provide L{IHalfCloseableProtocol} if the wrapped protocol doesn't. N)rL r r� � assertFalser r� r �rR �tpr� rS rS rT �.test_wrappingProtocolNotFileDescriptorReceiver� s zCWrappingFactoryTests.test_wrappingProtocolNotFileDescriptorReceiverc C s@ t � }t�t�� |�}|�t� � |�d� | �|j dg� dS )z� L{_WrappingProtocol.fileDescriptorReceived} calls the wrapped protocol's C{fileDescriptorReceived} method. �* N) rl r r� r �Deferredr� r. rn rz rm )rR ZwrappedProtocolr� rS rS rT �*test_wrappedProtocolFileDescriptorReceived� s z?WrappingFactoryTests.test_wrappedProtocolFileDescriptorReceivedc C s0 t � }t� }t�||�}| �tj�|�d� dS )zw Our L{_WrappingProtocol} should be an L{IHalfCloseableProtocol} if the C{wrappedProtocol} is. TN)r� rf r r� rz r �IHalfCloseableProtocolr )rR �cd�hcpr� rS rS rT �"test_wrappingProtocolHalfCloseable� s z7WrappingFactoryTests.test_wrappingProtocolHalfCloseablec C s* t � }t�d|�}| �tj�|�d� dS )z� Our L{_WrappingProtocol} should not provide L{IHalfCloseableProtocol} if the C{WrappedProtocol} doesn't. NF)rL r r� rz r r� r r� rS rS rT �%test_wrappingProtocolNotHalfCloseable� s z:WrappingFactoryTests.test_wrappingProtocolNotHalfCloseablec C s( t � }t�d|�}| �tj�|�� dS )zs Our L{_WrappingProtocol} should be an L{IHandshakeListener} if the C{wrappedProtocol} is. N)ro r r� r� r �IHandshakeListenerr )rR ZhandshakeListener�wrappedrS rS rT �&test_wrappingProtocolHandshakeListener� s z;WrappingFactoryTests.test_wrappingProtocolHandshakeListenerc C s( t � }t�d|�}| �tj�|�� dS )z~ Our L{_WrappingProtocol} should not provide L{IHandshakeListener} if the C{wrappedProtocol} doesn't. N)rL r r� r� r r� r r� rS rS rT �)test_wrappingProtocolNotHandshakeListener� s z>WrappingFactoryTests.test_wrappingProtocolNotHandshakeListenerc C s* t � }t�d|�}|�� | �|j� dS )z~ L{_WrappingProtocol.readConnectionLost} should proxy to the wrapped protocol's C{readConnectionLost} N)rf r r� rj r� rg �rR r� r� rS rS rT �&test_wrappedProtocolReadConnectionLost� s z;WrappingFactoryTests.test_wrappedProtocolReadConnectionLostc C s* t � }t�d|�}|�� | �|j� dS )z� L{_WrappingProtocol.writeConnectionLost} should proxy to the wrapped protocol's C{writeConnectionLost} N)rf r r� rk r� rh r� rS rS rT �'test_wrappedProtocolWriteConnectionLost� s z<WrappingFactoryTests.test_wrappedProtocolWriteConnectionLostc C s, t � }t�d|�}|�� | �|jd� dS )z~ L{_WrappingProtocol.handshakeCompleted} should proxy to the wrapped protocol's C{handshakeCompleted} NrY )ro r r� rq rz rp )rR Zlistenerr� rS rS rT �&test_wrappedProtocolHandshakeCompleted� s z;WrappingFactoryTests.test_wrappedProtocolHandshakeCompletedN)rb rc rd re r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rS rS rS rT rx � s, rx c @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dS )�ClientEndpointTestCaseMixin�Q Generic test methods to be mixed into all client endpoint test classes. c C s0 t � }| �t� |�\}}}| �ttj|�� dS )zK The endpoint provides L{interfaces.IStreamClientEndpoint} N)r� �createClientEndpoint� MemoryReactorr� r r ZIStreamClientEndpoint)rR � clientFactory�ep� ignoredArgs�addressrS rS rT �test_interface� s � z*ClientEndpointTestCaseMixin.test_interfacec C s | � |�d d S )z� Retrieve a single factory that has connected using the given reactor. (This behavior is valid for TCP and SSL but needs to be overridden for UNIX.) @param reactor: a L{MemoryReactor} r r� ��expectedClients�rR r rS rS rT �retrieveConnectedFactory� s z4ClientEndpointTestCaseMixin.retrieveConnectedFactoryc s� t � }t� }t � }| �||�\}}}|�|�}g � � fdd�}|�|� | �|�} | j�|� | �� |g� | � |�} | �t | �d� | � | d |� dS )z} A client endpoint can connect and returns a deferred who gets called back with a protocol instance. c s � � | � d S r[ r� �r� �ZreceivedProtosrS rT � checkProto s zKClientEndpointTestCaseMixin.test_endpointConnectSuccess.<locals>.checkProtorY r N) r� r� r� �connectr� r� r� �callbackrz r� �len�assertConnectArgs� rR �proto�mreactorr� r� � expectedArgs� ignoredDestr� r� r} r� rS r� rT �test_endpointConnectSuccess� s � z7ClientEndpointTestCaseMixin.test_endpointConnectSuccessc sd t jdd�}t|d�}t� }| �||�\}}}|�|�}g � � fdd�}|�|� | �� |g� dS )�t If an endpoint tries to connect to a non-listening port it gets a C{ConnectError} failure. �Connection Failedr� ��connectExceptionc s � � | j� d S r[ �r\ �valuer� �ZreceivedExceptionsrS rT � checkFailure2 s zMClientEndpointTestCaseMixin.test_endpointConnectFailure.<locals>.checkFailureN)r r� r- r� r� r� r� rz ) rR � expectedErrorr� r� r� r� r� r� r� rS r� rT �test_endpointConnectFailure s � z7ClientEndpointTestCaseMixin.test_endpointConnectFailurec s� t � }t� }| �||�\}}}|�|�}g � � fdd�}|�|� |�� | �|�}|�dtt � � �� | � t � �d� � d } | � | jt j� | � | jj|� dS )�� Calling L{Deferred.cancel} on the L{Deferred} returned from L{IStreamClientEndpoint.connect} is errbacked with an expected L{ConnectingCancelledError} exception. c s � � | � d S r[ r� r� �ZreceivedFailuresrS rT r� I s zRClientEndpointTestCaseMixin.test_endpointConnectingCancelled.<locals>.checkFailureNrY r )r� r� r� r� r� �cancelr� r� r8 r � UserErrorrz r� �assertIsInstancer� r! r� ) rR r� r� r� r� r� r� r� �attemptFactory�failurerS r� rT � test_endpointConnectingCancelled9 s z<ClientEndpointTestCaseMixin.test_endpointConnectingCancelledc C sb t � }t� }| j||fi | �� ��\}}}|�|� | �|�}| �t|�d� | �|d |� dS )zn The endpoint should pass it's connectArgs parameter to the reactor's listen methods. rY r N) r� r� r� � connectArgsr� r� rz r� r� )rR r} r� r� r� � ignoredHostr� rS rS rT �"test_endpointConnectNonDefaultArgs\ s �� z>ClientEndpointTestCaseMixin.test_endpointConnectNonDefaultArgsN) rb rc rd re r� r� r� r� r� r� rS rS rS rT r� � s #r� c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) �ServerEndpointTestCaseMixinr� c C s0 t � }| �t� |�\}}}| �ttj|�� dS )zL The endpoint provides L{interfaces.IStreamServerEndpoint}. N)r� �createServerEndpointr� r� r r ZIStreamServerEndpoint)rR r} r� r� r� rS rS rT r� v s � z*ServerEndpointTestCaseMixin.test_interfacec sh t � }t� }| �||�\}}}|�|�}g � � fdd�}|�|� | �� |g� | �| �|�|g� dS )zs An endpoint can listen and returns a deferred that gets called back with a port instance. c s � � | �� � d S r[ )r\ �getHost)�port�Z receivedHostsrS rT �checkPortAndServer� s zRServerEndpointTestCaseMixin.test_endpointListenSuccess.<locals>.checkPortAndServerN)r� r� r� �listenr� rz �expectedServers)rR r� r} r� r� � expectedHostr� r� rS r� rT �test_endpointListenSuccess� s z6ServerEndpointTestCaseMixin.test_endpointListenSuccessc sh t � }t�dd|�}t|d�}| �||�\}}}|�t � �}g � � fdd�}|�|� | �� |g� dS )z� When an endpoint tries to listen on an already listening port, a C{CannotListenError} failure is errbacked. rK �P )�listenExceptionc s � � | j� d S r[ r� r� r� rS rT r� � s zLServerEndpointTestCaseMixin.test_endpointListenFailure.<locals>.checkFailureN)r� r ZCannotListenErrorr- r� r� r� rz ) rR r} � exceptionr� r� r� r� r� r� rS r� rT �test_endpointListenFailure� s z6ServerEndpointTestCaseMixin.test_endpointListenFailurec C sP t � }t� }| j||fi | �� ��\}}}|�|� | �|�}| �||g� dS )zm The endpoint should pass it's listenArgs parameter to the reactor's listen methods. N)r� r� r� � listenArgsr� r� rz )rR r} r� r� r� r� r� rS rS rT �!test_endpointListenNonDefaultArgs� s �� z=ServerEndpointTestCaseMixin.test_endpointListenNonDefaultArgsN)rb rc rd re r� r r r rS rS rS rT r� q s r� c @ s e Zd ZdZdS )�EndpointTestCaseMixinzJ Generic test methods to be mixed into all endpoint test classes. N�rb rc rd re rS rS rS rT r � s r c @ s e Zd ZdZdd� Zdd� ZdS )�SpecificFactoryz� An L{IProtocolFactory} whose C{buildProtocol} always returns its C{specificProtocol} and sets C{passedAddress}. Raising an exception if C{specificProtocol} has already been used. c C s || _ d S r[ )�specificProtocol)rR r rS rS rT rU � s zSpecificFactory.__init__c C s" t | jd�rtd��|| j_| jS )N� passedAddressz specificProtocol already used.)�hasattrr r� r rt rS rS rT rv � s z SpecificFactory.buildProtocolN)rb rc rd re rU rv rS rS rS rT r � s r c @ s e Zd ZdZddd�ZdS )� FakeStdioz_ A L{stdio.StandardIO} like object that simply captures its constructor arguments. Nc C s || _ || _dS )z� @param protocolInstance: like the first argument of L{stdio.StandardIO} @param reactor: like the reactor keyword argument of L{stdio.StandardIO} N)�protocolInstancer )rR r r rS rS rT rU � s zFakeStdio.__init__)N�rb rc rd re rU rS rS rS rT r � s r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �StandardIOEndpointsTestsz* Tests for Standard I/O Endpoints c C sN t � | _t�| j�}| �|jtj� t|_t � | _ | � |� t | j ���| _dS )z� Construct a L{StandardIOEndpoint} with a dummy reactor and a fake L{stdio.StandardIO} like object. Listening on it with a L{SpecificFactory}. N)r� r r �StandardIOEndpoint�assertIsZ_stdior Z StandardIOr r) r �successResultOfr� r � fakeStdio�rR �endpointrS rS rT �setUp� s �z StandardIOEndpointsTests.setUpc C s( | � | jj| j� | �| jjjt� dS )z� L{StandardIOEndpoint} returns a L{Deferred} that fires with an instance of a L{stdio.StandardIO} like object that was passed the result of L{SpecificFactory.buildProtocol} which was passed a L{PipeAddress}. N)r r r r r� r r* rQ rS rS rT �test_protocolCreation s �z.StandardIOEndpointsTests.test_protocolCreationc C s | � | jj| j� dS )z� L{StandardIOEndpoint} passes its C{reactor} argument to the constructor of its L{stdio.StandardIO} like object. N)r r r rQ rS rS rT �test_passedReactor s z+StandardIOEndpointsTests.test_passedReactorN)rb rc rd re r r r rS rS rS rT r � s r c @ s e Zd ZdZdd� Zdd� ZdS )�StubApplicationProtocolz# An L{IProtocol} provider. c C s || _ dS )zY @param data: The data received by the protocol. @type data: str N)rN r] rS rS rT r^ s z$StubApplicationProtocol.dataReceivedc C s || _ dS )zA @type reason: L{twisted.python.failure.Failure} Nr� r_ rS rS rT ra s z&StubApplicationProtocol.connectionLostN)rb rc rd re r^ ra rS rS rS rT r s r c sZ e Zd ZdZd� fdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z � Z S )�MemoryProcessTransportzC A fake L{IProcessTransport} provider to be used in tests. Nc s. t � jt� t� d� g | _t� | _t� | _d S )N)Z hostAddressZ peerAddress)�superrU r �signals�set�closedChildFDsr) r �rR r �� __class__rS rT rU , s z MemoryProcessTransport.__init__c C s |dkr| � |� d S rM ��write)rR ZchildFDrN rS rS rT � writeToChild2 s z#MemoryProcessTransport.writeToChildc C s | � d� d S rM �� closeChildFDrQ rS rS rT � closeStdin6 s z!MemoryProcessTransport.closeStdinc C s | � d� d S rX r' rQ rS rS rT � closeStdout9 s z"MemoryProcessTransport.closeStdoutc C s | � d� d S )Nr� r' rQ rS rS rT � closeStderr< s z"MemoryProcessTransport.closeStderrc C s | j �|� d S r[ )r �add)rR �fdrS rS rT r( ? s z#MemoryProcessTransport.closeChildFDc C s | j �|� d S r[ )r r\ )rR �signalrS rS rT � signalProcessB s z$MemoryProcessTransport.signalProcessc C s d S r[ rS rQ rS rS rT �pidE s zMemoryProcessTransport.pid)N) rb rc rd re rU r& r) r* r+ r( r/ r0 � __classcell__rS rS r" rT r & s r c @ s( e Zd ZdZdi dddddfdd�ZdS )�MemoryProcessReactorzA A fake L{IReactorProcess} provider to be used in tests. rS Nr c C sR || _ || _|| _|| _|| _|| _|| _|| _| | _t � | _ | j � | j � | j S )z� @ivar processProtocol: Stores the protocol passed to the reactor. @return: An L{IProcessTransport} provider. ) �processProtocol� executabler� �env�path�uid�gid�usePTY�childFDsr �processTransportr� ) rR r3 r4 r� r5 r6 r7 r8 r9 r: rS rS rT � spawnProcessU s z!MemoryProcessReactor.spawnProcess)rb rc rd re r< rS rS rS rT r2 O s �r2 c @ sP e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dS )�ProcessEndpointsTestsz, Tests for child process endpoints. c C s. t � | _t�| jd�| _t�� | _t| j_d S �N� /bin/executable) r2 r r �ProcessEndpointr� r r( r} r rQ rS rS rT r y s zProcessEndpointsTests.setUpc C s� | � | jjt� | �| jjd� | �| jjd� | �| jji � | �| jj � | �| jj � | �| jj � | �| jj d� | �| jj � | �| jjtj� dS )zU Default values are set for the optional parameters in the endpoint. r? rS r N)r� r� �_reactorr2 rz � _executable�_args�_envr� �_path�_uid�_gid�_usePTY� _childFDs�_errFlagr ZLOGrQ rS rS rT �test_constructorDefaults s z.ProcessEndpointsTests.test_constructorDefaultsc C s� ddi}t �t� ddgd|d idddddd d d �tj� }| �|jt� | �|jd� | �|j dg� | �|j d|d i� | �|j d� | �|j d� | �|j d� | �|j� | �|jdd d d �� | �|jtj� dS ) zI The parameters passed to the endpoint are stored in it. � HOMENr? � /runProcessHere/rY r� T�w�r�r� � � )r r@ r2 r �DROPr� rA rz rB rC rD rE rF rG r� rH rI rJ )rR �environr� rS rS rT �test_constructorNonDefaults� s. � z1ProcessEndpointsTests.test_constructorNonDefaultsc C s2 | j �| j�}| �|� | jj}| �|tj� dS )z� The wrapper function _WrapIProtocol gives an IProcessProtocol implementation that wraps over an IProtocol. N) r� r� r} r r r3 r� r �_WrapIProtocol�rR r� ZwpprS rS rT �test_wrappedProtocol� s z*ProcessEndpointsTests.test_wrappedProtocolc C s� ddi}t � }t�|ddgd|d idddddd d d �� }|�| j�}| �|� | �|jtj� | � |j |j � | � |j |j � | � |j|j� | � |j|j� | � |j|j� | � |j|j� | � |j|j� | � |j|j� dS ) z� The parameters for spawnProcess stored in the endpoint are passed when the endpoint's connect method is invoked. rL Nr? rM rY r� TrN rO rP )r2 r r@ r� r} r r� r3 rV rz r4 rB r� rC r5 rD r6 rE r7 rF r8 rG r9 rH r: rI )rR rT � memoryReactorr� r� rS rS rT �test_spawnProcess� s0 � z'ProcessEndpointsTests.test_spawnProcessc C s@ G dd� dt j�}|� }| j�|�}| �|� | �|jt� dS )zz The address passed to the factory's buildProtocol in the endpoint is a _ProcessAddress instance. c @ s e Zd ZeZdZdd� ZdS )zBProcessEndpointsTests.test_processAddress.<locals>.TestAddrFactoryNc S s || _ | �� }| |_|S r[ )r� r r} )rR ru r� rS rS rT rv � s zPProcessEndpointsTests.test_processAddress.<locals>.TestAddrFactory.buildProtocol)rb rc rd r r r� rv rS rS rS rT �TestAddrFactory� s r[ N)r r( r� r� r r� r� r )rR r[ Z myFactoryr� rS rS rT �test_processAddress� s z)ProcessEndpointsTests.test_processAddressc C s$ | � | j�| j��}| �|t� dS )zd L{ProcessEndpoint.connect} returns a Deferred with the connected protocol. N)r r� r� r} r� r )rR r� rS rS rT � test_connect� s z"ProcessEndpointsTests.test_connectc C s6 dd� }|| j _| j �| j�}| �|�}|�t� dS )zg In case of failure, L{ProcessEndpoint.connect} returns a Deferred that fails. c S s t � �d S r[ )� Exception) �ppr4 r� r5 r6 r7 r8 r9 r: rS rS rT �testSpawnProcess� s zCProcessEndpointsTests.test_connectFailure.<locals>.testSpawnProcessN)r� Z _spawnProcessr� r} r� Ztrapr^ )rR r` r� r rS rS rT �test_connectFailure� s z)ProcessEndpointsTests.test_connectFailureN) rb rc rd re r rK rU rX rZ r\ r] ra rS rS rS rT r= t 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"S )#� ProcessEndpointTransportTestsze Test the behaviour of the implementation detail L{endpoints._ProcessEndpointTransport}. c C sF t � | _t�| jd�| _| �| j�t�t ���}| jj | _ |j | _ d S r> )r2 r r r@ r r r� r( � forProtocolr) r; �processr� �endpointTransportr! rS rS rT r s � z#ProcessEndpointTransportTests.setUpc C s t t| j� dS )zE L{_ProcessEndpointTransport}s provide L{IConsumer}. N)r r" re rQ rS rS rT �test_verifyConsumer s z1ProcessEndpointTransportTests.test_verifyConsumerc C s t t| j� dS )zI L{_ProcessEndpointTransport}s provide L{IPushProducer}. N)r r$ re rQ rS rS rT �test_verifyProducer s z1ProcessEndpointTransportTests.test_verifyProducerc C s t t| j� dS )zF L{_ProcessEndpointTransport}s provide L{ITransport}. N)r r& re rQ rS rS rT �test_verifyTransport s z2ProcessEndpointTransportTests.test_verifyTransportc C s | � | jj| j� dS )zd The L{_ProcessEndpointTransport} instance stores the process passed to it. N)r re Z_processrd rQ rS rS rT �test_constructor$ s z.ProcessEndpointTransportTests.test_constructorc C s> t t�G dd� d��}|� }| j�|d� | �| jj|� dS )z� Registering a producer with the endpoint transport registers it with the underlying process transport. c @ s e Zd ZdS )zFProcessEndpointTransportTests.test_registerProducer.<locals>.AProducerNr� rS rS rS rT � AProducer1 s rj FN)r r$ re ZregisterProducerr rd �producer)rR rj Z aProducerrS rS rT �test_registerProducer+ s z3ProcessEndpointTransportTests.test_registerProducerc C s | j �� | �| jjd� dS )zY Pausing the endpoint transport pauses the underlying process transport. ZpausedN)re ZpauseProducingrz rd � producerStaterQ rS rS rT �test_pauseProducing9 s z1ProcessEndpointTransportTests.test_pauseProducingc C s& | � � | j�� | �| jjd� dS )zc Resuming the endpoint transport resumes the underlying process transport. Z producingN)rn re ZresumeProducingrz rd rm rQ rS rS rT �test_resumeProducing@ s z2ProcessEndpointTransportTests.test_resumeProducingc C s | j �� | �| jjd� dS )zo Stopping the endpoint transport as a producer stops the underlying process transport. �stoppedN)re Z stopProducingrz rd rm rQ rS rS rT �test_stopProducingI s z0ProcessEndpointTransportTests.test_stopProducingc C s$ | � � | j�� | �| jj� dS )z� Unregistring the endpoint transport's producer unregisters the underlying process transport's producer. N)rl re ZunregisterProducerr� rd rk rQ rS rS rT �test_unregisterProducerQ s z5ProcessEndpointTransportTests.test_unregisterProducerc C s g | j _| �tt| jd� dS )z� L{endpoints._ProcessEndpointTransport} filters out extraneous attributes of its underlying transport, to present a more consistent cross-platform view of subprocesses and prevent accidental dependencies. �pipesN)rd rs � assertRaises�AttributeError�getattrre rQ rS rS rT �test_extraneousAttributesZ s z7ProcessEndpointTransportTests.test_extraneousAttributesc C s( | j �g d�� | �| jj�� d� dS )z� The writeSequence method of L{_ProcessEndpointTransport} writes a list of string passed to it to the transport's stdin. )s test1s test2s test3s test1test2test3N)re � writeSequencerz rd �io�getvaluerQ rS rS rT �test_writeSequenced s z0ProcessEndpointTransportTests.test_writeSequencec C s$ | j �d� | �| jj�� d� dS )z� The write method of L{_ProcessEndpointTransport} writes a string of data passed to it to the child process's stdin. s testN)re r% rz rd ry rz rQ rS rS rT � test_writel s z(ProcessEndpointTransportTests.test_writec C s | j �� | �| jj� dS )z� A call to the loseConnection method of a L{_ProcessEndpointTransport} instance returns a call to the process transport's loseConnection. N)re ZloseConnectionr� rd � connectedrQ rS rS rT �test_loseConnectiont s z1ProcessEndpointTransportTests.test_loseConnectionc C s, | j �� }| �|t� | �|| j�� � dS )z� L{_ProcessEndpointTransport.getHost} returns a L{_ProcessAddress} instance matching the process C{getHost}. N)re r� r� r r rd )rR �hostrS rS rT � test_getHost| s z*ProcessEndpointTransportTests.test_getHostc C s, | j �� }| �|t� | �|| j�� � dS )z� L{_ProcessEndpointTransport.getPeer} returns a L{_ProcessAddress} instance matching the process C{getPeer}. N)re ZgetPeerr� r r rd )rR ZpeerrS rS rT � test_getPeer� s z*ProcessEndpointTransportTests.test_getPeerN)rb rc rd re r rf rg rh ri rl rn ro rq rr rw r{ r| r~ r� r� rS rS rS rT rb s" rb c @ sX e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dS )�WrappedIProtocolTestszL Test the behaviour of the implementation detail C{_WrapIProtocol}. c C s4 t � | _t�| jd�| _d | _t�� | _t | j_d S r> ) r2 r r r@ r� �eventLogr r( r} r rQ rS rS rT r � s zWrappedIProtocolTests.setUpc C sD | j �| j�}| �|� | jj}| �|jt� | � |j | j j � dS )zQ Stores an L{IProtocol} provider and the flag to log/drop stderr N) r� r� r} r r r3 r� r r rz ZerrFlagrJ rW rS rS rT ri � s z&WrappedIProtocolTests.test_constructorc C s6 | j �| j�}| �|� | jj}| �|jj|j� dS )zx Our process transport is properly hooked up to the wrappedIProtocol when a connection is made. N) r� r� r} r r r3 rz r r� rW rS rS rT �test_makeConnection� s z)WrappedIProtocolTests.test_makeConnectionc C s || _ dS )z! A log observer. N)r� )rR Z eventDictrS rS rT �_stdLog� s z WrappedIProtocolTests._stdLogc C s� | j �| j�}| �|� | jj}t�| j� | � tj | j� |� dd� | � | j d |j� | � | j d d� | � | j d |j� | �dt�| j �� dS )z� When the _errFlag is set to L{StandardErrorBehavior.LOG}, L{endpoints._WrapIProtocol} logs stderr (in childDataReceived). r� s stderr1r4 rN r zwrote stderr unhandled byN)r� r� r} r r r3 r5 � addObserverr� � addCleanup�removeObserver�childDataReceivedrz r� r4 r �assertInZtextFromEventDictrW rS rS rT �test_logStderr� s z$WrappedIProtocolTests.test_logStderrc C sb t j| j_| j�| j�}| �|� | jj}t � | j � | � t j | j � |�dd� | �| j� dS )z� When the _errFlag is set to L{StandardErrorBehavior.DROP}, L{endpoints._WrapIProtocol} ignores stderr. r� s stderr2N)r rS r� rJ r� r} r r r3 r5 r� r� r� r� r� r� r� rW rS rS rT �test_stderrSkip� s z%WrappedIProtocolTests.test_stderrSkipc C s@ | j �| j�}| �|� | jj}|�dd� | �|jj d� dS )z� In childDataReceived of L{_WrappedIProtocol} instance, the protocol's dataReceived is called when stdout is generated. rY s stdoutN) r� r� r} r r r3 r� rz r rN rW rS rS rT � test_stdout� s z!WrappedIProtocolTests.test_stdoutc C sR | j �| j�}| �|� | jj}|�tt� d��� | � |j j � tj�tj� dS )z� L{error.ProcessDone} with status=0 is turned into a clean disconnect type, i.e. L{error.ConnectionDone}. r N)r� r� r} r r r3 � processEndedr8 r Z ProcessDonerz r r` �checkZConnectionDonerW rS rS rT �test_processDone� s �z&WrappedIProtocolTests.test_processDonec C sP | j �| j�}| �|� | jj}|�tt� � �� | � |j j � tj�tj� dS )z{ Exceptions other than L{error.ProcessDone} with status=0 are turned into L{error.ConnectionLost}. N)r� r� r} r r r3 r� r8 r ZProcessTerminatedrz r r` r� ZConnectionLostrW rS rS rT �test_processEnded� s �z'WrappedIProtocolTests.test_processEndedN) rb rc rd re r ri r� r� r� r� r� r� r� rS rS rS rT r� � s r� c @ sH e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dS )�TCP4EndpointsTestsz' Tests for TCP IPv4 Endpoints. c C s |j S �zD @return: List of calls to L{IReactorTCP.listenTCP} �Z tcpServersr� rS rS rT r� s z"TCP4EndpointsTests.expectedServersc C s |j S �zE @return: List of calls to L{IReactorTCP.connectTCP} �� tcpClientsr� rS rS rT r� s z"TCP4EndpointsTests.expectedClientsc C sP |\}}}}}|\}} } } } | � ||� | � || � | � || � | � || � dS �a] Compare host, port, timeout, and bindAddress in C{receivedArgs} to C{expectedArgs}. We ignore the factory because we don't only care what protocol comes out of the C{IStreamClientEndpoint.connect} call. @param receivedArgs: C{tuple} of (C{host}, C{port}, C{factory}, C{timeout}, C{bindAddress}) that was passed to L{IReactorTCP.connectTCP}. @param expectedArgs: C{tuple} of (C{host}, C{port}, C{factory}, C{timeout}, C{bindAddress}) that we expect to have been passed to L{IReactorTCP.connectTCP}. N�rz � rR � receivedArgsr� r r� �ignoredFactory�timeout� bindAddressr � expectedPort�_ignoredFactory�expectedTimeout�expectedBindAddressrS rS rT r� s � z$TCP4EndpointsTests.assertConnectArgsc C s ddd�S ��K @return: C{dict} of keyword arguments to pass to connect. � �� localhosti�� �r� r� rS rQ rS rS rT r� + s z TCP4EndpointsTests.connectArgsc C s ddd�S ��I @return: C{dict} of keyword arguments to pass to listen �d � 127.0.0.1��backlog� interfacerS rQ rS rS rT r 1 s z TCP4EndpointsTests.listenArgsc K sB t ddd�}tj||jfi |��|j||�dd�|�dd�f|fS )a� Create an L{TCP4ServerEndpoint} and return the values needed to verify its behaviour. @param reactor: A fake L{IReactorTCP} that L{TCP4ServerEndpoint} can call L{IReactorTCP.listenTCP} on. @param factory: The thing that we expect to be passed to our L{IStreamServerEndpoint.listen} implementation. @param listenArgs: Optional dictionary of arguments to L{IReactorTCP.listenTCP}. �TCP�0.0.0.0r r� �2 r� rK )r r �TCP4ServerEndpointr� �get�rR r r} r r� rS rS rT r� 7 s ��z'TCP4EndpointsTests.createServerEndpointc K sJ t ddd�}tj||j|jfi |��|j|j||�dd�|�dd�f|fS )a� Create an L{TCP4ClientEndpoint} and return the values needed to verify its behavior. @param reactor: A fake L{IReactorTCP} that L{TCP4ClientEndpoint} can call L{IReactorTCP.connectTCP} on. @param clientFactory: The thing that we expect to be passed to our L{IStreamClientEndpoint.connect} implementation. @param connectArgs: Optional dictionary of arguments to L{IReactorTCP.connectTCP} r� r� r r� � r� N)r r �TCP4ClientEndpointr r� r� �rR r r� r� r� rS rS rT r� P s �� ��z'TCP4EndpointsTests.createClientEndpointN� rb rc rd re r� r� r� r� r r� r� rS rS rS rT r� � s r� c @ sH e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dS )�TCP6EndpointsTestsz' Tests for TCP IPv6 Endpoints. c C s |j S r� r� r� rS rS rT r� r s z"TCP6EndpointsTests.expectedServersc C s |j S r� r� r� rS rS rT r� x s z"TCP6EndpointsTests.expectedClientsc C sP |\}}}}}|\}} } } } | � ||� | � || � | � || � | � || � dS r� r� r� rS rS rT r� ~ s � z$TCP6EndpointsTests.assertConnectArgsc C s ddd�S r� rS rQ rS rS rT r� � s z TCP6EndpointsTests.connectArgsc C s ddd�S )r� r� �::1r� rS rQ rS rS rT r � s z TCP6EndpointsTests.listenArgsc K sF |� dd�}td|d�}tj||jfi |��|j||� dd�|f|fS )a� Create a L{TCP6ServerEndpoint} and return the values needed to verify its behaviour. @param reactor: A fake L{IReactorTCP} that L{TCP6ServerEndpoint} can call L{IReactorTCP.listenTCP} on. @param factory: The thing that we expect to be passed to our L{IStreamServerEndpoint.listen} implementation. @param listenArgs: Optional dictionary of arguments to L{IReactorTCP.listenTCP}. r� z::r� r r� r� )r� r r �TCP6ServerEndpointr� )rR r r} r r� r� rS rS rT r� � s �z'TCP6EndpointsTests.createServerEndpointc K sJ t ddd�}tj||j|jfi |��|j|j||�dd�|�dd�f|fS )�� Create a L{TCP6ClientEndpoint} and return the values needed to verify its behavior. @param reactor: A fake L{IReactorTCP} that L{TCP6ClientEndpoint} can call L{IReactorTCP.connectTCP} on. @param clientFactory: The thing that we expect to be passed to our L{IStreamClientEndpoint.connect} implementation. @param connectArgs: Optional dictionary of arguments to L{IReactorTCP.connectTCP} r� r� r r� r� r� N)r r �TCP6ClientEndpointr r� r� r� rS rS rT r� � s �� ��z'TCP6EndpointsTests.createClientEndpointNr� rS rS rS rT r� m s r� c @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dS )� TCP6EndpointNameResolutionTestszl Tests for a TCP IPv6 Client Endpoint pointed at a hostname instead of an IPv6 address literal. c sd t ddd�}tj|d|jfi |��� _� fdd�}|� j_� j|j|j||�dd�|�d d �f|fS ) r� r� �::2r �ipv6.example.comc s> � � d| � tttddftttddftttddfg}t�|�S )Nr� rK )r� r r r )z::3r r r )z::4r r r )rz r r r r �succeed)r rN rQ rS rT �testNameResolution� s �zPTCP6EndpointNameResolutionTests.createClientEndpoint.<locals>.testNameResolutionr� r� r� N)r r r� r� r� Z_nameResolutionr r� )rR r r� r� r� r� rS rQ rT r� � s" �� ��z4TCP6EndpointNameResolutionTests.createClientEndpointc C s ddd�S r� rS rQ rS rS rT r� s z+TCP6EndpointNameResolutionTests.connectArgsc C s |j S r� r� r� rS rS rT r� s z/TCP6EndpointNameResolutionTests.expectedClientsc C sP |\}}}}}|\}} } } } | � ||� | � || � | � || � | � || � dS r� r� r� rS rS rT r� s � z1TCP6EndpointNameResolutionTests.assertConnectArgsc C s" t �ddd�}| �|jtj� dS )zg By default, L{TCP6ClientEndpoint._deferToThread} is L{threads.deferToThread}. Nzwww.example.com�� )r r� rz �_deferToThreadr Z deferToThread�rR r� rS rS rT � test_freeFunctionDeferToThread. s z>TCP6EndpointNameResolutionTests.test_freeFunctionDeferToThreadc sZ g � � fdd�}t �tdd�}t� }||_||_|�t� � | �|ddt fi fg� � dS )zl While resolving hostnames, _nameResolution calls _deferToThread with _getaddrinfo. c s � � | ||f� t�� S r[ )r\ r r� )r� r� �kwargs�ZcallsrS rT �fakeDeferToThread= s zNTCP6EndpointNameResolutionTests.test_nameResolution.<locals>.fakeDeferToThreadr� r� r N) r r� r r� � _getaddrinfor� r� rr rz r )rR r� r �fakegetaddrinforS r� rT �test_nameResolution6 s �z3TCP6EndpointNameResolutionTests.test_nameResolutionN) rb rc rd re r� r� r� r� r� r� rS rS rS rT r� � s ( r� c @ s e Zd ZdZddd�ZdS )� RaisingMemoryReactorWithClockzE An extension of L{RaisingMemoryReactor} with L{task.Clock}. Nc C s t �| � t�| ||� d S r[ )r+ rU r- )rR r r� rS rS rT rU P s z&RaisingMemoryReactorWithClock.__init__)NNr rS rS rS rT r� K s r� rS c sf �du r i ��� � �tt�G ��fdd�d��� tt�G � fdd�dttdtt| ������}|| �S )ap Create a reactor that will deterministically resolve all hostnames it is passed to the list of addresses given. @param reactor: An object that we wish to add an L{IReactorPluggableNameResolver} to. @type reactor: Any object with some formally-declared interfaces (i.e. one where C{list(providedBy(reactor))} is not empty); usually C{IReactor*} interfaces. @param expectedAddresses: (optional); the addresses expected to be returned for every address. If these are strings, they should be IPv4 or IPv6 literals, and they will be wrapped in L{IPv4Address} and L{IPv6Address} objects in the resolution result. @type expectedAddresses: iterable of C{object} or C{str} @param hostMap: (optional); the names (unicode) mapped to lists of addresses (str or L{IAddress}); in the same format as expectedAddress, which map the results for I{specific} hostnames to addresses. @return: A new reactor which provides all the interfaces previously provided by C{reactor} as well as L{IReactorPluggableNameResolver}. All name resolutions performed with its C{nameResolver} attribute will resolve reentrantly and synchronously with the given C{expectedAddresses}. However, it is not a complete implementation as it does not have an C{installNameResolver} method. Nc s e Zd Zed� �fdd� �ZdS )z9deterministicResolvingReactor.<locals>.SimpleNameResolverr Nr� c sT | � d � ��|� �D ]0}t|t�r<ttgt|� d||�}| �|� q| �� d S )Nr� ) �resolutionBeganr� � isinstance�strr r r �addressResolved�resolutionComplete)ZresolutionReceiver�hostName� portNumberZ addressTypesZtransportSemantics�expectedAddress��expectedAddresses�hostMaprS rT �resolveHostNamew s �� zIdeterministicResolvingReactor.<locals>.SimpleNameResolver.resolveHostName)r Nr� )rb rc rd � staticmethodr� rS r� rS rT �SimpleNameResolveru s �r� c s e Zd Z� � ZdS )z3deterministicResolvingReactor.<locals>.WithResolverN)rb rc rd Z nameResolverrS )r� rS rT � WithResolver� s r� �*)�copyr r# r% r7 r �tupler )r r� r� r� rS )r� r� r� rT � deterministicResolvingReactorU s �r� c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) �SimpleHostnameResolverTestsa� Tests for L{endpoints._SimpleHostnameResolver}. @ivar fakeResolverCalls: Arguments with which L{fakeResolver} was called. @type fakeResolverCalls: L{list} of C{(hostName, port)} L{tuple}s. @ivar fakeResolverReturns: The return value of L{fakeResolver}. @type fakeResolverReturns: L{Deferred} @ivar resolver: The instance to test. @type resolver: L{endpoints._SimpleHostnameResolver} @ivar resolutionBeganCalls: Arguments with which receiver's C{resolutionBegan} method was called. @type resolutionBeganCalls: L{list} @ivar addressResolved: Arguments with which C{addressResolved} was called. @type addressResolved: L{list} @ivar resolutionCompleteCallCount: The number of calls to the receiver's C{resolutionComplete} method. @type resolutionCompleteCallCount: L{int} @ivar receiver: A L{interfaces.IResolutionReceiver} provider. c sV g � _ t�� � _t�� j�� _g � _g � _ d� _ t t j �G � fdd�d��}|� _d S )Nr c s< e Zd Ze� fdd��Ze� fdd��Ze� fdd��ZdS )z4SimpleHostnameResolverTests.setUp.<locals>._Receiverc s � j �| � d S r[ )�resolutionBeganCallsr\ )ZresolutionInProgressrQ rS rT r� � s zDSimpleHostnameResolverTests.setUp.<locals>._Receiver.resolutionBeganc s � j �| � d S r[ )�addressResolvedCallsr\ )r� rQ rS rT r� � s zDSimpleHostnameResolverTests.setUp.<locals>._Receiver.addressResolvedc s � j d7 _ d S rX )�resolutionCompleteCallCountrS rQ rS rT r� � s zGSimpleHostnameResolverTests.setUp.<locals>._Receiver.resolutionCompleteN)rb rc rd r� r� r� r� rS rQ rS rT � _Receiver� s r� )�fakeResolverCallsr r� �fakeResolverReturnsr Z_SimpleHostnameResolver� fakeResolver�resolverr� r� r� r r ZIResolutionReceiver�receiver)rR r� rS rQ rT r � s z!SimpleHostnameResolverTests.setUpc C s | j �||f� | jS )z� A fake resolver callable. @param hostName: The hostname to resolve. @param portNumber: The port number the returned address should include. @return: L{fakeResolverCalls} @rtype: L{Deferred} )r� r\ r� )rR r� r� rS rS rT r� � s z(SimpleHostnameResolverTests.fakeResolverc C s | � ttj| j�� dS )zs A L{endpoints._SimpleHostnameResolver} instance provides L{interfaces.IHostnameResolver}. N)r� r r r# r� rQ rS rS rT r� � s z*SimpleHostnameResolverTests.test_interfacec s g �t t��fdd��� t�� � | �� fdd�� | j�| jd�}| �|| j� | j � t � � | � dt ��� | � dt | �t ��� �\}| �|�d�� | �|�dd�� | �|�d t| j��� | � dt | j�� | � | jd jd� | �| j� | � d| j� d S ) z� A resolution failure is logged with the name that failed to resolve and the callable that tried to resolve it. The resolution receiver begins, receives no addresses, and completes. c s � � | � d S r[ r� )�event)�logsrS rT � captureLogs� s zHSimpleHostnameResolverTests.test_resolveNameFailure.<locals>.captureLogsc s t �� �S r[ )r1 r� rS )r� rS rT r� � r� zESimpleHostnameResolverTests.test_resolveNameFailure.<locals>.<lambda>� example.comrY ZisError�name�callabler N)r r0 r1 r� r� r� r� r� r r� Zerrbackr^ rz r� �flushLoggedErrorsr� r� �reprr� r� r� r� r� r� )rR r� r� rS )r� r� rT �test_resolveNameFailure� s$ z3SimpleHostnameResolverTests.test_resolveNameFailurec C s� d}d}d}| j �| jd�}| �|| j� | j�tttd||fft ttd||ffg� | � dt | j �� | � | j d j d� | � | jtd||�td||�g� | � | jd� d S ) zs The resolution receiver begins, and resolved hostnames are delivered before it completes. r �1.2.3.4z 1::2::3::4r� rK rY r r� N)r� r� r� r r� r� r r r r rz r� r� r� r� r r r� )rR r� Zipv4HostZipv6Hostr� rS rS rT �test_resolveNameDelivers s" ���z4SimpleHostnameResolverTests.test_resolveNameDeliversN) rb rc rd re r r� r� r� r� rS rS rS rT r� � s #r� c @ s e Zd ZdZdd� ZdS )�+HostnameEndpointFallbackNameResolutionTestszd L{HostnameEndpoint._fallbackNameResolution} defers a name resolution call to a thread. c sJ ddl m} tj|ddd�}d\� �|�� ��}� ��fdd�}|�|�S )z� L{_fallbackNameResolution} returns a L{Deferred} that fires with the resoution of the the host and request port. r )r �ignored)r r� )r� rY c sL �� t| �d� | \\}}}}}�� |t� �� |t� �� |� �f� d S rX )rz r� r r )�result�family�socktype�_Zsockaddr�r r� rR rS rT � assertHostPortFamilySockType0 s zmHostnameEndpointFallbackNameResolutionTests.test_fallbackNameResolution.<locals>.assertHostPortFamilySockType)�twisted.internetr r �HostnameEndpointZ_fallbackNameResolutionr� )rR r r� ZresolutionDeferredr� rS r� rT �test_fallbackNameResolution# s zGHostnameEndpointFallbackNameResolutionTests.test_fallbackNameResolutionN)rb rc rd re r rS rS rS rT r� s r� c @ sH e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dS )�#_HostnameEndpointMemoryReactorMixinz� Common methods for testing L{HostnameEndpoint} against L{MemoryReactor} instances that do not provide L{IReactorPluggableNameResolver}. c O s< z||i |��}W n t y, t�� Y S 0 t�|�S dS )a� A synchronous version of L{deferToThread}. @param f: The callable to invoke. @type f: L{callable} @param args: Positional arguments to the callable. @param kwargs: Keyword arguments to the callable. @return: A L{Deferred} that fires with the result of applying C{f} to C{args} and C{kwargs} or the exception raised. N)� BaseExceptionr r� r� )rR r� r� r� r� rS rS rT �synchronousDeferredToThreadA s z?_HostnameEndpointMemoryReactorMixin.synchronousDeferredToThreadc C s |j S )z� Extract expected clients from the reactor. @param reactor: The L{MemoryReactor} under test. @return: List of calls to L{IReactorTCP.connectTCP} r� r� rS rS rT r� V s z3_HostnameEndpointMemoryReactorMixin.expectedClientsc C s ddd�S )zL @return: C{dict} of keyword arguments to pass to connect. g $@r� r� rS rQ rS rS rT r� ` s z/_HostnameEndpointMemoryReactorMixin.connectArgsc C sP |\}}}}}|\}} } } } | � ||� | � || � | � || � | � || � dS r� r� r� rS rS rT r� g s � z5_HostnameEndpointMemoryReactorMixin.assertConnectArgsc C sn t jdd�}t|d�}t� }| �||�\}}}|�|�}|�tjj � | � | � |�j |� | � g |� � � dS )z� When L{HostnameEndpoint.connect} cannot connect to its destination, the returned L{Deferred} will fail with C{ConnectError}. r� r� r� N�r r� r� r� r� r� �advancer r �_DEFAULT_ATTEMPT_DELAYrz r� r� �getDelayedCalls�rR r� r� r� r� r� r� r� rS rS rT r� � s � z?_HostnameEndpointMemoryReactorMixin.test_endpointConnectFailurec C s` t � }t� }| �||� | �� }| �dt|�� | �t|d d � | �|d d � d�� dS )z� Instantiating L{HostnameEndpoint} with a reactor that does not provide L{IReactorPluggableResolver} emits a deprecation warning. rY r �category�messagez�Passing HostnameEndpoint a reactor that does not provide IReactorPluggableNameResolver (twisted.internet.testing.MemoryReactorClock) was deprecated in Twisted 17.5.0; please use a reactor that provides IReactorPluggableNameResolver insteadN) r� r� r� Z flushWarningsrz r� r �DeprecationWarningr� � startswith)rR r� r� �warningsrS rS rT �test_deprecation� s ��z4_HostnameEndpointMemoryReactorMixin.test_deprecationc C sf t � }t� }| �||�\}}}dd� }||_|�|�}| �| �|�jtj � | � dt | � t ��� dS )z8 Hostname resolution errors are logged. c _ s t dd��d S )N���z#No address associated with hostname)r )r� r� rS rS rT �getaddrinfoThatFails� s zS_HostnameEndpointMemoryReactorMixin.test_errorsLogged.<locals>.getaddrinfoThatFailsrY N)r� r� r� r� r� r� r� r� r �DNSLookupErrorrz r� r� r )rR r� r� r� r� r� r r� rS rS rT �test_errorsLogged� s � z5_HostnameEndpointMemoryReactorMixin.test_errorsLoggedN) rb rc rd re r r� r� r� r� r r rS rS rS rT r : s r c @ s e Zd ZdZdd� ZdS )�&HostnameEndpointMemoryIPv4ReactorTestsz� IPv4 resolution tests for L{HostnameEndpoint} with L{MemoryReactor} subclasses that do not provide L{IReactorPluggableNameResolver}. c sf d� t dd�}tj|d|jfi |��}� fdd�}||_| j|_|� |j||�dd�|�dd �f|fS ) a� Creates a L{HostnameEndpoint} instance where the hostname is resolved into a single IPv4 address. @param reactor: The L{MemoryReactor} @param clientFactory: The client L{IProtocolFactory} @param connectArgs: Additional arguments to L{HostnameEndpoint.connect} @return: A L{tuple} of the form C{(endpoint, (expectedAddress, expectedPort, clientFactory, timeout, localBindAddress, hostnameAddress))} r� � example.comr c s t ttd� dffgS �NrK r )r r r �r r� r� r� �r� rS rT r� � s �zTHostnameEndpointMemoryIPv4ReactorTests.createClientEndpoint.<locals>.fakegetaddrinfor� r� r� N�r r r r� r� r r� r� �rR r r� r� r� r r� rS r rT r� � s& �� ��z;HostnameEndpointMemoryIPv4ReactorTests.createClientEndpointN�rb rc rd re r� rS rS rS rT r � s r c @ s e Zd ZdZdd� ZdS )�&HostnameEndpointMemoryIPv6ReactorTestsz� IPv6 resolution tests for L{HostnameEndpoint} with L{MemoryReactor} subclasses that do not provide L{IReactorPluggableNameResolver}. c sf d� t dd�}tj|d|jfi |��}� fdd�}||_| j|_|� |j||�dd�|�dd �f|fS ) a� Creates a L{HostnameEndpoint} instance where the hostname is resolved into a single IPv6 address. @param reactor: The L{MemoryReactor} @param clientFactory: The client L{IProtocolFactory} @param connectArgs: Additional arguments to L{HostnameEndpoint.connect} @return: A L{tuple} of the form C{(endpoint, (expectedAddress, expectedPort, clientFactory, timeout, localBindAddress, hostnameAddress))} �1:2::3:4� ipv6.example.comr c s t ttd� dffgS r )r r r r r rS rT r� s �zTHostnameEndpointMemoryIPv6ReactorTests.createClientEndpoint.<locals>.fakegetaddrinfor� r� r� Nr r rS r rT r� s& �� ��z;HostnameEndpointMemoryIPv6ReactorTests.createClientEndpointNr rS rS rS rT r � s r c @ sZ e Zd ZdZdd� Zdd� Zdd� Zdd � Zdd d �Zd d� Z dd� Z dd� Z dd� Z d S )� HostnameEndpointsOneIPv4Testsz^ Tests for the hostname based endpoints when GAI returns only one (IPv4) address. c K sT d}t dd�}tjt||g�d|jfi |��}|||j||�dd�|�dd�f|fS )z{ Creates a L{HostnameEndpoint} instance where the hostname is resolved into a single IPv4 address. r� r r r� r� r� N�r r r r� r� r� )rR r r� r� r� r� r rS rS rT r� 7 s$ �� ��z2HostnameEndpointsOneIPv4Tests.createClientEndpointc C s |j S r� r� r� rS rS rT r� Q s z-HostnameEndpointsOneIPv4Tests.expectedClientsc C sP |\}}}}}|\}} } } } | � ||� | � || � | � || � | � || � dS r� r� r� rS rS rT r� W s � z/HostnameEndpointsOneIPv4Tests.assertConnectArgsc C s ddd�S r� rS rQ rS rS rT r� s s z)HostnameEndpointsOneIPv4Tests.connectArgsNc C s� t � }t�� }tj|_| �||�\}}}|�|�}|durD|�|� |�� | �|�}|� dt t � � �� | � |�} | �| jt j� | �| jj|� | �|jd d jj� | �g |�� � dS )z� Calling L{Deferred.cancel} on the L{Deferred} returned from L{IStreamClientEndpoint.connect} will cause it to be errbacked with a L{ConnectingCancelledError} exception. Nr r� )r� r r( r) r� r� r r� r� r� r8 r r� r� r� r� r! rz r� r� r� � _connector�stoppedConnectingr ) rR r r� r� r� r� r� r� r� r� rS rS rT r� y s z>HostnameEndpointsOneIPv4Tests.test_endpointConnectingCancelledc C s$ t jj}||d }| j|d� dS )a Calling L{Deferred.cancel} on the L{Deferred} returned from L{IStreamClientEndpoint.connect} after enough time has passed that all connection attempts have been initiated will cause it to be errbacked with a L{ConnectingCancelledError} exception. g @)r N)r r r r� )rR Z oneBetweenr rS rS rT �7test_endpointConnectingCancelledAfterAllAttemptsStarted� s zUHostnameEndpointsOneIPv4Tests.test_endpointConnectingCancelledAfterAllAttemptsStartedc C sn t jdd�}t|d�}t� }| �||�\}}}|�|�}|�tjj � | � | � |�j |� | � g |� � � dS )z� If L{HostnameEndpoint.connect} is invoked and there is no server listening for connections, the returned L{Deferred} will fail with C{ConnectError}. r� r� r� Nr r rS rS rT r� � s � z9HostnameEndpointsOneIPv4Tests.test_endpointConnectFailurec C s� t jdd�}t� }t� }| �||�\}}}|�|�}|�d� |jd \}} } } } | �|j d |� | � | � |�j |� | � g |� � � dS )a If a connection attempt initiated by L{HostnameEndpoint.connect} fails only after L{HostnameEndpoint} has exhausted the list of possible server addresses, the returned L{Deferred} will fail with C{ConnectError}. r� r� �333333�?r N)r r� r� r� r� r� r r� r� Z connectorsrz r� r� r ) rR r� r� r� r� r� r� r� r r� r} r� r� rS rS rT �)test_endpointConnectFailureAfterIteration� s � zGHostnameEndpointsOneIPv4Tests.test_endpointConnectFailureAfterIterationc s� t � }t� }t � }| �||�\}}}|�|�}g � � fdd�}|�|� | �|�} |�d� | j�|� | � � |g� | � |�} | � t | �d� | � | d |� | � g |� � � dS )a\ If a connection attempt initiated by L{HostnameEndpoint.connect} succeeds only after L{HostnameEndpoint} has exhausted the list of possible server addresses, the returned L{Deferred} will fire with the connected protocol instance and the endpoint will leave no delayed calls in the reactor. c s � � | � d S r[ r� r� r� rS rT r� � s z[HostnameEndpointsOneIPv4Tests.test_endpointConnectSuccessAfterIteration.<locals>.checkProtor$ rY r N)r� r� r� r� r� r� r r� r� rz r� r� r� r r� rS r� rT �)test_endpointConnectSuccessAfterIteration� s$ � zGHostnameEndpointsOneIPv4Tests.test_endpointConnectSuccessAfterIteration)N) rb rc rd re r� r� r� r� r� r# r� r% r& rS rS rS rT r 1 s r c @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dS )� HostnameEndpointsOneIPv6Testsz^ Tests for the hostname based endpoints when GAI returns only one (IPv6) address. c K sP t dd�}tjt|dg�d|jfi |��}|d|j||�dd�|�dd�f|fS )z{ Creates a L{HostnameEndpoint} instance where the hostname is resolved into a single IPv6 address. r r r r� r� r� Nr )rR r r� r� r� r rS rS rT r� � s" �� ��z2HostnameEndpointsOneIPv6Tests.createClientEndpointc C s |j S r� r� r� rS rS rT r� s z-HostnameEndpointsOneIPv6Tests.expectedClientsc C sP |\}}}}}|\}} } } } | � ||� | � || � | � || � | � || � dS r� r� r� rS rS rT r� s � z/HostnameEndpointsOneIPv6Tests.assertConnectArgsc C s ddd�S r� rS rQ rS rS rT r� 9 s z)HostnameEndpointsOneIPv6Tests.connectArgsc C s� t � }t�� }tj|_| �t|dg�|�\}}}|�|�}|�� | �|�}|� dt t � � �� | � |�}| �|jt j� | �|jj|� | �|jd d jj� | �g |�� � dS )r� r� Nr r� )r� r r( r) r� r� r� r� r� r� r8 r r� r� r� r� r! rz r� r� r� r! r" r ) rR r� r� r� r� r� r� r� r� rS rS rT r� ? s � z>HostnameEndpointsOneIPv6Tests.test_endpointConnectingCancelledc C sj t jdd�}t|d�}t� }| �||�\}}}|�|�}|�d� | �| �|�j |� | �g |� � � dS )r� r� r� r� r$ N) r r� r� r� r� r� r rz r� r� r r rS rS rT r� \ s � z9HostnameEndpointsOneIPv6Tests.test_endpointConnectFailureN) rb rc rd re r� r� r� r� r� r� rS rS rS rT r' � s r' c @ s8 e Zd ZdZdZdZdd� Zdd� Zdd � Zd d � Z d S ) �HostnameEndpointIDNATestszJ Tests for L{HostnameEndpoint}'s constructor's encoding behavior. � bücher.chs xn--bcher-kva.chc C s> t �tt� dg�| jd�}| �|j| j� | �|j| j� dS )z� A L{HostnameEndpoint} constructed with text will contain an IDNA-encoded bytes representation of that text. r� r N� r r r� r� �sampleIDNATextrz � _hostBytes�sampleIDNABytes� _hostTextr rS rS rT �test_idnaHostnameTextw s �z/HostnameEndpointIDNATests.test_idnaHostnameTextc C s> t �tt� dg�| jd�}| �|j| j� | �|j| j� dS )z� A L{HostnameEndpoint} constructed with bytes will contain an IDNA-decoded textual representation of those bytes. r� r Nr* r rS rS rT �test_idnaHostnameBytes� s �z0HostnameEndpointIDNATests.test_idnaHostnameBytesc C sD t �tt� dg�td| j�d�}| �|j| j� | �|j | j� dS )z� A L{HostnameEndpoint} constructed with NFD-normalized text will store the NFC-normalized version of that text. r� ZNFDr N) r r r� r� r r+ rz r, r- r. r rS rS rT �test_nonNormalizedText� s �z0HostnameEndpointIDNATests.test_nonNormalizedTextc C s� t �tt� dg�dd�}|�t�t��}| �|t �}| � dt |�� t �tt� dg�dd�}|�t� �}| �|t �}| � dt |�� dS )a& Since any client of L{IStreamClientEndpoint} needs to handle Deferred failures from C{connect}, L{HostnameEndpoint}'s constructor will not raise exceptions when given bad host names, instead deferring to returning a failing L{Deferred} from C{connect}. r� � �-garbage-�r z\xff-garbage-\xffu ⿰-garbage-⿰z\u2ff0-garbage-\u2ff0N) r r r� r� r� r( rc r) r� r� r� r� )rR r �deferred�errrS rS rT � test_deferBadEncodingToConnect� s � � z8HostnameEndpointIDNATests.test_deferBadEncodingToConnectN) rb rc rd re r+ r- r/ r0 r1 r5 rS rS rS rT r( o s r( c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) �HostnameEndpointReprTestsz@ Tests for L{HostnameEndpoint}'s string representation. c C s> t �tt� g �dd�}t|�}| �d|� | �tt|�� dS )z� The string representation of L{HostnameEndpoint} includes the host and port passed to the constructor. r� r z!<HostnameEndpoint example.com:80>N� r r r� r+ r� rz r r� �type�rR r �reprS rS rT � test_allASCII� s � z'HostnameEndpointReprTests.test_allASCIIc C s> t �tt� g �dd�}t|�}| �d|� | �tt|�� dS )z� When IDN is passed to the L{HostnameEndpoint} constructor the string representation includes the punycode version of the host. r) � z'<HostnameEndpoint xn--bcher-kva.ch:443>Nr7 r9 rS rS rT �test_idnaHostname� s � z+HostnameEndpointReprTests.test_idnaHostnamec C s> t �tt� g �dd�}t|�}| �d|� | �tt|�� dS )z� When the host passed to L{HostnameEndpoint} is an IPv6 address it is wrapped in brackets in the string representation, like in a URI. This prevents the colon separating the host from the port from being ambiguous. s ::1� z<HostnameEndpoint [::1]:22>Nr7 r9 rS rS rT �test_hostIPv6Address� s � z.HostnameEndpointReprTests.test_hostIPv6Addressc C s* t �tt� g �dd�}| �dt|�� dS )z� When a bad hostname is passed to L{HostnameEndpoint}, the string representation displays invalid characters in backslash-escaped form. r2 r z'<HostnameEndpoint \xff-garbage-\xff:80>N)r r r� r+ rz r� r rS rS rT �test_badEncoding� s ��z*HostnameEndpointReprTests.test_badEncodingN)rb rc rd re r; r= r? r@ rS rS rS rT r6 � s r6 c @ s e Zd ZdZdd� ZdS )� HostnameEndpointsGAIFailureTestszM Tests for the hostname based endpoints when GAI returns no address. c C sH t �tt� g �dd�}t� }|�|�}| �|tj�}| � dt |�� dS )z� If no address is returned by GAI for a hostname, the connection attempt fails with L{error.DNSLookupError}. r r r� N) r r r� r+ r� r� r� r r r� r� )rR r r� ZdConnect�excrS rS rT � test_failure s � z-HostnameEndpointsGAIFailureTests.test_failureN)rb rc rd re rC rS rS rS rT rA � s rA c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) �&HostnameEndpointsFasterConnectionTestsz� Tests for the hostname based endpoints when gai returns an IPv4 and an IPv6 address, and one connection takes less time than the other. c C s( t � | _t�t| jddg�dd�| _d S )Nr� r � www.example.comr )r� r� r r r� r rQ rS rS rT r s �z,HostnameEndpointsFasterConnectionTests.setUpc C s� t � | _t�t| jdt� dg�dd�| _d}| j�|� | j�d� | jj d \}}}}}| � t | jj �d� | � |d� | � |d� dS ) z� If an address type other than L{IPv4Address} and L{IPv6Address} is returned by on address resolution, the endpoint ignores that address. r� r rE r Nr$ rY r� ) r� r� r r r� r� r r� r r� rz r� )rR r� r r� r} r� r� rS rS rT � test_ignoreUnknownAddressTypes s �� zEHostnameEndpointsFasterConnectionTests.test_ignoreUnknownAddressTypesc C s� t �� }t j|_ | j�|�}g }|�|j� | jjd \}}}}}| � |d� | � |d� |� ||f�} t � } | � |g � | � | � | � t |�d� | � |d j|� | � g | j�� � dS )a= The endpoint returns a connection to the IPv4 address. IPv4 ought to be the first attempt, since nameResolution (standing in for GAI here) returns it first. The IPv4 attempt succeeds, the connection is established, and a Deferred fires with the protocol constructed. r r� r rY N)r r( r) r r� r� r\ r� r� rz rv r� r� r� r} r � rR r� r� �resultsr r� r} r� r� r� Z fakeTransportrS rS rT �test_IPv4IsFaster5 s z8HostnameEndpointsFasterConnectionTests.test_IPv4IsFasterc C s� t �� }t j|_ | j�|�}g }|�|j� | j�d� | jj d \}}}}}| � |d� | � |d� |� ||f�} t � } | � |g � | � | � | � t|�d� | � |d j|� | � g | j�� � dS )a= The endpoint returns a connection to the IPv6 address. IPv6 ought to be the second attempt, since nameResolution (standing in for GAI here) returns it second. The IPv6 attempt succeeds, a connection is established, and a Deferred fires with the protocol constructed. r$ rY r r r N)r r( r) r r� r� r\ r� r r� rz rv r� r� r� r} r rG rS rS rT �test_IPv6IsFasterT s z8HostnameEndpointsFasterConnectionTests.test_IPv6IsFasterc C s� t �� }t j|_ | j�|�}g }|�|j� | j�d� | jj d \}}}}}|� ||f�} t � } | � | � | � d| jj d d jj� | � g | j�� � dS )a Once the endpoint returns a successful connection, all the other pending connections are cancelled. Here, the second connection attempt, i.e. IPv6, succeeds, and the pending first attempt, i.e. IPv4, is cancelled. r$ rY Tr r� N)r r( r) r r� r� r\ r� r r� rv r� r� rz r! r" r rG rS rS rT � test_otherConnectionsCancelledu s �zEHostnameEndpointsFasterConnectionTests.test_otherConnectionsCancelledN) rb rc rd re r rF rI rJ rK rS rS rS rT rD s !rD c @ sP e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dS )�SSL4EndpointsTestsz" Tests for SSL Endpoints. c C s |j S )zD @return: List of calls to L{IReactorSSL.listenSSL} )Z sslServersr� rS rS rT r� � s z"SSL4EndpointsTests.expectedServersc C s |j S )zE @return: List of calls to L{IReactorSSL.connectSSL} )Z sslClientsr� rS rS rT r� � s z"SSL4EndpointsTests.expectedClientsc C s` |\}}}}}}|\} } } } } }| � || � | � || � | � || � | � || � | � ||� dS )a� Compare host, port, contextFactory, timeout, and bindAddress in C{receivedArgs} to C{expectedArgs}. We ignore the factory because we don't only care what protocol comes out of the C{IStreamClientEndpoint.connect} call. @param receivedArgs: C{tuple} of (C{host}, C{port}, C{factory}, C{contextFactory}, C{timeout}, C{bindAddress}) that was passed to L{IReactorSSL.connectSSL}. @param expectedArgs: C{tuple} of (C{host}, C{port}, C{factory}, C{contextFactory}, C{timeout}, C{bindAddress}) that we expect to have been passed to L{IReactorSSL.connectSSL}. Nr� )rR r� r� r r� r� ZcontextFactoryr� r� r r� r� ZexpectedContextFactoryr� r� rS rS rT r� � s* � � z$SSL4EndpointsTests.assertConnectArgsc C s ddd�S r� rS rQ rS rS rT r� � s z SSL4EndpointsTests.connectArgsc C s ddd�S r� rS rQ rS rS rT r � s z SSL4EndpointsTests.listenArgsc C sL t ddd�\| _| _t ddd�\| _| _t| j| jdd�| _tdd�| _d S ) zF Set up client and server SSL contexts for use later. zServer Test Certificate�server)�OZCNzClient Test Certificate�clientF)� privateKey� certificate�requireCertificate)rR N)rJ ZsKeyZsCertZcKeyZcCertrD �serverSSLContext�clientSSLContextrQ rS rS rT r � s �� �zSSL4EndpointsTests.setUpc K sJ t ddd�}tj||j| jfi |��|j|| j|�dd�|�dd�f|fS )a� Create an L{SSL4ServerEndpoint} and return the tools to verify its behaviour. @param factory: The thing that we expect to be passed to our L{IStreamServerEndpoint.listen} implementation. @param reactor: A fake L{IReactorSSL} that L{SSL4ServerEndpoint} can call L{IReactorSSL.listenSSL} on. @param listenArgs: Optional dictionary of arguments to L{IReactorSSL.listenSSL}. r� r� r r� r� r� rK )r r �SSL4ServerEndpointr� rS r� r� rS rS rT r� � s �� ��z'SSL4EndpointsTests.createServerEndpointc K sR t ddd�}tj||j|j| jfi |��|j|j|| j|�dd�|�dd�f|fS )a� Create an L{SSL4ClientEndpoint} and return the values needed to verify its behaviour. @param reactor: A fake L{IReactorSSL} that L{SSL4ClientEndpoint} can call L{IReactorSSL.connectSSL} on. @param clientFactory: The thing that we expect to be passed to our L{IStreamClientEndpoint.connect} implementation. @param connectArgs: Optional dictionary of arguments to L{IReactorSSL.connectSSL} r� r� r r� r� r� N)r r �SSL4ClientEndpointr r� rT r� r� rS rS rT r� s$ �� ��z'SSL4EndpointsTests.createClientEndpointN) rb rc rd re r� r� r� r� r r r� r� rS rS rS rT rL � s & rL c @ sP e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dS )�UNIXEndpointsTestsz) Tests for UnixSocket Endpoints. c C s | � |�d d S )z� Override L{EndpointTestCaseMixin.retrieveConnectedFactory} to account for different index of 'factory' in C{connectUNIX} args. r rY r� r� rS rS rT r� ( s z+UNIXEndpointsTests.retrieveConnectedFactoryc C s |j S )zF @return: List of calls to L{IReactorUNIX.listenUNIX} )Z unixServersr� rS rS rT r� / s z"UNIXEndpointsTests.expectedServersc C s |j S )zG @return: List of calls to L{IReactorUNIX.connectUNIX} )Z unixClientsr� rS rS rT r� 5 s z"UNIXEndpointsTests.expectedClientsc C s@ |\}}}}|\}}} } | � ||� | � || � | � || � dS )a Compare path, timeout, checkPID in C{receivedArgs} to C{expectedArgs}. We ignore the factory because we don't only care what protocol comes out of the C{IStreamClientEndpoint.connect} call. @param receivedArgs: C{tuple} of (C{path}, C{timeout}, C{checkPID}) that was passed to L{IReactorUNIX.connectUNIX}. @param expectedArgs: C{tuple} of (C{path}, C{timeout}, C{checkPID}) that we expect to have been passed to L{IReactorUNIX.connectUNIX}. Nr� ) rR r� r� r6 r� r� �checkPIDZ expectedPathr� r� ZexpectedCheckPIDrS rS rT r� ; s � z$UNIXEndpointsTests.assertConnectArgsc C s ddd�S )r� r� rY )r� rX rS rQ rS rS rT r� T s z UNIXEndpointsTests.connectArgsc C s dddd�S )r� r� i� rY )r� �mode�wantPIDrS rQ rS rS rT r Z s z UNIXEndpointsTests.listenArgsc K sL t | �� �}tj||jfi |��|j||�dd�|�dd�|�dd�f|fS )a� Create an L{UNIXServerEndpoint} and return the tools to verify its behaviour. @param reactor: A fake L{IReactorUNIX} that L{UNIXServerEndpoint} can call L{IReactorUNIX.listenUNIX} on. @param factory: The thing that we expect to be passed to our L{IStreamServerEndpoint.listen} implementation. @param listenArgs: Optional dictionary of arguments to L{IReactorUNIX.listenUNIX}. r� r� rY � rZ r )r �mktempr �UNIXServerEndpointr� r� r� rS rS rT r� ` s ��z'UNIXEndpointsTests.createServerEndpointc K sB t | �� �}tj||jfi |��|j||�dd�|�dd�f|fS )a� Create an L{UNIXClientEndpoint} and return the values needed to verify its behaviour. @param reactor: A fake L{IReactorUNIX} that L{UNIXClientEndpoint} can call L{IReactorUNIX.connectUNIX} on. @param clientFactory: The thing that we expect to be passed to our L{IStreamClientEndpoint.connect} implementation. @param connectArgs: Optional dictionary of arguments to L{IReactorUNIX.connectUNIX} r� r� rX r )r r\ r �UNIXClientEndpointr� r� r� rS rS rT r� z s ��z'UNIXEndpointsTests.createClientEndpointN) rb rc rd re r� r� r� r� r� r r� r� rS rS rS rT rW # s rW c @ sl e Zd ZdZdZdd� Zdd� Zdd� Zd d � Zd d � Z d d� Z dd� Z dd� Z dd� Z dd� Zdd� ZdS )� ParserTestszK Tests for L{endpoints._parseServer}, the low-level parsing logic. r( c O s t j|i |��S )zT Provide a hook for test_strports to substitute the deprecated API. )r Z _parseServer)rR �a�kwrS rS rT �parse� s zParserTests.parsec C s, | � | �d| j�dd| jfddd�f� dS )zN Simple strings with a 'tcp:' prefix should be parsed as TCP. ztcp:80r� r rK r� �r� r� N�rz rb r� rQ rS rS rT �test_simpleTCP� s �zParserTests.test_simpleTCPc C s, | � | �d| j�dd| jfddd�f� dS )zU TCP port descriptions parse their 'interface' argument as a string. ztcp:80:interface=127.0.0.1r� r r� r� rc Nrd rQ rS rS rT �test_interfaceTCP� s �z ParserTests.test_interfaceTCPc C s, | � | �d| j�dd| jfddd�f� dS )zU TCP port descriptions parse their 'backlog' argument as an integer. ztcp:80:backlog=6r� r rK � rc Nrd rQ rS rS rT �test_backlogTCP� s �zParserTests.test_backlogTCPc C s. | � | �d| j�dd| jfdddd�f� dS ) z� L{endpoints._parseServer} returns a C{'UNIX'} port description with defaults for C{'mode'}, C{'backlog'}, and C{'wantPID'} when passed a string with the C{'unix:'} prefix and no other parameter values. zunix:/var/run/finger�UNIX�/var/run/fingerr[ r� T�rY r� rZ Nrd rQ rS rS rT �test_simpleUNIX� s ��zParserTests.test_simpleUNIXc C s. | � | �d| j�dd| jfdddd�f� dS ) zK C{mode} can be set by including C{"mode=<some integer>"}. z unix:/var/run/finger:mode=0660ri rj i� r� Trk Nrd rQ rS rS rT � test_modeUNIX� s ��zParserTests.test_modeUNIXc C s. | � | �d| j�dd| jfdddd�f� dS ) zM C{wantPID} can be set to false by included C{"lockfile=0"}. z unix:/var/run/finger:lockfile=0ri rj r[ r� Frk Nrd rQ rS rS rT �test_wantPIDUNIX� s ��z ParserTests.test_wantPIDUNIXc C s. | � | �d| j�dd| jfdddd�f� dS ) zf Backslash can be used to escape colons and backslashes in port descriptions. zunix:foo\:bar\=baz\:qux\\ri zfoo:bar=baz:qux\r[ r� Trk Nrd rQ rS rS rT � test_escape� s ��zParserTests.test_escapec C s | � t�d�d� dS )z� L{endpoints.quoteStringArgument} should quote backslashes and colons for interpolation into L{endpoints.serverFromString} and L{endpoints.clientFactory} arguments. zsome : stuff \zsome \: stuff \\N)rz r �quoteStringArgumentrQ rS rS rT �test_quoteStringArgument� s �z$ParserTests.test_quoteStringArgumentc C s. | � | �d| j�dd| jfdddd�f� dS ) z� In strports descriptions, '=' in a parameter value does not need to be quoted; it will simply be parsed as part of the value. zunix:address=foo=barri zfoo=barr[ r� Trk Nrd rQ rS rS rT �test_impliedEscape� s ��z ParserTests.test_impliedEscapec C s | � t| jd| j� dS )ze L{strports.parse} raises C{ValueError} when given an unknown endpoint type. zbogus-type:nothingN)rt r� rb r� rQ rS rS rT �test_unknownType s z ParserTests.test_unknownTypeN)rb rc rd re r� rb re rf rh rl rm rn ro rq rr rs rS rS rS rT r_ � s r_ c @ s� e Zd ZdZdd� Zeee�dd� �Zeee�dd� �Z dZ eee�d d � �Z eee�d d � �Z eee�d d� �Z eee�dd� �Zdd� Zdd� Zdd� ZdS )�ServerStringTestszC Tests for L{twisted.internet.endpoints.serverFromString}. c C s\ t � }t�|d�}| �|tj� | �|j|� | �|jd� | �|j d� | �|j d� dS )z� When passed a TCP strports description, L{endpoints.serverFromString} returns a L{TCP4ServerEndpoint} instance initialized with the values from the string. z&tcp:1234:backlog=12:interface=10.0.0.1r� � �10.0.0.1N) r� r �serverFromStringr� r� r rA rz �_port�_backlog� _interface)rR r rM rS rS rT �test_tcp s �zServerStringTests.test_tcpc C s� t � }t�|dttf �}| �|tj� | �|j|� | �|j d� | �|j d� | �|j d� | �|j j t� |j �� }| �|t� dS )z� When passed an SSL strports description, L{endpoints.serverFromString} returns a L{SSL4ServerEndpoint} instance initialized with the values from the string. �Vssl:1234:backlog=12:privateKey=%s:certKey=%s:sslmethod=TLSv1_METHOD:interface=10.0.0.1r� ru rv N)r� r rw �escapedPEMPathNamer� rU r rA rz rx ry rz �_sslContextFactory�methodrB � getContext� ContextType�rR r rM �ctxrS rS rT �test_ssl) s �� zServerStringTests.test_sslc C s� t � }t�|dt� ��}| �|tj� | �|j|� | �|j d� | �|j d� | �|j d� | �|j j t� | �|j jt@ � |j �� }| �|t� dS )z� An SSL string endpoint description with minimal arguments returns a properly initialized L{SSL4ServerEndpoint} instance. zssl:4321:privateKey=�� r� rK N)r� r rw r} r� rU r rA rz rx ry rz r~ r rA r� �_optionsr@ r� r� r� rS rS rT �test_sslWithDefaults@ s � � z&ServerStringTests.test_sslWithDefaultsz(ssl:1234:privateKey=%s:extraCertChain=%sc C st t �t� | jttf �}dd� dD �}|j}| �|jd � d�|d � d�� | �|jd � d�|d � d�� dS )zf Specifying a chain file loads the contained certificates in the right order. c S s& g | ] }t �t�d |f ��� ��qS )z thing%d.pem)rC �loadPEM�casPath�child� getContent)�.0�nrS rS rT � <listcomp>k s �z8ServerStringTests.test_sslChainLoads.<locals>.<listcomp>)rY r� r �sha1rY N) r rw r� �SSL_CHAIN_TEMPLATEr} �escapedChainPathNamer~ rz �extraCertChain�digest)rR rM ZexpectedChainCerts�cfrS rS rT �test_sslChainLoadsZ s$ ��� ���z$ServerStringTests.test_sslChainLoadsc C s� t | �� �}|�� �� | �t��0}t�t� | j t t� |j �f � W d � n1 sX0 Y | � t|j�d|j f � dS )zy If C{extraCertChain} is passed, it has to contain at least one valid certificate in PEM format. NzOSpecified chain file '%s' doesn't contain any valid certificates in PEM format.)r9 r\ �create�closert r� r rw r� r� r} rp r6 rz r� r )rR �fpZcaughtrS rS rT � test_sslChainFileMustContainCertw s" ���" ��z2ServerStringTests.test_sslChainFileMustContainCertc C sL d}t � }t�|d�tt|��}|j}| �|jt� | � t |�|jj � dS )z� If C{dhParameters} are specified, they are passed as L{DiffieHellmanParameters} into L{CertificateOptions}. ZsomeFilez1ssl:4321:privateKey={}:certKey={}:dhParameters={}N) r� r rw �formatr} r~ r� Z dhParametersrE rz r9 Z_dhFile)rR �fileNamer rM r� rS rS rT �test_sslDHparameters� s ��z&ServerStringTests.test_sslDHparametersc C s� t � }t�|dttf �}| �|tj� | �|j|� | � |j d� | � |j d� | � |j d� | � |j jt� |j �� }| �|t� dS )zq Lack of a trailing newline in key and cert .pem files should not generate an exception. r| r� ru rv N)r� r rw �&escapedNoTrailingNewlineKeyPEMPathName�'escapedNoTrailingNewlineCertPEMPathNamer� rU r rA rz rx ry rz r~ r rB r� r� r� rS rS rT � test_sslNoTrailingNewlinePem� s" ��� z.ServerStringTests.test_sslNoTrailingNewlinePemc C sh t � }t�|d�}| �|tj� | �|j|� | �|jd� | �|j d� | �|j d� | � |j � dS )z� When passed a UNIX strports description, L{endpoint.serverFromString} returns a L{UNIXServerEndpoint} instance initialized with the values from the string. z0unix:/var/foo/bar:backlog=7:mode=0123:lockfile=1� /var/foo/bar� �S N) r� r rw r� r] r rA rz Z_addressry �_moder� Z_wantPID)rR r r rS rS rT � test_unix� s �zServerStringTests.test_unixc C s& | � ttjdd�}| �t|�d� dS )zq L{endpoints.serverFromString} raises C{ValueError} when given an unknown endpoint type. N� ftl:andromeda/carcosa/hali/2387� Unknown endpoint type: 'ftl')rt r� r rw rz r� �rR r� rS rS rT rs � s �z"ServerStringTests.test_unknownTypec C sb t | � t� }t�|d�}ddlm} | �|j|� | �|j |ddf� | �|j t ddd�� d S ) z� L{endpoints.serverFromString} looks up plugins of type L{IStreamServerEndpoint} and constructs endpoints from them. z fake:hello:world:yes=no:up=downr )�fakeZhelloZworld�noZdown)�yes�upN) � addFakePluginr� r rw � twisted.plugins.fakeendpointr� r �parserrz r� r� �dict)rR � notAReactorZ fakeEndpointr� rS rS rT �test_typeFromPlugin� s � z%ServerStringTests.test_typeFromPluginN)rb rc rd re r{ r �skipSSL� skipSSLReasonr� r� r� r� r� r� r� r� rs r� rS rS rS rT rt s$ rt �fakeendpoint.pyc sx ddl ��j�� � ttj��� ��fdd�}| �|� t| �� �}|� � t t �j � |��|�|�� tj�|j� dS )z� For the duration of C{testCase}, add a fake plugin to twisted.plugins which contains some sample endpoint parsers. r Nc s( �j �� �j �� � �tjd d �< d S r[ )�modules�clear�updater �__path__rS �Z savedModulesZsavedPluginPath�sysrS rT �cleanup� s z addFakePlugin.<locals>.cleanup)r� r� r� �listr r� r� r9 r\ ZcreateDirectoryr: rb �filePath�siblingZcopyTor� r\ r6 )ZtestCaseZ dropinSourcer� r� rS r� rT r� � s r� c @ sh e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dd� Z dd� ZdS )�ClientStringTestszC Tests for L{twisted.internet.endpoints.clientFromString}. c C sj t � }t�|d�}| �|tj� | �|j|� | �|jd� | �|j d� | �|j d� | �|j d� dS )z� When passed a TCP strports description, L{endpoints.clientFromString} returns a L{TCP4ClientEndpoint} instance initialized with the values from the string. z=tcp:host=example.com:port=1234:timeout=7:bindAddress=10.0.0.2r� r� r� �z10.0.0.2r N� r� r �clientFromStringr� r� r rA rz �_hostrx �_timeout� _bindAddress�rR r rO rS rS rT r{ s �zClientStringTests.test_tcpc C sj t � }t�|d�}| �|tj� | �|j|� | �|jd� | �|j d� | �|j d� | �|j d� dS )z� When passed a TCP strports description using positional arguments, L{endpoints.clientFromString} returns a L{TCP4ClientEndpoint} instance initialized with the values from the string. z3tcp:example.com:1234:timeout=7:bindAddress=10.0.0.2r� r� r� r� Nr� r� rS rS rT �test_tcpPositionalArgs! s �z(ClientStringTests.test_tcpPositionalArgsc C s2 t � }t�|d�}| �|jd� | �|jd� dS )z� When passed a TCP strports description specifying host as a positional argument, L{endpoints.clientFromString} returns a L{TCP4ClientEndpoint} instance initialized with the values from the string. z8tcp:example.com:port=1234:timeout=7:bindAddress=10.0.0.2r� r� N�r� r r� rz r� rx r� rS rS rT �test_tcpHostPositionalArg2 s �z+ClientStringTests.test_tcpHostPositionalArgc C s2 t � }t�|d�}| �|jd� | �|jd� dS )z� When passed a TCP strports description specifying port as a positional argument, L{endpoints.clientFromString} returns a L{TCP4ClientEndpoint} instance initialized with the values from the string. z8tcp:host=example.com:1234:timeout=7:bindAddress=10.0.0.2r� r� Nr� r� rS rS rT �test_tcpPortPositionalArg@ s �z+ClientStringTests.test_tcpPortPositionalArgc C s0 t � }t�|d�}| �|jd� | �|j� dS )z{ A TCP strports description may omit I{timeout} or I{bindAddress} to allow the default to be used. z tcp:host=example.com:port=1234r� N)r� r r� rz r� r� r� r� rS rS rT �test_tcpDefaultsM s z"ClientStringTests.test_tcpDefaultsc C sZ t � }t�|d�}| �|tj� | �|j|� | �|jd� | �|j d� | � |j � dS )z� When passed a UNIX strports description, L{endpoints.clientFromString} returns a L{UNIXClientEndpoint} instance initialized with the values from the string. z+unix:path=/var/foo/bar:lockfile=1:timeout=9r� � N� r� r r� r� r^ r rA rz rE r� r� � _checkPIDr� rS rS rT r� W s �zClientStringTests.test_unixc C s, t �t� d�}| �|jd� | �|j� dS )zz A UNIX strports description may omit I{lockfile} or I{timeout} to allow the defaults to be used. zunix:path=/var/foo/barr� N)r r� r� rz r� r� r� )rR rO rS rS rT �test_unixDefaultsg s z#ClientStringTests.test_unixDefaultsc C sZ t � }t�|d�}| �|tj� | �|j|� | �|jd� | �|j d� | � |j � dS )z� When passed a UNIX strports description specifying path as a positional argument, L{endpoints.clientFromString} returns a L{UNIXClientEndpoint} instance initialized with the values from the string. z&unix:/var/foo/bar:lockfile=1:timeout=9r� r� Nr� r� rS rS rT �test_unixPathPositionalArgp s �z,ClientStringTests.test_unixPathPositionalArgc C sb t | � t� }t�|d�}ddlm} | �|j|� | �|j |ddf� | �|j t ddd�� d S ) z� L{endpoints.clientFromString} looks up plugins of type L{IStreamClientEndpoint} and constructs endpoints from them. � crfake:alpha:beta:cee=dee:num=1r ��fakeClientWithReactor�alpha�beta�dee�1�Zcee�numN) r� r� r r� r� r� r r� rz r� r� r� )rR r� �clientEndpointr� rS rS rT r� � s � z%ClientStringTests.test_typeFromPluginc C s& | � ttjdd�}| �t|�d� dS )zq L{endpoints.clientFromString} raises C{ValueError} when given an unknown endpoint type. Nr� r� )rt r� r r� rz r� r� rS rS rT rs � s �z"ClientStringTests.test_unknownTypec C sV t | � t� }t�|d�}ddlm} | �|j|j|j f||ddft ddd�f� d S ) z� L{endpoints.clientFromString} will pass a reactor to plugins implementing the L{IStreamClientEndpointStringParserWithReactor} interface. r� r r� r� r� r� r� r� N) r� r� r r� r� r� rz r� r� r� r� )rR r r� r� rS rS rT � test_stringParserWithReactor� s � ��z.ClientStringTests.test_stringParserWithReactorN)rb rc rd re r{ r� r� r� r� r� r� r� r� rs r� rS rS rS rT r� s r� c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) �SSLClientStringTestszU Tests for L{twisted.internet.endpoints.clientFromString} which require SSL. c s` t � }t�|dtttf �}| �|tj� | �|j|� | � |j d� | � |j d� | � |j d� | � |j d� |j}| �|t� | � |jt� | �|jt@ � |�� }| �|t� | � t|j�t� t|j�}|�t |j �� | � |t � dd� t � d�t � d �fD �}g � G � fd d �d �}|j!�"|� � | � t#d d � � D �dd� d�t#|dd� d�� dS )�� When passed an SSL strports description, L{clientFromString} returns a L{SSL4ClientEndpoint} instance initialized with the values from the string. zdssl:host=example.net:port=4321:privateKey=%s:certKey=%s:bindAddress=10.0.0.3:timeout=3:caCertsDir=%s� example.netr� r� �z10.0.0.3r c S s, g | ]$}|� � �� �d �rt�|�� ��qS )z.pem)�basename�lower�endswithrC r� r� �r� �xrS rS rT r� � s �z1SSLClientStringTests.test_ssl.<locals>.<listcomp>� thing1.pem� thing2.pemc s e Zd Z� fdd�ZdS )z.SSLClientStringTests.test_ssl.<locals>.ListCtxc s G � fdd�d�}|� S )Nc s e Zd Z� fdd�ZdS )zLSSLClientStringTests.test_ssl.<locals>.ListCtx.get_cert_store.<locals>.Storec s � � |� d S r[ r� )rR �cert�Z addedCertsrS rT �add_cert� s zUSSLClientStringTests.test_ssl.<locals>.ListCtx.get_cert_store.<locals>.Store.add_certN)rb rc rd r� rS r� rS rT �Store� s r� rS )rR r� r� rS rT �get_cert_store� s z=SSLClientStringTests.test_ssl.<locals>.ListCtx.get_cert_storeN)rb rc rd r� rS r� rS rT �ListCtx� s r� c s s | ]}t |�V qd S r[ �rC r� rS rS rT � <genexpr>� r� z0SSLClientStringTests.test_ssl.<locals>.<genexpr>c S s | � � S r[ �r� �r� rS rS rT r� � r� z/SSLClientStringTests.test_ssl.<locals>.<lambda>)�keyc S s | � � S r[ r� r� rS rS rT r� � r� N)$r� r r� r} �escapedCAsPathNamer� rV r rA rz r� rx r� r� r~ rD r rA r� r� r@ r� r� rC rQ �testCertificaterG Z_setPrivateKeyrF rP �testPrivateCertificater� r� � trustRootZ_addCACertsToContext�sorted)rR r rO � certOptionsr� Z privateCertZ expectedCertsr� rS r� rT r� � sF �� ���z SSLClientStringTests.test_sslc C st t � }t�|dtttf �}| �|tj� | �|j|� | � |j d� | � |j d� | � |j d� | � |j d� dS )r� zZssl:example.net:4321:privateKey=%s:certKey=%s:bindAddress=10.0.0.3:timeout=3:caCertsDir=%sr� r� r� r� N)r� r r� r} r� r� rV r rA rz r� rx r� r� r� rS rS rT �test_sslPositionalArgs� s ��z+SSLClientStringTests.test_sslPositionalArgsc C sz t � }t�|d�}| �|tj� | �|j|� | �|jd� | �|j d� |j }| �|j t � | � |j� | � |j� dS )z� When passed an SSL strports description without extra arguments, L{clientFromString} returns a L{SSL4ClientEndpoint} instance whose context factory is initialized with default values. zssl:example.net:4321r� r� N)r� r r� r� rV r rA rz r� rx r~ r rA r� rQ rP )rR r rO r� rS rS rT r� s z)SSLClientStringTests.test_sslWithDefaultsc C sX G dd� dt �}t�d��� }||_| �dd� t�|�jD �t � t�d�� � �g� dS )z� If a certificate in the directory is unreadable, L{endpoints._loadCAsFromDir} will ignore that certificate. c @ s e Zd Zdd� ZdS )zKSSLClientStringTests.test_unreadableCertificate.<locals>.UnreadableFilePathc S s. t �| �}|t�d��� kr&tt��n|S d S )Nr� )r9 r� r� r� �OSErrorr r] rS rS rT r� s zVSSLClientStringTests.test_unreadableCertificate.<locals>.UnreadableFilePath.getContentN)rb rc rd r� rS rS rS rT �UnreadableFilePath s r� r� c S s g | ] }t |��qS rS r� r� rS rS rT r� ' r� zCSSLClientStringTests.test_unreadableCertificate.<locals>.<listcomp>r� N) r9 r� r� �parentZ clonePathrz r Z_loadCAsFromDirZ_caCertsrC r� r� )rR r� Z casPathClonerS rS rT �test_unreadableCertificate s �z/SSLClientStringTests.test_unreadableCertificatec C sH t � }t�|d�}|j}| �|t� | �|j� |�� }| �|t � dS )z� When passed an SSL strports description without any extra parameters, L{clientFromString} returns a simple non-verifying endpoint that will speak SSL. z%ssl:host=simple.example.org:port=4321N) r� r r� r~ r� rD r� �verifyr� r� )rR r rO r� r� rS rS rT �test_sslSimple+ s � z#SSLClientStringTests.test_sslSimpleN) rb rc rd re r� r� r� r� r� rS rS rS rT r� � s 4r� c @ sH e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dS )� AdoptedStreamServerEndpointTestszA Tests for adopted socket-based stream server endpoints. c C s& t �|||�}dd� |_dd� |_|S )z� Create an L{AdoptedStreamServerEndpoint} which may safely be used with an invalid file descriptor. This is convenient for a number of unit tests. c S s d S r[ rS �r- rS rS rT r� J r� zPAdoptedStreamServerEndpointTests._createStubbedAdoptedEndpoint.<locals>.<lambda>c S s d S r[ rS r rS rS rT r� K r� )r ZAdoptedStreamServerEndpoint�_close�_setNonBlocking)rR r �fileno� addressFamilyr� rS rS rT � _createStubbedAdoptedEndpointA s z>AdoptedStreamServerEndpointTests._createStubbedAdoptedEndpointc C s2 d}t }| �|||�}tddd�}||||f|fS )a� Create a new L{AdoptedStreamServerEndpoint} for use by a test. @return: A three-tuple: - The endpoint - A tuple of the arguments expected to be passed to the underlying reactor method - An IAddress object which will match the result of L{IListeningPort.getHost} on the port returned by the endpoint. ru r� r� r� )r r r )rR r r} r r r r� rS rS rT r� N s z5AdoptedStreamServerEndpointTests.createServerEndpointc C s |j S )z� @return: The ports which were actually adopted by C{reactor} via calls to its L{IReactorSocket.adoptStreamPort} implementation. )� adoptedPortsr� rS rS rT r� ` s z0AdoptedStreamServerEndpointTests.expectedServersc C s i S )zx @return: A C{dict} of additional keyword arguments to pass to the C{createServerEndpoint}. rS rQ rS rS rT r g s z+AdoptedStreamServerEndpointTests.listenArgsc sR t � � ��� dt�}|�t� � ��|�t� �tj�}� �fdd�}|�|� |S )z� L{AdoptedStreamServerEndpoint.listen} can only be used once. The file descriptor given is closed after the first use, and subsequent calls to C{listen} return a L{Deferred} that fails with L{AlreadyListened}. � c s �� dt� j�� d S rX )rz r� r �r� �r rR rS rT � listenFailedy s zEAdoptedStreamServerEndpointTests.test_singleUse.<locals>.listenFailed) r� r r r� r� r� r ZAlreadyListenedr� )rR r r� r rS r rT �test_singleUsen s z/AdoptedStreamServerEndpointTests.test_singleUsec sR t � }��|dt�}g � � fdd�}||_|�t� �}� �fdd�}|�|� |S )zv L{AdoptedStreamServerEndpoint.listen} sets the file description given to it to non-blocking. r c s � � d| f� d S )N�setNonBlockingr� �r )�eventsrS rT r � s zTAdoptedStreamServerEndpointTests.test_descriptionNonBlocking.<locals>.setNonBlockingc s �� dg� � d S )N)r r r� r �r rR rS rT �listened� s zNAdoptedStreamServerEndpointTests.test_descriptionNonBlocking.<locals>.listened)r� r r r r� r� r� )rR r r r r� r rS r rT �test_descriptionNonBlocking s z<AdoptedStreamServerEndpointTests.test_descriptionNonBlockingc sT t � ����dt�}g � � �fdd�}||_|�t� �}� �fdd�}|�|� |S )z� L{AdoptedStreamServerEndpoint.listen} closes its file descriptor after adding it to the reactor with L{IReactorSocket.adoptStreamPort}. r c s � � d| t�j�f� d S )Nr� )r\ r� r r )r r rS rT r� � s zEAdoptedStreamServerEndpointTests.test_descriptorClosed.<locals>.closec s �� dg� � d S )N)r� r rY r� r r rS rT r � s zHAdoptedStreamServerEndpointTests.test_descriptorClosed.<locals>.listened)r� r r r r� r� r� )rR r r� r� r rS )r r rR rT �test_descriptorClosed� s z6AdoptedStreamServerEndpointTests.test_descriptorClosedN) rb rc rd re r r� r� r r r r rS rS rS rT r� < s r� c @ sF e Zd ZdZejZdd� Zdd� Zdd� Z dd � Z d d � Z d d � Z dS )�SystemdEndpointPluginTestsz� Unit tests for the systemd stream server endpoint and endpoint string description parser. @see: U{systemd<http://www.freedesktop.org/wiki/Software/systemd>} c C s< t ttj��}|D ]}t|| j�r q8q| �d|��� dS )z� L{endpoints._SystemdParser} is found as a plugin for L{interfaces.IStreamServerEndpointStringParser} interface. z Did not find systemd parser in N�r� r2 r �!IStreamServerEndpointStringParserr� � _parserClassr� �rR �parsersr� rS rS rT �test_pluginDiscovery� s z/SystemdEndpointPluginTests.test_pluginDiscoveryc C s | � � }| �ttj|�� dS )zx L{endpoints._SystemdParser} instances provide L{interfaces.IStreamServerEndpointStringParser}. N�r r� r r r �rR r� rS rS rT r� � s �z)SystemdEndpointPluginTests.test_interfacec C sj t � }g d�}d}| �� }t|�|_|j||t|�d�}| �|j|� | �|j |� | �|j || � dS )a� Helper for unit tests for L{endpoints._SystemdParser.parseStreamServer} for different address families. Handling of the address family given will be verify. If there is a problem a test-failing exception will be raised. @param addressFamily: An address family constant, like L{socket.AF_INET}. @param addressFamilyString: A string which should be recognized by the parser as representing C{addressFamily}. )rR rg r� � r� r� )�domain�indexN) r� r r; Z _sddaemonZparseStreamServerr� r r rz r r )rR r ZaddressFamilyStringr Z descriptorsr r� rM rS rS rT �_parseStreamServerTest� s �z1SystemdEndpointPluginTests._parseStreamServerTestc C s | � td� dS )zC IPv4 can be specified using the string C{"INET"}. ZINETN)r r rQ rS rS rT �test_parseStreamServerINET� s z5SystemdEndpointPluginTests.test_parseStreamServerINETc C s | � td� dS )zD IPv6 can be specified using the string C{"INET6"}. ZINET6N)r r rQ rS rS rT �test_parseStreamServerINET6� s z6SystemdEndpointPluginTests.test_parseStreamServerINET6c C s> zddl m} W n ty, t�d��Y n0 | �|d� dS )zS A UNIX domain socket can be specified using the string C{"UNIX"}. r )�AF_UNIXz Platform lacks AF_UNIX supportri N)�socketr" � ImportErrorr> ZSkipTestr )rR r" rS rS rT �test_parseStreamServerUNIX� s z5SystemdEndpointPluginTests.test_parseStreamServerUNIXN) rb rc rd re r Z_SystemdParserr r r� r r r! r% rS rS rS rT r � s r c @ s. e Zd ZdZejZdd� Zdd� Zdd� Z dS ) � TCP6ServerEndpointPluginTestsz[ Unit tests for the TCP IPv6 stream server endpoint string description parser. c C s< t ttj��}|D ]}t|| j�r q8q| �d|��� dS )z� L{endpoints._TCP6ServerParser} is found as a plugin for L{interfaces.IStreamServerEndpointStringParser} interface. z*Did not find TCP6ServerEndpoint parser in Nr r rS rS rT r s z2TCP6ServerEndpointPluginTests.test_pluginDiscoveryc C s | � � }| �ttj|�� dS )z{ L{endpoints._TCP6ServerParser} instances provide L{interfaces.IStreamServerEndpointStringParser}. Nr r rS rS rT r� s �z,TCP6ServerEndpointPluginTests.test_interfacec C sX t �t� d�}| �|t j� | �|jt� | �|jd� | �|jd� | �|j d� dS )z� L{serverFromString} returns a L{TCP6ServerEndpoint} instance with a 'tcp6' endpoint string description. z$tcp6:8080:backlog=12:interface=\:\:1i� ru r� N) r rw r� r� r� rA rz rx ry rz r� rS rS rT �test_stringDescription s �z4TCP6ServerEndpointPluginTests.test_stringDescriptionN) rb rc rd re r Z_TCP6ServerParserr r r� r' rS rS rS rT r& s r& c @ s. e Zd ZdZejZdd� Zdd� Zdd� Z dS ) � StandardIOEndpointPluginTestszM Unit tests for the Standard I/O endpoint string description parser. c C s< t ttj��}|D ]}t|| j�r q8q| �d|��� dS )z� L{endpoints._StandardIOParser} is found as a plugin for L{interfaces.IStreamServerEndpointStringParser} interface. z*Did not find StandardIOEndpoint parser in Nr r rS rS rT r 5 s z2StandardIOEndpointPluginTests.test_pluginDiscoveryc C s | � � }| �ttj|�� dS )z{ L{endpoints._StandardIOParser} instances provide L{interfaces.IStreamServerEndpointStringParser}. Nr r rS rS rT r� A s �z,StandardIOEndpointPluginTests.test_interfacec C s. t �t� d�}| �|t j� | �|jt� dS )z� L{serverFromString} returns a L{StandardIOEndpoint} instance with a 'stdio' endpoint string description. zstdio:N)r rw r� r� r rA r� rS rS rT r' K s z4StandardIOEndpointPluginTests.test_stringDescriptionN) rb rc rd re r Z_StandardIOParserr r r� r' rS rS rS rT r( . s r( c @ s e Zd ZdZdd� Zdd� ZdS )�ConnectProtocolTestsz' Tests for C{connectProtocol}. c C sl t � }t�|dd�}t� }t�||� | �t|j�d� |jd d j}| � |t j � | � |� d�|� dS )z� C{endpoints.connectProtocol} calls the given endpoint's C{connect()} method with a factory that will build the given protocol. r� r rY r� N)r� r r� r� �connectProtocolrz r� r� Z_wrappedFactoryr� r r( r rv )rR r r Z theProtocolr} rS rS rT �"test_connectProtocolCreatesFactoryZ s z7ConnectProtocolTests.test_connectProtocolCreatesFactoryc s: t �� � G � fdd�d�}|� }| �� t�|t� �� dS )z~ C{endpoints.connectProtocol} returns the result of calling the given endpoint's C{connect()} method. c s e Zd Z� fdd�ZdS )zOConnectProtocolTests.test_connectProtocolReturnsConnectResult.<locals>.Endpointc s � S )zR Return a marker object for use in our assertion. rS )rR r} �r� rS rT r� t s zWConnectProtocolTests.test_connectProtocolReturnsConnectResult.<locals>.Endpoint.connectN)rb rc rd r� rS r, rS rT �Endpoints s r- N)r r� r r r* r� )rR r- r rS r, rT �(test_connectProtocolReturnsConnectResultl s z=ConnectProtocolTests.test_connectProtocolReturnsConnectResultN)rb rc rd re r+ r. rS rS rS rT r) U s r) c s4 e Zd ZdZ� fdd�Z� fdd�Zdd� Z� ZS )�UppercaseWrapperProtocolzL A wrapper protocol which uppercases all strings passed through it. c s t � �|�� � dS )z� Uppercase a string passed in from the transport. @param data: The string to uppercase. @type data: L{bytes} N)r r^ �upperr] r" rS rT r^ � s z%UppercaseWrapperProtocol.dataReceivedc s t � �|�� � dS )z� Uppercase a string passed out to the transport. @param data: The string to uppercase. @type data: L{bytes} N)r r% r0 r] r" rS rT r% � s z UppercaseWrapperProtocol.writec C s |D ]}| � |� qdS )zy Uppercase a series of strings passed out to the transport. @param seq: An iterable of strings. Nr$ )rR �seqrN rS rS rT rx � s z&UppercaseWrapperProtocol.writeSequence)rb rc rd re r^ r% rx r1 rS rS r" rT r/ ~ s r/ c @ s e Zd ZdZeZdS )�UppercaseWrapperFactoryzK A wrapper factory which uppercases all strings passed through it. N)rb rc rd re r/ r rS rS rS rT r2 � s r2 c @ s e Zd ZdZdd� Zdd� ZdS )�NetstringTrackerz� A netstring receiver which keeps track of the strings received. @ivar strings: A L{list} of received strings, in order. c C s g | _ d S r[ )�stringsrQ rS rS rT rU � s zNetstringTracker.__init__c C s | j �|� dS )z� Receive a string and append it to C{self.strings}. @param string: The string to be appended to C{self.strings}. N)r4 r\ )rR r� rS rS rT �stringReceived� s z NetstringTracker.stringReceivedN)rb rc rd re rU r5 rS rS rS rT r3 � s r3 c @ s e Zd ZdZdS )� FakeErrorz� An error which isn't really an error. This is raised in the L{wrapClientTLS} tests in place of a 'real' exception. Nr rS rS rS rT r6 � s r6 c @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dS )�WrapperClientEndpointTestsz. Tests for L{_WrapperClientEndpoint}. c C s6 t � \| _| _t� | _t�| jt�| _t � t �| _ d S r[ ) r< r � completerr� �contextr Z_WrapperEndpointr2 r� r( rc r3 r} rQ rS rS rT r � s �z WrapperClientEndpointTests.setUpc C sL | j �| j�}| j�� }| �|�}|jj�d� |� � | � |j dg� dS )z� Any modifications performed by the underlying L{ProtocolWrapper} propagate through to the wrapped L{Protocol}. s 5:hello,s HELLON) r� r� r} r8 � succeedOncer rM r� r% �flushrz r4 �rR Z connecting�pumpr� rS rS rT �test_wrappingBehavior� s z0WrapperClientEndpointTests.test_wrappingBehaviorc C sB | j �| j�}| j�� }| �|�}|�d� | �|j� � d� dS )z� Methods defined on the wrapped L{Protocol} are accessible from the L{Protocol} returned from C{connect}'s L{Deferred}. s spams 4:SPAM,N) r� r� r} r8 r: r Z sendStringrz �clientIOZ getOutBufferr< rS rS rT �test_methodsAvailable� s z0WrapperClientEndpointTests.test_methodsAvailablec C s6 | j �| j�}| �|� | j�t� � | �|t� dS )zS Connection failures propagate upward to C{connect}'s L{Deferred}. N)r� r� r} �assertNoResultr8 ZfailOncer6 r� �rR r� rS rS rT �test_connectionFailure� s z1WrapperClientEndpointTests.test_connectionFailurec C s0 | j �| j�}| �|� |�� | �|t� dS )zM Cancellation propagates upward to C{connect}'s L{Deferred}. N)r� r� r} rA r� r� r! rB rS rS rT �test_connectionCancellation� s z6WrapperClientEndpointTests.test_connectionCancellationc C s8 | j �| j�}| j�� }| �|�}| �|jj|j� dS )z| The transport of the wrapped L{Protocol}'s transport is the transport passed to C{makeConnection}. N) r� r� r} r8 r: r r r� r? r< rS rS rT �*test_transportOfTransportOfWrappedProtocol� s zEWrapperClientEndpointTests.test_transportOfTransportOfWrappedProtocolN) rb rc rd re r r> r@ rC rD rE rS rS rS rT r7 � s r7 c C s |� d�jS )a, Given a L{MemoryReactor} and the result of calling L{wrapClientTLS}, extract the L{IOpenSSLClientConnectionCreator} associated with it. Implementation presently uses private attributes but could (and should) be refactored to just call C{.connect()} on the endpoint, when L{HostnameEndpoint} starts directing its C{getaddrinfo} call through the reactor it is passed somehow rather than via the global threadpool. @param memoryReactor: the reactor attached to the given endpoint. (Presently unused, but included so tests won't need to be modified to honor it.) @param tlsEndpoint: The result of calling L{wrapClientTLS}. @return: the client connection creator associated with the endpoint wrapper. @rtype: L{IOpenSSLClientConnectionCreator} N)Z_wrapperFactoryZ_connectionCreator)rY Z tlsEndpointrS rS rT � connectionCreatorFromEndpoint s rF c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) �WrapClientTLSParserTestsz0 Tests for L{_TLSClientEndpointParser}. c C sj t � }t�|td��}|j}| �|j|� | �|jd� | �|j d� | �|j d� | �|j td�� dS )zm A L{HostnameEndpoint} is constructed from parameters passed to L{clientFromString}. z4tls:example.com:443:timeout=10:bindAddress=127.0.0.1r r< r� r� N) r� r r� r6 �_wrappedEndpointr rA rz r, rx r� r� )rR r r ZhostnameEndpointrS rS rT �!test_hostnameEndpointConstruction! s �z:WrapClientTLSParserTests.test_hostnameEndpointConstructionc C s> t � }t�|d�}| �|jjd� t||�}| �|jd� dS )z� The hostname passed to L{clientFromString} is treated as utf-8 bytes; it is then encoded as IDNA when it is passed along to L{HostnameEndpoint}, and passed as unicode to L{optionsForClientTLS}. s tls:éxample.example.com:443s xn--xample-9ua.example.comu éxample.example.comN)r� r r� rz rH r, rF � _hostname)rR r r ZconnectionCreatorrS rS rT �test_utf8Encoding2 s �� z*WrapClientTLSParserTests.test_utf8Encodingc s| t � }t�t|dg�d�ttt�t�� j ��� d��}|� t � t��}|j�� \}}}}}|�d�� | �|� � duszJ �t�t�� �} t| jj| jt�t�� �jg| d�} t� �t| dt � �fdd��d ��d��t �fd d�� fd d��\} } } �j � d � | � |�}|j � d � | � � | �!�j j"� | �!|j j"� | �!�j j#� | �!|j j#� t�$�j �}| �%|t�t�� �� dS )z� When passed a string endpoint description beginning with C{tls:}, L{clientFromString} returns a client endpoint initialized with the values from the string. r� z=tls:localhost:4321:privateKey={}:certificate={}:trustRoots={}�asciiN)rP rQ r� r� Fc s � S r[ rS rS )� plainServerrS rT r� q r� z3WrapClientTLSParserTests.test_tls.<locals>.<lambda>)ZisClientZwrappedFactoryc s � S r[ rS rS )�serverProtocolrS rT r� t r� c s � S r[ rS rS )�clientProtocolrS rT r� u r� s hello s hi you too )&r� r r� r� r� r} rp �pemPathr� r6 �encoder� r( rc r) r� �poprv rA rG r� r� rD rP �originalrC � chainPathrI r= r� r% r r; r� Z disconnectingZ disconnectedZpeerFromTransportrz )rR r r r� r r� r} r� r� Z serverCertZ serverOptionsZsProtoZcProtor= Z plainClientZpeerCertificaterS )rO rM rN rT �test_tlsB sZ ��� ��� � z!WrapClientTLSParserTests.test_tlsc C s> t � }t�|d�}t||�}| �|jd� | �|jjd� dS )z� When passed a C{tls:} strports description without extra arguments, L{clientFromString} returns a client endpoint whose context factory is initialized with default values. s tls:example.com:443r� r N)r� r r� rF rz rJ rH r, )rR r r ZcreatorrS rS rT �test_tlsWithDefaults� s z-WrapClientTLSParserTests.test_tlsWithDefaultsN)rb rc rd re rI rK rU rV rS rS rS rT rG s ArG c K s� z| j }| j}W n ty. | j}| j}Y n0 |D ]}||vr4td�|���q4i }|�|� |�|� t||�}||| j < |S )a� Create a copy of the given function with the given globals substituted. The globals must already exist in the function's existing global scope. @param function: any function object. @type function: L{types.FunctionType} @param newGlobals: each keyword argument should be a global to set in the new function's returned scope. @type newGlobals: L{dict} @return: a new function, like C{function}, but with new global scope. z<Name bound by replacingGlobals but not present in module: {}) � func_codeZ func_globalsru �__code__� __globals__� TypeErrorr� r� r rb )�functionZ newGlobalsZ codeObjectZ funcGlobalsr� Z mergedGlobalsZ newFunctionrS rS rT �replacingGlobals� s& �� r\ c @ s e Zd ZdZdd� ZdS )�WrapClientTLSTestszj Tests for the error-reporting behavior of L{wrapClientTLS} when C{pyOpenSSL} is unavailable. c C s2 t tjdd�}| �t|dd�}| �dt|�� dS )z� If SSL is not supported, L{TLSMemoryBIOFactory} will be L{None}, which causes C{_wrapper} to also be L{None}. If C{_wrapper} is L{None}, then an exception is raised. NrH zOpenSSL not available)r\ r Z wrapClientTLSrt �NotImplementedErrorr� r� )rR ZreplacedZnotImplementedrS rS rT �test_noOpenSSL� s z!WrapClientTLSTests.test_noOpenSSLN)rb rc rd re r_ rS rS rS rT r] � s r] )rS N)r� )�re �errnor r# r r r r r �typesr � unicodedatar r> r Zzope.interfacer r r Zzope.interface.interfacer Zzope.interface.verifyr r Ztwistedr r� r r r r r r r r Ztwisted.internet.abstractr Ztwisted.internet.addressr r r r r Ztwisted.internet.endpointsr Ztwisted.internet.errorr! Ztwisted.internet.interfacesr" r# r$ r% r& Ztwisted.internet.protocolr' r( r) Ztwisted.internet.stdior* Ztwisted.internet.taskr+ Ztwisted.internet.testingr, r� r- r. r/ Ztwisted.loggerr0 r1 Ztwisted.pluginr2 Ztwisted.protocolsr3 r4 Ztwisted.pythonr5 Ztwisted.python.compatr6 Ztwisted.python.componentsr7 Ztwisted.python.failurer8 Ztwisted.python.filepathr9 Ztwisted.python.modulesr: Ztwisted.python.systemdr; Ztwisted.test.iosimr< r= Z twisted.trialr� r� rP ZnoTrailingNewlineKeyPemPathZ noTrailingNewlineCertPemPathrb r� r� rT rp r6 r} r� r� r� r� Z OpenSSL.SSLr? r� r@ rA rB Ztwisted.internet.sslrC rD rE rF rG Ztwisted.protocols.tlsrI Ztwisted.test.test_sslverifyrJ r� r� r� r� r� r� r$ r� r� rL r� rf r� rl r� ro rr rs ZTestCaserx r� r� r r r r r ZIProcessTransportr ZIReactorProcessr2 r= rb r� r� r� r� r� r� ZSynchronousTestCaser� r� r r r r r' r( r6 rA rD rL rW r_ rt r� r� r� r� r r& r( r) ZProtocolWrapperr/ ZWrappingFactoryr2 ZNetstringReceiverr3 r^ r6 r7 rF rG r\ r] rS rS rS rT �<module> s$ ( � � �� P)# $ ooks < �4 �4 IvHF q b + pU-')! At$
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка