g\ >ddlmZddlmZddlmZGddeZy)) AsyncConsumer)aclose_old_connections) StopConsumercNeZdZdZdZddddZddd Zd Zd Zd Z d Z dZ y)AsyncHttpConsumerzf Async HTTP consumer. Provides basic primitives for building asynchronous HTTP endpoints. cg|_y)N)body)selfargskwargss S/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/channels/generic/http.py__init__zAsyncHttpConsumer.__init__ s  N)statusheaderscK|g}n)t|trt|j}|j d||dd{y7w)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_headerssL ?G  &7==?+Gii*f Q   sAA A AF) more_bodycxKt|tsJd|jd||dd{y7w)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"s>$&;(;;&ii)4i P   s 0:8:c~K|jdd|i|d{|j|d{y77w)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/sA  d8v8888nnT""" 9"s=9=;==c Ktdw)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 rhandlezAsyncHttpConsumer.handle8s " M  s c Kyw)zh Overrideable place to run disconnect handling. Do not send anything from here. Nr!)r s r disconnectzAsyncHttpConsumer.disconnectBs sc`Kd|vr|jj|d|jdsU |jdj |jd{|j d{t y7'7#|j d{7wxYww)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_requestIs W  II  WV_ -{{;' (kk#((499"5666oo'''. (6'doo'''sL4B.-B$B %B)B.<B=B. BB.B+$B'%B++B.czK|jd{td{t7 7w)zG Let the user do their cleanup and close the consumer. N)r'rrr,s rhttp_disconnectz!AsyncHttpConsumer.http_disconnectWs5oo$&&&n &s;7;9;;) __name__ __module__ __qualname____doc__rrrr"r%r'r.r0r!rrrrs; ,/ $27  #   !rrN)channels.consumerrdbr exceptionsrrr!rrr8s+'%V Vr