ó
    Û°›jž1  ã            	       óÈ   • S SK r S SKJr  S SKJrJ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JrJrJr  SSKJrJr  SS	KJr  SS
KJrJrJr   " S S\\\\\4      5      rg)é    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                   ój  ^ • \ rS rSrSrS\R                  SS4S jr\SS\R                  S   -  4S j5       r
\S\4S j5       r\S\4S	 j5       rS4S
 jrS4S jrS4S jrS\4S jrS\S-  SS4U 4S jjrS4S jrS4U 4S jjrS5S\SS4U 4S jjjr\4S\S\SS4U 4S jjjr S6S\S\S\/ S4   S-  SS4S jjrSSSSS\SSSSS.
S \S-  S!\S"\S#\S$\S-  S%\S&\S'\S(\S)\SS4S* jjr S4S+ jr!S4S, jr"S4S- jr#\S\S-  4S. j5       r$\$RJ                  S$\S-  SS4S/ j5       r$S4S0 jr&S1\'SS4S2 jr(S3r)U =r*$ )7ÚResponseHandleré   z8Helper class to adapt between Protocol and StreamReader.ÚloopÚreturnNc                 ó  • [         R                  " XS S9  [        R                  " X5        SU l        S U l        SU l        S U l        S U l        S U l        SU l	        S U l
        S U l        SU l        S U l        SU l        g )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     ÚQ/home/mande/repo/quber/.venv/lib/python3.13/site-packages/aiohttp/client_proto.pyr"   ÚResponseHandler.__init__   s|   € Ü×Ò˜d°dÒ;Ü×Ò˜4Ô&à"ˆÔà-1ˆŒØ"ˆÔØ#ˆÔØ<@ˆÔàˆŒØˆŒ
à+/ˆÔØ@DˆÔ!à56ˆÔ$à48ˆŒØ',ˆÕ$r    c                 ó”   • U R                   c0  U R                  (       d  U R                  R                  5       U l         U R                   $ )aî  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    r0   ÚclosedÚResponseHandler.closed3   s4   € ð �<‰<Ñ¨×(D×(DØŸ:™:×3Ñ3Ó5ˆDŒLØ�|‰|Ðr    c                 ó   • U R                   $ ©N)Ú	_upgradedr5   s    r0   ÚupgradedÚResponseHandler.upgradedE   s   € à�~‰~Ðr    c                 óh  • [        U R                  =(       d—    U R                  S L=(       a    U R                  R                  5       (       + =(       d\    U R                  =(       dI    U R
                  S L=(       d4    U R                  S L=(       d    U R                  =(       d    U R                  5      $ r9   )	Úboolr#   r$   Úis_eofr:   Ú
_exceptionr&   Ú_bufferr)   r5   s    r0   Úshould_closeÚResponseHandler.should_closeI   sŽ   € äØ×Ñ÷ Ø—‘ TÐ)×H°$·-±-×2FÑ2FÓ2HÔ.H÷à�~‰~÷ð �‰ dÐ*÷ð ×#Ñ#¨4Ð/÷	ð
 �|‰|÷ð �z‰zó
