o @»Bi(ã@s¬ddlmZddlmZddlmZzddlmZWney)ddl mZYnwddl m Z m Z ddl m Z ddlmZdZGd d „d e ƒZee ƒGd d „d eƒƒZd S)é)Úabsolute_import)Ú implementer)ÚProtocolWrapper©Ú NoResource)Ú IResourceÚResource)ÚPY3)Ú NOT_DONE_YET)ÚWebSocketResourceÚWSGIRootResourcec@s eZdZdZdd„Zdd„ZdS)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__Ú _wsgiResourceÚchildren)ÚselfÚ wsgiResourcer©rúY/var/www/html/Trade-python/venv/lib/python3.10/site-packages/autobahn/twisted/resource.pyr Ds  zWSGIRootResource.__init__cCs|j ¡|j d|¡|jS)Nr)ÚprepathÚpopÚpostpathÚinsertr)rÚpathÚrequestrrrÚgetChildPs zWSGIRootResource.getChildN)Ú__name__Ú __module__Ú __qualname__Ú__doc__r rrrrrr 4s r c@s4eZdZdZdZdd„Zdd„Zdd„Zd 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)rÚfactoryrrrr ]s zWebSocketResource.__init__cCstdƒS)zR This resource cannot have children, hence this will always fail. zNo such child resource.r)rÚnamerrrrÚgetChildWithDefaultfsz%WebSocketResource.getChildWithDefaultcCsdS)zS This resource cannot have children, hence this is always ignored. Nr)rrÚchildrrrÚputChildlszWebSocketResource.putChildcCs€|jjdur%ddlm}| dd¡| dd¡|jd|jf}| d ¡S|j   |j  ¡¡}|s7| d ¡d S|jjd}|j_t |t ƒrI||_n||_| |¡t|d ƒr\|j ¡n t|d ƒre| ¡tr–|jd|jd}|j ¡D]}||ddd |d¡d7}qv|d7}||j ¡7}n#d|j|jf}|j ¡D]}|d|dd |d¡f7}q£|d7}| |¡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)ÚprotocoliªsUpgrade requiredsUpgrades WebSocketÚÚutf8iôóÚ_networkProducerÚresumeProducingó s HTTP/1.1 s: ó,és z%s %s HTTP/1.1 z%s: %s ú,z )ÚchannelÚ transportÚautobahn.websocketr%ÚsetResponseCodeÚ setHeaderÚ_SERVER_STATUS_TEMPLATEÚ __version__ÚencoderÚ buildProtocolÚgetPeerÚ isinstancerÚwrappedProtocolÚmakeConnectionÚhasattrr)r*r ÚmethodÚuriÚrequestHeadersÚgetAllRawHeadersÚjoinÚcontentÚreadÚ dataReceivedr )rrr%Úhtmlr0ÚdataÚhrrrÚrenderqs>          $  zWebSocketResource.renderN) rrrrÚisLeafr r"r$rHrrrrr Vs  r N)Ú __future__rÚzope.interfacerÚtwisted.protocols.policiesrÚtwisted.web.errorrÚ ImportErrorÚtwisted.web.resourcerrÚsixr Útwisted.web.serverr Ú__all__r Úobjectr rrrrÚs    þ  "