§
    ~Štjž1  ã            	       óÜ   — d dl Z d dlmZ d dlmZm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mZmZmZ ddlmZmZ dd	lmZ dd
lmZmZmZ  G d„ deeeeef                  ¦  «        ZdS )é    N)Úsuppress)ÚAnyÚCallableé   )ÚBaseProtocol)ÚClientConnectionErrorÚClientOSErrorÚClientPayloadErrorÚServerDisconnectedErrorÚSocketTimeoutError)Ú_EXC_SENTINELÚDEFAULT_CHUNK_SIZEÚEMPTY_BODY_STATUS_CODESÚBaseTimerContextÚset_exceptionÚ
set_result)ÚHttpResponseParserÚRawResponseMessage)ÚHttpProcessingError)ÚEMPTY_PAYLOADÚ	DataQueueÚStreamReaderc                   ó2  ‡ — e Zd ZdZdej        ddfd„Zeddej        d         z  fd„¦   «         Z	ede
fd„¦   «         Zede
fd„¦   «         Zd2d	„Zd2d
„Zd2d„Zde
fd„Zdedz  ddfˆ fd„Zd2d„Zd2ˆ fd„Zd3de
ddfˆ fd„Zefdededdfˆ fd„Z	 d4dededeg df         dz  ddfd„Zdddddedddddœ
dedz  d e
d!e
d"e
d#edz  d$ed%ed&ed'ed(eddfd)„Zd2d*„Z d2d+„Z!d2d,„Z"ededz  fd-„¦   «         Z#e#j$        d#edz  ddfd.„¦   «         Z#d2d/„Z%d0e&ddfd1„Z'ˆ xZ(S )5ÚResponseHandlerz8Helper class to adapt between Protocol and StreamReader.ÚloopÚreturnNc                 ó  — t          j        | |d ¬¦  «         t          j        | |¦  «         d| _        d | _        d| _        d | _        d | _        d | _        d| _	        d | _
        d | _        d| _        d | _        d| _        d S )N)r   ÚparserFó    é   )r   Ú__init__r   Ú_should_closeÚ_payloadÚ_skip_payloadÚ_payload_parserÚ_data_received_cbÚ_timerÚ_tailÚ_read_timeoutÚ_read_timeout_handleÚ_timeout_ceil_thresholdÚ_closedÚ_connection_lost_called)Úselfr   s     úR/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/aiohttp/client_proto.pyr!   zResponseHandler.__init__   s�   € ÝÔ˜d¨°dÐ;Ñ;Ô;Ð;ÝÔ˜4 Ñ&Ô&Ð&à"ˆÔà-1ˆŒØ"ˆÔØ#ˆÔØ<@ˆÔàˆŒØˆŒ
à+/ˆÔØ@DˆÔ!à56ˆÔ$à48ˆŒØ',ˆÔ$Ð$Ð$r   c                 óh   — | j         €%| j        s| j                             ¦   «         | _         | j         S )a6  Future that is set when the connection is closed.

        This property returns a Future that will be completed when the connection
        is closed. The Future is created lazily on first access to avoid creating
        futures that will never be awaited.

        Returns:
            - A Future[None] if the connection is still open or was closed after
              this property was accessed
            - None if connection_lost() was already called before this property
              was ever accessed (indicating no one is waiting for the closure)
        )r,   r-   Ú_loopÚcreate_future©r.   s    r/   ÚclosedzResponseHandler.closed3   s1   € ð Œ<Ð¨Ô(DÐØœ:×3Ò3Ñ5Ô5ˆDŒLØŒ|Ðr   c                 ó   — | j         S ©N)Ú	_upgradedr3   s    r/   ÚupgradedzResponseHandler.upgradedE   s
   € àŒ~Ðr   c                 ó¾   — t          | j        pI| j        d uo| j                             ¦   «          p&| j        p| j        d up| j        d up| j        p| j        ¦  «        S r6   )	Úboolr"   r#   Úis_eofr7   Ú
