U j1@sdZddlZddlmZmZmZmZmZmZm Z m Z ddl m Z ddl mZddlmZddlmZmZdd lmZmZdd lmZdd lmZdd lmZdd lmZejeeeeddddZ GdddejZ!dS)z+ Test cases for L{twisted.logger._global}. N)IOAnyListOptionalTextIOTupleTypecast)Failure)unittest)textFileLogObserver)MORE_THAN_ONCE_WARNING LogBeginner) ILogObserverLogEvent)LogLevel)Logger) LogPublisher)nextLine)test actualEventsexpectedEventsreturncsrt|t|kr|||t|D]}t|Oq&ttdfdd fdd|D}|||dS)a7 Compare two sequences of log events, examining only the the keys which are present in both. @param test: a test case doing the comparison @param actualEvents: A list of log events that were emitted by a logger. @param expectedEvents: A list of log events that were expected by a test. )eventrcs,|}|D]}|kr||q|SN)copykeyspop)rrkey) allMergedKeysC/tmp/pip-unpacked-wheel-j5h_c8_q/twisted/logger/test/test_global.pysimplify*s   zcompareEvents..simplifycsg|] }|qSr!r!.0r)r#r!r" 1sz!compareEvents..N)len assertEqualsetrr)rrrrZsimplifiedActualr!)r r#r" compareEventss  r*c@seZdZdZddddZddddZdddd Zeedd d d Z ddd dZ ddddZ ddddZ ddddZ ddddZddddZddddZddddZddddZdddd ZdS)!LogBeginnerTestsz# Tests for L{LogBeginner}. NrcCsZt|_t|_Gddd}Gddd}||_||_t|j|j|j|j|_dS)Nc@seZdZeZeZdS)z&LogBeginnerTests.setUp..NotSysN)__name__ __module__ __qualname__objectstdoutstderrr!r!r!r"NotSys>sr3c @sFeZdZddddZdeeeeeee e eeddddZ dS) z+LogBeginnerTests.setUp..NotWarningsNr,cSs g|_dSr)warnings)selfr!r!r"__init__Csz4LogBeginnerTests.setUp..NotWarnings.__init__)messagecategoryfilenamelinenofilelinercSs|j||||||fdS)a Emulate warnings.showwarning. @param message: A warning message to emit. @param category: A warning category to associate with C{message}. @param filename: A file name for the source code file issuing the warning. @param lineno: A line number in the source file where the warning was issued. @param file: A file to write the warning message to. If L{None}, write to L{sys.stderr}. @param line: A line of source code to include with the warning message. If L{None}, attempt to read the line from C{filename} and C{lineno}. N)r4append)r5r7r8r9r:r;r<r!r!r" showwarningJsz7LogBeginnerTests.setUp..NotWarnings.showwarning)NN) r-r.r/r6strrWarningintrrrr>r!r!r!r" NotWarningsBs  rB) r publisherioStringIO errorStream sysModulewarningsModulerbeginner)r5r3rBr!r!r"setUp:s #zLogBeginnerTests.setUpcsrtddd}ggttfdd}ttfdd}|j||f||||g||gdS)z? Test that C{beginLoggingTo()} adds observers. r Zfoobarcs |Srr=eevents1r!r"tzBLogBeginnerTests.test_beginLoggingToAddObservers..cs |SrrNrOevents2r!r"rSurTN)dictr rrIbeginLoggingTorCr(r5rZo1Zo2r!rRrVr"test_beginLoggingToAddObserversks  z0LogBeginnerTests.test_beginLoggingToAddObserverscsrtddd}ggttfdd}ttfdd}|||j||f||g||gdS)z\ Test that events are buffered until C{beginLoggingTo()} is called. rKr rLcs |SrrNrOrQr!r"rSrTzDLogBeginnerTests.test_beginLoggingToBufferedEvents..cs |SrrNrOrUr!r"rSrTN)rWr rrCrIrXr(rYr!rZr"!test_beginLoggingToBufferedEvents}s  z2LogBeginnerTests.test_beginLoggingToBufferedEvents)limitrIrcCsft|dD]}|t|dq g}|tt|jg|ttd|dtdd|DdS)a Verify that when more than C{limit} events are logged to L{LogBeginner}, only the last C{limit} are replayed by L{LogBeginner.beginLoggingTo}. @param limit: The maximum number of events the log beginner should buffer. @param beginner: The L{LogBeginner} against which to verify. @raise: C{self.failureException} if the wrong events are replayed by C{beginner}. rK)countcss|]}|dVqdS)r^Nr!r$r!r!r" sz4LogBeginnerTests._bufferLimitTest..N) rangerCrWrXr rr=r(list)r5r]rIr^eventsr!r!r"_bufferLimitTests z!LogBeginnerTests._bufferLimitTestcCstj}|||jdS)z Up to C{LogBeginner._DEFAULT_BUFFER_SIZE} log events are buffered for replay by L{LogBeginner.beginLoggingTo}. N)rZ_DEFAULT_BUFFER_SIZErcrI)r5r]r!r!r"test_defaultBufferLimitsz(LogBeginnerTests.test_defaultBufferLimitcCs.d}t|j|j|j|j|d}|||dS)z The size of the L{LogBeginner} event buffer can be overridden with the C{initialBufferSize} initilizer argument. )ZinitialBufferSizeN)rrCrFrGrHrc)r5r]rIr!r!r"test_overrideBufferLimitsz)LogBeginnerTests.test_overrideBufferLimitc Cs$g}g}t}t|}|tddt\}}|jtt |j |g|tddt\}}|jtt |j |g|tddtt t j ||||d} d|_t||tddtdd| tddgt||| tddg|} |d|d|d | |d|d|d | dS) z When invoked twice, L{LogBeginner.beginLoggingTo} will emit a log message warning the user that they previously began logging, and add the new log observers. Z prebuffer)rZ postbufferZpostwarn)Z log_formatZ log_levelZfileNowZlineNowZfileThenZlineThenN<:>)rDrEr rCrWrrIrXr rr=rrwarnZmaxDiffr*getvalueassertIn) r5rRrVZ fileHandleZ textObserverZ firstFilenameZ firstLineZsecondFilenameZ secondLinewarningoutputr!r!r"test_beginLoggingToTwicesB    z)LogBeginnerTests.test_beginLoggingToTwicecCs:t|jd}|d|jddd||jddS)zP Critical messages will be written as text to the error stream. Zobserverz ignore thisza critical {message}r7)r7za critical message N)rrCinfocriticalr(rFrkr5logr!r!r"test_criticalLoggings  z%LogBeginnerTests.test_criticalLoggingcCs8t|jd}|jd|d||jddS)z Once logging has begun with C{beginLoggingTo}, critical messages are no longer written to the output stream. rpr!zanother critical messageN)rrCrIrXrrr(rFrkrsr!r!r"test_criticalLoggingStopss   z*LogBeginnerTests.test_criticalLoggingStopscCsg}|jtt|jgtdtt|jjdt ||t dddg|dd=tdtt|jj dt ||t dddgdS)z L{LogBeginner.beginLoggingTo} will re-direct the standard output and error streams by setting the C{stdio} and C{stderr} attributes on its sys module object. z Hello, world.r;r1)Z log_namespacelog_ioNz Error, world.r2) rIrXr rr=printrrGr1r*rWr2)r5rbr!r!r"%test_beginLoggingToRedirectStandardIOs   z6LogBeginnerTests.test_beginLoggingToRedirectStandardIOcCsD|jj}|jj}|jjddd||jj|||jj|dS)z L{LogBeginner.beginLoggingTo} will leave the existing stdout/stderr in place if it has been told not to replace them. r!F)ZredirectStandardION)rGr1r2rIrXZassertIs)r5ZoldOutZoldErrr!r!r"test_beginLoggingToDontRedirect s z0LogBeginnerTests.test_beginLoggingToDontRedirectcCsttd}ttd}||j_||j_g}|jtt |j gtt |jj}tt |jj}| |j d| |j d|d|dt||tddtddgdS) z When L{LogBeginner.beginLoggingTo} redirects stdout/stderr streams, the replacement streams will preserve the encoding of the replaced streams, to minimally disrupt any application relying on a specific encoding. z shift-JISbig5s s u李)ryu瑩N)rD TextIOWrapperBytesIOrGr1r2rIrXr rr=rr(encodingwriter*rW)r5ZweirdZweirderrrbr1r2r!r!r"$test_beginLoggingToPreservesEncodings  z5LogBeginnerTests.test_beginLoggingToPreservesEncodingc Cs|jdttdg}|jtt|jg|jdttdt }|jjdttd|d| |jj dttdddfdttd|dfgt ||tdtjd tjtdd gdS) z L{LogBeginner.beginLoggingTo} will redirect the warnings of its warnings module into the logging system. z a messagerKzanother messager z yet anotherrerxN.)rmr8r9r:)rHr>DeprecationWarning__file__rIrXr rr=rDrEr(r4r*rWr.r-)r5rbfr!r!r"test_warningsModule/sLz$LogBeginnerTests.test_warningsModulecCsXttd}t|jd}|jd|d|j}|d||d||d|dS)zR The string resulting from a logged failure contains a traceback. z,this is not the behavior you are looking forrpz a failure)failure TracebackN)r ExceptionrrCrrFrkrl)r5rrtmsgr!r!r"test_failuresAppendTracebacksVs     z.LogBeginnerTests.test_failuresAppendTracebacks)r-r.r/__doc__rJr[r\rArrcrdrfrorurwr{r|rrrr!r!r!r"r+5s1+   'r+)"rrDtypingrrrrrrrr Ztwisted.python.failurer Z twisted.trialr _filer Z_globalrrZ _interfacesrrZ_levelsrZ_loggerrZ _observerrZtest.test_stdlibrZTestCaser*r+r!r!r!r"s"(