8'h@$bddlmZmZddlZddlZddlmZejjddr>ddl m Z ddl m Z ddl mZe eGd d eZGd d ej"Zy ddlZdd lm Z mZddlmZGddej"Zy#e$rddlZdd l m Z mZY/wxYw))absolute_importprint_functionN) replace_loop USE_TWISTEDF)patch) implementer) IReactorTimec2eZdZdZdZdZdZdZdZdZ y) FakeReactorzP This just fakes out enough reactor methods so .run() can work. Fc.d|_||_g|_y)NF) stop_calledto_raisedelayed)selfrs Z/var/www/html/trade_iq/venv/lib/python3.12/site-packages/autobahn/wamp/test/test_runner.py__init__zFakeReactor.__init__-s$D $DMDLc|jN)rrargskws rrunzFakeReactor.run2s -- rcd|_y)NT)r )rs rstopzFakeReactor.stop5s #D rcB|jj||||fyr)rappend)rdelayfuncrkwargss r callLaterzFakeReactor.callLater8s LL  dF ; z:TestWampTwistedRunner.test_connect_error..[srT) start_reactorN)autobahn.twisted.wampr.twisted.internet.errorr/twisted.internetr0 ImportErrorunittestSkipTestrr assertRaisesr assertTruer )rrr.r/r0runner exception mockreactors rtest_connect_errorz(TestWampTwistedRunner.test_connect_errorDs 6CI4'':HEF.~>I1;y3IJ 9k!!*JJd"  7 78  9 9  6'' 55 6  9 9sA?s7 " # $ % ~  9  & $ 9rr+)rMockr-c4eZdZdZdZdZdZdZdZdZ y) TestApplicationRunnerzI Test the autobahn.asyncio.wamp.ApplicationRunner class. c |j|j}|||g|i|y#t$r|j}Y%wxYwr)assertRaisesRegexAttributeErrorassertRaisesRegexp)rr?errorrrfs r_assertRaisesRegexz(TestApplicationRunner._assertRaisesRegexnsM +&&** i , , , " ,++ ,s (AActt5}tjtd|5tttf|_i}t dd|}|jd|j||jjddd d d d d d y #1swYxYw#1swYy xYw) z Ensure that loop.create_connection is called with the exact SSL context object that is passed (as ssl) to the __init__ method of ApplicationRunner. get_event_loop return_valuews://127.0.0.1:8080/wsr1ssl_unused_rRN rrBrobjectasynciorun_until_completer.rassertIscreate_connection call_args)rlooprRr>s rtest_explicit_SSLContextz.TestApplicationRunner.test_explicit_SSLContextws df% S\\'+;$OS.2@P.QD+C./H(368FJJz*MM#t'='='G'G'J5'QR S S SSS S Ss#B?A1B3"B?3B< 8B??Cctt5}tjtd|5tttf|_t dd}|jd|jd|jjddd d d d d d y #1swYxYw#1swYy xYw) z Ensure that loop.create_connection is called with ssl=False if no ssl argument is passed to the __init__ method of ApplicationRunner and the websocket URL starts with "ws:". rMrNrPr1rSFrTrRNrUrr\r>s r test_omitted_SSLContext_insecurez6TestApplicationRunner.test_omitted_SSLContext_insecures df% U\\'+;$OU.2@P.QD+./H(SFJJz*MM%)?)?)I)I!)LU)ST U U UUU U Us#B;A-B/B;/B8 4B;;Cctt5}tjtd|5tttf|_t dd}|j|j|jd|jjddddddddy#1swYxYw#1swYyxYw) z Ensure that loop.create_connection is called with ssl=True if no ssl argument is passed to the __init__ method of ApplicationRunner and the websocket URL starts with "wss:". rMrNzwss://127.0.0.1:8080/wssr1TrTrRN) rrBrrVrWrXr.rfailrYrZr[r_s rtest_omitted_SSLContext_securez4TestApplicationRunner.test_omitted_SSLContext_secures df% T\\'+;$OT.2@P.QD+./JHUFJJtyy)MM$(>(>(H(H(KE(RS T T TTT T Ts#CA7B9(C9C >CCctt5}tttf|_tddd}d}|j t ||j ddddy#1swYyxYw) z ApplicationRunner must raise an exception if given an ssl value of True but only a "ws:" URL. rNws://127.0.0.1:8080/wssr1TrQ^ssl argument value passed to ApplicationRunner conflicts with the "ws:" prefix of the url argument\. Did you mean to use "wss:"\?$rSN)rrBrXr.rK Exceptionr)rr\r>rIs r"test_conflict_SSL_True_with_ws_urlz8TestApplicationRunner.test_conflict_SSL_True_with_ws_urlss df% R*.TVTVrIs r$test_conflict_SSLContext_with_ws_urlz:TestApplicationRunner.test_conflict_SSLContext_with_ws_urls  7**446df% R*.TVTVrys67 '::>>-'*8BfBB.9 1 19D%- 8bR 1 1bR % #$$ %s2 BB.-B.