ó
    °"³j¯4  ã                  óž  • 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J	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  SSKJr  \R@                  " S5      r!\
R*                  \
RD                  -  \
RF                  -  r$ " S S\RJ                  5      r& " S S\5      r' " S S5      r( " S S\5      r)g)é    )ÚannotationsN)Ú	Generatoré   )ÚNetworkStream)ÚConnectionNotAvailableÚLocalProtocolErrorÚRemoteProtocolErrorÚ
WriteErrorÚmap_exceptions)ÚOriginÚRequestÚResponse)ÚLockÚShieldCancellation)ÚTrace)Úsafe_iterateé   )ÚConnectionInterfacezhttpcore2.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   ó    ÚS/home/mande/repo/quber/.venv/lib/python3.13/site-packages/httpcore2/_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 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ˆÔØˆÔÜŸ.š.Ü—Z‘ZØ&*×&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     NÔf = 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_headersée   s   CONNECTéÈ   i,  )Úhttp_versionÚreason_phraseÚnetwork_stream)ÚstatusÚheadersÚcontentÚ
extensionsÚresponse_closedr   )Úcan_handle_requestÚurlr8   ÚRuntimeErrorr+   r0   r/   r   r   r    r1   r   r.   r   r   ÚloggerÚ_send_request_headersÚ_send_request_bodyr
   Ú_receive_response_headersÚreturn_valuer,   ÚmethodÚHTTP11UpgradeStreamr   ÚHTTP11ConnectionByteStreamÚBaseExceptionr   Ú_response_closed)r7   r>   ÚkwargsÚtracerD   rG   rE   rH   Útrailing_datarF   Úexcs              r$   Úhandle_requestÚHTTP11Connection.handle_request?   sT  € Ø×&Ñ& w§{¡{×'9Ñ'9×:Ñ:ÜÐ!>¸w¿{¹{×?QÑ?QÐ>RÐRdÐei×eqÑeqÐdrÐsÓtÐtà×ÓØ�{‰{Ô2×6Ñ6Ô8K×8PÑ8PÐQÓQØ×#Ò# qÑ(Õ#Ü1×8Ñ8�”Ø"&�•ä,Ó.Ð.ð  ÷	 ð2	Ø Ð)ˆFðÜÐ1´6¸7ÔKÈuØ×.Ò.Ñ8°Ò8÷ LäÐ.´¸ÔHÈEØ×+Ò+Ñ5¨fÒ5÷ Iô Ð1´6¸7ÔKÈuð ×2Ò2Ñ<°VÑ<ñØ ØØ!ØØ!ð !ØØ!Øð	&�Ô"÷ Lð "×1Ñ1ˆNð ˜#“ G§N¡N°jÓ$@ÀsÈfÕGZÐWZÖGZÜ!4°^À]Ó!S�äØØÜ2°4ÓAà$0Ø%2Ø&4ññ		ð 	÷Y Öú÷ LÕKúçHÕHûäó ñ ðú÷ LÕKûô> ó 	Ü#Õ%ÜÐ,¬f°gÔ>À%Ø×)Ñ)Ô+÷ ?×>Ö>ú÷ &ð ˆ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)rT   ÚtargetrH   ©r`   )rJ   Úgetr   r2   r   r   rT   rM   rb   rH   Ú_send_event©r7   r>   Útimeoutsr`   Úevents        r$   rP   Ú&HTTP11Connection._send_request_headers�   sŒ   € Ø×%Ñ%×)Ñ)¨)°RÓ8ˆØ—,‘,˜w¨Ó-ˆäœS×3Ñ3Ô5GÐHÕIÜ—K’KØ—~‘~Ø—{‘{×)Ñ)ØŸ™ñˆE÷ Jð 	×Ñ˜¨ÐÒ0÷ JÕIús   Á?B&Â&
B4c                ó²  • UR                   R                  S0 5      nUR                  SS 5      n[        UR                  [        R
                  5      (       d   e[        UR                  5       nU H&  n[        R                  " US9nU R                  XcS9  M(     S S S 5        U R                  [        R                  " 5       US9  g ! , (       d  f       N2= f)Nr`   ra   )Údatarc   )rJ   rd   Ú
isinstancer9   ÚtypingÚIterabler   r2   ÚDatare   ÚEndOfMessage)r7   r>   rg   r`   ÚiteratorÚchunkrh   s          r$   rQ   Ú#HTTP11Connection._send_request_body�   s¨   € Ø×%Ñ%×)Ñ)¨)°RÓ8ˆØ—,‘,˜w¨Ó-ˆä˜'Ÿ.™.¬&¯/©/×:Ñ:Ð:Ð:Ü˜'Ÿ.™.Ô)¨XÛ!�ÜŸš eÑ,�Ø× Ñ  Ð Ó8ñ "÷ *ð
 	×Ñœ×)Ò)Ó+°WÐÒ=÷ *Õ)ús   Á/-CÃ
Cc                ót   • U R                   R                  U5      nUb  U R                  R                  X2S9  g g )Nrc   )r6   Úsendr,   ra   )r7   rh   r`   Úbytes_to_sends       r$   re   Ú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`   Úreadrc   rB   s   HTTP/)rJ   rd   Ú_receive_eventrl   r2   r   ÚInformationalResponseÚstatus_coderD   rH   Ú	raw_itemsr6   r[   Úreason)	r7   r>   rg   r`   rh   rD   rH   r[   Ú_s	            r$   rR   Ú*HTTP11Connection._receive_response_headers    sÎ   € ð ×%Ñ%×)Ñ)¨)°RÓ8ˆØ—,‘,˜v tÓ,ˆàØ×'Ñ'°Ð'Ð8ˆEÜ˜%¤§¡×.Ñ.ØÜ˜%¤×!:Ñ!:×;Ñ;À×@QÑ@QÐUXÓ@XØñ ð   %×"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`   ry   rc   )
rJ   rd   rz   rl   r2   ro   Úbytesrk   rp   ÚPAUSEDrf   s        r$   Ú_receive_response_bodyÚ'HTTP11Connection._receive_response_body·   s‡   é € Ø×%Ñ%×)Ñ)¨)°RÓ8ˆØ—,‘,˜v tÓ,ˆàØ×'Ñ'°Ð'Ð8ˆEÜ˜%¤§¡×*Ñ*Ü˜EŸJ™JÓ'Ó'Ü˜E¤C×$4Ñ$4´c·j±jÐ#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)Nrc   r#   z/Server disconnected without sending a response.)r   r2   r	   r6   Ú
next_eventÚ	NEED_DATAr,   ry   ÚREAD_NUM_BYTESÚtheir_stateÚSEND_RESPONSEÚreceive_data)r7   r`   rh   rk   Úmsgs        r$   rz   ÚHTTP11Connection._receive_eventÂ   sµ   € ØÜ¤×!8Ñ!8Ô:MÐ NÕOØŸ™×2Ñ2Ó4�÷ Pð œŸ™Ò%Ø×+Ñ+×0Ñ0°×1DÑ1DÈgÐ0ÐV�ð ˜3“; 4§?¡?×#>Ñ#>Ä#×BSÑBSÓ#SØK�CÜ-¨cÓ2Ð2à—‘×,Ñ,¨TÕ2ð �ñ- ßOÕOús   ¡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)r0   r6   Ú	our_stater2   ÚDONErŠ   r   r    r/   Ústart_next_cycler-   ÚtimeÚ	monotonicr.   Úclose)r7   Únows     r$   rX   Ú!HTTP11Connection._response_closedÛ   s”   € Ø×ÓØ�‰×(Ñ(¬C¯H©HÒ4¸¿¹×9TÑ9TÔX[×X`ÑX`Ò9`Ü1×6Ñ6�”Ø—‘×0Ñ0Ô2Ø×)Ñ)Ñ5ÜŸ.š.Ó*�CØ&)×,BÑ,BÑ&B�D”Oøà—
‘
”÷ ×Öús   �CCÃ
C(c                ób   • [         R                  U l        U R                  R	                  5         g r�   )r   r!   r/   r,   r–   ©r7   s    r$   r–   ÚHTTP11Connection.closeè   s#   € ô *×0Ñ0ˆŒØ×Ñ×"Ñ"Õ$r#   c                ó   • XR                   :H  $ r�   )r+   ©r7   r8   s     r$   rL   Ú#HTTP11Connection.can_handle_requestò   s   € ØŸ™Ñ%Ð%r#   c                ó,   • U R                  5       (       + $ r�   )Ú	is_closedrš   s    r$   Úis_connectedÚHTTP11Connection.is_connectedõ   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                  nUS L=(       a    X:„  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)r7   r—   Ú	expire_atÚkeepalive_expiredÚserver_disconnecteds        r$   Úhas_expiredÚHTTP11Connection.has_expiredÿ   sm   € Ü�nŠnÓˆð —O‘Oˆ	Ø%¨TÐ1×E°c±oÐð
 #Ÿk™kÔ-@×-EÑ-EÑE÷ 
È$×J^ÑJ^×JmÑJmØóK
Ðð !×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$   r    Ú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/   Únamer1   r�   s     r$   ÚinfoÚHTTP11Connection.info  s:   € Ü�T—\‘\Ó"ˆØ‘˜<¨¯©×(8Ñ(8Ð'9Ð9JÈ4×K^ÑK^ÐJ_Ð`Ð`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·   r1   )r7   Ú
class_namer8   s      r$   Ú__repr__ÚHTTP11Connection.__repr__  sU   € Ø—^‘^×,Ñ,ˆ
Ü�T—\‘\Ó"ˆØ�:�,˜b ¡
¨"¨T¯[©[×-=Ñ-=Ð,>Ð>OÐPT×PcÑPcÐOdÐdfÐgÐgr#   c                ó   • U $ r�   r   rš   s    r$   Ú	__enter__ÚHTTP11Connection.__enter__!  s   € Øˆr#   c                ó$   • U R                  5         g r�   )r–   )r7   Úexc_typeÚ	exc_valueÚ	tracebacks       r$   Ú__exit__ÚHTTP11Connection.__exit__$  s   € ð 	�
‰
�r#   )r.   r6   r-   r,   r+   r1   r/   r0   r�   )r8   r   r9   r   r:   úfloat | NoneÚreturnÚNone)r>   r   rÊ   r   )r>   r   rÊ   rË   )rh   z	h11.Eventr`   rÉ   rÊ   rË   )r>   r   rÊ   z:tuple[bytes, int, bytes, list[tuple[bytes, bytes]], bytes])r>   r   rÊ   úGenerator[bytes])r`   rÉ   rÊ   zh11.Event | type[h11.PAUSED]©rÊ   rË   )r8   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‰   r5   r;   r]   rP   rQ   re   rR   r„   rz   rX   r–   rL   r¡   r¥   r­   r°   r    r¸   r¾   rÁ   rÇ   r"   r   r#   r$   r&   r&   )   sé   † Ø€NØ *Ðð *.ð	
àð
ð ð
ð 'ð	
ð
 
õ
ô$>ôD
1ô
>öGðUØðUà	CôUô.	öô2	ô%ô&ô$ô7ô8ô 7ô9ôaôhôð
 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)
