j]^ddlmZddlZddlZddlZddlZddlZddlmZddl Z ddl Z ddl Z ddl Z ddlZ ddlmZddlmZmZmZddlmZmZmZddlmZmZmZdd lmZdd lm Z d d l!m"Z"ej#d Z$ddZ%Gddej&Z'Gdde"Z(GddZ)dS)) annotationsN) Generator) NetworkStream)ConnectionNotAvailableLocalProtocolErrorRemoteProtocolError)OriginRequestResponse)Lock SemaphoreShieldCancellation)Trace) safe_iterate)ConnectionInterfacezhttpcore2.http2requestr returnboolc>td|jDS)Nc3|K|]7\}}|dkp|dkV8dS)scontent-lengthtransfer-encodingNlower).0k_vs CC:\Projects\DSCons\.venv\Lib\site-packages\httpcore2\_sync\http2.py z#has_body_headers..sJppW\WXZ\qwwyy--R>R1Rpppppp)anyheaders)rs rhas_body_headersr$s# pp`g`oppp p ppr!ceZdZdZdZdZdS)HTTPConnectionStaterrN)__name__ __module__ __qualname__ACTIVEIDLECLOSEDr!rr&r&s F D FFFr!r&c6eZdZdZejdZ d?d@d ZdAdZ dBdZ dCdZ dCdZ dDdZ dCdZdEdZdFdZdGd Zd?dHd"ZdId%ZdJd&ZdKd'ZdLd)ZdBd*ZdMd+ZdNd-ZdOd.ZdOd/ZdOd0ZdOd1ZdOd2ZdOd3ZdPd5Z dPd6Z!dQd7Z" dRdSd>Z#dS)THTTP2ConnectionF)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)selfr3r4r5s r__init__zHTTP2Connection.__init__)s  %/?334;3GG). (,&&66&&66%*"$)!!&  NR#1526r!rr rr c ||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|<nV#t>j j!$r?d|_"|xj dzc_ |j#twxYw ||d}tdt ||5|$||dddn #1swxYwYtd t ||5|%||dddn #1swxYwYtd t ||5}|&||\} } | | f|_'dddn #1swxYwYtQ| | tS||| d |j*|d S#t$$r}t'5d|i}tdt ||5|+| dddn #1swxYwYdddn #1swxYwYtY|t>j j-r*|j.rt_|j.ta||d}~wwxYw)NzAttempted to send request to z on connection to rrsend_connection_initTr stream_idsend_request_headerssend_request_bodyreceive_response_headersrTsHTTP/2) http_versionnetwork_streamrT)statusr#content extensionsrTresponse_closedr.)1can_handle_requesturlr3 RuntimeErrorr9rErAr&r+r,rCrBrrDrHrlogger_send_connection_init BaseExceptionrclose _max_streamsr@local_settingsmax_concurrent_streamsr_max_streams_semaphorerangeacquireget_next_available_stream_idrKr< exceptionsNoAvailableStreamIDErrorrIrelease_send_request_headers_send_request_body_receive_response return_valuer HTTP2ConnectionByteStreamr:_response_closed isinstance ProtocolErrorrLr r) rOr sci_kwargsexclocal_settings_max_streams_rTkwargstracer[r#s rhandle_requestzHTTP2Connection.handle_requestKs &&w{'9:: u sw{?Qsseieqsstt t   / /{29;N;STTT##q(##"&18 ,...  / / / / / / / / / / / / / / /_ : :- :"+W!5J5vw SSAA22@@Z@@@AAAAAAAAAAAAAAA$+--%% %%%%%%%%%%%%%%%I .2*%&!-1^-J-a*.78R.S.S+9D>>??????????????? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? #r}:;; ..K-d.IJJJ)---I- sl AB//B36B3G  D %C?3 D ?D D D D  G  EE#E8 EE E E EEA)G  GG0#HAI'+M:J+ M:+J//M:2J/3M: K1% M:1K55M:8K59M:$M7 M:MM: M .M:: QP>O(.O O(O O(O O( P>(O, ,P>/O, 0AP>>QNonec 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. Trdr1)clientinitial_valuesN) r<settingsSettings SettingCodes ENABLE_PUSHMAX_CONCURRENT_STREAMSMAX_HEADER_LIST_SIZEr@rgENABLE_CONNECT_PROTOCOLinitiate_connectionincrement_flow_control_window_write_outgoing_data)rOrs rrcz%HTTP2Connection._send_connection_inits)+ (<(< (4a (? (=u )= ) ) % N )"+*B*Z [ **,,, 44U;;; !!'*****r!rTintcbt| }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)hostrrrvs r z9HTTP2Connection._send_request_headers..s.KKK41aaggii76J6JQ6J6J6Jr!rs:methods :authoritys:schemes:pathclg|]1\}}|dv||f2S))rrrrs rrz9HTTP2Connection._send_request_headers..sR   1wwyyWWYYNr!) end_streamrrXN) r$r#methodr`schemetargetr@ send_headersrr)rOrrTr authorityr#s rrpz%HTTP2Connection._send_request_headerss*'222 LK7?KKKAN  ( I & + , w{) *         ##Iw:#NNN 44Ui4PPP !!'*****r!c(t|sdSt|jtjsJt |j5}|D]}|||| dddn #1swxYwY|||dS)zP Iterate over the request body sending it to a given stream ID. N)r$rvr4typingIterabler_send_stream_data_send_end_stream)rOrrTiteratorchunks rrqz"HTTP2Connection._send_request_bodys ((  F'.&/::::: '. ) ) BX! B B&&w 5AAAA B B B B B B B B B B B B B B B B gy11111sA11A58A5databytesc$d}|t|krz|||}||||z}|t|z }|j|||||t|kxdSdS)zI Send a single chunk of data in one or more data frames. rN)len_wait_for_outgoing_flowr@ send_datar)rOrrTrpositionmax_flowrs rrz!HTTP2Connection._send_stream_datasT""33GYGGHHx$778E E "H N $ $Y 6 6 6  % %g . . . T""""""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)rOrrTs rrz HTTP2Connection._send_end_streams4 !!),,, !!'*****r!%tuple[int, list[tuple[bytes, bytes]]]c\ |||}t|tjjrn7d}g}|jJ|jD]\\}}|dkr%t |dd}0|ds| ||f]||fS) zT Return the response status code and headers for a given stream ID. TNs:statusasciiignore)errors:) _receive_stream_eventrvr<eventsResponseReceivedr#rdecode startswithappend)rOrrTevent status_coder#rrs rrrz!HTTP2Connection._receive_response s ..w BBE%!;<<    -/}(((M ' 'DAqJ!!((78("D"DEE \\$'' '1v&&&W%%r!Generator[bytes]c#\K |||}t|tjjrS|jJ|jJ|j}|j||| ||jVn!t|tjj rdS)z] Iterator that returns the bytes of the response body for a given stream ID. TN) rrvr<r DataReceivedflow_controlled_lengthrr@acknowledge_received_datar StreamEnded)rOrrTramounts r_receive_response_bodyz&HTTP2Connection._receive_response_bodys ..w BBE%!788 3???z---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) rKget_receive_eventspoprvr<r StreamResetr )rOrrTrs 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)rFrLlast_stream_idrCrr rKr_read_incoming_datarvr<rRemoteSettingsChangedrrb_receive_remote_settings_changersrrrrrTrConnectionTerminatedr)rOrrTrrrr}s rrzHTTP2Connection._receive_events=sA _# <# <*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)rOrrT local_flowmax_frame_sizeflows rrz'HTTP2Connection._wait_for_outgoing_flows.BB9MM "nD:~..aii   ) ) )AA)LLJ!^CNz>22D aii  r!rc||jkSr)r9rOr3s rr_z"HTTP2Connection.can_handle_requests%%r!c,| Sr) is_closedrs r is_connectedzHTTP2Connection.is_connecteds>>####r!c|jtjko9|j o1|j o)|jjjtj j jk Sr) rAr&r-rJrIr@ state_machinestater<r=ConnectionStaters r is_availablezHTTP2Connection.is_availablesV K.5 5 a** a-- a^172=;X;__`  r!cJtj}|j}|duo||kSr)rrrB)rOr expire_ats r has_expiredzHTTP2Connection.has_expireds,nO $8y8r!c,|jtjkSr)rAr&r,rs ris_idlezHTTP2Connection.is_idles{1666r!cdS)NTr.rs r can_multiplexzHTTP2Connection.can_multiplexstr!c,|jtjkSr)rAr&r-rs rrzHTTP2Connection.is_closeds{1888r!strc\t|j}|d|jjd|jS)Nz , HTTP/2, , Request Count: )rr9rAnamerCrs rinfozHTTP2Connection.infos5T\""^^dk&6^^I\^^^r!c ~|jj}t|j}d|d|d|jjd|jd S)N) __class__r(rr9rArrC)rO class_namer3s r__repr__zHTTP2Connection.__repr__sM^, T\""g:ggggT[-=ggPTPcggggr!c|Srr.rs r __enter__zHTTP2Connection.__enter__s r!exc_typetype[BaseException] | None exc_valueBaseException | None tracebacktypes.TracebackType | Nonec.|dSr)re)rOrrrs r__exit__zHTTP2Connection.__exit__ s r!r)r3r r4rr5r6)rr rr )rr rr)rr rTrrr)rr rTrrrrr)rr rTrrr)rr rTrrr)rr rTrrr)rr rTrrr)rrrr)rTrrrrr)rr rr)rr rTrrr)r3r rr)rr)rr)rr0)NNN)rrrrrrrr)$r(r)r*rr<r8H2Configurationr?rPr~rcrprqrrrrrrrrrurerrrr_rrrrrrrr rrr.r!rr0r0%sN Y & & & F FF *. 7 7 7 7 7D\\\\|++++>++++> 2 2 2 2 / / / /++++&&&&(    *+*+*+*+*+X + + + +!!!! %%%%86(&&&&$$$$    999977779999____hhhh 04*.04 r!r0c&eZdZdd Zdd Zdd Zd S)rtr=r0rr rTrrrc>||_||_||_d|_dS)NF) _connection_request _stream_id_closed)rOr=rrTs rrPz"HTTP2ConnectionByteStream.__init__s#% # r!rc#K|j|jd} tdt|j|5t |j|j|j5}|D]}|V dddn #1swxYwYddddS#1swxYwYdS#t$rA}t5| dddn #1swxYwY|d}~wwxYw)NrSreceive_response_body) rrrrbrrrrdrre)rOr|rrrys r__iter__z"HTTP2ConnectionByteStream.__iter__s!]II . vNN $ $!$;;DM]a]l;mm$!)$$# $$$$$$$$$$$$$$$$ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $    $%%                  I  sB4B# A:. B:A> >BA> B BBBBB C*)C%7C C%C C%C C%%C*c|jsgd|_d|ji}tdt|j|5|j|jddddS#1swxYwYdSdS)NTrTr^rX)rrrrbrrru)rOr|s rrezHTTP2ConnectionByteStream.close*s| 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=r0rr rTrrr)rrr)r(r)r*rPr!rer.r!rrtrtsV "MMMMMMr!rt)rr rr)* __future__renumloggingrtypesrcollections.abcr h2.configr< h2.connection h2.events h2.exceptions h2.settings_backends.baser _exceptionsrrr _modelsr r r _synchronizationr rr_tracer_utilsr interfacesr getLoggerrbr$IntEnumr&r0rtr.r!rr6s""""""  %%%%%%******YYYYYYYYYY//////////BBBBBBBBBB!!!!!!++++++  , - -qqqq$, jjjjj)jjjZMMMMMMMMMMr!