כhv@pSrSSKJr SSKrSSKJrJr SSKJr SSKJ r J r J r J r SSK Jr SSKJr SS KJrJrJr SS KJr SS KJrJrJrJrJrJrJrJrJ r!J"r" SS K#J$r$ SS K%J&r& SSK'J(r( SSK)J*r*J+r+J,r,J-r-J.r. SSK/J0r1 SSK2J3r3 SSK4J5r5 SSK6J7r7 SSK8J9r9J:r:J;r;Jr> SSK?J@r@JArA SSKBJCrC SSKDJErEJ r "SS\R5rG\"SS\H55rI"SS\R5rJ\ "SS \JS!9rK\ \ \\4\./S4rL\3"5rM"S"S#\R\K5rN"S$S%\R\K5rO\"S S&9"S'S(55rP\S8S)j5rQ\"\+5\"S*S+\ \K555rR\R\JrS\QRS9S,j5rU\QRS:S-j5rV\QRS;S.j5rW\QRSS1j5rZ\QRS?S2j5r[\QRS@S3j5r\SAS4jr]"S5S6\C5r^SBS7jr_g)CzD Private implementation module for public L{twisted.web.websocket}. ) annotationsN) dataclassfield)singledispatch)CallableGenericTypeVarUnion) implementer)URL) ConnectionConnectionType WSConnection)ConnectionState) AcceptConnection BytesMessageCloseConnectionEventPingPongRejectConnection RejectDataRequest TextMessage) H11Handshake)RemoteProtocolError)Deferred) IConsumer IProtocol IPushProducer IReactorTCP ITransport)Factory)Logger)Failure) BAD_REQUEST)URIBrowserLikePolicyForHTTPSResponse_StandardEndpointFactory)Headers)IAgentEndpointFactoryIPolicyForHTTPS)Resource) NOT_DONE_YETrc\\rSrSrSrS SjrS SjrS SSjjrSSSjjrSSjr SSjr S r g )WebSocketTransport<z1 The transport that can send websocket messages. cg)z Send a text message. N)selftexts _C:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/web/_websocket_impl.pysendTextMessage"WebSocketTransport.sendTextMessageAcg)z Send a bytes message. Nr4r5datas r7sendBytesMessage#WebSocketTransport.sendBytesMessageFr:r;cg)z Drop the websocket connection. Nr4)r5codes r7loseConnection!WebSocketTransport.loseConnectionKr:r;cg)a Send a websocket Ping request to measure latency. @note: Per U{Mozilla's documentation }, multiple 'ping' requests may be coalesced into a single 'pong', and unsolicited 'pong' requests must be ignored, so we do not return a L{deferred } here; pongs are delivered separately. Nr4r5payloads r7pingWebSocketTransport.pingPr:r;cg)z6 Attach the given L{IPushProducer} to this transport. Nr4r5producers r7attachProducer!WebSocketTransport.attachProducer\r:r;cg)zD Detach a previously attached L{IPushProducer} from this transport. Nr4r5s r7detachProducer!WebSocketTransport.detachProducerar:r;r4Nr6strreturnNoner>bytesrUrV))rBintrUrVr;rGrXrUrVrLr rUrVrUrV) __name__ __module__ __qualname____firstlineno____doc__r8r?rCrHrMrQ__static_attributes__r4r;r7r1r1<s%      r;r1c$\rSrSr%SrS\S'Srg)ConnectionRejectedgz{ A websocket connection was rejected by an HTTP response. @ivar response: The HTTP response that describes the rejection. r)responser4N)r_r`rarbrc__annotations__rdr4r;r7rfrfgs r;rfcT\rSrSrSrS SjrS SjrS SjrSSjrSSjr SSjr S r g )WebSocketProtocolra+ An object that conforms to L{WebSocketProtocol} can receive all the events from a websocket connection. @note: While this is I{sort of} like a L{byte-stream protocol }, the interface is distinct in a few ways; in particular, we have discrete C{negotiationStarted} and C{negotiationFinished} methods, representing those events in the websocket handshaking process, and no C{connectionMade}; similarly, since websockets can natively support both text and bytes messages, rather than fragmentable segments of a byte stream, we have C{textMessageReceived} and C{bytesMessageReceived} but no C{dataReceived}. Finally, this is a L{typing.Protocol} and not a L{zope.interface.Interface}, since it does not predate the L{typing} module. cg)zz An underlying transport (e.g.: a TCP connection) has been established; negotiation of the websocket transport has begun. Nr4r5 transports r7negotiationStarted$WebSocketProtocol.negotiationStartedr:r;cg)zV Negotiation is complete: a bidirectional websocket channel is now fully established. Nr4rPs r7negotiationFinished%WebSocketProtocol.negotiationFinishedr:r;cg)a( A Pong message was received. @note: Per U{the standard }:: A Pong frame sent in response to a Ping frame must have identical "Application data" as found in the message body of the Ping frame being replied to. If an endpoint receives a Ping frame and has not yet sent Pong frame(s) in response to previous Ping frame(s), the endpoint MAY elect to send a Pong frame for only the most recently processed Ping frame. Given that some Pong frames may be dropped, this event should only be used in concert with the transport's L{.ping } method for its intended purpose, to measure latency and connection durability, not to transport application data. Nr4rFs r7 pongReceivedWebSocketProtocol.pongReceivedr:r;cg)z, A text message was received from the peer. Nr4)r5messages r7textMessageReceived%WebSocketProtocol.textMessageReceivedr:r;cg)z- A bytes message was received from the peer. Nr4r=s r7bytesMessageReceived&WebSocketProtocol.bytesMessageReceivedr:r;cg)z$ The websocket connection was lost. Nr4r5reasons r7connectionLost WebSocketProtocol.connectionLostr:r;r4N)ror1rUrVr^r\)ryrTrUrVrWrr%rUrV) r_r`rarbrcrprsrvrzr}rrdr4r;r7rkrkrs%"   .   r;rk_WSPT) covariantboundc"\rSrSrSrSSjrSrg)WebSocketServerFactoryz A L{WebSocketServerFactory} is a factory for a particular kind of L{WebSocketProtocol} that implements server-side websocket listeners via L{WebSocketResource}. cg)z To conform to L{WebSocketServerFactory}, you must implement a C{buildProtocol} method which takes a L{Request } and returns a L{WebSocketProtocol}. @return: a L{WebSocketProtocol} that will handle the inbound connection. Nr4)r5requests r7 buildProtocol$WebSocketServerFactory.buildProtocolr:r;r4N)rrrUrr_r`rarbrcrrdr4r;r7rr   r;rc"\rSrSrSrSSjrSrg)WebSocketClientFactoryz A L{WebSocketClientFactory} is a factory for a particular kind of L{WebSocketProtocol} that implements client-side websocket listeners via L{WebSocketClientEndpoint}. cg)z To conform to L{WebSocketServerFactory}, you must implement a C{buildProtocol} method which takes a string representing an URL and returns a L{WebSocketProtocol}. @return: a L{WebSocketProtocol} that will handle the outgoing connection. Nr4)r5urls r7r$WebSocketClientFactory.buildProtocolr:r;r4N)rrTrUrrr4r;r7rrrr;r)frozencz\rSrSr%SrS\S'S\S'\\"5SS4S Sjj5rS S jr S r g) WebSocketClientEndpointz A L{WebSocketClientEndpoint} describes an URL to connect to and a way of connecting to that URL, that can connect a L{WebSocketClientFactory} to that URL. r,endpointFactoryrTrNc0[XXE5n[Xb5$)a Construct a L{WebSocketClientEndpoint} from a reactor and a URL. @param reactor: The reactor to use for the TCP connection. @param url: a string describing an URL where a websocket server lives. @param tlsPolicy: The TLS policy to use for HTTPS connections. @param connectTimeout: The number of seconds for the TCP-level connection timeout. @param bindAddress: The bind address to use for the TCP client connections. @return: the newly constructed endpoint. )r*r)clsreactorr tlsPolicyconnectTimeout bindAddressrs r7newWebSocketClientEndpoint.news 43  '<[R"TR5n[UR SSSS95nUR UR [URU555 g)N)schemehostport) r fromTextrrTreplacewritesend WSRequestr)wscthtargetr5s r7clientBootstrap8WebSocketClientEndpoint.connect..clientBootstrap sN TXX&A"2DABF GGCHHYqvvv67 8r;c~>[[[R5TTR TR 55$N)_WebSocketWireProtocolrrCLIENTrr)rprotocolFactoryr5sr71WebSocketClientEndpoint.connect..'s.. !6!67##11$((;r;NrWSConnection | Connectionrr"rUrV) rendpointForURIr' fromBytesrencodeconnectProtocolFactory forProtocol_done)r5rendpoint connectedrs`` @r7rWebSocketClientEndpoint.connects''66 MM$((//'2 3  9 9A8H8H  ' ' 9 3 __$$3 %s$A?B!BB!BB!B!r4) rr!rrTrr-rz int | Nonerz bytes | NonerUr)rzWebSocketClientFactory[_WSP]rUr) r_r`rarbrcri classmethodr(rrrdr4r;r7rrs +* H &?%@%)$( ===# = # = " = !==<%r;rcg)z$ Handle a websocket protocol event. Nr4eventprotos r7 _handleEventr1r:r;c\rSrSr%S\S'S\S'S\S'\"SS 9rS \S '\"SS 9rS \S 'SrS\S'SSjr SSjr S Sjr S!Sjr S"Sjr S SjrS#S$SjjrS%S&SjjrS'SjrSSjrSSjrSSjrSrg)(ri8r_wsconn _Bootstrap _bootstrapr_wspF)initr"rozDeferred[_WSP]rNzResponse | None_rejectResponsecNXl[5UlUR5 gr)rorrconnectionMaderns r7makeConnection%_WebSocketWireProtocol.makeConnectionGs"Z  r;cURRU5 URURUR5 gr)rrprrrorPs r7r%_WebSocketWireProtocol.connectionMadeLs* $$T*  dnn5r;cURRU5 URR5Hn[X 5 M gr)r receive_dataeventsr)r5r>rs r7 dataReceived#_WebSocketWireProtocol.dataReceivedQs3 !!$'\\((*E  %+r;cURRU5 URb#URRU5 SUlggr)rrr_bodyDataFinishedrs r7r%_WebSocketWireProtocol.connectionLostVsA   (    +  2 26 :#'D  ,r;cURnUceURURR[ U555 gr)rorrrr)r5r6rs r7r8&_WebSocketWireProtocol.sendTextMessage]s5 NN}}  !!+d"345r;cURnUceURURR[ U555 gr)rorrrr)r5r>rs r7r?'_WebSocketWireProtocol.sendBytesMessagebs5 NN}}  !!,t"456r;cURnUceURURR[ U555 gr)rorrrr)r5rGrs r7rH_WebSocketWireProtocol.pinggs4 NN}}  !!$w-01r;cURnUceURURR[ X555 UR 5 gr)rorrrrrC)r5rBrrs r7rC%_WebSocketWireProtocol.loseConnectionlsA NN}}  !!/$"?@A r;cN[UR5RUS5 g)NT)rroregisterProducerrKs r7rM%_WebSocketWireProtocol.attachProducerrs$..!228TBr;cJ[UR5R5 gr)rrounregisterProducerrPs r7rQ%_WebSocketWireProtocol.detachProducerus$..!446r;cURnU?URUR5 URR5 gr)rcallbackrrsr5dones r7_completeConnection*_WebSocketWireProtocol._completeConnectionxs0zz J dii  %%'r;cURceURnU?UR[UR55 gr)rrerrbackrfrs r7_rejectConnection(_WebSocketWireProtocol._rejectConnection~s:##///zz J '(<(<=>r;)rrro)ror"rUrVr^rWrrSr[r\)rYr)rBrZrrTrUrVr])r_r`rarbrirrorrrrrrr8r?rHrCrMrQrrrdr4r;r7rr8s~'& J"u-Iz-"u-E>-'+O_+ 6 & (6 7 2  C7( ?r;rc$UR5 gr)rrs r7_handle_acceptConnectionrs r;c[5nURHup4URX45 M [SURSX!R 5UlUR5 g)Nz1.1r)r+headers addRawHeaderr) status_coderorr)rrhdrkvs r7_handle_rejectConnectionrsP )C  $UE,=,=r3XE r;cURcS5eURRUR5 UR(aURR 5 gg)Nz7response should never be None when receiving RejectData)r_bodyDataReceivedr> body_finishedrorCrs r7_handle_rejectDatarsX )A@A) ++EJJ7  &&(r;cNURRUR5 gr)rrzr>rs r7_handle_textMessager s JJ""5::.r;cNURRUR5 gr)rr}r>rs r7_handle_bytesMessager s JJ##EJJ/r;cURRURRUR 555 gr)rorrrrhrs r7 _handle_pingrs* OO%--,,U^^-=>?r;cNURRUR5 gr)rrvrGrs r7 _handle_pongrs JJEMM*r;c*URceURR[R:waBURR URR UR555 URR5 gr) rorstaterCLOSEDrrrhrCrs r7_handle_closeConnectionrsb ?? && & }}o444 emm001ABC OO""$r;cRUR[5 URSS5 g)Nz content-typez text/plains$websocket protocol negotiation error)setResponseCoder& setHeader)rs r7_negotiationErrorrs# K( nl3 2r;c:^\rSrSrSrSU4SjjrSSjrSrU=r$)WebSocketResourceiz A L{WebSocketResource} is a L{Resource} that presents a websocket listener. You can install it into any twisted web server resource hierarchy. c.>[TU]5 Xlg)z Create a L{WebSocketResource} that will respond to incoming connections with the given L{WebSocketServerFactory}. @param factory: The factory that will be used to respond to inbound websocket connections on appropriately formatted GET requests. N)super__init__factory)r5r __class__s r7rWebSocketResource.__init__s  r;c[[R5nURR 5nUVVVs/sHupEUHodU4PM M nnnnUR XqR 5 URRU5n U cS5eUR[55n URn UR R"n U cS5eU cS5e[%U [&U 5n UR R)U 5 U R+U 5 U R-5 [.$s snnnf![a)n[RSXS9 [U5sSnA$SnAff=f)z^ This implementation of the C{GET} HTTP method will respond to inbound websocket connections. z{request} failed with {rpe})rrpeNz"connection not accepted by twistedzchannel transport not connectedz"connection not accepted by wsproto)rrSERVERrequestHeadersgetAllRawHeadersinitiate_upgrade_connectionpathr_logerrorrrrrr connectionchannelrorserverBootstrap_protocolUpgradeForWebsocketsrrsr/)r5r handshakerawhkeyhvalsval simpleHeadersr"wsprottoSendwsconr wireProtos r7 render_GETWebSocketResource.render_GETsF !!6!67 $$5578;Muu M .  1 1- N++G4!G#GG! 0 23$$ OO % %}???} F"FF *5/6J 55i@ ""$#N# . JJ4gJ O$W- - .s#D:E E4 E/)E4/E4)r)rz)WebSocketServerFactory[WebSocketProtocol]rUrV)rrrUz bytes | int) r_r`rarbrcrr8rd __classcell__)rs@r7rrs r;rcg)z; The server requires no bootstrapping, so this is a no-op. Nr4)rrs r7r,r,r:r;)rrrAnyWSWPrUrV)rrrr<rUrV)rrrr<rUrV)rrrr<rUrV)rrrr<rUrV)rrrr<rUrV)rrrr<rUrV)rrrr<rUrV)rrrr<rUrV)rrrUrXr)`rc __future__rtyping dataclassesrr functoolsrrrr r zope.interfacer hyperlinkr wsprotor rrwsproto.connectionrwsproto.eventsrrrrrrrrrrrwsproto.handshakerwsproto.utilitiesrtwisted.internet.deferrtwisted.internet.interfacesrrr r!r"twisted.internet.protocolr#rtwisted.loggerr$twisted.python.failurer%twisted.web._responsesr&twisted.web.clientr'r(r)r*twisted.web.http_headersr+twisted.web.iwebr,r-twisted.web.resourcer.twisted.web.serverr/Protocolr1 Exceptionrfrkrrr(rrrrrr<registerrrrr r rrrrrr,r4r;r7rVss # ($44&<<.   +1+A!*. -C)4( ( V  B B Jv->? u\:56 CTI J  x V__T2 $ V__T2 $ $M%M%M%`  Y H?WT]H? H?V !!2 3  ))//00@@++%%3 ))Xr;