
    h4                       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   )NetworkStream)ConnectionNotAvailableLocalProtocolErrorRemoteProtocolError
WriteErrormap_exceptions)OriginRequestResponse)LockShieldCancellation)Trace   )ConnectionInterfacez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       G/var/www/html/env/lib/python3.13/site-packages/httpcore/_sync/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)(HTTP11Connection+   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__HTTP11Connection.__init__/   s[     %/?(,)--6..ZZ&*&D&D
r!   c           	     ,   U R                  UR                  R                  5      (       d/  [        SUR                  R                   SU R                   35      eU R
                     U R                  [        R                  [        R                  4;   a2  U =R                  S-  sl
        [        R                  U l        S U l        O
[        5       e S S S 5         SU0n [        S[        X5       nU R                   " S0 UD6  S S S 5        [        S[        X5       nU R"                  " S0 UD6  S S S 5        [        S[        X5       nU R&                  " S0 UD6u  nnnnnUUUU4Ul        S S S 5        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$ ! , (       d  f       GN= f! , (       d  f       N= f! , (       d  f       N= f! [$         a     Nf = f! , (       d  f       N= f! [4         ah  n
[7        5          [        S[        U5       nU R9                  5         S S S 5        O! , (       d  f       O= fS S S 5        U
e! , (       d  f       U
e= fS n
A
ff = 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HTTP11UpgradeStreamr   HTTP11ConnectionByteStreamBaseExceptionr   _response_closed)r5   r<   kwargstracerB   rE   rC   rF   trailing_datarD   excs              r"   handle_requestHTTP11Connection.handle_requestA   sh   &&w{{'9'9::/0B0B/C Dll^% 
 {{2668K8P8PQQ##q(#188"&,..  	 8	)F*FG..88 .HE++5f5 I *FG 22<V< !! !!	&"" "11N #:-C64GC4G!4^]!S24A$0%2&4		 	e   IH   F  	#%,fg>%))+ ?>> & I &% I		s   &A+GH!  H  1GH  G/0H  8H! 	$H-AH! 
G
G,(H  /
G=9H  <H! =H   
H
H! HH! 
HH! !
J+
J5I<I!	I<!
I/+I<2
J<
J	JJc                n   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  g ! , (       d  f       N= f)Ntimeoutwrite)rR   targetrF   r^   )rH   getr
   r0   r   r   rR   rK   r`   rF   _send_eventr5   r<   timeoutsr^   events        r"   rN   &HTTP11Connection._send_request_headers   s    %%)))R8,,w-S335GHIKK~~{{))E J 	0 JIs   ?B&&
B4c                h   UR                   R                  S0 5      nUR                  SS 5      n[        UR                  [        R
                  5      (       d   eUR                   H&  n[        R                  " US9nU R                  XSS9  M(     U R                  [        R                  " 5       US9  g )Nr^   r_   )datara   )
rH   rb   
isinstancer7   typingIterabler0   Datarc   EndOfMessage)r5   r<   re   r^   chunkrf   s         r"   rO   #HTTP11Connection._send_request_body   s    %%)))R8,,w-'..&//::::^^EHH%(EU4 $ 	))+W=r!   c                t    U R                   R                  U5      nUb  U R                  R                  X2S9  g g )Nra   )r4   sendr*   r_   )r5   rf   r^   bytes_to_sends       r"   rc   HTTP11Connection._send_event   s8    ,,U3$  &&}&F %r!   c                   UR                   R                  S0 5      nUR                  SS 5      n U R                  US9n[        U[        R
                  5      (       a  O2[        U[        R                  5      (       a  UR                  S:X  a  OMa  SUR                  -   nUR                  R                  5       nU R                  R                  u  pxXTR                  UR                  Xg4$ )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   *HTTP11Connection._receive_response_headers   s     %%)))R8,,vt,'''8E%..5#";";<<%%,   %"4"44 --))+??88..gTTr!   c              #  X  #    UR                   R                  S0 5      nUR                  SS 5      n U R                  US9n[        U[        R
                  5      (       a  [        UR                  5      v   O0[        U[        R                  [        R                  45      (       a  g Mx  7f)Nr^   rv   ra   )
rH   rb   rw   rj   r0   rm   bytesri   rn   PAUSEDrd   s        r"   _receive_response_body'HTTP11Connection._receive_response_body   s      %%)))R8,,vt,'''8E%**EJJ''EC$4$4cjj#ABB s   B(B*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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)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   HTTP11Connection._receive_event   s     !8!8:M NO224 P %++00'' 1  3;4??#>#>#BSBS#SKC-c22,,T2 1 OOs   C
C$c                   U R                      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         S S S 5        g ! , (       d  f       g = fN)r.   r4   	our_stater0   DONEr   r   r   r-   start_next_cycler+   time	monotonicr,   close)r5   nows     r"   rV   !HTTP11Connection._response_closed   s    ))SXX5OO//388;166002))5..*C&),B,B&BDO

 s   CC
C(c                b    [         R                  U l        U R                  R	                  5         g r   )r   r   r-   r*   r   r5   s    r"   r   HTTP11Connection.close   s#     *00""$r!   c                    XR                   :H  $ r   )r)   r5   r6   s     r"   rJ   #HTTP11Connection.can_handle_request  s    %%r!   c                <    U R                   [        R                  :H  $ r   r-   r   r   r   s    r"   is_availableHTTP11Connection.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HTTP11Connection.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HTTP11Connection.is_idle   s    {{16666r!   c                <    U R                   [        R                  :H  $ r   )r-   r   r   r   s    r"   	is_closedHTTP11Connection.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HTTP11Connection.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__HTTP11Connection.__repr__-  sZ    ^^,,
T\\"
|2fZr$++*:*:); <"112"6	
r!   c                    U $ r   r   r   s    r"   	__enter__HTTP11Connection.__enter__8  s    r!   c                $    U R                  5         g r   )r   )r5   exc_type	exc_value	tracebacks       r"   __exit__HTTP11Connection.__exit__;  s     	

r!   )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.Iterator[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
1	>G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              #  v  #    SU R                   0n [        S[        U R                   U5         U R                  R                  " S0 UD6 H  nUv   M	     S S S 5        g ! , (       d  f       g = f! [
         a<  n[        5          U R                  5         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"   __iter__#HTTP11ConnectionByteStream.__iter__J  s     T]]+
	.vN!--DDNvNEK O ONN  	 $%

 &I &%I	sc   B9A0 (AA0 B9
A-)A0 ,B9-A0 0
B6:
B1B
B1
B.	)B11B66B9c                    U R                   (       dF  SU l         [        S[        U R                  5         U R                  R                  5         S S S 5        g g ! , (       d  f       g = f)NTrI   )r   r   rM   r   r   rV   r   s    r"   r    HTTP11ConnectionByteStream.closeX  sH    ||DL(&$--@  113 A@ @@s   A
A')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    
4r!   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   HTTP11UpgradeStream.__init__`  s    )r!   Nc                    U R                   (       a%  U R                   S U nU R                   US  U l         U$ U R                  R                  X5      $ r   )r   r   rv   )r5   	max_bytesr^   buffers       r"   rv   HTTP11UpgradeStream.readd  sL    ''
3F!%!3!3IJ!?DM<<$$Y88r!   c                :    U R                   R                  X5        g r   )r   r_   )r5   r   r^   s      r"   r_   HTTP11UpgradeStream.writel  s    6+r!   c                8    U R                   R                  5         g r   )r   r   r   s    r"   r   HTTP11UpgradeStream.closeo  s    r!   c                :    U R                   R                  XU5      $ r   )r   	start_tls)r5   ssl_contextserver_hostnamer^   s       r"   r   HTTP11UpgradeStream.start_tlsr  s     ||%%kGLLr!   c                8    U R                   R                  U5      $ r   )r   r   )r5   r   s     r"   r   "HTTP11UpgradeStream.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    *9, '+ $	M#M $M 	M
 
M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 / 7  +			,	- ||KKHH$,, V* Vr4 461- 1r!   