Merge 5dcaba7a16 into 3505d4a1c2

shadowsocks/encrypt.py

@@ -26,6 +26,7 @@ import string
 import struct
 import logging
 
+logger = logging.getLogger('encrypt')
 
 def random_string(length):
     import M2Crypto.Rand
@@ -53,7 +54,7 @@ def init_table(key, method=None):
         try:
             __import__('M2Crypto')
         except ImportError:
-            logging.error('M2Crypto is required to use encryption other than default method')
+            logger.error('M2Crypto is required to use encryption other than default method')
             sys.exit(1)
     if not method:
         global encrypt_table, decrypt_table
@@ -63,7 +64,7 @@ def init_table(key, method=None):
         try:
             Encryptor(key, method)  # make an Encryptor to test if the settings if OK
         except Exception as e:
-            logging.error(e)
+            logger.error(e)
             sys.exit(1)
 
 
@@ -140,7 +141,7 @@ class Encryptor(object):
                 self.cipher_iv = iv[:m[1]]  # this iv is for cipher, not decipher
             return M2Crypto.EVP.Cipher(method.replace('-', '_'), key, iv, op, key_as_bytes=0, d='md5', salt=None, i=1, padding=1)
 
-        logging.error('method %s not supported' % method)
+        logger.error('method %s not supported' % method)
         sys.exit(1)
 
     def encrypt(self, buf):

shadowsocks/local.py

@@ -48,6 +48,8 @@ import encrypt
 import utils
 
 
+logger = logging.getLogger('local')
+
 def send_all(sock, data):
     bytes_sent = 0
     while True:
@@ -64,6 +66,7 @@ class ThreadingTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
 
 
 class Socks5Server(SocketServer.StreamRequestHandler):
+
     def getServer(self):
         aPort = REMOTE_PORT
         aServer = SERVER
@@ -77,7 +80,8 @@ class Socks5Server(SocketServer.StreamRequestHandler):
         r = re.match(r'^(.*)\:(\d+)$', aServer)
         if r:
             # support config like "server": "123.123.123.1:8381"
-            # or "server": ["123.123.123.1:8381", "123.123.123.2:8381", "123.123.123.2:8382"]
+            # or "server": ["123.123.123.1:8381", "123.123.123.2:8381",
+            # "123.123.123.2:8382"]
             aServer = r.group(1)
             aPort = int(r.group(2))
         return (aServer, aPort)
@@ -124,7 +128,7 @@ class Socks5Server(SocketServer.StreamRequestHandler):
             data = self.rfile.read(4) or '\x00' * 4
             mode = ord(data[1])
             if mode != 1:
-                logging.warn('mode != 1')
+                logger.warn('mode != 1')
                 return
             addrtype = ord(data[3])
             addr_to_send = data[3]
@@ -141,7 +145,7 @@ class Socks5Server(SocketServer.StreamRequestHandler):
                 addr = socket.inet_ntop(socket.AF_INET6, addr_ip)
                 addr_to_send += addr_ip
             else:
-                logging.warn('addr_type not supported')
+                logger.warn('addr_type not supported')
                 # not supported
                 return
             addr_port = self.rfile.read(2)
@@ -155,99 +159,141 @@ class Socks5Server(SocketServer.StreamRequestHandler):
                 aServer, aPort = self.getServer()
                 remote = socket.create_connection((aServer, aPort))
                 self.send_encrypt(remote, addr_to_send)
-                logging.info('connecting %s:%d' % (addr, port[0]))
+                logger.info('connecting %s:%d' % (addr, port[0]))
             except socket.error, e:
-                logging.warn(e)
+                logger.warn(e)
                 return
             self.handle_tcp(sock, remote)
         except socket.error, e:
-            logging.warn(e)
+            logger.warn(e)
 
 
-def main():
+class ShadowSocksServer(object):
-    global SERVER, REMOTE_PORT, KEY, METHOD
 
-    logging.basicConfig(level=logging.DEBUG,
+    def __init__(self):
-                        format='%(asctime)s %(levelname)-8s %(message)s',
-                        datefmt='%Y-%m-%d %H:%M:%S', filemode='a+')
 
