
    2hN/              	           S SK r S SKJr  S SKJrJr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  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OptionalTupleUnion   )BaseProtocol)ClientConnectionErrorClientOSErrorClientPayloadErrorServerDisconnectedErrorSocketTimeoutError)_EXC_SENTINELEMPTY_BODY_STATUS_CODESBaseTimerContextset_exception
set_result)HttpResponseParserRawResponseMessage)HttpProcessingError)EMPTY_PAYLOAD	DataQueueStreamReaderc                   B  ^  \ rS rSrSrS\R                  SS4S jr\S\	S\R                  S   4   4S j5       r\S\4S j5       r\S\4S	 j5       rS1S
 jrS1S jrS1S jrS\4S jrS\\   SS4U 4S jjrS1S jrS1U 4S jjrS1U 4S jjr\4S\S\SS4U 4S jjjrS\S\SS4S jr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 S1S( jr!S1S) jr"S1S* jr#\S\\   4S+ j5       r$\$RJ                  S"\\   SS4S, j5       r$S1S- jr&S.\'SS4S/ jr(S0r)U =r*$ )2ResponseHandler   z8Helper class to adapt between Protocol and StreamReader.loopreturnNc                    [         R                  " X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        SU l        g )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_closed_connection_lost_called)selfr   s     L/var/www/auris/envauris/lib/python3.13/site-packages/aiohttp/client_proto.pyr"   ResponseHandler.__init__   s    d.4&"04"#
59.2CG!89$:>',$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r0   s    r1   closedResponseHandler.closed4   s4     <<(D(D::335DL||r    c                     U R                   $ N)r)   r6   s    r1   upgradedResponseHandler.upgradedF   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      $ r:   )	boolr#   r$   is_eofr)   
_exceptionr&   _bufferr(   r6   s    r1   should_closeResponseHandler.should_closeJ   s     T)H$--2F2F2H.H~~ d* ##4/	
 || zz
 	
r    c                     SU l         g NT)r#   r6   s    r1   force_closeResponseHandler.force_closeV   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 r:   )r@   	transportcloser$   _drop_timeoutr0   rI   s     r1   rJ   ResponseHandler.closeY   A    NN	 OO!DN DM 	 !r    c                     S U l         U R                  nUb/  UR                  5         S U l        S U l        U R	                  5         g g r:   )r@   rI   abortr$   rK   rL   s     r1   rP   ResponseHandler.abortb   rN   r    c                 j    U R                   S L=(       a    U R                   R                  5       (       + $ r:   )rI   
is_closingr6   s    r1   is_connectedResponseHandler.is_connectedk   s&    ~~T)M$..2K2K2M.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_eofr*   r$   r   r?   
isinstanceOSErrorr   argsr   r   r#   _reading_pausedsuperconnection_lost)
r0   rV   original_connection_errorreraised_excconnection_closed_cleanlyuncompletedunderlying_excclient_payload_exc_msgunderlying_non_eof_exc	__class__s
            r1   r_   ResponseHandler.connection_lostn   s   '+$$'!0$=$E!<<# )4<<.0<<<LL)+,E+IJ . +)$$$--/ % <<#"ll335" {{}}3W==,.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 r:   )rK   r6   s    r1   eof_receivedResponseHandler.eof_received   s    r    c                 B   > [         TU ]  5         U R                  5         g r:   )r^   pause_readingrK   r0   rg   s    r1   rm   ResponseHandler.pause_reading   s    r    c                 B   > [         TU ]  5         U R                  5         g r:   )r^   resume_reading_reschedule_timeoutrn   s    r1   rq   ResponseHandler.resume_reading   s       "r    	exc_causec                 R   > SU l         U R                  5         [        TU ]  X5        g rE   )r#   rK   r^   r   )r0   rV   rt   rg   s      r1   r   ResponseHandler.set_exception   s&    
 "c-r    parserpayloadc                     X l         Xl        U R                  5         U R                  (       a%  U R                  Sso0l        U R	                  U5        g g )Nr    )r$   r&   rK   r(   data_received)r0   rw   rx   datas       r1   
set_parserResponseHandler.set_parser   sE      %::#zz3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_sizer~   r   r   r   r   r   r   r   r   c       	             X l         XPl        Xpl        [        U U R                  UU[
        U(       + UUUU	S9
U l        U R                  (       a%  U R                  Ssol        U R                  U
5        g g )N)r~   payload_exceptionresponse_with_bodyr   r   r   r   r    )	r%   r+   r-   r   r4   r   r*   r(   rz   )r0   r~   r   r   r   r   r   r   r   r   r{   s              r1   set_response_params#ResponseHandler.set_response_params   ss     *)'=$)JJ0#//)+')
 ::#zz3D*t$ r    c                 b    U R                   b"  U R                   R                  5         S U l         g g r:   )r,   cancelr6   s    r1   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 r:   )r+   r,   r   r4   
call_later_on_read_timeout)r0   timeouts     r1   rr   #ResponseHandler._reschedule_timeout  sX    $$$$0%%,,.(,

(=(=..)D% )-D%r    c                 $    U R                  5         g r:   )rr   r6   s    r1   start_timeoutResponseHandler.start_timeout  s      "r    c                     U R                   $ r:   r+   r6   s    r1   r   ResponseHandler.read_timeout  s    !!!r    c                     Xl         g r:   r   )r0   r   s     r1   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$   )r0   rV   s     r1   r    ResponseHandler._on_read_timeout  s8     !FG3==$$--- %r    r{   c                 r   U R                  5         U(       d  g U R                  bK  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  pU	R"                  (       a  SU l        Xl        U R&                  (       d  U	R                  [(        ;   a  U R                  U	[*        4S5        Mb  U R                  X4S5        Mw     Ub5  U[*        La  UR-                  U R.                  5        OU R/                  5         U(       a  U(       a  U R	                  U5        g g g ! [         a  nU R                  b  U R                  R                  5         [        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   )rr   r&   	feed_datar$   rz   r)   r*   r(   BaseExceptionrI   rJ   rZ   r   r   r   r   r   rB   r#   r%   r   r   on_eofrK   )
r0   r{   eoftailmessagesr;   rd   rV   rx   r   s
             r1   rz   ResponseHandler.data_received#  s     " +,,66t<IC $'+$&&t,>>T\\1JJ$J	'+||'='=d'C$H& "*. (G##%)"#M!!W\\5L%L7;115 !) 
 m+t112""$t$ 8U  	~~) $$&.*=>>)',,*22*22 *+s3!	s   &F! !
H6+BH11H6)r.   r/   r@   r*   r$   r&   r+   r,   r]   r#   r%   r(   r-   r'   r)   rI   )r   N)+__name__
__module____qualname____firstlineno____doc__asyncioAbstractEventLoopr"   propertyr   Futurer7   r>   r;   rB   rF   rJ   rP   rT   r   r   r_   rj   rm   rq   r   r   r   r|   r   floatintr   rK   rr   r   r   setterr   bytesrz   __static_attributes____classcell__)rg   s   @r1   r   r      s   B-W66 -4 -0 dGNN4$889  " $   	
d 	
 	
"!!Nd NI.8M#: I.t I.V# $1.. !. 
	. .% %s %t %$ -1"$ $(,!()!""% ()"% 	"%
 "% "% uo"% "% !&"% "% "% 
"%H-

-# "huo " " *% *T * *.D%% D%D D% D%r    r   ) r   
contextlibr   typingr   r   r   r   base_protocolr	   client_exceptionsr
   r   r   r   r   helpersr   r   r   r   r   httpr   r   http_exceptionsr   streamsr   r   r   r    r    r1   <module>r      sV      . . '   9 0 ; ;N%lIe4F4T.U$V N%r    