Ë
    ìO´j¯4  ã                  óž  — d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlm	Z	 d dl
Z
ddlmZ ddlmZmZmZmZmZ ddlmZmZmZ ddlmZmZ dd	lmZ dd
lmZ ddlmZ  ej@                  d«      Z!e
j*                  e
jD                  z  e
jF                  z  Z$ G d„ dejJ                  «      Z& G d„ de«      Z' G d„ d«      Z( G d„ de«      Z)y)é    )ÚannotationsN)Ú	Generatoré   )ÚNetworkStream)ÚConnectionNotAvailableÚLocalProtocolErrorÚRemoteProtocolErrorÚ
WriteErrorÚmap_exceptions)ÚOriginÚRequestÚResponse)ÚLockÚShieldCancellation)ÚTrace)Úsafe_iterateé   )ÚConnectionInterfacezhttpcore2.http11c                  ó   — e Zd ZdZdZdZdZy)ÚHTTPConnectionStater   r   r   é   N)Ú__name__Ú
__module__Ú__qualname__ÚNEWÚACTIVEÚIDLEÚCLOSED© ó    úm/var/www/origus_pro_usr/data/www/origus.pro/core/.venv/lib/python3.12/site-packages/httpcore2/_sync/http11.pyr   r   "   s   „ Ø
€CØ€FØ€DØ�Fr    r   c                  óè   — e Zd ZdZdZ	 d	 	 	 	 	 	 	 dd„Zdd„Zdd„Zdd„Zddd„Z		 	 	 	 dd	„Z
dd
„Zddd„Zd d„Zd d„Zd!d„Zd"d„Zd"d„Zd"d„Zd"d„Zd"d„Zd#d„Zd#d„Zd$d„Z	 	 	 d%	 	 	 	 	 	 	 d&d„Zy)'ÚHTTP11Connectioni   i � Nc                óú   — || _         || _        || _        d | _        t        j
                  | _        t        «       | _        d| _	        t        j                  t        j                  | j                  ¬«      | _        y )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__zHTTP11Connection.__init__-   sa   € ð ˆŒØ%ˆÔØ/?ˆÔØ(,ˆŒÜ)×-Ñ-ˆŒÜ›6ˆÔØˆÔÜŸ.™.Ü—Z‘ZØ&*×&DÑ&Dô
ˆ�r    c           	     óâ  — | j                  |j                  j                  «      s/t        d|j                  j                  › d| j                  › �«      ‚| j
                  5  | j                  t        j                  t        j                  fv r2| xj                  dz  c_
        t        j                  | _        d | _        n
