U n5{il$ã@s„dZddlmZddlmZddlmZddlmZddl m Z Gdd„dƒZ Gd d „d ƒZ Gd d „d ej ƒZGd d„dej ƒZdS)z+ Test cases for twisted.words.xish.utility é)Ú OrderedDict)Úunittest)Úutility)ÚElement)ÚEventDispatcherc@s eZdZdZdd„Zdd„ZdS)ÚCallbackTrackerzŒ Test helper for tracking callbacks. Increases a counter on each call to L{call} and stores the object passed in the call. cCsd|_d|_dS)Nr©ÚcalledÚobj©Úself©r úD/tmp/pip-unpacked-wheel-mnhg7r0q/twisted/words/test/test_xishutil.pyÚ__init__szCallbackTracker.__init__cCs|jd|_||_dS)Nér)r r r r rÚcalls zCallbackTracker.callN)Ú__name__Ú __module__Ú __qualname__Ú__doc__rrr r r rrsrc@s0eZdZdZdd„Zdd„Zdd„Zdd „Zd S) ÚOrderedCallbackTrackerz= Test helper for tracking callbacks and their order. cCs g|_dS©N)ÚcallListr r r rr'szOrderedCallbackTracker.__init__cCs|j |j¡dSr)rÚappendÚcall1©r Úobjectr r rr*szOrderedCallbackTracker.call1cCs|j |j¡dSr)rrÚcall2rr r rr-szOrderedCallbackTracker.call2cCs|j |j¡dSr)rrÚcall3rr r rr0szOrderedCallbackTracker.call3N)rrrrrrrrr r r rr"s rc@speZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dd„Z dd„Z dd„Z dd„Zdd„ZdS)ÚEventDispatcherTestsz' Tests for L{EventDispatcher}. cCs<tƒ}tƒ}tƒ}tƒ}| d|j¡| d|j¡| d|j¡| d|j¡tdƒ}| d¡tdƒ}| d¡| |¡| |jd ¡| |j |¡| |jd ¡| |¡| |jd ¡| |jd ¡| |j |¡| |jd ¡| |d¡| |jd ¡| |j |¡|  d|j¡| |¡| |jd ¡dS) Nú /message/bodyú/messageú /presenceú//event/testevent©ÚnsÚmessageÚbody©r%Úpresencer)érr) rrÚ addObserverrrÚ addElementÚdispatchÚ assertEqualr r ÚremoveObserver)r ÚdÚcb1Úcb2Zcb3ÚmsgÚpresr r rÚ testStuff9s6      zEventDispatcherTests.testStuffcCsvtƒ}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. r#rN)rrr+rr-r.r r )r r0r1r2r r rÚtest_addObserverTwice]s z*EventDispatcherTests.test_addObserverTwicecsztƒ‰tdƒ}tƒ‰‡‡fdd„}ˆ d|¡ˆ |¡| ˆjd¡ˆ |¡| ˆjd¡ˆ |¡| ˆjd¡dS) zG Test for registration of an observer during dispatch. r$csˆ dˆj¡dS©Nr!)r+r©Ú_©Úcbr0r rÚ onMessagexszBEventDispatcherTests.test_addObserverInDispatch..onMessager!rrr*N©rrrÚaddOnetimeObserverr-r.r ©r r3r<r r:rÚtest_addObserverInDispatchps    z/EventDispatcherTests.test_addObserverInDispatchcsztƒ‰tdƒ}tƒ‰‡‡fdd„}ˆ d|¡ˆ |¡| ˆjd¡ˆ |¡| ˆjd¡ˆ |¡| ˆjd¡dS)zN Test for registration of a onetime observer during dispatch. r$csˆ dˆj¡dSr7)r>r)r3r:r rr<ŽszIEventDispatcherTests.test_addOnetimeObserverInDispatch..onMessager!rrNr=r?r r:rÚ!test_addOnetimeObserverInDispatch†s    z6EventDispatcherTests.test_addOnetimeObserverInDispatchcCsVtƒ}tdƒ}tƒ}| d|j¡| |¡| |jd¡| |¡| |jd¡dS)Nr$r!r)rrrr>rr-r.r )r r0r3r;r r rÚtestOnetimeDispatchœs  z(EventDispatcherTests.testOnetimeDispatchcCsZtƒ}tdƒ}tdƒ}tƒ}| d|j¡| |¡}| d|¡| |¡}| d|¡dS)Nr$r(r"FT)rrrr+rr-r.)r r0r3r4r;Úresultr r rÚtestDispatcherResult§s   z)EventDispatcherTests.testDispatcherResultcCsŠtƒ}tƒ}| d|j¡| d|jd¡| d|jd¡tdƒ}| d¡| |¡|  |j |j|j|jgdt dd „|j Dƒƒ¡dS) Nr r!éÿÿÿÿrr$r'zCalls out of order: %scSsg|] }|j‘qSr )r)Ú.0Úcr r rÚ ÁszAEventDispatcherTests.testOrderedXPathDispatch..) rrr+rrrrr,r-r.rÚrepr©r r0r;r3r r rÚtestOrderedXPathDispatch´s  ýz-EventDispatcherTests.testOrderedXPathDispatchcCs^tƒ}tƒ}| d|j¡| dd¡| d|j¡| d|j¡| dt|j   d¡ƒ¡dS)zO Test observer clean-up after removeObserver for named events. ú //event/testNrr) rrr+rr-r.r r/ÚlenÚ_eventObserversÚpop©r r0r;r r rÚtest_cleanUpRemoveEventObserverÊs z4EventDispatcherTests.test_cleanUpRemoveEventObservercCsdtƒ}tƒ}tdƒ}| d|j¡| |¡| d|j¡| d|j¡| dt |j   d¡ƒ¡dS)zO Test observer clean-up after removeObserver for XPath events. ©Nr&r!rrN) rrrr+rr-r.r r/rMÚ_xpathObserversrOrJr r rÚtest_cleanUpRemoveXPathObserverØs z4EventDispatcherTests.test_cleanUpRemoveXPathObservercCsPtƒ}tƒ}| d|j¡| dd¡| d|j¡| dt|j  d¡ƒ¡dS)zD Test observer clean-up after onetime named events. rLNrr) rrr>rr-r.r rMrNrOrPr r rÚ test_cleanUpOnetimeEventObserverçs  z5EventDispatcherTests.test_cleanUpOnetimeEventObservercCsVtƒ}tƒ}tdƒ}| d|j¡| |¡| d|j¡| dt|j   d¡ƒ¡dS)zD Test observer clean-up after onetime XPath events. rRr!rrN) rrrr>rr-r.r rMrSrOrJr r rÚ test_cleanUpOnetimeXPathObserverôs z5EventDispatcherTests.test_cleanUpOnetimeXPathObservercsÆGdd„dtjƒ}Gdd„dtƒ‰‡fdd„}tƒ}tƒ}tj}zx|t_| d|¡| d|j¡z| dd¡Wnˆk r| d ¡YnX|  d t |  ˆ¡ƒ¡|  d |j ¡W5|t_XdS) 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. c@seZdZdd„ZdS)zOEventDispatcherTests.test_observerRaisingException..OrderedCallbackListcSs tƒ|_dSr)rÚ callbacksr r r rr szXEventDispatcherTests.test_observerRaisingException..OrderedCallbackList.__init__N)rrrrr r r rÚOrderedCallbackList srXc@s eZdZdS)zEEventDispatcherTests.test_observerRaisingException..TestErrorN)rrrr r r rÚ TestErrorsrYcs ˆƒ‚dSrr r8©rYr rÚ raiseErrorszFEventDispatcherTests.test_observerRaisingException..raiseErrorrLNz2TestError raised. Should have been logged instead.r) rZ CallbackListÚ Exceptionrrr+rr-Zfailr.rMZflushLoggedErrorsr )r rXr[r0r;ZoriginalCallbackListr rZrÚtest_observerRaisingExceptions"  z2EventDispatcherTests.test_observerRaisingExceptionN)rrrrr5r6r@rArBrDrKrQrTrUrVr]r r r rr4s$   rc@s(eZdZdZdd„Zdd„Zdd„ZdS) Ú XmlPipeTestsz: Tests for L{twisted.words.xish.utility.XmlPipe}. cCst ¡|_dSr)rZXmlPipeÚpiper r r rÚsetUp.szXmlPipeTests.setUpcsH‡fdd„}g‰|jj d|¡tdƒ}|jj |¡| |gˆ¡dS)zO Send an element from the source and observe it from the sink. csˆ |¡dSr©r©r ©r r rr;6sz,XmlPipeTests.test_sendFromSource..cbú/test[@xmlns="testns"]©ZtestnsÚtestN)r_Úsinkr+rÚsourceÚsendr.©r r;Úelementr rcrÚtest_sendFromSource1s  z XmlPipeTests.test_sendFromSourcecsH‡fdd„}g‰|jj d|¡tdƒ}|jj |¡| |gˆ¡dS)zO Send an element from the sink and observe it from the source. csˆ |¡dSrrarbrcr rr;Dsz*XmlPipeTests.test_sendFromSink..cbrdreN)r_rhr+rrgrir.rjr rcrÚtest_sendFromSink?s  zXmlPipeTests.test_sendFromSinkN)rrrrr`rlrmr r r rr^)sr^N)rÚ collectionsrZ twisted.trialrZtwisted.words.xishrZtwisted.words.xish.domishrZtwisted.words.xish.utilityrrrZTestCaserr^r r r rÚs     v