@OOfa%ddlmZddlZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddl m Z ddl mZdd l mZdd lmZeGd d ej$ZGd dej(Zdd gZy)) annotationsN) dataclass)field)Any)ClassVar) connection) exceptions)version) serializablecjeZdZUdZded< eej Zded< dZded <d Z d Z y ) ErroraQ An Error. This is distinct from an protocol error response (say, a HTTP code 500), which is represented by a normal `mitmproxy.http.Response` object. This class is responsible for indicating errors that fall outside of normal protocol communications, like interrupted connections, timeouts, or protocol errors. strmsg)default_factoryfloat timestampzConnection killed. ClassVar[str]KILLED_MESSAGEc|jSNrselfs O/var/www/premiumrankchecker/venv/lib/python3.12/site-packages/mitmproxy/flow.py__str__z Error.__str__% xxc|jSrrrs r__repr__zError.__repr__(rrN) __name__ __module__ __qualname____doc____annotations__rtimerrrrrrr r s; H'TYY7Iu75$8NM8rr c6eZdZUdZded< ded< dZded< d ed < d Zd ed < ded< d ed< ded< d& d'dZiZded<ded< dZ d(dZ d)dZ e d*dZ fdZdZd&dZdZed Zd!Zd"Zd#Zd$Zed+d%ZxZS),Flowz Base class for network flows. A flow is a collection of objects, for example HTTP request/response pairs or a list of TCP messages. See also: - mitmproxy.http.HTTPFlow - mitmproxy.tcp.TCPFlow - mitmproxy.udp.UDPFlow connection.Client client_connconnection.Server server_connNz Error | Noneerrorbool interceptedrmarkedz str | None is_replaylivertimestamp_createdcttj|_||_||_||_tj|_d|_ d|_ d|_ d|_ d|_ t|_d|_y)NFr0)ruuiduuid4idr*r,r3r%r4r/ _resume_event_backupr1r2dictmetadatacomment)rr*r,r3s r__init__z Flow.__init__psp djjl#&& !%!&37$(  %)(,  rzdict[str, type[Flow]] _Flow__typesrtypec |jjdj|_|tj |j<y)Nr()r removesuffixlowerr@r(r?)clskwargss r__init_subclass__zFlow.__init_subclass__s3<<,,V4::<!$ SXXrc tj|j|j|jr|jj nd|j j |jj |j|j|jtj|j|j|jd }|j |k7rtj|j nd|d<|S)N) r r@r8r-r*r,r/r2r1r<r=r4backup)r FLOW_FORMAT_VERSIONr@r8r- get_stater*r,r/r2r1copydeepcopyr<r=r4r:rstates rrJzFlow.get_states22II''/3zzTZZ))+t++557++557++kk dmm4||!%!7!7  :>9N$-- 5TXh rc|jdtjk(sJ|jd|jk(sJ|jd|_|dra|j r+|j j |jdn@tj|jd|_n|jd|_|jj |jd|jj |jd|jd|_ |jd|_ |jd |_ |jd |_|jd |_|jd |_|jd d|_|ik(sJy)Nr r@r8r-r*r,r/r2r1r<r=r4rH)popr rIr@r8r- set_stater from_stater*r,r/r2r1r<r=r4r:rMs rrQzFlow.set_statesXyy#w'B'BBBByy DII---))D/ >zz $$UYYw%78"--eii.@A 7+DJ ""599]#;< ""599]#;< 99]3;/ii)  *- yy+ !&+>!?yy40 {{rc tj|d}t j dd}t j d}|||}|j||S#t$rtd|dwxYw)Nr@zUnknown flow type: )r0r)peernamesockname)address)r(r?KeyError ValueErrorrClientServerrQ)rDrNflow_clsclientserverfs rrRzFlow.from_states D||E&M2H""GgF""40 VV $ E  D25=/BC C Ds A!!A<c2t|}d|_|S)zMake a copy of this flow.F)superrKr3)rr^ __class__s rrKz Flow.copys GLNrcV|jr|j|jk7Sy)zU `True` if this file has been modified by a user, `False` otherwise. Fr:rJrs rmodifiedz Flow.modifieds$ <<<<4>>#33 3rcH|js|j|_yy)z_ Save a backup of this flow, which can be restored by calling `Flow.revert()`. Nrc)rforces rrHz Flow.backups||>>+DLrcb|jr#|j|jd|_yy)z5 Revert to the last backed up state. N)r:rQrs rrevertz Flow.reverts' << NN4<< (DL rc|jxr6|jxr'|jjtjk( S)zB*Read-only:* `True` if this flow can be killed, `False` otherwise.)r3r-rr rrs rkillablez Flow.killables2yyX$**"W5CWCW1WXXrc|jstjdttj|_d|_d|_y)zh Kill this flow. The current request/response will not be forwarded to its destination. zFlow is not killable.FN)rjr ControlExceptionr rr-r/r3rs rkillz Flow.kills@}}--.EF F 5//0   rcz|jryd|_|j|jjyy)z[ Intercept this Flow. Processing will stop until resume is called. NT)r/r9clearrs r interceptzFlow.intercepts;        )    $ $ & *rcK|jsy|jtj|_|jj d{y7w)z2 Wait until this Flow is resumed. N)r/r9asyncioEventwaitrs rwait_for_resumezFlow.wait_for_resumesF     %!(D   %%'''sAAAAcz|jsyd|_|j|jjyy)uI Continue with the flow – called after an intercept(). NF)r/r9setrs rresumez Flow.resume s;      )    " " $ *rc.|jjS)z *Read-only:* Start time of the flow. Depending on the flow type, this property is an alias for `mitmproxy.connection.Client.timestamp_start` or `mitmproxy.http.Request.timestamp_start`. )r*timestamp_startrs rrzzFlow.timestamp_starts///r)F)r*r)r,r+r3r.returnNone)r{serializable.State)rNr}r{r|)rNr}r{r()r{r)r r!r"r#r$r-r1r>r?rFrJrQ classmethodrRrKrdrHrhpropertyrjrmrprurxrz __classcell__)ras@rr(r(,s0#"1""E<= FC  J  &'   (&(G "' >%$,   , YY  '(%00rr() __future__rrrrKr%r6 dataclassesrrtypingrr mitmproxyrr r mitmproxy.coretypesr SerializableDataclassr Serializabler(__all__r&rrrsq" ! , L . . 2n0< $ $n0d   r