o b*@sdZddlmZmZmZmZddlmZddlm Z ddl m Z ddl m Z ddlmZmZdd lmZdd lmZGd d d e jZd S)z- Test cases for L{twisted.logger._observer}. )DictListTuplecast) implementer)BrokenMethodImplementation) verifyObject)unittest) ILogObserverLogEvent)Logger) LogPublisherc@steZdZdZdddZdddZddd Zdd d Zdd d ZdddZ dddZ dddZ dddZ dddZ dS)LogPublisherTestsz$ Tests for L{LogPublisher}. returnNc CsHt}ztt|WdSty#}z ||WYd}~dSd}~ww)z8 L{LogPublisher} is an L{ILogObserver}. N)rrr rfail)self publishererC/usr/lib/python3/dist-packages/twisted/logger/test/test_observer.pytest_interfacesz LogPublisherTests.test_interfacecCs@ttdd}ttdd}t||}|||ht|jdS)zB L{LogPublisher.observers} returns the observers. cSdSNrrrrr'z2LogPublisherTests.test_observers..cSrrrrrrrr(rN)rr r assertEqualset _observers)ro1o2rrrrtest_observers#s z LogPublisherTests.test_observerscCsZttdd}ttdd}ttdd}t||}||||||ht|jdS)z? L{LogPublisher.addObserver} adds an observer. cSrrrrrrrr1rz4LogPublisherTests.test_addObserver..cSrrrrrrrr2rcSrrrrrrrr3rN)rr r addObserverrrrrr r!o3rrrrtest_addObserver-s   z"LogPublisherTests.test_addObservercCst}|t|jtdS)ze L{LogPublisher.addObserver} refuses to add an observer that's not callable. N)r assertRaises TypeErrorr#object)rrrrrtest_addObserverNotCallable9sz-LogPublisherTests.test_addObserverNotCallablecCsZttdd}ttdd}ttdd}t|||}|||||ht|jdS)zE L{LogPublisher.removeObserver} removes an observer. cSrrrrrrrrErz7LogPublisherTests.test_removeObserver..cSrrrrrrrrFrcSrrrrrrrrGrNrr rremoveObserverrrrr$rrrtest_removeObserverAs   z%LogPublisherTests.test_removeObservercCsXttdd}ttdd}ttdd}t||}|||||ht|jdS)zd L{LogPublisher.removeObserver} removes an observer that is not registered. cSrrrrrrrrRrzDLogPublisherTests.test_removeObserverNotRegistered..cSrrrrrrrrSrcSrrrrrrrrTrNr+r$rrr test_removeObserverNotRegisteredMs   z2LogPublisherTests.test_removeObserverNotRegisteredc Csxtddd}g}g}g}tt|j}tt|j}tt|j}t|||}|||||||||||dS)z6 L{LogPublisher} calls its observers. r foobarN)dictrr appendrassertIn) reventevents1events2events3r r!r%rrrr test_fanOutZs       zLogPublisherTests.test_fanOutcstddd}tdgttdtddffdd }g}t|tt|j}||||d d |D}| t |d| |d j | t ddS) z} Observer raises an exception during fan out: a failure is logged, but not re-raised. Life goes on. r/r r0ARGH! EVIL DEATH!r6rNcs }||r dSr)r4)r6 shouldRaiseevents exceptionrrobserverxs  z7LogPublisherTests.test_observerRaises..observercSsg|] }d|vr|dqS) log_failurer).0rrrr sz9LogPublisherTests.test_observerRaises..r) r3 RuntimeErrorrr r rrr4r5rlenassertIsvalue)rr6r@ collectorrerrorsrr=rtest_observerRaisesns  z%LogPublisherTests.test_observerRaisescs^tddd}tdttdtddfdd }Gfd 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 r0r;r6rNcSstd)Nz Sad panda)rD)r6rrrr@szGLogPublisherTests.test_observerRaisesAndLoggerHatesMe..observercs&eZdZdededdffdd ZdS)zILogPublisherTests.test_observerRaisesAndLoggerHatesMe..GurkLoggerargskwargsrNcsrr)rrKrLr?rrfailureszQLogPublisherTests.test_observerRaisesAndLoggerHatesMe..GurkLogger.failure)__name__ __module__ __qualname__r)rNrrMrr GurkLoggersrR)r3rDrr r r rlog)rr6r@rRrrrMr#test_observerRaisesAndLoggerHatesMes  z5LogPublisherTests.test_observerRaisesAndLoggerHatesMecstddgd}ittdtddffdd }ttdtddffd d }t||}|||d||ff|d||f||ffdS) zA Tracing keeps track of forwarding to observers. r/r )r1r2 log_tracerrNc*dtttttft|ddS)Nr/rU setdefaultrrr r tuplertracesrrr z(LogPublisherTests.test_trace..o1crV)Nr rUrWrrZrrr!r\z(LogPublisherTests.test_trace..o2)r3rr r rr)rr6r r!rrrZr test_traces  zLogPublisherTests.test_trace)rN)rOrPrQ__doc__rr"r&r*r-r.r:rJrTr]rrrrrs    rN)r^typingrrrrzope.interfacerzope.interface.exceptionsrzope.interface.verifyr twisted.trialr _interfacesr r _loggerr _observerrTestCaserrrrrs