
    vKgR	                     H    S SK r S SKJrJr  S SKJr  S SKJr   " S S5      rg)    N)ctx
exceptions)http1)humanc                   >    \ rS rSrS rS rS rS rS rS r	S r
S	rg
)StreamBodies   c                     S U l         g )Nmax_size)selfs    u/var/www/highfloat_scraper/venv/lib/python3.13/site-packages/seleniumwire/thirdparty/mitmproxy/addons/streambodies.py__init__StreamBodies.__init__	   s	        c                     UR                  S[        R                  [           S S5        UR                  S[        SS5        g )Nstream_large_bodiesz
            Stream data to the client if response body exceeds the given
            threshold. If streamed, the body will not be stored in any way.
            Understands k/m/g suffixes, i.e. 3m for 3 megabytes.
            stream_websocketsFz
            Stream WebSocket messages between client and server.
            Messages are captured and cannot be modified.
            )
add_optiontypingOptionalstrbool)r   loaders     r   loadStreamBodies.load   sA    !6??3#7	
 	u	
r   c                 
   SU;   aU  [         R                  R                  (       a5   [        R                  " [         R                  R                  5      U l        g g g ! [         a  n[        R                  " U5      eS nAff = f)Nr   )	r   optionsr   r   
parse_sizer   
ValueErrorr   OptionsError)r   updatedes      r   	configureStreamBodies.configure   sc     G+0O0O1 % 0 01P1P Q 1P+  1 --a001s   3A 
B'A==Bc                 l   U R                   (       a  U(       a  UR                  OUR                  n [        R                  " UR                  U(       d  UR                  OS 5      nU(       a  UR                  (       d  SUs=::  a  U R                   ::  di  O  UR                  =(       d    SUl
        [        R                  R                  SR                  U(       d  SOSUR                  R                  5      5        g g g g g ! [
        R                   a    UR                  R                  5          g f = f)Nr   TzStreaming {} {}zresponse fromz
request to)r   requestresponser   expected_http_body_sizer   HttpExceptionreplykillraw_contentstreamr   loginfoformathost)r   f
is_requestrexpected_sizes        r   runStreamBodies.run$   s    =='		QZZA % = =IIqzz! Q]]A<_RVR_R_<_88+t.55Zo]iklktktkykyz{ =`]}  ++ s   4D .D32D3c                 (    U R                  US5        g )NTr7   r   r3   s     r   requestheadersStreamBodies.requestheaders3   s    Dr   c                 (    U R                  US5        g )NFr:   r;   s     r   responseheadersStreamBodies.responseheaders6   s    Er   c                 L   [         R                  R                  (       a  SUl        [         R                  R                  SR                  [        R                  " UR                  R                  5      [        R                  " UR                  R                  5      S95        g g )NTz:Streaming WebSocket messages between {client} and {server})clientserver)r   r   r   r.   r/   r0   r1   r   format_addressclient_connaddressserver_connr;   s     r   websocket_startStreamBodies.websocket_start9   sp    ;;((AHGGLLU\\++AMM,A,AB++AMM,A,AB ] D  )r   r   N)__name__
__module____qualname____firstlineno__r   r   r$   r7   r<   r?   rH   __static_attributes__ r   r   r   r      s&    
"1|r   r   )	r   !seleniumwire.thirdparty.mitmproxyr   r   *seleniumwire.thirdparty.mitmproxy.net.httpr   'seleniumwire.thirdparty.mitmproxy.utilsr   r   rO   r   r   <module>rS      s     = < 97 7r   