fume-manage-python.git

U  
Z±dnyã    @svddlmZzddlmZWn ek
r<ddlmZYnXddlmZmZm    Z    ddl
Z
ddlmZddl Z ddlZddlmZddlZddlZddlZdZejdkrÜejd    krÜzddlZWnek
rÚed
YnXe  e¡ZdZZdZZd 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<Z<d=D]:Ze=e;edZ>e?e>es&e;j@ Ae¡eBe;ee<eq&Gd>d?d?e;ZCdS)Bé)Ú    b64encode)ÚCallable)Ú
EOPNOTSUPPÚEINVALÚEAGAINN)ÚBytesIO)ÚSEEK_CURz1.7.1Únt)érz8To run PySocks on Windows you must install win_inet_ptonéér
)ÚSOCKS4ÚSOCKS5ÚHTTPcst ¡fdd}|S)Nc
sv|d}zTz*| ¡}|dkr&| d¡||WW¢*Stk
rX}zW5d}~XYnXW5|dkrp| d¡XdS)NrFT)ÚsetblockingÚ
gettimeoutÚ    Exception)ÚargsÚkwargsÚselfZ_is_blockingÚe©Úfunction©ú<d:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\socks.pyÚwrapper(s
z"set_self_blocking.<locals>.wrapper)Ú    functoolsÚwraps)rrrrrÚset_self_blocking&s rc@s"eZdZdZdddZddZdS)Ú
ProxyErrorz4Socket_err contains original socket.error exception.NcCs(||_||_|r$|jd |¡7_dS)Nz: {})ÚmsgÚ
socket_errÚformat)rr r!rrrÚ__init__;szProxyError.__init__cCs|jS©N)r ©rrrrÚ__str__BszProxyError.__str__)N)Ú__name__Ú
__module__Ú__qualname__Ú__doc__r#r&rrrrr9s
rc@seZdZdS)ÚGeneralProxyErrorN©r'r(r)rrrrr+Fsr+c@seZdZdS)ÚProxyConnectionErrorNr,rrrrr-Jsr-c@seZdZdS)ÚSOCKS5AuthErrorNr,rrrrr.Nsr.c@seZdZdS)ÚSOCKS5ErrorNr,rrrrr/Rsr/c@seZdZdS)ÚSOCKS4ErrorNr,rrrrr0Vsr0c@seZdZdS)Ú    HTTPErrorNr,rrrrr1Zsr1zRequest 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 refusedzTTL expiredz(Command not supported, or protocol errorzAddress type not supported)rrr
ééééé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_typeÚaddrÚportÚrdnsÚusernameÚpasswordrrrÚset_default_proxyssþrCcOs d|kr| d¡|d<t||S©NZ    proxytyper=)ÚpoprC)rrrrrÚsetdefaultproxy~srFcCstjS)z4Returns the default proxy, set by set_default_proxy.)r;r<rrrrÚget_default_proxysrGcCstjrt|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)r;r<Úsocketr+)ÚmodulerrrÚwrap_modules
rJc
Cs6|\}
}|
 d¡r|
 d¡}
|r4| d¡r4| d¡}d}t ||dtj¡D]Ò} | \}}}}}d}zzt|||}|    r|    D]}|j|qvt|tt    fr| 
|¡|r¶| ||||||¡|rÄ| |¡|  |
|f¡|WStjtfk
r}z|}|r
| ¡d}W5d}~XYqJXqJ|r(|t d¡dS)aícreate_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.)Ú
startswithÚstriprHÚgetaddrinfoÚSOCK_STREAMr;Ú
setsockoptÚ
isinstanceÚintÚfloatÚ
settimeoutÚ    set_proxyÚbindÚconnectÚerrorrÚclose)Ú    dest_pairÚtimeoutÚsource_addressr=Ú
proxy_addrÚ
proxy_portZ
proxy_rdnsZproxy_usernameZproxy_passwordÚsocket_optionsZremote_hostZremote_portÚerrÚrÚfamilyÚsocket_typeÚprotoÚ    canonnameÚsaÚsockÚoptrrrrÚcreate_connectionsB
 
 
 
ÿ
 
ric@seZdZdZddZeZdS)Ú_BaseSocketzBAllows Python 2 delegated methods such as send() to be overridden.cOsDtj|f||t|_|jD]}t|||j|<t||q dSr$)Ú_orig_socketr#ÚdictÚ _savedmethodsÚ
_savenamesÚgetattrÚdelattr)rÚposÚkwÚnamerrrr#Øs
 
