hQ'SSKJr SSKJr SSKJr SSKJr SSKJ r J r SSK J r SSKJr SS KJrJr SS KJr SS KJr SS KJr SS KJr Sr\"\5"SS\55r\"\ 5"SS\55r"SS\ \5r"SS\5r"SS\5rSr Sr!g!\a \"S5ef=f!\a SSK J r Nf=f))IHostnameResolverz=Twisted 17.1.0 or later required for autobahn.twisted.testing)Deferred) IPv4Address)HostResolution) ISSLTransportIReactorPluggableNameResolver)MemoryReactorClock)iosim)directlyProvides implementer)IWebSocketClientAgent)_TwistedWebSocketClientAgent)WebSocketServerProtocol)WebSocketServerFactory) create_pumpercreate_memory_agentMemoryReactorClockResolverc\rSrSrSSjrSrg)_StaticTestResolver>c[U5nURU5 UR[SSUS:XaSOU55 UR 5 g)zB Implement IHostnameResolver which always returns 127.0.0.1:31337 TCP 127.0.0.1rizN)rresolutionBeganaddressResolvedrresolutionComplete)selfreceiverhostName portNumber resolutions eC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\autobahn/twisted/testing/__init__.pyresolveHostName#_StaticTestResolver.resolveHostName@sL$H-   ,  {Z1_E* U  ##%N)r)__name__ __module__ __qualname____firstlineno__r$__static_attributes__r'r&r#rr>s &r&rc2\rSrSrSrSr\S5rSrSr g)_TestNameResolverLz1 A test version of IReactorPluggableNameResolver NcRURc[5UlUR$N) _resolverrrs r# nameResolver_TestNameResolver.nameResolverTs >> !02DN~~r&c*URnXlU$r1r2)rresolverolds r#installNameResolver%_TestNameResolver.installNameResolverZsnn! r&r7) r(r)r*r+__doc__r2propertyr4r:r,r'r&r#r.r.Ls%I  r&r.c\rSrSrSrSrg)r`zM Combine MemoryReactor, Clock and an IReactorPluggableNameResolver together. r'N)r(r)r*r+r<r,r'r&r#rr`s  r&rc(\rSrSrSrSrSSjrSrg)_TwistedWebMemoryAgentha A testing agent which will hook up an instance of `server_protocol` for every client that is created via the `open` API call. :param reactor: the reactor to use for tests (usually an instance of MemoryReactorClockResolver) :param pumper: an implementation IPumper (e.g. as returned by `create_pumper`) :param server_protocol: the server-side WebSocket protocol class to instantiate (e.g. a subclass of `WebSocketServerProtocol` cXlX0lX l[UR5Ul[ 5Ul[5Ulgr1) _reactor_server_protocol_pumperr_agentset_pumpsdict_servers)rreactorpumperserver_protocols r#__init___TwistedWebMemoryAgent.__init__xs6 / 34==A e  r&Nc^^URS5nTRRXUS9nU(aTRRSupgppOTRR Supgpn [ SSU5n [ SSS5n TR5m[TSS5c[5Tl [R"TS XS 9nURS5n[R"US XS 9nU(a [U[5 [U[5 [R "TXU5nTR"R%U5 UU4S jnUR'U5 U$) a= Implement IWebSocketClientAgent with in-memory transports. :param transport_config: a string starting with 'wss://' or 'ws://' :param options: a dict containing options :param protocol_class: the client protocol class to instantiate (or `None` for defaults, which is to use `WebSocketClientProtocol`) zwss://)protocol_classrrrfactoryNT)isServer hostAddress peerAddressFc&>TTRU'U$r1)rK)protorrNs r# add_mapping0_TwistedWebMemoryAgent.open..add_mappings#2DMM% Lr&) startswithrGopenrD sslClients tcpClientsrrEgetattrrrTr FakeTransport buildProtocolr rconnectrFadd addCallback)rtransport_configoptionsrR is_securereal_client_protocolhostportrTcontext_factorytimeout bindAddressserver_addressclient_addressserver_transportclientProtocolclient_transportpumprZrNs` @r#r]_TwistedWebMemoryAgent.opens`%//9  ${{// ) 0  IMIaIabdIe FD';8< 8P8PQS8T 5D+$UK>$UK?//1 ?It 4 <&<&>O # .. d&D!..t4 .. U&D  -} = -} =}} -?OQ   ((5##r&)rGrFrIrDrErKr1)r(r)r*r+r<rOr]r,r'r&r#rArAhs 6$r&rAc<\rSrSrSrSrSrSrSrSr Sr S r g ) _Kalamazooa Feeling whimsical about class names, see https://en.wikipedia.org/wiki/Handcar This is 'an IOPump pumper', an object which causes a series of IOPumps it is monitoring to do their I/O operations periodically. This needs the 'real' reactor which trial drives, because reasons: - so @inlineCallbacks / async-def functions work (if I could explain exactly why here, I would) - we need to 'break the loop' of synchronous calls somewhere and polluting the tests themselves with that is bad - get rid of e.g. .flush() calls in tests themselves (thus 'teaching' the tests about details of I/O scheduling that they shouldn't know). cV[5UlSUl/UlSSKJn Xlg)NFr)rL)rHrI_pumping_waiting_for_stoptwisted.internetrL_global_reactor)rglobal_reactors r#rO_Kalamazoo.__init__s#e  !#>-r&c:URRU5 g)zX Add a new IOPump. It will be removed when both its client and server are disconnected. N)rIrd)rps r#rd_Kalamazoo.adds r&cUR(agSUlURRSUR5 g)z Begin triggering I/O in all IOPump instances we have. We will keep periodically 'pumping' our IOPumps until `.stop()` is called. Call from `setUp()` for example. NTr)rzr} callLater _pump_oncer3s r#start_Kalamazoo.starts/ ==   &&q$//:r&cUR(d[UR5(a.[5nURR U5 SUlU$[5nUR S5 U$)zg :returns: a Deferred that fires when we have stopped pump()-ing Call from `tearDown()`, for example. FN)rzlenr{rappendcallbackrds r#stop_Kalamazoo.stopsZ ==C 6 677 A  " " ) )! ,!DMH J 4r&cUR(a7UR5 URRSUR5 gUR HnUR S5 M /Ulg)zc flush all data from all our IOPump instances and schedule another iteration on the global reactor g?N)rz_flushr}rrr{rrs r#r_Kalamazoo._pump_oncesR == KKM  * *3 @++ 4 ,%'D "r&cURn[5=o lUH\nUR5 URR(aUR R(aMKUR U5 M^ g)z5 Flush all data between pending client/server pairs. N)rIrHflushclientIO disconnectedserverIOrd)r old_pumps new_pumpsrs r#r_Kalamazoo._flushsTKK "%%' KA GGIzz&&1::+B+B MM!  r&)r}rzrIr{N) r(r)r*r+r<rOrdrrrrr,r'r&r#rwrws%&. ;  ( r&rwc[5$)z, return a new instance implementing IPumper )rwr'r&r#rrs  <r&c,Uc[n[XU5$)a return a new instance implementing `IWebSocketClientAgent`. connection attempts will be satisfied by traversing the Upgrade request path starting at `resource` to find a `WebSocketResource` and then exchange data between client and server using purely in-memory buffers. )rrA)rLrMrNs r#rrs1 !'? CCr&N)"twisted.internet.interfacesr ImportErrortwisted.internet.deferrtwisted.internet.addressrtwisted.internet._resolverrrrtwisted.internet.testingr twisted.test.proto_helpers twisted.testr zope.interfacer r autobahn.websocket.interfacesr autobahn.twisted.websocketrrr__all__objectrr.rrArwrrr'r&r#rs<= ,05T>;8?C>=   && &  & *+,& !35F P$2P$fSSl Dq G >=>sB&B8&B58 CC