_exceptionr%   Ú_bufferr(   r3   s    r/   Úshould_closezResponseHandler.should_closeI   s„   € åØÔð Ø” TÐ)ÐH°$´-×2FÒ2FÑ2HÔ2HÐ.HðàŒ~ðð Œ dÐ*ðð Ô#¨4Ð/ð	ð
 Œ|ðð Œzñ
ô 
ð 	
r   c                 ó   — d| _         d S ©NT)r"   r3   s    r/   Úforce_closezResponseHandler.force_closeU   s   € Ø!ˆÔÐÐr   c                 ó–   — d | _         | j        }|�8|                     ¦   «          d | _        d | _        |                      ¦   «          d S d S r6   )r<   Ú	transportÚcloser#   Ú_drop_timeout©r.   rC   s     r/   rD   zResponseHandler.closeX   óT   € ØˆŒØ”Nˆ	ØÐ Ø�OŠOÑÔÐØ!ˆDŒNØ ˆDŒMØ×ÒÑ Ô Ð Ð Ð ð	 !Ð r   c                 ó–   — d | _         | j        }|�8|                     ¦   «          d | _        d | _        |                      ¦   «          d S d S r6   )r<   rC   Úabortr#   rE   rF   s     r/   rI   zResponseHandler.aborta   rG   r   c                 óH   — | j         d uo| j                              ¦   «          S r6   )rC   Ú
is_closingr3   s    r/   Úis_connectedzResponseHandler.is_connectedj   s%   € ØŒ~ TÐ)ÐM°$´.×2KÒ2KÑ2MÔ2MÐ.MÐMr   Úexcc                 óÈ  •— d| _         |                      ¦   «          |}|}|d u }| j        �B|rt          | j        d ¦  «         n*|€J ‚t	          | j        t          d|›�¦  «        |¦  «         | j        �Et          t          ¦  «        5  | j         	                    ¦   «          d d d ¦  «         n# 1 swxY w Y   d }| j
        �j	 | j
         	                    ¦   «         }nO# t          $ rB}| j        �1d|›�}|s|›d|›�}t	          | j        t          |¦  «        |¦  «         Y d }~nd }~ww xY w|                      ¦   «         s]t          |t          ¦  «        rt!          |j        Ž }|rt%          |¦  «        }|rt&          n|}|€J ‚|€J ‚|                      ||¦  «         d| _        d | _
        d | _        d | _        d| _        t-          ¦   «                              |¦  «         d S )NTzConnection lost: z#Response payload is not completed: z. F)r-   rE   r,   r   r   r   r%   r   Ú	ExceptionÚfeed_eofÚ_parserr#   r
   r;   Ú
isinstanceÚOSErrorr	   Úargsr   r   r"   Ú_reading_pausedÚsuperÚconnection_lost)
r.   rM   Úoriginal_connection_errorÚreraised_excÚconnection_closed_cleanlyÚuncompletedÚunderlying_excÚclient_payload_exc_msgÚunderlying_non_eof_excÚ	__class__s
            €r/   rW   zResponseHandler.connection_lostm   sª  ø€ Ø'+ˆÔ$Ø×ÒÑÔÐà$'Ð!Ø0ˆà$=ÀÐ$EÐ!àŒ<Ð#ð )ð 
Ý˜4œ<¨Ñ.Ô.Ð.Ð.à0Ð<Ð<Ð<ÝØ”LÝ)ØJÐ,EÐJÐJñô ð .ñô ð ð ÔÐ+Ý�)Ñ$Ô$ð 0ð 0ØÔ$×-Ò-Ñ/Ô/Ð/ð0ð 0ð 0ñ 0ô 0ð 0ð 0ð 0ð 0ð 0ð 0øøøð 0ð 0ð 0ð 0ð ˆØŒ<Ð#ðØ"œl×3Ò3Ñ5Ô5��øÝð ð ð Ø”=Ð,àQ¸nÐQÐQð +ð 5ð à5ð >ð >Ø8ð>ð >ð /õ "ØœÝ*Ð+AÑBÔBØ&ñô ð øøøøøøøøøðøøøð  �{Š{‰}Œ}ð 	EÝÐ3µWÑ=Ô=ð NÝ,Ð.GÔ.LÐM�Ø(ð DÝ6°{ÑCÔC�ð
 -ð/•�à.ð #ð
 *Ð5Ð5Ð5ØÐ+Ð+Ð+Ø×Ò˜|Ð-CÑDÔDÐDà!ˆÔØˆŒØˆŒØ#ˆÔØ$ˆÔå‰Œ×Ò Ñ-Ô-Ð-Ð-Ð-s*   Â	B/Â/B3Â6B3ÃC Ã
