Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/words/test/__pycache__/test_jabbercomponent.cpython-39.pyc
Ðазад
a k�hR6 � @ s d Z ddlmZ ddlmZ ddlmZ ddlmZ ddl m Z m Z m Z ddl mZ ddlmZ dd lmZ G d d � d �ZG d d � d ej�ZG dd� dej�ZG dd� dej�ZG dd� de j�ZG dd� dej�ZG dd� dej�ZG dd� dej�Z G dd� dej�Z d S ) z7 Tests for L{twisted.words.protocols.jabber.component} � )�sha1)� verifyObject)�failure)�unittest)� component�ijabber� xmlstream)�JID)�domish)�XmlPipec @ s e Zd Zdd� Zdd� ZdS )�DummyTransportc C s || _ d S �N)�list)�selfr � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/words/test/test_jabbercomponent.py�__init__ s zDummyTransport.__init__c C s | j �|� d S r )r �append)r �bytesr r r �write s zDummyTransport.writeN)�__name__� __module__� __qualname__r r r r r r r s r c @ s e Zd Zdd� Zdd� ZdS )�#ComponentInitiatingInitializerTestsc C sj g | _ t�� | _d| j_t�| j�| _d| j_| j j| j_| j� � | j� d� d| j_ t � | j�| _d S )N�secret�test:componentz�<stream:stream xmlns='test:component' xmlns:stream='http://etherx.jabber.org/streams' from='example.com' id='12345' version='1.0'>Z12345)�outputr Z Authenticator� authenticator�password� XmlStream� namespacer �send�connectionMade� dataReceived�sidr Z ComponentInitiatingInitializer�init�r r r r �setUp s �z)ComponentInitiatingInitializerTests.setUpc C sb | j �� }| jd }| �d|j� | �d|j� | �td��� t|�� g |_ | j � |� � � |S )z? Test basic operations of component handshake. ���� handshaker � 12345secret) r% Z initializer � assertEqual�name�urir � hexdigest�str�childrenr r# ZtoXml)r �dr) r r r � testHandshake- s z1ComponentInitiatingInitializerTests.testHandshakeN)r r r r' r2 r r r r r s r c @ s e Zd Zdd� Zdd� ZdS )�ComponentAuthTestsc C s d| _ d S �NT)� authComplete)r �streamr r r � authPassedD s z ComponentAuthTests.authPassedc C s� d| _ g }t�dd�}t�|�}t|�|_|�tj| j � |� � |� d� t d�� � �d�}| �|d d| d � |� d � | �| j d � d S ) NFZcjidr sv <stream:stream xmlns='jabber:component:accept' xmlns:stream='http://etherx.jabber.org/streams' from='cjid' id='12345'>r* �ascii� s <handshake>s </handshake>� <handshake/>T)r5 r Z ConnectComponentAuthenticatorr r r � transport� addObserver�STREAM_AUTHD_EVENTr7 r" r# r r. �encoder+ )r Zoutlist�ca�xsZhvr r r �testAuthG s � zComponentAuthTests.testAuthN)r r r r7 rA r r r r r3 C s r3 c @ s e Zd ZdZdd� ZdS )� ServiceTestsz) Tests for L{component.Service}. c C s t �� }ttj|� dS )zF L{component.Service} implements L{ijabber.IService}. N)r �Servicer r ZIService)r Zservicer r r �test_interfacef s zServiceTests.test_interfaceN)r r r �__doc__rD r r r r rB a s rB c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) �JabberServiceHarnessc C s d| _ d| _d| _d S )NF)�componentConnectedFlag�componentDisconnectedFlag�transportConnectedFlagr& r r r r o s z JabberServiceHarness.__init__c C s d| _ d S r4 )rG �r r r r r �componentConnectedt s z'JabberServiceHarness.componentConnectedc C s d| _ d S r4 )rH r& r r r �componentDisconnectedw s z*JabberServiceHarness.componentDisconnectedc C s d| _ d S r4 )rI rJ r r r �transportConnectedz s z'JabberServiceHarness.transportConnectedN)r r r r rK rL rM r r r r rF n s rF c @ s e Zd Zdd� ZdS )�JabberServiceManagerTestsc C s� t �dd�}t� }|�|� g }|�� �d �}| |_|j|j_|� � | � d|j � |� |t j� | � d|j� |�d � | � d|j� d S )NZfoor T)r ZServiceManagerrF ZsetServiceParentZ getFactory� buildProtocolr; r r r" r+ rI �dispatchr r= rG �connectionLostrH )r �smZsvcZwlistr@ r r r �testSM s z JabberServiceManagerTests.testSMN)r r r rS r r r r rN ~ s rN c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � RouterTestsz( Tests for L{component.Router}. c s| t �� }g � � fdd�|_t� }|�d|j� | �dt|j�� | �|j|jd � t � d�}|j � |� | �|g� � dS )zJ Test route registration and routing on incoming stanzas. c s � � | �S r �r ��element�Zroutedr r �<lambda>� � z+RouterTests.test_addRoute.<locals>.<lambda>z example.orgr9 )Ztestns�testN) r �RouterZrouter �addRoute�sinkr+ �len�routesr �Element�sourcer! )r �router�piperW r rX r � test_addRoute� s zRouterTests.test_addRoutec s� t � }t � }t�� }|�d|j� |�d|j� g � |j�d� fdd�� t�d�}d|d< d|d< |j� |� | � |g� � d S ) z, Test routing of a message. �component1.example.orgzcomponent2.example.org�/*c s � � | �S r rU rV ��outgoingr r rY � rZ z(RouterTests.test_route.<locals>.<lambda>�NZpresence�from�toN� r r r\ r] r^ rb r< r ra r! r+ )r � component1Z component2rc �stanzar rh r � test_route� s zRouterTests.test_routec s� t � }t � }t�� }|�d|j� |�d|j� g � |j�d� fdd�� t�d�}d|d< d|d < |j� |� | � |g� � dS ) a Test routing of a message using the default route. The default route is the one with L{None} as its key in the routing table. It is taken when there is no more specific route in the routing table that matches the stanza's destination. rf Nrg c s � � | �S r rU rV rh r r rY � rZ z/RouterTests.test_routeDefault.<locals>.<lambda>rj rk z example.comrl rm )r rn Zs2src ro r rh r �test_routeDefault� s z RouterTests.test_routeDefaultN)r r r rE re rp rq r r r r rT � s rT c @ sX e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dS )�!ListenComponentAuthenticatorTestsz> Tests for L{component.ListenComponentAuthenticator}. c C s, g | _ t�d�}t�|�| _| j j| j_d S )Nr )r r Z ListenComponentAuthenticatorr r r r! )r r r r r r' � s z'ListenComponentAuthenticatorTests.setUpc C s | j �d� dS )zA Stub loseConnection because we are a transport. z no reasonN)r rQ r& r r r �loseConnection� s z0ListenComponentAuthenticatorTests.loseConnectionc s� g � � fdd�}| j }||_|�| � | �d|j� | �|j� |�d� | �d|j � | � d|j� | � |j� | �d|j j f� d � dS )zK The received stream header should set several attributes. c s � � | |f� d S r rU )�eventZ observerfn�Z observersr r �addOnetimeObserver� s zPListenComponentAuthenticatorTests.test_streamStarted.<locals>.addOnetimeObserverNzz<stream:stream xmlns='jabber:component:accept' xmlns:stream='http://etherx.jabber.org/streams' to='component.example.org'>)r r rg r( )r rv �makeConnection�assertIdenticalr$ � assertFalseZ _headerSentr# r+ �version�assertNotIdenticalZ assertTruer � onElement)r rv r@ r ru r �test_streamStarted� s � z4ListenComponentAuthenticatorTests.test_streamStartedc C sL g }| j }|j|_|�| � |�d� | �dt|�� | �d|d j� dS )zM The received stream header should have a correct namespace. zp<stream:stream xmlns='jabber:client' xmlns:stream='http://etherx.jabber.org/streams' to='component.example.org'>r9 zinvalid-namespacer( N�r r �sendStreamErrorrw r# r+ r_ � condition�r � streamErrorsr@ r r r � test_streamStartedWrongNamespace s �zBListenComponentAuthenticatorTests.test_streamStartedWrongNamespacec C sL g }| j }|j|_|�| � |�d� | �dt|�� | �d|d j� dS )zJ The received stream header should have a 'to' attribute. z_<stream:stream xmlns='jabber:component:accept' xmlns:stream='http://etherx.jabber.org/streams'>r9 zimproper-addressingr( Nr~ r� r r r �test_streamStartedNoTo s �z8ListenComponentAuthenticatorTests.test_streamStartedNoToc C sH g }| j }|j|j_t�d�}|�d� |j�|� | �d|d � dS )z< We expect a handshake element with a hash. )�jabber:component:acceptr) �1234r( N) r r r � onHandshaker ra Z addContentr| r+ )r � handshakesr@ r) r r r �test_onElement+ s z0ListenComponentAuthenticatorTests.test_onElementc C sV g }g }| j }|j|j_|j|_t�d�}|j�|� | �|� | � d|d j � dS )z9 Reject elements that are not handshakes )r� �message�not-authorizedr( N) r r r r� r r ra r| ry r+ r� )r r� r� r@ rW r r r �test_onElementNotHandshake9 s z<ListenComponentAuthenticatorTests.test_onElementNotHandshakec s` g � � fdd�}| j }|�t j|� d|_d}|j�|� | �d| jd � | �dt� �� dS ) zU Receiving a handshake matching the secret authenticates the stream. c s � � | � d S r rU �r@ �Zauthdr r � authenticatedO s zIListenComponentAuthenticatorTests.test_onHandshake.<locals>.authenticatedr� Z(32532c0f7dbf1253c095b18b18e36d38d94c1256r: r( r9 N) r rv r= r$ r r� r+ r r_ )r r� r@ �theHashr r� r �test_onHandshakeI s z2ListenComponentAuthenticatorTests.test_onHandshakec sl g }g � � fdd�}| j }|�t j|� |j|_d|_d}|j�|� | �d|d j � | �dt � �� dS )zH Receiving a bad handshake should yield a stream error. c s � � | � d S r rU r� r� r r r� a s zRListenComponentAuthenticatorTests.test_onHandshakeWrongHash.<locals>.authenticatedr� r� r( r N) r rv r= r r r$ r r� r+ r� r_ )r r� r� r@ r� r r� r �test_onHandshakeWrongHashZ s z;ListenComponentAuthenticatorTests.test_onHandshakeWrongHashN) r r r rE r' rs r} r� r� r� r� r� r� r r r r rr � s rr c @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dS )� XMPPComponentServerFactoryTestsz< Tests for L{component.XMPPComponentServerFactory}. c C s8 t �� | _t �| jd�| _| j�d �| _td�| j_d S )Nr �component.example.org) r r\ rc ZXMPPComponentServerFactory�factoryrO r r Z thisEntityr& r r r r' t s z%XMPPComponentServerFactoryTests.setUpc C sV | j �| j t j� | �d| j j� | �d| jj� | �d| j j� | �d| j j� dS )zY A new connection increases the stream serial count. No logs by default. r r9 N) r rP �STREAM_CONNECTED_EVENTr+ �serialr� rx � rawDataInFn� rawDataOutFnr& r r r �test_makeConnectionz s z3XMPPComponentServerFactoryTests.test_makeConnectionc C s> d| j _| j�| jtj� | �d| jj� | �d| jj� dS )zD Setting logTraffic should set up raw data loggers. TN)r� Z logTrafficr rP r� r{ r� r� r& r r r � test_makeConnectionLogTraffic� s z=XMPPComponentServerFactoryTests.test_makeConnectionLogTrafficc C sX | j �| j t j� G dd� dt�}t�|� �}| j �|t j� | �dt| � |��� dS )zQ An observer for stream errors should trigger onError to log it. c @ s e Zd ZdS )z?XMPPComponentServerFactoryTests.test_onError.<locals>.TestErrorN)r r r r r r r � TestError� s r� r9 N) r rP r� � Exceptionr ZFailureZSTREAM_ERROR_EVENTr+ r_ ZflushLoggedErrors)r r� �reasonr r r � test_onError� s z,XMPPComponentServerFactoryTests.test_onErrorc C s< | j �| j t j� | �d| jj� | �| j | jjd � dS )zG Make sure a new stream is added to the routing table. r� N)r rP r= ZassertInrc r` rx r& r r r �test_connectionInitialized� s �z:XMPPComponentServerFactoryTests.test_connectionInitializedc C s6 | j �| j t j� | j �dt j� | �d| jj� dS )zU Make sure a stream is removed from the routing table on disconnect. Nr� )r rP r= ZSTREAM_END_EVENTZ assertNotInrc r` r& r r r �test_connectionLost� s z3XMPPComponentServerFactoryTests.test_connectionLostN) r r r rE r' r� r� r� r� r� r r r r r� o s r� N) rE �hashlibr Zzope.interface.verifyr Ztwisted.pythonr Z twisted.trialr Z twisted.words.protocols.jabberr r r Z"twisted.words.protocols.jabber.jidr Ztwisted.words.xishr Ztwisted.words.xish.utilityr r ZTestCaser r3 rB rC rF rN rT rr r� r r r r �<module> s$ ( "?
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка