Merge pull request #1 from oulinbao/master

release 0.1.0

Author: 欧林宝

.gitignore

@@ -0,0 +1,7 @@
+.idea
+build/
+dist/
+*.egg-info
+*.pyc
+.pytest_cache/
+.DS_Store

README

@@ -0,0 +1,20 @@
+# 京东云CLI
+京东云CLI提供使用命令行的方式访问您的云中资源。
+
+## 安装方法：
+### Linux && Mac
+pip安装：
+`pip install jdcloud_cli`
+
+源码安装：
+`python setup.py install`
+
+安装后执行：
+```
+echo 'eval "$(register-python-argcomplete jdc)"' >> .bashrc
+echo 'export COLUMNS=100' >> .bashrc
+source ~/.bashrc
+```
+
+
+### Windows

README.md

@@ -0,0 +1,75 @@
+# coding=utf8
+
+# Copyright 2018 JDCLOUD.COM
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http:#www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+# NOTE: This class is auto generated by the jdcloud code generator program.
+
+from jdcloud_sdk.core.config import Config
+from jdcloud_sdk.core.credential import Credential
+from jdcloud_sdk.services.vm.client.VmClient import VmClient
+from jdcloud_sdk.services.iam.client.IamClient import IamClient
+from jdcloud_sdk.services.disk.client.DiskClient import DiskClient
+from jdcloud_sdk.services.mongodb.client.MongodbClient import MongodbClient
+from jdcloud_sdk.services.mps.client.MpsClient import MpsClient
+from jdcloud_sdk.services.streambus.client.StreambusClient import StreambusClient
+from jdcloud_sdk.services.ipanti.client.IpantiClient import IpantiClient
+from jdcloud_sdk.services.rds.client.RdsClient import RdsClient
+from jdcloud_sdk.services.redis.client.RedisClient import RedisClient
+from jdcloud_sdk.services.monitor.client.MonitorClient import MonitorClient
+from jdcloud_sdk.services.vpc.client.VpcClient import VpcClient
+from jdcloud_sdk.services.xdata.client.XdataClient import XdataClient
+from jdcloud_sdk.services.nc.client.NcClient import NcClient
+from jdcloud_sdk.services.oss.client.OssClient import OssClient
+from jdcloud_cli.config import ProfileManager
+from jdcloud_cli.logger import get_logger
+
+
+class ClientFactory(object):
+
+    def __init__(self, service):
+        self.__service = service
+
+    def get(self, app):
+        client_map = {
+            'vm': VmClient,
+            'iam': IamClient,
+            'disk': DiskClient,
+            'mongodb': MongodbClient,
+            'mps': MpsClient,
+            'streambus': StreambusClient,
+            'ipanti': IpantiClient,
+            'rds': RdsClient,
+            'redis': RedisClient,
+            'monitor': MonitorClient,
+            'vpc': VpcClient,
+            'xdata': XdataClient,
+            'nc': NcClient,
+            'oss': OssClient,
+        }
+
+        profile_manager = ProfileManager()
+        cli_config = profile_manager.load_current_profile()
+        if cli_config is None:
+            return None
+
+        logger = get_logger(app.pargs.debug)
+
+        config = Config(cli_config.endpoint, cli_config.scheme)
+        credential = Credential(cli_config.access_key, cli_config.secret_key)
+        if self.__service not in client_map:
+            return None
+
+        client = client_map[self.__service](credential, config, logger)
+        return client

jdcloud_cli/__init__.py

