+ 0j+/^RIt^RIt^RIHt^RIHt^RIHt^RIH t H t H t H t !RR] ]P4t!RR ] ]P4t!R R ] ]P4t!R R ] ]P4t!RR]P&4t!RR]P&4t!RR]P&4t!RR]P&4t!RR]P&4t!RR]P&4t!RR]P&4t!RR]P64t]P:]]3,t!RR4tR#) N) StrOrBytes)singledispatchmethod) ProtocolError) AddressTypedecode_addressencode_address#get_address_port_tuple_from_addressc*]tRt^tRtRtRtRtRtRt R#)SOCKS5AuthMethodz-Enumeration of SOCKS5 authentication methods.N) __name__ __module__ __qualname____firstlineno____doc__NO_AUTH_REQUIREDGSSAPIUSERNAME_PASSWORDNO_ACCEPTABLE_METHODS__static_attributes__rc/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/socksio/socks5.pyr r s7 F#rr c&]tRt^tRtRtRtRtRtR#) SOCKS5CommandzEnumeration of SOCKS5 commands.r rrN) rrrrrCONNECTBIND UDP_ASSOCIATErrrrrrs)G DMrrcLa]tRt^ toRtRtRtRt]V3RlRl4t Rt Vt R#) SOCKS5ATypez$Enumeration of SOCKS5 address types.r rc$<V^8dQhRS[RR/#)atypereturnr$)r)format __classdict__s"r __annotate__SOCKS5AType.__annotate__(s  { } rcV\P8Xd\P#V\P8Xd\P #V\P 8Xd\P#\V4hN) rIPV4r$ IPV4_ADDRESSDN DOMAIN_NAMEIPV6 IPV6_ADDRESS ValueError)clsr(s&&r from_atypeSOCKS5AType.from_atype'sY K$$ $++ + knn $** * k&& &++ +rrN) rrrrrr1r3r5 classmethodr8r__classdictcell__r+s@rr$r$ s).LKL  rr$c>]tRt^2tRtRtRtRtRtRt Rt Rt R t R t R tR #) SOCKS5ReplyCodez"Enumeration of SOCKS5 reply codes.r r rrr%rN)rrrrr SUCCEEDEDGENERAL_SERVER_FAILURE!CONNECTION_NOT_ALLOWED_BY_RULESETNETWORK_UNREACHABLEHOST_UNREACHABLECONNECTION_REFUSED TTL_EXPIREDCOMMAND_NOT_SUPPORTEDADDRESS_TYPE_NOT_SUPPORTEDrrrrr>r>2s9,I$(/%! K#!(rr>cBa]tRt^@toRtV3RlRltV3RltRtVtR#)SOCKS5AuthMethodsRequestzEncapsulates a request to the proxy for available authentication methods. Args: methods: A list of acceptable authentication methods. c <V^8dQhRS[/#r'r)bytes)r*r+s"rr,%SOCKS5AuthMethodsRequest.__annotate__Is   u  rc RPR\VP4P^RR7RPVP4.4#)z=Packs the instance into a raw binary in the appropriate form.rr?big byteorder)joinlenmethodsto_bytesselfs&rdumpsSOCKS5AuthMethodsRequest.dumpsIsIxxDLL!**1*>&   rcJ<V^8dQh/S[PS[,;R&#)r'rY)typingListr )r*r+s"rr,rR@s[[) **rrN rrrrrr]__annotate_func__rr;r<s@rrMrM@s   rrMcLa]tRt^UtoRt]V3RlRl4tV3RltRtVt R#)SOCKS5AuthReplyzEncapsulates a reply from the proxy with the authentication method to be used. Args: method: The authentication method to be used. Raises: ProtocolError: If the data does not conform with the expected structure. c$<V^8dQhRS[RR/#)r'datar)rerP)r*r+s"rr,SOCKS5AuthReply.__annotate__bs<<<#4 12 2 <.tCy9: : < 12 ; Q& &&99  ZZ;33 3tyy>R' ''99 ^F??1?6B BrcJ<V^8dQh/S[;R&S[;R&S[;R&S[;R&#)r'rr(rr)rr$rQr)r*r+s"rr,rs7  K IrrN) rrrrrr:rr]propertyrrcrr;r<s@rrrsF  6  " C C{rrcLa]tRt^toRt]V3RlRl4tV3RltRtVt R#) SOCKS5ReplyzEncapsulates a reply from the SOCKS5 proxy server Args: reply_code: The code representing the type of reply. atype: The address type of the addr field. addr: Optional IP address returned. port: The port number returned. c$<V^8dQhRS[RR/#)r'rgr)rrP)r*r+s"rr,SOCKS5Reply.__annotate__s<<<=rrfrom_socks5_atyper from_bytesr6)r7rgr(rns&& rroSOCKS5Reply.loadss 9  12 2 <S *E*495#K$A$A%$H$qQS*U^^DI^?    < 12 ; r$strr)r*r+s"rr,rs7   I IrrNrrr<s@rrrs%<s{{rc$<V^8dQhRS[RR/#r'requestr)N)SOCKS5RequestType)r*r+s"rr,rDs$$-$$$rc \4h)zPacks a request object and adds it to the send data buffer. Also progresses the protocol state of the connection. Args: request: The request instance to be packed. rr\rs&&rsendSOCKS5Connection.sendCs "##rc$<V^8dQhRS[RR/#rrM)r*r+s"rr,rOs44%=4$4rc~V;PVP4, un\PVnR#r/)rr]rrrrs&&r _auth_methodsSOCKS5Connection._auth_methodsNs& gmmo-!33 rc$<V^8dQhRS[RR/#r)rt)r*r+s"rr,rTs../L.QU.rcVP\P8wd \R4h\PVnV;P VP 4, unR#)z/Not currently waiting for username and passwordN)rrrrrrr]rs&&r_auth_username_password(SOCKS5Connection._auth_username_passwordSsD ;;+JJ J QR R!AA  gmmo-rc$<V^8dQhRS[RR/#rr)r*r+s"rr,r[s.. 8.T.rcVP\P8d \R4hV;PVP 4, unR#)zASOCKS5 connections must be authenticated before sending a requestN)rrrrrr]rs&&r_commandSOCKS5Connection._commandZs= ;;99 9S  gmmo-rcT<V^8dQhRS[RS[PS[S[S[3,/#)r'rgr))rQr`rrerr~)r*r+s"rr,rbs.$$$$$$ o{4OO P$$rc @VP\P8Xd\P V4pVP \ P8Xd\PVnV#VP \ P8Xd\PVnV#VP\P8XdV\P V4pVP'd\PVnV#\PVnV#VP\P8Xdc\P V4pVP \"P$8Xd\P&VnV#\PVnV#\)4h)zUnpacks response data into a reply object. Args: data: The raw response data from the proxy server. Returns: A reply instance corresponding to the connection state and reply data. )rrrrerormr rrrrrr~rrrrr>rCrr)r\rg auth_replyusername_password_replyreplys&& r receive_dataSOCKS5Connection.receive_databs: ;;+77 7(..t4J  $4$F$FF)NN  ""&6&G&GG)>>   ;;+EE E&A&G&G&M #&...)>> + **44 * * ;;+:: :%%d+E?#<#<<)66 L*44 L!##rc <V^8dQhRS[/#rOrP)r*r+s"rr,rserc N\VP4p\4VnV#)zaReturns the data to be sent via the I/O library of choice. Also clears the connection's buffer. )rQrr)r\rgs& r data_to_sendSOCKS5Connection.data_to_sends# T''(&[ r)rrrN)rrrrrrrrrrregisterrMrrtrrrrrrr;r<s@rrr2s 77 $$ ]]+,4-4 ]]01.2.  ]]'(.).$$$$Lrr) enumr`_typesrcompatr exceptionsrutilsrrrr rQEnumr rr$r> NamedTuplerMrertr~rrrIntEnumrrrrrrrrs (%$udii$E499 % $ )eTYY ) v00 * F$5$5 . 0&"3"3 0GC6,,GCT&<&##&