rV   i-  c                ó*   • Xl         X l        SU l        g )NF)Ú_connectionÚ_requestÚ_closed)r7   Ú
connectionr>   s      r$   r;   Ú#HTTP11ConnectionByteStream.__init__.  s   € Ø%ÔØŒØˆ�r#   c              #  óÀ  #   • SU R                   0n [        S[        U R                   U5         [        U R                  R
                  " S0 UD65       nU H  nUv •  M	     S S S 5        S S S 5        g ! , (       d  f       N= f! , (       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   rO   r   rÑ   r„   rW   r   r–   )r7   rY   rq   rr   r\   s        r$   Ú__iter__Ú#HTTP11ConnectionByteStream.__iter__3  s±   é € Ø˜TŸ]™]Ð+ˆð	ÜÐ.´¸¿¹ÀvÕNÜ! $×"2Ñ"2×"IÒ"IÑ"SÈFÑ"SÔTÐX`Û!)˜Ø#œñ "*÷ U÷ OÐNßTÕTú÷ OÕNûô ó 	ô $Õ%Ø—
‘
”÷ &àˆI÷ &Ô%àˆIþð	üs{   ‚C’B ®&BÁA3Á"BÁ*B Á2CÁ3
B	Á=BÂ
BÂB ÂCÂB Â
CÂ
CÂ)CÂ:
CÃ
C	ÃCÃCÃC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)NTrK   )rÓ   r   rO   rÒ   rÑ   rX   rš   s    r$   r–   Ú HTTP11ConnectionByteStream.closeB  sH   € Ø�|�|ØˆDŒLÜÐ(¬&°$·-±-Õ@Ø× Ñ ×1Ñ1Ô3÷ AÐ@ð ç@Õ@ús   ´AÁ
A')rÓ   rÑ   rÒ   N)rÔ   r&   r>   r   rÊ   rË   )rÊ   rÌ   rÍ   )r   r   r   r   r;   rØ   r–   r"   r   r#   r$   rV   rV   -  s   † ôô
÷4r#   rV   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)rU   iI  c                ó   • Xl         X l        g r�   )Ú_streamÚ_leading_data)r7   r9   Úleading_datas      r$   r;   ÚHTTP11UpgradeStream.__init__J  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Þ   ry   )r7   Ú	max_bytesr`   Úbuffers       r$   ry   ÚHTTP11UpgradeStream.readN  sL   € Ø××Ø×'Ñ'¨
¨Ð3ˆFØ!%×!3Ñ!3°I°JÐ!?ˆDÔØˆMà—<‘<×$Ñ$ YÓ8Ð8r#   c                ó:   • U R                   R                  X5        g r�   )rÞ   ra   )r7   rä   r`   s      r$   ra   ÚHTTP11UpgradeStream.writeV  s   € Ø�‰×Ñ˜6Õ+r#   c                ó8   • U R                   R                  5         g r�   )rÞ   r–   rš   s    r$   r–   ÚHTTP11UpgradeStream.closeY  s   € Ø�‰×ÑÕr#   c                ó:   • U R                   R                  XU5      $ r�   )rÞ   Ú	start_tls)r7   Ússl_contextÚserver_hostnamer`   s       r$   rë   ÚHTTP11UpgradeStream.start_tls\  s   € ð �|‰|×%Ñ% kÀGÓLÐLr#   c                ó8   • U R                   R                  U5      $ r�   )rÞ   r©   )r7   r¸   s     r$   r©   Ú"HTTP11UpgradeStream.get_extra_infod  s   € Ø�|‰|×*Ñ*¨4Ó0Ð0r#   )rß   rÞ   )r9   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   r;   ry   ra   r–   rë   r©   r"   r   r#   r$   rU   rU   I  sS   † ô*ö9ö,ôð '+Ø $ð	Mà#ðMð $ðMð ð	Mð
 
õM÷1r#   rU   )*Ú
__future__r   ÚenumÚloggingÚsslr”   Útypesrm   Úcollections.abcr   r2   Ú_backends.baser   Ú_exceptionsr   r   r	   r
   r   Ú_modelsr   r   r   Ú_synchronizationr   r   Ú_tracer   Ú_utilsr   Ú
interfacesr   Ú	getLoggerrO   ro   rp   ÚH11SendEventÚIntEnumr   r&   rV   rU   r   r#   r$   Ú<module>r     s§   ðÝ "ã Û Û 
Û Û Û Ý %ã 
å *÷õ ÷ 0Ñ /ß 7Ý Ý !Ý +à	×	Ò	Ð-Ó	.€ð �{‰{˜SŸX™XÑ%¨×(8Ñ(8Ñ8€ô˜$Ÿ,™,ô ôAÐ*ô A÷H4ñ 4ô81˜-õ 1r#   