D*Ã(8D%Ä%D*c                 ó.   — |                       ¦   «          d S r6   )rE   r3   s    r/   Úeof_receivedzResponseHandler.eof_received¸   s   € à×ÒÑÔÐÐÐr   c                 óp   •— t          ¦   «                              ¦   «          |                      ¦   «          d S r6   )rV   Úpause_readingrE   )r.   r_   s    €r/   rc   zResponseHandler.pause_reading¼   s1   ø€ Ý‰Œ×ÒÑÔÐØ×ÒÑÔÐÐÐr   TÚresume_parserc                 óˆ   •— | j         }t          ¦   «                              |¦  «         |r|                      ¦   «          d S d S r6   )rU   rV   Úresume_readingÚ_reschedule_timeout)r.   rd   Ú
was_pausedr_   s      €r/   rf   zResponseHandler.resume_readingÀ   sM   ø€ ØÔ)ˆ
Ý‰Œ×Ò˜}Ñ-Ô-Ð-Øð 	'Ø×$Ò$Ñ&Ô&Ð&Ð&Ð&ð	'ð 	'r   Ú	exc_causec                 ó‚   •— d| _         |                      ¦   «          t          ¦   «                              ||¦  «         d S r@   )r"   rE   rV   r   )r.   rM   ri   r_   s      €r/   r   zResponseHandler.set_exceptionÆ   s?   ø€ ð
 "ˆÔØ×ÒÑÔÐÝ‰Œ×Ò˜c 9Ñ-Ô-Ð-Ð-Ð-r   r   ÚpayloadÚdata_received_cbc                 ó²   — || _         || _        || _        |                      ¦   «          | j        r&| j        dc}| _        |                      |¦  «         d S d S )Nr   )r#   r%   r&   rE   r(   Údata_received)r.   r   rk   rl   Údatas        r/   Ú
