Python CLI - Fixed issues in help display, improved packaging, removed setuptools configuration, minor improvements, added stratos.sh file to product
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/54072669 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/54072669 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/54072669 Branch: refs/heads/stratos-4.1.x Commit: 540726691b6e390e5c53038b7cb3d1efb3e09c10 Parents: 7a8c968 Author: Chamila de Alwis <[email protected]> Authored: Mon Nov 9 17:58:14 2015 +0530 Committer: Chamila de Alwis <[email protected]> Committed: Mon Nov 9 17:58:42 2015 +0530 ---------------------------------------------------------------------- .../src/main/python/README.md | 40 +- .../src/main/python/cli/CLI.py | 1530 ---------------- .../src/main/python/cli/Configs.py | 32 - .../src/main/python/cli/Exceptions.py | 25 - .../src/main/python/cli/Logging.py | 29 - .../src/main/python/cli/Main.py | 66 - .../src/main/python/cli/Stratos.py | 489 ----- .../src/main/python/cli/Utils.py | 99 - .../src/main/python/cli/cli.py | 1690 ++++++++++++++++++ .../src/main/python/cli/config.py | 32 + .../src/main/python/cli/exception.py | 26 + .../src/main/python/cli/logutils.py | 29 + .../src/main/python/cli/main.py | 71 + .../src/main/python/cli/restclient.py | 493 +++++ .../src/main/python/cli/utils.py | 38 + .../src/main/python/setup.cfg | 2 - .../src/main/python/setup.py | 46 - .../distribution/src/main/assembly/bin.xml | 13 +- .../distribution/src/main/bin/stratos.sh | 34 + 19 files changed, 2422 insertions(+), 2362 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/54072669/components/org.apache.stratos.python.cli/src/main/python/README.md ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.python.cli/src/main/python/README.md b/components/org.apache.stratos.python.cli/src/main/python/README.md index 07f021f..1721423 100644 --- a/components/org.apache.stratos.python.cli/src/main/python/README.md +++ b/components/org.apache.stratos.python.cli/src/main/python/README.md @@ -1,4 +1,4 @@ -Apache Stratos CLI +Apache Stratos Python CLI ================== #Pre-requisites @@ -10,37 +10,9 @@ pip install texttable ``` -#Build -Build and install stratos CLI by, +#Running Stratos Python CLI +Run the `stratos.sh` Bash file. -``` -$ python setup.py build -$ python setup.py install -``` - -or use -``` - $ python setup.py develop -``` - -instead `install` if developing - -To start the Python CLI issue, - -``` -$ stratos-cli -``` - -Install with Pip - -``` -pip install stratos -``` - -or to install a specific version use - -``` -pip install stratos==1.0 -``` - - +```Bash +./stratos.sh +``` \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/54072669/components/org.apache.stratos.python.cli/src/main/python/cli/CLI.py ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.python.cli/src/main/python/cli/CLI.py b/components/org.apache.stratos.python.cli/src/main/python/cli/CLI.py deleted file mode 100755 index fe0c419..0000000 --- a/components/org.apache.stratos.python.cli/src/main/python/cli/CLI.py +++ /dev/null @@ -1,1530 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you 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 cmd2 import * -from Utils import * -from Stratos import * -import Configs -from Exceptions import BadResponseError - - -class CLI(Cmd): - """Apache Stratos CLI""" - - prompt = Configs.stratos_prompt - # resolving the '-' issue - Cmd.legalChars = '-' + Cmd.legalChars - - def __init__(self): - # resolving the '-' issue - [Cmd.shortcuts.update({a[3:].replace('_', '-'): a[3:]}) for a in self.get_names() if a.startswith('do_')] - Cmd.__init__(self) - - def completenames(self, text, *ignored): - # resolving the '-' issue - return [a[3:].replace('_', '-') for a in self.get_names() if a.replace('_', '-').startswith('do-'+text)] - - """ - - Stratos CLI specific methods - ==================================================================================================================== - - # User - * list-users - * add-user - * update-user - * remove-user - - """ - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_list_users(self, line , opts=None): - """Retrieve details of all users.""" - try: - users = Stratos.list_users() - table = PrintableTable() - rows = [["Username", "Role"]] - for user in users: - rows.append([user['userName'], user['role']]) - table.add_rows(rows) - table.print_table() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-s', '--username_user', type="str", help="Username of the user"), - make_option('-a', '--password_user', type="str", help="Password of the user"), - make_option('-r', '--role_name', type="str", help="Role name of the user"), - make_option('-f', '--first_name', type="str", help="First name of the user"), - make_option('-l', '--last_name', type="str", help="Last name of the user"), - make_option('-e', '--email', type="str", help="Email of the user"), - make_option('-o', '--profile_name', type="str", help="Profile name of the user") - ]) - @auth - def do_add_user(self, line , opts=None): - """Add a user.""" - try: - if not opts.username_user or not opts.password_user: - print("usage: add-user [-s <username>] [-a <credential>] [-r <role>] [-e <email>] [-f <first name>]" + - " [-l <last name>] [-o <profile name>]") - return - else: - user = Stratos.add_users(opts.username_user, opts.password_user, opts.role_name, opts.first_name, - opts.last_name, opts.email, opts.profile_name) - if user: - print("User successfully created") - else: - print("Error creating the user") - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-s', '--username_user', type="str", help="Username of the user to be created"), - make_option('-a', '--password_user', type="str", help="Password of the user to be created"), - make_option('-r', '--role_name', type="str", help="Role name of the user to be created"), - make_option('-f', '--first_name', type="str", help="First name of the user to be created"), - make_option('-l', '--last_name', type="str", help="Last name of the user to be created"), - make_option('-e', '--email', type="str", help="Email of the user to be created"), - make_option('-o', '--profile_name', type="str", help="Profile name of the user to be created") - ]) - @auth - def do_update_user(self, line , opts=None): - """Update a specific user.""" - try: - user = Stratos.update_user(opts.username_user, opts.password_user, opts.role_name, opts.first_name, - opts.last_name, opts.email, opts.profile_name) - if user: - print("User successfully updated") - else: - print("Error updating the user") - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_remove_user(self, name , opts=None): - """Delete a user.""" - try: - if not name: - print("usage: remove-user [username]") - else: - user_removed = Stratos.remove_user(name) - if user_removed: - print("You have successfully deleted user: "+name) - else: - print("Could not delete user: "+name) - except BadResponseError as e: - self.perror(str(e)) - - """ - # Applications - * list-applications - * describe-application - * add-application - * update-application - * remove-application - * describe-application-runtime - * deploy-application - - """ - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_list_applications(self, line , opts=None): - """Retrieve details of all the applications.""" - try: - applications = Stratos.list_applications() - if not applications: - print("No applications found") - else: - table = PrintableTable() - rows = [["Application ID", "Alias", "Status"]] - for application in applications: - rows.append([application['applicationId'], application['alias'], application['status']]) - table.add_rows(rows) - table.print_table() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_describe_application(self, application_id , opts=None): - """Describe an application.""" - try: - if not application_id: - print("usage: describe-application [cluster-id]") - return - application = Stratos.describe_application(application_id) - if not application: - print("Application not found in : "+application_id) - else: - print("Application : "+application_id) - PrintableTree(application).print_tree() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_add_application(self, line , opts=None): - """Add an application.""" - try: - if not opts.json_file_path: - print("usage: add-application [-f <resource path>]") - else: - add_application = Stratos.add_application(open(opts.json_file_path, 'r').read()) - if add_application: - print("Application added successfully") - else: - print("Error adding application") - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_update_application(self, application , opts=None): - """Update an application.""" - try: - if not opts.json_file_path: - print("usage: update-application [-f <resource path>] [application]") - else: - update_application = Stratos.update_application(application, open(opts.json_file_path, 'r').read()) - if update_application: - print("Application updated successfully") - else: - print("Error updating application") - except BadResponseError as e: - self.perror(str(e)) - - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_remove_application(self, application , opts=None): - """Delete an application.""" - try: - if not application: - print("usage: remove-application [application]") - else: - application_removed = Stratos.remove_application(application) - if application_removed: - print("You have successfully removed application: "+application) - else: - print("Could not delete application : "+application) - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-a', '--application_id', type="str", help="Unique ID of the application"), - make_option('-o', '--application_policy_id', type="str", help="Unique ID of the application policy") - ]) - @auth - def do_deploy_application(self, line , opts=None): - """Deploy an application.""" - try: - if not opts.application_id or not opts.application_policy_id: - print("usage: deploy-application [-a <applicationId>] [-o <applicationPolicyId>]") - else: - application_removed = Stratos.deploy_application(opts.application_id, opts.application_policy_id) - if application_removed: - print("You have successfully deployed application: "+opts.application_id) - else: - print("Could not deployed application : "+opts.application_id) - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-a', '--application_id', type="str", help="Unique ID of the application"), - make_option('-o', '--application_policy_id', type="str", help="Unique ID of the application policy") - ]) - @auth - def do_undeploy_application(self, line , opts=None): - """Undeploy an application.""" - try: - if not opts.application_id: - print("usage: undeploy-application [-a <applicationId>]") - else: - application_removed = Stratos.undeploy_application(opts.application_id) - if application_removed: - print("You have successfully undeployed application: "+opts.application_id) - else: - print("Could not undeployed application : "+opts.application_id) - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_describe_application_runtime(self, application_id , opts=None): - """Describe the runtime topology of an application.""" - try: - if not application_id: - print("usage: describe-application-runtime [application-id]") - return - application_runtime = Stratos.describe_application_runtime(application_id) - if not application_runtime: - print("Application runtime not found") - else: - print("Application : "+application_id) - PrintableJSON(application_runtime).pprint() - except BadResponseError as e: - self.perror(str(e)) - - """ - # Application signup - * describe-application-signup - * add-application-signup - * remove-application-signup - - """ - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_describe_application_signup(self, application_id , opts=None): - """Retrieve details of a specific application signup.""" - try: - if not application_id: - print("usage: describe-application-signup [application-id]") - return - application_signup = Stratos.describe_application_signup(application_id) - if not application_signup: - print("Application signup not found") - else: - PrintableJSON(application_signup).pprint() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_add_application_signup(self, application_id, opts=None): - """Add a new application signup to the system""" - try: - if not opts.json_file_path: - print("usage: add-application-signup [-f <resource path>] [application_id]") - else: - application_signup = Stratos.add_application_signup(application_id, open(opts.json_file_path, 'r').read()) - if application_signup: - print("Application signup added successfully") - else: - print("Error creating application signup") - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_remove_application_signup(self, signup , opts=None): - """Delete an application sign up.""" - try: - if not signup: - print("usage: remove-application-signup [signup]") - else: - signup_removed = Stratos.remove_application_signup(signup) - if signup_removed: - print("You have successfully remove signup: "+signup) - else: - print("Could not delete application signup: "+signup) - except BadResponseError as e: - self.perror(str(e)) - - """ - # Tenants - * list-tenants - * list-tenants-by-partial-domain - * describe-tenant - * add-tenant - * activate-tenant - * deactivate-tenant - - """ - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_list_tenants(self, line , opts=None): - """Retrieve details of all tenants.""" - try: - tenants = Stratos.list_tenants() - table = PrintableTable() - rows = [["Domain", "Tenant ID", "Email", " State", "Created Date"]] - for tenant in tenants: - rows.append([tenant['tenantDomain'], tenant['tenantId'], tenant['email'], - "Active" if tenant['active'] else "De-Active", datetime.datetime.fromtimestamp(tenant['createdDate']/1000).strftime('%Y-%m-%d %H:%M:%S')]) - table.add_rows(rows) - table.print_table() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_list_tenants_by_partial_domain(self, partial_domain , opts=None): - """Search for tenants based on the partial domain value entered.""" - try: - tenants = Stratos.list_tenants_by_partial_domain(partial_domain) - table = PrintableTable() - rows = [["Domain", "Tenant ID", "Email", " State", "Created Date"]] - for tenant in tenants: - rows.append([tenant['tenantDomain'], tenant['tenantId'], tenant['email'], - "Active" if tenant['active'] else "De-Active", datetime.datetime.fromtimestamp(tenant['createdDate']/1000).strftime('%Y-%m-%d %H:%M:%S')]) - table.add_rows(rows) - table.print_table() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_describe_tenant(self, tenant_domain_name, opts=None): - """Retrieve details of a specific tenant.""" - if not tenant_domain_name: - print("usage: describe-tenant [Domain-Name]") - else: - try: - tenant = Stratos.describe_tenant(tenant_domain_name) - if not tenant: - print("Tenant not found") - else: - print("-------------------------------------") - print("Tenant Information:") - print("-------------------------------------") - print("Tenant domain: "+tenant['tenantDomain']) - print("ID: "+str(tenant['tenantId'])) - print("Active: "+str(tenant['active'])) - print("Email: "+tenant['email']) - print("Created date: "+datetime.datetime.fromtimestamp(tenant['createdDate']/1000).strftime('%Y-%m-%d %H:%M:%S')) - print("-------------------------------------") - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-s', '--username_user', type="str", help="Username of the tenant"), - make_option('-a', '--password_user', type="str", help="Password of the tenant"), - make_option('-d', '--domain_name', type="str", help="domain name of the tenant"), - make_option('-f', '--first_name', type="str", help="First name of the tenant"), - make_option('-l', '--last_name', type="str", help="Last name of the tenant"), - make_option('-e', '--email', type="str", help="Email of the tenant") - ]) - @auth - def do_add_tenant(self, line , opts=None): - """Add a tenant.""" - try: - tenant = Stratos.add_tenant(opts.username_user, opts.first_name, opts.last_name, opts.password_user, - opts.domain_name, opts.email) - if tenant: - print("Tenant added successfully : "+opts.domain_name) - else: - print("Error creating the tenant : "+opts.domain_name) - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-s', '--username_user', type="str", help="Username of the tenant"), - make_option('-a', '--password_user', type="str", help="Password of the tenant"), - make_option('-d', '--domain_name', type="str", help="domain name of the tenant"), - make_option('-f', '--first_name', type="str", help="First name of the tenant"), - make_option('-l', '--last_name', type="str", help="Last name of the tenant"), - make_option('-e', '--email', type="str", help="Email of the tenant"), - make_option('-i', '--tenant_id', type="str", help="ID of the tenant") - ]) - @auth - def do_update_tenant(self, line , opts=None): - """Update a specific tenant.""" - try: - tenant = Stratos.update_tenant(opts.username_user, opts.first_name, opts.last_name, opts.password_user, - opts.domain_name, opts.email, opts.tenant_id) - if tenant: - print("Tenant updated successfully : "+opts.domain_name) - else: - print("Error updating the tenant : "+opts.domain_name) - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_activate_tenant(self, tenant_domain, opts=None): - """Activate a tenant.""" - try: - if not tenant_domain: - print("usage: activate-tenant <TENANT_DOMAIN> ") - else: - activate_tenant = Stratos.activate_tenant(tenant_domain) - if activate_tenant: - print("You have successfully activated the tenant : "+tenant_domain) - else: - print("Could not activate tenant : "+tenant_domain) - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_deactivate_tenant(self, tenant_domain, opts=None): - """Deactivate a tenant.""" - try: - if not tenant_domain: - print("usage: deactivate-tenant <TENANT_DOMAIN> ") - else: - activate_tenant = Stratos.deactivate_tenant(tenant_domain) - if activate_tenant: - print("You have successfully deactivated the tenant : "+tenant_domain) - else: - print("Could not deactivate tenant : "+tenant_domain) - except BadResponseError as e: - self.perror(str(e)) - - """ - # Cartridges - * list-cartridges - * list-cartridges-by-filter - * describe-cartridge - * add-cartridge - * remove-cartridge - - """ - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_list_cartridges(self, line , opts=None): - """Retrieve details of available cartridges.""" - try: - cartridges = Stratos.list_cartridges() - table = PrintableTable() - rows = [["Type", "Category", "Name", "Description", "Version", "Multi-Tenant"]] - for cartridge in cartridges: - rows.append([cartridge['type'], cartridge['category'], cartridge['displayName'], cartridge['description'], - cartridge['version'], "True" if cartridge['multiTenant'] == 1 else "False"]) - table.add_rows(rows) - table.print_table() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_list_cartridges_by_filter(self, filter_text , opts=None): - """Retrieve details of available cartridges.""" - try: - if not filter_text: - print("usage: describe-cartridge-by-filter [filter]") - else: - cartridges = Stratos.list_cartridges_by_filter(filter_text) - table = PrintableTable() - rows = [["Type", "Category", "Name", "Description", "Version", "Multi-Tenant"]] - for cartridge in cartridges: - rows.append([cartridge['type'], cartridge['category'], cartridge['displayName'], cartridge['description'], - cartridge['version'], "True" if cartridge['multiTenant'] == 1 else "False"]) - table.add_rows(rows) - table.print_table() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_describe_cartridge(self, cartridge_type, opts=None): - """Retrieve details of a specific cartridge.""" - if not cartridge_type: - print("usage: describe-cartridge [cartridge-type]") - else: - try: - cartridge = Stratos.describe_cartridge(cartridge_type) - if not cartridge: - print("Cartridge not found") - else: - print("-------------------------------------") - print("Cartridge Information:") - print("-------------------------------------") - print("Type: "+cartridge['type']) - print("Category: "+cartridge['category']) - print("Name: "+cartridge['displayName']) - print("Description: "+cartridge['description']) - print("Version: "+str(cartridge['version'])) - print("Multi-Tenant: "+str(cartridge['multiTenant'])) - print("Host Name: "+cartridge['host']) - print("-------------------------------------") - except requests.HTTPError as e: - self.perror(str(e)) - - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_add_cartridge(self, line , opts=None): - """Add a cartridge definition.""" - try: - if not opts.json_file_path: - print("usage: add-cartridge [-f <resource path>]") - else: - cartridge = Stratos.add_cartridge(open(opts.json_file_path, 'r').read()) - if cartridge: - print("Cartridge added successfully") - else: - print("Error adding Cartridge") - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_update_cartridge(self, line , opts=None): - """Update a cartridge""" - try: - if not opts.json_file_path: - print("usage: update-cartridge [-f <resource path>]") - else: - cartridge = Stratos.update_cartridge(open(opts.json_file_path, 'r').read()) - if cartridge: - print("Cartridge updated successfully") - else: - print("Error updating Cartridge") - except BadResponseError as e: - self.perror(str(e)) - - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_remove_cartridge(self, cartridge_type , opts=None): - """Delete a cartridge""" - try: - if not cartridge_type: - print("usage: remove-cartridge [cartridge-type]") - else: - cartridge_removed = Stratos.remove_cartridge(cartridge_type) - if cartridge_removed: - print("Successfully un-deployed cartridge : "+cartridge_type) - else: - print("Could not un-deployed cartridge : "+cartridge_type) - except BadResponseError as e: - self.perror(str(e)) - - """ - # Cartridge groups - * list-cartridge-groups - * describe-cartridge-group - * add-cartridge-group - * remove-cartridge-group - - """ - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_list_cartridge_groups(self, line , opts=None): - """Retrieve details of all the cartridge groups.""" - try: - cartridge_groups = Stratos.list_cartridge_groups() - if not cartridge_groups: - print("No cartridge groups found") - else: - table = PrintableTable() - rows = [["Name", "No. of cartridges", "No of groups"]] - for cartridge_group in cartridge_groups: - rows.append([cartridge_group['name'], len(cartridge_group['cartridges']), - len(cartridge_group['cartridges'])]) - table.add_rows(rows) - table.print_table() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_describe_cartridge_group(self, group_definition_name , opts=None): - """Retrieve details of a cartridge group.""" - try: - if not group_definition_name: - print("usage: describe-cartridge-group [cartridge-group-name]") - return - cartridge_group = Stratos.describe_cartridge_group(group_definition_name) - if not cartridge_group: - print("Cartridge group not found") - else: - print("Service Group : "+group_definition_name) - PrintableJSON(cartridge_group).pprint() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_add_cartridge_group(self, line , opts=None): - """Add a cartridge group.""" - try: - if not opts.json_file_path: - print("usage: add-cartridge-group [-f <resource path>]") - else: - cartridge_group = Stratos.add_cartridge_group(open(opts.json_file_path, 'r').read()) - if cartridge_group: - print("Cartridge group added successfully") - else: - print("Error adding Cartridge group") - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_update_cartridge_group(self, line , opts=None): - """Add a new user to the system""" - try: - if not opts.json_file_path: - print("usage: update-cartridge-group [-f <resource path>]") - else: - cartridge = Stratos.update_cartridge_group(open(opts.json_file_path, 'r').read()) - if cartridge: - print("Cartridge group updated successfully") - else: - print("Error updating Cartridge group") - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_remove_cartridge_group(self, group_definition_name , opts=None): - """Delete a cartridge group.""" - try: - if not group_definition_name: - print("usage: remove-cartridge-group [cartridge-group-name]") - else: - cartridge_removed = Stratos.remove_cartridge_group(group_definition_name) - if cartridge_removed: - print("Successfully un-deployed cartridge group : "+group_definition_name) - else: - print("Could not un-deployed cartridge group : "+group_definition_name) - except BadResponseError as e: - self.perror(str(e)) - - """ - # Deployment Policies - * list-deployment-policies - * describe-deployment-policy - * add-deployment-policy - * update-deployment-policy - * remove-deployment-policy - - """ - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_list_deployment_policies(self, line , opts=None): - """Retrieve details of a deployment policy.""" - try: - deployment_policies = Stratos.list_deployment_policies() - if not deployment_policies: - print("No deployment policies found") - else: - table = PrintableTable() - rows = [["Id", "Accessibility"]] - for deployment_policy in deployment_policies: - rows.append([deployment_policy['id'], len(deployment_policy['networkPartitions'])]) - table.add_rows(rows) - table.print_table() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_describe_deployment_policy(self, line , opts=None): - """Describe a deployment policy.""" - try: - if not line: - print("usage: describe-deployment-policy [deployment-policy-id]") - return - deployment_policy = Stratos.describe_deployment_policy(line) - if not deployment_policy: - print("Deployment policy not found") - else: - PrintableJSON(deployment_policy).pprint() - except BadResponseError as e: - self.perror(str(e)) - - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_add_deployment_policy(self, line , opts=None): - """Add a deployment policy definition.""" - try: - if not opts.json_file_path: - print("usage: add-deployment-policy [-f <resource path>]") - else: - deployment_policy = Stratos.add_deployment_policy(open(opts.json_file_path, 'r').read()) - if deployment_policy: - print("Deployment policy added successfully") - else: - print("Error creating deployment policy") - except BadResponseError as e: - self.perror(str(e)) - - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_update_deployment_policy(self, line , opts=None): - """Update a deployment policy.""" - try: - if not opts.json_file_path: - print("usage: update-deployment-policy [-f <resource path>]") - else: - cartridge = Stratos.update_deployment_policy(open(opts.json_file_path, 'r').read()) - if cartridge: - print("Deployment policy updated successfully") - else: - print("Error updating Deployment policy") - except BadResponseError as e: - self.perror(str(e)) - - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_remove_deployment_policy(self, deployment_policy_id , opts=None): - """Delete a deployment policy.""" - try: - if not deployment_policy_id: - print("usage: remove-deployment-policy [deployment-policy-id]") - else: - cartridge_removed = Stratos.remove_deployment_policy(deployment_policy_id) - if cartridge_removed: - print("Successfully deleted deployment policy : "+deployment_policy_id) - else: - print("Could not deleted deployment policy : "+deployment_policy_id) - except BadResponseError as e: - self.perror(str(e)) - - - """ - # Deployment Policies - * list-application-policies - * describe-application-policy - * update-application-policy - * remove-application-policy - - """ - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_list_application_policies(self, line , opts=None): - """Retrieve details of all the application policies.""" - try: - application_policies = Stratos.list_application_policies() - if not application_policies: - print("No application policies found") - else: - table = PrintableTable() - rows = [["Id", "Accessibility"]] - for application_policy in application_policies: - rows.append([application_policy['id'], len(application_policy['networkPartitions'])]) - table.add_rows(rows) - table.print_table() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_describe_application_policy(self, application_policy_id , opts=None): - """Retrieve details of a specific application policy.""" - try: - if not application_policy_id: - print("usage: describe-application-policy [application-policy-id]") - return - application_policy = Stratos.describe_application_policy(application_policy_id) - if not application_policy: - print("Deployment policy not found") - else: - PrintableJSON(application_policy).pprint() - except BadResponseError as e: - self.perror(str(e)) - - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_add_application_policy(self, line , opts=None): - """Add an application policy.""" - try: - if not opts.json_file_path: - print("usage: add-application-policy [-f <resource path>]") - else: - application_policy = Stratos.add_application_policy(open(opts.json_file_path, 'r').read()) - if application_policy: - print("Deployment policy added successfully") - else: - print("Error creating application policy") - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_update_application_policy(self, line , opts=None): - """Update an application policy.""" - try: - if not opts.json_file_path: - print("usage: update-application-policy [-f <resource path>]") - else: - cartridge = Stratos.update_application_policy(open(opts.json_file_path, 'r').read()) - if cartridge: - print("Deployment policy updated successfully") - else: - print("Error updating Deployment policy") - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_remove_application_policy(self, application_policy_id , opts=None): - """Delete an application policy.""" - try: - if not application_policy_id: - print("usage: remove-application-policy [application-policy-id]") - else: - cartridge_removed = Stratos.remove_application_policy(application_policy_id) - if cartridge_removed: - print("Successfully deleted application policy : "+application_policy_id) - else: - print("Could not deleted application policy : "+application_policy_id) - except BadResponseError as e: - self.perror(str(e)) - - """ - # Network Partitions - * list-network-partitions - * describe-network-partition - * add-network-partition - * update-network-partition - * remove-network-partition - - """ - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_list_network_partitions(self, line , opts=None): - """Retrieve details of all the network partitions.""" - try: - network_partitions = Stratos.list_network_partitions() - table = PrintableTable() - rows = [["Network Partition ID", "Number of Partitions"]] - for network_partition in network_partitions: - rows.append([network_partition['id'], len(network_partition['partitions'])]) - table.add_rows(rows) - table.print_table() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_describe_network_partition(self, network_partition_id , opts=None): - """Describe a network partition.""" - try: - if not network_partition_id: - print("usage: describe-network-partition [network-partition]") - return - deployment_policy = Stratos.describe_network_partition(network_partition_id) - if not deployment_policy: - print("Network partition not found: "+network_partition_id) - else: - print("Partition: "+network_partition_id) - PrintableJSON(deployment_policy).pprint() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_add_network_partition(self, line , opts=None): - """Add a new network partition.""" - try: - if not opts.json_file_path: - print("usage: add-network-partition [-f <resource path>]") - else: - tenant = Stratos.add_network_partition(open(opts.json_file_path, 'r').read()) - if tenant: - print("Network partition added successfully") - else: - print("Error creating network partition") - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_update_network_partition(self, line , opts=None): - """Update a specific network partition.""" - try: - if not opts.json_file_path: - print("usage: update-network-partition [-f <resource path>]") - else: - cartridge = Stratos.update_network_partition(open(opts.json_file_path, 'r').read()) - if cartridge: - print("Network partition updated successfully") - else: - print("Error updating Network partition") - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_remove_network_partition(self, network_partition_id, opts=None): - """Delete a network partition.""" - try: - if not network_partition_id: - print("usage: remove-network-partition [network-partition-id]") - else: - cartridge_removed = Stratos.remove_network_partition(network_partition_id) - if cartridge_removed: - print("Successfully deleted network-partition : "+network_partition_id) - else: - print("Could not deleted network-partition : "+network_partition_id) - except BadResponseError as e: - self.perror(str(e)) - - """ - # Auto-scaling policies - * list-autoscaling-policies - * describe-autoscaling-policy - * add-autoscaling-policy - * update-autoscaling-policy - * remove-autoscaling-policy - - """ - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_list_autoscaling_policies(self, line , opts=None): - """Retrieve details of auto-scaling policies.""" - try: - autoscaling_policies = Stratos.list_autoscaling_policies() - if not autoscaling_policies: - print("No autoscaling policies found") - else: - table = PrintableTable() - rows = [["Id", "Accessibility"]] - for autoscaling_policy in autoscaling_policies: - rows.append([autoscaling_policy['id'], "Public" if autoscaling_policy['isPublic'] else "Private"]) - table.add_rows(rows) - table.print_table() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_describe_autoscaling_policy(self, autoscaling_policy_id , opts=None): - """Retrieve details of a specific auto-scaling policy.""" - try: - if not autoscaling_policy_id: - print("usage: describe-autoscaling-policy [autoscaling-policy-id]") - return - autoscaling_policy = Stratos.describe_autoscaling_policy(autoscaling_policy_id) - if not autoscaling_policy: - print("Autoscaling policy not found : "+autoscaling_policy_id) - else: - print("Autoscaling policy : "+autoscaling_policy_id) - PrintableJSON(autoscaling_policy).pprint() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_add_autoscaling_policy(self, line , opts=None): - """Add an auto-scaling policy definition.""" - try: - if not opts.json_file_path: - print("usage: add-autoscaling-policy [-f <resource path>]") - else: - autoscaling_policy = Stratos.add_autoscaling_policy(open(opts.json_file_path, 'r').read()) - if autoscaling_policy: - print("Autoscaling policy added successfully") - else: - print("Error adding autoscaling policy") - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_update_autoscaling_policy(self, line , opts=None): - """Update an auto-scaling policy.""" - try: - if not opts.json_file_path: - print("usage: update-autoscaling-policy [-f <resource path>]") - else: - autoscaling_policy = Stratos.update_autoscaling_policy(open(opts.json_file_path, 'r').read()) - if autoscaling_policy: - print("Autoscaling policy updated successfully:") - else: - print("Error updating Autoscaling policy") - except BadResponseError as e: - self.perror(str(e)) - - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_remove_autoscaling_policy(self, autoscaling_policy_id , opts=None): - """Delete an autoscaling_policy.""" - try: - if not autoscaling_policy_id: - print("usage: remove-autoscaling-policy [application-id]") - else: - autoscaling_policy_removed = Stratos.remove_autoscaling_policy(autoscaling_policy_id) - if autoscaling_policy_removed: - print("Successfully deleted Auto-scaling policy : "+autoscaling_policy_id) - else: - print("Auto-scaling policy not found : "+autoscaling_policy_id) - except BadResponseError as e: - self.perror(str(e)) - - - """ - # Kubernetes clusters/hosts - * list-kubernetes-clusters - * describe-kubernetes-cluster - * describe-kubernetes-master - * add-kubernetes-cluster - * add-kubernetes-host - * list-kubernetes-hosts - * update-kubernetes-host - * update-kubernetes-master - * remove-kubernetes-cluster - * remove-kubernetes-host - - """ - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_list_kubernetes_clusters(self, line , opts=None): - """Retrieving details of all Kubernetes-CoreOS Clusters.""" - try: - kubernetes_clusters = Stratos.list_kubernetes_clusters() - if not kubernetes_clusters: - print("No Kubernetes clusters found") - else: - table = PrintableTable() - rows = [["Group ID", "Description"]] - for kubernetes_cluster in kubernetes_clusters: - rows.append([kubernetes_cluster['clusterId'], kubernetes_cluster['description']]) - table.add_rows(rows) - table.print_table() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_describe_kubernetes_cluster(self, kubernetes_cluster_id, opts=None): - """Describe a Kubernetes-CoreOS Cluster.""" - try: - if not kubernetes_cluster_id: - print("usage: describe-kubernetes-cluster [cluster-i]]") - return - kubernetes_cluster = Stratos.describe_kubernetes_cluster(kubernetes_cluster_id) - if not kubernetes_cluster: - print("Kubernetes cluster not found") - else: - print("Kubernetes cluster: "+kubernetes_cluster_id) - PrintableJSON(kubernetes_cluster).pprint() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_describe_kubernetes_master(self, kubernetes_cluster_id , opts=None): - """Retrieve details of the master in a Kubernetes-CoreOS Cluster.""" - try: - if not kubernetes_cluster_id: - print("usage: describe-kubernetes-master [cluster-id]") - return - kubernetes_master = Stratos.describe_kubernetes_master(kubernetes_cluster_id) - if not kubernetes_master: - print("Kubernetes master not found in : "+kubernetes_cluster_id) - else: - print("Cluster : "+kubernetes_cluster_id) - PrintableJSON(kubernetes_master).pprint() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_add_kubernetes_cluster(self, opts=None): - """Add a Kubernetes-CoreOS Cluster.""" - try: - if not opts.json_file_path: - print("usage: add-kubernetes-cluster [-f <resource path>]") - else: - kubernetes_cluster = Stratos.add_kubernetes_cluster(open(opts.json_file_path, 'r').read()) - if kubernetes_cluster: - print("You have successfully deployed the Kubernetes cluster") - else: - print("Error deploying the Kubernetes cluster ") - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_add_kubernetes_host(self, kubernetes_cluster_id , opts=None): - """Add a host to a Kubernetes-CoreOS Cluster.""" - try: - if not kubernetes_cluster_id or not opts.json_file_path: - print("usage: add-kubernetes-host [-f <resource path>] [kubernetes cluster id]") - else: - kubernetes_host = Stratos.add_kubernetes_host(kubernetes_cluster_id, open(opts.json_file_path, 'r').read()) - if kubernetes_host: - print("You have successfully deployed host to Kubernetes cluster: "+kubernetes_cluster_id) - else: - print("Error deploying host to Kubernetes cluster: "+kubernetes_cluster_id) - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-c', '--cluster_id', type="str", help="Cluster ID") - ]) - def do_list_kubernetes_hosts(self, line , opts=None): - """Retrieve details of all hosts of a Kubernetes-CoreOS Cluster.""" - try: - if not opts.cluster_id: - print("usage: list-kubernetes-hosts [-c <cluster id>]") - return - kubernetes_cluster_hosts = Stratos.list_kubernetes_hosts(opts.cluster_id) - if not kubernetes_cluster_hosts: - print("No kubernetes hosts found") - else: - table = PrintableTable() - rows = [["Host ID", "Hostname", "Private IP Address", "Public IP Address"]] - for kubernetes_cluster_host in kubernetes_cluster_hosts: - rows.append([kubernetes_cluster_host['hostId'], kubernetes_cluster_host['hostname'], - kubernetes_cluster_host['privateIPAddress'], kubernetes_cluster_host['publicIPAddress']]) - table.add_rows(rows) - table.print_table() - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-c', '--cluster_id', type="str", help="Cluster id of the cluster"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_update_kubernetes_master(self, line , opts=None): - """Update the master node of the Kubernetes-CoreOS Cluster.""" - try: - if not opts.json_file_path: - print("usage: update-kubernetes-master [-c <cluster id>] [-p <resource path>]") - else: - cartridge = Stratos.update_kubernetes_master(opts.cluster_id, open(opts.json_file_path, 'r').read()) - if cartridge: - print("Kubernetes master updated successfully") - else: - print("Error updating Kubernetes master") - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_update_kubernetes_host(self, line , opts=None): - """Update the host of a Kubernetes-CoreOS Cluster.""" - try: - if not opts.json_file_path: - print("usage: update-kubernetes-host [-f <resource path>]") - else: - cartridge = Stratos.update_kubernetes_host(open(opts.json_file_path, 'r').read()) - if cartridge: - print(cartridge) - print("You have succesfully updated host to Kubernetes cluster") - else: - print("Error updating Kubernetes host") - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_remove_kubernetes_cluster(self, kubernetes_cluster_id, opts=None): - """Delete a Kubernetes-CoreOS Cluster.""" - try: - if not kubernetes_cluster_id: - print("usage: remove-kubernetes-cluster [cluster-id]") - else: - kubernetes_cluster_removed = Stratos.remove_kubernetes_cluster(kubernetes_cluster_id) - if kubernetes_cluster_removed: - print("Successfully un-deployed kubernetes cluster : "+kubernetes_cluster_id) - else: - print("Kubernetes cluster not found : "+kubernetes_cluster_id) - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-c', '--cluster_id', type="str", help="Cluster id of Kubernets cluster"), - make_option('-o', '--host_id', type="str", help="Host id of Kubernets cluster") - ]) - @auth - def do_remove_kubernetes_host(self, line, opts=None): - """Delete the host of a Kubernetes-CoreOS Cluster.""" - try: - if not opts.cluster_id or not opts.host_id: - print("usage: remove-kubernetes-host [-c cluster-id] [-o host-id]") - else: - kubernetes_host_removed = Stratos.remove_kubernetes_host(opts.cluster_id, opts.host_id) - if kubernetes_host_removed: - print("Successfully un-deployed kubernetes host : "+opts.host_id) - else: - print("Kubernetes host not found : "+opts.cluster_id+"/"+opts.host_id) - except BadResponseError as e: - self.perror(str(e)) - - """ - # Domain Mapping - * list-domain-mappings - * add-domain-mapping - * remove-domain-mapping - - """ - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_list_domain_mappings(self, application_id , opts=None): - """Retrieve details of domain mappings of an application.""" - try: - if not application_id: - print("usage: list-domain-mappings [application-id]") - else: - domain_mappings = Stratos.list_domain_mappings(application_id) - if domain_mappings: - table = PrintableTable() - rows = [["Domain", "Tenant ID", "Email", " State", "Created Date"]] - for domain_mapping in domain_mappings: - rows.append([domain_mapping['domain_mappingsDomain'], domain_mapping['domain_mappingId'], domain_mapping['email'], - "Active" if domain_mapping['active'] else "De-Active", datetime.datetime.fromtimestamp(domain_mapping['createdDate']/1000).strftime('%Y-%m-%d %H:%M:%S')]) - table.add_rows(rows) - table.print_table() - else: - print("No domain mappings found in application: "+application_id) - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user"), - make_option('-f', '--json_file_path', type="str", help="Path of the JSON file") - ]) - @auth - def do_add_domain_mapping(self, application_id, opts=None): - """Map domain to a subscribed cartridge.""" - try: - if not application_id or not opts.json_file_path: - print("usage: add-domain-mapping [-f <resource path>] [application id]") - else: - domain_mapping = Stratos.add_domain_mapping(application_id, open(opts.json_file_path, 'r').read()) - if domain_mapping: - print(" Domain mapping added successfully") - else: - print("Error creating domain mapping") - except BadResponseError as e: - self.perror(str(e)) - - @options([ - make_option('-u', '--username', type="str", help="Username of the user"), - make_option('-p', '--password', type="str", help="Password of the user") - ]) - @auth - def do_remove_domain_mappings(self, domain , opts=None): - """Remove domain mappings of an application.""" - try: - if not domain: - print("usage: remove-domain-mappings [domain]") - else: - domain_removed = Stratos.remove_domain_mappings(domain) - if domain_removed: - print("You have successfully deleted domain: "+domain) - else: - print("Could not delete domain: "+domain) - except BadResponseError as e: - self.perror(str(e)) - http://git-wip-us.apache.org/repos/asf/stratos/blob/54072669/components/org.apache.stratos.python.cli/src/main/python/cli/Configs.py ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.python.cli/src/main/python/cli/Configs.py b/components/org.apache.stratos.python.cli/src/main/python/cli/Configs.py deleted file mode 100644 index 41a04e7..0000000 --- a/components/org.apache.stratos.python.cli/src/main/python/cli/Configs.py +++ /dev/null @@ -1,32 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you 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 - -stratos_prompt = "stratos> " - -stratos_dir = "~/.stratos" -log_file_name = "stratos-cli.log" - -stratos_dir_path = os.path.expanduser(stratos_dir) -log_file_path = os.path.join(stratos_dir_path, log_file_name) - -stratos_url = os.getenv('STRATOS_URL', "https://localhost:9443/";) -stratos_api_url = stratos_url + "api/" -stratos_username = os.getenv('STRATOS_USERNAME', "") -stratos_password = os.getenv('STRATOS_PASSWORD', "") -debug_cli = os.getenv('STRATOS_CLI_DEBUG', "False") http://git-wip-us.apache.org/repos/asf/stratos/blob/54072669/components/org.apache.stratos.python.cli/src/main/python/cli/Exceptions.py ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.python.cli/src/main/python/cli/Exceptions.py b/components/org.apache.stratos.python.cli/src/main/python/cli/Exceptions.py deleted file mode 100644 index 056a8c7..0000000 --- a/components/org.apache.stratos.python.cli/src/main/python/cli/Exceptions.py +++ /dev/null @@ -1,25 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you 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. - - -class BadResponseError(Exception): - def __init__(self, error_code, message=""): - self.error_code = error_code - self.message = message - - def __str__(self): - return self.message \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/54072669/components/org.apache.stratos.python.cli/src/main/python/cli/Logging.py ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.python.cli/src/main/python/cli/Logging.py b/components/org.apache.stratos.python.cli/src/main/python/cli/Logging.py deleted file mode 100644 index 3caa892..0000000 --- a/components/org.apache.stratos.python.cli/src/main/python/cli/Logging.py +++ /dev/null @@ -1,29 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you 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 logging -import os -import Configs - -if not os.path.exists(Configs.stratos_dir_path): - try: - os.makedirs(Configs.stratos_dir_path) - logging.info("Created directory: "+Configs.stratos_dir_path) - except OSError: - logging.warning("Failed to create directory: "+Configs.stratos_dir_path) - -logging.basicConfig(filename=Configs.log_file_path, level=logging.DEBUG) http://git-wip-us.apache.org/repos/asf/stratos/blob/54072669/components/org.apache.stratos.python.cli/src/main/python/cli/Main.py ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.python.cli/src/main/python/cli/Main.py b/components/org.apache.stratos.python.cli/src/main/python/cli/Main.py deleted file mode 100755 index 2b9b649..0000000 --- a/components/org.apache.stratos.python.cli/src/main/python/cli/Main.py +++ /dev/null @@ -1,66 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you 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 sys -import readline -import getpass -from CLI import CLI -import Configs - -# Fix Python 2.x. -from Stratos import Stratos -from Exceptions import BadResponseError - -try: - input = raw_input -except NameError: - pass - - -def prompt_for_credentials(): - """Prompt for user credentials""" - while Configs.stratos_username is "" or Configs.stratos_password is "": - if Configs.stratos_username is "": - Configs.stratos_username = input("Username: ") - - if Configs.stratos_password is "": - Configs.stratos_password = getpass.getpass("Password: ") - if Stratos.authenticate(): - print("Successfully authenticated [%s]" % Configs.stratos_url) - else: - print("Could not authenticate") - exit() - - - -def main(): - # resolving the '-' issue - readline.set_completer_delims(readline.get_completer_delims().replace('-', '')) - - cli = CLI() - - if len(sys.argv) > 1: - try: - cli.onecmd(' '.join(sys.argv[1:])) - except BadResponseError as e: - print(str(e)) - else: - prompt_for_credentials() - cli.cmdloop() - -if __name__ == '__main__': - main()
