Yf1dZddlZddlmZmZmZmZmZmZm Z m Z ddl m Z ddl mZddlmZddlmZmZdd lmZmZdd lmZdd lmZdd lmZdd lmZdejdeedeeddfdZ GddejZ!dS)z+ Test cases for L{twisted.logger._global}. N)IOAnyListOptionalTextIOTupleTypecast)Failure)unittest)textFileLogObserver)MORE_THAN_ONCE_WARNING LogBeginner) ILogObserverLogEvent)LogLevel)Logger) LogPublisher)nextLinetest actualEventsexpectedEventsreturncTt|t|kr|||t|D]&}t|z'dtdtffd fd|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. eventrc|}|D]}|vr|||SN)copykeyspop)rrkey allMergedKeyss Q/var/www/html/env/lib/python3.11/site-packages/twisted/logger/test/test_global.pysimplifyzcompareEvents..simplify*sGzz||::<<  C-''  c&g|] }|Sr().0rr%s r$ z!compareEvents..1s!BBBEBBBr&N)len assertEqualsetr r)rrrrsimplifiedActualr#r%s @@r$ compareEventsr/s <C//// ~666EEM++UZZ\\*** XCBBB\BBB%~66666r&ceZdZdZddZddZddZdededdfd Z dd Z dd Z dd Z dd Z ddZddZddZddZddZddZdS)LogBeginnerTestsz# Tests for L{LogBeginner}. rNc"t|_tj|_Gdd}Gdd}||_||_t|j|j|j|j|_dS)Nc6eZdZeZeZdS)&LogBeginnerTests.setUp..NotSysN)__name__ __module__ __qualname__objectstdoutstderrr(r&r$NotSysr4>s$VXXFVXXFFFr&r;cpeZdZd dZ d dedeedededee e d eeddfd Z dS) +LogBeginnerTests.setUp..NotWarningsrNcg|_dSr)warnings)selfs r$__init__z4LogBeginnerTests.setUp..NotWarnings.__init__Cs   r&messagecategoryfilenamelinenofilelinecF|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)r?append)r@rBrCrDrErFrGs r$ showwarningz7LogBeginnerTests.setUp..NotWarnings.showwarningJs.2 $$gx64QU%VWWWWWr&rN)NN) r5r6r7rAstrr WarningintrrrrJr(r&r$ NotWarningsr=Bs    +/&* X X Xw- X  X   X r#w'  Xsm X X X X X X Xr&rO) r publisherioStringIO errorStream sysModulewarningsModulerbeginner)r@r;rOs r$setUpzLogBeginnerTests.setUp:s%;==        ! X! X! X! X! X! X! X! XF )kmm# ND,dnd>Q   r&cRtdd}ggttfd}ttfd}|j||f||||g||gdS)z? Test that C{beginLoggingTo()} adds observers. r foobarc.|SrrIeevents1s r$zBLogBeginnerTests.test_beginLoggingToAddObservers..t'..*;*;r&c.|Srr^r`events2s r$rbzBLogBeginnerTests.test_beginLoggingToAddObservers..urcr&N)dictr rrVbeginLoggingTorPr,r@ro1o2rarfs @@r$test_beginLoggingToAddObserversz0LogBeginnerTests.test_beginLoggingToAddObserversks""""$"$ , ; ; ; ; < < , ; ; ; ; < < $$b"X... u %'*** %'*****r&cRtdd}ggttfd}ttfd}|||j||f||g||gdS)z\ Test that events are buffered until C{beginLoggingTo()} is called. rYr rZc.|Srr^r_s r$rbzDLogBeginnerTests.test_beginLoggingToBufferedEvents..rcr&c.|Srr^res r$rbzDLogBeginnerTests.test_beginLoggingToBufferedEvents..rcr&N)rgr rrPrVrhr,ris @@r$!test_beginLoggingToBufferedEventsz2LogBeginnerTests.test_beginLoggingToBufferedEvents}s """"$"$ , ; ; ; ; < < , ; ; ; ; < < u $$b"X... %'*** %'*****r&limitrVc lt|dzD]%}|t|&g}|t t |jg|ttd|dztd|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}. rY)countc3&K|] }|dV dS)rsNr()r)rs r$ z4LogBeginnerTests._bufferLimitTest..s&44Ew444444r&N) rangerPrgrhr rrIr,list)r@rqrVrseventss r$_bufferLimitTestz!LogBeginnerTests._bufferLimitTests519%% . .E NN4e,,, - - - -!#lFM!B!B CDDD  q%!)$$ % % 44V444 4 4     r&cTtj}|||jdS)z Up to C{LogBeginner._DEFAULT_BUFFER_SIZE} log events are buffered for replay by L{LogBeginner.beginLoggingTo}. N)r_DEFAULT_BUFFER_SIZEryrV)r@rqs r$test_defaultBufferLimitz(LogBeginnerTests.test_defaultBufferLimits* 0 eT]33333r&cd}t|j|j|j|j|}|||dS)z The size of the L{LogBeginner} event buffer can be overridden with the C{initialBufferSize} initilizer argument. )initialBufferSizeN)rrPrSrTrUry)r@rqrVs r$test_overrideBufferLimitz)LogBeginnerTests.test_overrideBufferLimitsT  N   N  #     eX.....r&c g}g}tj}t|}|t dt \}}|jtt|j |g|t dt \}}|jtt|j |g|t dt ttj ||||} d|_t||t dt d| t dgt||| t dg|} |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. prebuffer)r postbufferpostwarn) log_format log_levelfileNowlineNowfileThenlineThenN<:>)rQrRrrPrgrrVrhr rrIrrwarnmaxDiffr/getvalueassertIn) r@rarf fileHandle textObserver firstFilename firstLinesecondFilename secondLinewarningoutputs r$test_beginLoggingToTwicez)LogBeginnerTests.test_beginLoggingToTwices #%"$[]] *:66  t+...///#+:: y $$d<&H&H,%WXXX t,///000%-ZZ"  $$d<&H&H,%WXXX t*---...-m""       ;'''<(((:&&&    dGgt*/E/E/E%FGGG$$&& 6-66)666??? 8.88:888&AAAAAr&ct|j}|d|dd||jddS)zP Critical messages will be written as text to the error stream. observerz ignore thisza critical {message}rB)rBza critical message N)rrPinfocriticalr,rSrr@logs r$test_criticalLoggingz%LogBeginnerTests.test_criticalLoggingskdn---  +Y ??? )22446LMMMMMr&ct|j}|jd|d||jddS)z Once logging has begun with C{beginLoggingTo}, critical messages are no longer written to the output stream. rr(zanother critical messageN)rrPrVrhrr,rSrrs r$test_criticalLoggingStopsz*LogBeginnerTests.test_criticalLoggingStopssj dn--- $$R((( /000 )2244b99999r&cg}|jtt|jgt dtt |jjt||tddg|dd=t dtt |jj t||tddgdS)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.rFr9) log_namespacelog_ioNz Error, world.r:) rVrhr rrIprintrrTr9r/rgr:)r@rxs r$%test_beginLoggingToRedirectStandardIOz6LogBeginnerTests.test_beginLoggingToRedirectStandardIOs "$ $$d<&G&G%HIII oD1F$G$GHHHH &4hOOOP    111I oD1F$G$GHHHH &4hOOOP     r&c|jj}|jj}|jdd||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)redirectStandardION)rTr9r:rVrhassertIs)r@oldOutoldErrs r$test_beginLoggingToDontRedirectz0LogBeginnerTests.test_beginLoggingToDontRedirect sk && $$RE$BBB dn+V444 dn+V44444r&ctjtjd}tjtjd}||j_||j_g}|jtt|j gtt|jj}tt|jj}| |j d| |j d|d|dt||t!dt!dgdS) 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李)ru瑩N)rQ TextIOWrapperBytesIOrTr9r:rVrhr rrIrr,encodingwriter/rg)r@weirdweirderrrxr9r:s r$$test_beginLoggingToPreservesEncodingz5LogBeginnerTests.test_beginLoggingToPreservesEncodings! {;;#BJLL&99 % (!# $$d<&G&G%HIIIfdn344fdn344 +666 &111 ]### ]###dFT%:%:%:Drs EEEEEEEEEEEEEEEEEEEE******""""""''''''9999999900000000$$$$$$''''''7  7x.7N7 7777>k(k(k(k(k(x(k(k(k(k(k(r&