set_parserzResponseHandler.set_parserÏ   sk   € ð  ˆŒØ%ˆÔØ!1ˆÔà×ÒÑÔÐàŒ:ð 	%Ø#œz¨3ÐˆD�$”*Ø×Ò˜tÑ$Ô$Ð$Ð$Ð$ð	%ð 	%r   Fr    iþ  é€   )
ÚtimerÚskip_payloadÚread_until_eofÚauto_decompressÚread_timeoutÚread_bufsizeÚtimeout_ceil_thresholdÚmax_line_sizeÚmax_field_sizeÚmax_headersrr   rs   rt   ru   rv   rw   rx   ry   rz   r{   c       
         óÞ   — || _         || _        || _        t          | | j        ||t
          | ||||	|
¬¦  «        | _        | j        r&| j        dc}| _        |                      |¦  «         d S d S )N)rr   Úpayload_exceptionÚresponse_with_bodyrt   ru   ry   rz   r{   r   )	r$   r)   r+   r   r1   r
   rQ   r(   rn   )r.   rr   rs   rt   ru   rv   rw   rx   ry   rz   r{   ro   s               r/   Úset_response_paramsz#ResponseHandler.set_response_paramsä   s˜   € ð *ˆÔà)ˆÔà'=ˆÔ$å)ØØŒJØØÝ0Ø#/Ð/Ø)Ø+Ø'Ø)Ø#ð
ñ 
ô 
ˆŒð Œ:ð 	%Ø#œz¨3ÐˆD�$”*Ø×Ò˜tÑ$Ô$Ð$Ð$Ð$ð	%ð 	%r   c                 óX   — | j         �"| j                              ¦   «          d | _         d S d S r6   )r*   Úcancelr3   s    r/   rE   zResponseHandler._drop_timeout
  s6   € ØÔ$Ð0ØÔ%×,Ò,Ñ.Ô.Ð.Ø(,ˆDÔ%Ð%Ð%ð 1Ð0r   c                 ó´   — | j         }| j        �| j                             ¦   «          |r'| j                             || j        ¦  «        | _        d S d | _        d S r6   )r)   r*   r�   r1   Ú
call_laterÚ_on_read_timeout)r.   Útimeouts     r/   rg   z#ResponseHandler._reschedule_timeout  sh   € ØÔ$ˆØÔ$Ð0ØÔ%×,Ò,Ñ.Ô.Ð.àð 	-Ø(,¬
×(=Ò(=Ø˜Ô.ñ)ô )ˆDÔ%Ð%Ð%ð )-ˆDÔ%Ð%Ð%r   c                 ó.   — |                       ¦   «          d S r6   )rg   r3   s    r/   Ústart_timeoutzResponseHandler.start_timeout  s   € Ø× Ò Ñ"Ô"Ð"Ð"Ð"r   c                 ó   — | j         S r6   ©r)   r3   s    r/   rv   zResponseHandler.read_timeout  s   € àÔ!Ð!r   c                 ó   — || _         d S r6   r‰   )r.   rv   s     r/   rv   zResponseHandler.read_timeout"  s   € à)ˆÔÐÐr   c                 óŠ   — t          d¦  «        }|                      |¦  «         | j        �t          | j        |¦  «         d S d S )Nz#Timeout on reading data from socket)r   r   r#   )r.   rM   s     r/   r„   z ResponseHandler._on_read_timeout&  sL   € Ý Ð!FÑGÔGˆØ×Ò˜3ÑÔÐØŒ=Ð$Ý˜$œ-¨Ñ-Ô-Ð-Ð-Ð-ð %Ð$r   ro   c                 ód  — |r|                       ¦   «          | j        �a| j        �|                      ¦   «          | j                             |¦  «        \  }}|r%d | _        d | _        |r|                      |¦  «         d S | j        s| j        €| xj        |z  c_        d S 	 | j                             |¦  «        \  }}}n©# t          $ rœ}| j
        �| j
                             ¦   «          t          |t          ¦  «        s‚ t          |t          ¦  «        r"t          |j        |j        |j        ¬¦  «        }nt          ¦   «         }|                      ||¦  «         Y d }~d S d }~ww xY w|| _        d }|D ]e\  }	}|	j        rd| _        || _        | j        s|	j        t,          v r|                      |	t.          fd¦  «         ŒM|                      |	|fd¦  «         Œf|�8|t.          ur|                     | j        ¦  «         n|                      ¦   «          |r|r|                      |¦  «         d S d S d S )N)ÚcodeÚmessageÚheadersTr   )rg   r%   r&   Ú	feed_datar#   rn   r7   rQ   r(   ÚBaseExceptionrC   rD   rR   rO   r   r�   rŽ   r�   r   r>   r"   r$   r   r   Úon_eofrE   )
