tfl$dZddlmZddlmZddlmZddlmZddl m Z GddZ Gd d Z Gd d ej ZGd dej ZdS)z+ Test cases for twisted.words.xish.utility ) OrderedDict)unittest)utility)Element)EventDispatcherceZdZdZdZdZdS)CallbackTrackerz Test helper for tracking callbacks. Increases a counter on each call to L{call} and stores the object passed in the call. c"d|_d|_dS)Nrcalledobjselfs _/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/words/test/test_xishutil.py__init__zCallbackTracker.__init__s c2|jdz|_||_dS)Nr )rr s rcallzCallbackTracker.callskAo rN)__name__ __module__ __qualname____doc__rrrrr r s<rr c*eZdZdZdZdZdZdZdS)OrderedCallbackTrackerz= Test helper for tracking callbacks and their order. cg|_dSN)callListrs rrzOrderedCallbackTracker.__init__'s  rcD|j|jdSr)rappendcall1robjects rr"zOrderedCallbackTracker.call1*  TZ(((((rcD|j|jdSr)rr!call2r#s rr'zOrderedCallbackTracker.call2-r%rcD|j|jdSr)rr!call3r#s rr)zOrderedCallbackTracker.call30r%rN)rrrrrr"r'r)rrrrr"sZ)))))))))))rrcZeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdS)EventDispatcherTestsz' Tests for L{EventDispatcher}. ct}t}t}t}|d|j|d|j|d|j|d|jt d}|dt d}|d||||jd ||j |||jd ||||jd ||jd ||j |||jd ||d||jd ||j || d|j||||jd dS) N /message/body/message /presence//event/testeventnsmessagebodyr2presencer6rr) rr addObserverrr addElementdispatch assertEqualr r removeObserver)rdcb1cb2cb3msgpress r testStuffzEventDispatcherTests.testStuff9s    osx000 j#(+++ k38,,, )38444'(( v)**  ### 3 Q''' #&&& Q''' 4 Q''' Q''' $''' Q''' 1)*** Q''' !$$$ ch/// 4 Q'''''rct}t}t}|d|j|d|j||d||jd||j|||jd||j|dS)z Test adding two observers for the same query. When the event is dispatched both of the observers need to be called. r0rN)rr r8rr:r;r r )rr=r>r?s rtest_addObserverTwicez*EventDispatcherTests.test_addObserverTwice]s    )38444 )38444 1)*** Q''' !$$$ Q''' !$$$$$rcttd}tfd}d|||jd||jd||jddS)zG Test for registration of an observer during dispatch. r1c>djdSNr.)r8r)_cbr=s r onMessagezBEventDispatcherTests.test_addObserverInDispatch..onMessagexs MM*bg . . . . .rr.rrr7Nrrr addOnetimeObserverr:r;r rrArKrJr=s @@rtest_addObserverInDispatchz/EventDispatcherTests.test_addObserverInDispatchps   '((    / / / / / / Z333 3 A&&& 3 A&&& 3 A&&&&&rcttd}tfd}d|||jd||jd||jddS)zN Test for registration of a onetime observer during dispatch. r1c>djdSrH)rMr)rArJr=s rrKzIEventDispatcherTests.test_addOnetimeObserverInDispatch..onMessages! RW 5 5 5 5 5rr.rrNrLrNs @@r!test_addOnetimeObserverInDispatchz6EventDispatcherTests.test_addOnetimeObserverInDispatchs   '((    6 6 6 6 6 6 Z333 3 A&&& 3 A&&& 3 A&&&&&rcRt}td}t}|d|j||||jd||||jddS)Nr1r.r)rrr rMrr:r;r )rr=rArJs rtestOnetimeDispatchz(EventDispatcherTests.testOnetimeDispatchs   '((    Z111 3 A&&& 3 A&&&&&rc\t}td}td}t}|d|j||}|d|||}|d|dS)Nr1r5r/FT)rrr r8rr:r;)rr=rArBrJresults rtestDispatcherResultz)EventDispatcherTests.testDispatcherResults   '(()**    k27+++C '''D!! v&&&&&rc t}t}|d|j|d|jd|d|jdt d}|d||| |j |j|j|jgdtd|j DzdS) Nr-r.rr1r4zCalls out of order: %scg|] }|j Sr)r).0cs r zAEventDispatcherTests.testOrderedXPathDispatch..s,M,M,MAQZ,M,M,Mr) rrr8r'r)r"rr9r:r;rreprrr=rJrAs rtestOrderedXPathDispatchz-EventDispatcherTests.testOrderedXPathDispatchs    # % % orx000 j"(B/// orx333'(( v 3  K Xrx * $t,M,M,M,M,M'N'N N     rct}t}|d|j|dd|d|j|d|j|dt|j ddS)zO Test observer clean-up after removeObserver for named events. //event/testNrr) rr r8rr:r;r r<len_eventObserverspoprr=rJs rtest_cleanUpRemoveEventObserverz4EventDispatcherTests.test_cleanUpRemoveEventObservers       nbg... 4((( BI&&& 111 C 1 5 5a 8 899:::::rct}t}td}|d|j|||d|j|d|j|dt|j ddS)zO Test observer clean-up after removeObserver for XPath events. Nr3r.rrN) rr rr8rr:r;r r<rc_xpathObserversrer_s rtest_cleanUpRemoveXPathObserverz4EventDispatcherTests.test_cleanUpRemoveXPathObservers      '(( j"'*** 3 BI&&& RW--- C 1 5 5a 8 899:::::rcLt}t}|d|j|dd|d|j|dt|j ddS)zD Test observer clean-up after onetime named events. rbNrr) rr rMrr:r;r rcrdrerfs r test_cleanUpOnetimeEventObserverz5EventDispatcherTests.test_cleanUpOnetimeEventObservers       ^RW555 4((( BI&&& C 1 5 5a 8 899:::::rcht}t}td}|d|j|||d|j|dt|j ddS)zD Test observer clean-up after onetime XPath events. rir.rrN) rr rrMrr:r;r rcrjrer_s r test_cleanUpOnetimeXPathObserverz5EventDispatcherTests.test_cleanUpOnetimeXPathObservers      '(( Z111 3 BI&&& C 1 5 5a 8 899:::::rcGddtj}Gddtfd}t}t }tj} |t_|d||d|j |ddn #$r|dYnwxYw| d t| | d |j |t_dS#|t_wxYw) z Test that exceptions in observers do not bubble up to dispatch. The exceptions raised in observers should be logged and other observers should be called as if nothing happened. ceZdZdZdS)OEventDispatcherTests.test_observerRaisingException..OrderedCallbackListc,t|_dSr)r callbacksrs rrzXEventDispatcherTests.test_observerRaisingException..OrderedCallbackList.__init__ s!,rN)rrrrrrrOrderedCallbackListrr s# / / / / /rruceZdZdS)EEventDispatcherTests.test_observerRaisingException..TestErrorN)rrrrrr TestErrorrws Drrxcrr)rIrxs r raiseErrorzFEventDispatcherTests.test_observerRaisingException..raiseErrors)++ rrbNz2TestError raised. Should have been logged instead.r) r CallbackList Exceptionrr r8rr:failr;rcflushLoggedErrorsr )rrurzr=rJoriginalCallbackListrxs @rtest_observerRaisingExceptionz2EventDispatcherTests.test_observerRaisingExceptions / / / / /'"6 / / /                    &3 8#6G MM.* 5 5 5 MM."' 2 2 2 P 40000 P P P NOOOOO P   QD$:$:9$E$E F F G G G   Q * * *#7G #7G 7 7 7 7s1=D/B0/D/0C  D/ C  AD//D=N)rrrrrCrErOrRrTrWr`rgrkrmrorrrrr+r+4s"("("(H%%%&''',''', ' ' ' ' ' '   , ; ; ; ; ; ; ; ; ; ; ; ;$8$8$8$8$8rr+c$eZdZdZdZdZdZdS) XmlPipeTestsz: Tests for L{twisted.words.xish.utility.XmlPipe}. c6tj|_dSr)rXmlPipepipers rsetUpzXmlPipeTests.setUp.sO%% rcfd}g|jjd|td}|jj|||gdS)zO Send an element from the source and observe it from the sink. c2|dSrr!r r s rrJz,XmlPipeTests.test_sendFromSource..cb6 MM#     r/test[@xmlns="testns"]testnstestN)rsinkr8rsourcesendr;rrJelementr s @rtest_sendFromSourcez XmlPipeTests.test_sendFromSource1s       ""#;R@@@,-- g&&& 'F+++++rcfd}g|jjd|td}|jj|||gdS)zO Send an element from the sink and observe it from the source. c2|dSrrrs rrJz*XmlPipeTests.test_sendFromSink..cbDrrrrN)rrr8rrrr;rs @rtest_sendFromSinkzXmlPipeTests.test_sendFromSink?s       $$%=rBBB,-- G$$$ 'F+++++rN)rrrrrrrrrrrr)sK&&& , , , , , , , ,rrN)r collectionsr twisted.trialrtwisted.words.xishrtwisted.words.xish.domishrtwisted.words.xish.utilityrr rTestCaser+rrrrrs( $#####""""""&&&&&&------666666"))))))))$r8r8r8r8r88,r8r8r8j",",",",",8$",",",",",r