ڊj*bdZddlmZmZddlmZddlmZGddeZGdd Z d dgZ y ) zd HTTP/2 stream state management. Each HTTP/2 stream represents a single request/response exchange. )Enumauto)BytesIO)HTTP2StreamErrorcreZdZdZeZeZeZeZeZ eZ eZ y) StreamStatez8HTTP/2 stream states as defined in RFC 7540 Section 5.1.N) __name__ __module__ __qualname____doc__rIDLERESERVED_LOCALRESERVED_REMOTEOPENHALF_CLOSED_LOCALHALF_CLOSED_REMOTECLOSEDZ/var/www/io.vulcan-creative.com/venv/lib/python3.12/site-packages/gunicorn/http2/stream.pyr r s8B 6DVNfO 6D VFrr ceZdZdZdZedZedZedZedZ ddZ ddZ d Z dd Z dd Zd Zdd ZdZddZdZdZdZdZdZdZdZy) HTTP2StreamzRepresents a single HTTP/2 stream. Manages stream state, headers, and body data for a single request/response exchange within an HTTP/2 connection. c@||_||_tj|_g|_t |_d|_d|_ d|_ d|_ |j|_ d|_d|_d|_d|_d|_g|_d|_d|_y)zInitialize an HTTP/2 stream. Args: stream_id: The unique stream identifier (odd for client-initiated) connection: The parent HTTP2ServerConnection FNr) stream_id connectionr rstaterequest_headersr request_bodyrequest_completeresponse_startedresponse_headers_sentresponse_completeinitial_window_size window_sizetrailersresponse_trailerspriority_weightpriority_depends_onpriority_exclusive _body_chunks _body_event_body_complete)selfrrs r__init__zHTTP2Stream.__init__%s#$!%%  "#I %!&%*"!&&99 "& "#$ "'#rc&|jdzdk(S)z;Check if this is a client-initiated stream (odd stream ID).rrr/s ris_client_streamzHTTP2Stream.is_client_streamO~~!Q&&rc&|jdzdk(S)zr,appendr-setr writer@r!r.r/datarCs r receive_datazHTTP2Stream.receive_datas"/ /@A      $ $T *  $$& %   # # %$(D !"&D   $$& rc|js-t|jd|jj||_|j d|_y)zmProcess received trailing headers. Args: trailers: List of (name, value) tuples z!Cannot receive trailers in state TN)r:rrrr>r'r@r!r/r's rreceive_trailerszHTTP2Stream.receive_trailerssQ "3DJJOO3DE  !  ! $rc|js-t|jd|jjd|_d|_|r|jd|_yy)zMark headers as sent. Args: headers: List of (name, value) tuples to send end_stream: True if this completes the response Raises: HTTP2StreamError: If headers cannot be sent in current state zCannot send headers in state TN) r<rrrr>r"r#_half_close_localr$rAs r send_headerszHTTP2Stream.send_headerss`}}"/ /@A  !%%)"   " " $%)D " rc|js-t|jd|jj|r|j d|_yy)zMark data as sent. Args: data: Bytes to send end_stream: True if this completes the response Raises: HTTP2StreamError: If data cannot be sent in current state zCannot send data in state TN)r<rrrr>rPr$rIs r send_datazHTTP2Stream.send_datasP}}",TZZ__,=>    " " $%)D " rc|js-t|jd|jj||_|j d|_y)zMark trailers as sent and close the stream. Args: trailers: List of (name, value) trailer tuples Raises: HTTP2StreamError: If trailers cannot be sent in current state zCannot send trailers in state TN)r<rrrr>r(rPr$rMs r send_trailerszHTTP2Stream.send_trailerssP}}"00AB "*  !%rcJtj|_d|_d|_y)zvReset this stream with RST_STREAM. Args: error_code: HTTP/2 error code (default: CANCEL) TNr rrr$r!)r/ error_codes rresetzHTTP2Stream.resets! !'' !% $rcJtj|_d|_d|_y)zClose this stream normally.TNrWr4s rclosezHTTP2Stream.closes '' !% $rNcd|tdtd||_|||_|||_yy)aUpdate stream priority from PRIORITY frame. Args: weight: Priority weight (1-256), higher = more resources depends_on: Stream ID this stream depends on exclusive: Whether this is an exclusive dependency Nr)maxminr)r*r+)r/weight depends_on exclusives rupdate_priorityzHTTP2Stream.update_prioritysA  #&q#c6*:#;D  !'1D $  &/D # !rc(|jtjk(rtj|_y|jtjk(rtj |_yt |jd|jj)z(Transition to half-closed (local) state.z!Cannot half-close local in state N) rr rrrrrrr>r4s rrPzHTTP2Stream._half_close_local sg ::)) )$66DJ ZZ;99 9$++DJ"3DJJOO3DE rc(|jtjk(rtj|_y|jtjk(rtj |_yt |jd|jj)z)Transition to half-closed (remote) state.z"Cannot half-close remote in state N) rr rrrrrrr>r4s rr@zHTTP2Stream._half_close_remotesg ::)) )$77DJ ZZ;88 8$++DJ"4TZZ__4EF rc6|jjS)zbGet the complete request body. Returns: bytes: The request body data )r getvaluer4s rget_request_bodyzHTTP2Stream.get_request_body%s   ))++rcKddl}|jG|j|_|js |jr|jj  |jr|jj dS|jry|jj|jjd{q7w)zRead next body chunk asynchronously for streaming. Returns: bytes: Next chunk of body data, or None if body is complete. rN) asyncior-Eventr,r.rGpopclearwait)r/rjs rread_body_chunkzHTTP2Stream.read_body_chunk-s     #&}}D   D$7$7  $$&  ((,,Q//""    " " $""'') ) ) *sCCC Cc`i}|jD]\}}|jds|||<|S)zExtract HTTP/2 pseudo-headers from request headers. Returns: dict: Mapping of pseudo-header names to values (e.g., {':method': 'GET', ':path': '/'}) :r startswith)r/pseudor>values rget_pseudo_headerszHTTP2Stream.get_pseudo_headersJs>// %KD%s#$t  % rcr|jDcgc]\}}|jds||fc}}Scc}}w)zGet regular (non-pseudo) headers from request. Returns: list: List of (name, value) tuples for regular headers rqrr)r/r>rus rget_regular_headerszHTTP2Stream.get_regular_headersWs> $33 e??3'5M   s3c d|jd|jjd|jd|jd S)Nz)rrr>r!r$r4s r__repr__zHTTP2Stream.__repr__csOt~~./ZZ__%& 1123!334A 7 r)F))NNN)r r r r r0propertyr5r8r:r<rDrKrNrQrSrUrYr[rcrPr@rhrorvrxr{rrrrrs ($T''''    )0'@% *.*(&$%% 0  ,*:    rrN) r enumrriorerrorsrr r__all__rrrrs:  $ $ K K \ - (r