כh5<SrSSKJr SSKJrJr SSKJrJrJ r SSK J r SSK J r SSKJr SSKJr SS KJr SS KJrJr SS KJr SS KJrJr SS KJr SSKJr SSK J!r!J"r" SSK#J$r$ SSK%J&r& SSK'J(r(J)r)J*r* SSK+J,r, \ "SSS9r-Sr."SS\&5r/"SS\&5r0\1"S5 SSK2J3r3J4r4J5r5J6r6J7r7J8r8J9r9 \"SS\655r:"S S!\8\:5r;"S"S#\5\:5r<\"S%S&\\-55r>\ "\.S'5"S(S)\55r?g*!\=a S$r.N5f=f)+z% Tests for L{twisted.web.websocket}. ) annotations) dataclassfield)AnyGenericTypeVar)skipIf) implementer)Deferred)ConnectionDone) IPushProducer)AccumulatingProtocolMemoryReactorClock)Failure)ConnectionCompleterIOPump)SynchronousTestCase) BAD_REQUEST)AgentreadBody)IRequest)Resource) NOT_DONE_YETRequestSite)DataWSPWebSocketProtocol)boundFc\rSrSrSSjrSrg) WeirdResource"c&URS5 g)aw Per U{the wsproto documentation }: - The only scenario in which the caller receives a RejectConnection with C{has_body == False} is if the peer violates sends an informational status code (1xx) other than 101 This is a weird edge case so we provoke it. f)setResponseCodeselfrequests cC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/web/test/test_websocket.py render_GETWeirdResource.render_GET#s $r%N)r)rreturnbytes)__name__ __module__ __qualname____firstlineno__r+__static_attributes__r-r%r*r!r!"s r%r!c"\rSrSrSrSSjrSrg)DelayedResponse2z A resource that will not respond to a C{GET} request right away. You will need to use the C{request.write(b'RESPONSE BODY')} and C{request.finish()} to trigger a response. cXl[$N)r)rr's r*r+DelayedResponse.render_GET9s  r%)r)N)r)rr.int)r0r1r2r3__doc__r+r4r-r%r*r6r62s  r%r6wsproto)ConnectionRejectedWebSocketClientEndpointWebSocketClientFactoryrWebSocketResourceWebSocketServerFactoryWebSocketTransportc\rSrSr%Sr\"\S9rS\S'Sr S\S'SS jr SS jr SS jr SS jr SS jrSSjrSSjrSSjrSrg)MyWSPMzg Used to implement both client-side and server-side WebSocket application that will help with testing. default_factoryz list[bytes]pongsNzFailure | NonewasLostcXlgr9) transport)r(rLs r*negotiationStartedMyWSP.negotiationStartedWs&Nr%cgr9r-r(s r*negotiationFinishedMyWSP.negotiationFinishedZs r%cXlgr9)rJ)r(reasons r*connectionLostMyWSP.connectionLost]s!Lr%c~US:XaURRS5 gURRU5 g)Nrequest response)rLsendBytesMessage bDeferredcallbackr(datas r*bytesMessageReceivedMyWSP.bytesMessageReceived`s/z!//0GH''-r%c~US:XaURRS5 gURRU5 g)Nr)response)rLsendTextMessagedeferredr\r]s r*textMessageReceivedMyWSP.textMessageReceivedfs.y ..z: &&t,r%c:URRU5 gr9)rIappend)r(payloads r* pongReceivedMyWSP.pongReceivedls JJ  g &r%cn[5UlURRS5 UR$)z: Send a text message to the server and expect a response. r))r rdrLrcrPs r* sendRequestMyWSP.sendRequestos),4:DM NN * *9 5== r%cn[5UlURRS5 UR$)z; Send a bytes message to the server and expect a response. rX)r r[rLrZrPs r* bytesRequestMyWSP.bytesRequestws)/7jDN NN + +J 7>> !r%)r[rdrLrJ)rLrCr.Noner.rr)rTrr.rr)r^r/r.rr)r^strr.rr)rir/r.rr)r.z Deferred[str])r.zDeferred[bytes])r0r1r2r3r<rlistrI__annotations__rJrMrQrUr_rerjrmrpr4r-r%r*rErEMsJ #48{8"&& '  " .  -  ' ! "r%rEc*\rSrSr%S\S'SSjrSrg) MyFactoryzWebSocketFixture[Any]fixturecd[5nURRRU5 U$r9)rErzserversrh)r(r)news r* buildProtocolMyFactory.buildProtocols&'C LL ' ' ,Jr%r-N)r)rr.rE)r0r1r2r3rvr~r4r-r%r*rxrxs && r%rxc\rSrSrSSjrSrg)MyClientFactoryc[5$r9)rE)r(uris r*r~MyClientFactory.buildProtocols 7Nr%r-N)rrtr.rE)r0r1r2r3r~r4r-r%r*rrs r%rTc\rSrSr%\"5rS\S'\"\S9rS\S'\"\ S9r S\S'S r S \S '\"\ S9r S \S '\"\S9rS\S'\SSj5rSSSjjrSSSjjrSrg)WebSocketFixtureWebSocketClientFactory[WSP] clientFactoryrGrreactorrresourcePr; portNumberz list[WSP]r|r6 slowResourcecU"U5n[5nX#lURRS[ U55 URRS[ SS55 URRS[ 55 URRSUR5 URRUR[URURS95 U$)Nsconnectsresources some-datazapplication/octet-streams processingsslow)r) rxrzrputChildrArr!rr listenTCPrr)clsrr( serverFactorys r*r}WebSocketFixture.news=!! $ z+<]+KL  l,FG  }mo> w(9(9:  OOT$--F  r%c# [R"URU5nURUR5IShvN $N7fr9)r?r}rconnectr)r(rclients r*rWebSocketFixture.connects6(,,T\\3?^^D$6$67777sAA AA cb[UR5nURUS9nUcS5eU$)a  There should be a single websocket connection in progress; complete it. @param greet: Should we immediately issue a greeting, i.e. deliver any pending buffered TCP data, upon connection? If C{False}, the caller must call C{flush} on the result to deliver any pending data. greetzConnection not in progress.)rr succeedOnce)r(r completer succeededs r*completeWebSocketFixture.completes=( 5 )))6 $C&CC$r%r-N)rrr.zWebSocketFixture[WSP])zhttp://localhost:80/connect)rrtr.r)T)rboolr.r)r0r1r2r3rrrvrrrrrrur|r6r classmethodr}rrr4r-r%r*rrsx16M.8"'8J"KG Kx8Hh8Jt4GY4$)/$JL/J  8  r%rz'wsproto library required for websocketscn\rSrSrS SjrS SjrS SjrS SjrS SjrS Sjr S Sjr S S jr S S jr S r g )WebSocketTestscJ[R[55n[R"UR 55nUR U5 UR[URR5S5 UR[URR5S5 UR5nURU5nUR5nUR U5 UR5 URURU5S5 g)z Connecting to a websocket server (installed with L{WebSocketResource}) from a websocket client (connected with L{WebSocketClientEndpoint}) results in a websocket connection. rbN)rr}rr fromCoroutinerassertNoResult assertEquallenr tcpServers tcpClientsrsuccessResultOfrmflush)r(rz connectedpumpwsClient requesteds r*test_websocketWebSocketTests.test_websockets #&&'89**7??+<=  I& W__778!< W__778!<!'' 2((*  I&  --i8*Er%cl[R[55n[R"UR 55nUR 5nURU5nUR5nURU5 UR5 URURU5S5 g)zr Connecting to a websocket server and sending it a bytes message results in C{bytesMessageReceived} being called. rYN) rr}rr rrrrrprrr)r(rzrrr bRequesteds r*test_bytesMessage WebSocketTests.test_bytesMessages #&&'89**7??+<= !'' 2**,  J'  --j9;RSr%c^[R[55n[R"UR 55 UR 5n/m[[5"U4SjS55nU"5nURSRRU5 URT/5 URRR5 URTS/5 URRR!5 URTSS/5 URRR#5 URT/SQ5 UR%URRU5 URSRR'5 UR%URRS5 g)zW Websocket transports can notify a producer of backpressure events via attachProducer. cF>\rSrSrSU4SjjrSU4SjjrSU4SjjrSrg)6WebSocketTests.test_backpressure..TestProducerc(>TRS5 g)Npausedrhr(eventss r*pauseProducingEWebSocketTests.test_backpressure..TestProducer.pauseProducings h'r%c(>TRS5 g)Nresumedrrs r*resumeProducingFWebSocketTests.test_backpressure..TestProducer.resumeProducing i(r%c(>TRS5 g)Nstoppedrrs r* stopProducingDWebSocketTests.test_backpressure..TestProducer.stopProducingrr%r-Nrs)r0r1r2r3rrrr4)rsr* TestProducerrs ( ) ) )r%rrrr)rrrN)rr}rr rrrr r r|rLattachProducerrserverIOproducerrrrassertIsdetachProducer)r(rzrr testProducerrs @r*test_backpressure WebSocketTests.test_backpressuresW #&&'89w01! ] # ) ) $ )$~ $$33LA $ --/ (, ..0 (I!67 ,,. !AB dmm,,l;$$335 dmm,,d3r%c[R[55n[R"UR 55nUR 5nURU5nURRS5 URUR/5 UR5 URURS/5 g)a Internally, Twisted's websocket resource responds to all ping requests with a pong as required by the spec, so peers can issue a C{ping} and receive a C{pong} message with the same payload; our websocket transport also implements a C{ping} method to send that message. s123N) rr}rr rrrrrLpingrrIrr(rzrrrs r* test_pingPongWebSocketTests.test_pingPongs#&&'89**7??+<= !'' 2' ,  &2r%c[R[55n[R"UR 55nUR 5nURU5nURURSRS5 URURS5 URR5 URURSRS5 URURS5 UR5 URURSRS5 URURS5 g)z] When the underlying TCP connection is lost, L{WebSocketProtocol.connectionLost} is invoked. rN)rr}rr rrrrrr|rJrLloseConnectionr assertIsNotrs r*test_serverConnectionLost(WebSocketTests.test_serverConnectionLost s #&&'89**7??+<= !'' 2 gooa(00$7 h&&-))+ gooa(00$7 h&&-  +33T: ))40r%c[R[55n[UR5nUR SS5nUR U5 UR5 URU5nURUR[5 [U5nURURU5S5 g)z Attempting to issue an C{HTTP GET} against a websocket server (installed with L{WebSocketResource}) results in a C{BAD_REQUEST} response. sGETshttp://localhost/connects$websocket protocol negotiation errorN) rr}rrrr)rrrrcoderr)r(rzagentrbrbodys r*test_badWebSocketTests.test_bads #&&'89goo&==)DE H%   * -{    &(O r%c[R[55n[R"UR S55nUR SS9nURU5 UR5 URU[5 g) Attempting to connect to a regular HTTP resource that does not support websockets will result in the Deferred returned from L{WebSocketClientEndpoint} failing. zhttp://localhost/emptyFrN rr}rr rrrrrfailureResultOfr>r(rzrrs r*test_connectionRefused%WebSocketTests.test_connectionRefused0sl #&&'89**7??;S+TU e, I&  Y(:;r%c[R[55n[R"UR S55nUR SS9nURU5 UR5 URU[5 g)rzhttp://localhost/processingFrNrrs r*test_connectionRefusedWeird*WebSocketTests.test_connectionRefusedWeird=sq #&&'89** OO9 : e, I&  Y(:;r%c [R[55n[R"UR S55nUR SS9nURU5 URRRS5 UR5 URU[5nURRnUR![#5=n5 UR%UR&S5 URRnURS5 UR5 UR%UR&S5 URS5 UR5 UR%UR&S5 UR)5 UR+UR,S5 UR5 UR,cS 5eUR%UR,R.[05 g) z When the client connection is refused by an asynchronous HTTP response, the websocket client will not be notified until the response arrives. zhttp://localhost/slowTrr%shellosworlds helloworldNzshould be closed now)rr}rr rrrrrr)writerrr>valuerb deliverBodyrrr^finishr closedReasontyper )r(rzrrrejectedresppreqs r*test_connectionRefusedSlow)WebSocketTests.test_connectionRefusedSlowLsy #&&'89**7??;R+ST d+ I&$$**3/ '' 3EF~~&& 2445 %""** (  * (  /  annd+ ~~)A+AA) ,,n=r%r-Nrs)r0r1r2r3rrrrrrrrrr4r-r%r*rrs2F$ T 4D3 1$ $ < <>r%rN)@r< __future__r dataclassesrrtypingrrrunittestr zope.interfacer twisted.internet.deferr twisted.internet.errorr twisted.internet.interfacesr twisted.internet.testingrrtwisted.python.failurertwisted.test.iosimrrtwisted.trial.unittestrtwisted.web._responsesrtwisted.web.clientrrtwisted.web.iwebrtwisted.web.resourcertwisted.web.serverrrrtwisted.web.staticrr shouldSkipr!r6 __import__twisted.web.websocketr>r?r@rrArBrCrErxr ImportErrorrrr-r%r*rs.#(((&+15M*:6..%)::# e./   H  h Ky/"!/"/"b*5107  (ws|( (V =>o>(o>?o>sJsDDD