z_BaseSocket.__init__N)r'r(r)r*r#ÚlistrnrrrrrjÖsrjcsfddS)Ncs|j||Sr$)rm)rrqrr©rsrrÚ<lambda>äóz_makemethod.<locals>.<lambda>rrurrurÚ_makemethodãsrx)ÚsendtoÚsendÚrecvfromÚrecvcs<eZdZdZdZejejdffdd    ZddZ    fdd    Z
d
dZdd Zd7ddZ 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);r;a2socksocket([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)rHrOÚ
SOCK_DGRAMÚ
ValueErrorr"Úsuperr;r#Ú
_proxyconnr<ÚproxyÚproxy_socknameÚproxy_peernameÚ_timeout)rrbÚtyperdrrr ©Ú    __class__rrr#üs
zsocksocket.__init__cCs<d}t||kr8| |t|¡}|s.td||7}q|S)zReceive EXACTLY the number of bytes requested from the file object.
 
        Blocks until the required number of bytes have been received.rwúConnection closed unexpectedly)ÚlenÚreadr+)rÚfileÚcountÚdataÚdrrrÚ_readalls
zsocksocket._readallcs@||_z| ¡}tt| |j¡Wntjk
r:YnXdSr$)rÚget_proxy_peernamerr;rTrHrX)rr[ZpeerrrrrTszsocksocket.settimeoutcCs|jSr$)rr%rrrr#szsocksocket.gettimeoutcCs|r| d¡n
| d¡dS)Ng)rT)rÚvrrrr&szsocksocket.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)r:r)rr=r>r?r@rArBrrrrU,sþzsocksocket.set_proxycOs"d|kr| d¡|d<|j||SrD)rErU)rrrrrrÚsetproxyAszsocksocket.setproxycsø|j\}}}}}}|r"|jtjkr4tj|f||S|jrFt td¡|t    kr^d}    t t
|    ¡tt|j|||  ¡\}
}d|f}t|_| ¡} |j | ¡d}| |j||¡\}
}| \}}
|\}
}tt| ||f¡tt| |j¡d|_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 typeÚ0ó)ú0.0.0.0rN)rrrHr}rkrVrrXrrrrr;ÚgetsocknameÚ_proxy_addrrWÚ_SOCKS5_requestrTrr)rrqrrr=r]r^r@rArBr Ú_r?ÚdstrZ UDP_ASSOCIATEZrelayÚhostrrrrVFs.ÿzsocksocket.bindc
s¢|jtjkr$tt|j|f||S|js4| d¡|d}|dd}t}d}|     |¡d}|     |¡| 
||¡tt|j| ¡|f||}    |    |  ¡S)N©Úréÿÿÿÿsó)rrHr}rr;ryrrVrÚwriteÚ_write_SOCKS5_addressrzÚgetvalueÚtell)
rÚbytesrrÚaddressÚflagsÚheaderZRSVZ
STANDALONEÚsentrrrryks 
 
 
ÿzsocksocket.sendtocs:|jtjkr |j|||jf|Stt|j||f|SdSr$)rrHr}ryrrr;rz)rr¤r¦rrrrrzszsocksocket.sendc    s¾|jtjkrtt| ||¡S|js.| d¡ttt|     |d|¡}| 
dt¡| d¡}t |rntd| |¡\}}|jr¬|j\}}||ks |d|fkr¬t td¡| |¡||ffS)NrirrzReceived UDP packet fragmentrzPacket filtered)rrHr}rr;r{rrVrr|ÚseekrrÚordÚNotImplementedErrorÚ_read_SOCKS5_addressrrXr)    rÚbufsizer¦ÚbufÚfragZfromhostZfromportZpeerhostZpeerportrrrr{s
 
 
zsocksocket.recvfromcOs|j||\}}|Sr$)r{)rrqrrr¤rrrrr|szsocksocket.recvcs|jr|j ¡tt| ¡Sr$)rrYrr;r%rrrrYs
zsocksocket.closecCs|jS)z:Returns the bound IP address and port number at the proxy.)rr%rrrÚget_proxy_sockname¢szsocksocket.get_proxy_socknamecCs| ¡S)z>
        Returns the IP and port number of the proxy.
        )Úgetpeernamer%rrrr¨szsocksocket.get_proxy_peernamecCs|jS)zwReturns the IP address and port number of the destination machine.
 
        Note: get_proxy_peername returns the proxy.)rr%rrrÚget_peername°szsocksocket.get_peernamecGsd}| |||¡\|_|_dS)z7Negotiates a stream connection through a SOCKS5 server.óN)rrr)rÚ    dest_addrZCONNECTrrrÚ_negotiate_SOCKS5¸sÿzsocksocket._negotiate_SOCKS5cs|j\}}}}}}    | d¡}
