gHZFddlmZddlZddlZddlZddlZddlZddlZddl Zddl Zddl Zddl Zddl mZddlmZmZmZddlmZmZmZddlmZmZmZddlmZd d lmZejd Z ddZ!Gddej"Z#GddeZ$GddZ%dS)) annotationsN) NetworkStream)ConnectionNotAvailableLocalProtocolErrorRemoteProtocolError)OriginRequestResponse)Lock SemaphoreShieldCancellation)Trace)ConnectionInterfacezhttpcore.http2requestr returnboolc>td|jDS)Nc3|K|]7\}}|dkp|dkV8dS)scontent-lengthtransfer-encodingNlower.0kvs R/var/www/html/mpstechhub/venv/lib/python3.11/site-packages/httpcore/_sync/http2.py z#has_body_headers..s[ Aq  &&K!''))7K*K)anyheaders)rs rhas_body_headersr#s2 O  r ceZdZdZdZdZdS)HTTPConnectionStaterrN)__name__ __module__ __qualname__ACTIVEIDLECLOSEDr rr%r%$s F D FFFr r%c(eZdZdZejdZ d=d>d Zd?dZ d@dZ dAdZ dAdZ dBdZ dAdZdCdZdDdZdEd Z d=dFd"ZdGd%ZdHd&ZdId'ZdJd)Zd@d*ZdKd+ZdLd-ZdMd.ZdMd/ZdMd0ZdMd1ZdNd3ZdNd4ZdOd5Z dPdQd<Z!dS)RHTTP2ConnectionF)validate_inbound_headersNoriginr streamrkeepalive_expiry float | Nonec||_||_||_tj|j|_tj |_ d|_ d|_ t|_t|_t|_t|_d|_d|_d|_i|_d|_d|_d|_dS)N)configrF)_origin_network_stream_keepalive_expiryh2 connection H2ConnectionCONFIG _h2_stater%r+_state _expire_at_request_countr _init_lock _state_lock _read_lock _write_lock_sent_connection_init_used_all_stream_ids_connection_error_events_connection_terminated_read_exception_write_exception)selfr2r3r4s r__init__zHTTP2Connection.__init__.s  %/?334;3GG). (,&&66&&66%*"$)!!&  NR#1526r rr rr c Z||jjs$td|jjd|j|j5|jtjtj fvr)|xj dz c_ d|_ tj|_nt dddn #1swxYwY|j 5|js d|i}tdt ||5|jdi|dddn #1swxYwYnN#t$$rA}t'5|dddn #1swxYwY|d}~wwxYwd|_d|_|jjj}t3||_t7||jz D]}|jdddn #1swxYwY|j |j}g|j|<n=#t>j j!$r&d|_"|xj dzc_ twxYw ||d}tdt ||5|#||dddn #1swxYwYtd t ||5|$||dddn #1swxYwYtd t ||5}|%||\}} || f|_&dddn #1swxYwYtO|| tQ||| d |j)|d S#t$$r}t'5d|i}tdt ||5|*| dddn #1swxYwYdddn #1swxYwYtW|t>j j,r*|j-rt]|j-t_||d}~wwxYw)NzAttempted to send request to z on connection to rrsend_connection_initTr stream_idsend_request_headerssend_request_bodyreceive_response_headersrSsHTTP/2) http_versionnetwork_streamrS)statusr"content extensionsrSresponse_closedr-)0can_handle_requesturlr2 RuntimeErrorr8rDr@r%r*r+rBrArrCrGrlogger_send_connection_init BaseExceptionrclose _max_streamsr?local_settingsmax_concurrent_streamsr _max_streams_semaphorerangeacquireget_next_available_stream_idrJr; exceptionsNoAvailableStreamIDErrorrH_send_request_headers_send_request_body_receive_response return_valuer HTTP2ConnectionByteStreamr9_response_closed isinstance ProtocolErrorrKrr) rNrkwargsexclocal_settings_max_streams_rStracerZr"s rhandle_requestzHTTP2Connection.handle_requestSs&&w{'9::  % 0B%%l%%    / /{29;N;STTT##q(##"&18 ,...  / / / / / / / / / / / / / / /_ : :- :'1F5vwOO==22<>>??????????????? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? #r}:;; ..K-d.IJJJ)---I- sk AB//B36B3G  D %C?3 D ?D D D D  G  EE#E8 EE E E EEA)G  GG0#H:IM!.J M!JM!JM!4K M!KM!K M!:$L* M!*L..M!1L.2.M!! P*+P%9ON8, O8N< <O?N< O P%O P%O AP%%P*Nonec tjdtjjjdtjjjdtjjjdi|j_|jjtjjj =|j |j d| |dS)z The HTTP/2 connection requires some initial setup before we can start using individual request/response streams on it. Trdr0)clientinitial_valuesN) r;settingsSettings SettingCodes ENABLE_PUSHMAX_CONCURRENT_STREAMSMAX_HEADER_LIST_SIZEr?rfENABLE_CONNECT_PROTOCOLinitiate_connectionincrement_flow_control_window_write_outgoing_data)rNrs rrbz%HTTP2Connection._send_connection_inits)+ (<(< (4a (? (=u )= ) ) % N ) K $ <  **,,, 44U;;; !!'*****r rSintcbt| }d|jDd}d|jfd|fd|jjfd|jjfgd|jDz}|j||||jd | | |d S) z@ Send the request headers to a given stream ID. cHg|]\}}|dk| S)hostrrs r z9HTTP2Connection._send_request_headers..s.KKK41aaggii76J6JQ6J6J6Jr rs:methods :authoritys:schemes:pathclg|]1\}}|dv||f2S))rrrrs rrz9HTTP2Connection._send_request_headers..sR   1wwyyWWYYNr ) end_streamrrWN) r#r"methodr_schemetargetr? send_headersrr)rNrrSr authorityr"s rrnz%HTTP2Connection._send_request_headerss*'222 LK7?KKKAN  ( I & + , w{) *         ##Iw:#NNN 44Ui4PPP !!'*****r ct|sdSt|jtjsJ|jD]}|||||||dS)zP Iterate over the request body sending it to a given stream ID. N)r#rtr3typingIterable_send_stream_data_send_end_stream)rNrrSdatas rroz"HTTP2Connection._send_request_bodys{ ((  F'.&/:::::N = =D  " "7It < < < < gy11111r rbytesc|r{|||}tt||}|d|||d}}|j|||||ydSdS)zI Send a single chunk of data in one or more data frames. N)_wait_for_outgoing_flowminlenr? send_datar)rNrrSrmax_flow chunk_sizechunks rrz!HTTP2Connection._send_stream_datas  /33GYGGHSYY11J{ {+T*++->4E N $ $Y 6 6 6  % %g . . .  / / / / /r cd|j|||dS)z` Send an empty data frame on on a given stream ID with the END_STREAM flag set. N)r?rr)rNrrSs rrz HTTP2Connection._send_end_streams4 !!),,, !!'*****r %tuple[int, list[tuple[bytes, bytes]]]cJ |||}t|tjjrn7d}g}|jD]\\}}|dkr%t |dd}0|ds| ||f]||fS)zT Return the response status code and headers for a given stream ID. Ts:statusasciiignore)errors:) _receive_stream_eventrtr;eventsResponseReceivedr"rdecode startswithappend)rNrrSevent status_coder"rrs rrpz!HTTP2Connection._receive_responses  ..w BBE%!;<<    M ' 'DAqJ!!((78("D"DEE \\$'' '1v&&&W%%r typing.Iterator[bytes]c#8K |||}t|tjjrA|j}|j|||||j Vn!t|tjj rdS)z] Iterator that returns the bytes of the response body for a given stream ID. TN) rrtr;r DataReceivedflow_controlled_lengthr?acknowledge_received_datarr StreamEnded)rNrrSramounts r_receive_response_bodyz&HTTP2Connection._receive_response_body0s  ..w BBE%!788 588KKK))'222j    E29#899  r Kh2.events.ResponseReceived | h2.events.DataReceived | h2.events.StreamEndedc6|j|s0||||j|0|j|d}t |t jjrt||S)z Return the next available event for a given stream ID. Will read more data from the network if required. r) rJget_receive_eventspoprtr;r StreamResetr)rNrrSrs rrz%HTTP2Connection._receive_stream_event@s,""9-- 5  ) 4 4 4,""9-- 5 Y'++A.. eRY2 3 3 -%e,, , r int | Nonec |j5|jH|jj}|r&|r$||kr|xjdzc_t t |j||j|s0||}|D]}t|tj j rKtdt|5}||||_dddn #1swxYwYmt|tj jtj jtj jtj jfr4|j|jvr%|j|j|t|tj jr||_dddn #1swxYwY||dS)zp Read some data from the network until we see one or more events for a given stream ID. Nrreceive_remote_settings)rErKlast_stream_idrBrrrJr_read_incoming_datartr;rRemoteSettingsChangedrra_receive_remote_settings_changerqrrrrrSrConnectionTerminatedr)rNrrSrrrrzs rrzHTTP2Connection._receive_eventsOsE_% <% <*6!%!6688L$0++ $**<AAAA   ),%)-&  B                  s5(B."A>=B.> BBBB..B25B2c |j|}|jj}t||}|dkrQ|||j|}|jj}t||}|dkQ|S)a  Returns the maximum allowable outgoing flow for a given stream. If the allowable flow is zero, then waits on the network until WindowUpdated frames have increased the flow rate. https://tools.ietf.org/html/rfc7540#section-6.9 r)r?local_flow_control_windowmax_outbound_frame_sizerr)rNrrS local_flowmax_frame_sizeflows rrz'HTTP2Connection._wait_for_outgoing_flows.BB9MM "nD:~..aii   ) ) )AA)LLJ!^CNz>22D aii  r rc||jkSr)r8rNr2s rr^z"HTTP2Connection.can_handle_requests%%r c|jtjko9|j o1|j o)|jjjtj j jk Sr) r@r%r,rIrHr? state_machinestater;r<ConnectionStaters r is_availablezHTTP2Connection.is_availablesX K.5 5 ** -- ,2=078  r cPtj}|jduo ||jkSr)rrrA)rNrs r has_expiredzHTTP2Connection.has_expireds(nd*DsT_/DDr c,|jtjkSr)r@r%r+rs ris_idlezHTTP2Connection.is_idles{1666r c,|jtjkSr)r@r%r,rs r is_closedzHTTP2Connection.is_closeds{1888r strc\t|j}|d|jjd|jS)Nz , HTTP/2, , Request Count: )rr8r@namerBrs rinfozHTTP2Connection.info sDT\"" 4 44;#3 4 4"1 4 4 r c ~|jj}t|j}d|d|d|jjd|jd S)N) __class__r'rr8r@rrB)rN class_namer2s r__repr__zHTTP2Connection.__repr__sc^, T\"" 6  6 6f 6 6$+*: 6 6"1 6 6 6 r c|Srr-rs r __enter__zHTTP2Connection.__enter__s r exc_typetype[BaseException] | None exc_valueBaseException | None tracebacktypes.TracebackType | Nonec.|dSr)rd)rNrrr s r__exit__zHTTP2Connection.__exit__ s r r)r2r r3rr4r5)rr rr )rr rr|)rr rSrrr|)rr rSrrrrr|)rr rSrrr)rr rSrrr)rr rSrrr)rr rSrrr|)rrrr|)rSrrr|rr|)rr rr)rr rSrrr)r2r rr)rr)rr)rr/)NNN)rrrrr r rr|)"r'r(r)rr;r7H2Configurationr>rOr{rbrnrorrrprrrrrsrdrrrr^rrrrrrrr r-r rr/r/*siN Y & & & F FF *. #7#7#7#7#7JddddL++++B++++> 2 2 2 2 / / / /++++&&&&*     9=.+.+.+.+.+`++++" ! ! ! !%%%%86(&&&&     EEEE77779999         04*.04 r r/c&eZdZdd Zdd Zdd Zd S)rrr<r/rr rSrrr|c>||_||_||_d|_dS)NF) _connection_request _stream_id_closed)rNr<rrSs rrOz"HTTP2ConnectionByteStream.__init__*s%& # r rc#K|j|jd} tdt|j|5|j|j|jD]}|V ddddS#1swxYwYdS#t $rA}t5|dddn #1swxYwY|d}~wwxYw)NrRreceive_response_body) rrrrarrrcrrd)rNrvrrws r__iter__z"HTTP2ConnectionByteStream.__iter__2sp!]II . vNN  !-DD MT_E  E KKKK                      $%%                  I  s^A8.A+ A8+A//A82A/3A88 CB>B1% B>1B5 5B>8B5 9B>>Cc|jsgd|_d|ji}tdt|j|5|j|jddddS#1swxYwYdSdS)NTrSr]rW)rrrrarrrs)rNrvs rrdzHTTP2ConnectionByteStream.closeBs| MDL!4?3F(&$-HH M M 11DO1LLL M M M M M M M M M M M M M M M M M M M Ms!A""A&)A&N)r<r/rr rSrrr|)rrr )r'r(r)rOrrdr-r rrrrr)sV MMMMMMr rr)rr rr)& __future__renumloggingrtypesr h2.configr; h2.connection h2.events h2.exceptions h2.settings_backends.baser _exceptionsrrr_modelsr r r _synchronizationr r r_tracer interfacesr getLoggerrar#IntEnumr%r/rrr-r rr*s""""""  ****** 0/////////BBBBBBBBBB++++++  + , ,$, |||||)|||~MMMMMMMMMMr