_f :ddlmZddlmZGddeZdS)) AsyncConsumer) StopConsumercPeZdZdZdZddddZddd Zd Zd Zd Z d Z dZ dS)AsyncHttpConsumerzf Async HTTP consumer. Provides basic primitives for building asynchronous HTTP endpoints. cg|_dS)N)body)selfargskwargss G/var/www/html/env/lib/python3.11/site-packages/channels/generic/http.py__init__zAsyncHttpConsumer.__init__ s  N)statusheaderscK|g}n6t|tr!t|}|d||dd{VdS)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)r rrs r send_headerszAsyncHttpConsumer.send_headerss ?GG  & & ,7==??++Gii*f Q Q           rF) more_bodycKt|ts Jd|d||dd{VdS)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)rr rN)rbytesr)r r rs r send_bodyzAsyncHttpConsumer.send_body!sr$&&;;(;;;&ii)4i P P           rcjK|jdd|i|d{V||d{VdS)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. rN)rr)r rr r s r send_responsezAsyncHttpConsumer.send_response.sb  d88v8888888888nnT"""""""""""rc$Ktd)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)r r s r handlezAsyncHttpConsumer.handle7s " M   rc KdS)zh Overrideable place to run disconnect handling. Do not send anything from here. Nr )r s r disconnectzAsyncHttpConsumer.disconnectAs rctKd|vr |j|d|ds| |d|jd{V|d{Vn#|d{VwxYwt dS)z Async entrypoint - concatenates body fragments and hands off control to ``self.handle`` when the body has been completely received. r rrN)r appendgetr$joinr&rr messages r http_requestzAsyncHttpConsumer.http_requestHs W   I  WV_ - - -{{;'' ! (kk#((49"5"5666666666oo''''''''''doo''''''''''..  ! !s 3B B'cVK|d{Vt)zG Let the user do their cleanup and close the consumer. N)r&rr+s r http_disconnectz!AsyncHttpConsumer.http_disconnectVs4oonnr) __name__ __module__ __qualname____doc__rrrr!r$r&r-r/r rr rrs ,/     $27      ###       ! ! !rrN)channels.consumerr exceptionsrrr rr r6sg++++++%%%%%%UUUUU UUUUUr