o >h\ @s8ddlmZddlmZddlmZGdddeZdS)) AsyncConsumer)aclose_old_connections) StopConsumerc@s^eZdZdZddZdddddZd d d d Zd dZddZddZ ddZ ddZ dS)AsyncHttpConsumerzf Async HTTP consumer. Provides basic primitives for building asynchronous HTTP endpoints. cOs g|_dS)N)body)selfargskwargsr u/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/channels/generic/http.py__init__ s zAsyncHttpConsumer.__init__N)statusheaderscsB|durg}n t|trt|}|d||dIdHdS)a? Sets the HTTP response status and headers. Headers may be provided as a list of tuples or as a dictionary. Note that the ASGI spec requires that the protocol server only starts sending the response to the client after ``self.send_body`` has been called the first time. Nzhttp.response.start)typerr) isinstancedictlistitemssend)rrrr r r send_headerss    zAsyncHttpConsumer.send_headersF) more_bodycs0t|ts Jd|d||dIdHdS)a Sends a response body to the client. The method expects a bytestring. Set ``more_body=True`` if you want to send more body content later. The default behavior closes the response, and further messages on the channel will be ignored. zBody is not byteszhttp.response.body)rrrN)rbytesr)rrrr r r send_body"s  zAsyncHttpConsumer.send_bodycs0|jdd|i|IdH||IdHdS)z Sends a response to the client. This is a thin wrapper over ``self.send_headers`` and ``self.send_body``, and everything said above applies here as well. This method may only be called once. rNr )rr)rrrr r r r send_response/szAsyncHttpConsumer.send_responsecs td)z Receives the request body as a bytestring. Response may be composed using the ``self.send*`` methods; the return value of this method is thrown away. z?Subclasses of AsyncHttpConsumer must provide a handle() method.)NotImplementedError)rrr r r handle8szAsyncHttpConsumer.handlecsdS)zh Overrideable place to run disconnect handling. Do not send anything from here. Nr )rr r r disconnectBszAsyncHttpConsumer.disconnectcshd|vr |j|d|ds2z|d|jIdHW|IdHt|IdHwdS)z Async entrypoint - concatenates body fragments and hands off control to ``self.handle`` when the body has been completely received. rrN)rappendgetrjoinrrrmessager r r http_requestIs zAsyncHttpConsumer.http_requestcs"|IdHtIdHt)zG Let the user do their cleanup and close the consumer. N)rrrr#r r r http_disconnectWs z!AsyncHttpConsumer.http_disconnect) __name__ __module__ __qualname____doc__r rrrrrr%r&r r r r rs    rN)channels.consumerrdbr exceptionsrrr r r r s