B ˽eny @szddlmZyddlmZWn ek r<ddlmZYnXddlmZmZm Z ddl Z ddl m Z ddl Z ddlZddlmZddlZddlZddlZdZejdkrejd kry ddlZWnek red YnXe eZd ZZd ZZd ZZeeedZ e!e"e #e $Z%ejZ&Z'ddZ(Gddde)Z*Gddde*Z+Gddde*Z,Gddde*Z-Gddde*Z.Gddde*Z/Gddde*Z0dd d!d"Z1d#d$d%d&d'd(d)d*d+Z2ed,ed,ed-iZ3d@d/d0Z4d1d2Z5d3d4Z6e6Z7d5d6Z8e8Z9dAd7d8Z:Gd9d:d:ejZ;d;d<Ze?e>es(e;j@AeeBe;eed?d?e;ZCdS)B) b64encode)Callable) EOPNOTSUPPEINVALEAGAINN)BytesIO)SEEK_CURz1.7.1nt)rz8To run PySocks on Windows you must install win_inet_ptonr )SOCKS4SOCKS5HTTPcstfdd}|S)Nc sp|d}zNy$|}|dkr&|d||Stk rR}zWdd}~XYnXWd|dkrj|dXdS)NrTF) gettimeout setblocking Exception)argskwargsselfZ _is_blockinge)functionH/home/ankuromar296_gmail_com/.local/lib/python3.7/site-packages/socks.pywrapper(s  z"set_self_blocking..wrapper) functoolswraps)rrr)rrset_self_blocking&src@s"eZdZdZdddZddZdS) ProxyErrorz4Socket_err contains original socket.error exception.NcCs(||_||_|r$|jd|7_dS)Nz: {})msg socket_errformat)rrr rrr__init__;szProxyError.__init__cCs|jS)N)r)rrrr__str__BszProxyError.__str__)N)__name__ __module__ __qualname____doc__r"r#rrrrr9s rc@s eZdZdS)GeneralProxyErrorN)r$r%r&rrrrr(Fsr(c@s eZdZdS)ProxyConnectionErrorN)r$r%r&rrrrr)Jsr)c@s eZdZdS)SOCKS5AuthErrorN)r$r%r&rrrrr*Nsr*c@s eZdZdS) SOCKS5ErrorN)r$r%r&rrrrr+Rsr+c@s eZdZdS) SOCKS4ErrorN)r$r%r&rrrrr,Vsr,c@s eZdZdS) HTTPErrorN)r$r%r&rrrrr-Zsr-zRequest rejected or failedzLRequest rejected because SOCKS server cannot connect to identd on the clientzPRequest rejected because the client program and identd report different user-ids)[\]zGeneral SOCKS server failurez!Connection not allowed by rulesetzNetwork unreachablezHost unreachablezConnection refusedz TTL expiredz(Command not supported, or protocol errorzAddress type not supported)r r r i8iTcCs.|||||r|nd|r"|ndft_dS)zSets a default proxy. All further socksocket objects will use the default unless explicitly changed. All parameters are as for socket.set_proxy().N)encode socksocket default_proxy) proxy_typeaddrportrdnsusernamepasswordrrrset_default_proxyssr?cOs d|kr|d|d<t||S)N proxytyper9)popr?)rrrrrsetdefaultproxy~srBcCstjS)z4Returns the default proxy, set by set_default_proxy.)r7r8rrrrget_default_proxysrCcCstjrt|j_ntddS)aAttempts to replace a module's socket library with a SOCKS socket. Must set a default proxy using set_default_proxy(...) first. This will only work on modules that import socket directly into the namespace; most of the Python Standard Library falls into this category.zNo default proxy specifiedN)r7r8socketr()modulerrr wrap_modules rFc  Cs8|\} } | dr| d} |r4|dr4|d}d} xt||dtjD]} | \}}}}}d}yxt|||}| rx| D]}|j|qzWt|tt fr| ||r| |||||||r| || | | f|Stjtfk r}z|} |r |d}Wdd}~XYqLXqLW| r*| tddS)acreate_connection(dest_pair, *[, timeout], **proxy_args) -> socket object Like socket.create_connection(), but connects to proxy before returning the socket object. dest_pair - 2-tuple of (IP/hostname, port). **proxy_args - Same args passed to socksocket.set_proxy() if present. timeout - Optional socket timeout value, in seconds. source_address - tuple (host, port) for the socket to bind to as its source address before connecting (only for compatibility) [z[]Nrzgai returned empty list.) startswithstriprD getaddrinfo SOCK_STREAMr7 setsockopt isinstanceintfloat settimeout set_proxybindconnecterrorrclose) dest_pairtimeoutsource_addressr9 proxy_addr proxy_portZ proxy_rdnsZproxy_usernameZproxy_passwordsocket_optionsZ remote_hostZ remote_porterrrfamily socket_typeproto canonnamesasockoptrrrrcreate_connections>        rec@seZdZdZddZeZdS) _BaseSocketzBAllows Python 2 delegated methods such as send() to be overridden.cOsHtj|f||t|_x(|jD]}t|||j|<t||q"WdS)N) _orig_socketr"dict _savedmethods _savenamesgetattrdelattr)rposkwnamerrrr"s  z_BaseSocket.__init__N)r$r%r&r'r"listrjrrrrrfsrfcs fddS)Ncs|j||S)N)ri)rrmrn)rorrz_makemethod..r)ror)ror _makemethodsrs)sendtosendrecvfromrecvcs<eZdZdZdZejejdffdd ZddZ fdd Z d d Z d d Z d7ddZ ddZfddZfddZd8fdd Zd9fdd ZddZfddZdd ZeZd!d"ZeZd#d$ZeZd%d&Zfd'd(Zd)d*Zd+d,Zd-d.Zd/d0Z e!ee"ee#e iZ$e%d:fd1d2 Z&e%d3d4Z'd5d6Z(Z)S);r7a2socksocket([family[, type[, proto]]]) -> socket object Open a SOCKS enabled socket. The parameters are the same as those of the standard socket init. In order for SOCKS to work, you must specify family=AF_INET and proto=0. The "type" argument must be either SOCK_STREAM or SOCK_DGRAM. Nrcsp|tjtjfkr"d}t||tt|j|||f||d|_|j rT|j |_ nd|_ d|_ d|_ d|_ dS)Nz0Socket type must be stream or datagram, not {!r})NNNNNN)rDrK SOCK_DGRAM ValueErrorr!superr7r" _proxyconnr8proxyproxy_socknameproxy_peername_timeout)rr^typer`rrr) __class__rrr"s zsocksocket.__init__cCs@d}x6t||kr:||t|}|s0td||7}qW|S)zReceive EXACTLY the number of bytes requested from the file object. Blocks until the required number of bytes have been received.rrzConnection closed unexpectedly)lenreadr()rfilecountdatadrrr_readalls zsocksocket._readallcs@||_y|}tt||jWntjk r:YnXdS)N)rget_proxy_peernamerzr7rPrDrT)rrWZpeer)rrrrPs zsocksocket.settimeoutcCs|jS)N)r)rrrrr#szsocksocket.gettimeoutcCs|r|dn |ddS)Ng)rP)rvrrrr&s zsocksocket.setblockingTcCs.|||||r|nd|r"|ndf|_dS)a Sets the proxy to be used. proxy_type - The type of the proxy to be used. Three types are supported: PROXY_TYPE_SOCKS4 (including socks4a), PROXY_TYPE_SOCKS5 and PROXY_TYPE_HTTP addr - The address of the server (IP or DNS). port - The port of the server. Defaults to 1080 for SOCKS servers and 8080 for HTTP proxy servers. rdns - Should DNS queries be performed on the remote side (rather than the local side). The default is True. Note: This has no effect with SOCKS4 servers. username - Username to authenticate with to the server. The default is no authentication. password - Password to authenticate with to the server. Only relevant when username is also provided.N)r6r|)rr9r:r;r<r=r>rrrrQ,szsocksocket.set_proxycOs"d|kr|d|d<|j||S)Nr@r9)rArQ)rrrrrrsetproxyAszsocksocket.setproxycs|j\}}}}}}|r"|jtjkr4tj|f||S|jrFttd|t kr^d} tt | t t |j||| \} } d| f} t|_|} |j| d}||j|| \} }| \}} |\} } t t ||| ft t ||jd|_dS)zVImplements proxy connection for UDP sockets. Happens during the bind() phase.z"Socket already bound to an addressz'UDP only supported by SOCKS5 proxy type0)z0.0.0.0rN)r|rrDrxrgrRr{rTrrrrzr7 getsockname _proxy_addrrS_SOCKS5_requestrPrr})rrmrnr9rYrZr<r=r>r_r;dstr|Z UDP_ASSOCIATEZrelayhost)rrrrRFs*    zsocksocket.bindc s|jtjkr$tt|j|f||S|js4|d|d}|dd}t}d}| |d}| || ||tt|j | |f||} | | S)N)rs)rrDrxrzr7rtr{rRrwrite_write_SOCKS5_addressrugetvaluetell) rbytesrraddressflagsheaderZRSVZ STANDALONEsent)rrrrtks      zsocksocket.sendtoc s:|jtjkr |j|||jf|Stt|j||f|SdS)N)rrDrxrtr~rzr7ru)rrrr)rrrrus zsocksocket.sendc s|jtjkrtt|||S|js.|dttt| |d|}| dt | d}t |rntd||\}}|jr|j\}}||ks|d|fkrttd| |||ffS)N)rrir r zReceived UDP packet fragmentrzPacket filtered)rrDrxrzr7rvr{rRrrwseekrrordNotImplementedError_read_SOCKS5_addressr~rTr) rbufsizerbuffragZfromhostZfromportZpeerhostZpeerport)rrrrvs      zsocksocket.recvfromcOs|j||\}}|S)N)rv)rrmrnrrrrrrwszsocksocket.recvcs|jr|jtt|S)N)r{rUrzr7)r)rrrrUs zsocksocket.closecCs|jS)z:Returns the bound IP address and port number at the proxy.)r})rrrrget_proxy_socknameszsocksocket.get_proxy_socknamecCs|S)z> Returns the IP and port number of the proxy. ) getpeername)rrrrrszsocksocket.get_proxy_peernamecCs|jS)zwReturns the IP address and port number of the destination machine. Note: get_proxy_peername returns the proxy.)r~)rrrr get_peernameszsocksocket.get_peernamecGsd}||||\|_|_dS)z7Negotiates a stream connection through a SOCKS5 server.N)rr~r})r dest_addrZCONNECTrrr_negotiate_SOCKS5szsocksocket._negotiate_SOCKS5cs|j\}}}}}} |d} |dd} z|r@| r@| dn | d| || d} | dddkrvtd | ddd kr|r| std | d tt| |tt|  | | || d} | ddd krtd | ddd krHtdn6| ddd krH| dddkr@tdntd | d|d | || }| || d}|dddkrtd t |dd}|dkrt |d}td|||| }tt||j||fS| | XdS)z Send SOCKS5 request with given command (CMD field) and address (DST field). Returns resolved DST address that was used. wbrbrssr r z%SOCKS5 proxy server sent invalid datazPNo username/password supplied. Server requested username/password authenticationrrzSOCKS5 authentication failedz7All offered SOCKS5 authentication methods were rejectedr z Unknown errorz {:#04x}: {}N)r|makefilerflushrr(r*chrrr6rr SOCKS5_ERRORSgetr+r!rrzr7rPrrU)rconncmdrr9r:r;r<r=r>writerreaderZ chosen_authZ auth_statusresolvedrespstatusrTZbnd)rrrrs\     .       zsocksocket._SOCKS5_requestc CsH|\}}|j\}}}}}} tjdtjdi} xrtjtjfD]b} yDt| |} || | | t| | }|td|||fStj k rw8Yq8Xq8W|r| d} |dt t |  | nbt ||tjtjtjtj}|d}|d} |dd}t| |} || | | t| | }|td|||fS)z~ Return the host and port packed for the SOCKS5 protocol, and the resolved address as a tuple object. rz>Hidnarrr1)r|rDAF_INETAF_INET6 inet_ptonr inet_ntopstructpackrTr6rrrJ AF_UNSPECrK IPPROTO_TCP AI_ADDRCONFIG)rr:rrr;r9rr<r=r>Zfamily_to_byter^ addr_bytesZ host_bytes addressesZ target_addrrrrr s6         z socksocket._write_SOCKS5_addresscCs||d}|dkr(t||d}nN|dkrN||d}||t|}n(|dkrnttj||d}ntdtd||d d }||fS) Nr rr1rrz%SOCKS5 proxy server sent invalid dataz>Hr r) rrD inet_ntoarrrr(runpack)rrZatypr:lengthr;rrrrMs  zsocksocket._read_SOCKS5_addresscCs|j\}}}}}}|d} |dd} zLd} yt|} Wn4tjk rr|r^d} d} ntt|} YnX| tddd || | |r| || d | r| | d d | | | d } | dd d krt d t | d d}|dkr&t|d}td||t| ddtd| dddf|_| rjt| |f|_n ||f|_Wd| | XdS)z0Negotiates a connection through a SOCKS4 server.rrrFsTz>BBHr1r rrr5z%SOCKS4 proxy server sent invalid datar Zz Unknown errorz {:#04x}: {}Nz>H)r|rrD inet_atonrT gethostbynamerrrr6rrr(r SOCKS4_ERRORSrr,r!rrr}r~rU)rr dest_portr9r:r;r<r=r>rrZremote_resolverrrrTrrr_negotiate_SOCKS4\sH        zsocksocket._negotiate_SOCKS4cCsj|j\}}}}}}|r|nt|}d|ddt|dd|dg} |rv|rv| dt|d|| d|d| | } | } | | st dy| d d \} } }Wntk rt d YnX| d st d y t| } Wntk r$tdYnX| dkrVd| |}| dkrN|d7}t|d|_||f|_dS)zwNegotiates a connection through an HTTP server. NOTE: This currently only supports HTTP CONNECT-style proxies.sCONNECT r:s HTTP/1.1sHost: sProxy-Authorization: basic s zConnection closed unexpectedly r z'HTTP proxy server sent invalid responsezHTTP/z0Proxy server does not appear to be an HTTP proxyz4HTTP proxy server did not return a valid HTTP statusz{}: {})iiiza [*] Note: The HTTP proxy server may not be supported by PySocks (must be a CONNECT tunnel proxy))s0.0.0.0rN)r|rDrr6strappendrsendalljoinrreadlinerUr(splitryrHrNr-r!r}r~)rrrr9r:r;r<r=r>Z http_headersZfobjZ status_liner` status_codeZ status_msgrTrrr_negotiate_HTTPsB        zsocksocket._negotiate_HTTPc s$t|dks|ddr,tdt||\}}|jtjkr||jsP|dt |}|dkrn|snd|_ n ||f|_ dS|j \}}}}} } t |t tfrt|dks|rt |tstdtt||j|dkr ||_ tt||jtt|||fdS|}ytt||Wnztjk r} zX||s|\}}d ||} t|} d | | }td || t|| n| Wdd} ~ XYnXy|j|}||||Wnbtjk r} z"|s|td | n| Wdd} ~ XYn tk r|YnXdS) z Connects to the specified destination through a proxy. Uses the same API as socket's connect(). To select the proxy server, use set_proxy(). dest_pair - 2-tuple of (IP/hostname, port). r rrGz PySocks doesn't support IPv6: %s)rrz0.0.0.0Nz0Invalid destination-connection (host, port) pairz{}:{}zError connecting to {} proxy {}z %s due to: %sz Socket error)rrHrDrTrrrxr{rRrr~r|rMrptuplerNr(rzr7rPrrSrrUr!PRINTABLE_PROXY_TYPESlogdebugr)_proxy_negotiatorsr)rrV catch_errorsrrr9rYrZr<r=r>rTZ proxy_serverZprintable_typerZ negotiate)rrrrSsd              zsocksocket.connectc CsHy|j|dddStk rB}z|jr0|jSWdd}~XYnXdS)a& https://docs.python.org/3/library/socket.html#socket.socket.connect_ex Like connect(address), but return an error indicator instead of raising an exception for errors returned by the C-level connect() call (other problems, such as "host not found" can still raise exceptions). T)rrN)rSOSErrorerrno)rrVrrrr connect_ex6szsocksocket.connect_excCs4|j\}}}}}}|pt|}|s,td||fS)zD Return proxy address to connect to as tuple object zInvalid proxy type)r| DEFAULT_PORTSrr()rr9rYrZr<r=r>rrrrFs zsocksocket._proxy_addr)NNNTNN)r)r)N)*r$r%r&r'r8rDrrKr"rrPrrrQrrRrtrurvrwrUrZgetproxysocknamerZgetproxypeernamerrrrrrrrr rrrrrSrr __classcell__rr)rrr7sH   %   b-<<\ r7)NNNTNN) NNNNNTNNN)Dbase64rcollections.abcr ImportError collectionsrrrrriorloggingosrrDrsys __version__ro version_infoZ win_inet_pton getLoggerr$rZPROXY_TYPE_SOCKS4r ZPROXY_TYPE_SOCKS5rZPROXY_TYPE_HTTPrZ PROXY_TYPESrhzipvalueskeysrZ _orgsocketrgrIOErrorrr(r)r*r+r,r-rrrr?rBrCZgetdefaultproxyrFZ wrapmodulererfrsrkmethodrMrjrsetattrr7rrrrs            8