YfVdZddlmZddlZddlZddlZddlmZddlm Z ddl m Z ddl m Z mZddlmZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZmZmZmZm Z GddeZ!GddeZ"GddZ#GddZ$GddeZ%GddeZ&GddeZ'GddeZ(Gdd eZ)Gd!d"eZ*dS)#z! Tests for L{twisted.trial.util} ) annotationsN)StringIO) Generator) implementer) assert_thatequal_to) DelayedCall)IProcessTransport)filepath)Failure)util)SynchronousTestCase)DirtyReactorAggregateError_JanitoracquireAttributeexcInfoOrFailureToExcInfo openTestLogc2eZdZdZd dZd dZd dZd dZdS) MktempTestszm Tests for L{TestCase.mktemp}, a helper function for creating temporary file or directory names. returnNonec|}tj|tjdd}||gddS)z The path name returned by C{mktemp} is directly beneath a directory which identifies the test method which created the name. N)ztwisted.trial.test.test_utilr test_name)mktempospathdirnamesplitsep assertEqual)selfnamedirss N/var/www/html/env/lib/python3.11/site-packages/twisted/trial/test/test_util.pyrzMktempTests.test_name)sk {{}}wt$$**26223B37  NNN     c~|}|||dS)zF Repeated calls to C{mktemp} return different values. N)rassertNotEqual)r"r#s r% test_uniquezMktempTests.test_unique4s5{{}} D$++--00000r&c4|}tj|}|tj||tj|dS)zS The directory part of the path name returned by C{mktemp} exists. N)rrrr assertTrueexists assertFalse)r"r#rs r% test_createdzMktempTests.test_created;sl{{}}'//$'' w//000 --.....r&ctj|}||tjdS)zZ The path returned by C{mktemp} is beneath the current working directory. N)rrabspathrr+ startswithgetcwd)r"rs r% test_locationzMktempTests.test_locationDsIwt{{}}--  4455555r&Nrr)__name__ __module__ __qualname____doc__rr)r.r3r&r%rr#sn     1111////666666r&rc*eZdZdZddZddZddZdS) DirtyReactorAggregateErrorTestsz6 Tests for the L{DirtyReactorAggregateError}. rrcntddg}|t|ddS)z5 Delayed calls are formatted nicely. FoobarzhReactor was unclean. DelayedCalls: (set twisted.internet.base.DelayedCall.debug = True to debug) Foo barNrr!strr"errors r%test_formatDelayedCallz6DirtyReactorAggregateErrorTests.test_formatDelayedCallQsE+E5>::  JJ      r&cptgddg}|t|ddS)z3 Selectables are formatted nicely. z selectable 1z selectable 2z;Reactor was unclean. Selectables: selectable 1 selectable 2Nr?rAs r%test_formatSelectablesz6DirtyReactorAggregateErrorTests.test_formatSelectables_sH+2/OPP  JJ      r&cttddgddg}|t|ddS)zR Both delayed calls and selectables can appear in the same error. bleckBoozoSel1Sel2zReactor was unclean. DelayedCalls: (set twisted.internet.base.DelayedCall.debug = True to debug) bleck Boozo Selectables: Sel1 Sel2Nr?rAs r%%test_formatDelayedCallsAndSelectableszEDirtyReactorAggregateErrorTests.test_formatDelayedCallsAndSelectablesmsM+GW+=?OPP  JJ  r&Nr4)r5r6r7r8rCrErKr9r&r%r;r;LsZ                r&r;c8eZdZdZ ddd Zddd Zdd ZddZdS) StubReactora~ A reactor stub which contains enough functionality to be used with the L{_Janitor}. @ivar iterations: A list of the arguments passed to L{iterate}. @ivar removeAllCalled: Number of times that L{removeAll} was called. @ivar selectables: The value that will be returned from L{removeAll}. @ivar delayedCalls: The value to return from L{getDelayedCalls}. N delayedCallslist[DelayedCall] selectableslist[object] | NonerrcF||_g|_d|_|sg}||_dS)z @param delayedCalls: See L{StubReactor.delayedCalls}. @param selectables: See L{StubReactor.selectables}. rN)rN iterationsremoveAllCalledrP)r"rNrPs r%__init__zStubReactor.__init__s6).0  K&r&timeout float | Nonec:|j|dS)z/ Increment C{self.iterations}. N)rSappend)r"rVs r%iteratezStubReactor.iterates  w'''''r&c|jS)z. Return C{self.delayedCalls}. )rNr"s r%getDelayedCallszStubReactor.getDelayedCallss   r& list[object]c0|xjdz c_|jS)zS Increment C{self.removeAllCalled} and return C{self.selectables}. )rTrPr\s r% removeAllzStubReactor.removeAlls! !r&N)rNrOrPrQrr)rVrWrr)rrO)rr^)r5r6r7r8rUrZr]rar9r&r%rMrMsSW ' ' ' ' '((((( !!!!       r&rMc"eZdZdZd dZd d Zd S) StubErrorReporterz A subset of L{twisted.trial.itrial.IReporter} which records L{addError} calls. @ivar errors: List of two-tuples of (test, error) which were passed to L{addError}. rrcg|_dSrb)errorsr\s r%rUzStubErrorReporter.__init__s 46 r&testobjectrBr c>|j||fdS)z6 Record parameters in C{self.errors}. N)rfrY)r"rgrBs r%addErrorzStubErrorReporter.addErrors$ D%=)))))r&Nr4)rgrhrBr rr)r5r6r7r8rUrjr9r&r%rdrdsF7777******r&rdcjeZdZdZddZddZddZddZddZdd Z dd Z dd Z dd Z dd Z ddZdS) JanitorTestsz Tests for L{_Janitor}! rrctg}tdd|}|||jddgdS)a During pending-call cleanup, the reactor will be spun twice with an instant timeout. This is not a requirement, it is only a test for current behavior. Hopefully Trial will eventually not do this kind of reactor stuff. Nreactorr)rMr _cleanPendingr!rSr"rojans r%test_cleanPendingSpinsReactorz*JanitorTests.test_cleanPendingSpinsReactorsXb//tT7333  +aV44444r&cd d}g}td|di|jd}t|g}tdd|}||||gdS) zW During pending-call cleanup, the janitor cancels pending timed calls. rr@cdS)NLulzr9r9r&r%funcz8JanitorTests.test_cleanPendingCancelsCalls..funcs6r&,r9cdSrbr9xs r%z.sQUr&Nrnrr@)r rYrMrrpr!)r"rw cancelled delayedCallrorrs r%test_cleanPendingCancelsCallsz*JanitorTests.test_cleanPendingCancelsCallss     (* !#tRY5E~~VV {m,,tT7333  [M22222r&c tdddiddd}t|}t|g}tdd| }|}|||gdS) aK The Janitor produces string representations of delayed calls from the delayed call cleanup method. It gets the string representations *before* cancelling the calls; this is important because cancelling the call removes critical debugging information from the string representation. rxcdSrbr9r9r&r%r|zIJanitorTests.test_cleanPendingReturnsDelayedCallStrings..r&r9cdSrbr9rzs r%r|zIJanitorTests.test_cleanPendingReturnsDelayedCallStrings..r&cdSrbr9rzs r%r|zIJanitorTests.test_cleanPendingReturnsDelayedCallStrings..r&cdSNrr9r9r&r%r|zIJanitorTests.test_cleanPendingReturnsDelayedCallStrings..WXr&secondsNrn)r r@rMrrpr!)r"rdelayedCallStringrorrstringss r%*test_cleanPendingReturnsDelayedCallStringsz7JanitorTests.test_cleanPendingReturnsDelayedCallStringss" r2~~~~yy    ,,{m,,tT7333##%% #4"566666r&ctg}tdd|}|||jddS)zM The Janitor will remove selectables during reactor cleanup. Nrnr`)rMr _cleanReactorr!rTrqs r%#test_cleanReactorRemovesSelectablesz0JanitorTests.test_cleanReactorRemovesSelectablessTb//tT7333  0!44444r&cttGdd}|}tg|g}tdd|}|||jdgdS)zI The Janitor will kill processes during reactor cleanup. c"eZdZdZd dZd dZdS) JJanitorTests.test_cleanReactorKillsProcesses..StubProcessTransportz A stub L{IProcessTransport} provider which records signals. @ivar signals: The signals passed to L{signalProcess}. rrcg|_dSrb)signalsr\s r%rUzSJanitorTests.test_cleanReactorKillsProcesses..StubProcessTransport.__init__s 02 r&signal str | intc:|j|dS)zF Append C{signal} to C{self.signals}. N)rrY)r"rs r% signalProcesszXJanitorTests.test_cleanReactorKillsProcesses..StubProcessTransport.signalProcesss  ##F+++++r&Nr4)rrrr)r5r6r7r8rUrr9r&r%StubProcessTransportrsF    3 3 3 3 , , , , , ,r&rNrnKILL)rr rMrrr!r)r"rptrorrs r%test_cleanReactorKillsProcessesz,JanitorTests.test_cleanReactorKillsProcessess & ' ' , , , , , , , ( ' ," ! # #b2$''tT7333  fX.....r&cGdd}tg|g}tdd|}||dgdS)z The Janitor returns string representations of the selectables that it cleaned up from the reactor cleanup method. ceZdZdZddZdS)JJanitorTests.test_cleanReactorReturnsSelectableStrings..Selectablezl A stub Selectable which only has an interesting string representation. rr@cdS)N (SELECTABLE!)r9r\s r%__repr__zSJanitorTests.test_cleanReactorReturnsSelectableStrings..Selectable.__repr__ s&r&Nr})r5r6r7r8rr9r&r% Selectablers2    ' ' ' ' ' 'r&rNrnr)rMrr!r)r"rrorrs r%)test_cleanReactorReturnsSelectableStringsz6JanitorTests.test_cleanReactorReturnsSelectableStringss  ' ' ' ' ' ' ' 'b::<<.11tT7333 **,,.?@@@@@r&ctg}t}t}t|||}||||jgdS)z The post-case cleanup method will return True and not call C{addError} on the result if there are no pending calls. rnN)rMrhrdrr+postCaseCleanupr!rfr"rorgreporterrrs r%test_postCaseCleanupNoErrorsz)JanitorTests.test_postCaseCleanupNoErrors'ss b//xx$&&tXw777 ++--... "-----r&c tdddiddd}t|}t|gg}t}t }t |||}|||t|j d ||j d d j j |gd S) z The post-case cleanup method will return False and call C{addError} on the result with a L{DirtyReactorAggregateError} Failure if there are pending calls. rxcdSrbr9r9r&r%r|z=JanitorTests.test_postCaseCleanupWithErrors..:rr&r9cdSrbr9rzs r%r|z=JanitorTests.test_postCaseCleanupWithErrors..:rr&cdSrbr9rzs r%r|z=JanitorTests.test_postCaseCleanupWithErrors..:rr&cdSrr9r9r&r%r|z=JanitorTests.test_postCaseCleanupWithErrors..:rr&rrnr`rN) r r@rMrhrdrr-rr!lenrfvaluerNr"rrrorgrrrs r%test_postCaseCleanupWithErrorsz+JanitorTests.test_postCaseCleanupWithErrors3s " r2~~~~yy    ,,{mR00xx$&&tXw777 ,,../// X_--q111 +A.4ADUCVWWWWWr&ctg}t}t}t|||}|||jgdS)z The post-class cleanup method will not call C{addError} on the result if there are no pending calls or selectables. rnN)rMrhrdrpostClassCleanupr!rfrs r%test_postClassCleanupNoErrorsz*JanitorTests.test_postClassCleanupNoErrorsEsg b//xx$&&tXw777  "-----r&c tdddiddd}t|}t|gg}t}t }t |||}||t|j d ||j d d j j |gd S) z The post-class cleanup method call C{addError} on the result with a L{DirtyReactorAggregateError} Failure if there are pending calls. rxcdSrbr9r9r&r%r|zIJanitorTests.test_postClassCleanupWithPendingCallErrors..Wrr&r9cdSrbr9rzs r%r|zIJanitorTests.test_postClassCleanupWithPendingCallErrors..Wrr&cdSrbr9rzs r%r|zIJanitorTests.test_postClassCleanupWithPendingCallErrors..Wrr&cdSrr9r9r&r%r|zIJanitorTests.test_postClassCleanupWithPendingCallErrors..Wrr&rrnr`rN) r r@rMrhrdrrr!rrfrrNrs r%*test_postClassCleanupWithPendingCallErrorsz7JanitorTests.test_postClassCleanupWithPendingCallErrorsQs " r2~~~~yy    ,,{mR00xx$&&tXw777  X_--q111 +A.4ADUCVWWWWWr&c~d}tg|g}t}t}t|||}||t |jd||jddjj t|gdS)z The post-class cleanup method call C{addError} on the result with a L{DirtyReactorAggregateError} Failure if there are selectables. zSELECTABLE HERErnr`rN) rMrhrdrrr!rrfrrPrepr)r" selectablerorgrrrs r%)test_postClassCleanupWithSelectableErrorsz6JanitorTests.test_postClassCleanupWithSelectableErrorsbs ' b:,//xx$&&tXw777  X_--q111 +A.4@4 CSCSBTUUUUUr&Nr4)r5r6r7r8rsrrrrrrrrrrr9r&r%rlrls  5 5 5 5 3 3 3 37777"5555////6AAAA& . . . .XXXX$ . . . .XXXX" V V V V V Vr&rlc*eZdZdZddZddZddZdS) RemoveSafelyTestsz* Tests for L{util._removeSafely}. rrc|d}tj|t j|}|tjtj |dS)z If a path doesn't contain a node named C{"_trial_marker"}, that path is not removed by L{util._removeSafely} and a L{util._NoTrialMarker} exception is raised instead. utf-8N) rencodermkdirr FilePath assertRaisesr _NoTrialMarker _removeSafely)r" directorydirPaths r%test_removeSafelyNoTrialMarkerz0RemoveSafelyTests.test_removeSafelyNoTrialMarkervsc KKMM((11  #I.. $-t/A7KKKKKr&cd d}t}|td||d}t j|tj|}| d ||_ tj ||d|dS) z If an L{OSError} is raised while removing a path in L{util._removeSafely}, an attempt is made to move the path to a new name. rrct) Raise an C{OSError} to emulate the branch of L{util._removeSafely} in which path removal fails. OSErrorr9r&r% dummyRemovezORemoveSafelyTests.test_removeSafelyRemoveFailsMoveSucceeds..dummyRemoves ))Or&stdoutr _trial_markercould not remove FilePathNr4)rpatchsysrrrrr rchildtouchremover rassertIngetvalue)r"routrrs r%(test_removeSafelyRemoveFailsMoveSucceedsz:RemoveSafelyTests.test_removeSafelyRemoveFailsMoveSucceedss    jj 3#&&&KKMM((11  #I.. &''--///$ 7### 13<<>>BBBBBr&cVdd}ddd }t}|td ||d }t j|tj|}| d  ||_ ||_ | ttj|}|t%|d |d|dS)z If an L{OSError} is raised while removing a path in L{util._removeSafely}, an attempt is made to move the path to a new name. If that attempt fails, the L{OSError} is re-raised. rrc td)rzpath removal failedrr9r&r%rzLRemoveSafelyTests.test_removeSafelyRemoveFailsMoveFails..dummyRemoves /00 0r&T destinationrh followLinksboolc td)z Raise an C{OSError} to emulate the branch of L{util._removeSafely} in which path movement fails. path movement failedr)rrs r% dummyMoveTozLRemoveSafelyTests.test_removeSafelyRemoveFailsMoveFails..dummyMoveTos 011 1r&rrrrrNr4)T)rrhrrrr)rrrrrrrr rrrrmoveTorrr rr!r@rr)r"rrrrrrBs r%%test_removeSafelyRemoveFailsMoveFailsz7RemoveSafelyTests.test_removeSafelyRemoveFailsMoveFailss 1 1 1 1 2 2 2 2 2jj 3#&&&KKMM((11  #I.. &''--///%$!!'4+=wGG U%;<<< 13<<>>BBBBBr&Nr4)r5r6r7r8rrrr9r&r%rrqsh L L L LCCCC:%C%C%C%C%C%Cr&rc"eZdZdZddZddZdS) ExcInfoTestsz1 Tests for L{excInfoOrFailureToExcInfo}. rrc|ttddf}||t|udS)z L{excInfoOrFailureToExcInfo} returns exactly what it is passed, if it is passed a tuple like the one returned by L{sys.exc_info}. fooN) ValueErrorr+r)r"infos r% test_excInfozExcInfoTests.test_excInfos> Ju--t4  9$ ? ??@@@@@r&c ddz n#t$rt}YnwxYw||j|j|jft |dS)z When called with a L{Failure} instance, L{excInfoOrFailureToExcInfo} returns a tuple like the one returned by L{sys.exc_info}, with the elements taken from the type, value, and traceback of the failure. r`rN) BaseExceptionr r!typertbr)r"fs r% test_failurezExcInfoTests.test_failuresl   EEE    AAA  !&!'1402KA2N2NOOOOOs ##Nr4)r5r6r7r8rrr9r&r%rrsPAAAA P P P P P Pr&rc2eZdZdZd dZd dZd dZd dZdS) AcquireAttributeTestsz( Tests for L{acquireAttribute}. rrctx|_}||t|tgdudS)z The value returned by L{acquireAttribute} is the value of the requested attribute on the first object in the list passed in which has that attribute. rNrhrr+rr"rs r%test_foundOnEarlierObjectz/AcquireAttributeTests.test_foundOnEarlierObjectsE $XX% U !142BG!L!LLMMMMMr&ctx|_}||tt|gdudS)z The same as L{test_foundOnEarlierObject}, but for the case where the 2nd element in the object list has the attribute and the first does not. rNrrs r%test_foundOnLaterObjectz-AcquireAttributeTests.test_foundOnLaterObjectsE $XX% U !1688T2BG!L!LLMMMMMr&cd|tttgddS)z If none of the objects passed in the list to L{acquireAttribute} have the requested attribute, L{AttributeError} is raised. rN)rAttributeErrorrrhr\s r%test_notFoundExceptionz,AcquireAttributeTests.test_notFoundExceptions+ .*:VXXJNNNNNr&ct}||ttgd|udS)z If none of the objects passed in the list to L{acquireAttribute} have the requested attribute and a default value is given, the default value is returned. rN)rhr+r)r"defaults r%test_notFoundDefaultz*AcquireAttributeTests.test_notFoundDefaults= (( #3VXXJw#O#OOPPPPPr&Nr4)r5r6r7r8rrrrr9r&r%rrsNNNNNNNNOOOOQQQQQQr&rcZeZdZdZddZddZddZddZddZdd Z dd Z dd Z dd Z d S)ListToPhraseTestsz Input is transformed into a string representation of the list, with each item separated by delimiter (defaulting to a comma) and the final two being separated by a final delimiter. rrcdg}d}tj|d}|||dS)zB If things is empty, an empty string is returned. andNr _listToPhraser!r"sampleexpectedresults r% test_emptyzListToPhraseTests.test_emptys< #FE22 6*****r&cfdg}d}tj|d}|||dS)z; With a single item, the item is returned. Oner Nr rs r% test_oneWordzListToPhraseTests.test_oneWords>#FE22 6*****r&chddg}d}tj|d}|||dS)zA Two words are separated by the final delimiter. rTwoz One and Twor Nr rs r% test_twoWordszListToPhraseTests.test_twoWords s@ #FE22 6*****r&chgd}d}tj|d}|||dS)zY With more than two words, the first two are separated by the delimiter. )rrThreezOne, Two, and Threer Nr rs r%test_threeWordsz!ListToPhraseTests.test_threeWords)sB)(((#FE22 6*****r&clgd}d}tj|dd}|||dS)zW If a delimiter is specified, it is used instead of the default comma. )rrrFourzOne; Two; Three; or Fourorz; ) delimiterNr rs r%test_fourWordsz ListToPhraseTests.test_fourWords2sG100-#FDDAAA 6*****r&chgd}d}tj|d}|||dS)zS If something in things is not a string, it is converted into one. )r`threez1, 2, and threer Nr rs r%test_notStringz ListToPhraseTests.test_notString;s@!$#FE22 6*****r&cd}|ttj|d}|t |ddS)z? If things is a string, a TypeError is raised. zOne, two, threer  Things must be a list or a tupleNr TypeErrorr r r!r@r"rrBs r%test_stringTypeErrorz&ListToPhraseTests.test_stringTypeErrorDsH#!!)T-?OO U%GHHHHHr&ctgd}|ttj|d}|t |ddS)zB If things is an iterator, a TypeError is raised. )r`r"r r&N)iterrr(r r r!r@r)s r%test_iteratorTypeErrorz(ListToPhraseTests.test_iteratorTypeErrorLsRiii!!)T-?OO U%GHHHHHr&cdd}|ttj|d}|t |ddS)zB If things is a generator, a TypeError is raised. rGenerator[int, None, None]c34KtdEd{VdS)Nr")ranger9r&r%rz9ListToPhraseTests.test_generatorTypeError..sampleYs*Qxx         r&r r&N)rr0r'r)s r%test_generatorTypeErrorz)ListToPhraseTests.test_generatorTypeErrorTsW     !!)T-?OO U%GHHHHHr&Nr4) r5r6r7r8rrrrr r$r*r.r3r9r&r%rrs ++++++++++++++++++++++++IIIIIIII I I I I I Ir&rc"eZdZdZddZddZdS)OpenTestLogTestsz# Tests for C{openTestLog}. rrcjtj}|tjtj|tjtjdd}t j|}t|5}| |dddn #1swxYwYt|j d5}| }dddn #1swxYwYt|dt|dS)zR The log file is opened in text mode and uses UTF-8 for encoding. )CasciiuHere comes the ☉Nrbr)locale getlocale addCleanup setlocaleLC_ALLr rrrwriteopenrreadrrr)r" currentLocaletextprwrittens r% test_utf8zOpenTestLogTests.test_utf8esk(**  (&-GGG777'  dkkmm , , ^^ q GGDMMM               !&$   1ffhhG                DKK(((7*;*;<<<<B;C88C<?C<cd}d}dtjdtj}tj|}t |5}||dddn #1swxYwYt |5}||dddn #1swxYwYt| dt|dS)z The log file is opened in append mode so if runner configuration specifies an existing log file its contents are not wiped out. zHello, world. zGoodbye, world. z Hello, world.z Goodbye, world.Nr) rlinesepr rrrr?r getContentdecoder)r" existingTextnewTextrrDrs r% test_appendzOpenTestLogTests.test_append{sa * %K2:KKrzKK  dkkmm , , ^^ "q GGL ! ! ! " " " " " " " " " " " " " " " ^^ q GGG                    LLNN ! !' * * X       s$A88A<?A<B44B8;B8Nr4)r5r6r7r8rFrMr9r&r%r5r5`sF====,      r&r5)+r8 __future__rr:rriortypingrzope.interfacerhamcrestrrtwisted.internet.baser twisted.internet.interfacesr twisted.pythonr twisted.python.failurer twisted.trialr twisted.trial.unittestrtwisted.trial.utilrrrrrrr;rMrdrlrrrrr5r9r&r%rZs7 #""""" &&&&&&********------999999######******666666&6&6&6&6&6%&6&6&6R0 0 0 0 0 &90 0 0 f* * * * * * * * Z********&oVoVoVoVoV&oVoVoVdRCRCRCRCRC+RCRCRCjPPPPP&PPP4$Q$Q$Q$Q$Q/$Q$Q$QNVIVIVIVIVI+VIVIVIr, , , , , *, , , , , r&