@@ -0,0 +1,139 @@
+# coding=utf8
+
+# Copyright 2018 JDCLOUD.COM
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http:#www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+import os
+from configparser import SafeConfigParser
+
+CONF_AK = 'access_key'
+CONF_SK = 'secret_key'
+CONF_REGION = 'region_id'
+CONF_ENDPOINT = 'endpoint'
+CONF_SCHEME = 'scheme'
+
+
+class Config(object):
+
+    def __init__(self, access_key, secret_key, region_id, endpoint, scheme):
+        self.access_key = access_key
+        self.secret_key = secret_key
+        self.region_id = region_id
+        self.endpoint = endpoint
+        self.scheme = scheme
+
+
+class ProfileManager(object):
+
+    def __new__(type):
+        if '_instance' not in type.__dict__:
+            type._instance = object.__new__(type)
+        return type._instance
+
+    def __init__(self):
+        cli_dir = self.__make_config_dir()
+        self.__config_file = cli_dir + '/config'
+        self.__current_file = cli_dir + '/current'
+        self.__current_profile_name = self.__get_current_profile_name()
+        self.__parser = SafeConfigParser()
+        self.__parser.read(self.__config_file)
+
+    def load_current_profile(self):
+        if self.__current_profile_name not in self.__parser.sections():
+            print 'Please use `jdc configure add` command to add cli configure first.'
+            return None
+
+        # notice that the type of config info which read from file is unicode
+        # python SDK uses type str
+        access_key = str(self.__parser.get(self.__current_profile_name, CONF_AK))
+        secret_key = str(self.__parser.get(self.__current_profile_name, CONF_SK))
+        region_id = str(self.__parser.get(self.__current_profile_name, CONF_REGION))
+        endpoint = str(self.__parser.get(self.__current_profile_name, CONF_ENDPOINT))
+        scheme = str(self.__parser.get(self.__current_profile_name, CONF_SCHEME))
+        return Config(access_key, secret_key, region_id, endpoint, scheme)
+
+    def get_all_profiles(self):
+        result = dict()
+        sections = self.__parser.sections()
+        for section in sections:
+            result[section] = self.__parser.items(section)
+        return result
+
+    def get_current_profile(self):
+        result = dict()
+        if not self.__parser.has_section(self.__current_profile_name):
+            return result
+
+        result[self.__current_profile_name] = self.__parser.items(self.__current_profile_name)
+
+        return result
+
+    def add_profile(self, profile, config):
+        if self.__parser.has_section(profile):
+            return False, 'Profile ' + profile + ' has existed'
+
+        self.__parser.add_section(profile)
+
+        # use enums for the fields order
+        for key in [CONF_AK, CONF_SK, CONF_REGION, CONF_ENDPOINT, CONF_SCHEME]:
+            value = config.__dict__[key]
+            self.__parser.set(profile, key, value)
+
+        return self.__write_config_file()
+
+    def delete_profile(self, profile):
+        if not self.__parser.has_section(profile):
+            return False, 'No profile ' + profile
+
+        if profile == self.__current_profile_name:
+            return False, 'Can not delete current profile: ' + profile
+
+        self.__parser.remove_section(profile)
+        return self.__write_config_file()
+
+    def set_current_profile(self, name):
+        if not self.__parser.has_section(name):
+            return False, 'Profile %s do not exist! Configure failed!' % name
+        try:
+            with open(self.__current_file, 'w') as f:
+                f.write(name)
+            self.__current_profile_name = name
+        except Exception as e:
+            return False, e.message
+        return True, ''
+
+    def __write_config_file(self):
+        try:
+            with open(self.__config_file, 'w+') as f:
+                self.__parser.write(f)
+        except Exception as e:
+            return False, e.message
+        return True, ''
+
+    def __make_config_dir(self):
+        home = os.path.expanduser("~")
+        cli_dir = home + "/.jdc"
+        if not os.path.exists(cli_dir):
+            os.makedirs(cli_dir)
+        return cli_dir
+
+    def __get_current_profile_name(self):
+        if not os.path.exists(self.__current_file):
+            with open(self.__current_file, 'w') as f:
+                f.write('default')
+            return 'default'
+
+        with open(self.__current_file, 'r') as f:
+            name = f.read()
+        return name

jdcloud_cli/client_factory.py

@@ -0,0 +1,21 @@
+# coding=utf8
+
+# Copyright 2018 JDCLOUD.COM
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http:#www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+WEBSOCKET_SCHEME = 'ws'
+
+METHOD_GET = 'GET'
+
+REGION_ID = 'regionId'

jdcloud_cli/config.py

@@ -0,0 +1,27 @@
+# coding=utf8
+
+# Copyright 2018 JDCLOUD.COM
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http:#www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+from cement.ext.ext_argparse import ArgparseController
+from jdcloud_cli.version import VERSION
+
+
+class BaseController(ArgparseController):
+    class Meta:
+        label = 'base'
+        arguments = [
+            (['--output'], dict(help='output format', choices=['json'], default='json')),
+            (['-v', '--version'], dict(action='version', version=VERSION)),
+        ]