t        «       ‚	 d d d «       	 d|i}	 t        dt        ||«      5 } | j                   di |¤Ž d d d «       t        dt        ||«      5 } | j"                  di |¤Ž d d d «       t        dt        ||«      5 } | j&                  di |¤Ž\  }}}}}||||f|_        d d d «       | j*                  }	dk(  s|j,                  d	k(  rd
|cxk  rdk  rn nt/        |	«      }	t1        |t3        | |«      |	dœ¬«      S # 1 sw Y   ŒþxY w# 1 sw Y   Œ×xY w# 1 sw Y   Œ¶xY w# t$        $ r Y ŒÄw xY w# 1 sw Y   Œ“xY w# t4        $ r^}
t7        «       5  t        dt        |«      5 }| j9                  «        d d d «       n# 1 sw Y   nxY wd d d «       |
‚# 1 sw Y   |
‚xY wd }
~
ww xY w)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Úurlr4   Ú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)r3   r9   ÚkwargsÚtracer?   rB   r@   rC   Útrailing_datarA   Úexcs              r!   Úhandle_requestzHTTP11Connection.handle_request?   sƒ  € Ø×&Ñ& 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ÀFÓKð 9ÈuØ.�D×.Ñ.Ñ8°Ò8÷9äÐ.´¸ÀÓHð 6ÈEØ+�D×+Ñ+Ñ5¨fÒ5÷6ô Ð1´6¸7ÀFÓKð Èuð 3�D×2Ñ2Ñ<°VÑ<ñØ ØØ!ØØ!ð !ØØ!Øð	&�Ô"÷ð "×1Ñ1ˆNð ˜#’ G§N¡N°jÒ$@ÀsÈfÔGZÐWZÕGZÜ!4°^À]Ó!S�äØØÜ2°4¸ÓAà$0Ø%2Ø&4ñô		ð 	÷Y	/ð 	/ú÷9ð 9ú÷6ð 6ûäò ñ ðú÷ð ûô> ò 	Ü#Ó%ñ ,ÜÐ,¬f°gÓ>ð ,À%Ø×)Ñ)Ô+÷,÷ ,ñ ,ú÷,ð ˆI÷,ð ˆIþð		úsÂ   Á!A)GÃH ÃG, Ã+GÃ>G, ÄG Ä+G, Ä3H Å$G;Å)AH ÇGÇGÇG, Ç G)Ç%G, Ç,	G8Ç5H Ç7G8Ç8H Ç;HÈ H È	I.È
I)ÈIÈ,IÈ=	IÉIÉIÉ
I)ÉI&	É!I)É)I.c                ón  — |j                   j                  di «      }|j                  dd «      }t        t        j                  t        i«      5  t        j
                  |j                  |j                  j                  |j                  ¬«      }d d d «       | j                  |¬«       y # 1 sw Y   ŒxY w)NÚtimeoutÚwrite)rO   ÚtargetrC   ©rZ   )rE   Úgetr   r.   r   r   rO   rH   r\   rC   Ú_send_event©r3   r9   ÚtimeoutsrZ   Úevents        r!   rK   z&HTTP11Connection._send_request_headers�   s‘   € Ø×%Ñ%×)Ñ)¨)°RÓ8ˆØ—,‘,˜w¨Ó-ˆäœS×3Ñ3Ô5GÐHÓIñ 	Ü—K‘KØ—~‘~Ø—{‘{×)Ñ)ØŸ™ôˆE÷	ð 	×Ñ˜¨ÐÕ0÷	ð 	ús   ÁAB+Â+B4c                ó¬  — |j                   j                  di «      }|j                  dd «      }t        |j                  t        j
                  «      sJ ‚t        |j                  «      5 }|D ]+  }t        j                  |¬«      }| j                  ||¬«       Œ- 	 d d d «       | j                  t        j                  «       |¬«       y # 1 sw Y   Œ/xY w)NrZ   r[   )Údatar]   )rE   r^   Ú
isinstancer5   ÚtypingÚIterabler   r.   ÚDatar_   ÚEndOfMessage)r3   r9   ra   rZ   ÚiteratorÚchunkrb   s          r!   rL   z#HTTP11Connection._send_request_body�   s³   € Ø×%Ñ%×)Ñ)¨)°RÓ8ˆØ—,‘,˜w¨Ó-ˆä˜'Ÿ.™.¬&¯/©/Ô:Ð:Ð:Ü˜'Ÿ.™.Ó)ð 	9¨XØ!ò 9�ÜŸ™ eÔ,�Ø× Ñ  °Ð Õ8ñ9÷	9ð
 	×Ñœ×)Ñ)Ó+°WÐÕ=÷	9ð 	9ús   Á*1C
Ã
Cc                óz   — | j                   j                  |«      }|�| j                  j                  ||¬«       y y )Nr]   )r2   Úsendr(   r[   )r3   rb   rZ   Úbytes_to_sends       r!   r_   zHTTP11Connection._send_event™   s:   € ØŸ™×,Ñ,¨UÓ3ˆØÐ$Ø× Ñ ×&Ñ& }¸gÐ&ÕFð %r    c                óÊ  — |j                   j                  di «      }|j                  dd «      }	 | j                  |¬«      }t        |t        j
                  «      rn+t        |t        j                  «      r|j                  dk(  rnŒXd|j                  z   }|j                  j                  «       }| j                  j                  \  }}||j                  |j                  ||fS )NrZ   Úreadr]   r=   s   HTTP/)rE   r^   Ú_receive_eventre   r.   r   ÚInformationalResponseÚstatus_coder?   rC   Ú	raw_itemsr2   rV   Úreason)	r3   r9   ra   rZ   rb   r?   rC   rV   Ú_s	            r!   rM   z*HTTP11Connection._receive_response_headers    sÎ   € ð ×%Ñ%×)Ñ)¨)°RÓ8ˆØ—,‘,˜v tÓ,ˆàØ×'Ñ'°Ð'Ó8ˆEÜ˜%¤§¡Ô.ØÜ˜%¤×!:Ñ!:Ô;À×@QÑ@QÐUXÒ@XØð ð   %×"4Ñ"4Ñ4ˆð —-‘-×)Ñ)Ó+ˆàŸ?™?×8Ñ8Ñˆ�qà˜U×.Ñ.°·±¸gÀ}ÐTÐTr    c              #  óH  K  — |j                   j                  di «      }|j                  dd «      }	 | j                  |¬«      }t        |t        j
                  «      rt        |j                  «      –— n+t        |t        j                  t        j                  f«      ry Œp­w)NrZ   rp   r]   )
