U  W[´$ã@s”dZddlmZmZddlmZddlmZddlm Z ddl m Z ddl m Z Gdd „d ƒZGd d „d ƒZGd d „d ejƒZGdd„dejƒZdS)z+ Test cases for twisted.words.xish.utility é)Úabsolute_importÚdivision)Ú 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úB/usr/lib/python3/dist-packages/twisted/words/test/test_xishutil.pyÚ__init__szCallbackTracker.__init__cCs|jd|_||_dS)Nér )rr rrrÚcalls zCallbackTracker.callN)Ú__name__Ú __module__Ú __qualname__Ú__doc__rrrrrrr sr c@s0eZdZdZdd„Zdd„Zdd„Zdd „Zd S) ÚOrderedCallbackTrackerz= Test helper for tracking callbacks and their order. cCs g|_dS©N)ÚcallListr rrrr*szOrderedCallbackTracker.__init__cCs|j |j¡dSr)rÚappendÚcall1©rÚobjectrrrr.szOrderedCallbackTracker.call1cCs|j |j¡dSr)rrÚcall2rrrrr2szOrderedCallbackTracker.call2cCs|j |j¡dSr)rrÚcall3rrrrr 6szOrderedCallbackTracker.call3N)rrrrrrrr rrrrr%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ÚpresrrrÚ testStuff@s6      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)rr r-rr/r0r r )rr2r3r4rrrÚtest_addObserverTwicees 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©Ú_©Úcbr2rrÚ onMessageszBEventDispatcherTests.test_addObserverInDispatch..onMessager#rrr,N©rrr ÚaddOnetimeObserverr/r0r ©rr5r>rr<rÚtest_addObserverInDispatchys    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¡dSr9)r@r)r5r<rrr>˜szIEventDispatcherTests.test_addOnetimeObserverInDispatch..onMessager#rrNr?rArr<rÚ!test_addOnetimeObserverInDispatchs    z6EventDispatcherTests.test_addOnetimeObserverInDispatchcCsVtƒ}tdƒ}tƒ}| d|j¡| |¡| |jd¡| |¡| |jd¡dS)Nr&r#r)rrr r@rr/r0r )rr2r5r=rrrÚtestOnetimeDispatch§s  z(EventDispatcherTests.testOnetimeDispatchcCsZtƒ}tdƒ}tdƒ}tƒ}| d|j¡| |¡}| d|¡| |¡}| d|¡dS)Nr&r*r$FT)rrr r-rr/r0)rr2r5r6r=ÚresultrrrÚ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ÚcrrrÚ ÍszAEventDispatcherTests.testOrderedXPathDispatch..) rrr-rr rrr.r/r0rÚrepr©rr2r=r5rrrÚ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) rr r-rr/r0r r1ÚlenÚ_eventObserversÚpop©rr2r=rrrÚ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) rr rr-rr/r0r r1rOÚ_xpathObserversrQrLrrrÚ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. rNNrr) rr r@rr/r0r rOrPrQrRrrrÚ 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. rTr#rrN) rr rr@rr/r0r rOrUrQrLrrrÚ test_cleanUpOnetimeXPathObservers 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)rZ callbacksr rrrrszXEventDispatcherTests.test_observerRaisingException..OrderedCallbackList.__init__N)rrrrrrrrÚOrderedCallbackListsrYc@s eZdZdS)zEEventDispatcherTests.test_observerRaisingException..TestErrorN)rrrrrrrÚ TestErrorsrZcs ˆƒ‚dSrrr:©rZrrÚ raiseError!szFEventDispatcherTests.test_observerRaisingException..raiseErrorrNNz2TestError raised. Should have been logged instead.r) rZ CallbackListÚ Exceptionrr r-rr/Zfailr0rOZflushLoggedErrorsr )rrYr\r2r=ZoriginalCallbackListrr[rÚtest_observerRaisingExceptions"  z2EventDispatcherTests.test_observerRaisingExceptionN)rrrrr7r8rBrCrDrFrMrSrVrWrXr^rrrrr!;s% r!c@s(eZdZdZdd„Zdd„Zdd„ZdS) Ú XmlPipeTestsz: Tests for L{twisted.words.xish.utility.XmlPipe}. cCst ¡|_dSr)rZXmlPipeÚpiper rrrÚ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 rrr=Gsz,XmlPipeTests.test_sendFromSource..cbú/test[@xmlns="testns"]©ZtestnsZtestN)r`Úsinkr-rÚsourceÚsendr0©rr=ÚelementrrdrÚtest_sendFromSourceCs  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ˆ |¡dSrrbrcrdrrr=Usz*XmlPipeTests.test_sendFromSink..cbrerfN)r`rhr-rrgrir0rjrrdrÚtest_sendFromSinkQs  zXmlPipeTests.test_sendFromSinkN)rrrrrarlrmrrrrr_:sr_N)rZ __future__rrÚ collectionsrZ twisted.trialrZtwisted.words.xishrZtwisted.words.xish.domishrZtwisted.words.xish.utilityrr rZTestCaser!r_rrrrÚs