@OOf5dZddlmZddlZddlZddlZddlZddlmZddlm Z ddl m Z ddl m Z ddlmZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlm Z ddl!m"Z"ddl#m$Z$ddl%m&Z&ddl'm(Z(ddl'm)Z)ddl'm*Z*ddl+m,Z,ddl+m-Z-ddl+m.Z.ej^e0Z1Gdd Z2Gd!d"e*Z3y)#zr This addon is responsible for starting/stopping the proxy server sockets/instances specified by the mode option. ) annotationsN)Iterable)Iterator)contextmanager)Optional)Opcode)command)ctx) exceptions)http)platform)tcp)udp) websocket)Address)Flow)events) mode_specs) server_hooks)TcpMessageInjected)UdpMessageInjected)WebSocketMessageInjected)ProxyConnectionHandler)ServerInstance) ServerManager) asyncio_utils)human)signalscFeZdZddZed dZd dZd dZd dZd dZ y)Serversctjd|_t|_t j |_||_y)NcyNr$]/var/www/premiumrankchecker/venv/lib/python3.12/site-packages/mitmproxy/addons/proxyserver.pyz"Servers.__init__...sr%) r AsyncSignalchangeddict _instancesasyncioLock_lock_manager)selfmanagers r&__init__zServers.__init__-s1**<8 FJf\\^  r%c6|jjSr#)r.lockedr0s r& is_updatingzServers.is_updating3szz  ""r%cKd}|j4d{i}g}tjjri|D]d}||jvr|j|}n?t j ||j}|j|j|||<f|jjDcgc]\}}||vr|j}}}||_|jjd{tj|ddid{D]%} | sd}t j#t%| 'tj|ddid{D]%} | sd}t j#t%| 'dddd{|jjd{|S7cc}}w777m77#1d{7swYGxYw7,w)NTreturn_exceptionsF)r.r optionsserverr+rmaker/appendstartitemsstopr)sendr,gatherloggererrorstr) r0modesall_ok new_instances start_tasksspecinstances stop_tasksrets r&updatezServers.update7s::! +! +HJMK{{!!!3Dt.#'??4#8#1#6#6tT]]#K#**8>>+;<*2M$' 3 $446D!},J ,DO,,##% % %%^^ZP4PP +"FLLS* +%^^[QDQQ +"FLLS* +=! +! +Fll!!! I! + &QR=! +! +! +! +F "sG.GG.B%G>G 'GGG G! G+:G%G& G0"G G.G!G.?G,G. GGGG.G)G G)%G.c,t|jSr#)lenr+r5s r&__len__zServers.__len__`s4??##r%cHt|jjSr#)iterr+valuesr5s r&__iter__zServers.__iter__csDOO**,--r%c~t|trtjj |}|j |Sr#) isinstancerDr ProxyModeparser+)r0modes r& __getitem__zServers.__getitem__fs1 dC ''--d3Dt$$r%N)r1rreturnbool)rEzIterable[mode_specs.ProxyMode]r]r^)r]int)r]zIterator[ServerInstance])rZzstr | mode_specs.ProxyModer]r) __name__ __module__ __qualname__r2propertyr6rNrQrUr[r$r%r&r r ,s0 ##'R$.%r%r cNeZdZUdZded<ded<ded<dZd ed <dZd ed <d ZdZe ddZ dZ dZ ddZ ddZd dZd!dZej"d d" d#dZej"dd$dZej"dd$dZd%dZy)& Proxyserverz2 This addon runs the actual proxy server. z)dict[tuple | str, ProxyConnectionHandler] connectionsr serversr^ is_runningNzAddress | None _connect_addrzasyncio.Task | None _update_taskc@i|_t||_d|_y)NF)rfr rgrhr5s r&r2zProxyserver.__init__xst} r%c4dt|jdS)Nz Proxyserver(z active conns))rPrfr5s r&__repr__zProxyserver.__repr__}sc$"2"234NCCr%c#rK||j|< d|j|=y#|j|=wxYwwr#)rf)r0 connection_idhandlers r&register_connectionzProxyserver.register_connections<+2' 0   /  /s7%747c|jdtddd|jdttdd|jdttdd |jd td d |jd td d|jdtdd|jdtdd|jdttddy)Nconnection_strategyeagera^Determine when server connections should be established. When set to lazy, mitmproxy tries to defer establishing an upstream connection as long as possible. This makes it possible to use server replay while being offline. When set to eager, mitmproxy can detect protocols with server-side greetings, as well as accurately mirror TLS ALPN negotiation.)rtlazy)choicesstream_large_bodiesa Stream data to the client if response body exceeds the given threshold. If streamed, the body will not be stored in any way, and such responses cannot be modified. Understands k/m/g suffixes, i.e. 3m for 3 megabytes. body_size_limitz Byte size limit of HTTP request and response bodies. Understands k/m/g suffixes, i.e. 3m for 3 megabytes. keep_host_headerFz Reverse Proxy: Keep the original host header instead of rewriting it to the reverse proxy target. proxy_debugz$Enable debug logs in the proxy core.normalize_outbound_headersTa Normalize outgoing HTTP/2 header names, but emit a warning when doing so. HTTP/2 does not allow uppercase header names. This option makes sure that HTTP/2 headers set in custom scripts are lowercased before they are sent. validate_inbound_headersz Make sure that incoming HTTP requests are not malformed. Disabling this option makes mitmproxy vulnerable to HTTP smuggling attacks. connect_addrzWSet the local IP address that mitmproxy should use when connecting to upstream servers.) add_optionrDrr^)r0loaders r&loadzProxyserver.loads !   X&    ! SM      SM                2   (      &        SM  i  r%cd|_y)NT)rhr5s r&runningzProxyserver.runnings r%c d|vr. tjtjjd|vr. tjtjjd|vr` tjjr>ttjtjjdf|_ nd|_ d |vsd |vr"g}tjjD]1} |jt j"j%|3|Dcgc]_}|j'tjj&|j)tjj(|j*fa}}t-t/|t-|k7rat1j2|j5ddd\}}} tj6|xsd|f} t jd| tjjr>tj8j:j=dst>jAdtCd|Dr:tDjFrtEjHnt jd|jJr6tMjN|jPjS|d|_*yyy#t $r1t jdtjjwxYw#t $r1t jdtjjwxYw#t $r2t jdtjjdwxYw#t $r!}t jd |d |d d}~wwxYwcc}w)Nrwz+Invalid stream_large_bodies specification: rxz'Invalid body_size_limit specification: r}rz Invalid value for connect_addr: z. Specify a valid IP address.rZr:z"Invalid proxy mode specification: z ()z0.0.0.0z3Cannot spawn multiple servers on the same address: nextlayerz5Warning: Running proxyserver without nextlayer addon!c3PK|]}t|tj ywr#)rWrTransparentMode).0ms r& z(Proxyserver.configure..sL:a!;!;<Ls$&z0Transparent mode not supported on this platform.zupdate servers)name)+r parse_sizer r9rw ValueErrorr OptionsErrorrxr}rD ipaddress ip_addressrirZr<rrXrY listen_host listen_porttransport_protocolrPset collectionsCounter most_commonformat_addressmasteraddonsgetrBwarninganyr original_addrinit_transparent_moderhr create_taskrgrNrj) r0updatedrErZer listen_addrshostport_dup_addrs r& configurezProxyserver.configuresY G +   !@!@A  '   !((,L%, D0(03I00F PFP Q <W__'(KO # #%) #49 #DH #) #W__\"###W__\"###r%re)4r __future__rr,rrloggingcollections.abcrr contextlibrtypingrwsproto.frame_protocolr mitmproxyr r r r r rrrmitmproxy.connectionrmitmproxy.flowrmitmproxy.proxyrrrmitmproxy.proxy.layers.tcprmitmproxy.proxy.layers.udpr mitmproxy.proxy.layers.websocketrmitmproxy.proxy.mode_serversrrrmitmproxy.utilsrrr getLoggerr`rBr rer$r%r&rs#$$%) ("&(99E?76)!#   8 $=%=%@B-Br%