U •uÄcT ã@sZddlZddlmZddlmZddlmZeeƒGdd„deƒƒZGdd„dej ƒZ dS) éN)Úpatch)Ú implementer)Ú IReactorTimec@s<eZdZdZdZdd„Zdd„Zdd„Zd d „Zd d „Z d S)Ú FakeReactorzH This just fakes out enough reactor methods so .run() can work. FcCsd|_||_g|_dS)NF)Ú stop_calledÚto_raiseÚdelayed)Úselfr©r úoc:\users\psant\downloads\hotstarbackend\school\venv\Lib\site-packages\autobahn\twisted\test\test_wamp_runner.pyÚ__init__)szFakeReactor.__init__cOs |j‚dS©N)r©r ÚargsÚkwr r r Úrun.szFakeReactor.runcCs d|_dS)NT)r)r r r r Ústop1szFakeReactor.stopcOs|j ||||f¡dSr )rÚappend)r ÚdelayÚfuncrÚkwargsr r r Ú callLater4szFakeReactor.callLatercOs tdƒ‚dS)NzConnectTCP shouldn't get called)Ú RuntimeErrorrr r r Ú connectTCP7szFakeReactor.connectTCPN) Ú__name__Ú __module__Ú __qualname__Ú__doc__rr rrrrr r r r r"src@s,eZdZedƒedƒedƒdd„ƒƒƒZdS)ÚTestWampTwistedRunnerztxaio.use_twistedztxaio.start_loggingz txaio.configc Gsœz(ddlm}ddlm}ddlm}Wntk rFt d¡‚YnX|ddƒ}|dƒ}t d t |ƒƒ*}|j ||j d d „d d |  |j¡W5QRXdS)zz Ensure the runner doesn't swallow errors and that it exits the reactor properly if there is one. r)ÚApplicationRunner)ÚConnectionRefusedError)Úreactorz No twistedzws://localhost:1Úrealmz It's a trap!ztwisted.internet.reactorcSsdSr r )Ú_r r r ÚXóz:TestWampTwistedRunner.test_connect_error..T)Z start_reactorN)Zautobahn.twisted.wamprZtwisted.internet.errorr Útwisted.internetr!Ú ImportErrorÚunittestÚSkipTestrrÚ assertRaisesrÚ assertTruer)r rrr r!ÚrunnerÚ exceptionZ mockreactorr r r Útest_connect_errorAs    ýz(TestWampTwistedRunner.test_connect_errorN)rrrrr.r r r r r;sr) r(Z unittest.mockrZzope.interfacerZtwisted.internet.interfacesrÚobjectrÚTestCaserr r r r Ús