U  W[@sZdZddlmZmZddlmZddlmZddlm Z ddlm Z Gdd d ej Z d S) z- Test cases for L{twisted.logger._observer}. ) verifyObjectBrokenMethodImplementation)unittest)Logger) ILogObserver) LogPublisherc@s`eZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ ddZ ddZ dS)LogPublisherTestsz$ Tests for L{LogPublisher}. c CsFt}ztt|Wn,tk r@}z||W5d}~XYnXdS)z8 L{LogPublisher} is an L{ILogObserver}. N)rrrrZfail)self publisherer C/usr/lib/python3/dist-packages/twisted/logger/test/test_observer.pytest_interfaces z LogPublisherTests.test_interfacecCs8dd}dd}t||}|t||ft|jdS)zB L{LogPublisher.observers} returns the observers. cSsdSNr r r r r&z2LogPublisherTests.test_observers..cSsdSrr rr r rr'rN)r assertEqualset _observers)r o1o2r r r rtest_observers"s z LogPublisherTests.test_observerscCsLdd}dd}dd}t||}|||t|||ft|jdS)z? L{LogPublisher.addObserver} adds an observer. cSsdSrr rr r rr1rz4LogPublisherTests.test_addObserver..cSsdSrr rr r rr2rcSsdSrr rr r rr3rN)r addObserverrrrr rro3r r r rtest_addObserver-s   z"LogPublisherTests.test_addObservercCst}|t|jtdS)ze L{LogPublisher.addObserver} refuses to add an observer that's not callable. N)rZ assertRaises TypeErrorrobject)r r r r rtest_addObserverNotCallable:sz-LogPublisherTests.test_addObserverNotCallablecCsLdd}dd}dd}t|||}|||t||ft|jdS)zE L{LogPublisher.removeObserver} removes an observer. cSsdSrr rr r rrGrz7LogPublisherTests.test_removeObserver..cSsdSrr rr r rrHrcSsdSrr rr r rrIrNrZremoveObserverrrrrr r rtest_removeObserverCs   z%LogPublisherTests.test_removeObservercCsJdd}dd}dd}t||}|||t||ft|jdS)zd L{LogPublisher.removeObserver} removes an observer that is not registered. cSsdSrr rr r rrUrzDLogPublisherTests.test_removeObserverNotRegistered..cSsdSrr rr r rrVrcSsdSrr rr r rrWrNr!rr r r test_removeObserverNotRegisteredPs   z2LogPublisherTests.test_removeObserverNotRegisteredcsxtddd}gggfdd}fdd}fdd}t|||}||||||||dS) z6 L{LogPublisher} calls its observers. rfoobarcs |Srappendr)events1r rrhrz/LogPublisherTests.test_fanOut..cs |Srr(r)events2r rrircs |Srr(r)events3r rrjrN)dictrassertIn)r eventrrrr r )r*r+r,r test_fanOut^s       zLogPublisherTests.test_fanOutcstddd}tdgfdd}g}t||j}||||dd|D}|t|d||d j|tdd S) z} Observer raises an exception during fan out: a failure is logged, but not re-raised. Life goes on. r$rr%ARGH! EVIL DEATH!cs }||rdSrr()r/Z shouldRaiseZevents exceptionr robserver}s z7LogPublisherTests.test_observerRaises..observercSsg|]}d|kr|dqS)Z log_failurer ).0r r r r sz9LogPublisherTests.test_observerRaises..rN) r- RuntimeErrorrr)r.rlenZassertIsvalue)r r/r4Z collectorr errorsr r2rtest_observerRaisesss   z%LogPublisherTests.test_observerRaisescsLtddd}tddd}Gfdddt}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$rr%r1cSs tddS)Nz Sad panda)r7)r/r r rr4szGLogPublisherTests.test_observerRaisesAndLoggerHatesMe..observercseZdZfddZdS)zILogPublisherTests.test_observerRaisesAndLoggerHatesMe..GurkLoggercsdSrr )r argskwargsr3r rfailureszQLogPublisherTests.test_observerRaisesAndLoggerHatesMe..GurkLogger.failureN)__name__ __module__ __qualname__r?r r>r r GurkLoggersrCN)r-r7rrlog)r r/r4rCr r r>r#test_observerRaisesAndLoggerHatesMes z5LogPublisherTests.test_observerRaisesAndLoggerHatesMecsrtddgd}ifdd}fdd}t||}|||d||ff|d||f||ffdS)zA Tracing keeps track of forwarding to observers. r$r)r&r' log_tracecsdt|dS)Nr$rF setdefaulttuplerZtracesr rrrz.LogPublisherTests.test_trace..csdt|dS)NrrFrGrrJr rrrN)r-rr)r r/rrr r rJr test_traces   zLogPublisherTests.test_traceN)r@rArB__doc__rrrr r"r#r0r;rErKr r r rr s     #r N) rLZzope.interface.verifyrrZ twisted.trialrZ_loggerrZ _observerrrZTestCaser r r r rs