
    h86                       S SK Jr  S SKrS SKrS SKrS SKrS SKrS SKrS SKrSSK	J
r
  SSKJrJrJrJrJr  SSKJrJrJr  SSKJrJr  SSKJr  S	S
KJr  \R8                  " S5      r\R<                  \R&                  \R>                  \R@                  4   r! " S S\RD                  5      r# " S S\5      r$ " S S5      r% " S S\
5      r&g)    )annotationsN   )AsyncNetworkStream)ConnectionNotAvailableLocalProtocolErrorRemoteProtocolError
WriteErrormap_exceptions)OriginRequestResponse)	AsyncLockAsyncShieldCancellation)Trace   )AsyncConnectionInterfacezhttpcore.http11c                  $    \ rS rSrSrSrSrSrSrg)HTTPConnectionState$   r   r   r       N)	__name__
__module____qualname____firstlineno__NEWACTIVEIDLECLOSED__static_attributes__r       H/var/www/html/env/lib/python3.13/site-packages/httpcore/_async/http11.pyr   r   $   s    
CFDFr!   r   c                  &   \ rS rSrSrSr S       SS jjrSS jrSS jrSS jr	SSS	 jjr
    SS
 jr    SS jr S   S S jjrS!S jrS!S jrS"S jrS#S jrS#S jrS#S jrS#S jrS$S jrS$S jrS%S jr   S&       S'S jjrSrg)(AsyncHTTP11Connection+   i   i  Nc                    Xl         X l        X0l        S U l        [        R
                  U l        [        5       U l        SU l	        [        R                  " [        R                  U R                  S9U l        g )Nr   )our_rolemax_incomplete_event_size)_origin_network_stream_keepalive_expiry
_expire_atr   r   _stater   _state_lock_request_counth11
ConnectionCLIENTMAX_INCOMPLETE_EVENT_SIZE
_h11_state)selforiginstreamkeepalive_expirys       r"   __init__AsyncHTTP11Connection.__init__/   s[     %/?(,)--$;..ZZ&*&D&D
r!   c           	       #    U R                  UR                  R                  5      (       d/  [        SUR                  R                   SU R                   35      eU R
                   IS h  vN   U R                  [        R                  [        R                  4;   a2  U =R                  S-  sl
        [        R                  U l        S U l        O
[        5       eS S S 5      IS h  vN    SU0n [        S[        X5       IS h  vN nU R                   " S0 UD6I S h  vN   S S S 5      IS h  vN   [        S[        X5       IS h  vN nU R"                  " S0 UD6I S h  vN   S S S 5      IS h  vN   [        S[        X5       IS h  vN nU R&                  " S0 UD6I S h  vN u  nnnnnUUUU4Ul        S S S 5      IS h  vN   U R*                  n	WS:X  d   UR,                  S	:X  a  S
Us=::  a  S:  a  O  O[/        U	W5      n	[1        UW[3        X5      WWU	S.S9$  GN GNB! , IS h  vN  (       d  f       GNX= f GN@ GN) GN! , IS h  vN  (       d  f       GN2= f GN  GN	 N! , IS h  vN  (       d  f       GN= f! [$         a     GN!f = f GN N N! , IS h  vN  (       d  f       N= f! [4         a  n
[7        5          [        S[        U5       IS h  vN  nU R9                  5       I S h  vN    S S S 5      IS h  vN    O! , IS h  vN  (       d  f       O= fS S S 5        U
e! , (       d  f       U
e= fS n
A
ff = f7f)NzAttempted to send request to z on connection to r   requestsend_request_headerssend_request_bodyreceive_response_headerse   s   CONNECT   i,  )http_versionreason_phrasenetwork_stream)statusheaderscontent
extensionsresponse_closedr   )can_handle_requesturlr6   RuntimeErrorr)   r.   r-   r   r   r   r/   r   r,   r   r   logger_send_request_headers_send_request_bodyr	   _receive_response_headersreturn_valuer*   methodAsyncHTTP11UpgradeStreamr   HTTP11ConnectionByteStreamBaseExceptionr   _response_closed)r5   r<   kwargstracerB   rE   rC   rF   trailing_datarD   excs              r"   handle_async_request*AsyncHTTP11Connection.handle_async_requestA   s    &&w{{'9'9::/0B0B/C Dll^% 
 ###{{2668K8P8PQQ##q(#188"&,.. $#8	)F *FG 44>v>>>  !!4fgNNRW11;F;;; ON *FG  88B6BB !! !!	&" " "11N #:-C64GC4G!9.-!X24A$0%2&4		 	e $### ?    O; ONNN   C   F  	(* !2FGDD//111 EDDDDD + I +* I		s   A*M,H%-M0A+H+M&H('M,J? 1J IJ 
I I	!I%J 0I1J 
I*J I2$I-%I2)J 4I05J 9J? JJ? J%(J!)J%>J? 	J#
AJ? $M(M+I1H42I>MJ 	IJ I'II'"	J -I20J 2J
8I;9J
J J? 
J 
JJ? JJ? !J%#J? %J<+J.,J<8J? ?
M	
ML>)K,
*L>.LL
LL>LL>L1 L#!L1-L>4
M>
M	MMMc                  #    UR                   R                  S0 5      nUR                  SS 5      n[        [        R                  [        05         [        R
                  " UR                  UR                  R                  UR                  S9nS S S 5        U R                  WUS9I S h  vN   g ! , (       d  f       N'= f N7f)Ntimeoutwrite)rR   targetrF   r^   )rH   getr
   r0   r   r   rR   rK   r`   rF   _send_eventr5   r<   timeoutsr^   events        r"   rN   +AsyncHTTP11Connection._send_request_headers   s     %%)))R8,,w-S335GHIKK~~{{))E J ug666 JI 	7s*   AC?B0C*C+C0
B>:Cc                  #    UR                   R                  S0 5      nUR                  SS 5      n[        UR                  [        R
                  5      (       d   eUR                    S h  vN n[        R                  " US9nU R                  XSS9I S h  vN   M6   N1 N
 U R                  [        R                  " 5       US9I S h  vN    g 7f)Nr^   r_   )datara   )
rH   rb   
isinstancer7   typingAsyncIterabler0   Datarc   EndOfMessage)r5   r<   re   r^   chunkrf   s         r"   rO   (AsyncHTTP11Connection._send_request_body   s     %%)))R8,,w-'..&*>*>????">> 	;%HH%(E""5":::	;: * s//17CCCsH   A&C(B",B-B"0'CB CB" C"'C	C
Cc                   #    U R                   R                  U5      nUb"  U R                  R                  X2S9I S h  vN   g g  N7f)Nra   )r4   sendr*   r_   )r5   rf   r^   bytes_to_sends       r"   rc   !AsyncHTTP11Connection._send_event   sD     ,,U3$&&,,],LLL %Ls   ;AAAc                  #    UR                   R                  S0 5      nUR                  SS 5      n U R                  US9I S h  vN n[        U[        R
                  5      (       a  O2[        U[        R                  5      (       a  UR                  S:X  a  OMi  SUR                  -   nUR                  R                  5       nU R                  R                  u  pxXTR                  UR                  Xg4$  N7f)Nr^   readra   r@   s   HTTP/)rH   rb   _receive_eventrj   r0   r   InformationalResponsestatus_coderB   rF   	raw_itemsr4   rY   reason)	r5   r<   re   r^   rf   rB   rF   rY   _s	            r"   rP   /AsyncHTTP11Connection._receive_response_headers   s      %%)))R8,,vt,--g->>E%..5#";";<<%%,   %"4"44 --))+??88..gTT# ?s   AC7C5B1C7c               n  #    UR                   R                  S0 5      nUR                  SS 5      n U R                  US9I S h  vN n[        U[        R
                  5      (       a  [        UR                  5      7v   O0[        U[        R                  [        R                  45      (       a  g M   Nn7f)Nr^   rv   ra   )
rH   rb   rw   rj   r0   rm   bytesri   rn   PAUSEDrd   s        r"   _receive_response_body,AsyncHTTP11Connection._receive_response_body   s      %%)))R8,,vt,--g->>E%**EJJ''EC$4$4cjj#ABB >s   AB5B3A/B5c                  #     [        [        R                  [        05         U R                  R	                  5       nS S S 5        W[        R
                  L a  U R                  R                  U R                  US9I S h  vN nUS:X  a5  U R                  R                  [        R                  :X  a  Sn[        U5      eU R                  R                  U5        OU$ M  ! , (       d  f       N= f Np7f)Nra   r!   z/Server disconnected without sending a response.)r
   r0   r   r4   
next_event	NEED_DATAr*   rv   READ_NUM_BYTEStheir_stateSEND_RESPONSEreceive_data)r5   r^   rf   ri   msgs        r"   rw   $AsyncHTTP11Connection._receive_event   s      !8!8:M NO224 P %!1166'' 7   3;4??#>#>#BSBS#SKC-c22,,T2 1 OOs)   !C3C AC3 C1AC3 
C.*C3c                ,  #    U R                    IS h  vN   U R                  R                  [        R                  L a  U R                  R
                  [        R                  L ae  [        R                  U l        U R                  R                  5         U R                  b(  [        R                  " 5       nXR                  -   U l        OU R                  5       I S h  vN   S S S 5      IS h  vN   g  N N N	! , IS h  vN  (       d  f       g = f7fN)r.   r4   	our_stater0   DONEr   r   r   r-   start_next_cycler+   time	monotonicr,   aclose)r5   nows     r"   rV   &AsyncHTTP11Connection._response_closed   s     ###))SXX5OO//388;166002))5..*C&),B,B&BDOkkm## $## $ $###sW   DC4DCC:C6C:#D.C8/D6C:8D:D DDDc                ~   #    [         R                  U l        U R                  R	                  5       I S h  vN   g  N7fr   )r   r   r-   r*   r   r5   s    r"   r   AsyncHTTP11Connection.aclose   s,      *00""))+++s   3=;=c                    XR                   :H  $ r   )r)   r5   r6   s     r"   rJ   (AsyncHTTP11Connection.can_handle_request  s    %%r!   c                <    U R                   [        R                  :H  $ r   r-   r   r   r   s    r"   is_available"AsyncHTTP11Connection.is_available  s    
 {{16666r!   c                   [         R                  " 5       nU R                  S L=(       a    XR                  :  nU R                  [        R
                  :H  =(       a    U R                  R                  S5      nU=(       d    U$ )Nis_readable)r   r   r,   r-   r   r   r*   get_extra_info)r5   r   keepalive_expiredserver_disconnecteds       r"   has_expired!AsyncHTTP11Connection.has_expired  sk    nn OO47QC//<Q KK.333 C$$33MB 	
 !7$77r!   c                <    U R                   [        R                  :H  $ r   r   r   s    r"   is_idleAsyncHTTP11Connection.is_idle   s    {{16666r!   c                <    U R                   [        R                  :H  $ r   )r-   r   r   r   s    r"   	is_closedAsyncHTTP11Connection.is_closed#  s    {{18888r!   c                ~    [        U R                  5      nU< SU R                  R                   SU R                   3$ )Nz, HTTP/1.1, , Request Count: )strr)   r-   namer/   r   s     r"   infoAsyncHTTP11Connection.info&  sA    T\\"jT[[%5%5$6 7"1124	
r!   c           	         U R                   R                  n[        U R                  5      nSU SU< SU R                  R
                   SU R                   S3	$ )N<z [z, r   z]>)	__class__r   r   r)   r-   r   r/   )r5   
class_namer6   s      r"   __repr__AsyncHTTP11Connection.__repr__-  sZ    ^^,,
T\\"
|2fZr$++*:*:); <"112"6	
r!   c                   #    U $ 7fr   r   r   s    r"   
__aenter__ AsyncHTTP11Connection.__aenter__8  s
     s   c                @   #    U R                  5       I S h  vN   g  N7fr   )r   )r5   exc_type	exc_value	tracebacks       r"   	__aexit__AsyncHTTP11Connection.__aexit__;  s      kkms   )r,   r4   r+   r*   r)   r/   r-   r.   r   )r6   r   r7   r   r8   float | NonereturnNone)r<   r   r   r   )r<   r   r   r   )rf   z	h11.Eventr^   r   r   r   )r<   r   r   z:tuple[bytes, int, bytes, list[tuple[bytes, bytes]], bytes])r<   r   r   typing.AsyncIterator[bytes])r^   r   r   zh11.Event | type[h11.PAUSED]r   r   )r6   r   r   bool)r   r   )r   r   )r   r$   )NNN)r   ztype[BaseException] | Noner   zBaseException | Noner   ztypes.TracebackType | Noner   r   )r   r   r   r   r   r3   r9   r[   rN   rO   rc   rP   r   rw   rV   r   rJ   r   r   r   r   r   r   r   r   r    r   r!   r"   r$   r$   +   s	   N * *.	

 #
 '	

 

$GV
7	DMUU	CU4	$ '+#	%:$ ,&7879


 04*.04	, ( .	
 
 r!   r$   c                  2    \ rS rSrSS jrSS jrS	S jrSrg)
rT   iD  c                *    Xl         X l        SU l        g )NF)_connection_request_closed)r5   
connectionr<   s      r"   r9   #HTTP11ConnectionByteStream.__init__E  s    %r!   c                 #    SU R                   0n [        S[        U R                   U5       IS h  vN   U R                  R                  " S0 UD6  S h  vN nU7v   M   N0 N
 S S S 5      IS h  vN    g ! , IS h  vN  (       d  f       g = f! [
         aE  n[        5          U R                  5       I S h  vN    S S S 5        Ue! , (       d  f       Ue= fS nAff = f7f)Nr<   receive_response_bodyr   )r   r   rM   r   r   rU   r   r   )r5   rW   ro   rZ   s       r"   	__aiter__$HTTP11ConnectionByteStream.__aiter__J  s     T]]+
	4fdmmVTT#'#3#3#J#J#TV#T  %K U #T UTTTTT  	 )*kkm## +I +*I	s   C& B A#B A:A'A%A'A:#B %A''A:(B 3A64B 9C&:B BBB C&B 
C#
C(C<B?=C
C
C	CC##C&c                *  #    U R                   (       d^  SU l         [        S[        U R                  5       IS h  vN   U R                  R                  5       I S h  vN   S S S 5      IS h  vN   g g  N8 N N
! , IS h  vN  (       d  f       g = f7f)NTrI   )r   r   rM   r   r   rV   r   s    r"   r   !HTTP11ConnectionByteStream.acloseX  se     ||DL.FF&&77999 GFF F9 GFFFsV   8BA3BA9A5A9!B,A7-B5A97B9B?B BB)r   r   r   N)r   r$   r<   r   r   r   )r   r   r   )r   r   r   r   r9   r   r   r    r   r!   r"   rT   rT   D  s    
:r!   rT   c                  n    \ rS rSrS
S jrSSS jjrSSS jjrSS jr  S       SS jjrSS jr	S	r
g)rS   i_  c                    Xl         X l        g r   )_stream_leading_data)r5   r7   leading_datas      r"   r9   !AsyncHTTP11UpgradeStream.__init__`  s    )r!   Nc                   #    U R                   (       a%  U R                   S U nU R                   US  U l         U$ U R                  R                  X5      I S h  vN $  N7fr   )r   r   rv   )r5   	max_bytesr^   buffers       r"   rv   AsyncHTTP11UpgradeStream.readd  sU     ''
3F!%!3!3IJ!?DM**9>>>>s   AAAAc                V   #    U R                   R                  X5      I S h  vN   g  N7fr   )r   r_   )r5   r   r^   s      r"   r_   AsyncHTTP11UpgradeStream.writel  s     ll  111s   )')c                T   #    U R                   R                  5       I S h  vN   g  N7fr   )r   r   r   s    r"   r   AsyncHTTP11UpgradeStream.acloseo  s     ll!!###s   (&(c                V   #    U R                   R                  XU5      I S h  vN $  N7fr   )r   	start_tls)r5   ssl_contextserver_hostnamer^   s       r"   r   "AsyncHTTP11UpgradeStream.start_tlsr  s$      \\++K'RRRRs    )')c                8    U R                   R                  U5      $ r   )r   r   )r5   r   s     r"   r   'AsyncHTTP11UpgradeStream.get_extra_infoz  s    ||**400r!   )r   r   )r7   r   r   r   r   r   r   )r   intr^   r   r   r   )r   r   r^   r   r   r   r   )NN)r   zssl.SSLContextr   z
str | Noner^   r   r   r   )r   r   r   z
typing.Any)r   r   r   r   r9   rv   r_   r   r   r   r    r   r!   r"   rS   rS   _  sS    *?2$ '+ $	S#S $S 	S
 
S1r!   rS   )'
__future__r   enumloggingsslr   typesrk   r0   _backends.baser   _exceptionsr   r   r   r	   r
   _modelsr   r   r   _synchronizationr   r   _tracer   
interfacesr   	getLoggerrM   Unionrm   rn   H11SendEventIntEnumr   r$   rT   rS   r   r!   r"   <module>r      s    "   
    
 /  0 / A  0			,	- ||KKHH$,, V4 Vr: :611 1r!   