vKgA`~SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJ r SSK J r SSK J r Jr SSKJr SSKJr \R&r\"\SS5r"S S 5r"S S \5r"S S\5rSrSr"SS5r"SS5r"SS\5rSr"SS\5r "SS5r!"SS5r"g)N)Optional)SSL)certs exceptions) basethread)tls IPPROTO_IPV6)cN\rSrSrSrSrSrSrSrSr Sr S r S r S r S rg ) _FileLikeic,XlSUlSUlgN)o_logfirst_byte_timestampselfrs i/var/www/highfloat_scraper/venv/lib/python3.13/site-packages/seleniumwire/thirdparty/mitmproxy/net/tcp.py__init___FileLike.__init__s $(!cXlgr)rrs rset_descriptor_FileLike.set_descriptor src.[URU5$r)getattrr)rattrs r __getattr___FileLike.__getattr__#stvvt$$rc/Ulg)zG Starts or resets the log. This will store all bytes read or written. Nrrs r start_log_FileLike.start_log&s  rcSUlg)z Stops the log. Nr"r#s rstop_log_FileLike.stop_log.s  rcURSL$rr"r#s r is_logging_FileLike.is_logging4syy$$rcxUR5(d [S5eSRUR5$)z Returns the log as a string. z Not logging!r)r* ValueErrorjoinrr#s rget_log_FileLike.get_log7s/  ^, ,xx ""rcfUR5(aURRU5 ggr)r*rappendrvs radd_log_FileLike.add_log?s& ??   II  Q  rcSUlgrrr#s rreset_timestamps_FileLike.reset_timestampsCs $(!r)rrrN)__name__ __module__ __qualname____firstlineno__ BLOCKSIZErrrr$r'r*r/r5r9__static_attributes__rrr r s4I) % %# )rr c \rSrSrSrSrSrg)WriterGc[URS5(aURR5 gg![R[ 4a$n[ R"[U55eSnAff=f)$ May raise exceptions.TcpDisconnect flushN) hasattrrrGsocketerrorIOErrorr TcpDisconnectstrr3s rrG Writer.flushIs\ 4667 # # 7  $LL'* 7 ..s1v66 7s9A7A22A7cU(aUR=(d [R"5Ul[URS5(a,UR U5 URR U5$URR U5nUR USU5 U$g![R[R4a$n[R"[U55eSnAff=f)rFsendallN)rtimerHrr5rPwriterErrorrIrJrrLrM)rr4res rrR Writer.writeSs (,(A(A(PTYY[D % 74669--LLO66>>!,, QALL2A'H IIv||, 7 ..s1v66 7sAB/=0B//$C7C22C7r8N)r;r<r=r>rGrRr@rArrrCrCGs 77rrCc0\rSrSrSrSSjrSrSrSrg) ReaderecSn[R"5nUS:XdUS:aUS:XdXR:a URnOUnURRU5nUR*=(d [R"5UlU(dO(X%- nUS:waU[-U5-nUS:XaMUS:aMUR/U5 U$![R a M*[R [R4ao URR5=(d Sn[R"5U- U:a[R"S5 GMO[R"5e[Ra [R"5e[Ra$n[R"[!U55eSnAf[R"a;nUR$S:XaSnAGMC[R&"[!U55eSnAf[R(a$n[R&"[!U55eSnAff=f)z3 If length is -1, we read until connection closes. rri,皙?N)r[zUnexpected EOF)rQr?rreadrZeroReturnErrorWantWriteError WantReadError gettimeoutsleepr TcpTimeoutrItimeoutrJrLrM SysCallErrorargs TlsExceptionrSrlenr5)rlengthresultstartrlendatardrUs rr] Reader.readgs lfqj|v6~~ 6vv{{4(6)-(A(A(PTYY[D % NF|#d)#MlfqjN V C&& &&(9(9: 2&&++-4IIK%'72JJsO$//11>> . ++--<< 7 ..s1v66## 66633 --c!f5599 6 --c!f55 6sD CI+A8I'AI7GI-H#H##I:IINcSnSnUbX1:aU$URS5nUS- nU(dU$X$- nUS:XaU$M:)Nrr )r])rsizerj bytes_readchs rreadlineReader.readlinesf J$6 1B !OJ   ; rcURU5nUS:waR[U5U:waCU(d[R"5e[R"SU<S[U5<35eU$)zU Like .read, but is guaranteed to either return length bytes, or raise an exception. r[z Expected z bytes, got )r]rhrrLTcpReadIncomplete)rrirjs r safe_readReader.safe_reads\ 6" Rr]ruryrr@rArrrXrXes.` PrrXcUVs/sH<n[U[R5(dM$UR5S:dM:UPM> sn=(d [R"USSU5S$s snf)a This is a wrapper around select.select() which also works for SSL.Connections by taking ssl_connection.pending() into account. Caveats: If .pending() > 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. rrA)r|rrpendingselect)rlistrdconns rssl_read_selectrsg   dCNN + 04 0B   2 ub"g .q 12 s"A-A-A-cUR[R5 [RS:XaRUR UR 5=(d S5 [S5HnURS5(aM O UR[R5 UR5 g![Ra N'f=f)z8 Does a hard close of a socket, without emitting a RST. ntiiN) shutdownrISHUT_WRosname settimeoutrarangerSHUT_RDrJclose)sock_s r close_socketrs$  fnn% 77d? OODOO-3 4,-yy. fnn%  JJL <<   sA=B7#B77C Cc4\rSrSrSrSrSrSrSrSr Sr g) _Connectionir[c[[R"URS55Ul[ [R"URS55Ulg)z6 Set up .rfile and .wfile attributes from .connection rbwbN)rXrISocketIO connectionrfilerCwfiler#s r _makefile_Connection._makefiles:FOODOOTBC FOODOOTBC rcU(a,XlUR5UlUR5 OSUlSUlSUlSUlSUlSUlgNF)r getpeername ip_addressrrrtls_establishedfinished)rrs rr_Connection.__init__#sO (O(446DO NN "DO"DODJDJ$ rcUR(dgURR5nURR5nURR 5nXU4$r)rrget_cipher_nameget_cipher_bitsget_cipher_version)rrbitsversions rget_current_cipher_Connection.get_current_cipher1sO##..0..0//4467""rcSUl[UR[R5(dl[ UR SS5(d5UR R5 UR R5 URR5 gURR5 g![Ra NMf=f![Ra gf=f)NTclosedF)rr|rrrrrrGrrrLrrrSr#s rfinish_Connection.finish:s $//3>>::4::x77JJ$$&JJ$$& JJ    ((* "//99  s$4B9C9CCC*)C*)rrrrrrN) r;r<r=r>rbufsizewbufsizerrrrr@rArrrrs!HH D #rrc,\rSrSrSrSrSrSrSrg)ConnectionCloseriPcXlSUlgr)r _canceled)rrs rrConnectionCloser.__init__Qs rc:SUl[UR5$)z4 Cancel the current closer, and return a fresh one. T)rrrr#s rpopConnectionCloser.popUs **rcU$rrAr#s r __enter__ConnectionCloser.__enter__\s rc\UR(dURR5 ggr)rrrrrfs r__exit__ConnectionCloser.__exit___s~~ IIOO r)rrN) r;r<r=r>rrrrr@rArrrrPs+rrc^\rSrSrSU4Sjjr\S\\R4Sj5r Sr SSjr Sr Sr SS jrS rS rS rS rSrU=r$) TCPClientidcr>[TU]S5 XlX lSUl/UlSUlX0lgr)superraddresssource_addresscert server_certssnispoof_source_address)rrrr __class__s rrTCPClient.__init__fs7  , $8!rreturnc0[URSS5$)N cert_error)rrr#s rssl_verification_error TCPClient.ssl_verification_errorost d;;rcUR(a_[UR[R5(a [ URR 5 g[ UR5 ggr)rr|rrr_socketr#s rrTCPClient.closessC ??$//3>>::T__445T__- rc [R"SUUS.UD6nURn[R"X@R5UlU(a0XlURR URS55 URR5 [XPR5 [R"URR55Ul URR5H2nURR![R"U55 M4 SUlUR$R'UR5 UR(R'UR5 g)N) alpn_protosridnaTrA)rcreate_client_contextrrrrset_tlsext_host_nameencodeset_connect_statedo_ssl_handshakerCertget_peer_certificaterget_peer_cert_chainrr2rrrr)rrr sslctx_kwargscontextris rconvert_to_tlsTCPClient.convert_to_tls}s ++ #   ..//B H OO 0 0F1C D ))+/JJtCCEF 446A    $ $UZZ] 37 $ !!$//2 !!$//2rc0[R"XU5$r)rI)rfamilytypeprotos r makesocketTCPClient.makesockets}}V511rc.[R"U0UD6$r)rI getaddrinfo)rrfkwargss rrTCPClient.getaddrinfos!!42622rcSnURURSURSS[R5HnUupEpgnSn UR XEU5n U(aU R U5 UR (aU RUR 5 UR(acU R[R[R5(d/U R[R[RS5 U R%U5 U s $ UbUe[R&"S5e![a:n U bU R5 [R "S[#U 5-5eSn A ff=f![R&a(n U nU bU R5 Sn A GMSn A GMSn A ff=f)Nrrpz$Failed to spoof the source address: z!getaddrinfo returns an empty list)rrrI SOCK_STREAMrrrbindr getsockoptSOL_IPIP_TRANSPARENT setsockopt ExceptionrrrrMconnectrJ) rrderrresafsocktyper canonnamesarrUrs rcreate_connectionTCPClient.create_connectionsn##DLLOT\\!_aI[I[\C14 .B%BD !rU;OOG,&&IId112,, #v}}f>S>STT OOFMM6;P;PRST R  +]8 ?I,,BC C%%+ JJL(55BSVK << !#JJLL$ !s> A'F3A"EF F 5FF  FG "GG cTUR5nXlUR5Ul UR5Ul UR5 [U5$![R[4a0n[R "SUR S<SU<35eSnAff=f)NzError connecting to "rz": )rrIrJrKrrrr getsocknamerrrrr)rrrs rrTCPClient.connects //1J %(446$002 %% g& ))a#'  sAB'7+B""B'c:URRU5 grrrrns rrTCPClient.settimeout ""1%rc6URR5$r)rrar#s rraTCPClient.gettimeouts))++rcZUR(aURR5$gNrrrget_alpn_proto_negotiatedr#s rr#TCPClient.get_alpn_proto_negotiated!   ??<<> >r) rrrrrrrrr)NNr)r;r<r=r>rpropertyrrInvalidCertificateExceptionrrrrrrrrrarr@ __classcell__rs@rrrdsb9<1W1W(X<<.3023$DL &&,rrcUR5 g![RaM [R"U///UR 55un nU(d[ R "S5eMs[Ra=n[USS5nU(aUe[ R"S[U5-5eSnAff=f)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_handshakerr`rrarrcrSrrgr)rssl_connectionrdrrUverification_errors rrrs  S  ' ' )    }}dVRT__5FGHB1 ++,>?? yy S!(t!L !(( --.G$q'.QRR  SsAC4C8B??CcD^\rSrSrSrU4SjrSrSrSrSr Sr U=r $) BaseHandlerizI The instantiator is expected to call the handle() and finish() methods. cJ>[TU]U5 X lX0lSUlgr)rrrserver clientcert)rrrr'rs rrBaseHandler.__init__s! $  rc [R"SUUS.UD6nURn[R"X@R5UlURR 5 [ XPR5 SUl URR5nU(a[R"U5UlUR R#UR5 UR$R#UR5 g![Ra'n[R"S[U5-5eSnAff=f)zY Convert connection to SSL. For a list of parameters, see tls.create_server_context(...) )rkeyrNTrA)rcreate_server_contextrrrset_accept_staterrSrrgrrrrrr(rrr)rrr+rrrr4s rrBaseHandler.convert_to_tlss ++..//B ((* O T?? 3 $335 #jj.DO !!$//2 !!$//2yy O))*Cd1g*MN N Os&D E"D??Ec[errr#s rhandleBaseHandler.handle s!!rc:URRU5 grr rs rrBaseHandler.settimeout#rrcZUR(aURR5$grrr#s rr%BaseHandler.get_alpn_proto_negotiated&rr)rr(rr'r) r;r<r=r>__doc__rrr1rrr@rrs@rr%r%s& 30"&rr%c6\rSrSrSr\S5rSrSrSr g)Counteri-cFSUl[R"5Ulg)Nr)_count threadingLock_lockr#s rrCounter.__init__.s ^^% rchUR URsSSS5 $!,(df  g=frr>r;r#s rcount Counter.count2s ZZ;;ZZs # 1czUR U=RS- slSSS5 g!,(df  g=fNrprAr#s rrCounter.__enter__7! ZZ KK1 KZZ, :czUR U=RS-slSSS5 g!,(df  g=frErArs rrCounter.__exit__;rGrH)r;r>N) r;r<r=r>rrrBrrr@rArrr9r9-s%&rr9cf\rSrSrSrSrS SjrSr\R4Sjr Sr Sr S S jr S rg ) TCPServeri@cXl[R"5UlURR 5 SUlURSS:Xa[ R"S5eSUl[ R "[ R[ R5UlUR R[ R[ RS5 UR R[ R[ RS5 UR R[[ RS5 UR R!UR5 UR (d[ R "[ R&[ R5UlUR R[ R[ RS5 UR R[ R[ RS5 UR R!UR5 UR (d[ R "[ R[ R5UlUR R[ R[ RS5 UR R[ R[ RS5 UR R!UR5 UR R)5UlUR R+5 [-5Ulg![ RaOnUR (aUR R#5 SUlUR$S:XaUeSnAGNhSnAff=f![ RaOnUR (aUR R#5 SUlUR$S:XaUeSnAGNSnAff=f)NFr localhostzOBinding to 'localhost' is prohibited. Please use '::1' or '127.0.0.1' directly.rpb)rr<Event_TCPServer__is_shut_downset_TCPServer__shutdown_requestrIrJAF_INET6rr SOL_SOCKET SO_REUSEADDR SO_KEEPALIVEr IPV6_V6ONLYrrerrnoAF_INETr listenr9handler_counter)rrrUs rrTCPServer.__init__Bs 'oo/ !"' <<?k ),,pq q  !--9K9KLDK KK " "6#4#4f6I6I1 M KK " "6#4#4f6I6I1 M KK " "<1C1CQ G KK  T\\ *{{ $mmFNNFM;CO!;OAOO!Q5AP??Qc>UR URX5 [ U5 SSS5 g![a)nUR[R:XdeSnANCSnAf UR X5 N[=f![ U5 f=f!,(df  g=fr)r\handle_client_connectionOSErrorrYEINVAL handle_errorr)rrclient_addressrUs rconnection_threadTCPServer.connection_threadvs|  ! ! )--jIZ(" !  ww%,,./ >!!*=Z(" !s<B5 B A;A#A>#A;9A>> B  B Bc 0URR5 UR(d[R"UR///U5up#nURU;aURR 5upV[ R"SURR<SUS<SUS<SURS<SURS<S3 URXV4S9nS Ul UR5 UR(dMS UlURR%5 g![Ra$ UR!XV5 UR#5 Nlf=f!S UlURR%5 f=f) NzTCPConnectionHandler (z: r:rpz -> ))targetrfTF)rQclearrSrrIacceptr BaseThreadrr;rrddaemonrkr< ThreadErrorrbrrR)r poll_intervalrTw_e_rrcts r serve_foreverTCPServer.serve_foreversI !!# &--"MM4;;-RO r;;!#151C1C1E.J"-- NN33*1-*1- LLO LLO  $55(9 A $AH+ #---,',D #    # # % %00+))*E"((*+',D #    # # %s0CE22D7E275E/,E2.E//E22#FcSUlURR5 URR 5 UR 5 g)NT)rSrQwaitrIrhandle_shutdownr#s rrTCPServer.shutdowns8"&   "  rc[(aR[[R"55n[SUS9 [S[ U5-US9 [XCS9 [SUS9 gg)z; Called when handle_client_connection raises an exception. z(----------------------------------------)filez&Error in processing of request from %sN) tracebackrM format_excprintr)r connection_rcfpexcs rrbTCPServer.handle_errorsV 9i**,-C )" % 9Drrdrsrsysstderrrbr_rwrr@rArrrLrL@s42)h) &8 rs  ?B5OOv~r2 ,),)^7Y7.+.b&JJr