mirror of
https://github.com/clearlinux/clearstack.git
synced 2026-06-15 18:46:35 +00:00
Refactor and remove dead code
- Call ArgumentParser directly vs using a variable as an alias - Remove unused function: controller.remove_argument - Remove unused function: controller.remove_validators - Remove unused function: validators.true_or_false - Refactor utils
This commit is contained in:
@@ -61,21 +61,6 @@ class Controller:
|
||||
for argument in group.get_all_arguments()])
|
||||
return arguments
|
||||
|
||||
def remove_argument(self, group_name, conf_name):
|
||||
for group in self._groups:
|
||||
if group.group_name == group_name:
|
||||
for arg in group.arguments:
|
||||
if arg.conf_name == conf_name:
|
||||
group.arguments.remove(arg)
|
||||
return True
|
||||
return False
|
||||
|
||||
def remove_validators(self, conf_names):
|
||||
for group in self._groups:
|
||||
for arg in group.arguments:
|
||||
if arg.conf_name in conf_names:
|
||||
arg.validators.clear()
|
||||
|
||||
def validate_groups(self, conf_values):
|
||||
""" Load validation functions, in order to check
|
||||
the values in the answer file """
|
||||
|
||||
+1
-4
@@ -33,11 +33,8 @@ from clearstack.common.util import LOG
|
||||
|
||||
class ClearstackConfiguratorShell(object):
|
||||
|
||||
def __init__(self, parser_class=argparse.ArgumentParser):
|
||||
self.parser_class = parser_class
|
||||
|
||||
def get_base_parser(self):
|
||||
parser = self.parser_class(
|
||||
parser = argparse.ArgumentParser(
|
||||
prog='clearstack',
|
||||
description=__doc__.strip(),
|
||||
epilog='See "clearstack help COMMAND" '
|
||||
|
||||
+8
-20
@@ -61,7 +61,6 @@ def run_recipe(recipe_file, recipe_src, hosts):
|
||||
_run_recipe_in_hosts(recipe_file, recipes_dir, hosts)
|
||||
return True
|
||||
|
||||
|
||||
def _run_recipe_local(recipe_file):
|
||||
if recipe_file.endswith('.py'):
|
||||
util.run_command("python3 {0}".format(recipe_file))
|
||||
@@ -93,7 +92,6 @@ def get_all_hosts():
|
||||
hosts.add(conf["CONFIG_AMQP_HOST"])
|
||||
hosts.add(conf["CONFIG_MARIADB_HOST"])
|
||||
hosts.add(conf["CONFIG_MONGODB_HOST"])
|
||||
|
||||
return hosts
|
||||
|
||||
|
||||
@@ -108,8 +106,8 @@ def generate_conf_file(conf_file):
|
||||
os.makedirs(dir_name)
|
||||
|
||||
config_file.add_section("general")
|
||||
for key in conf.keys():
|
||||
config_file.set("general", key, '{0}'.format(conf[key]))
|
||||
for key, value in conf.items():
|
||||
config_file.set("general", key, '{0}'.format(value))
|
||||
|
||||
with open(conf_file, 'w') as f:
|
||||
config_file.write(f)
|
||||
@@ -117,46 +115,38 @@ def generate_conf_file(conf_file):
|
||||
|
||||
def copy_resources():
|
||||
_copy_resources_to_hosts(get_all_hosts())
|
||||
return True
|
||||
|
||||
|
||||
def _copy_resources_local():
|
||||
resources_dir = os.path.dirname(os.path.realpath(__file__))
|
||||
modules_src = "{0}/modules".format(resources_dir)
|
||||
common_src = "{0}/common".format(resources_dir)
|
||||
|
||||
modules_dst = "{0}/modules".format(__recipes_directory)
|
||||
common_dst = "{0}/common".format(__recipes_directory)
|
||||
conf_file = "{0}/defaults.conf".format(__recipes_directory)
|
||||
|
||||
generate_conf_file(conf_file)
|
||||
shutil.copytree(modules_src, modules_dst)
|
||||
shutil.copytree(common_src, common_dst)
|
||||
|
||||
|
||||
def _copy_resources_to_hosts(_hosts):
|
||||
ssh = SshHandler.get()
|
||||
try:
|
||||
SshHandler.get().test_hosts(_hosts)
|
||||
ssh.test_hosts(_hosts)
|
||||
except Exception as e:
|
||||
raise e
|
||||
|
||||
hosts = set(_hosts)
|
||||
ssh = SshHandler.get()
|
||||
resources_dir = os.path.dirname(os.path.realpath(__file__))
|
||||
modules_dir = "{0}/modules".format(resources_dir)
|
||||
common_dir = "{0}/common".format(resources_dir)
|
||||
conf_file = "{0}/defaults.conf".format(__recipes_directory)
|
||||
|
||||
if util.has_localhost(hosts):
|
||||
if util.has_localhost(_hosts):
|
||||
_copy_resources_local()
|
||||
util.remove_localhost(_hosts)
|
||||
|
||||
util.remove_localhost(hosts)
|
||||
|
||||
if not os.path.isfile(conf_file):
|
||||
generate_conf_file(conf_file)
|
||||
generate_conf_file(conf_file)
|
||||
|
||||
""" Copy modules and conf to hosts """
|
||||
for host in hosts:
|
||||
for host in _hosts:
|
||||
try:
|
||||
ssh.transfer_file(modules_dir, __recipes_directory, host)
|
||||
ssh.transfer_file(common_dir, __recipes_directory, host)
|
||||
@@ -164,8 +154,6 @@ def _copy_resources_to_hosts(_hosts):
|
||||
except Exception as e:
|
||||
raise e
|
||||
|
||||
return True
|
||||
|
||||
|
||||
def get_logs():
|
||||
SshHandler.get().get_logs(get_all_hosts())
|
||||
|
||||
@@ -27,11 +27,6 @@ def y_or_n(value):
|
||||
raise ValueError("please set 'y' or 'n'")
|
||||
|
||||
|
||||
def true_or_false(value):
|
||||
if not value.lower() in ("true", "false"):
|
||||
raise ValueError("please set 'True' or 'False'")
|
||||
|
||||
|
||||
def ip_or_hostname(value):
|
||||
for v in value.split(","):
|
||||
try:
|
||||
|
||||
Reference in New Issue
Block a user