rE   r^   rq   re   r.   rh   Úbytesrd   ri   ÚPAUSEDr`   s        r!   Ú_receive_response_bodyz'HTTP11Connection._receive_response_body·   s‚   è ø€ Ø×%Ñ%×)Ñ)¨)°RÓ8ˆØ—,‘,˜v tÓ,ˆàØ×'Ñ'°Ð'Ó8ˆEÜ˜%¤§¡Ô*Ü˜EŸJ™JÓ'Ó'Ü˜E¤C×$4Ñ$4´c·j±jÐ#AÔBØð ùs   ‚B B"c                óÂ  — 	 t        t        j                  t        i«      5  | j                  j	                  «       }d d d «       t        j
                  u r|| j                  j                  | j                  |¬«      }|dk(  r4| j                  j                  t        j                  k(  rd}t        |«      ‚| j                  j                  |«       n|S ŒÓ# 1 sw Y   ŒšxY w)Nr]   r    z/Server disconnected without sending a response.)r   r.   r	   r2   Ú
next_eventÚ	NEED_DATAr(   rp   ÚREAD_NUM_BYTESÚtheir_stateÚSEND_RESPONSEÚreceive_data)r3   rZ   rb   rd   Úmsgs        r!   rq   zHTTP11Connection._receive_eventÂ   s½   € ØÜ¤×!8Ñ!8Ô:MÐ NÓOñ 5ØŸ™×2Ñ2Ó4�÷5ð œŸ™Ñ%Ø×+Ñ+×0Ñ0°×1DÑ1DÈgÐ0ÓV�ð ˜3’; 4§?¡?×#>Ñ#>Ä#×BSÑBSÒ#SØK�CÜ-¨cÓ2Ð2à—‘×,Ñ,¨TÕ2ð �ð- ÷5ð 5ús   ¡CÃCc                óÆ  — | j                   5  | j                  j                  t        j                  u rŠ| j                  j
                  t        j                  u rdt        j                  | _        | j                  j                  «        | j                  �9t        j                  «       }|| j                  z   | _        n| j                  «        d d d «       y # 1 sw Y   y xY w©N)r,   r2   Ú	our_stater.   ÚDONEr   r   r   r+   Ústart_next_cycler)   ÚtimeÚ	monotonicr*   Úclose)r3   Únows     r!   rS   z!HTTP11Connection._response_closedÛ   sž   € Ø×Ññ 	Ø�‰×(Ñ(¬C¯H©HÑ4¸¿¹×9TÑ9TÔX[×X`ÑX`Ñ9`Ü1×6Ñ6�”Ø—‘×0Ñ0Ô2Ø×)Ñ)Ð5ÜŸ.™.Ó*�CØ&)¨D×,BÑ,BÑ&B�D•Oà—
‘
”÷	÷ 	ñ 	ús   �CCÃC c                ób   — t         j                  | _        | j                  j	                  «        y r„   )r   r   r+   r(   rŠ   ©r3   s    r!   rŠ   zHTTP11Connection.closeè   s#   € ô *×0Ñ0ˆŒØ×Ñ×"Ñ"Õ$r    c                ó    — || j                   k(  S r„   )r'   ©r3   r4   s     r!   rG   z#HTTP11Connection.can_handle_requestò   s   € Ø˜Ÿ™Ñ%Ð%r    c                ó$   — | j                  «        S r„   )Ú	is_closedr�   s    r!   Úis_connectedzHTTP11Connection.is_connectedõ   s   € Ø—>‘>Ó#Ð#Ð#r    c                ó<   — | j                   t        j                  k(  S r„   ©r+   r   r   r�   s    r!   Úis_availablezHTTP11Connection.is_availableø   s   € ð
 �{‰{Ô1×6Ñ6Ñ6Ð6r    c                óØ   — t        j                  «       }| j                  }|d uxr ||kD  }| j                  t        j
                  k(  xr | j                  j                  d«      }|xs |S )NÚis_readable)rˆ   r‰   r*   r+   r   r   r(   Úget_extra_info)r3   r‹   Ú	expire_atÚkeepalive_expiredÚserver_disconnecteds        r!   Úhas_expiredzHTTP11Connection.has_expiredÿ   so   € Ü�n‰nÓˆð —O‘Oˆ	Ø%¨TÐ1ÒE°c¸I±oÐð
 #Ÿk™kÔ-@×-EÑ-EÑEò 
