Ë
    [üàgY'  ã            	       óÀ   — 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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y)é    N)Úsuppress)ÚAnyÚOptionalÚTupleé   )ÚBaseProtocol)ÚClientOSErrorÚClientPayloadErrorÚServerDisconnectedErrorÚSocketTimeoutError)Ú_EXC_SENTINELÚEMPTY_BODY_STATUS_CODESÚBaseTimerContextÚset_exception)ÚHttpResponseParserÚRawResponseMessage)ÚHttpProcessingError)ÚEMPTY_PAYLOADÚ	DataQueueÚStreamReaderc                   óÀ  ‡ — 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efde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edee   fd(„«       Zej@                  dee   ddf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     úR/var/www/skyplay_api_hub/venv/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                 ó  — t        | j                  xsu | j                  d uxr | j                  j                  «        xsH | j                  xs: | j
                  d uxs* | j                  d uxs | j                  xs | j                  «      S r-   )	Úboolr   r    Úis_eofr%   Ú
_exceptionr"   Ú_bufferr$   r.   s    r+   Úshould_closezResponseHandler.should_close3   sŽ   € äØ×Ñò Ø—‘ TÐ)ÒH°$·-±-×2FÑ2FÓ2HÐ.Hòà�~‰~òð �‰ dÐ*òð ×#Ñ#¨4Ð/ò	ð
 �|‰|òð �z‰zó
ð 	
r   c                 ó   — d| _         y ©NT)r   r.   s    r+   Úforce_closezResponseHandler.force_close?   s
   € Ø!ˆÕr   c                 óŒ   — d | _         | j                  }|�/|j                  «        d | _        d | _        | j	                  «        y y r-   )r3   Ú	transportÚcloser    Ú_drop_timeout)r*   r:   s     r+   r;   zResponseHandler.closeB   sA   € ØˆŒØ—N‘Nˆ	ØÐ Ø�O‰OÔØ!ˆDŒNØ ˆDŒMØ×ÑÕ ð	 !r   c                 óX   — | j                   d uxr | j                   j                  «        S r-   )r:   Ú
is_closingr.   s    r+   Úis_connectedzResponseHandler.is_connectedK   s&   € Ø�~‰~ TÐ)ÒM°$·.±.×2KÑ2KÓ2MÐ.MÐMr   Úexcc                 óæ  •— | j                  «        |}|}|d u }| j                  �2t        t        «      5  | j                  j	                  «        d d d «       d }| j
                  �	 | j
                  j	                  «       }| j                  «       sSt        |t        «      rt        |j                  Ž }|rt        |«      }|rt        n|}|€J ‚|€J ‚| j                  ||«       d| _        d | _        d | _        d | _        d| _        t$        ‰	| �M  |«       y # 1 sw Y   ŒÈxY w# t        $ rD}| j                  �.d|›�}|s|›d|›�}t        | j                  t        |«      |«       Y d }~Œêd }~ww xY w)Nz#Response payload is not completed: z. TF)r<   r"   r   Ú	ExceptionÚfeed_eofr&   r    r   r
   r2   Ú
isinstanceÚOSErrorr	   Úargsr   r   r   Ú_reading_pausedÚsuperÚconnection_lost)
r*   r@   Úoriginal_connection_errorÚreraised_excÚconnection_closed_cleanlyÚuncompletedÚunderlying_excÚclient_payload_exc_msgÚunderlying_non_eof_excÚ	__class__s
            €r+   rI   zResponseHandler.connection_lostN   s“  ø€ Ø×ÑÔà$'Ð!Ø0ˆà$=ÀÐ$EÐ!à×ÑÐ+Üœ)Ó$ñ 0Ø×$Ñ$×-Ñ-Ô/÷0ð ˆØ�<‰<Ð#ðØ"Ÿl™l×3Ñ3Ó5�ð" �{‰{Œ}ÜÐ3´WÔ=Ü,Ð.G×.LÑ.LÐM�Ù(Ü6°{ÓC�ñ
 -õ à.ð #ð
 *Ð5Ð5Ð5ØÐ+Ð+Ð+Ø×Ñ˜|Ð-CÔDà!ˆÔØˆŒØˆŒØ#ˆÔØ$ˆÔä‰Ñ Õ-÷[0ð 0ûô ò Ø—=‘=Ð,à=¸nÐ=PÐQð +ñ 5à5Ð9¸Ø8Ð<ð>ð /ô "ØŸ™Ü*Ð+AÓBØ&ôÿøðús#   µDÁ'D# ÄD Ä#	E0Ä,:E+Å+E0c                 ó$   — | j                  «        y r-   )r<   r.   s    r+   Úeof_receivedzResponseHandler.eof_received†   s   € à×ÑÕr   c                 óB   •— t         ‰| �  «        | j                  «        y r-   )rH   Úpause_readingr<   ©r*   rQ   s    €r+   rU   zResponseHandler.pause_readingŠ   s   ø€ Ü‰ÑÔØ×ÑÕr   c                 óB   •— t         ‰| �  «        | j                  «        y r-   )rH   Úresume_readingÚ_reschedule_timeoutrV   s    €r+   rX   zResponseHandler.resume_readingŽ   s   ø€ Ü‰ÑÔ Ø× Ñ Õ"r   Ú	exc_causec                 óT   •— d| _         | j                  «        t        ‰| �  ||«       y r7   )r   r<   rH   r   )r*   r@   rZ   rQ   s      €r+   r   zResponseHandler.set_exception’   s(   ø€ ð
 "ˆÔØ×ÑÔÜ‰Ñ˜c 9Õ-r   ÚparserÚpayloadc                 ó¤   — || _         || _        | j                  «        | j                  r&| j                  dc}| _        | j	                  |«       y y )Nr   )r    r"   r<   r$   Údata_received)r*   r\   r]   Ú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_sizerb   rc   rd   re   rf   rg   rh   ri   rj   c       	         óä   — || _         || _        || _        t        | | j                  ||t
        | ||||	¬«
      | _        | j                  r&| j                  dc}
| _        | j                  |
«       y y )N)rb   Úpayload_exceptionÚresponse_with_bodyrd   re   ri   rj   r   )	r!   r'   r)   r   Ú_loopr
   r&   r$   r_   )r*   rb   rc   rd   re   rf   rg   rh   ri   rj   r`   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(   rq   rn   Ú
call_laterÚ_on_read_timeout)r*   Útimeouts     r+   rY   z#ResponseHandler._reschedule_timeoutÓ   sZ   € Ø×$Ñ$ˆØ×$Ñ$Ð0Ø×%Ñ%×,Ñ,Ô.áØ(,¯
©
×(=Ñ(=Ø˜×.Ñ.ó)ˆDÕ%ð )-ˆDÕ%r   c                 ó$   — | j                  «        y r-   )rY   r.   s    r+   Ústart_timeoutzResponseHandler.start_timeoutß   s   € Ø× Ñ Õ"r   c                 ó   — | j                   S r-   ©r'   r.   s    r+   rf   zResponseHandler.read_timeoutâ   s   € à×!Ñ!Ð!r   c                 ó   — || _         y r-   ry   )r*   rf   s     r+   rf   zResponseHandler.read_timeoutæ   s
   € à)ˆÕr   c                 ó‚   — t        d«      }| j                  |«       | j                  �t        | j                  |«       y y )Nz#Timeout on reading data from socket)r   r   r    )r*   r@   s     r+   rt   z ResponseHandler._on_read_timeoutê   s8   € Ü Ð!FÓGˆØ×Ñ˜3ÔØ�=‰=Ð$Ü˜$Ÿ-™-¨Õ-ð %r   r`   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 ]j  \  }	}|	j"                  rd| _        || _        | j&                  s|	j                  t(        v r| j                  |	t*        fd«       ŒW| j                  |	|fd«       Œl |�4|t*        ur|j-                  | j.                  «       n| j/                  «        |r|r| j	                  |«       y y y # t        $ r‰}| j                  �| j                  j                  «        t        |t        «      r-t        |j                  |j                  |j                  ¬«      }n
