o ¼>hl$ã@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 ú€/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/twisted/words/test/test_xishutil.pyÚ__init__s zCallbackTracker.__init__cCs|jd|_||_dS)Nér)r r r r rÚcalls  zCallbackTracker.callN)Ú__name__Ú __module__Ú __qualname__Ú__doc__rrr r r rrs rc@s0eZdZdZdd„Zdd„Zdd„Zdd „Zd S) ÚOrderedCallbackTrackerz= Test helper for tracking callbacks and their order. cCs g|_dS©N)ÚcallListr r r rr's zOrderedCallbackTracker.__init__cCó|j |j¡dSr)rÚappendÚcall1©r Úobjectr r rr*ózOrderedCallbackTracker.call1cCrr)rrÚcall2rr r rr-rzOrderedCallbackTracker.call2cCrr)rrÚcall3rr r rr 0rzOrderedCallbackTracker.call3N)rrrrrrrr r 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Úcb2Úcb3Ú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/r0r r )r r2r3r4r 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&cóˆ dˆj¡dS©Nr#)r-r©Ú_©Úcbr2r rÚ onMessagexrzBEventDispatcherTests.test_addObserverInDispatch..onMessager#rrr,N©rrrÚaddOnetimeObserverr/r0r ©r r6r@r r>rÚtest_addObserverInDispatchpó    z/EventDispatcherTests.test_addObserverInDispatchcsztƒ‰tdƒ}tƒ‰‡‡fdd„}ˆ d|¡ˆ |¡| ˆjd¡ˆ |¡| ˆjd¡ˆ |¡| ˆjd¡dS)zN Test for registration of a onetime observer during dispatch. r&cr:r;)rBr)r6r>r rr@ŽrzIEventDispatcherTests.test_addOnetimeObserverInDispatch..onMessager#rrNrArCr r>rÚ!test_addOnetimeObserverInDispatch†rEz6EventDispatcherTests.test_addOnetimeObserverInDispatchcCsVtƒ}tdƒ}tƒ}| d|j¡| |¡| |jd¡| |¡| |jd¡dS)Nr&r#r)rrrrBrr/r0r )r r2r6r?r r rÚtestOnetimeDispatchœs  z(EventDispatcherTests.testOnetimeDispatchcCsZtƒ}tdƒ}tdƒ}tƒ}| d|j¡| |¡}| d|¡| |¡}| d|¡dS)Nr&r*r$FT)rrrr-rr/r0)r r2r6r7r?Ú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-rr rrr.r/r0rÚrepr©r r2r?r6r 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/r0r r1ÚlenÚ_eventObserversÚpop©r r2r?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/r0r r1rRÚ_xpathObserversrTrOr 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. rQNrr) rrrBrr/r0r rRrSrTrUr 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. rWr#rrN) rrrrBrr/r0r rRrXrTrOr r rÚ test_cleanUpOnetimeXPathObserverôs z5EventDispatcherTests.test_cleanUpOnetimeXPathObservercsÈGdd„dtjƒ}Gdd„dtƒ‰‡fdd„}tƒ}tƒ}tj}z?|t_| d|¡| d|j¡z| dd¡WnˆyG| d ¡Ynw|  d t |  ˆ¡ƒ¡|  d |j ¡W|t_dS|t_w) 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 s zXEventDispatcherTests.test_observerRaisingException..OrderedCallbackList.__init__N)rrrrr r r rÚOrderedCallbackList s r]c@s eZdZdS)zEEventDispatcherTests.test_observerRaisingException..TestErrorN)rrrr r r rÚ TestErrorsr^csˆƒ‚rr r<©r^r rÚ raiseErrorszFEventDispatcherTests.test_observerRaisingException..raiseErrorrQNz2TestError raised. Should have been logged instead.r) rÚ CallbackListÚ Exceptionrrr-rr/Úfailr0rRÚflushLoggedErrorsr )r r]r`r2r?ÚoriginalCallbackListr r_rÚtest_observerRaisingExceptions$   ÿz2EventDispatcherTests.test_observerRaisingExceptionN)rrrrr8r9rDrFrGrIrPrVrYrZr[rfr r r rr!4s$   r!c@s(eZdZdZdd„Zdd„Zdd„ZdS) Ú XmlPipeTestsz: Tests for L{twisted.words.xish.utility.XmlPipe}. cCst ¡|_dSr)rÚXmlPipeÚpiper r r rÚsetUp.ózXmlPipeTests.setUpcóH‡fdd„}g‰|jj d|¡tdƒ}|jj |¡| |gˆ¡dS)zO Send an element from the source and observe it from the sink. cóˆ |¡dSr©r©r ©r r rr?6rkz,XmlPipeTests.test_sendFromSource..cbú/test[@xmlns="testns"]©ÚtestnsÚtestN)riÚsinkr-rÚsourceÚsendr0©r r?Úelementr rprÚtest_sendFromSource1ó z XmlPipeTests.test_sendFromSourcecrl)zO Send an element from the sink and observe it from the source. crmrrnrorpr rr?Drkz*XmlPipeTests.test_sendFromSink..cbrqrrN)rirvr-rrurwr0rxr rprÚtest_sendFromSink?r{zXmlPipeTests.test_sendFromSinkN)rrrrrjrzr|r r r rrg)s  rgN)rÚ collectionsrÚ twisted.trialrÚtwisted.words.xishrÚtwisted.words.xish.domishrÚtwisted.words.xish.utilityrrrÚTestCaser!rgr r r rÚs     v