'hA`~ddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z mZddlmZddlmZej&ZeeddZGd d ZGd d eZGd deZdZdZGddZGddZGddeZdZGddeZ GddZ!GddZ"y)N)Optional)SSL)certs exceptions) basethread)tls IPPROTO_IPV6)cFeZdZdZdZdZdZdZdZdZ dZ d Z d Z y ) _FileLikeic.||_d|_d|_yN)o_logfirst_byte_timestampselfrs i/var/www/html/scrapers/gsc/venv/lib/python3.12/site-packages/seleniumwire/thirdparty/mitmproxy/net/tcp.py__init__z_FileLike.__init__s $(!c||_yr)rrs rset_descriptorz_FileLike.set_descriptor s rc.t|j|Sr)getattrr)rattrs r __getattr__z_FileLike.__getattr__#stvvt$$rcg|_y)zg Starts or resets the log. This will store all bytes read or written. Nrrs r start_logz_FileLike.start_log&s  rcd|_y)z$ Stops the log. Nrrs rstop_logz_FileLike.stop_log.s  rc|jduSrrrs r is_loggingz_FileLike.is_logging4syy$$rcn|js tddj|jS)z2 Returns the log as a string. z Not logging!r)r$ ValueErrorjoinrrs rget_logz_FileLike.get_log7s, ^, ,xx ""rc\|jr|jj|yyr)r$rappendrvs radd_logz_FileLike.add_log?s# ??  II  Q  rcd|_yr)rrs rreset_timestampsz_FileLike.reset_timestampsCs $(!rN) __name__ __module__ __qualname__ BLOCKSIZErrrr r"r$r(r-r/rrr r s4I) % %# )rr ceZdZdZdZy)Writerct|jdr |jjyy#tjt f$r#}t jt|d}~wwxYw)8 May raise exceptions.TcpDisconnect flushN) hasattrrr9socketerrorIOErrorr TcpDisconnectstrr+s rr9z Writer.flushIsY 4667 # 7  $LL'* 7 ..s1v66 7s4A0 A++A0c|r|jxstj|_ t|jdr,|j ||jj |S|jj |}|j |d||Sy#tjtjf$r#}tjt|d}~wwxYw)r8sendallN)rtimer:rr-rAwriterErrorr;r<rr>r?)rr,res rrCz Writer.writeSs (,(A(A(PTYY[D % 74669-LLO66>>!,, QALL2A'H IIv||, 7 ..s1v66 7sAB-0B#C%C  C%N)r0r1r2r9rCr4rrr6r6Gs 77rr6c&eZdZdZddZdZdZy)Readercnd}tj}|dk(s|dkDr|dk(s||jkDr |j}n|} |jj|}|j*xstj|_|sn$||z }|dk7r|t-|z}|dk(r|dkDr|j/||S#tj $rY(tj tjf$re|jjxsd}tj|z |krtjdY1tjtj$rtjtj$r#}tjt!|d}~wtj"$r8}|j$dk(rYd}~/tj&t!|d}~wtj($r#}tj&t!|d}~wwxYw)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 lfqj|v6~~ 6vv{{4(6)-(A(A(PTYY[D % dNF|#d)#MlfqjN V C&& &&(9(9: 2&&++-4IIK%'72JJsO$//11>> . ++--<< 7 ..s1v66## 66633 --c!f5599 6 --c!f55 6sDCH4A/H4A H4F22H4G;G;;H4H//H4Ncrd}d} |||k\r |S|jd}|dz }|s |S||z }|dk(r |S3)Nrr )rL)rsizerY bytes_readchs rreadlinezReader.readlinesj J$$6 1B !OJ  " ; rc|j|}|dk7rHt||k7r:|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_reads\ 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. rr4)rhrropendingselect)rlistrSconns rssl_read_selectrws]   dCNN + 0B   2 ub"g .q 12 s6Ac |jtjtjdk(rF|j |j xsdtdD]}|jdrn|jtj|jy#tj$rY&wxYw)z@ Does a hard close of a socket, without emitting a RST. ntiiN) shutdownr;SHUT_WRosname settimeoutrPrangerkSHUT_RDr<close)sock_s r close_socketrs$  fnn% 77d? OODOO-3 4,- yy  fnn%  JJL <<   sA4B*7"B**C?Cc,eZdZdZdZdZdZdZdZy) _ConnectionrJcttj|jd|_t tj|jd|_y)zF Set up .rfile and .wfile attributes from .connection rbwbN)rHr;SocketIO connectionrfiler6wfilers r _makefilez_Connection._makefiles:FOODOOTBC FOODOOTBC rc|r-||_|j|_|jnd|_d|_d|_d|_d|_d|_yNF)r getpeername ip_addressrrrtls_establishedfinished)rrs rrz_Connection.__init__#sQ (DO(446DO NN "DO"DODJDJ$ rc|jsy|jj}|jj}|jj }|||fSr)rrget_cipher_nameget_cipher_bitsget_cipher_version)rr~bitsversions rget_current_cipherz_Connection.get_current_cipher1sQ##..0..0//446T7""rcd|_t|jtjsgt |j dds5 |j j|j j|jjy |jjy#tj$rYLwxYw#tj$rYywxYw)NTclosedF)rrhrrrorrr9rrr>rr{rDrs rfinishz_Connection.finish:s $//3>>:4::x7JJ$$&JJ$$& JJ    ((* "//99  s$4B/C/CCCCN) r0r1r2rbufsizewbufsizerrrrr4rrrrs!HH D #rrc$eZdZdZdZdZdZy)ConnectionCloserc ||_d|_yr)rv _canceled)rrvs rrzConnectionCloser.__init__Qs rc:d|_t|jS)zH Cancel the current closer, and return a fresh one. T)rrrvrs rpopzConnectionCloser.popUs **rc|Srr4rs r __enter__zConnectionCloser.__enter__\s rcR|js|jjyyr)rrvrrrUs r__exit__zConnectionCloser.__exit___s~~ IIOO rN)r0r1r2rrrrr4rrrrPs+rrceZdZd fd ZedeejfdZdZ d dZ dZ dZ ddZ d Zd Zd Zd ZxZS) TCPClientcxt|d||_||_d|_g|_d|_||_yr)superraddresssource_addresscert server_certssnispoof_source_address)rrrr __class__s rrzTCPClient.__init__fs=  , $8!rreturnc0t|jddS)N cert_error)rrrs rssl_verification_errorz TCPClient.ssl_verification_errorost d;;rc|jrZt|jtjr t |jj yt |jyyr)rrhrror_socketrs rrzTCPClient.closess@ ??$//3>>:T__445T__- rc tjd||d|}|j}tj||j|_|r1||_|jj |jd|jjt||jtj|jj|_ |jjD]0}|jj!tj|2d|_|j$j'|j|j(j'|jy)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}s++ #   ..$//B DH OO 0 0F1C D ))+t/JJtCCEF 446 4A    $ $UZZ] 3 4 $ !!$//2 !!$//2rc0tj|||Sr)r;)rfamilytypeprotos r makesocketzTCPClient.makesockets}}VT511rc,tj|i|Sr)r; getaddrinfo)rrUkwargss rrzTCPClient.getaddrinfos!!42622rcXd}|j|jd|jddtjD]}|\}}}}}d} |j |||} |r| j ||j r| j|j |jr^ | jtjtjs/| jtjtjd| j%|| cS||tj&d#t$r8} | | jtj dt#| zd} ~ wwxYw#tj&$r} | }| | jYd} ~ ed} ~ wwxYw)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_connectionso##DLLOT\\!_aI[I[\ !C14 .B%BD !r8U;OOG,&&IId112,, #v}}f>S>ST OOFMM6;P;PRST R  + !8 ?I,,BC C%%+ JJL(55BSVK << !#JJL !s> AE7'AD3E73 E4<3E//E44E77F) F$$F)cN |j}||_|j|_ |j|_ |jt|S#tjtf$r-}t j d|j dd|d}~wwxYw)NzError connecting to "rz": )rr;r<r=rrmrr getsocknamerrrrr)rrrs rrzTCPClient.connects //1J %(446$002 %% g& ))a#'  sAB$7(BB$c:|jj|yrrrrns rrzTCPClient.settimeout ""1%rc6|jjSr)rrPrs rrPzTCPClient.gettimeouts))++rcP|jr|jjSyNrrrget_alpn_proto_negotiatedrs rrz#TCPClient.get_alpn_proto_negotiated!   ??<<> >r)NNr)r0r1r2rpropertyrrInvalidCertificateExceptionrrrrrrrrrPr __classcell__rs@rrrds]9<1W1W(X<<.3023$DL &&,rrcn |jy#tj$rEtj|ggg|j \}}}|st j dYjtj$r7}t|dd}|r|t jdt|zd}~wwxYw)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. zSelect timed outrNSSL handshake error: %s) do_handshakerrOrtrPrrRrDrrVrn)rssl_connectionrdrrFverification_errors rrrs  S  ' ' )    }}dVRT__5FGHB1 ++,>?? yy S!(t!L !(( --.G$q'.QRR  SsAB4+B4=2B//B4c:eZdZdZfdZdZdZdZdZxZ S) BaseHandlerzU The instantiator is expected to call the handle() and finish() methods. cNt||||_||_d|_yr)rrrserver clientcert)rrrrrs rrzBaseHandler.__init__s% $  rc ~tjd||d|}|j}tj||j|_|jj  t ||jd|_ |jj}|rtj||_|j j#|j|j$j#|jy#tj$r&}tjdt|zd}~wwxYw)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 ++..$//B ((* O T4?? 3 $335 #jj.DO !!$//2 !!$//2yy O))*Cd1g*MN N Os%DD<!D77D<ctrrprs rhandlezBaseHandler.handle s!!rc:|jj|yrrrs rrzBaseHandler.settimeout#rrcP|jr|jjSyrrrs rrz%BaseHandler.get_alpn_proto_negotiated&rr) r0r1r2__doc__rrrrrrrs@rrrs! 30"&rrc.eZdZdZedZdZdZy)CountercDd|_tj|_y)Nr)_count threadingLock_lockrs rrzCounter.__init__.s ^^% rc^|j5|jcdddS#1swYyxYwrrrrs rcountz Counter.count2s% ZZ ;;   s #,cp|j5|xjdz c_dddy#1swYyxYwNr^rrs rrzCounter.__enter__7, ZZ  KK1 K   ,5cp|j5|xjdzc_dddy#1swYyxYwrrrs rrzCounter.__exit__;rrN)r0r1r2rrrrrr4rrr r -s%&rr cXeZdZdZdZd dZdZejfdZ dZ dZ d dZ y ) TCPServercT||_tj|_|jj d|_|jddk(rt jdd|_ t j t jt j|_|j jt jt jd|j jt jt jd|j jtt jd|j j!|j|j s t j t j&t j|_|j jt jt jd|j jt jt jd|j j!|j|j st j t jt j|_|j jt jt jd|j jt jt jd|j j!|j|j j)|_|j j+t-|_y#t j$rI}|j r|j j#d|_|j$dk(r|Yd}~Ud}~wwxYw#t j$rI}|j r|j j#d|_|j$dk(r|Yd}~d}~wwxYw)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_INETrlistenr handler_counter)rrrFs rrzTCPServer.__init__Bs 'oo/ !"' <<?k ),,pq q  !--9K9KLDK KK " "6#4#4f6I6I1 M KK " "6#4#4f6I6I1 M KK " "<1C1CQ G KK  T\\ *{{ $mmFNNFOO P'>P""P'c4|j5 |j||t | dddy#t$r(}|jtjk(sYd}~Ad}~w|j ||YZxYw#t |wxYw#1swYyxYwr)r+handle_client_connectionOSErrorr(EINVAL handle_errorr)rrclient_addressrFs rconnection_threadzTCPServer.connection_threadvs  ! ! ) )--j.IZ( ) )  ww%,,./ >!!*n=Z( ) )s<B6 B A;A"A>"A;9A>> B  BBc |jj |jstj|jggg|\}}}|j|vr|jj \}}t jd|jjd|dd|dd|jdd|jdd |j||f}d |_ |j|jsd |_|jj%y#tj$r%|j!|||j#YfwxYw#d |_|jj%wxYw) NzTCPConnectionHandler (z: r:r^z -> ))targetrUTF)r clearr"rtr;acceptr BaseThreadrr0rr2daemonrZr ThreadErrorr0rr!)r poll_intervalrEw_e_rr1ts r serve_foreverzTCPServer.serve_foreversN !!# &--"MM4;;-RO 2r;;!#151C1C1E.J"-- NN33*1-*1- LLO LLO  $55(.9 A $AH+ #--,',D #    # # % %00+))*nE"((*+',D #    # # %s0C E$*D): E$)5E!E$ E!!E$$#Fcd|_|jj|jj |j y)NT)r"r waitr;rhandle_shutdownrs rr{zTCPServer.shutdowns8"&   "  rctr^ttj}td|tdt |z|t||td|yy)zO Called when handle_client_connection raises an exception. z(----------------------------------------)filez&Error in processing of request from %sN) tracebackr? format_excprintrn)r connection_r1fpexcs rr0zTCPServer.handle_errorsV i**,-C )" % 9DrYs  ?B5OOv~r2 ,),)^7Y7.+.b&JJr