t        «       }| j!                  ||«       Y d }~y d }~ww xY w)N)ÚcodeÚmessageÚheadersTr   )rY   r"   Ú	feed_datar    r_   r%   r&   r$   ÚBaseExceptionr:   r;   rD   r   r}   r~   r   r   r5   r   r!   r   r   Úon_eofr<   )
r*   r`   ÚeofÚtailÚmessagesr/   rN   r@   r]   r~   s
             r+   r_   zResponseHandler.data_receivedð   sÞ  € Ø× Ñ Ô"áØð ×ÑÐ+Ø×,Ñ,×6Ñ6°tÓ<‰IˆC�ÙØ $�”Ø'+�Ô$áØ×&Ñ& tÔ,Øà�>Š>˜TŸ\™\Ð1à�JŠJ˜$Ñ�JØð	Ø'+§|¡|×'=Ñ'=¸dÓ'CÑ$ˆH�h ð& "ˆŒà*.ˆØ (ò 		6ÑˆG�WØ×#Ò#Ø%)�Ô"à#ˆDŒMà×!Ò! W§\¡\Ô5LÑ%LØ—‘ ¬Ð7¸Õ;à—‘ ¨Ð1°1Õ5ð		6ð Ðð
 œmÑ+Ø—‘˜t×1Ñ1Õ2à×"Ñ"Ô$á™Ø×Ñ˜tÕ$ð ˆ8øôU ò 	Ø�~‰~Ð)ð —‘×$Ñ$Ô&ä˜.Ô*=Ô>Ü)Ø'×,Ñ,Ø*×2Ñ2Ø*×2Ñ2ô‘ô *Ó+�Ø×Ñ˜s NÔ3Üûð!	ús   ÂE6 Å6	HÅ?A?HÈH)r   N)%Ú__name__Ú
__module__Ú__qualname__Ú__doc__ÚasyncioÚAbstractEventLoopr   Úpropertyr1   r/   r5   r8   r;   r?   r   r�   rI   rS   rU   rX   r   r   r   ra   r   ÚfloatÚintro   r<   rY   rw   rf   Úsetterrt   Úbytesr_   Ú__classcell__)rQ   s   @r+   r   r      sÛ  ø„ ÙBð:˜W×6Ñ6ð :¸4ó :ð* ð˜$ò ó ðð ð	
˜dò 	
ó ð	
ó"ó!ðN˜dó Nð6. 8¨MÑ#:ð 6.¸tõ 6.ópõõ#ð $1ñ.àð.ð !ð.ð 
õ	.ð% ð %¨sð %°tó %ð$ -1Ø"Ø$Ø $Ø(,Ø!Ø()Ø!Ø"ò"%ð Ð(Ñ)ð"%ð ð	"%ð
 ð"%ð ð"%ð ˜u‘oð"%ð ð"%ð !&ð"%ð ð"%ð ð"%ð 
ó"%óH-ó

-ó#ð ð"˜h u™oò "ó ð"ð ×Ñð*¨°%©ð *¸Tò *ó ð*ó.ðD% %ð D%¨D÷ D%r   r   )rŠ   Ú
contextlibr   Útypingr   r   r   Úbase_protocolr   Úclient_exceptionsr	   r
   r   r   Úhelpersr   r   r   r   Úhttpr   r   Úhttp_exceptionsr   Ústreamsr   r   r   r   © r   r+   ú<module>r›      sV   ðÛ Ý ß 'Ñ 'å '÷ó ÷ó ÷ 9Ý 0ß ;Ñ ;ô]%�l I¨eÐ4FÈÐ4TÑ.UÑ$Võ ]%r   