| dd¡}zÆ|r@|    r@|
 d¡n
|
 d¡|
 ¡| |d¡}|dddkrvtd    |ddd
kr|r|    std|
 dtt    | 
¡|tt    |     
¡|    ¡|
 ¡| |d¡} | dddkrötd    | ddd krHtdn6|ddd krH|dddkr@tdntd    |
 d|d ¡| ||
¡}|
 ¡| |d¡}|dddkrtd    t|dd}|dkrÊt  |d¡}td ||¡| |¡}tt| |j¡||fW¢S| ¡|
 ¡XdS)z
        Send SOCKS5 request with given command (CMD field) and
        address (DST field). Returns resolved DST address that was used.
        ÚwbÚrbrssrróú%SOCKS5 proxy server sent invalid dataózPNo username/password supplied. Server requested username/password authenticationr³rzSOCKS5 authentication failedóÿz7All offered SOCKS5 authentication methods were rejectedr
ú Unknown errorú{:#04x}: {}N)rÚmakefilerYr Úflushrr+r.Úchrrr:r¡rªÚ SOCKS5_ERRORSÚgetr/r"r¬rr;rTr)rÚconnÚcmdrr=r>r?r@rArBÚwriterÚreaderZchosen_authZauth_statusZresolvedÚrespÚstatusrXZbndrrrr¾sp
 
ÿÿþýÿ
ÿÿÿ
 
zsocksocket._SOCKS5_requestc    CsL|\}}|j\}}}}}}    tjdtjdi}
tjtjfD]j}zJt ||¡}| |
||¡t ||¡}| t d|¡¡||fWStj    k
rYq6Yq6Xq6|rÐ| 
d¡} | dtt|  
¡| ¡nbt  ||tjtjtjtj¡}|d}|d}|dd}t ||¡}| |
||¡t ||¡}| t d|¡¡||fS)z~
        Return the host and port packed for the SOCKS5 protocol,
        and the resolved address as a tuple object.
        r³óú>HÚidnarrr5)rrHÚAF_INETÚAF_INET6Ú    inet_ptonr Ú    inet_ntopÚstructÚpackrXr:rÀrrNÚ    AF_UNSPECrOÚIPPROTO_TCPÚ AI_ADDRCONFIG)rr>rrr?r=rr@rArBZfamily_to_byterbÚ
addr_bytesZ
host_bytesÚ    addressesZtarget_addrrrrr¡ s8
 ýz socksocket._write_SOCKS5_addresscCs| |d¡}|dkr(t | |d¡¡}nN|dkrN| |d¡}| |t|¡}n(|dkrnt tj| |d¡¡}ntdt d| |d    ¡¡d
}||fS)Nrr³r5rrÉér¹rÊrr)    rrHÚ    inet_ntoarªrÏrÍr+rÐÚunpack)rrZatypr>Úlengthr?rrrr¬Mszsocksocket._read_SOCKS5_addresscCs|j\}}}}}}| d¡}    | dd¡}
zLd}zt |¡}Wn4tjk
rr|r^d}d}nt t |¡¡}YnX|     t     ddd    |¡¡|     |¡|r¢|     |¡|     d
¡|rÄ|     | 
d¡d
¡|     ¡| |
d¡} | dd    d
krðt d t| d    d}|dkr&t |d¡}td ||¡t | dd¡t d| dd¡df|_|rjt |¡|f|_n
||f|_W5|
 ¡|     ¡XdS)z0Negotiates a connection through a SOCKS4 server.r¶r·rFsTz>BBHr5rrrËr9z%SOCKS4 proxy server sent invalid dataréZr¼r½NrÊ)rr¾rYrHÚ    inet_atonrXÚ gethostbynamer rÐrÑr:r¿rr+rªÚ SOCKS4_ERRORSrÂr0r"rØrÙrr)rr´Ú    dest_portr=r>r?r@rArBrÅrÆZremote_resolverÕrÇrÈrXrrrÚ_negotiate_SOCKS4\sN
