o >h( @sddlmZddlmZzddlmZWn!ey5zddlmZWney2ddl mZYnwYnwddlm Z m Z ddl m Z dZGdd d e Zee Gd d d eZd S) ) implementer)ProtocolWrappernotFound) NoResource) IResourceResource) NOT_DONE_YET)WebSocketResourceWSGIRootResourcec@s eZdZdZddZddZdS)r a Root resource when you want a WSGI resource be the default serving resource for a Twisted Web site, but have subpaths served by different resources. This is a hack needed since `twisted.web.wsgi.WSGIResource `_. does not provide a ``putChild()`` method. .. seealso:: * `Autobahn Twisted Web WSGI example `_ * `Original hack `_ cCst|||_||_dS)a} :param wsgiResource: The WSGI to serve as root resource. :type wsgiResource: Instance of `twisted.web.wsgi.WSGIResource `_. :param children: A dictionary with string keys constituting URL subpaths, and Twisted Web resources as values. :type children: dict N)r__init__ _wsgiResourcechildren)self wsgiResourcerry/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/autobahn/twisted/resource.pyr Fs  zWSGIRootResource.__init__cCs|j|jd||jS)Nr)prepathpoppostpathinsertr )rpathrequestrrrgetChildRs zWSGIRootResource.getChildN)__name__ __module__ __qualname____doc__r rrrrrr 6s r c@s4eZdZdZdZddZddZddZd d Zd S) r z/ A Twisted Web resource for WebSocket. TcCs ||_dS)z :param factory: An instance of :class:`autobahn.twisted.websocket.WebSocketServerFactory`. :type factory: obj N)_factory)rfactoryrrrr _s zWebSocketResource.__init__cCs tddS)zR This resource cannot have children, hence this will always fail. zNo such child resource.)messager)rnamerrrrgetChildWithDefaulths z%WebSocketResource.getChildWithDefaultcCsdS)zS This resource cannot have children, hence this is always ignored. Nr)rrchildrrrputChildnszWebSocketResource.putChildcCsJ|jjdur%ddlm}|dd|dd|jd|jf}|d S|j |j }|s7|d d S|jjd}|j_t |t rI||_nt |jt rT||j_n||_||t|d rg|jn t|d rp||jd|jd}|jD]}||ddd|dd7}q|d7}||j7}||tS)z Render the resource. This will takeover the transport underlying the request, create a :class:`autobahn.twisted.websocket.WebSocketServerProtocol` and let that do any subsequent communication. Nr)protocolisUpgrade requiredsUpgrades WebSocketutf8i_networkProducerresumeProducing s HTTP/1.1 s: ,s )channel transportautobahn.websocketr%setResponseCode setHeader_SERVER_STATUS_TEMPLATE __version__encoder buildProtocolgetPeer isinstancerwrappedProtocolmakeConnectionhasattrr)r*methodurirequestHeadersgetAllRawHeadersjoincontentread dataReceivedr )rrr%htmlr/datahrrrrenderss8            $ zWebSocketResource.renderN) rrrrisLeafr r"r$rGrrrrr Xs  r N)zope.interfacertwisted.protocols.policiesrtwisted.web.pagesr ImportErrortwisted.web.resourcertwisted.web.errorrrtwisted.web.serverr __all__r objectr rrrrs$     "