-    # fix py2exe
+        self.options = self.default_options()
-    if hasattr(sys, "frozen") and sys.frozen in \
-            ("windows_exe", "console_exe"):
-        p = os.path.dirname(os.path.abspath(sys.executable))
-        os.chdir(p)
-    version = ''
-    try:
-        import pkg_resources
-        version = pkg_resources.get_distribution('shadowsocks').version
-    except:
-        pass
-    print 'shadowsocks %s' % version
 
-    KEY = None
+    def default_options(self):
-    METHOD = None
+        return {
-    LOCAL = ''
+            "server":"localhost",
-    IPv6 = False
+            "server_port":8388,
+            "local_port":1080,
+            "password":"barfoo!",
+            "timeout":600,
+            "method":"table",
+            "IPv6": False
+        }
 
-    config_path = utils.find_config()
+    def serve_forever(self):
-    optlist, args = getopt.getopt(sys.argv[1:], 's:b:p:k:l:m:c:6')
+        global SERVER, REMOTE_PORT, KEY, METHOD
-    for key, value in optlist:
-        if key == '-c':
-            config_path = value
         
-    if config_path:
+        self.set_logging()
-        logging.info('loading config from %s' % config_path)
+        self.run_info()
-        with open(config_path, 'rb') as f:
+        self.set_options()
-            try:
+        self.check_config()
-                config = json.load(f)
-            except ValueError as e:
-                logging.error('found an error in config.json: %s', e.message)
-                sys.exit(1)
-    else:
-        config = {}
 
-    optlist, args = getopt.getopt(sys.argv[1:], 's:b:p:k:l:m:c:6')
+        SERVER = self.options['server']
-    for key, value in optlist:
+        REMOTE_PORT = self.options['server_port']
-        if key == '-p':
+        PORT = self.options['local_port']
-            config['server_port'] = int(value)
+        KEY = self.options['password']
-        elif key == '-k':
+        METHOD = self.options.get('method', None)
-            config['password'] = value
+        LOCAL = self.options.get('local', '')
-        elif key == '-l':
-            config['local_port'] = int(value)
-        elif key == '-s':
-            config['server'] = value
-        elif key == '-m':
-            config['method'] = value
-        elif key == '-b':
-            config['local'] = value
-        elif key == '-6':
-            IPv6 = True
 
-    SERVER = config['server']
+        encrypt.init_table(KEY, METHOD)
-    REMOTE_PORT = config['server_port']
-    PORT = config['local_port']
-    KEY = config['password']
-    METHOD = config.get('method', None)
-    LOCAL = config.get('local', '')
 
-    if not KEY and not config_path:
+        try:
-        sys.exit('config not specified, please read https://github.com/clowwindy/shadowsocks')
+            if self.options['IPv6']:
+                ThreadingTCPServer.address_family = socket.AF_INET6
+            server = ThreadingTCPServer((LOCAL, PORT), Socks5Server)
+            logger.info("starting local at %s:%d" %
+                         tuple(server.server_address[:2]))
+            server.serve_forever()
+        except socket.error, e:
+            logger.error(e)
+        except KeyboardInterrupt:
+            server.shutdown()
+            sys.exit(0)
+            self.server.serve_forever()
 
-    utils.check_config(config)
+    def check_config(self):
+        utils.check_config(self.options)
 