È$×J^ÑJ^×JmÑJmØóK
Ðð !Ò7Ð$7Ð7r    c                ó<   — | j                   t        j                  k(  S r„   r”   r�   s    r!   Úis_idlezHTTP11Connection.is_idle  s   € Ø�{‰{Ô1×6Ñ6Ñ6Ð6r    c                ó<   — | j                   t        j                  k(  S r„   )r+   r   r   r�   s    r!   r‘   zHTTP11Connection.is_closed  s   € Ø�{‰{Ô1×8Ñ8Ñ8Ð8r    c                ó|   — t        | j                  «      }|›d| j                  j                  › d| j                  › �S )Nz, HTTP/1.1, ú, Request Count: )Ústrr'   r+   Únamer-   r�   s     r!   ÚinfozHTTP11Connection.info  s:   € Ü�T—\‘\Ó"ˆØ�˜<¨¯©×(8Ñ(8Ð'9Ð9JÈ4×K^ÑK^ÐJ_Ð`Ð`r    c           	     ó²   — | j                   j                  }t        | j                  «      }d|› d|›d| j                  j
                  › d| j                  › d�	S )Nú<z [z, r¡   z]>)Ú	__class__r   r¢   r'   r+   r£   r-   )r3   Ú
class_namer4   s      r!   Ú__repr__zHTTP11Connection.__repr__  sU   € Ø—^‘^×,Ñ,ˆ
Ü�T—\‘\Ó"ˆØ�:�,˜b  
¨"¨T¯[©[×-=Ñ-=Ð,>Ð>OÐPT×PcÑPcÐOdÐdfÐgÐgr    c                ó   — | S r„   r   r�   s    r!   Ú	__enter__zHTTP11Connection.__enter__!  s   € Øˆr    c                ó$   — | j                  «        y r„   )rŠ   )r3   Úexc_typeÚ	exc_valueÚ	tracebacks       r!   Ú__exit__zHTTP11Connection.__exit__$  s   € ð 	�
‰
�r    r„   )r4   r   r5   r   r6   úfloat | NoneÚreturnÚNone)r9   r   r²   r   )r9   r   r²   r³   )rb   z	h11.EventrZ   r±   r²   r³   )r9   r   r²   z:tuple[bytes, int, bytes, list[tuple[bytes, bytes]], bytes])r9   r   r²   úGenerator[bytes])rZ   r±   r²   zh11.Event | type[h11.PAUSED]©r²   r³   )r4   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~   r1   r7   rX   rK   rL   r_   rM   rz   rq   rS   rŠ   rG   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                  ó$   — e Zd Zdd„Zdd„Zdd„Zy)rQ   c                ó.   — || _         || _        d| _        y )NF)Ú_connectionÚ_requestÚ_closed)r3   Ú
connectionr9   s      r!   r7   z#HTTP11ConnectionByteStream.__init__.  s   € Ø%ˆÔØˆŒØˆ�r    c              #  óž  K  — d| j                   i}	 t        dt        | j                   |«      5  t         | j                  j
                  di |¤Ž«      5 }|D ]  }|–— Œ 	 d d d «       d d d «       y # 1 sw Y   ŒxY w# 1 sw Y   y xY w# t        $ r7}t        «       5  | j                  «        d d d «       |‚# 1 sw Y   |‚xY wd }~ww xY w­w)Nr9   Úreceive_response_bodyr   )	rº   r   rJ   r   r¹   rz   rR   r   rŠ   )r3   rT   rj   rk   rW   s        r!   Ú__iter__z#HTTP11ConnectionByteStream.__iter__3  sË   è ø€ Ø˜TŸ]™]Ð+ˆð	ÜÐ.´¸¿¹ÀvÓNñ $Ü!Ð"I $×"2Ñ"2×"IÑ"IÑ"SÈFÑ"SÓTð $ÐX`Ø!)ò $˜Ø#›ñ$÷$÷$ð $÷$ð $ú÷$ð $ûô ò 	ô $Ó%ñ Ø—
