Ë
    CØïi°!  ã            	       ó¬   — d dl Z d dlmZ d dlmZmZmZ ddlmZ ddl	m
Z
mZmZmZ ddlmZmZ ddlmZmZ dd	lmZmZmZ  G d
„ deeeeef      «      Zy)é    N)Úsuppress)ÚAnyÚOptionalÚTupleé   )ÚBaseProtocol)ÚClientOSErrorÚClientPayloadErrorÚServerDisconnectedErrorÚServerTimeoutError)ÚBaseTimerContextÚstatus_code_must_be_empty_body)ÚHttpResponseParserÚRawResponseMessage)ÚEMPTY_PAYLOADÚ	DataQueueÚStreamReaderc                   óh  ‡ — e Zd ZdZdej
                  ddfd„Zedefd„«       Z	edefd„«       Z
d*d„Zd*d	„Zdefd
„Zdee   ddfˆ fd„Zd*d„Zd*ˆ fd„Zd*ˆ fd„Zdeddfˆ fd„Zdededdfd„Zddddddddddœ	dee   dedededee   ded ed!ed"eddfd#„Zd*d$„Zd*d%„Zd*d&„Zd*d'„Zd(eddfd)„Z ˆ xZ!S )+ÚResponseHandlerz8Helper class to adapt between Protocol and StreamReader.ÚloopÚreturnNc                 óø   — t        j                  | |¬«       t        j                  | |«       d| _        d | _        d| _        d | _        d | _        d| _        d| _	        d | _
        d | _        d | _        d| _        y )N)r   Fó    é   )r   Ú__init__r   Ú_should_closeÚ_payloadÚ_skip_payloadÚ_payload_parserÚ_timerÚ_tailÚ	_upgradedÚ_parserÚ_read_timeoutÚ_read_timeout_handleÚ_timeout_ceil_threshold)Úselfr   s     úN/var/www/html/aiagents/fe/lib/python3.12/site-packages/aiohttp/client_proto.pyr   zResponseHandler.__init__   su   € Ü×Ñ˜d¨Õ.Ü×Ñ˜4 Ô&à"ˆÔà04ˆŒØ"ˆÔØ#ˆÔàˆŒàˆŒ
ØˆŒØ59ˆŒà.2ˆÔØCGˆÔ!à89ˆÕ$r   c                 ó   — | j                   S ©N)r"   ©r'   s    r(   ÚupgradedzResponseHandler.upgraded)   s   € à�~‰~Ðr   c                 ó2  — | j                   �| j                   j                  «       r| j                  ry| j                  xsW | j                  xsI | j	                  «       d uxs5 | j
                  d uxs% t        | «      dkD  xs t        | j                  «      S ©NTr   )	r   Úis_eofr"   r   Ú	exceptionr   ÚlenÚboolr!   r+   s    r(   Úshould_closezResponseHandler.should_close-   sŽ   € à�=‰=Ð$¨T¯]©]×-AÑ-AÔ-CÀtÇ~Â~Øð ×Ñò  Ø�~‰~ò à�~‰~Ó tÐ+ò ð ×#Ñ#¨4Ð/ò ô �4‹y˜1‰}ò	 ô
 �D—J‘JÓð	
r   c                 ó   — d| _         y ©NT)r   r+   s    r(   Úforce_closezResponseHandler.force_close;   s
   € Ø!ˆÕr   c                 ó~   — | j                   }|�/|j                  «        d | _         d | _        | j                  «        y y r*   )Ú	transportÚcloser   Ú_drop_timeout)r'   r8   s     r(   r9   zResponseHandler.close>   s:   € Ø—N‘Nˆ	ØÐ Ø�O‰OÔØ!ˆDŒNØ ˆDŒMØ×ÑÕ ð	 !r   c                 óX   — | j                   d uxr | j                   j                  «        S r*   )r8   Ú
is_closingr+   s    r(   Úis_connectedzResponseHandler.is_connectedF   s&   € Ø�~‰~ TÐ)ÒM°$·.±.×2KÑ2KÓ2MÐ.MÐMr   Úexcc                 óŽ  •— | j                  «        | j                  �2t        t        «      5  | j                  j	                  «        d d d «       d }| j
                  �	 | j
                  j	                  «       }| j                  «       s@t        |t        «      rt        |j                  Ž }|€t        |«      }| j                  |«       d| _        d | _        d | _        d | _        d| _        t"        ‰| �I  |«       y # 1 sw Y   ŒµxY w# t        $ r3 | j                  �$| j                  j                  t        d«      «       Y ŒÊw xY w)Nz!Response payload is not completedTF)r:   r   r   Ú	ExceptionÚfeed_eofr#   r   Úset_exceptionr
   r/   Ú