-    encrypt.init_table(KEY, METHOD)
+    def set_logging(self):
+        logfmt = '[%%(levelname)s] %s%%(message)s' % '%(name)s - '
+        config = lambda x: logging.basicConfig(level=x,
+                                               format='[%(asctime)s] ' + logfmt, datefmt='%Y%m%d %H:%M:%S')
+        if self.options.get('debug'):
+            config(logging.DEBUG)
+        else:
+            config(logging.INFO)
+        # logging.basicConfig(level=logging.DEBUG,
+        #                     format='%(asctime)s %(levelname)-8s %(message)s',
+        #                     datefmt='%Y-%m-%d %H:%M:%S', filemode='a+')
+
+    def set_options(self):
+        config_path = self._find_options()
+        config = self._parse_file_options(config_path)
+        config = self._parse_cmd_options(config)
+        self.options.update(config)
+
+    def _parse_file_options(self, config_path):
+        if config_path:
+            logger.info('loading config from %s' % config_path)
+            with open(config_path, 'rb') as f:
+                try:
+                    config = json.load(f)
+                except ValueError as e:
+                    logger.error(
+                        'found an error in config.json: %s', e.message)
+                    sys.exit(1)
+        else:
+            config = {}
+
+        return config
+
+    def _find_options(self):
+        config_path = utils.find_config()
+        print config_path
+        optlist, args = getopt.getopt(sys.argv[1:], 's:b:p:k:l:m:c:6')
+        for key, value in optlist:
+            if key == '-c':
+                config_path = value
+        return config_path
+
+    def _parse_cmd_options(self, config):
+        optlist, args = getopt.getopt(sys.argv[1:], 's:b:p:k:l:m:c:6')
+        for key, value in optlist:
+            if key == '-p':
+                config['server_port'] = int(value)
+            elif key == '-k':
+                self.options['password'] = value
+            elif key == '-l':
+                config['local_port'] = int(value)
+            elif key == '-s':
+                config['server'] = value
+            elif key == '-m':
+                config['method'] = value
+            elif key == '-b':
+                config['local'] = value
+            elif key == '-6':
+                config['IPv6'] = True
+        return config
+
+    def run_info(self):
+
+        if hasattr(sys, "frozen") and sys.frozen in \
+                ("windows_exe", "console_exe"):
+            p = os.path.dirname(os.path.abspath(sys.executable))
+            os.chdir(p)
+        version = ''
+        try:
+            import pkg_resources
+            version = pkg_resources.get_distribution('shadowsocks').version
+        except:
+            pass
+        logger.info('shadowsocks %s' % version)
 
-    try:
-        if IPv6:
-            ThreadingTCPServer.address_family = socket.AF_INET6
-        server = ThreadingTCPServer((LOCAL, PORT), Socks5Server)
-        logging.info("starting local at %s:%d" % tuple(server.server_address[:2]))
-        server.serve_forever()
-    except socket.error, e:
-        logging.error(e)
-    except KeyboardInterrupt:
-        server.shutdown()
-        sys.exit(0)
 
 if __name__ == '__main__':
-    main()
+    ShadowSocksServer().serve_forever()

shadowsocks/server.py

@@ -46,6 +46,7 @@ import getopt
 import encrypt
 import utils
 
+logger = logging.getLogger('server')
 
 def send_all(sock, data):
     bytes_sent = 0
@@ -63,6 +64,7 @@ class ThreadingTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
 
 
 class Socks5Server(SocketServer.StreamRequestHandler):
+
     def handle_tcp(self, sock, remote):
         try:
             fdset = [sock, remote]
@@ -95,7 +97,8 @@ class Socks5Server(SocketServer.StreamRequestHandler):
 
     def handle(self):
         try:
-            self.encryptor = encrypt.Encryptor(self.server.key, self.server.method)
+            self.encryptor = encrypt.Encryptor(
+                self.server.key, self.server.method)
             sock = self.connection
             iv_len = self.encryptor.iv_len()
             if iv_len:
@@ -111,99 +114,152 @@ class Socks5Server(SocketServer.StreamRequestHandler):
                                         self.decrypt(self.rfile.read(16)))
             else:
                 # not supported
-                logging.warn('addr_type not supported, maybe wrong password')
+                logger.warn('addr_type not supported, maybe wrong password')
                 return
             port = struct.unpack('>H', self.decrypt(self.rfile.read(2)))
             try:
-                logging.info('connecting %s:%d' % (addr, port[0]))
+                logger.info('connecting %s:%d' % (addr, port[0]))
                 remote = socket.create_connection((addr, port[0]))
             except socket.error, e:
                 # Connection refused
