hgA`ddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z mZddlmZddlmZejZeeddZGd d ZGd d eZGd deZdZdZGddZGddZGddeZdZGddeZ GddZ!GddZ"dS)N)Optional)SSL)certs exceptions) basethread)tls IPPROTO_IPV6)cHeZdZdZdZdZdZdZdZdZ dZ d Z d Z d S) _FileLikeic0||_d|_d|_dSN)o_logfirst_byte_timestampselfrs b/var/www/fb-scrape/myenv/lib/python3.11/site-packages/seleniumwire/thirdparty/mitmproxy/net/tcp.py__init__z_FileLike.__init__s $(!!!c||_dSr)rrs rset_descriptorz_FileLike.set_descriptor s rc,t|j|Sr)getattrr)rattrs r __getattr__z_FileLike.__getattr__#stvt$$$rcg|_dS)zg Starts or resets the log. This will store all bytes read or written. Nrrs r start_logz_FileLike.start_log&s  rcd|_dS)z$ Stops the log. Nrrs rstop_logz_FileLike.stop_log.s rc|jduSrrrs r is_loggingz_FileLike.is_logging4sy$$rc||stdd|jS)z2 Returns the log as a string. z Not logging!r)r$ ValueErrorjoinrrs rget_logz_FileLike.get_log7s8   -^,, ,xx """rcf|r|j|dSdSr)r$rappendrvs radd_logz_FileLike.add_log?s: ??   I  Q       rcd|_dSr)rrs rreset_timestampsz_FileLike.reset_timestampsCs$(!!!rN) __name__ __module__ __qualname__ BLOCKSIZErrrr r"r$r(r-r/rrr r sI))) %%% %%%###   )))))rr ceZdZdZdZdS)Writerct|jdr[ |jdS#tjt f$r&}t jt|d}~wwxYwdS)8 May raise exceptions.TcpDisconnect flushN) hasattrrr9socketerrorIOErrorr TcpDisconnectstrr+s rr9z Writer.flushIsw 467 # # 7 7 L'* 7 7 7 .s1vv666 7 7 7s2A.!A))A.c|r|jptj|_ t|jdr/|||j|S|j|}||d||S#tjtj f$r&}tj t|d}~wwxYwdS)r8sendallN)rtimer:rr-rAwriterErrorr;r<rr>r?)rr,res rrCz Writer.writeSs 7(,(A(PTY[[D % 7469--LLOOO6>>!,,, QALL2A2'''HIv|, 7 7 7 .s1vv666 7 7 7sAB '8B C!;!CC!N)r0r1r2r9rCr4rrr6r6Gs277777777rr6c(eZdZdZddZdZdZdS)Readerc.d}tj}|dks|dkr|dks ||jkr|j}n|} |j|}nX#tj$rYntjtjf$r_|jpd}tj|z |krtj dYtj tj $rtj tj$r&}tjt!|d}~wtj$r6}|jdkrYd}~ntjt!|d}~wtj$r&}tjt!|d}~wwxYw|jptj|_|sn+||z }|dkr|t-|z}|dk|dk|||S)zG If length is -1, we read until connection closes. rri,皙?N)rJzUnexpected EOF)rBr3rreadrZeroReturnErrorWantWriteError WantReadError gettimeoutsleepr TcpTimeoutr;timeoutr<r>r? SysCallErrorargs TlsExceptionrDrlenr-)rlengthresultstartrlendatarSrFs rrLz Reader.readgs. llfqjj||v66~ 6v{{4((&   &(9: 2 2 2&++--4IKK%'722JsOOOH$/111> . . . +---< 7 7 7 .s1vv666# 6 6 66333EEEE -c!ff5559 6 6 6 -c!ff555 6(,(A(PTY[[D %  dNF||#d))#MllfqjjN V sCAF0-A#F0AF0!D55F0 E8!E88F0 !F++F0Ncvd}d} |||krn*|d}|dz }|sn ||z }|dkrn3|S)NrrT )rL)rsizerY bytes_readchs rreadlinezReader.readlinesh  J$$6$61B !OJ " ;;  rc||}|dkrOt||kr<|stjtjd|dt||S)zu Like .read, but is guaranteed to either return length bytes, or raise an exception. rJz Expected z bytes, got )rLrWrr>TcpReadIncomplete)rrXrYs r safe_readzReader.safe_readsx 6"" R< 0 for any of the connections in rlist, we avoid the select syscall and **will not include any other connections which may or may not be ready**. Args: rlist: wait until ready for reading Returns: subset of rlist which is ready for reading. cvg|]6}t|tjr|dk4|7S)r)rhrropending).0conns r z#ssl_read_select..sI    dCN + + 04 0B0B 0B0B0Brr4r)select)rlistrSs rssl_read_selectrzsB      2 ub"g . .q 12rc |tjtjdkrR||pdtdD]}|dsn|tj n#tj $rYnwxYw| dS)z@ Does a hard close of a socket, without emitting a RST. ntiiN) shutdownr;SHUT_WRosname settimeoutrPrangerkSHUT_RDr<close)sock_s r close_socketrs$  fn%%% 7d?? OODOO--3 4 4 4,--  yyE fn%%%% <      JJLLLLLsB B##B54B5c.eZdZdZdZdZdZdZdZdS) _ConnectionrJcttj|jd|_t tj|jd|_dS)zF Set up .rfile and .wfile attributes from .connection rbwbN)rHr;SocketIO connectionrfiler6wfilers r _makefilez_Connection._makefilesBFODOTBBCC FODOTBBCC rc|r5||_||_|nd|_d|_d|_d|_d|_d|_dSNF)r getpeername ip_addressrrrtls_establishedfinished)rrs rrz_Connection.__init__#sf  (DO(4466DO NN    "DO"DODJDJ$ rc|jsdS|j}|j}|j}|||fSr)rrget_cipher_nameget_cipher_bitsget_cipher_version)rrbitsversions rget_current_cipherz_Connection.get_current_cipher1sX# 4..00..00/4466T7""rcd|_t|jtjszt |jddsI |j|jn#tj $rYnwxYw|j dS |j dS#tj $rYdSwxYw)NTclosedF)rrhrrrorrr9rrr>rr~rDrs rfinishz_Connection.finish:s $/3>:: 4:x77 J$$&&&J$$&&&&!/D J        ((*****9    s#2A11BB"B==CCN) r0r1r2rbufsizewbufsizerrrrr4rrrrs]HH D D D   ###rrc&eZdZdZdZdZdZdS)ConnectionCloserc"||_d|_dSr)rv _canceled)rrvs rrzConnectionCloser.__init__Qs rc8d|_t|jS)zH Cancel the current closer, and return a fresh one. T)rrrvrs rpopzConnectionCloser.popUs ***rc|Srr4rs r __enter__zConnectionCloser.__enter__\s rcJ|js|jdSdSr)rrvrrrUs r__exit__zConnectionCloser.__exit___s.~  IOO       rN)r0r1r2rrrrr4rrrrPsP+++rrceZdZdfd ZedeejfdZdZ ddZ dZ dZ dd Z d Zd Zd Zd ZxZS) TCPClientNctd||_||_d|_g|_d|_||_dSr)superraddresssource_addresscert server_certssnispoof_source_address)rrrr __class__s rrzTCPClient.__init__fsN  , $8!!!rreturnc.t|jddS)N cert_error)rrrs rssl_verification_errorz TCPClient.ssl_verification_errorost d;;;rc|jrPt|jtjrt |jjdSt |jdSdSr)rrhrror_socketrs rrzTCPClient.closess] ? .$/3>:: .T_455555T_-----  . .rc tjd||d|}|j}tj||j|_|r4||_|j|d|jt||jtj |j |_ |jD].}|jtj |/d|_|j|j|j|jdS)N) alpn_protosridnaTr4)rcreate_client_contextrrrorset_tlsext_host_nameencodeset_connect_statedo_ssl_handshakerCertget_peer_certificaterget_peer_cert_chainrr*rrrr)rrr sslctx_kwargscontextris rconvert_to_tlszTCPClient.convert_to_tls}sB+ #     .$/BB  EDH O 0 0F1C1C D D D ))+++t///JtCCEEFF 4466 4 4A   $ $UZ]] 3 3 3 3# !!$/222 !!$/22222rc.tj|||Sr)r;)rfamilytypeprotos r makesocketzTCPClient.makesockets}VT5111rc$tj|i|Sr)r; getaddrinfo)rrUkwargss rrzTCPClient.getaddrinfos!426222rcPd}||jd|jddtjD]S}|\}}}}}d} ||||} |r| ||jr| |j|jr | tj tj s+| tj tj dnL#t$r?} | | tjdt#| zd} ~ wwxYw| || cS#tj$r#} | }| | Yd} ~ Md} ~ wwxYw||tjd)Nrr^z$Failed to spoof the source address: z!getaddrinfo returns an empty list)rrr; SOCK_STREAMrrrbindr getsockoptSOL_IPIP_TRANSPARENT setsockopt Exceptionrrrmr?connectr<) rrSerrresafsocktyper canonnamesarrFrs rcreate_connectionzTCPClient.create_connections##DLOT\!_aI[\\ ! !C14 .B%BD !r8U;;-OOG,,,&3IId1222,  #v}f>STTU OOFM6;PRSTTT$+ JJLLL(5BSVVK  R    < ! ! !#JJLLL ! ?I,BCC Cs> AE AC65E6 D?:D::D??EF *FF cl |}nC#tjtf$r*}t jd|jdd|d}~wwxYw||_||_ | |_ | t|S)NzError connecting to "rz": )rr;r<r=rrmrr getsocknamerrrrr)rrrs rrzTCPClient.connects //11JJ g&   ))a##'   %(4466$0022 %%%sA%AAc:|j|dSrrrrns rrzTCPClient.settimeout ""1%%%%%rc4|jSr)rrPrs rrPzTCPClient.gettimeouts))+++rcF|jr|jSdSNrrrget_alpn_proto_negotiatedrs rrz#TCPClient.get_alpn_proto_negotiated&   ?<<>> >3r)NNr)r0r1r2rpropertyrrInvalidCertificateExceptionrrrrrrrrrPr __classcell__rs@rrrds999999<1W(X<<<X<...33330222333$D$D$D$DL & & &&&&,,,rrc| |n#tj$rGtj|ggg|\}}}|st jdYltj$r>}t|dd}|r|t j dt|zd}~wwxYwdS)aPeform the SSL handshake. If a timeout has been set on the socket externally, it causes OpenSSL to raise EWOULDBLOCK which breaks the handshake. This function will catch that condition and will retry the operation until it succeeds or some other error occurs. See https://github.com/pyca/pyopenssl/issues/168 for more information. Args: sock: The underlying socket. ssl_connection: The OpenSSL Connection object. TzSelect timed outrNSSL handshake error: %s) do_handshakerrOrxrPrrRrDrrVrn)rssl_connectionrdrrFverification_errors rrrs S  ' ' ) ) ) )    }dVRT__5F5FGGHB1 @ +,>??? Hy S S S!(t!L!L ! S(( -.G$q''.QRRR  S sAB9-B9;9B44B9c:eZdZdZfdZdZdZdZdZxZ S) BaseHandlerzU The instantiator is expected to call the handle() and finish() methods. ctt|||_||_d|_dSr)rrrserver clientcert)rrrrrs rrzBaseHandler.__init__s4 $$$  rc Btjd||d|}|j}tj||j|_|j t ||jn;#tj$r)}tj dt|zd}~wwxYwd|_ |j }|rtj||_|j|j|j|jdS)zq Convert connection to SSL. For a list of parameters, see tls.create_server_context(...) )rkeyrNTr4)rcreate_server_contextrrroset_accept_staterrDrrVrnrrrrrrrr)rrrrrrr,s rrzBaseHandler.convert_to_tlss) +.$/BB ((*** O T4? 3 3 3 3y O O O)*Cd1gg*MNN N O#3355  /#j..DO !!$/222 !!$/22222sA++B#:$BB#ctrrprs rhandlezBaseHandler.handle s!!rc:|j|dSrrrs rrzBaseHandler.settimeout#rrcF|jr|jSdSrrrs rrz%BaseHandler.get_alpn_proto_negotiated&rr) r0r1r2__doc__rrr rrrrs@rrrs~ 3330"""&&&rrc6eZdZdZedZdZdZdS)CountercDd|_tj|_dS)Nr)_count threadingLock_lockrs rrzCounter.__init__.s ^%% rcR|j5|jcdddS#1swxYwYdSrrrrs rcountz Counter.count2ss Z  ;                  s   cf|j5|xjdz c_ddddS#1swxYwYdSNr^rrs rrzCounter.__enter__7~ Z   KK1 KK                   &**cf|j5|xjdzc_ddddS#1swxYwYdSrrrs rrzCounter.__exit__;rrN)r0r1r2rrrrrr4rrrr-s\&&&XrrcPeZdZdZdZd dZdZejfdZ dZ dZ d d Z d S) TCPServerc8||_tj|_|jd|_|jddkrt jdd|_ t jt jt j |_|j t j t j d|j t j t j d|j tt jd|j|jnP#t j$r>}|jr|jd|_|jdkr|Yd}~nd}~wwxYw|js t jt jt j |_|j t j t j d|j t j t j d|j|jnP#t j$r>}|jr|jd|_|jdkr|Yd}~nd}~wwxYw|jst jt jt j |_|j t j t j d|j t j t j d|j|j|j|_|jt-|_dS)NFr localhostzOBinding to 'localhost' is prohibited. Please use '::1' or '127.0.0.1' directly.r^b)rrEvent_TCPServer__is_shut_downset_TCPServer__shutdown_requestr;r<AF_INET6rr SOL_SOCKET SO_REUSEADDR SO_KEEPALIVEr IPV6_V6ONLYrrerrnoAF_INETrlistenrhandler_counter)rrrFs rrzTCPServer.__init__Bs 'o// !!!"' <?k ) ),pqq q  !-9KLLDK K " "6#4f6I1 M M M K " "6#4f6I1 M M M K " "<1CQ G G G K  T\ * * * *|   { $ !!###DKw"}}}}}}  {  $mFNF!!*n=====Z(((( Z((((( ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )sHB!A6 A#AA6A#!A6&B6BBBBrKc |j |jstj|jggg|\}}}|j|vr|j\}}t jd|jj d|dd|dd|j dd|j dd |j ||f}d |_ | n?#tj$r-||||YnwxYw|jd |_|jdS#d |_|jwxYw) NzTCPConnectionHandler (z: r:r^z -> ))targetrUTF)r#clearr%rxr;acceptr BaseThreadrr0rr5daemonrZr ThreadErrorr3rr$)r poll_intervalrEw_e_rr4ts r serve_foreverzTCPServer.serve_forevers !!### &- +"M4;-ROO 2r;!##151C1C1E1E.J"-- N333*1---*1--- LOOO LOOO  $5(.9   A $AH+ $0+++))*nEEE"((*****+%- +,',D #   # # % % % % %',D #   # # % % % %s0B/E C E 9DE D E "E+cd|_|j|j|dS)NT)r%r#waitr;rhandle_shutdownrs rr~zTCPServer.shutdownsK"&   """  rctrvttj}td|tdt |z|t||td|dSdS)zO Called when handle_client_connection raises an exception. z(----------------------------------------)filez&Error in processing of request from %sN) tracebackr? format_excprintrn)r connection_r4fpexcs rr3zTCPServer.handle_errors  &i*,,--C )" % % % % 9Dr\s  ????????BBBBBB555555Owv~r22 ,),),),),),),),)^77777Y777.....+...b&JJJJJJJJJJr