isinstanceÚOSErrorr	   Úargsr   r   Ú_reading_pausedÚsuperÚconnection_lost)r'   r>   ÚuncompletedÚ	__class__s      €r(   rH   zResponseHandler.connection_lostI   s  ø€ Ø×ÑÔà×ÑÐ+Üœ)Ó$ñ 0Ø×$Ñ$×-Ñ-Ô/÷0ð ˆØ�<‰<Ð#ðØ"Ÿl™l×3Ñ3Ó5�ð �{‰{Œ}Ü˜#œwÔ'Ü# S§X¡XÐ.�Øˆ{Ü-¨kÓ:�ð ×Ñ˜sÔ#à!ˆÔØˆŒØˆŒØ#ˆÔØ$ˆÔä‰Ñ Õ$÷90ð 0ûô ò Ø—=‘=Ð,Ø—M‘M×/Ñ/Ü*Ð+NÓOôùðús   ­C<ÁD Ã<DÄ9EÅEc                 ó$   — | j                  «        y r*   )r:   r+   s    r(   Úeof_receivedzResponseHandler.eof_receivedk   s   € à×ÑÕr   c                 óB   •— t         ‰| �  «        | j                  «        y r*   )rG   Úpause_readingr:   ©r'   rJ   s    €r(   rN   zResponseHandler.pause_readingo   s   ø€ Ü‰ÑÔØ×ÑÕr   c                 óB   •— t         ‰| �  «        | j                  «        y r*   )rG   Úresume_readingÚ_reschedule_timeoutrO   s    €r(   rQ   zResponseHandler.resume_readings   s   ø€ Ü‰ÑÔ Ø× Ñ Õ"r   c                 óR   •— d| _         | j                  «        t        ‰| �  |«       y r5   )r   r:   rG   rB   )r'   r>   rJ   s     €r(   rB   zResponseHandler.set_exceptionw   s$   ø€ Ø!ˆÔØ×ÑÔÜ‰Ñ˜cÕ"r   ÚparserÚpayloadc                 ó¤   — || _         || _        | j                  «        | j                  r&| j                  dc}| _        | j	                  |«       y y )Nr   )r   r   r:   r!   Údata_received)r'   rT   rU   Údatas       r(   Ú
set_parserzResponseHandler.set_parser|   sK   € ð  ˆŒØ%ˆÔà×ÑÔà�:Š:Ø#Ÿz™z¨3ÐˆD�$”*Ø×Ñ˜tÕ$ð r   FTi   r   iþ  )	ÚtimerÚskip_payloadÚread_until_eofÚauto_decompressÚread_timeoutÚread_bufsizeÚtimeout_ceil_thresholdÚmax_line_sizeÚmax_field_sizerZ   r[   r\   r]   r^   r_   r`   ra   rb   c       	         óä   — || _         || _        || _        t        | | j                  ||t
        | ||||	¬«
      | _        | j                  r&| j                  dc}
| _        | j                  |
«       y y )N)rZ   Úpayload_exceptionÚresponse_with_bodyr\   r]   ra   rb   r   )	r   r$   r&   r   Ú_loopr
   r#   r!   rW   )r'   rZ   r[   r\   r]   r^   r_   r`   ra   rb   rX   s              r(   Úset_response_paramsz#ResponseHandler.set_response_params‹   s{   € ð *ˆÔà)ˆÔà'=ˆÔ$ä)ØØ�J‰JØØÜ0Ø#/Ð/Ø)Ø+Ø'Ø)ô
ˆŒð �:Š:Ø#Ÿz™z¨3ÐˆD�$”*Ø×Ñ˜tÕ$ð r   c                 ó`   — | j                   �"| j                   j                  «        d | _         y y r*   )r%   Úcancelr+   s    r(   r:   zResponseHandler._drop_timeout¯   s-   € Ø×$Ñ$Ð0Ø×%Ñ%×,Ñ,Ô.Ø(,ˆDÕ%ð 1r   c                 óÒ   — | j                   }| j                  �| j                  j                  «        |r,| j                  j	                  || j
                  «      | _        y d | _        y r*   )r$   r%   ri   rf   Ú
