%i(ddlmZmZddlmZddlZddlmZejddl Z ddl m Z m Z ddlmZmZmZmZmZddlmZddlmZdd lmZdd lmZmZmZmZdd lm Z dd l!m"Z"m#Z#m$Z$dd l%m&Z&ddl'm(Z(ddl)m*Z*m+Z+m,Z,ddl-m.Z.ddl m/Z/ddl0m1Z1dZ2dZ3dZ4dZ5dZ6Gdde Z7Gdde jpj2jrZ:eGdde:ejvZ;eGdde:ejxZ<Gd d!e=Z>eGd"d#e>ej~e jpj2jZ?eGd$d%e>eje jpj2jZAee.Gd&d'e=ZCGd(d)eCe;ZDGd*d+eCe<ZEGd,d-e?ZFGd.d/eAZGed:d0ZHed;d1ZIeGd2d3eje;ZJeGd4d5eje?ZKeGd6d7eje<ZLeGd8d9ejeAZMy)<) b64decode b64encode)OptionalN) implementer)create_transport_detailstransport_channel_id) _is_tls_error_maybe_tls_reasonhltypehlvalpublic) websocket)TransportDetails)protocol)PerMessageDeflateOfferPerMessageDeflateOfferAcceptPerMessageDeflateResponsePerMessageDeflateResponseAccept)IWebSocketClientAgent)ConnectionDenyConnectionRequestConnectionResponse) endpoints)Deferred)ConnectionAbortedConnectionDoneConnectionLost) ITransport)connectionDone)Failure)WampWebSocketClientFactoryWampWebSocketClientProtocolWampWebSocketServerFactoryWampWebSocketServerProtocolWebSocketAdapterFactoryWebSocketAdapterProtocolWebSocketClientFactoryWebSocketClientProtocolWebSocketServerFactoryWebSocketServerProtocolWrappingWebSocketAdapterWrappingWebSocketClientFactoryWrappingWebSocketClientProtocolWrappingWebSocketServerFactoryWrappingWebSocketServerProtocol connectWScreate_client_agentlistenWSct|S)zB :returns: an instance implementing IWebSocketClientAgent )_TwistedWebSocketClientAgentreactors t/var/www/html/navyabakers_fullstack/navyabakers_prod/venv/lib/python3.12/site-packages/autobahn/twisted/websocket.pyr1r1Rs ( 00ct|ts#tdjt ||j ds|j ds tdy)z> raises a ValueError if `transport_config` is invalid z-'transport_config' must be a string, found {}zws://zwss://z6'transport_config' must start with 'ws://' or 'wss://'N) isinstancestr ValueErrorformattype startswith)transport_configs r7check_transport_configrAYse & , ; B B%&     & &w /8H8S8S9QRR r8ct|ts tdgd}|jD] }||vstdj |y)z5 raises a ValueError if `options` is invalid z'options' must be a dict)origin protocols useragentheadersproxyz'options' may not contain '{}'N)r:dictr<keysr=)options valid_keysactual_ks r7check_client_optionsrMnsY gt $344JLLNP : %=DDXNO OPr8c|jr!ddlm}|j|j}|j :|_tj||j d|j d}|S|jr4ddlm}tj||j|j}|Stj||j|j}|S)Nrsslhostport) isSecuretwisted.internetrPoptionsForClientTLSrQrGcontextFactoryrHostnameEndpointSSL4ClientEndpointrR)r6factoryr@rJrPcontext_factoryendpoints r7_endpoint_from_configr\s(11',,?}} !0--  MM& ! MM& ! 2 O%    , 33   H O!11  H Or8ceZdZdZdZddZy)r4z6 This agent creates connections using Twisted c||_yN)_reactor)selfr6s r7__init__z%_TwistedWebSocketClientAgent.__init__s  r8Nc$ t|t|td||jd|}|tn||_t |j|||}t |j|} fd fd}|j| S)a- Open a new connection. :param dict transport_config: valid transport configuration :param dict options: additional options for the factory :param protocol_class: a callable that returns an instance of the protocol (WebSocketClientProtocol if the default None is passed in) :returns: a Deferred that fires with an instance of `protocol_class` (or WebSocketClientProtocol by default) that has successfully shaken hands (completed the handshake). )urlr6c(j|yr_)errback)frtn_ds r7failedz1_TwistedWebSocketClientAgent.open..faileds MM! r8cNfd}jj|S)Nc*j|Sr_)callback)argprotorhs r7handshake_completedzQ_TwistedWebSocketClientAgent.open..got_proto..handshake_completedsu% r8)is_open addCallbacks)rnrorirhs` r7 got_protoz4_TwistedWebSocketClientAgent.open..got_protos$  MM & &':F CLr8) rArMr'r`r(rr\rconnectrq) rar@rJprotocol_classrYr[proto_drrrirhs @@r7openz!_TwistedWebSocketClientAgent.opens" /0W%(  $-- ;B (6'= #>  ) MM7$4g  ""7+   Y/ r8r_)__name__ __module__ __qualname____doc__rbrwrsr8r7r4r4s /r8r4ceZdZUdZej ZdZee e d<dZ ee e d<dZ efdefdZdefd Zdd Zd Zd Zd ZdZdZdZdZdZdZdZdZdZdZ y)r&a Adapter class for Twisted WebSocket client and server protocols. Called from Twisted: * :meth:`autobahn.twisted.websocket.WebSocketAdapterProtocol.connectionMade` * :meth:`autobahn.twisted.websocket.WebSocketAdapterProtocol.connectionLost` * :meth:`autobahn.twisted.websocket.WebSocketAdapterProtocol.dataReceived` Called from Network-independent Code (WebSocket implementation): * :meth:`autobahn.twisted.websocket.WebSocketAdapterProtocol._onOpen` * :meth:`autobahn.twisted.websocket.WebSocketAdapterProtocol._onMessageBegin` * :meth:`autobahn.twisted.websocket.WebSocketAdapterProtocol._onMessageFrameData` * :meth:`autobahn.twisted.websocket.WebSocketAdapterProtocol._onMessageFrameEnd` * :meth:`autobahn.twisted.websocket.WebSocketAdapterProtocol._onMessageEnd` * :meth:`autobahn.twisted.websocket.WebSocketAdapterProtocol._onMessage` * :meth:`autobahn.twisted.websocket.WebSocketAdapterProtocol._onPing` * :meth:`autobahn.twisted.websocket.WebSocketAdapterProtocol._onPong` * :meth:`autobahn.twisted.websocket.WebSocketAdapterProtocol._onClose` FIXME: * :meth:`autobahn.twisted.websocket.WebSocketAdapterProtocol._closeConnection` * :meth:`autobahn.twisted.websocket.WebSocketAdapterProtocol._create_transport_details` * :meth:`autobahn.twisted.websocket.WebSocketAdapterProtocol.registerProducer` * :meth:`autobahn.twisted.websocket.WebSocketAdapterProtocol.unregisterProducer` Npeer is_serverct|j|j|_tj |j_|jj|_ |jj|j|j|jjdt|jt|jy#YYxYw)Nz/{func} connection established for peer="{peer}"funcr})r transportr~_transport_detailsrCHANNEL_FRAMING_WEBSOCKETchannel_framingr} setTcpNoDelay tcpNoDelay_connectionMadelogdebugr connectionMader ras r7rz'WebSocketAdapterProtocol.connectionMade s #; NNDNN#   6 6 / ++00   NN ( ( 9   =++,tyy!    s !%CCreasoncnd}t|jtr+|jj d|j d}nQt |jr0|jjt|jn t|jtr(|jj d|j nt|jtrjt|j}t|jdr|jj}|jj d|j |nF|jj d |j t|j|j |j||rE|jj d t!|j"t%|j  y|jj d t!|j"t%|j |y)NFz,Connection to/from {peer} was closed cleanly)r}Tz-Connection to/from {peer} was aborted locallymessagezDConnection to/from {peer} was lost in a non-clean fashion: {message})r}rz7Connection to/from {peer} lost ({error_type}): {error}))r} error_typeerrorz8{func} connection lost for peer="{peer}", closed cleanlyrzD{func} connection lost for peer="{peer}", closed with error {reason})rr}r)r:valuerrrr}r rr rrr;hasattrrr>_connectionLostr connectionLostr )rar was_cleanrs r7rz'WebSocketAdapterProtocol.connectionLost+s fllN 3 HHNN>TYY  I 6<< ( HHNN,V\\: ;  &7 8 HHNN?dii   n 5&,,'Gv||Y/ ,,.. HHNNVYY   HHNNIYY -ll   V$  HHNNJD//0499%   HHNNVD//0499%  r8datac |jjdt|jt |j t t ||j|y)Nz2{func} received {data_len} bytes for peer="{peer}")rr}data_len)rrr dataReceivedr r}len _dataReceivedrars r7rz%WebSocketAdapterProtocol.dataReceivedcsP  @))*tyy!3t9%   4 r8c|r1t|jdr|jjy|jjy)NabortConnection)rrrloseConnection)raaborts r7_closeConnectionz)WebSocketAdapterProtocol._closeConnectionns5 WT^^->? NN * * , NN ) ) +r8c|jjr>dt|j|jjdi}||j_|j y)Nz tls-unique)r is_securerrr~ channel_idonOpen)rars r7_onOpenz WebSocketAdapterProtocol._onOpenusU  " " , ,2NND$;$;$E$E|J 26W6p ! !, &))!%*- =,r8r&c6eZdZdZej ZdZy)r*z Base class for Twisted-based WebSocket server protocols. Implements :class:`autobahn.websocket.interfaces.IWebSocketChannel`. TN)rxryrzr{rrrr~rsr8r7r*r*s %   CIr8r*cHeZdZdZej ZdZdefdZ dZ y)r(z Base class for Twisted-based WebSocket client protocols. Implements :class:`autobahn.websocket.interfaces.IWebSocketChannel`. Fresponsec|jjdt|j||j |S)Nz{meth}(response={response}))methr)rrr _onConnect onConnect)rars r7rz"WebSocketClientProtocol._onConnects:  )(  ~~h''r8c|jjd|jj|jj y)NzStarting TLS upgrade)rrrstartTLSrYrVrs r7rz WebSocketClientProtocol.startTLSs/ -.  ; ;`_ and should be compatible with that. It uses WebSocket subprotocol negotiation and supports the following WebSocket subprotocols: - ``binary`` (or a compatible subprotocol) - ``base64`` Octets are either transmitted as the payload of WebSocket binary messages when using the ``binary`` subprotocol (or an alternative binary compatible subprotocol), or encoded with Base64 and then transmitted as the payload of WebSocket text messages when using the ``base64`` subprotocol. cPt|trv|}|jD](}||jjvs|dk7|_|cSt t jdj|jjt|tr|}|j|jjvrM|jtjjdj|jj|jdk7|_ytd)Nbase64z2this server only speaks {0} WebSocket subprotocolsz2this client only speaks {0} WebSocket subprotocolsz logic error)r:rrDrY _subprotocols _binaryModerNOT_ACCEPTABLEr=rr_fail_connectionWebSocketProtocol CLOSE_STATUS_CODE_PROTOCOL_ERROR Exception)rarequestOrResponserequestprs r7rz"WrappingWebSocketAdapter.onConnectGs '): ;'G&&  222'(H}D$H !--DKKLL..  )+= >(H   (B(BB%%..OOHOO 22 (00Hmessage payload type does not match the negotiated subprotocolz*message payload base64 decoding error: {0}) rrrr"CLOSE_STATUS_CODE_UNSUPPORTED_DATArr!CLOSE_STATUS_CODE_INVALID_PAYLOADr=rr)rarres r7rz"WrappingWebSocketAdapter.onMessagefs t'' '  ! !**MMP  '0G KK $ $W - !)) 22TTDKKANs A%% B1.9B,,B1c:|jjdyr_)rrrs r7rz WrappingWebSocketAdapter.onClosexs ""4(r8ct|tk(sJ|jr|j|dyt |}|j|dy)NT)rF)r>rr sendMessagerrs r7writezWrappingWebSocketAdapter.write{sLDzU"""      TD  1T?D   TE  2r8c4|D]}|j|yr_)r)rards r7 writeSequencez&WrappingWebSocketAdapter.writeSequences A JJqM r8c$|jyr_) sendClosers r7rz'WrappingWebSocketAdapter.loseConnections  r8c6|jjSr_)rgetPeerrs r7r z WrappingWebSocketAdapter.getPeer~~%%''r8c6|jjSr_)rgetHostrs r7r z WrappingWebSocketAdapter.getHostr r8N) rxryrzr{rrrrrrrr r rsr8r7r+r+2s4&+8%.$)3 ((r8r+ceZdZdZy)r/zD Server protocol for stream-based transport over WebSocket. Nrrsr8r7r/r/r8r/ceZdZdZy)r-zD Client protocol for stream-based transport over WebSocket. Nrrsr8r7r-r-rr8r-c2eZdZdZ ddZdZdZdZy)r.zL Wrapping server factory for stream-based transport over WebSocket. Nc||_ddg|_|r|jj|tj ||||j|j ||j d|rd}|j |y y ) z :param factory: Stream-based factory to be wrapped. :type factory: A subclass of ``twisted.internet.protocol.Factory`` :param url: WebSocket URL of the server this server factory will work for. :type url: unicode binaryrrdr6rDautoFragmentSizeF failByDropcL|D]}t|tst|cSyr_)r:rr)offersoffers r7acceptz7WrappingWebSocketServerFactory.__init__..accepts)#CE!%)?@;EBBCr8perMessageCompressionAcceptN)_factoryrappendr)rbsetProtocolOptions)rarYrdr6enableCompressionr subprotocolrs r7rbz'WrappingWebSocketServerFactory.__init__s   &1     % %k 2'' c7d6H6H ( 1AB 51  C  # # # G r8ct}||_|jj||_||j_|Sr_)r/rYr buildProtocolrrraaddrrns r7r$z,WrappingWebSocketServerFactory.buildProtocol8/1 }}2248 !&  r8cb|jjtj|yr_)r startFactoryr)rs r7r)z+WrappingWebSocketServerFactory.startFactorys  ""$++D1r8cb|jjtj|yr_)r stopFactoryr)rs r7r+z*WrappingWebSocketServerFactory.stopFactorys  !!#**40r8NTrN)rxryrzr{rbr$r)r+rsr8r7r.r.s+)HV21r8r.c&eZdZdZ ddZdZy)r,zL Wrapping client factory for stream-based transport over WebSocket. NcV||_ddg|_|r|jj|tj ||||j|j ||j d|r3t g}|j |d}|j | y y ) a :param factory: Stream-based factory to be wrapped. :type factory: A subclass of ``twisted.internet.protocol.Factory`` :param url: WebSocket URL of the server this client factory will connect to. :type url: unicode rrrrFr)perMessageCompressionOffersc:t|tr t|Syr_)r:rr)rs r7rz7WrappingWebSocketClientFactory.__init__..acceptsh(AB:8DDCr8rN)rrrr'rbr r) rarYrdr6r!rr"rrs r7rbz'WrappingWebSocketClientFactory.__init__s   &1     % %k 2'' c7d6H6H ( 1AB 51 -./F  # # # G E  # # # G r8ct}||_|jj||_||j_|Sr_)r-rYrr$rrr%s r7r$z,WrappingWebSocketClientFactory.buildProtocolr'r8r,)rxryrzr{rbr$rsr8r7r,r,s!,H\r8r,ct|dr |j}nddlm}|jr|ddlm}|j }|j 8||_|j|j d|j d|||}|S|jr,|j|j|j||||}|S|j|j|j|||}|S)a Establish WebSocket connection to a server. The connection parameters like target host, port, resource and others are provided via the factory. :param factory: The WebSocket protocol factory to be used for creating client protocol instances. :type factory: An :class:`autobahn.websocket.WebSocketClientFactory` instance. :param contextFactory: SSL context factory, required for secure WebSocket connections ("wss"). :type contextFactory: A `twisted.internet.ssl.ClientContextFactory `_ instance. :param timeout: Number of seconds to wait before assuming the connection has failed. :type timeout: int :param bindAddress: A (host, port) tuple of local address to bind to, or None. :type bindAddress: tuple :returns: The connector. :rtype: An object which implements `twisted.interface.IConnector `_. r6rr5rOrQrR) rr6rTrSrPClientContextFactoryrGrV connectTCP connectSSLrQrR)rYrVtimeout bindAddressr6rPconns r7r0r0!s,w "//,  ! , 557N}} !/!! MM& !7==#8'7K " K   %%   D K%% gllGWkD Kr8ct|dr |j}nddlm}|jr.| t d|j |j ||||}|S|j|j |||}|S)a Listen for incoming WebSocket connections from clients. The connection parameters like listening port and others are provided via the factory. :param factory: The WebSocket protocol factory to be used for creating server protocol instances. :type factory: An :class:`autobahn.websocket.WebSocketServerFactory` instance. :param contextFactory: SSL context factory, required for secure WebSocket connections ("wss"). :type contextFactory: A twisted.internet.ssl.ContextFactory. :param backlog: Size of the listen queue. :type backlog: int :param interface: The interface (derived from hostname given) to bind to, defaults to '' (all). :type interface: str :returns: The listening port. :rtype: An object that implements `twisted.interface.IListeningPort `_. r6rr5zCSecure WebSocket listen requested, but no SSL context factory given)rr6rTrSr listenSSLrR listenTCP)rYrVbacklog interfacer6listeners r7r2r2Ys,w "//,  !U $$ LL'>7I  O$$W\\7GYO Or8ceZdZdZy)r$z Twisted-based WAMP-over-WebSocket server protocol. Implements: * :class:`autobahn.wamp.interfaces.ITransport` Nrrsr8r7r$r$r8r$ceZdZdZeZdZy)r#zD Twisted-based WAMP-over-WebSocket server protocol factory. c|jdd}tjj||||j|d<t j|g|i|y)a :param factory: A callable that produces instances that implement :class:`autobahn.wamp.interfaces.ITransportHandler` :type factory: callable :param serializers: A list of WAMP serializers to use (or ``None`` for all available serializers). :type serializers: list of objects implementing :class:`autobahn.wamp.interfaces.ISerializer` serializersNrD)rrr#rb _protocolsr)rarYrrrCs r7rbz#WampWebSocketServerFactory.__init__sTjj5 ,,55dG[Q"oo{ ''>t>v>r8N)rxryrzr{r$rrbrsr8r7r#r#s+H?r8r#ceZdZdZy)r"z Twisted-based WAMP-over-WebSocket client protocol. Implements: * :class:`autobahn.wamp.interfaces.ITransport` Nrrsr8r7r"r"r@r8r"ceZdZdZeZdZy)r!zD Twisted-based WAMP-over-WebSocket client protocol factory. c|jdd}tjj||||j|d<t j|g|i|d|_y)a :param factory: A callable that produces instances that implement :class:`autobahn.wamp.interfaces.ITransportHandler` :type factory: callable :param serializer: The WAMP serializer to use (or ``None`` for "best" serializer, chosen as the first serializer available from this list: CBOR, MessagePack, UBJSON, JSON). :type serializer: object implementing :class:`autobahn.wamp.interfaces.ISerializer` rCNrDF)rrr!rbrDr'noisyrEs r7rbz#WampWebSocketClientFactory.__init__s[jj5 ,,55dG[Q"oo{''>t>v> r8N)rxryrzr{r"rrbrsr8r7r!r!s+Hr8r!)NN)N2)Nrrrtypingrrzope.interfacer use_twistedtwisted.internet.protocoltwistedautobahn.twisted.utilrr autobahn.utilr r r r r autobahn.wamprautobahn.wamp.typesrautobahn.websocketrautobahn.websocket.compressrrrrautobahn.websocket.interfacesrautobahn.websocket.typesrrrrTrtwisted.internet.deferrtwisted.internet.errorrrrtwisted.internet.interfacesrrtwisted.python.failurer __all__r1rArMr\r4internetProtocolr&r*r(objectr%r) ServerFactoryr' ClientFactoryr+r/r-r.r,r0r2r$r#r"r!rsr8r7rds6( & PQQ#0' @ '+TT24* ,1*P*(V7#87tG,w//88AAG,T h>>   =h>>==2f H ## ++HH>%E ## ++%E%E\ Z`(v`(`(F55=1%;=1@8%;8v44n$$N  ))+B  ? ((*@??@  ))+B   ((*@r8