՟fI]<ddlZddlZddlZddlZddlZddlZddlZddlZddl Zddl Zddl m Z ddl mZmZmZddlmZmZmZddlmZmZmZddlmZdd lmZej:d Zd ed efd Z GddejBZ"GddeZ#GddZ$y)N)AsyncNetworkStream)ConnectionNotAvailableLocalProtocolErrorRemoteProtocolError)OriginRequestResponse) AsyncLockAsyncSemaphoreAsyncShieldCancellation)Trace)AsyncConnectionInterfacezhttpcore.http2requestreturnc:td|jDS)Nc3rK|]/\}}|jdk(xs|jdk(1yw)scontent-lengthtransfer-encodingN)lower).0kvs P/var/www/cvtools/html/venv/lib/python3.12/site-packages/httpcore/_async/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).AsyncHTTP2ConnectionF)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__zAsyncHTTP2Connection.__init__,s  %9I334;;3G).. 26#+$;#+$;%*"$)!!&    #<@<@rrrc K|j|jjs/td|jjd|j|j 4d{|j tjtjfvr2|xjdz c_ d|_ tj|_n tdddd{|j4d{|js d|i}tdt ||4d{|j"di|d{dddd{d|_d|_|j,j.j0}t3||_t7||j*z D]$}|j4j9d{&dddd{|j4j9d{ |j,j;}g|j<|< ||d}tdt ||4d{|jG||d{dddd{td t ||4d{|jI||d{dddd{td t ||4d{}|jK||d{\}} || f|_&dddd{tO tQ||| d |jR|d S77Y#1d{7swYjxYw7]7477#1d{7swY!xYw#t$$r@}t'5|j)d{7ddd|#1swY|xYwd}~wwxYw77#1d{7swYxYw7#t>j@jB$r'd|_"|xjdzc_ twxYw777#1d{7swYxYw777#1d{7swYxYw77{7b#1d{7swYsxYw#t$$r}t'5d|i}tdt ||4d{7|jU| d{7dddd{7n#1d{7swYnxYwdddn #1swYnxYwtW|t>j@jXr,|jZrt]|jZt_||d}~wwxYww)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 aclose _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_async_requestz)AsyncHTTP2Connection.handle_async_requestUs0&&w{{'9'9: / 0B0B/CDll^%  ## / /{{299;N;S;STT##q(#"&188 ,..  / /?? @ @--'1F$%;VWfUCC8d88B6BBBCC.2*%&!NN11HH+/==W.X+9D(>#y)?)#'-g%6"  7 71$9U$-&*&:&:!*  s / / / / / @CBCCCC$02,"kkm++,I,I"@/ @ @ @ @2 4 }}55 +(,D %   1 $ (* * + WV W W W W TS T T T T 7# 7 7 7 7$ (* E%y1 !2FGVLEE//)/DDDEEEEE E E E #r}}::;..-d.I.IJJ)--I- sA%U''L5(U'+A)L; U'L8 U'4M5U'8 OM3 M!M3$M:M;M? M3 M M3A6ON?O U'O!U'9O:U'?)O)RP%RP.P( P.$ R/P+0R Q RQ %Q&Q * R5Q 6RQ#RQ,+Q&,Q,< RQ),R4U'8U';MM M U'M3MM3M0 #M&$M0 +M33 N<< N7N*N N* N7*N4 /N77N<<OU'O O O U'AP""U'%R(P.+R.Q4P7 5Q< RQ  R Q Q Q  R&Q,)R,Q?2Q5 3Q?:R U$ UT0R3 1T5S# S S# TST#S5 )S,*S5 1T8 UT AUU$$U'c VKtjjdtjjjdtjjj dtjjj di|j_|jjtjjj=|jj|jjd|j|d{y7w)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*AsyncHTTP2Connection._send_connection_inits)+ (<(< ((44a ((?? ((==u )= ) % NN ) ) KK $ $ < <  **, 44U;''000sDD)!D'"D)rNcXKt| }|jDcgc]\}}|jdk(s|c}}d}d|jfd|fd|jj fd|jj fg|jDcgc])\}}|jdvr|j|f+c}}z}|jj||||jjd | |j|d {y cc}}wcc}}w7w) 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*AsyncHTTP2Connection._send_request_headerss*'22 $+??K41aaggi76JQKAN  ( I & ++ , w{{)) *    1wwyWWYN   ##Iw:#N 44Ui4P''000'L  1s.D*DDAD*.D"AD*D(D*cKt|syt|jtjsJ|j23d{}|j |||d{%7 76|j ||d{7yw)zP Iterate over the request body sending it to a given stream ID. N)rror/typing AsyncIterable_send_stream_data_send_end_stream)rIrrNdatas rrjz'AsyncHTTP2Connection._send_request_bodys ( '..&*>*>???!.. C C$(()TB B B C B)##GY777sG?BA*A&A* B A(!B&A*(B*BBBrcK|rr|j||d{}tt||}|d|||d}}|jj |||j |d{|rqyy7]7 w)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&AsyncHTTP2Connection._send_stream_datas} !99'9MMHSY1J{ +T*+->4E NN $ $Y 6++G4 4 4 M 5s(A<A8AA<.A:/A<6A<:A<cxK|jj||j|d{y7w)z` Send an empty data frame on on a given stream ID with the END_STREAM flag set. N)r:rr)rIrrNs rrz%AsyncHTTP2Connection._send_end_streams. !!),''000s 0:8:cVK |j||d{}t|tjjrn@d}g}|j D]L\}}|dk(rt |jdd}(|jdr:|j||fN||fS7w)zT Return the response status code and headers for a given stream ID. Ns:statusasciiignore)errors:) _receive_stream_eventror6eventsResponseReceivedrintdecode startswithappend)rIrrNevent status_coderrrs rrkz&AsyncHTTP2Connection._receive_responses 44WiHHE%!;!;<  MM 'DAqJ!!((78("DE \\$'1v&  ' W%%IsB)B'A3B)B)c~K |j||d{}t|tjjrQ|j }|j j|||j|d{|jn%t|tjjry77<w)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+AsyncHTTP2Connection._receive_response_body2s 44WiHHE%!7!785588K//888jj E299#8#89H9s"B=B9A$B=>B;?;B=;B=cNK|jj|s6|j||d{|jj|s6|j|jd}t |t j jr t||S7ow)z Return the next available event for a given stream ID. Will read more data from the network if required. Nr) rEget_receive_eventspopror6r StreamResetr)rIrrNrs rrz*AsyncHTTP2Connection._receive_stream_eventBs,,""9-&&w : : :,,""9- Y'++A. eRYY22 3%e, , ;s1B%B#B%AB%c K|j4d{|jS|jj}|r&|r$||kDr|xjdzc_t t |j||j j|sq|j|d{}|D]R}t|tjjrKtdt|4d{}|j|d{||_dddd{st|tjj"tjj$tjj&tjj(frC|j*|j vs|j |j*j-|&t|tjj.sL||_Udddd{|j1|d{y777I737#1d{7swYxYw7C#1d{7swYSxYw7Aw)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 rrz$AsyncHTTP2Connection._receive_eventsSs??% <% <**6!%!D!D>D!D>,D)2D#3BD) D% D) D>D'D>!D>#D)%D)'D>)D;/D2 0D;7D>cK|jjtj|_|j j d{y7wr)r:close_connectionr!r(r;r4r_rIs rr_zAsyncHTTP2Connection.acloses= ''))00 ""))+++sA AAAcK|jjdi}|jdd}|j |j |jj |j |d{}|dk(r t d |jj|}|S72#t$r}||_d|_|d}~wwxYww)NtimeoutreadrzServer disconnectedT) rWrrGr4rREAD_NUM_BYTESr ExceptionrDr: receive_data)rIrtimeoutsrrrrrs rrz(AsyncHTTP2Connection._read_incoming_datas%%)))R8,,vt,    +&& & --2243F3FPPDs{)*?@@04~~/J/J4/P %Q $'D %)D "I s<AC  )B(3B&4B(C &B(( C1CCC cK|jjdi}|jdd}|j4d{|jj }|j |j  |j j||d{dddd{y7l7#t$r}||_d|_ |d}~wwxYw7*#1d{7swYyxYww)NrwriteT) rWrrAr: data_to_sendrHr4rrrD)rIrrrrrrs rrz)AsyncHTTP2Connection._write_outgoing_datas%%)))R8,,w-##  >>668L$$0+++ **00wGGG   H ),%)-&      sw?C*B.C*3C9B2B0B2 C*(C)C*0B22 C;C  CCC*C'C C'#C*cNK|jj|}|jj}t||}|dk(r\|j |d{|jj|}|jj}t||}|dk(r\|S7Iw)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 rN)r:local_flow_control_windowmax_outbound_frame_sizerr)rIrrN local_flowmax_frame_sizeflows rrz,AsyncHTTP2Connection._wait_for_outgoing_flows..BB9M "nnDD:~.ai&&w/ / /AA)LJ!^^CCNz>2D ai  0sAB%B#AB%!B%c ||jk(Sr)r3rIr.s rrYz'AsyncHTTP2Connection.can_handle_requests%%rc|jtjk7xrd|j xrU|j xrF|j j jtjjjk( Sr) r;r!r(rDrCr: state_machinestater6r7ConnectionStaters r is_availablez!AsyncHTTP2Connection.is_availabless KK.55 5 *** --- ,,22==00778  rchtj}|jduxr||jkDSr)rrr<)rIrs r has_expiredz AsyncHTTP2Connection.has_expireds+nnd*DsT__/DDrc<|jtjk(Sr)r;r!r'rs ris_idlezAsyncHTTP2Connection.is_idle s{{16666rc<|jtjk(Sr)r;r!r(rs r is_closedzAsyncHTTP2Connection.is_closeds{{18888rc|t|j}|d|jjd|jS)Nz , HTTP/2, , Request Count: )strr3r;namer=rs rinfozAsyncHTTP2Connection.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__zAsyncHTTP2Connection.__repr__sZ^^,, T\\" |2fZr$++*:*:);<"112" 6 rcK|Swrr)rs r __aenter__zAsyncHTTP2Connection.__aenter__#s  sexc_type exc_value tracebackc@K|jd{y7wr)r_)rIrrrs r __aexit__zAsyncHTTP2Connection.__aexit__&s kkms rrN)rr+)NNN):r#r$r%rr6r2H2Configurationr9rrrOptionalfloatrJr r rvr]rrirjbytesrrTupleListrk AsyncIteratorrUnionrrrrrrEventrrnr_rrrboolrYrrrrrrrrTyper^types TracebackTyperr)rrr+r+(s N YY & & & FF 48 'A'A#'A!//%0 'ARd'dhdL171t1B171s1t1> 8 8C 8D 8 5 5+. 56; 5  51g1#1$1&&+.& c6;;v||E5L'ABB C&*+.   e $ +.  ""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!& # rcK|j|jd} tdt|j|4d{|jj |j|j23d{}|7D7 6dddd{7y#1d{7swYyxYw#t $r@}t5|jd{7ddd|#1swY|xYwd}~wwxYww)NrMreceive_response_body) r r rr\r rr^r r_)rIrqrrrs r __aiter__z#HTTP2ConnectionByteStream.__aiter__8s!]]I 4fdmmVT  #'#3#3#J#J MMT__$K$  % K   $      )* $kkm## $I $I  sC: B.BB.2B3B7B8B;BB.BB B.BB.C:B+B" B+'B.*C:+B.. C77 C2C%CC% C2%C/ *C22C77C:cLK|jsyd|_d|ji}tdt|j|4d{|j j |jd{dddd{yy7D77 #1d{7swYyxYww)NTrNrXrR)r r rr\r r rn)rIrqs rr_z HTTP2ConnectionByteStream.acloseHs||DL!4??3F. vN S S&&77$//7RRR S S S SR S S S SsZAB$B B$*B2B 3B7 B$B B$ B B$B!B B!B$r) r#r$r%r+r rrJrrrrr_r)rrrmrm/sD.9@MP !5!5e!< Srrm)%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/QQ0   + ,g$$,, D3DNSSr