՟f1[<ddlZddlZddlZddlZddlZddlZddlZddlZddl Zddl Zddl m Z ddl mZmZmZddlmZmZmZddlmZmZmZddlmZdd lmZej:d Zd ed efd Z GddejBZ"GddeZ#GddZ$y)N) NetworkStream)ConnectionNotAvailableLocalProtocolErrorRemoteProtocolError)OriginRequestResponse)Lock SemaphoreShieldCancellation)Trace)ConnectionInterfacezhttpcore.http2requestreturnc:td|jDS)Nc3rK|]/\}}|jdk(xs|jdk(1yw)scontent-lengthtransfer-encodingN)lower).0kvs O/var/www/cvtools/html/venv/lib/python3.12/site-packages/httpcore/_sync/http2.py z#has_body_headers..s< Aq  &&K!'')7K*KKs57)anyheaders)rs rhas_body_headersrs OO ceZdZdZdZdZy)HTTPConnectionStaterrN)__name__ __module__ __qualname__ACTIVEIDLECLOSEDrrr!r!"s F D Frr!c &eZdZdZej j dZ d*dede de je fdZ d ed efd Zd ed dfd Zd ed ed dfdZd ed ed dfdZd ed eded dfdZd ed ed dfdZd ed ed e j0ee j2e j0eefffdZd ed ed e j6efdZd ed ed e j:ej<j>ej<j@ej<jBffdZ" d*d ed e jed dfdZ#dej<jHd dfdZ%d ed dfdZ&d+dZ'd ed e j2ej<jHfdZ(d ed dfdZ)d ed ed efdZ*ded e+fdZ,d e+fdZ-d e+fd Z.d e+fd!Z/d e+fd"Z0d e1fd#Z2d e1fd$Z3d,d%Z4 d-d&e je jje6d'e je6d(e je7jpd dfd)Z9y).HTTP2ConnectionF)validate_inbound_headersNoriginstreamkeepalive_expiryc||_||_||_tjj |j |_tj|_ d|_ d|_ t|_t|_t|_t|_d|_d|_d|_i|_d|_d|_d|_y)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)selfr.r/r0s r__init__zHTTP2Connection.__init__,s  %9I334;;3G).. 26&6&6%*"$)!!&    #<@<@rrrc x|j|jjs/td|jjd|j|j 5|j tjtjfvr2|xjdz c_ d|_ tj|_n t ddd|j5|js d|i}tdt ||5|j"di|dddd|_d|_|j,j.j0}t3||_t7||j*z D]}|j4j9ddd|j4j9 |j,j;}g|j<|< ||d}tdt ||5|jG||dddtd t ||5|jI||dddtd t ||5}|jK||\}} || f|_&dddtO tQ||| d |jR|d S#1swYxYw#1swYxYw#t$$r7}t'5|j)ddd|#1swY|xYwd}~wwxYw#1swYpxYw#t>j@jB$r'd|_"|xjdzc_ twxYw#1swYLxYw#1swY+xYw#1swYxYw#t$$r}t'5d|i}tdt ||5|jU| dddn #1swYnxYwdddn #1swYnxYwtW|t>j@jXr,|jZrt]|jZt_||d}~wwxYw)NzAttempted to send request to z on connection to rrsend_connection_initTr stream_idsend_request_headerssend_request_bodyreceive_response_headersrNsHTTP/2) http_versionnetwork_streamrN)statusrcontent extensionsrNresponse_closedr))0can_handle_requesturlr. RuntimeErrorr3r?r;r!r&r'r=r<rr>rBrlogger_send_connection_init BaseExceptionr close _max_streamsr:local_settingsmax_concurrent_streamsr _max_streams_semaphorerangeacquireget_next_available_stream_idrEr6 exceptionsNoAvailableStreamIDErrorrC_send_request_headers_send_request_body_receive_response return_valuer HTTP2ConnectionByteStreamr4_response_closed isinstance ProtocolErrorrFrr) rIrkwargsexclocal_settings_max_streams_rNtracerUrs rhandle_requestzHTTP2Connection.handle_requestUs &&w{{'9'9: / 0B0B/CDll^%     /{{299;N;S;STT##q(#"&188 ,..  /__ :--'1F5vwO=222??? ? ? ? #r}}::;..-d.I.IJJ)--I- s !A)J$ L-J>J1J>A5L6)L M;7M M;%M"9M; M/30M;$J.1J; 6J>> K> K9K," K9,K6 1K99K>>LL AMMM;"M,'M;/M84M;; P9 P4O%O8 OO O P4O AP44P9c :tjjdtjjjdtjjj dtjjj di|j_|jjtjjj=|jj|jjd|j|y)z The HTTP/2 connection requires some initial setup before we can start using individual request/response streams on it. Trdr,)clientinitial_valuesN) r6settingsSettings SettingCodes ENABLE_PUSHMAX_CONCURRENT_STREAMSMAX_HEADER_LIST_SIZEr:raENABLE_CONNECT_PROTOCOLinitiate_connectionincrement_flow_control_window_write_outgoing_data)rIrs rr]z%HTTP2Connection._send_connection_inits)+ (<(< ((44a ((?? ((==u )= ) % NN ) ) KK $ $ < <  **, 44U; !!'*rrNc<t| }|jDcgc]\}}|jdk(s|c}}d}d|jfd|fd|jj fd|jj fg|jDcgc])\}}|jdvr|j|f+c}}z}|jj||||jjd | |j|y cc}}wcc}}w) z@ Send the request headers to a given stream ID. hostrs:methods :authoritys:schemes:path)rr) end_streamr{rRN) rrrmethodrZschemetargetr: send_headersrr)rIrrNrrr authorityrs rriz%HTTP2Connection._send_request_headerss *'22 $+??K41aaggi76JQKAN  ( I & ++ , w{{)) *    1wwyWWYN   ##Iw:#N 44Ui4P !!'*'L sDD.Dct|syt|jtjsJ|jD]}|j ||||j ||y)zP Iterate over the request body sending it to a given stream ID. N)rror/typingIterable_send_stream_data_send_end_stream)rIrrNdatas rrjz"HTTP2Connection._send_request_bodys\ ( '..&//:::NN =D  " "7It < = gy1rrc|rb|j||}tt||}|d|||d}}|jj |||j ||rayy)zI Send a single chunk of data in one or more data frames. N)_wait_for_outgoing_flowminlenr: send_datar)rIrrNrmax_flow chunk_sizechunks rrz!HTTP2Connection._send_stream_datasg 33GYGHSY1J{ +T*+->4E NN $ $Y 6  % %g . rc\|jj||j|y)z` Send an empty data frame on on a given stream ID with the END_STREAM flag set. N)r:rr)rIrrNs rrz HTTP2Connection._send_end_streams$ !!), !!'*rc: |j||}t|tjjrn8d}g}|j D]L\}}|dk(rt |jdd}(|jdr:|j||fN||fS)zT Return the response status code and headers for a given stream ID. s:statusasciiignore)errors:) _receive_stream_eventror6eventsResponseReceivedrintdecode startswithappend)rIrrNevent status_coderrrs rrkz!HTTP2Connection._receive_responses ..w BE%!;!;<  MM 'DAqJ!!((78("DE \\$'1v&  ' W%%rc#TK |j||}t|tjjrH|j }|j j|||j||jn%t|tjjryw)z] Iterator that returns the bytes of the response body for a given stream ID. N) rror6r DataReceivedflow_controlled_lengthr:acknowledge_received_datarr StreamEnded)rIrrNramounts r_receive_response_bodyz&HTTP2Connection._receive_response_body2s ..w BE%!7!785588K))'2jj E299#8#89sB&B(c2|jj|s.|j|||jj|s.|j|jd}t |t j jr t||S)z Return the next available event for a given stream ID. Will read more data from the network if required. r) rEget_receive_eventspopror6r StreamResetr)rIrrNrs rrz%HTTP2Connection._receive_stream_eventBsw,,""9-  ) 4,,""9- Y'++A. eRYY22 3%e, , rc |j5|jS|jj}|r&|r$||kDr|xjdzc_t t |j||j j|sQ|j|}|D]:}t|tjjr3tdt|5}|j|||_ddd[t|tjj"tjj$tjj&tjj(frC|j*|j vs|j |j*j-|t|tjj.s4||_=ddd|j1|y#1swYbxYw#1swY(xYw)zp Read some data from the network until we see one or more events for a given stream ID. Nrreceive_remote_settings)r@rFlast_stream_idr=rrrEr_read_incoming_dataror6rRemoteSettingsChangedrr\_receive_remote_settings_changerlrrrrrNrConnectionTerminatedr)rIrrNrrrrus rrzHTTP2Connection._receive_eventsSs__% <**6!%!c|jjtj|_|j j yr)r:close_connectionr!r(r;r4r_rIs rr_zHTTP2Connection.closes3 ''))00  ""$rcz|jjdi}|jdd}|j |j |jj |j |}|dk(r t d |jj|}|S#t$r}||_d|_|d}~wwxYw)NtimeoutreadrzServer disconnectedT) rWrrGr4rREAD_NUM_BYTESr ExceptionrDr: receive_data)rIrtimeoutsrrrrrs rrz#HTTP2Connection._read_incoming_datas%%)))R8,,vt,    +&& & '',,T-@-@'JDs{)*?@@04~~/J/J4/P  $'D %)D "I s6B B:%B55B:c|jjdi}|jdd}|j5|jj }|j |j  |j j|| dddy#t$r}||_d|_ |d}~wwxYw#1swYyxYw)NrwriteT) rWrrAr: data_to_sendrHr4rrrD)rIrrrrrrs rrz$HTTP2Connection._write_outgoing_datas%%)))R8,,w-    >>668L$$0+++ $$**<A   ),%)-&    s)3B6/B B3B..B33B66B?c2|jj|}|jj}t||}|dk(rT|j ||jj|}|jj}t||}|dk(rT|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)rIrrN local_flowmax_frame_sizeflows rrz'HTTP2Connection._wait_for_outgoing_flows..BB9M "nnDD:~.ai   )AA)LJ!^^CCNz>2D ai  rc ||jk(Sr)r3rIr.s rrYz"HTTP2Connection.can_handle_requests%%rc|jtjk7xrd|j xrU|j xrF|j j jtjjjk( Sr) r;r!r(rDrCr: state_machinestater6r7ConnectionStaters r is_availablezHTTP2Connection.is_availabless KK.55 5 *** --- ,,22==00778  rchtj}|jduxr||jkDSr)rrr<)rIrs r has_expiredzHTTP2Connection.has_expireds+nnd*DsT__/DDrc<|jtjk(Sr)r;r!r'rs ris_idlezHTTP2Connection.is_idle s{{16666rc<|jtjk(Sr)r;r!r(rs r is_closedzHTTP2Connection.is_closeds{{18888rc|t|j}|d|jjd|jS)Nz , HTTP/2, , Request Count: )strr3r;namer=rs rinfozHTTP2Connection.infosAT\\"j 4;;#3#3"45"112 4 rc |jj}t|j}d|d|d|jj d|j d S)N) __class__r#rr3r;rr=)rI class_namer.s r__repr__zHTTP2Connection.__repr__sZ^^,, T\\" |2fZr$++*:*:);<"112" 6 rc|Srr)rs r __enter__zHTTP2Connection.__enter__#s rexc_type exc_value tracebackc$|jyr)r_)rIrrrs r__exit__zHTTP2Connection.__exit__&s rrrN)rr+)NNN):r#r$r%rr6r2H2Configurationr9rrrOptionalfloatrJr r rvr]rrirjbytesrrTupleListrkIteratorrUnionrrrrrrEventrrnr_rrrboolrYrrrrrrrrTyper^types TracebackTyperr)rrr+r+(sN YY & & & FF 48 'A'A'A!//%0 'ARdgd(dL+W++B+W+++> 2' 2c 2d 2 / /+. /6; /  /++C+D+&&+.& c6;;v||E5L'ABB C&*+.   +.  ""BII$:$:BII //&++m"<=??=1??5#6#67   rr+cReZdZdedededdfdZdeje fdZ d dZ y) rmr7rrNrNc<||_||_||_d|_y)NF) _connection_request _stream_id_closed)rIr7rrNs rrJz"HTTP2ConnectionByteStream.__init__0s!& # rc#K|j|jd} tdt|j|5|jj |j|jD]}| dddy#1swYyxYw#t $r7}t5|jddd|#1swY|xYwd}~wwxYww)NrMreceive_response_body) r r rr\r rr^r r_)rIrqrrrs r__iter__z"HTTP2ConnectionByteStream.__iter__8s!]]I . vN !--DD MMT__E E K     $%   I I  scC B ;A>5B =C >BB C B C  CB8. C8C =CC  C c|jsad|_d|ji}tdt|j|5|j j |jdddyy#1swYyxYw)NTrNrXrR)r r rr\r r rn)rIrqs rr_zHTTP2ConnectionByteStream.closeHsp||DL!4??3F(&$--H M  11DOO1L M M M Ms 'A//A8r) r#r$r%r+r rrJrrrrr_r)rrrmrm/sB)4;HK &//%0 Mrrm)%enumloggingrrr h2.configr6 h2.connection h2.events h2.exceptions h2.settings_backends.baser _exceptionsrrr_modelsrr r _synchronizationr r r _tracer interfacesr getLoggerr\rrIntEnumr!r+rmr)rrr!s  * 0/BB+   + ,g$$,, D)DNMMr