Automatic Deployment

- node discovery
- refactoring to support multiple shelves
- configure nodes and interfaces
- provisioning
- deployment
- extending with autodeployment scripts from libvirt prototype

JIRA: [BGS-2] Create Fuel deployment scrip

Signed-off-by: Szilard Cserey <szilard.cserey@ericsson.com>
Change-Id: Ic48f93594914d5bef6c9de34d87434c7cd567198

1 files changed, 0 insertions, 212 deletions

diff --git a/fuel/deploy/deploy.py b/fuel/deploy/deploy.py
deleted file mode 100644
index 4037c1d..0000000
--- a/fuel/deploy/deploy.py
+++ /dev/null
@@ -1,212 +0,0 @@
-import time
-import os
-import sys
-
-import common
-from dha import DeploymentHardwareAdapter
-from dea import DeploymentEnvironmentAdapter
-from configure_environment import ConfigureEnvironment
-
-
-SUPPORTED_RELEASE = 'Juno on CentOS 6.5'
-
-N = common.N
-E = common.E
-R = common.R
-RO = common.RO
-exec_cmd = common.exec_cmd
-parse = common.parse
-err = common.err
-
-class Deploy(object):
-
-    def __init__(self, yaml_config_dir):
-        self.supported_release = None
-        self.yaml_config_dir = yaml_config_dir
-
-    def get_id_list(self, list):
-        return [l[0] for l in list]
-
-    def cleanup_fuel_environments(self, env_list):
-        WAIT_LOOP = 10
-        SLEEP_TIME = 2
-        id_list = self.get_id_list(env_list)
-        for id in id_list:
-            exec_cmd('fuel env --env %s --delete' % id)
-            for i in range(WAIT_LOOP):
-                if id in self.get_id_list(parse(exec_cmd('fuel env list'))):
-                    time.sleep(SLEEP_TIME)
-                else:
-                    continue
-
-    def cleanup_fuel_nodes(self, node_list):
-        for node in node_list:
-            if node[N['status']] == 'discover':
-                exec_cmd('fuel node --node-id %s --delete-from-db'
-                         % node[N['id']])
-                exec_cmd('dockerctl shell cobbler cobbler system remove '
-                         '--name node-%s' % node[N['id']])
-
-    def check_previous_installation(self):
-        env_list = parse(exec_cmd('fuel env list'))
-        if env_list:
-            self.cleanup_fuel_environments(env_list)
-        node_list = parse(exec_cmd('fuel node list'))
-        if node_list:
-            self.cleanup_fuel_nodes(node_list)
-
-    def check_supported_release(self):
-        release_list= parse(exec_cmd('fuel release -l'))
-        for release in release_list:
-            if release[R['name']] == SUPPORTED_RELEASE:
-                self.supported_release = release
-                break
-        if not self.supported_release:
-            err("This Fuel doesn't contain the following "
-                "release: %s\n" % SUPPORTED_RELEASE)
-
-    def check_role_definitions(self):
-        role_list= parse(exec_cmd('fuel role --release %s'
-                                  % self.supported_release[R['id']]))
-        roles = [role[RO['name']] for role in role_list]
-        if 'compute' not in roles:
-            err("Role compute does not exist in release %"
-                % self.supported_release[R['name']])
-        if 'controller' not in roles:
-            err("Role controller does not exist in release %"
-                % self.supported_release[R['name']])
-
-    def check_prerequisites(self):
-        self.check_supported_release()
-        self.check_role_definitions()
-        self.check_previous_installation()
-
-    def power_off_blades(self, dha, shelf_blades_dict):
-        for shelf, blade_list in shelf_blades_dict.iteritems():
-            dha.power_off_blades(shelf, blade_list)
-
-    def power_on_blades(self, dha, shelf_blades_dict):
-        for shelf, blade_list in shelf_blades_dict.iteritems():
-            dha.power_on_blades(shelf, blade_list)
-
-    def set_boot_order(self, dha, shelf_blades_dict):
-        for shelf, blade_list in shelf_blades_dict.iteritems():
-            dha.set_boot_order_blades(shelf, blade_list)
-
-    def count_discovered_nodes(self, node_list):
-        discovered_nodes = 0
-        for node in node_list:
-            if node[N['status']] == 'discover':
-                discovered_nodes += 1
-        return discovered_nodes
-
-    def wait_for_discovered_blades(self, no_of_blades):
-        WAIT_LOOP = 10
-        SLEEP_TIME = 2
-        all_discovered = False
-        node_list = parse(exec_cmd('fuel node list'))
-        for i in range(WAIT_LOOP):
-            if (self.count_discovered_nodes(node_list) < no_of_blades):
-                time.sleep(SLEEP_TIME)
-                node_list = parse(exec_cmd('fuel node list'))
-            else:
-                all_discovered = True
-                break
-        if not all_discovered:
-            err("There are %s blades defined, but not all of "
-                "them have been discovered\n" % no_of_blades)
-
-    def assign_cluster_node_ids(self, dha, dea, controllers, compute_hosts):
-        node_list= parse(exec_cmd('fuel node list'))
-        for shelf_id in dea.get_shelf_ids():
-            for blade_id in dea.get_blade_ids_per_shelf(shelf_id):
-                blade_mac_list = dha.get_blade_mac_addresses(
-                    shelf_id, blade_id)
-
-                found = False
-                for node in node_list:
-                    if (node[N['mac']] in blade_mac_list and
-                        node[N['status']] == 'discover'):
-                        found = True
-                        break
-                if found:
-                    if dea.is_controller(shelf_id, blade_id):
-                        controllers.append(node[N['id']])
-                    if dea.is_compute_host(shelf_id, blade_id):
-                        compute_hosts.append(node[N['id']])
-                else:
-                    err("Could not find the Node ID for blade "
-                        "with MACs %s or blade is not in "
-                        "discover status\n" % blade_mac_list)
-
-
-    def configure_environment(self, dea):
-        config_env = ConfigureEnvironment(dea, self.yaml_config_dir)
-
-
-
-    def provision(self):
-
-
-
-    def fix_power_address(self):
-
-
-
-
-    def deploy(self):
-
-        if id in self.get_id_list(parse(exec_cmd('fuel env list'))):
-
-        self.fix_power_address()
-
-
-
-
-def main():
-
-    yaml_path = exec_cmd('pwd').strip() + '/dea.yaml'
-    yaml_config_dir = '/var/lib/opnfv/pre_deploy'
-
-    deploy = Deploy(yaml_config_dir)
-
-    dea = DeploymentEnvironmentAdapter()
-
-    if not os.path.isfile(yaml_path):
-        sys.stderr.write("ERROR: File %s not found\n" % yaml_path)
-        sys.exit(1)
-
-    dea.parse_yaml(yaml_path)
-
-    server_type, mgmt_ip, username, password = dea.get_server_info()
-    shelf_blades_dict = dea.get_blade_ids_per_shelves()
-
-    dha = DeploymentHardwareAdapter(server_type, mgmt_ip, username, password)
-
-    deploy.check_prerequisites()
-
-    deploy.power_off_blades(dha, shelf_blades_dict)
-
-    deploy.set_boot_order(dha, shelf_blades_dict)
-
-    deploy.power_on_blades(dha, shelf_blades_dict)
-
-    macs = dha.get_blade_mac_addresses()
-
-    deploy.wait_for_discovered_blades(dea.get_no_of_blades())
-
-
-    controllers = []
-    compute_hosts = []
-    deploy.assign_cluster_node_ids(dha, dea, controllers, compute_hosts)
-
-
-
-    deploy.configure_environment(dea)
-
-    deploy.deploy(dea)
-
-
-
-if __name__ == '__main__':
-    main()
\ No newline at end of file