| 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 : /lib/python3/dist-packages/twisted/logger/test/__pycache__/ |
Upload File : |
o
�b* � @ s� d Z ddlmZmZmZmZ ddlmZ ddlm Z ddl
m Z ddl m
Z
ddlmZmZ dd lmZ dd
lmZ G d d � d e
j�Zd
S )z-
Test cases for L{twisted.logger._observer}.
� )�Dict�List�Tuple�cast)� implementer)�BrokenMethodImplementation)� verifyObject)�unittest� )� ILogObserver�LogEvent)�Logger)� LogPublisherc @ st e Zd ZdZddd�Zddd�Zddd �Zdd
d �Zdd d
�Zddd�Z ddd�Z
ddd�Z ddd�Z ddd�Z
dS )�LogPublisherTestsz$
Tests for L{LogPublisher}.
�returnNc
C sH t � }ztt|� W dS ty# } z | �|� W Y d}~dS d}~ww )z8
L{LogPublisher} is an L{ILogObserver}.
N)r r r r �fail)�self� publisher�e� r �C/usr/lib/python3/dist-packages/twisted/logger/test/test_observer.py�test_interface s ��z LogPublisherTests.test_interfacec C s@ t tdd� �}t tdd� �}t||�}| �||ht|j�� dS )zB
L{LogPublisher.observers} returns the observers.
c S � d S �Nr �r r r r �<lambda>' � z2LogPublisherTests.test_observers.<locals>.<lambda>c S r r r r r r r r ( r N)r r r � assertEqual�set�
_observers)r �o1�o2r r r r �test_observers# s
z LogPublisherTests.test_observersc C sZ t tdd� �}t tdd� �}t tdd� �}t||�}|�|� | �|||ht|j�� dS )z?
L{LogPublisher.addObserver} adds an observer.
c S r r r r r r r r 1 r z4LogPublisherTests.test_addObserver.<locals>.<lambda>c S r r r r r r r r 2 r c S r r r r r r r r 3 r N)r r r � addObserverr r r �r r r! �o3r r r r �test_addObserver- s
z"LogPublisherTests.test_addObserverc C s t � }| �t|jt� � dS )ze
L{LogPublisher.addObserver} refuses to add an observer that's
not callable.
N)r � assertRaises� TypeErrorr# �object)r r r r r �test_addObserverNotCallable9 s z-LogPublisherTests.test_addObserverNotCallablec C sZ t tdd� �}t tdd� �}t tdd� �}t|||�}|�|� | �||ht|j�� dS )zE
L{LogPublisher.removeObserver} removes an observer.
c S r r r r r r r r E r z7LogPublisherTests.test_removeObserver.<locals>.<lambda>c S r r r r r r r r F r c S r r r r r r r r G r N�r r r �removeObserverr r r r$ r r r �test_removeObserverA s
z%LogPublisherTests.test_removeObserverc C sX t tdd� �}t tdd� �}t tdd� �}t||�}|�|� | �||ht|j�� dS )zd
L{LogPublisher.removeObserver} removes an observer that is not
registered.
c S r r r r r r r r R r zDLogPublisherTests.test_removeObserverNotRegistered.<locals>.<lambda>c S r r r r r r r r S r c S r r r r r r r r T r Nr+ r$ r r r � test_removeObserverNotRegisteredM s
z2LogPublisherTests.test_removeObserverNotRegisteredc C sx t ddd�}g }g }g }tt|j�}tt|j�}tt|j�}t|||�}||� | �||� | �||� | �||� dS )z6
L{LogPublisher} calls its observers.
� r
��foo�barN)�dictr r �appendr �assertIn) r �event�events1�events2�events3r r! r% r r r r � test_fanOutZ s z LogPublisherTests.test_fanOutc s� t ddd�}td��g � tt�dtddf� �fdd � �}g }t|tt|j��}||� | �|� � d
d � |D �}| � t
|�d� | � |d j �� | � t
� �d� dS )
z}
Observer raises an exception during fan out: a failure is logged, but
not re-raised. Life goes on.
r/ r
r0 �ARGH! EVIL DEATH!r6 r Nc s � }� � | � |r ��d S r )r4 )r6 � shouldRaise��events� exceptionr r �observerx s
�z7LogPublisherTests.test_observerRaises.<locals>.observerc S s g | ]
}d |v r|d �qS )� log_failurer )�.0r r r r �
<listcomp>� s z9LogPublisherTests.test_observerRaises.<locals>.<listcomp>r )
r3 � RuntimeErrorr r r r r r4 r5 r �len�assertIs�value)r r6 r@ � collectorr �errorsr r= r �test_observerRaisesn s z%LogPublisherTests.test_observerRaisesc s^ t ddd�}td�� tt�dtddfdd ��}G � fd
d �d t�}t|�}|� |_||� dS ) z�
Observer raises an exception during fan out and the publisher's Logger
pukes when the failure is reported. The exception does not propagate
back to the caller.
r/ r
r0 r; r6 r Nc S s t d��)Nz Sad panda)rD )r6 r r r r@ � s zGLogPublisherTests.test_observerRaisesAndLoggerHatesMe.<locals>.observerc s& e Zd Zdededdf� fdd� ZdS )zILogPublisherTests.test_observerRaisesAndLoggerHatesMe.<locals>.GurkLogger�args�kwargsr Nc s � �r r )r rK rL �r? r r �failure� s zQLogPublisherTests.test_observerRaisesAndLoggerHatesMe.<locals>.GurkLogger.failure)�__name__�
__module__� __qualname__r) rN r rM r r �
GurkLogger� s rR )r3 rD r r r r
r �log)r r6 r@ rR r r rM r �#test_observerRaisesAndLoggerHatesMe� s z5LogPublisherTests.test_observerRaisesAndLoggerHatesMec s� t ddg d�}i � tt�dtddf� fdd� �}tt�dtddf� fd d
� �}t||�}||� | �� d ||ff� | �� d ||f||ff� dS ) zA
Tracing keeps track of forwarding to observers.
r/ r
)r1 r2 � log_tracer r Nc �* � � dtttttf t| d ��� d S )Nr/ rU ��
setdefaultr r r
r �tupler ��tracesr r r � � �z(LogPublisherTests.test_trace.<locals>.o1c rV )Nr
rU rW r rZ r r r! � r\ z(LogPublisherTests.test_trace.<locals>.o2)r3 r r r r r )r r6 r r! r r rZ r �
test_trace� s
z LogPublisherTests.test_trace)r N)rO rP rQ �__doc__r r" r& r* r- r. r: rJ rT r] r r r r r s
r N)r^ �typingr r r r �zope.interfacer �zope.interface.exceptionsr �zope.interface.verifyr �
twisted.trialr � _interfacesr r �_loggerr
� _observerr �TestCaser r r r r �<module> s