‘
”÷àˆI÷àˆIþð	üs{   ‚C’B
 ®&A>ÁA2Á!A>Á)B
 Á1CÁ2A;	Á7A>Á>BÂB
 ÂCÂB
 Â
	C
Â
CÂB8Â.
CÂ8C	Â=CÃC
Ã
Cc                óÀ   — | j                   sFd| _         t        dt        | j                  «      5  | j                  j                  «        d d d «       y y # 1 sw Y   y xY w)NTrF   )r»   r   rJ   rº   r¹   rS   r�   s    r!   rŠ   z HTTP11ConnectionByteStream.closeB  sR   € Ø�|Š|ØˆDŒLÜÐ(¬&°$·-±-Ó@ñ 4Ø× Ñ ×1Ñ1Ô3÷4ð 4ð ÷4ð 4ús   ¯AÁAN)r¼   r#   r9   r   r²   r³   )r²   r´   rµ   )r   r   r   r7   r¿   rŠ   r   r    r!   rQ   rQ   -  s   „ óó
ô4r    rQ   c                  óT   — e Zd Zdd„Zd	d
d„Zd	dd„Zdd„Z	 	 d	 	 	 	 	 	 	 dd„Zdd„Zy)rP   c                ó    — || _         || _        y r„   )Ú_streamÚ_leading_data)r3   r5   Úleading_datas      r!   r7   zHTTP11UpgradeStream.__init__J  s   € ØˆŒØ)ˆÕr    Nc                óœ   — | j                   r%| j                   d | }| j                   |d  | _         |S | j                  j                  ||«      S r„   )rÄ   rÃ   rp   )r3   Ú	max_bytesrZ   Úbuffers       r!   rp   zHTTP11UpgradeStream.readN  sN   € Ø×ÒØ×'Ñ'¨
¨Ð3ˆFØ!%×!3Ñ!3°I°JÐ!?ˆDÔØˆMà—<‘<×$Ñ$ Y°Ó8Ð8r    c                ó<   — | j                   j                  ||«       y r„   )rÃ   r[   )r3   rÈ   rZ   s      r!   r[   zHTTP11UpgradeStream.writeV  s   € Ø�‰×Ñ˜6 7Õ+r    c                ó8   — | j                   j                  «        y r„   )rÃ   rŠ   r�   s    r!   rŠ   zHTTP11UpgradeStream.closeY  s   € Ø�‰×ÑÕr    c                ó<   — | j                   j                  |||«      S r„   )rÃ   Ú	start_tls)r3   Ússl_contextÚserver_hostnamerZ   s       r!   rÌ   zHTTP11UpgradeStream.start_tls\  s   € ð �|‰|×%Ñ% k°?ÀGÓLÐLr    c                ó8   — | j                   j                  |«      S r„   )rÃ   r˜   )r3   r¤   s     r!   r˜   z"HTTP11UpgradeStream.get_extra_infod  s   € Ø�|‰|×*Ñ*¨4Ó0Ð0r    )r5   r   rÅ   rx   r²   r³   r„   )rÇ   ÚintrZ   r±   r²   rx   )rÈ   rx   rZ   r±   r²   r³   rµ   )NN)rÍ   zssl.SSLContextrÎ   z
str | NonerZ   r±   r²   r   )r¤   r¢   r²   z
typing.Any)	r   r   r   r7   rp   r[   rŠ   rÌ   r˜   r   r    r!   rP   rP   I  sS   „ ó*ô9ô,óð '+Ø $ð	Mà#ðMð $ðMð ð	Mð
 
óMô1r    rP   )*Ú
__future__r   ÚenumÚloggingÚsslrˆ   Útypesrf   Úcollections.abcr   r.   Ú_backends.baser   Ú_exceptionsr   r   r	   r
   r   Ú_modelsr   r   r   Ú_synchronizationr   r   Ú_tracer   Ú_utilsr   Ú
interfacesr   Ú	getLoggerrJ   rh   ri   ÚH11SendEventÚIntEnumr   r#   rQ   rP   r   r    r!   ú<module>rá      s©   ðÝ "ã Û Û 
Û Û Û Ý %ã 
å *÷õ ÷ 0Ñ /ß 7Ý Ý !Ý +à	ˆ×	Ñ	Ð-Ó	.€ð �{‰{˜SŸX™XÑ%¨×(8Ñ(8Ñ8€ô˜$Ÿ,™,ô ôAÐ*ô A÷H4ñ 4ô81˜-õ 1r    