jX^dZddlmZddlmZGddZGddZddgZdS) zV HTTP/2 request wrapper. Provides a Request-compatible interface for HTTP/2 streams. )BytesIO)split_request_uricBeZdZdZdZd dZd dZd dZdZdZ d Z dS) HTTP2BodyzBody wrapper for HTTP/2 request data. Provides a file-like interface to the request body, compatible with gunicorn's Body class expectations. cVt||_t||_dS)zfInitialize with body data. Args: data: bytes containing the request body N)r_datalen_len)selfdatas c/var/www/finuniver-perm.ru/html/student/venv/lib/python3.11/site-packages/gunicorn/http2/request.py__init__zHTTP2Body.__init__s" T]] II Ncl||jS|j|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/ <:??$$ $zt$$$rcl||jS|j|S)zRead a line from the body. Args: size: Maximum bytes to read Returns: bytes: A line of data )rreadliners r rzHTTP2Body.readline.s3 <:&&(( (z""4(((rc6|j|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;sz##D)))rc*t|jS)zIterate over lines in the body.)iterrr s r __iter__zHTTP2Body.__iter__FsDJrc|jS)zReturn the content length.)r rs r __len__zHTTP2Body.__len__Js yrc8|jdS)zClose the body stream.N)rclosers r r zHTTP2Body.closeNs r)N) __name__ __module__ __qualname____doc__rrrrrrr rr rrs  % % % % ) ) ) ) * * * *   rrc\eZdZdZdZdZdZdZedZ edZ dZ d S) 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|_|}|dd|_|dd|_|dd}|dd }||_ t|}|j pd|_ |j pd|_ |j pd|_ n%#t$r||_ d|_ d|_ YnwxYw||_g|_|D]3\}} |j|| f4|r2d |jD|_|jd |fg|_|jrd |jD|_|} t-| |_d |_d |_|j|_d|_|j|_|j|_dS)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/c(g|]\}}|dk ||fS)HOSTr%).0nvs r z)HTTP2Request.__init__..s%KKKtq!qF{{QF{{{rr/c@g|]\}}||fSr%)upper)r0namevalues r r3z)HTTP2Request.__init__..s9D%u%rFN)streamcfg peer_addr remote_addrversionget_pseudo_headersgetmethodschemeurirpathqueryfragment ValueError _authorityheadersget_regular_headersappendr5trailersget_request_bodyrbody must_close_expected_100_continue stream_id req_numberproxy_protocol_infopriority_weightpriority_depends_on) r r8r9r:pseudo authorityrBpartsr6r7 body_datas r rzHTTP2Request.__init__[s7 "$ **,,jjE22 jjG44 JJ|R00 zz'3'' %d++E (bDI*DJ!N0bDMM   DIDJDMMM  $ !5577 7 7KD% L  u 5 6 6 6 6  5KKt|KKKDL L   3 4 4 4 ? #)?DM ++-- i((  &+#!*$(  &5#)#=   s"9CC>=C>cd|_dS)z1Force the connection to close after this request.TNrMrs r force_closezHTTP2Request.force_closes rc|jrdSdS)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 TFrYrs r should_closezHTTP2Request.should_closes ? 4urc\|}|jD]\}}||kr|cSdS)zGet a header value by name. Args: name: Header name (case-insensitive) Returns: str: Header value, or None if not found N)r5rG)r r6h_nameh_values r get_headerzHTTP2Request.get_headersBzz||#|  OFG~~trct|d}| t|S#t$rYnwxYwdS)zsGet the Content-Length header value. Returns: int: Content length, or None if not set zCONTENT-LENGTHN)r`intrE)r cls r content_lengthzHTTP2Request.content_lengthsP__- . . > 2ww    ts ( 55c,|dS)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~...rcBd|jd|jd|jjdS)Nz)r?rBr8rOrs r __repr__zHTTP2Request.__repr__sC 2k 2 2I 2 2. 2 2 2 rN) r!r"r#r$rrZr\r`propertyrdrfrir%rr r'r'SsK>K>K>Z        X //X/     rr'N)r$ior gunicorn.utilrrr'__all__r%rr rns  ++++++????????DT T T T T T T T n ; 'r