--- /dev/null
+# Copyright 2019 Nokia
+
+# 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 cmdatahandlers.api import config
+from cmdatahandlers.api import utils
+from cmdatahandlers.api import configerror
+from serviceprofiles import profiles
+import yaml
+import jinja2
+
+CAAS_CONFIG_FILE_PATH = "/etc/cmframework/config/"
+CAAS_CONFIG_FILE = "caas.yaml"
+
+
+class Config(config.Config):
+ valid_redundancy_models = ['non-redundant', 'active-cold-standby']
+
+ def __init__(self, confman):
+ super(Config, self).__init__(confman)
+ self.ROOT = 'cloud.caas'
+ self.DOMAIN = 'caas'
+
+ def init(self):
+ pass
+
+ def validate(self):
+ print("validate")
+
+ def flavour_set(self):
+ hostsconf = self.confman.get_hosts_config_handler()
+ caas_masters = []
+ for host in hostsconf.get_hosts():
+ if 'caas_master' in hostsconf.get_service_profiles(host):
+ caas_masters.append(host)
+
+ if len(caas_masters) > 1:
+ return "multi"
+ else:
+ return "single"
+
+ def set_dynamic_config(self):
+ if utils.is_virtualized():
+ self.config[self.ROOT]['vnf_embedded_deployment'] = self.get_vnf_flag()
+ user_conf = self.confman.get_users_config_handler()
+ self.config[self.ROOT]['helm_home'] = "/home/" + user_conf.get_admin_user() + "/.helm"
+ self.config[self.ROOT]['flavour'] = self.flavour_set()
+
+ def set_static_config(self):
+ try:
+ template = jinja2.Environment(
+ loader=jinja2.FileSystemLoader(
+ CAAS_CONFIG_FILE_PATH)).get_template(CAAS_CONFIG_FILE)
+ with open(CAAS_CONFIG_FILE_PATH + CAAS_CONFIG_FILE) as config_file:
+ data = yaml.load(config_file)
+ outputText = template.render(data)
+ config_data = yaml.load(outputText)
+ for key in config_data:
+ self.config[self.ROOT][key] = config_data[key]
+ except jinja2.exceptions.TemplateNotFound:
+ return
+ except Exception:
+ raise configerror.ConfigError("Unexpected issue occured!")
+
+ def add_defaults(self):
+ if not self.config.get('cloud.caas', ''):
+ return
+ self.set_dynamic_config()
+ self.set_static_config()
+
+ def is_vnf_embedded_deployment(self):
+ return (self.get_caas_only() and self.get_vnf_flag())
+
+ def get_vnf_flag(self):
+ return bool(self.config.get(self.ROOT, {}).get('vnf_embedded_deployment',
+ False))
+
+ def get_caas_only(self):
+ return self.is_caas_deployment() and not self.is_openstack_deployment()
+
+ def is_openstack_deployment(self):
+ return bool(self.get_controller_hosts())
+
+ def is_caas_deployment(self):
+ return bool(self.get_caas_master_hosts())
+
+ def is_hybrid_deployment(self):
+ return self.is_caas_deployment() and self.is_openstack_deployment()
+
+ def get_caas_master_hosts(self):
+ service_profiles_lib = profiles.Profiles()
+ return self._get_hosts_for_service_profile(service_profiles_lib.get_caasmaster_service_profile())
+
+ def _get_hosts_for_service_profile(self, profile):
+ hostsconf = self.confman.get_hosts_config_handler()
+ return hostsconf.get_service_profile_hosts(profile)
+
+ def get_controller_hosts(self):
+ service_profiles_lib = profiles.Profiles()
+ return self._get_hosts_for_service_profile(service_profiles_lib.get_controller_service_profile())
+
+ def get_apiserver_in_hosts(self):
+ return self.config.get(self.ROOT, {}).get('apiserver_in_hosts', '')
+
+ def get_registry_url(self):
+ return self.config.get(self.ROOT, {}).get('registry_url', '')
+
+ def get_update_registry_url(self):
+ return self.config.get(self.ROOT, {}).get('update_registry_url', '')
+
+ def get_swift_url(self):
+ return self.config.get(self.ROOT, {}).get('swift_url', '')
+
+ def get_swift_update_url(self):
+ return self.config.get(self.ROOT, {}).get('swift_update_url', '')
+
+ def get_ldap_master_url(self):
+ return self.config.get(self.ROOT, {}).get('ldap_master_url', '')
+
+ def get_ldap_slave_url(self):
+ return self.config.get(self.ROOT, {}).get('ldap_slave_url', '')
+
+ def get_chart_repo_url(self):
+ return self.config.get(self.ROOT, {}).get('chart_repo_url', '')
+
+ def get_tiller_url(self):
+ return self.config.get(self.ROOT, {}).get('tiller_url', '')
+
+ def get_apiserver_svc_ip(self):
+ return self.config.get(self.ROOT, {}).get('apiserver_svc_ip', '')
+
+ def get_caas_parameter(self, parameter):
+ return self.config.get(self.ROOT, {}).get(parameter, '')