| Server IP : 209.38.156.173 / Your IP : 216.73.216.122 [ Web Server : Apache/2.4.52 (Ubuntu) System : Linux lakekumayuhotel 5.15.0-136-generic #147-Ubuntu SMP Sat Mar 15 15:53:30 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.1.2-1ubuntu2.22 Disable Function : NONE Domains : 2 Domains MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /usr/lib/python3/dist-packages/twisted/words/test/__pycache__/ |
Upload File : |
o
�bl$ � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZ ddl m
Z
G dd� d�Z G d d
� d
�Z G d d � d ej
�ZG d
d� dej
�ZdS )z+
Test cases for twisted.words.xish.utility
� )� OrderedDict)�unittest)�utility)�Element)�EventDispatcherc @ s e Zd ZdZdd� Zdd� ZdS )�CallbackTrackerz�
Test helper for tracking callbacks.
Increases a counter on each call to L{call} and stores the object
passed in the call.
c C s d| _ d | _d S )Nr ��called�obj��self� r
�B/usr/lib/python3/dist-packages/twisted/words/test/test_xishutil.py�__init__ s
zCallbackTracker.__init__c C s | j d | _ || _d S )N� r )r r
r
r
r �call s
zCallbackTracker.callN)�__name__�
__module__� __qualname__�__doc__r r r
r
r
r r s r c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) �OrderedCallbackTrackerz=
Test helper for tracking callbacks and their order.
c C s
g | _ d S �N)�callListr r
r
r r ' s
z OrderedCallbackTracker.__init__c C � | j �| j� d S r )r �append�call1�r �objectr
r
r r * � z OrderedCallbackTracker.call1c C r r )r r �call2r r
r
r r - r z OrderedCallbackTracker.call2c C r r )r r �call3r r
r
r r 0 r z OrderedCallbackTracker.call3N)r r r r r r r r r
r
r
r r " s r c @ sp e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� ZdS )�EventDispatcherTestsz'
Tests for L{EventDispatcher}.
c C s< t � }t� }t� }t� }|�d|j� |�d|j� |�d|j� |�d|j� td�}|�d� td�}|�d� |�|� | �|jd � | �|j |� | �|jd
� |�|� | �|jd � | �|jd � | �|j |� | �|jd
� |�|d� | �|jd � | �|j |� |�
d|j� |�|� | �|jd � d S ) N�
/message/body�/message� /presence�//event/testevent��ns�message�body�r' �presencer+ � r r ) r r � addObserverr r �
addElement�dispatch� assertEqualr r
�removeObserver)r �d�cb1�cb2�cb3�msg�presr
r
r � testStuff9 s6
z EventDispatcherTests.testStuffc C sv t � }t� }t� }|�d|j� |�d|j� |�|d� | �|jd� | �|j|� | �|jd� | �|j|� dS )z�
Test adding two observers for the same query.
When the event is dispatched both of the observers need to be called.
r% r N)r r r- r r/ r0 r r
)r r2 r3 r4 r
r
r �test_addObserverTwice] s z*EventDispatcherTests.test_addObserverTwicec sz t � �td�}t� � � �fdd�}��d|� ��|� | �� jd� ��|� | �� jd� ��|� | �� jd� dS ) zG
Test for registration of an observer during dispatch.
r& c � �� d� j� d S �Nr# )r- r ��_��cbr2 r
r � onMessagex r zBEventDispatcherTests.test_addObserverInDispatch.<locals>.onMessager# r r r, N�r r r �addOnetimeObserverr/ r0 r �r r6 r@ r
r> r �test_addObserverInDispatchp �
z/EventDispatcherTests.test_addObserverInDispatchc sz t � �td�}t� � � �fdd�}��d|� ��|� | �� jd� ��|� | �� jd� ��|� | �� jd� dS )zN
Test for registration of a onetime observer during dispatch.
r& c r: r; )rB r )r6 r> r
r r@ � r zIEventDispatcherTests.test_addOnetimeObserverInDispatch.<locals>.onMessager# r r NrA rC r
r> r �!test_addOnetimeObserverInDispatch� rE z6EventDispatcherTests.test_addOnetimeObserverInDispatchc C sV t � }td�}t� }|�d|j� |�|� | �|jd� |�|� | �|jd� d S )Nr& r# r )r r r rB r r/ r0 r )r r2 r6 r? r
r
r �testOnetimeDispatch� s
z(EventDispatcherTests.testOnetimeDispatchc C sZ t � }td�}td�}t� }|�d|j� |�|�}| �d|� |�|�}| �d|� d S )Nr& r* r$ FT)r r r r- r r/ r0 )r r2 r6 r7 r? �resultr
r
r �testDispatcherResult� s
z)EventDispatcherTests.testDispatcherResultc C s� t � }t� }|�d|j� |�d|jd� |�d|jd� td�}|�d� |�|� | � |j
|j|j|jgdt dd � |j
D �� � d S )
Nr" r# ���r r& r) zCalls out of order: %sc S s g | ]}|j �qS r
)r )�.0�cr
r
r �
<listcomp>� s zAEventDispatcherTests.testOrderedXPathDispatch.<locals>.<listcomp>) r r r- r r r r r. r/ r0 r �repr�r r2 r? r6 r
r
r �testOrderedXPathDispatch� s
�z-EventDispatcherTests.testOrderedXPathDispatchc C s^ t � }t� }|�d|j� |�dd� | �d|j� |�d|j� | �dt|j �
d��� dS )zO
Test observer clean-up after removeObserver for named events.
� //event/testNr r ) r r r- r r/ r0 r r1 �len�_eventObservers�pop�r r2 r? r
r
r � test_cleanUpRemoveEventObserver� s z4EventDispatcherTests.test_cleanUpRemoveEventObserverc C sd t � }t� }td�}|�d|j� |�|� | �d|j� |�d|j� | �dt |j
� d��� dS )zO
Test observer clean-up after removeObserver for XPath events.
�Nr( r# r r N) r r r r- r r/ r0 r r1 rR �_xpathObserversrT rO r
r
r � test_cleanUpRemoveXPathObserver� s
z4EventDispatcherTests.test_cleanUpRemoveXPathObserverc C sP t � }t� }|�d|j� |�dd� | �d|j� | �dt|j� d��� dS )zD
Test observer clean-up after onetime named events.
rQ Nr r )
r r rB r r/ r0 r rR rS rT rU r
r
r � test_cleanUpOnetimeEventObserver� s z5EventDispatcherTests.test_cleanUpOnetimeEventObserverc C sV t � }t� }td�}|�d|j� |�|� | �d|j� | �dt|j �
d��� dS )zD
Test observer clean-up after onetime XPath events.
rW r# r r N) r r r rB r r/ r0 r rR rX rT rO r
r
r � test_cleanUpOnetimeXPathObserver� s
z5EventDispatcherTests.test_cleanUpOnetimeXPathObserverc s� G dd� dt j�}G dd� dt�� � fdd�}t� }t� }t j}z?|t _|�d|� |�d|j� z|�dd� W n � yG | �d � Y nw | � d
t
| � � ��� | � d
|j � W |t _dS |t _w ) z�
Test that exceptions in observers do not bubble up to dispatch.
The exceptions raised in observers should be logged and other
observers should be called as if nothing happened.
c @ s e Zd Zdd� ZdS )zOEventDispatcherTests.test_observerRaisingException.<locals>.OrderedCallbackListc S s t � | _d S r )r � callbacksr r
r
r r s zXEventDispatcherTests.test_observerRaisingException.<locals>.OrderedCallbackList.__init__N)r r r r r
r
r
r �OrderedCallbackList
s r] c @ s e Zd ZdS )zEEventDispatcherTests.test_observerRaisingException.<locals>.TestErrorN)r r r r
r
r
r � TestError s r^ c s � � �r r
r< �r^ r
r �
raiseError s zFEventDispatcherTests.test_observerRaisingException.<locals>.raiseErrorrQ Nz2TestError raised. Should have been logged instead.r )
r � CallbackList� Exceptionr r r- r r/ �failr0 rR �flushLoggedErrorsr )r r] r` r2 r? �originalCallbackListr
r_ r � test_observerRaisingException s$ �z2EventDispatcherTests.test_observerRaisingExceptionN)r r r r r8 r9 rD rF rG rI rP rV rY rZ r[ rf r
r
r
r r! 4 s $
r! c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � XmlPipeTestsz:
Tests for L{twisted.words.xish.utility.XmlPipe}.
c C s t �� | _d S r )r �XmlPipe�piper r
r
r �setUp. � zXmlPipeTests.setUpc �H � fdd�}g � | j j�d|� td�}| j j�|� | �|g� � dS )zO
Send an element from the source and observe it from the sink.
c � � � | � d S r �r �r
�r r
r r? 6 rk z,XmlPipeTests.test_sendFromSource.<locals>.cb�/test[@xmlns="testns"]��testns�testN)ri �sinkr- r �source�sendr0 �r r? �elementr
rp r �test_sendFromSource1 � z XmlPipeTests.test_sendFromSourcec rl )zO
Send an element from the sink and observe it from the source.
c rm r rn ro rp r
r r? D rk z*XmlPipeTests.test_sendFromSink.<locals>.cbrq rr N)ri rv r- r ru rw r0 rx r
rp r �test_sendFromSink? r{ z XmlPipeTests.test_sendFromSinkN)r r r r rj rz r| r
r
r
r rg ) s
rg N)r � collectionsr �
twisted.trialr �twisted.words.xishr �twisted.words.xish.domishr �twisted.words.xish.utilityr r r �TestCaser! rg r
r
r
r �<module> s v