ð 	
r    c                 ó   • SU l         g ©NT)r#   r5   s    r0   Úforce_closeÚResponseHandler.force_closeU   s
   € Ø!ˆÕr    c                 óŽ   • S U l         U R                  nUb/  UR                  5         S U l        S U l        U R	                  5         g g r9   )r@   Ú	transportÚcloser$   Ú_drop_timeout©r/   rI   s     r0   rJ   ÚResponseHandler.closeX   óA   € ØˆŒØ—N‘Nˆ	ØÑ Ø�O‰OÔØ!ˆDŒNØ ˆDŒMØ×ÑÕ ð	 !r    c                 óŽ   • S U l         U R                  nUb/  UR                  5         S U l        S U l        U R	                  5         g g r9   )r@   rI   Úabortr$   rK   rL   s     r0   rP   ÚResponseHandler.aborta   rN   r    c                 ój   • U R                   S L=(       a    U R                   R                  5       (       + $ r9   )rI   Ú
is_closingr5   s    r0   Úis_connectedÚResponseHandler.is_connectedj   s&   € Ø�~‰~ TÐ)×M°$·.±.×2KÑ2KÓ2MÔ.MÐMr    Úexcc                 óê  >• SU l         U R                  5         UnUnUS L nU R                  bG  U(       a  [        U R                  S 5        O)Uc   e[	        U R                  [        SU< 35      U5        U R                  b2  [        [        5         U R                  R                  5         S S S 5        S nU R                  b   U R                  R                  5       nU R                  5       (       dc  [        U[        5      (       a  [!        UR"                  6 nU(       a  [%        U5      nU(       a  [&        OUnUc   eUc   eU R	                  X85        SU l        S U l
        S U l        S U l        SU l        [,        T	U ]]  U5        g ! , (       d  f       Nã= f! [         aN  nU R                  b6  SU< 3nU(       d	  U< SU< 3n[	        U R                  [        U5      U5         S nAGNS nAff = f)NTzConnection lost: z#Response payload is not completed: z. F)r.   rK   r-   r   r   r   r&   r   Ú	ExceptionÚfeed_eofÚ_parserr$   r
   r?   Ú
isinstanceÚOSErrorr	   Úargsr   r   r#   Ú_reading_pausedÚsuperÚconnection_lost)
r/   rV   Úoriginal_connection_errorÚreraised_excÚconnection_closed_cleanlyÚuncompletedÚunderlying_excÚclient_payload_exc_msgÚunderlying_non_eof_excÚ	__class__s
            €r0   r`   ÚResponseHandler.connection_lostm   sé  ø€ Ø'+ˆÔ$Ø×ÑÔà$'Ð!Ø0ˆà$=ÀÐ$EÐ!à�<‰<Ñ#ö )Ü˜4Ÿ<™<¨Õ.à0Ñ<Ð<Ð<ÜØ—L‘LÜ)Ø+Ð,EÑ+IÐJóð .ôð ×ÑÑ+Üœ)Õ$Ø×$Ñ$×-Ñ-Ô/÷ %ð ˆØ�<‰<Ñ#ðØ"Ÿl™l×3Ñ3Ó5�ð" �{‰{�}‰}ÜÐ3´W×=Ñ=Ü,Ð.G×.LÑ.LÐM�Þ(Ü6°{ÓC�ö
 -õ à.ð #ð
 *Ñ5Ð5Ð5ØÑ+Ð+Ð+Ø×Ñ˜|ÔDà!ˆÔØˆŒØˆŒØ#ˆÔØ$ˆÔä‰Ñ Õ-÷[ %Õ$ûô ó Ø—=‘=Ñ,à=¸nÑ=PÐQð +ö 5à5Ñ9¸Ø8Ñ<ð>ð /ô "ØŸ™Ü*Ð+AÓBØ&ôÿùðús%   ÂF	ÃF Æ	
FÆ
G2Æ$AG-Ç-G2c                 ó$   • U R                  5         g r9   )rK   r5   s    r0   Úeof_receivedÚResponseHandler.eof_received¸   s   € à×ÑÕr    c                 óB   >• [         TU ]  5         U R                  5         g r9   )r_   Úpause_readingrK   )r/   rh   s    €r0   rn   ÚResponseHandler.pause_reading¼   s   ø€ Ü‰ÑÔØ×ÑÕr    TÚresume_parserc                 ól   >• U R                   n[        TU ]	  U5        U(       a  U R                  5         g g r9   )r^   r_   Úresume_readingÚ_reschedule_timeout)r/   rp   Ú
was_pausedrh   s      €r0   rr   ÚResponseHandler.resume_readingÀ   s/   ø€ Ø×)Ñ)ˆ
Ü‰Ñ˜}Ô-ÞØ×$Ñ$Õ&ð r    Ú	exc_causec                 óR   >• SU l         U R                  5         [        TU ]  X5        g rE   )r#   rK   r_   r   )r/   rV   rv   rh   s      €r0   r   ÚResponseHandler.set_exceptionÆ   s&   ø€ ð
 "ˆÔØ×ÑÔÜ‰Ñ˜cÕ-r    r   ÚpayloadÚdata_received_cbc                 ó´   • X l         Xl        X0l        U R                  5         U R                  (       a%  U R                  Sso@l        U R                  U5        g g )Nr    )r$   r&   r'   rK   r)   Údata_received)r/   r   ry   rz   Údatas        r0   Ú
set_parserÚResponseHandler.set_parserÏ   sK   € ð  ŒØ%ÔØ!1Ôà×ÑÔà�:�:Ø#Ÿz™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_headersr�   r‚   rƒ   r„   r…   r†   r‡   rˆ   r‰   rŠ   c       
         óê   • X l         XPl        Xpl        [        U U R                  UU[
        U(       + UUUU	U
S9U l        U R                  (       a%  U R                  Sso°l        U R                  U5        g g )N)r�   Úpayload_exceptionÚresponse_with_bodyrƒ   r„   rˆ   r‰   rŠ   r    )	r%   r*   r,   r   r3   r
   rZ   r)   r|   )r/   r�   r‚   rƒ   r„   r…   r†   r‡   rˆ   r‰   rŠ   r}   s               r0   Úset_response_paramsÚ#ResponseHandler.set_response_paramsä   sv   € ð *Ôà)Ôà'=Ô$ä)ØØ�J‰JØØÜ0Ø#/Ô/Ø)Ø+Ø'Ø)Ø#ñ
ˆŒð �:�:Ø#Ÿz™z¨3ÐˆD”*Ø×Ñ˜tÕ$ð r    c                 ób   • U R                   b"  U R                   R                  5         S U l         g g r9   )r+   Úcancelr5   s    r0   rK   ÚResponseHandler._drop_timeout
  s-   € Ø×$Ñ$Ñ0Ø×%Ñ%×,Ñ,Ô.Ø(,ˆDÕ%ð 1r    c                 óÜ   • U R                   nU R                  b  U R                  R                  5         U(       a+  U R                  R	                  XR
                  5      U l        g S U l        g r9   )r*   r+   r‘   r3   Ú
call_laterÚ_on_read_timeout)r/   Útimeouts     r0   rs   Ú#ResponseHandler._reschedule_timeout  sX   € Ø×$Ñ$ˆØ×$Ñ$Ñ0Ø×%Ñ%×,Ñ,Ô.æØ(,¯
©
×(=Ñ(=Ø×.Ñ.ó)ˆDÕ%ð )-ˆDÕ%r    c                 ó$   • U R                  5         g r9   )rs   r5   s    r0   Ústart_timeoutÚResponseHandler.start_timeout  s   € Ø× Ñ Õ"r    c                 ó   • U R                   $ r9   ©r*   r5   s    r0   r…   ÚResponseHandler.read_timeout  s   € à×!Ñ!Ð!r    c                 ó   • Xl         g r9   rœ   )r/   r…   s     r0   r…   r�   "  s   € à)Õr    c                 ó„   • [        S5      nU R                  U5        U R                  b  [        U R                  U5        g g )Nz#Timeout on reading data from socket)r   r   r$   )r/   rV   s     r0   r•   Ú ResponseHandler._on_read_timeout&  s8   € Ü Ð!FÓGˆØ×Ñ˜3ÔØ�=‰=Ñ$Ü˜$Ÿ-™-¨Õ-ð %r    r}   c                 óÖ  • U(       a  U R                  5         U R                  bh  U R                  b  U R                  5         U R                  R                  U5      u  p#U(       a&  S U l        S U l        U(       a  U R                  U5        g U R                  (       d  U R                  c  U =R                  U-  sl        g  U R                  R                  U5      u  pEnXPl        S nU Hu  u  p˜U	R&                  (       a  SU l        X€l        U R*                  (       d  U	R                  [,        ;   a  U R                  U	[.        4S5        Mb  U R                  X˜4S5        Mw     Ub5  U[.        La  UR1                  U R2                  5        OU R3                  5         U(       a  U(       a  U R                  U5        g g g ! [         a¡  nU R                  b  U R                  R                  5         [        U[        5      (       d  e [        U[        5      (       a*  [        UR                  UR                   UR"                  S9nO
[        5       nU R%                  Xv5         S nAg S nAff = f)N)ÚcodeÚmessageÚheadersTr   )rs   r&   r'   Ú	feed_datar$   r|   r:   rZ   r)   ÚBaseExceptionrI   rJ   r[   rX   r   r¢   r£   r¤   r   rB   r#   r%   r   r   Úon_eofrK   )
r/   r}   ÚeofÚtailÚmessagesr;   re   rV   ry   r£   s
             r0   r|   ÚResponseHandler.data_received,  sõ  € ö Ø×$Ñ$Ô&ð ×ÑÑ+Ø×%Ñ%Ñ1Ø×&Ñ&Ô(Ø×,Ñ,×6Ñ6°tÓ<‰IˆCÞØ $�”Ø'+�Ô$æØ×&Ñ& tÔ,Øà�>�>˜TŸ\™\Ñ1à�JŠJ˜$Ñ�JØð	Ø'+§|¡|×'=Ñ'=¸dÓ'CÑ$ˆH ð* "Œà'+ˆÛ (ÑˆGØ×#×#Ø%)�Ô"à#ŒMà×!×! W§\¡\Ô5LÓ%LØ—‘ ¬Ð7¸Ö;à—‘ Ð1°1Ö5ñ !)ð Ñð
 œmÒ+Ø—‘˜t×1Ñ1Õ2à×"Ñ"Ô$æžØ×Ñ˜tÕ$ð ˆ8øôY ó 	Ø�~‰~Ñ)ð —‘×$Ñ$Ô&Ü˜n¬i×8Ñ8Øä˜.Ô*=×>Ñ>Ü)Ø'×,Ñ,Ø*×2Ñ2Ø*×2Ñ2ñ‘ô *Ó+�Ø×Ñ˜sÔ3Üûð%	ús   ÃF= Æ=
I(ÇBI#É#I()r-   r.   r'   r@   rZ   r$   r&   r*   r+   r^   r#   r%   r)   r,   r(   r:   rI   )r   N)Tr9   )+Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__ÚasyncioÚAbstractEventLoopr"   ÚpropertyÚFuturer6   r>   r;   rB   rF   rJ   rP   rT   r¦   r`   rk   rn   rr   r   r   r   r   r~   r   r   ÚfloatÚintrŽ   rK   rs   r™   r…   Úsetterr•   Úbytesr|   Ú__static_attributes__Ú__classcell__)rh   s   @r0   r   r      sZ  ø† ÙBð-˜W×6Ñ6ð -¸4ô -ð, ð˜˜wŸ~™~¨dÑ3Ñ3ó ó ðð" ð˜$ó ó ðð ð	
˜dó 	
ó ð	
ô"ô!ô!ðN˜dô NðI. =°4Ñ#7ð I.¸D÷ I.ôV÷ñ'¨Dð '¸D÷ 'ð 'ð $1ñ.àð.ð !ð.ð 
÷	.ð .ð 7;ñ	%àð%ð ð%ð # 2 t 8Ñ,¨tÑ3ð	%ð
 
õ%ð0 *.Ø"Ø$Ø $Ø%)Ø.Ø()Ø!Ø"Øò$%ð   $Ñ&ð$%ð ð	$%ð
 ð$%ð ð$%ð ˜d‘lð$%ð ð$%ð !&ð$%ð ð$%ð ð$%ð ð$%ð 
õ$%ôL-ô

-ô#ð ð"˜e d™ló "ó ð"ð ×Ñð*¨°©ð *¸$ó *ó ð*ô.ðH% %ð H%¨D÷ 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    r0   Ú<module>rÅ      sS   ðÛ Ý ß  å '÷õ ÷÷ ÷ 9Ý 0ß ;Ñ ;ôZ%�l I¨eÐ4FÈÐ4TÑ.UÑ$Võ Z%r    