call_laterÚ_on_read_timeout)r'   Útimeouts     r(   rR   z#ResponseHandler._reschedule_timeout´   sZ   € Ø×$Ñ$ˆØ×$Ñ$Ð0Ø×%Ñ%×,Ñ,Ô.áØ(,¯
©
×(=Ñ(=Ø˜×.Ñ.ó)ˆDÕ%ð )-ˆDÕ%r   c                 ó$   — | j                  «        y r*   )rR   r+   s    r(   Ústart_timeoutzResponseHandler.start_timeoutÀ   s   € Ø× Ñ Õ"r   c                 óŒ   — t        d«      }| j                  |«       | j                  �| j                  j                  |«       y y )Nz#Timeout on reading data from socket)r   rB   r   )r'   r>   s     r(   rl   z ResponseHandler._on_read_timeoutÃ   s<   € Ü Ð!FÓGˆØ×Ñ˜3ÔØ�=‰=Ð$Ø�M‰M×'Ñ'¨Õ,ð %r   rX   c                 óš  — | j                  «        |sy | j                  �B| j                  j                  |«      \  }}|r!d | _        d | _        |r| j	                  |«       y | j
                  s| j                  €| xj                  |z  c_        y 	 | j                  j                  |«      \  }}}|| _        d }|D ]m  \  }}|j                  rd| _        || _        | j                  st        |j                   «      r| j                  |t"        fd«       ŒZ| j                  ||fd«       Œo |�4|t"        ur|j%                  | j&                  «       n| j'                  «        |r|r| j	                  |«       y || _        y y # t        $ rA}| j                  �| j                  j                  «        | j                  |«       Y d }~y d }~ww xY wr.   )rR   r   Ú	feed_datar   rW   r"   r#   r!   ÚBaseExceptionr8   r9   rB   r3   r   r   r   Úcoder   Úon_eofr:   )	r'   rX   ÚeofÚtailÚmessagesr,   r>   rU   Úmessages	            r(   rW   zResponseHandler.data_receivedÉ   sª  € Ø× Ñ Ô"áØð ×ÑÐ+Ø×,Ñ,×6Ñ6°tÓ<‰IˆC�ÙØ $�”Ø'+�Ô$áØ×&Ñ& tÔ,Øà�~Š~ §¡Ð!5à—
’
˜dÑ"–
ð
Ø/3¯|©|×/EÑ/EÀdÓ/KÑ,�H˜h¨ð "*�”à26�Ø(0ò >Ñ$�G˜WØ×+Ò+Ø-1˜Ô*à$+�D”Mà×)Ò)Ô-KØŸ™ô.ð Ÿ™¨´Ð'?ÀÕCàŸ™¨°Ð'9¸1Õ=ð>ð Ð&ð
 ¤mÑ3ØŸ™ t×'9Ñ'9Õ:à×*Ñ*Ô,áÙØ×*Ñ*¨4Õ0à%)˜�
ð	 øôG %ò Ø—~‘~Ð1ð Ÿ™×,Ñ,Ô.à×&Ñ& sÔ+Üûðús   ÂF  Æ 	G
Æ	7GÇG
)r   N)"Ú__name__Ú
__module__Ú__qualname__Ú__doc__ÚasyncioÚAbstractEventLoopr   Úpropertyr2   r,   r3   r6   r9   r=   r   rs   rH   rL   rN   rQ   rB   r   rY   r   ÚfloatÚintrg   r:   rR   ro   rl   ÚbytesrW   Ú__classcell__)rJ   s   @r(   r   r      sz  ø„ ÙBð:˜W×6Ñ6ð :¸4ó :ð* ð˜$ò ó ðð ð
˜dò 
ó ð
ó"ó!ðN˜dó Nð % 8¨MÑ#:ð  %¸tõ  %óDõõ#ð# ð #°4õ #ð
% ð %¨sð %°tó %ð$ -1Ø"Ø$Ø $Ø(,Ø!Ø()Ø!Ø"ò"%ð Ð(Ñ)ð"%ð ð	"%ð
 ð"%ð ð"%ð ˜u‘oð"%ð ð"%ð !&ð"%ð ð"%ð ð"%ð 
ó"%óH-ó

-ó#ó-ð?* %ð ?*¨D÷ ?*r   r   )r~   Ú
contextlibr   Útypingr   r   r   Úbase_protocolr   Úclient_exceptionsr	   r
   r   r   Úhelpersr   r   Úhttpr   r   Ústreamsr   r   r   r   © r   r(   ú<module>r�      sM   ðÛ Ý ß 'Ñ 'å '÷ó ÷ Fß 8ß ;Ñ ;ôw*�l I¨eÐ4FÈÐ4TÑ.UÑ$Võ w*r   