-                logging.warn(e)
+                logger.warn(e)
                 return
             self.handle_tcp(sock, remote)
         except socket.error, e:
-            logging.warn(e)
+            logger.warn(e)
-
-def main():
-    logging.basicConfig(level=logging.DEBUG,
-                        format='%(asctime)s %(levelname)-8s %(message)s',
-                        datefmt='%Y-%m-%d %H:%M:%S', filemode='a+')
 
 
-    version = ''
+class ShadowSocksServer(object):
-    try:
-        import pkg_resources
-        version = pkg_resources.get_distribution('shadowsocks').version
-    except:
-        pass
-    print 'shadowsocks %s' % version
 
-    KEY = None
+    def __init__(self):
-    METHOD = None
-    IPv6 = False
 
-    config_path = utils.find_config()
+        self.options = self.default_options()
-    optlist, args = getopt.getopt(sys.argv[1:], 's:p:k:m:c:6')
-    for key, value in optlist:
-        if key == '-c':
-            config_path = value
 
-    if config_path:
+    def default_options(self):
-        logging.info('loading config from %s' % config_path)
+        return {
-        with open(config_path, 'rb') as f:
+            "server":"localhost",
-            try:
+            "server_port":8388,
-                config = json.load(f)
+            "local_port":1080,
-            except ValueError as e:
+            "password":"barfoo!",
-                logging.error('found an error in config.json: %s', e.message)
+            "timeout":600,
-                sys.exit(1)
+            "method":"table",
-        logging.info('loading config from %s' % config_path)
+            "IPv6": False
-    else:
+        }
-        config = {}
 
-    optlist, args = getopt.getopt(sys.argv[1:], 's:p:k:m:c:6')
+    def serve_forever(self):
-    for key, value in optlist:
-        if key == '-p':
-            config['server_port'] = int(value)
-        elif key == '-k':
-            config['password'] = value
-        elif key == '-s':
-            config['server'] = value
-        elif key == '-m':
-            config['method'] = value
-        elif key == '-6':
-            IPv6 = True
 
-    SERVER = config['server']
+        self.set_logging()
-    PORT = config['server_port']
+        self.run_info()
-    KEY = config['password']
+        self.set_options()
-    METHOD = config.get('method', None)
+        self.check_config()
-    PORTPASSWORD = config.get('port_password', None)
-    TIMEOUT = config.get('timeout', 600)
 
-    if not KEY and not config_path:
+        SERVER = self.options['server']
-        sys.exit('config not specified, please read https://github.com/clowwindy/shadowsocks')
+        PORT = self.options['server_port']
+        KEY = self.options['password']
+        METHOD = self.options.get('method', None)
+        PORTPASSWORD = self.options.get('port_password', None)
+        TIMEOUT = self.options.get('timeout', 600)
 
-    utils.check_config(config)
+        if PORTPASSWORD:
+            if PORT or KEY:
+                logger.warn(
+                    'warning: port_password should not be used with server_port and password. server_port and password will be ignored')
+        else:
+            PORTPASSWORD = {}
+            PORTPASSWORD[str(PORT)] = KEY
 
