Yf*dZddlmZmZmZmZddlmZddlm Z ddl m Z ddl m Z ddlmZmZdd lmZdd lmZGd d e jZd S)z- Test cases for L{twisted.logger._observer}. )DictListTuplecast) implementer)BrokenMethodImplementation) verifyObject)unittest) ILogObserverLogEvent)Logger) LogPublishercbeZdZdZddZddZddZddZddZdd Z dd Z dd Z dd Z dd Z dS)LogPublisherTestsz$ Tests for L{LogPublisher}. returnNct} tt|dS#t$r }||Yd}~dSd}~wwxYw)z8 L{LogPublisher} is an L{ILogObserver}. N)rr r rfail)self publisheres S/var/www/html/env/lib/python3.11/site-packages/twisted/logger/test/test_observer.pytest_interfacez LogPublisherTests.test_interfacesb!NN   y 1 1 1 1 1)    IIaLLLLLLLLL s' AA  Acttd}ttd}t||}|||ht |jdS)zB L{LogPublisher.observers} returns the observers. cdSNrs rz2LogPublisherTests.test_observers..'$cdSrrrs rrz2LogPublisherTests.test_observers..(r r!N)rr r assertEqualset _observers)ro1o2rs rtest_observersz LogPublisherTests.test_observers#s`, / / , / / R((  "b3y';#<#<=====r!c*ttd}ttd}ttd}t||}||||||ht |jdS)z? L{LogPublisher.addObserver} adds an observer. cdSrrrs rrz4LogPublisherTests.test_addObserver..1r r!cdSrrrs rrz4LogPublisherTests.test_addObserver..2r r!cdSrrrs rrz4LogPublisherTests.test_addObserver..3r r!N)rr r addObserverr#r$r%rr&r'o3rs rtest_addObserverz"LogPublisherTests.test_addObserver-s, / / , / / , / / R(( b!!! "b"s9+?'@'@AAAAAr!c|t}|t|jt dS)ze L{LogPublisher.addObserver} refuses to add an observer that's not callable. N)r assertRaises TypeErrorr-object)rrs rtest_addObserverNotCallablez-LogPublisherTests.test_addObserverNotCallable9s2 !NN  )Y%:FHHEEEEEr!c*ttd}ttd}ttd}t|||}|||||ht |jdS)zE L{LogPublisher.removeObserver} removes an observer. cdSrrrs rrz7LogPublisherTests.test_removeObserver..Er r!cdSrrrs rrz7LogPublisherTests.test_removeObserver..Fr r!cdSrrrs rrz7LogPublisherTests.test_removeObserver..Gr r!Nrr rremoveObserverr#r$r%r.s rtest_removeObserverz%LogPublisherTests.test_removeObserverAs, / / , / / , / / R,,   $$$ "b3y';#<#<=====r!c(ttd}ttd}ttd}t||}|||||ht |jdS)zd L{LogPublisher.removeObserver} removes an observer that is not registered. cdSrrrs rrzDLogPublisherTests.test_removeObserverNotRegistered..Rr r!cdSrrrs rrzDLogPublisherTests.test_removeObserverNotRegistered..Sr r!cdSrrrs rrzDLogPublisherTests.test_removeObserverNotRegistered..Tr r!Nr:r.s r test_removeObserverNotRegisteredz2LogPublisherTests.test_removeObserverNotRegisteredMs , / / , / / , / / R((   $$$ "b3y';#<#<=====r!ctdd}g}g}g}tt|j}tt|j}tt|j}t |||}|||||||||||dS)z6 L{LogPublisher} calls its observers. r foobarN)dictrr appendrassertIn) reventevents1events2events3r&r'r/rs r test_fanOutzLogPublisherTests.test_fanOutZs""""$"$"$ , / / , / / , / / R,,  % eW%%% eW%%% eW%%%%%r!ctdd}tdgttdtddffd }g}t |t t|j}||||d |D}| t|d| |d j | tddS) z} Observer raises an exception during fan out: a failure is logged, but not re-raised. Life goes on. rCr rDARGH! EVIL DEATH!rJrNc@ }||rdSr)rH)rJ shouldRaiseevents exceptions robserverz7LogPublisherTests.test_observerRaises..observerxs3$*K MM%    r!c&g|]}d|v|dS) log_failurer).0rs r z9LogPublisherTests.test_observerRaises..s'LLLq!9K9K!M"9K9K9Kr!r) rG RuntimeErrorrr r rrrHrIr#lenassertIsvalue)rrJrU collectorrerrorsrSrTs @@rtest_observerRaisesz%LogPublisherTests.test_observerRaisesns& """ !455 !# \ " " H        # " %'  4 i>N+O+OPP  % eV$$$MLILLL Va((( fQioy111 Va(((((r!ctdd}tdttdtddfd}Gfd 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. rCr rDrPrJrNc td)Nz Sad panda)rZ)rJs rrUzGLogPublisherTests.test_observerRaisesAndLoggerHatesMe..observers{++ +r!c(eZdZdededdffd ZdS)ILogPublisherTests.test_observerRaisesAndLoggerHatesMe..GurkLoggerargskwargsrNcrr)rrerfrTs rfailurezQLogPublisherTests.test_observerRaisesAndLoggerHatesMe..GurkLogger.failuresr!)__name__ __module__ __qualname__r4rh)rTsr GurkLoggerrdsH V v $        r!rl)rGrZrr r rrlog)rrJrUrlrrTs @r#test_observerRaisesAndLoggerHatesMez5LogPublisherTests.test_observerRaisesAndLoggerHatesMes """ !455 \ " " ,H , , , , # " ,          !** "  %r!ctddg}ittdtddffd }ttdtddffd }t ||}|||d||ff|d||f||ffdS) zA Tracing keeps track of forwarding to observers. rCr )rErF log_tracerrNc dtttttft |ddS)NrCrp setdefaultrrrr tuplertracess rr&z(LogPublisherTests.test_trace..o1O   4eFL$89:E!K..o2rwr!)rGrr r rr#)rrJr&r'rrvs @r test_tracezLogPublisherTests.test_tracesR000@B \ " " ( t      # "  \ " " ( t      # "  !R((  % i_$6777 i_y"o$FGGGGGr!)rN)rirjrk__doc__rr(r0r5r<rArNr`rnryrr!rrrs>>>> B B B BFFFF > > > > > > > >&&&&())))@.HHHHHHr!rN)rztypingrrrrzope.interfacerzope.interface.exceptionsrzope.interface.verifyr twisted.trialr _interfacesr r _loggerr _observerrTestCaserrr!rrs+***********&&&&&&@@@@@@......""""""00000000$$$$$$lHlHlHlHlH)lHlHlHlHlHr!