ÿ
 
 
 
ÿ
ÿzsocksocket._negotiate_SOCKS4cCsj|j\}}}}}}|r|nt |¡}d| d¡dt| ¡dd| d¡g}    |rv|rv|     dt|d|¡|     d¡| d |    ¡¡|     ¡}
|
 
¡}|
 ¡|s´tdz|  d    d
¡\}} }Wntk
rætdYnX| d¡sútd zt| } 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 
rú rz'HTTP proxy server sent invalid responsezHTTP/z0Proxy server does not appear to be an HTTP proxyz4HTTP proxy server did not return a valid HTTP statuséÈz{}: {})iiiza
[*] Note: The HTTP proxy server may not be supported by PySocks (must be a CONNECT tunnel proxy))s0.0.0.0rN)rrHrÝr:ÚstrÚappendrÚsendallÚjoinr¾ÚreadlinerYr+Úsplitr~rLrRr1r"rr)rr´rßr=r>r?r@rArBZhttp_headersZfobjZstatus_linerdÚstatus_codeZ
status_msgrXrrrÚ_negotiate_HTTPsR
ÿÿýÿ
 
ÿÿ
 
 
zsocksocket._negotiate_HTTPc
s$t|dks|d d¡r,t dt|¡|\}}|jtjkr||jsP| d¡t     |¡}|dkrn|snd|_
n
||f|_
dS|j\}}}}}    }
t|t tfr¶t|dks¶|r¶t|ts¾tdtt| |j¡|dkr
||_
tt| |j¡tt| ||f¡dS| ¡}ztt| |¡Wnztjk
r }zX| ¡|s|\}}d     ||¡}t|} d
 | |¡}t d||¡t||n|W5d}~XYnXz|j|}||||Wnbtjk
r}z"|sì| ¡td|n|W5d}~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).
        rrrKz PySocks doesn't support IPv6: %srrNz0Invalid destination-connection (host, port) pairz{}:{}zError connecting to {} proxy {}z %s due to: %szSocket error)rrLrHrXrärr}rrVrÝrrrQrtÚtuplerRr+rr;rTrrWrrYr"ÚPRINTABLE_PROXY_TYPESÚlogÚdebugr-Ú_proxy_negotiatorsr)rrZÚcatch_errorsr´rßr=r]r^r@rArBrXZproxy_serverZprintable_typer Z    negotiaterrrrWÙst    ÿ
 
 
ÿ
ÿþýÿ
ÿ
zsocksocket.connectc
CsRz|j|ddWdStk
rL}z|jr:|jWY¢SW5d}~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)rñrN)rWÚOSErrorÚerrno)rrZrrrrÚ
connect_ex6szsocksocket.connect_excCs4|j\}}}}}}|pt |¡}|s,td||fS)zD
        Return proxy address to connect to as tuple object
        zInvalid proxy type)rÚ DEFAULT_PORTSrÂr+)rr=r]r^r@rArBrrrrFsÿzsocksocket._proxy_addr)NNNTNN)r)r)N)*r'r(r)r*r<rHrÌrOr#rrTrrrUrrVryrzr{r|rYr°ZgetproxysocknamerZgetproxypeernamer²r±rµrr¡r¬ràrër rrrðrrWrôrÚ __classcell__rrrrr;ñsXÿ    ÿ
%b-<<ý\
r;)NNNTNN)    NNNNNTNNN)DÚbase64rÚcollections.abcrÚImportErrorÚcollectionsrórrrrÚiorÚloggingÚosrrHrÐÚsysÚ__version__rsÚversion_infoZ win_inet_ptonÚ    getLoggerr'rîZPROXY_TYPE_SOCKS4r ZPROXY_TYPE_SOCKS5rZPROXY_TYPE_HTTPrZPROXY_TYPESrlÚzipÚvaluesÚkeysríZ
_orgsocketrkrÚIOErrorrr+r-r.r/r0r1rÞrÁrõrCrFrGZgetdefaultproxyrJZ
wrapmodulerirjrxroÚmethodrQrnråÚsetattrr;rrrrÚ<module>sÿ
 
 
 ü    øÿ
û
=