-    if PORTPASSWORD:
+        encrypt.init_table(KEY, METHOD)
-        if PORT or KEY:
+        if self.options['IPv6']:
-            logging.warn('warning: port_password should not be used with server_port and password. server_port and password will be ignored')
+            ThreadingTCPServer.address_family = socket.AF_INET6
-    else:
+        for port, key in PORTPASSWORD.items():
-        PORTPASSWORD = {}
+            server = ThreadingTCPServer((SERVER, int(port)), Socks5Server)
-        PORTPASSWORD[str(PORT)] = KEY
+            server.key, server.method, server.timeout = key, METHOD, int(
+                TIMEOUT)
+            logger.info("starting server at %s:%d" %
+                         tuple(server.server_address[:2]))
+            threading.Thread(target=server.serve_forever).start()
+
+    def check_config(self):
+        utils.check_config(self.options)
+
+    def set_logging(self):
+        logfmt = '[%%(levelname)s] %s%%(message)s' % '%(name)s - '
+        config = lambda x: logging.basicConfig(level=x,
+                                               format='[%(asctime)s] ' + logfmt, datefmt='%Y%m%d %H:%M:%S')
+        if self.options.get('debug'):
+            config(logging.DEBUG)
+        else:
+            config(logging.INFO)
+        # logging.basicConfig(level=logging.DEBUG,
+        #                     format='%(asctime)s %(levelname)-8s %(message)s',
+        #                     datefmt='%Y-%m-%d %H:%M:%S', filemode='a+')
+
+    def set_options(self):
+        config_path = self._find_options()
+        config = self._parse_file_options(config_path)
+        config = self._parse_cmd_options(config)
+        self.options.update(config)
+
+    def _parse_file_options(self, config_path):
+        if config_path:
+            logger.info('loading config from %s' % config_path)
+            with open(config_path, 'rb') as f:
+                try:
+                    config = json.load(f)
+                except ValueError as e:
+                    logger.error(
+                        'found an error in config.json: %s', e.message)
+                    sys.exit(1)
+        else:
+            config = {}
+
+        return config
+
+    def _find_options(self):
+        config_path = utils.find_config()
+        print config_path
+        optlist, args = getopt.getopt(sys.argv[1:], 's:b:p:k:l:m:c:6')
+        for key, value in optlist:
+            if key == '-c':
+                config_path = value
+        return config_path
+
+    def _parse_cmd_options(self, config):
+        optlist, args = getopt.getopt(sys.argv[1:], 's:b:p:k:l:m:c:6')
+        for key, value in optlist:
+            if key == '-p':
+                config['server_port'] = int(value)
+            elif key == '-k':
+                self.options['password'] = value
+            elif key == '-l':
+                config['local_port'] = int(value)
+            elif key == '-s':
+                config['server'] = value
+            elif key == '-m':
+                config['method'] = value
+            elif key == '-b':
+                config['local'] = value
+            elif key == '-6':
+                config['IPv6'] = True
+        return config
+
+    def run_info(self):
+
+        if hasattr(sys, "frozen") and sys.frozen in \
+                ("windows_exe", "console_exe"):
+            p = os.path.dirname(os.path.abspath(sys.executable))
+            os.chdir(p)
+        version = ''
+        try:
+            import pkg_resources
+            version = pkg_resources.get_distribution('shadowsocks').version
+        except:
+            pass
+        logger.info('shadowsocks %s' % version)
 
-    encrypt.init_table(KEY, METHOD)
-    if IPv6:
-        ThreadingTCPServer.address_family = socket.AF_INET6
-    for port, key in PORTPASSWORD.items():
-        server = ThreadingTCPServer((SERVER, int(port)), Socks5Server)
-        server.key, server.method, server.timeout = key, METHOD, int(TIMEOUT)
-        logging.info("starting server at %s:%d" % tuple(server.server_address[:2]))
-        threading.Thread(target=server.serve_forever).start()
 
 if __name__ == '__main__':
     try:
-        main()
+        ShadowSocksServer().serve_forever()
     except socket.error, e:
-        logging.error(e)
+        logger.error(e)

shadowsocks/utils.py

@@ -4,6 +4,7 @@
 import os
 import logging
 
+logger = logging.getLogger('utils')
 
 def find_config():
     config_path = 'config.json'
@@ -16,7 +17,7 @@ def find_config():
 
 def check_config(config):
     if config.get('server', '') in ['127.0.0.1', 'localhost']:
-        logging.warn('Server is set to "%s", maybe it\'s not correct' % config['server'])
+        logger.warn('Server is set to "%s", maybe it\'s not correct' % config['server'])
-        logging.warn('Notice server will listen at %s:%s' % (config['server'], config['server_port']))
+        logger.warn('Notice server will listen at %s:%s' % (config['server'], config['server_port']))
     if (config.get('method', '') or '').lower() == 'rc4':
-        logging.warn('RC4 is not safe; please use a safer cipher, like AES-256-CFB')
+        logger.warn('RC4 is not safe; please use a safer cipher, like AES-256-CFB')