$%h4ddlmZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z m Z mZmZmZddlmZmZmZddlmZmZddlmZd d lmZej8d Zej<ej&ej>ej@fZ!Gd d ejDZ#GddeZ$GddZ%Gdde Z&y)) annotationsN) NetworkStream)ConnectionNotAvailableLocalProtocolErrorRemoteProtocolError WriteErrormap_exceptions)OriginRequestResponse)LockShieldCancellation)Trace)ConnectionInterfacezhttpcore.http11ceZdZdZdZdZdZy)HTTPConnectionStaterrrN)__name__ __module__ __qualname__NEWACTIVEIDLECLOSEDS/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/httpcore/_sync/http11.pyrr$s C F D FrrceZdZdZdZ d ddZddZddZddZdddZ dd Z dd Z d dd Z dd Z dd Zd dZd!dZd!dZd!dZd!dZd"dZd"dZd#dZ d$ d%dZy)&HTTP11ConnectioniiNc||_||_||_d|_tj |_t|_d|_ tjtj|j|_y)Nr)our_rolemax_incomplete_event_size)_origin_network_stream_keepalive_expiry _expire_atrr_stater _state_lock_request_counth11 ConnectionCLIENTMAX_INCOMPLETE_EVENT_SIZE _h11_state)selforiginstreamkeepalive_expirys r__init__zHTTP11Connection.__init__/sa  %/?(,)-- 6..ZZ&*&D&D rc |j|jjs/td|jjd|j|j 5|j tjtjfvr2|xjdz c_ tj|_d|_ n t ddd d|i} tdt||5}|j di|dddtdt||5}|j"di|dddtdt||5}|j&di|\}}}}}||||f|_ddd|j*} dk(s|j,d k(rd |cxkrd krnn t/| } t1|t3||| d  S#1swYxYw#1swYxYw#1swYxYw#t$$rYwxYw#1swYxYw#t4$r^} t75tdt|5}|j9dddn #1swYnxYwddd| #1swY| xYwd} ~ wwxYw)NzAttempted to send request to z on connection to rrequestsend_request_headerssend_request_bodyreceive_response_headersesCONNECTi,) http_version reason_phrasenetwork_stream)statusheaderscontent extensionsresponse_closedr)can_handle_requesturlr2 RuntimeErrorr%r*r)rrrr+rr(rrlogger_send_request_headers_send_request_bodyr _receive_response_headers return_valuer&methodHTTP11UpgradeStreamr HTTP11ConnectionByteStream BaseExceptionr_response_closed) r1r7kwargstracer=r@r>rA trailing_datar?excs rhandle_requestzHTTP11Connection.handle_requestAs&&w{{'9'9:/ 0B0B/CDll^%     /{{2668K8P8PQQ##q(#188 "&,..  /8 )F *FGV9.D..889.H6E+D++5f56*FGV 3D22,%))+,,, ,I ,I  s!A)GHG,+G>G,G +G,3H$G;)AHGGG, G)%G,, G85H7G88H;HH I. I)I,I= II I I)I& !I))I.cn|jjdi}|jdd}ttjti5tj |j |jj|j}ddd|j|y#1swYxYw)Ntimeoutwrite)rMtargetrArX) rCgetr r,rr rMrFrZrA _send_eventr1r7timeoutsrXevents rrIz&HTTP11Connection._send_request_headerss%%)))R8,,w- S335GH I KK~~{{))E  0   s AB++B4cj|jjdi}|jdd}t|jtj sJ|jD]+}t j|}|j||-|jt j|y)NrXrY)datar[) rCr\ isinstancer3typingIterabler,Datar] EndOfMessage)r1r7r_rXchunkr`s rrJz#HTTP11Connection._send_request_bodys%%)))R8,,w-'..&//:::^^ 5EHH%(E   UG  4 5 ))+W=rcz|jj|}||jj||yy)Nr[)r0sendr&rY)r1r`rX bytes_to_sends rr]zHTTP11Connection._send_events:,,U3  $  & &}g & F %rc|jjdi}|jdd} |j|}t|tj rn+t|tj r|jdk(rnXd|jz}|jj}|jj\}}||j|j||fS)NrXreadr[r;sHTTP/)rCr\_receive_eventrcr,r InformationalResponse status_coder=rA raw_itemsr0rTreason) r1r7r_rXr`r=rArT_s rrKz*HTTP11Connection._receive_response_headerss%%)))R8,,vt,'''8E%.5#";";<%%, %"4"44 --))+??88 qU.. g}TTrc#HK|jjdi}|jdd} |j|}t|tj rt |jn+t|tjtjfrypw)NrXrmr[) rCr\rnrcr,rfbytesrbrgPAUSEDr^s r_receive_response_bodyz'HTTP11Connection._receive_response_bodys%%)))R8,,vt,'''8E%*EJJ''EC$4$4cjj#AB sB B"c ttjti5|jj }dddtj ur||j j|j|}|dk(r4|jjtjk(r d}t||jj|n|S#1swYxYw)Nr[rz/Server disconnected without sending a response.) r r,rr0 next_event NEED_DATAr&rmREAD_NUM_BYTES their_state SEND_RESPONSE receive_data)r1rXr`rbmsgs rrnzHTTP11Connection._receive_events!8!8:M NO 5224 5 %++00''13;4??#>#>#BSBS#SKC-c22,,T2 1 5 5s CCc|j5|jjtjur|jj tjurdt j|_|jj|j9tj}||jz|_ n|jdddy#1swYyxYwN)r*r0 our_stater,DONEr|rrr)start_next_cycler'time monotonicr(close)r1nows rrQz!HTTP11Connection._response_closeds    ))SXX5OO//388;166 002))5..*C&)D,B,B&BDO    s CCC cbtj|_|jj yr)rrr)r&rr1s rrzHTTP11Connection.closes#*00  ""$rc ||jk(Sr)r%r1r2s rrEz#HTTP11Connection.can_handle_requests%%rc<|jtjk(Srr)rrrs r is_availablezHTTP11Connection.is_available s {{16666rctj}|jduxr||jkD}|jtj k(xr|j jd}|xs|S)N is_readable)rrr(r)rrr&get_extra_info)r1rkeepalive_expiredserver_disconnecteds r has_expiredzHTTP11Connection.has_expiredsmnn OO47QC$//) __class__rrr%r)rr+)r1 class_namer2s r__repr__zHTTP11Connection.__repr__-sZ^^,, T\\" |2fZr$++*:*:);<"112" 6 rc|Srrrs r __enter__zHTTP11Connection.__enter__8s rc$|jyr)r)r1exc_type exc_value tracebacks r__exit__zHTTP11Connection.__exit__;s rr)r2r r3rr4 float | NonereturnNone)r7r rr )r7r rr)r`z h11.EventrXrrr)r7r rz:tuple[bytes, int, bytes, list[tuple[bytes, bytes]], bytes])r7r rtyping.Iterator[bytes])rXrrzh11.Event | type[h11.PAUSED]rr)r2r rbool)rr)rr)rr!)NNN)rztype[BaseException] | NonerzBaseException | Nonerztypes.TracebackType | Nonerr)rrrr{r/r5rVrIrJr]rKrwrnrQrrErrrrrrrrrrrr!r!+sN * *.    '    $GV 1 >GUU CU4    '+# %:  %&7 879   04*.04 ,(.   rr!c$eZdZddZddZddZy)rOc.||_||_d|_y)NF) _connection_request_closed)r1 connectionr7s rr5z#HTTP11ConnectionByteStream.__init__Es%  rc#^Kd|ji} tdt|j|5|jjdi|D]}| dddy#1swYyxYw#t $r7}t 5|jddd|#1swY|xYwd}~wwxYww)Nr7receive_response_bodyr)rrrHrrwrPrr)r1rRrhrUs r__iter__z#HTTP11ConnectionByteStream.__iter__JsT]]+ . vN DT--DDNvN EK     $%   I I  scB-A*&AA*B-A'#A*&B-'A** B*3 B%=B B%B" B%%B**B-c|jsFd|_tdt|j5|jj dddyy#1swYyxYw)NTrD)rrrHrrrQrs rrz HTTP11ConnectionByteStream.closeXsR||DL(&$--@ 4  113 4 4 4 4s AAN)rr!r7r rr)rrr)rrrr5rrrrrrOrODs 4rrOcTeZdZddZd d dZd d dZd dZ d ddZddZy)rNc ||_||_yr)_stream _leading_data)r1r3 leading_datas rr5zHTTP11UpgradeStream.__init__`s )rNc|jr%|jd|}|j|d|_|S|jj||Sr)rrrm)r1 max_bytesrXbuffers rrmzHTTP11UpgradeStream.readdsN   '' 3F!%!3!3IJ!?D M<<$$Y8 8rc<|jj||yr)rrY)r1rrXs rrYzHTTP11UpgradeStream.writels 67+rc8|jjyr)rrrs rrzHTTP11UpgradeStream.closeos rc<|jj|||Sr)r start_tls)r1 ssl_contextserver_hostnamerXs rrzHTTP11UpgradeStream.start_tlsrs ||%%k?GLLrc8|jj|Sr)rr)r1rs rrz"HTTP11UpgradeStream.get_extra_infozs||**400r)r3rrrurrr)rintrXrrru)rrurXrrrr)NN)rzssl.SSLContextrz str | NonerXrrr)rrrz typing.Any) rrrr5rmrYrrrrrrrNrN_sS*9, '+ $ M#M$M M  M1rrN)' __future__renumloggingsslrtypesrdr,_backends.baser _exceptionsrrrr r _modelsr r r _synchronizationrr_tracer interfacesr getLoggerrHUnionrfrg H11SendEventIntEnumrr!rOrNrrrrs"  *0/7+   , -||KKHH $,,V*Vr4461-1r