AҐiXPdZddlmZddlmZGddZGddZddgZy) zV HTTP/2 request wrapper. Provides a Request-compatible interface for HTTP/2 streams. )BytesIO)split_request_uric@eZdZdZdZd dZd dZd dZdZdZ d Z y) HTTP2BodyzBody wrapper for HTTP/2 request data. Provides a file-like interface to the request body, compatible with gunicorn's Body class expectations. cDt||_t||_y)zfInitialize with body data. Args: data: bytes containing the request body N)r_datalen_len)selfdatas O/var/www/descvideos/venv/lib/python3.12/site-packages/gunicorn/http2/request.py__init__zHTTP2Body.__init__s T] I Ncp||jjS|jj|S)zRead data from the body. Args: size: Number of bytes to read, or None for all remaining Returns: bytes: The requested data )rreadr sizes r rzHTTP2Body.read!s- <::??$ $zzt$$rcp||jjS|jj|S)zRead a line from the body. Args: size: Maximum bytes to read Returns: bytes: A line of data )rreadliners r rzHTTP2Body.readline.s1 <::&&( (zz""4((rc8|jj|S)zRead all lines from the body. Args: hint: Approximate byte count hint Returns: list: List of lines )r readlines)r hints r rzHTTP2Body.readlines;szz##D))rc,t|jS)zIterate over lines in the body.)iterrr s r __iter__zHTTP2Body.__iter__FsDJJrc|jS)zReturn the content length.)r rs r __len__zHTTP2Body.__len__Js yyrc8|jjy)zClose the body stream.N)rclosers r r zHTTP2Body.closeNs r)N) __name__ __module__ __qualname____doc__rrrrrrr rr rrs*  % ) * rrcNeZdZdZdZdZdZdZedZ edZ dZ y ) HTTP2RequestzHTTP/2 request wrapper compatible with gunicorn Request interface. Wraps an HTTP2Stream to provide the same interface as the HTTP/1.x Request class, allowing workers to handle HTTP/2 requests using existing code paths. c||_||_||_||_d|_|j }|j dd|_|j dd|_|j dd}|j dd }||_ t|}|jxsd|_ |jxsd|_ |jxsd|_ ||_g|_|j#D]0\}} |j j%|j'| f2|rI|j D cgc]\} } | d k7s | | fc} } |_|j j%d |fg|_|j(r4|j(D cgc]\}} |j'| fc} }|_|j+} t-| |_d |_d |_|j4|_d |_|j:|_|j<|_y #t$r||_ d|_ d|_ YmwxYwcc} } wcc} }w) zInitialize from an HTTP/2 stream. Args: stream: HTTP2Stream instance with received headers/body cfg: Gunicorn configuration object peer_addr: Client address tuple (host, port) )rz:methodGETz:schemehttpsz :authorityz:path/HOSTFN)streamcfg peer_addr remote_addrversionget_pseudo_headersgetmethodschemeurirpathqueryfragment ValueError _authorityheadersget_regular_headersappenduppertrailersget_request_bodyrbody must_close_expected_100_continue stream_id req_numberproxy_protocol_infopriority_weightpriority_depends_on) r r/r0r1pseudo authorityr9partsnamevaluenv body_datas r rzHTTP2Request.__init__[s% "$ **,jjE2 jjG4 JJ|R0 zz'3' %d+E (bDI*DJ!NN0bDM$ !557 7KD% LL  u 5 6 7 /3||Ktq!qF{QFKDL LL   3 4 ??$*??D%u%DM ++- i(  &+#!**$(  &55#)#=#= [ DIDJDM $L s%A H$: I I I$IIcd|_y)z1Force the connection to close after this request.TNrErs r force_closezHTTP2Request.force_closes rc|jryy)zCheck if connection should close after this request. HTTP/2 connections are persistent by design, but we may still need to close if explicitly requested. Returns: bool: True if connection should close TFrUrs r should_closezHTTP2Request.should_closes ??rc^|j}|jD]\}}||k(s |cSy)zGet a header value by name. Args: name: Header name (case-insensitive) Returns: str: Header value, or None if not found N)rAr>)r rOh_nameh_values r get_headerzHTTP2Request.get_headers7zz|#|| OFG~ rc`|jd}| t|Sy#t$rYywxYw)zsGet the Content-Length header value. Returns: int: Content length, or None if not set zCONTENT-LENGTHN)r\intr<)r cls r content_lengthzHTTP2Request.content_lengthsB__- . > 2w  s ! --c$|jdS)zoGet the Content-Type header value. Returns: str: Content type, or None if not set z CONTENT-TYPE)r\rs r content_typezHTTP2Request.content_types~..rcjd|jd|jd|jjdS)Nz)r6r9r/rGrs r __repr__zHTTP2Request.__repr__s?kk]#II;../q 2 rN) r!r"r#r$rrVrXr\propertyr`rbrer%rr r'r'SsJK>Z    // rr'N)r$ior gunicorn.utilrrr'__all__r%rr rjs6  +??DT T n ; 'r