r.   ro   ÚeofÚtailÚmessagesr8   r\   rM   rk   rŽ   s
             r/   rn   zResponseHandler.data_received,  s¢  € ð ð 	'Ø×$Ò$Ñ&Ô&Ð&ð ÔÐ+ØÔ%Ð1Ø×&Ò&Ñ(Ô(Ð(ØÔ,×6Ò6°tÑ<Ô<‰IˆC�Øð -Ø $�”Ø'+�Ô$àð -Ø×&Ò& tÑ,Ô,Ð,ØˆFàŒ>ð 	˜Tœ\Ð1àˆJŒJ˜$ÑˆJŒJØˆFð	Ø'+¤|×'=Ò'=¸dÑ'CÔ'CÑ$ˆH�h  øÝð 	ð 	ð 	ØŒ~Ð)ð ”×$Ò$Ñ&Ô&Ð&Ý˜n­iÑ8Ô8ð Øå˜.Õ*=Ñ>Ô>ð ,Ý)Ø'Ô,Ø*Ô2Ø*Ô2ðñ ô ��õ *Ñ+Ô+�Ø×Ò˜s NÑ3Ô3Ð3ØˆFˆFˆFˆFˆFøøøøð%	øøøð( "ˆŒà'+ˆØ (ð 		6ð 		6ÑˆG�WØÔ#ð *Ø%)�Ô"à#ˆDŒMàÔ!ð 6 W¤\Õ5LÐ%LÐ%LØ—’ ­Ð7¸Ñ;Ô;Ð;Ð;à—’ ¨Ð1°1Ñ5Ô5Ð5Ð5àÐð
 �mÐ+Ð+Ø—’˜tÔ1Ñ2Ô2Ð2Ð2à×"Ò"Ñ$Ô$Ð$àð 	%˜ð 	%Ø×Ò˜tÑ$Ô$Ð$Ð$Ð$ð	%ð 	%ð 	%ð 	%s   Â B? Â?
E%Ã	BE Å E%)r   N)Tr6   ))Ú__name__Ú
__module__Ú__qualname__Ú__doc__ÚasyncioÚAbstractEventLoopr!   ÚpropertyÚFuturer4   r:   r8   r>   rA   rD   rI   rL   r‘   rW   ra   rc   rf   r   r   r   r   rp   r   r   ÚfloatÚintr   rE   rg   r‡   rv   Úsetterr„   Úbytesrn   Ú__classcell__)r_   s   @r/   r   r      sí  ø€ € € € € ØBÐBð-˜WÔ6ð -¸4ð -ð -ð -ð -ð, ð˜˜wœ~¨dÔ3Ñ3ð ð ð ñ „Xðð" ð˜$ð ð ð ñ „Xðð ð	
˜dð 	
ð 	
ð 	
ñ „Xð	
ð"ð "ð "ð "ð!ð !ð !ð !ð!ð !ð !ð !ðN˜dð Nð Nð Nð NðI. =°4Ñ#7ð I.¸Dð I.ð I.ð I.ð I.ð I.ð I.ðVð ð ð ðð ð ð ð ð ð'ð '¨Dð '¸Dð 'ð 'ð 'ð 'ð 'ð 'ð $1ð.ð .àð.ð !ð.ð 
ð	.ð .ð .ð .ð .ð .ð 7;ð	%ð %àð%ð ð%ð # 2 t 8Ô,¨tÑ3ð	%ð
 
ð%ð %ð %ð %ð0 *.Ø"Ø$Ø $Ø%)Ø.Ø()Ø!Ø"Øð$%ð $%ð $%ð   $Ñ&ð$%ð ð	$%ð
 ð$%ð ð$%ð ˜d‘lð$%ð ð$%ð !&ð$%ð ð$%ð ð$%ð ð$%ð 
ð$%ð $%ð $%ð $%ðL-ð -ð -ð -ð

-ð 
-ð 
-ð 
-ð#ð #ð #ð #ð ð"˜e d™lð "ð "ð "ñ „Xð"ð Ôð*¨°©ð *¸$ð *ð *ð *ñ Ôð*ð.ð .ð .ð .ðH% %ð H%¨Dð H%ð H%ð H%ð H%ð H%ð H%ð H%ð H%r   r   ) rš   Ú
contextlibr   Útypingr   r   Úbase_protocolr   Úclient_exceptionsr   r	   r
   r   r   Úhelpersr   r   r   r   r   r   Úhttpr   r   Úhttp_exceptionsr   Ústreamsr   r   r   Útupler   © r   r/   ú<module>r­      sz  ðØ €€€Ø Ð Ð Ð Ð Ð Ø  Ð  Ð  Ð  Ð  Ð  Ð  Ð  à 'Ð 'Ð 'Ð 'Ð 'Ð 'ðð ð ð ð ð ð ð ð ð ð ð ð ð ðð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð 9Ð 8Ð 8Ð 8Ð 8Ð 8Ð 8Ð 8Ø 0Ð 0Ð 0Ð 0Ð 0Ð 0Ø ;Ð ;Ð ;Ð ;Ð ;Ð ;Ð ;Ð ;Ð ;Ð ;ðZ%ð Z%ð Z%ð Z%ð Z%�l I¨eÐ4FÈÐ4TÔ.UÔ$Vñ Z%ô Z%ð Z%ð Z%ð Z%r   