File: //usr/lib/python3/dist-packages/twisted/logger/test/__pycache__/test_observer.cpython-38.pyc
U
W[� � @ sZ d Z ddlmZmZ ddlmZ ddlmZ ddlm Z ddlm
Z
G dd � d ej �Z d
S ) z-
Test cases for L{twisted.logger._observer}.
� )� verifyObject�BrokenMethodImplementation)�unittest� )�Logger)� ILogObserver)� LogPublisherc @ s` e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dS )�LogPublisherTestsz$
Tests for L{LogPublisher}.
c
C sF t � }ztt|� W n, tk
r@ } z| �|� W 5 d}~X Y nX dS )z8
L{LogPublisher} is an L{ILogObserver}.
N)r r r r Zfail)�self� publisher�e� r
�C/usr/lib/python3/dist-packages/twisted/logger/test/test_observer.py�test_interface s
z LogPublisherTests.test_interfacec C s8 dd� }dd� }t ||�}| �t||f�t|j�� dS )zB
L{LogPublisher.observers} returns the observers.
c S s d S �Nr
�r r
r
r �<lambda>& � z2LogPublisherTests.test_observers.<locals>.<lambda>c S s d S r r
r r
r
r r ' r N)r � assertEqual�set�
_observers)r
�o1�o2r r
r
r �test_observers" s
z LogPublisherTests.test_observersc C sL dd� }dd� }dd� }t ||�}|�|� | �t|||f�t|j�� dS )z?
L{LogPublisher.addObserver} adds an observer.
c S s d S r r
r r
r
r r 1 r z4LogPublisherTests.test_addObserver.<locals>.<lambda>c S s d S r r
r r
r
r r 2 r c S s d S r r
r r
r
r r 3 r N)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 Z assertRaises� TypeErrorr �object)r
r r
r
r �test_addObserverNotCallable: s z-LogPublisherTests.test_addObserverNotCallablec C sL dd� }dd� }dd� }t |||�}|�|� | �t||f�t|j�� dS )zE
L{LogPublisher.removeObserver} removes an observer.
c S s d S r r
r r
r
r r G r z7LogPublisherTests.test_removeObserver.<locals>.<lambda>c S s d S r r
r r
r
r r H r c S s d S r r
r r
r
r r I r N�r ZremoveObserverr r r r r
r
r �test_removeObserverC s
z%LogPublisherTests.test_removeObserverc C sJ dd� }dd� }dd� }t ||�}|�|� | �t||f�t|j�� dS )zd
L{LogPublisher.removeObserver} removes an observer that is not
registered.
c S s d S r r
r r
r
r r U r zDLogPublisherTests.test_removeObserverNotRegistered.<locals>.<lambda>c S s d S r r
r r
r
r r V r c S s d S r r
r r
r
r r W r Nr! r r
r
r � test_removeObserverNotRegisteredP s
z2LogPublisherTests.test_removeObserverNotRegisteredc sx t ddd�}g � g �g �� fdd�}�fdd�}�fdd�}t|||�}||� | �|� � | �|�� | �|�� dS ) z6
L{LogPublisher} calls its observers.
� r ��foo�barc s
� � | �S r ��appendr )�events1r
r r h r z/LogPublisherTests.test_fanOut.<locals>.<lambda>c s
� � | �S r r( r )�events2r
r r i r c s
� � | �S r r( r )�events3r
r r j r N)�dictr �assertIn)r
�eventr r r r r
)r* r+ r, r � test_fanOut^ s z LogPublisherTests.test_fanOutc s� t ddd�}td��g � � �fdd�}g }t||j�}||� | �|� � dd� |D �}| �t|�d� | �|d j�� | �t� �d� d
S ) z}
Observer raises an exception during fan out: a failure is logged, but
not re-raised. Life goes on.
r$ r r% �ARGH! EVIL DEATH!c s � }� � | � |r��d S r r( )r/ Z shouldRaise�Zevents� exceptionr
r �observer} s
z7LogPublisherTests.test_observerRaises.<locals>.observerc S s g | ]}d |kr|d �qS )Z log_failurer
)�.0r r
r
r �
<listcomp>� s �z9LogPublisherTests.test_observerRaises.<locals>.<listcomp>r N) r- � RuntimeErrorr r) r. r �lenZassertIs�value)r
r/ r4 Z collectorr �errorsr
r2 r �test_observerRaisess s �z%LogPublisherTests.test_observerRaisesc sL t ddd�}td�� dd� }G � fdd�dt�}t|�}|� |_||� d S )
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 r% r1 c S s t d��d S )Nz Sad panda)r7 )r/ r
r
r r4 � s zGLogPublisherTests.test_observerRaisesAndLoggerHatesMe.<locals>.observerc s e Zd Z� fdd�ZdS )zILogPublisherTests.test_observerRaisesAndLoggerHatesMe.<locals>.GurkLoggerc s � �d S r r
)r
�args�kwargs�r3 r
r �failure� s zQLogPublisherTests.test_observerRaisesAndLoggerHatesMe.<locals>.GurkLogger.failureN)�__name__�
__module__� __qualname__r? r
r> r
r �
GurkLogger� s rC N)r- r7 r r �log)r
r/ r4 rC r r
r> r �#test_observerRaisesAndLoggerHatesMe� s z5LogPublisherTests.test_observerRaisesAndLoggerHatesMec sr t ddg d�}i � � fdd�}� fdd�}t||�}||� | �� d ||ff� | �� d ||f||ff� dS )zA
Tracing keeps track of forwarding to observers.
r$ r )r& r' � log_tracec s � � dt| d ��S )Nr$ rF ��
setdefault�tupler �Ztracesr
r r � r z.LogPublisherTests.test_trace.<locals>.<lambda>c s � � dt| d ��S )Nr rF rG r rJ r
r r � r N)r- r r )r
r/ r r r r
rJ r �
test_trace� s
z LogPublisherTests.test_traceN)r@ rA rB �__doc__r r r r r" r# r0 r; rE rK r
r
r
r r s
#r N)
rL Zzope.interface.verifyr r Z
twisted.trialr Z_loggerr Z _observerr r ZTestCaser r
r
r
r �<module> s