հjndZddlmZddlmZmZddlmZddlm Z GddZ Gdd eZ d dgZ y ) zV HTTP/2 request wrapper. Provides a Request-compatible interface for HTTP/2 streams. )BytesIO) HeaderPolicy!RFC9110_5_5_INVALID_AND_DANGEROUS) InvalidHeader)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 L/var/www/mission/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 )r readrsizes rrzHTTP2Body.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 )r readliners rrzHTTP2Body.readline3s1 <::&&( (zz""4((rc8|jj|S)zRead all lines from the body. Args: hint: Approximate byte count hint Returns: list: List of lines )r readlines)rhints rrzHTTP2Body.readlines@szz##D))rc,t|jS)zIterate over lines in the body.)iterr rs r__iter__zHTTP2Body.__iter__KsDJJrc|jS)zReturn the content length.)r rs r__len__zHTTP2Body.__len__Os yyrc8|jjy)zClose the body stream.N)r closers rr#zHTTP2Body.closeSs r)N) __name__ __module__ __qualname____doc__rrrrrr!r#rrr r s*  % ) * rr cReZdZdZdZdZdZdZdZe dZ e dZ d Z 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. Fc ||_||_||_||_d|_|j }|j dd|_|jrdnd|_ |j d}|r|jr||_ |j dd}|j d d }||_ t|}|jxsd|_ |jxsd|_|jxsd|_||_g|_d g} t'} |j)\} } |j+D]k\} }| j-} t/j0|r t3| | |j5| || | | | }|Q|j$j7|m|rI|j$Dcgc]\}}|dk7s ||fc}}|_|j$j7d|fg|_|j8r4|j8D cgc]\} }| j-|fc}} |_|j;}t=||_d |_ d |_!|jD|_#d |_$|jJ|_%|jL|_&y #t $r||_ d|_d|_YwxYwcc}}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:methodGEThttpshttpz:schemez :authorityz:path/F)reqNHOST)'streamcfg peer_addr remote_addrversionget_pseudo_headersgetmethodis_sslscheme_peer_is_trusted_proxyurirpathqueryfragment ValueError _authorityheadersset_peer_trusted_for_forwardedget_regular_headersupperrsearchr_apply_header_policyappendtrailersget_request_bodyr body must_close_expected_100_continue stream_id req_numberproxy_protocol_infopriority_weightpriority_depends_on)rr4r5r6pseudoclaimed_scheme authorityr@parts scheme_stateseensecure_scheme_headersforwarder_headersnamevaluekeptnv body_datas rrzHTTP2Request.__init__ds "$ **,jjE2 "%g I. d99;(DKJJ|R0 zz'3' %d+E (bDI*DJ!NN0bDM$  w u  , , . 10!557 &KD%::#Dd33,,e\4%'8D| LL   % & /3||Ktq!qF{QFKDL LL   3 4 ??$*??D%u%DM ++- i(  ',#!**$(  &55#)#=#= } DIDJDM BL s%6A J'= K  K K'K K cd|_y)z1Force the connection to close after this request.TNrPrs 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 TFrfrs 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)rIrE)rr_h_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)rmintrC)rcls rcontent_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)rmrs r content_typezHTTP2Request.content_types~..rcjd|jd|jd|jjdS)Nz)r;r@r4rRrs r__repr__zHTTP2Request.__repr__s?kk]#II;../q 2 rN) r$r%r&r'_policy_expect_continuerrgrirmpropertyrqrsrvr(rrr*r*XsR$c>J    // rr*N) r'iorgunicorn.http.messagerrgunicorn.http.errorsr gunicorn.utilrr r*__all__r(rrr~sB  /+??Dp <p f ; 'r