U uc( @sddlmZddlmZzddlmZWnFek rnzddlmZWn ek rhddl mZYnXYnXddlm 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)selfZ wsgiResourcerrZ/var/www/html/HOTSTAR/school/venv/lib/python3.8/site-packages/autobahn/twisted/resource.pyr Fs zWSGIRootResource.__init__cCs|j|jd||jS)Nr)ZprepathpopZpostpathinsertr )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 _szWebSocketResource.__init__cCs tddS)zR This resource cannot have children, hence this will always fail. zNo such child resource.)messager)rnamerrrrgetChildWithDefaulthsz%WebSocketResource.getChildWithDefaultcCsdS)zS This resource cannot have children, hence this is always ignored. Nr)rrchildrrrputChildnszWebSocketResource.putChildcCsL|jjdkrJddlm}|dd|dd|jd|jf}|d S|j |j }|sn|d d S|jjd}|j_t |t r||_nt |jt r||j_n||_||t|d r|jnt|d r||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 )Zchannel transportZautobahn.websocketr"ZsetResponseCodeZ setHeaderZ_SERVER_STATUS_TEMPLATE __version__encoderZ buildProtocolZgetPeer isinstancerZwrappedProtocolZmakeConnectionhasattrr&r'methodZuriZrequestHeadersZgetAllRawHeadersjoincontentreadZ dataReceivedr )rrr"htmlr+datahrrrrenderss8             & zWebSocketResource.renderN) rrrrZisLeafr rr!r7rrrrr Xs  r N)Zzope.interfacerZtwisted.protocols.policiesrZtwisted.web.pagesr ImportErrorZtwisted.web.resourcerZtwisted.web.errorrrZtwisted.web.serverr __all__r objectr rrrrs   "