Iic&SSKJr SSKrSSKrSSKrSSKrSSKr\R"\ 5r "SS5r "SS5r g!\a SSKJr NIf=f))urlparseNc8\rSrSrSrSrSrSrSrSr Sr S r S r S r g ) ProxyConnectionStateszz zz zzz zz N)__name__ __module__ __qualname____firstlineno__ DISCONNECTED CONNECTINGNEGOTIATE_PROPOSE NEGOTIATINGAUTHENTICATINGREQUEST_SUBMIT REQUESTING READ_ADDRESSCOMPLETE__static_attributes__r:/venv/lib/python3.13/site-packages/kafka/socks5_wrapper.pyrrs0#LJ-!K'N'NJ#LHrrcv\rSrSrSrSr\S5r\\R4Sj5r SrSr Sr S r S rS rg ) Socks5WrapperzqSocks5 proxy wrapper Manages connection through socks5 proxy with support for username/password authentication. cNSUlSUl[U5UlSUl[ R Ul[RUl URURRURRU5n[R"U5Ulg)Nr) _buffer_in _buffer_outr _proxy_url_sockrr _statesocket AF_UNSPEC _target_afi dns_lookuphostnameportrandomchoice _proxy_addr)self proxy_urlafi proxy_addrss r__init__Socks5Wrapper.__init__"sw"9- +88 !++oodoo&>&>@T@TVYZ !==5rcNUS[R[R4;$)z8Given a getaddrinfo struct, return True iff ipv4 or ipv6r)r!AF_INETAF_INET6)clsgais ris_inet_4_or_6Socks5Wrapper.is_inet_4_or_6.s 1v&..&//:::rc [[UR[R"XU[R 555$![R a#n[RSXU5 /sSnA$SnAff=f)zRReturns a list of getaddrinfo structs, optionally filtered to an afi (ipv4 / ipv6)z%DNS lookup failed for proxy %s:%d, %rN) listfilterr5r! getaddrinfo SOCK_STREAMgaierrorlogwarning)r3hostr&r,exs rr$Socks5Wrapper.dns_lookup3sn s11%11$c282D2D FGH H  KK?R PI sAAA<A71A<7A<cXlURun n[R"X25UlUR$)zOpen and record a socket. Returns the actual underlying socket object to ensure e.g. selects and ssl wrapping works as expected. )r#r)r!r)r*family sock_typer,_s rr!Socks5Wrapper.socketCs9 "**Q1a]]32 zzrcUR(aMURRUR5nURUSUlUR(aMLgg)zSend out all data that is stored in the outgoing buffer. It is expected that the caller handles error handling, including non-blocking as well as connection failure exceptions. N)rrsend)r* sent_bytess r _flush_bufSocks5Wrapper._flush_bufNsH )9)9:J#// :XaSnSn O_["R%SUR85 [RUlUR R'5 [R($[.R0"SR3U 5SSSU[:R@"UR8US5US5Ul [RBUlUR[RB:XaUR5 UR!S5nUSSS:Xa[RDUlOX["R%SUSS5 [RUlUR R'5 [R($UR[RD:XaURGS5nUSSS:XaUR!S5nOsUSSS:XaUR!S5nOX["R%SUSS5 [RUlUR R'5 [R($[RHUlUR[RH:Xag["R%SUR5 [RUlUR (aUR R'5 [R($)aRuns a state machine through connection to authentication to proxy connection request. The somewhat strange setup is to facilitate non-intrusive use from BrokerConnection state machine. This function is called with a socket in non-blocking mode. Both send and receive calls can return in EWOULDBLOCK/EAGAIN which we specifically avoid handling here. These are handled in main BrokerConnection connection loop, which then would retry calls to this function.ssrzUnrecognized SOCKS versionz !bb{}sb{}sz(Unrecognized SOCKS authentication methodsz#Socks5 proxy authentication failurezUnknown address family, %rz !bbbb{}shszProxy request failed: %rssz#Unrecognized remote address type %rz.Internal error, state %r not handled correctly)%r rr r r)r connect_exerrnoEISCONNrrusernamepasswordrrrJrVr=errorclose ECONNREFUSEDrrMstructpackformatencoderr#r!r1r2 inet_ptonrrrRr) r*addrrEsockaddrretrUuserlenpasslen addr_typeaddr_lens rrcSocks5Wrapper.connect_exqs ;;/<< </::DK ;;/:: :#'#3#3 Aq!Q**''1C#.3EE  ;;/AA A''DOO,D,D#2 $3 /;;DK ;;/;; ; OO ..#C1Qx7" 673@@    ")))1Qx7"3BB QqW$doo667doo667#);; ''9OO,,335OO,,335 $ 4BB  DE3@@    "))) ;;/>> > OO ..#Ck!3BB  ?@3@@    "))) ;;/>> >6>>1 !!V__4  68H8HI3@@    ")))%{{""8,  !1!147;Q D 0::DK ;;/:: : OO ..#C1Qx;&3@@  4c!Ah?3@@    "))) ;;/<< <..#C1Qx;&NN9-Qq[(NN:. ?QqJ3@@    ")))/88DK ;;/88 8 BDKKP+88 :: JJ   !!!r)rrr)rrr r#N)rr r r __doc__r. classmethodr5r!r"r$rJrRrVrcrrrrrrsW 6;;(.(8(8   =) G"rr) urllib.parser ImportErrorrdloggingr'r!rk getLoggerrr=rrrrrr~sX"%   !  ]"]"1"!"sA AA