← Back
Editing: 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
Save File
Cancel