1 # ============LICENSE_START=======================================================
3 # ================================================================================
4 # Copyright (c) 2017-2020 AT&T Intellectual Property. All rights reserved.
5 # ================================================================================
6 # Licensed under the Apache License, Version 2.0 (the "License");
7 # you may not use this file except in compliance with the License.
8 # You may obtain a copy of the License at
10 # http://www.apache.org/licenses/LICENSE-2.0
12 # Unless required by applicable law or agreed to in writing, software
13 # distributed under the License is distributed on an "AS IS" BASIS,
14 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 # See the License for the specific language governing permissions and
16 # limitations under the License.
17 # ============LICENSE_END=========================================================
19 # ECOMP is a trademark and service mark of AT&T Intellectual Property.
21 # -*- coding: utf-8 -*-
23 Provides dcae cli config utilities
30 from dcae_cli import util
31 from dcae_cli import _version
32 from dcae_cli.util import get_app_dir, get_pref, update_pref, write_pref, pref_exists
35 class ConfigurationInitError(RuntimeError):
38 def get_config_path():
39 '''Returns the absolute configuration file path'''
40 return os.path.join(get_app_dir(), 'config.json')
43 def _init_config_server_url():
44 return click.prompt("Please enter the remote server url", type=str).strip()
46 def _init_config_db_url():
47 click.echo("Now we need to set up access to the onboarding catalog")
48 hostname = click.prompt("Please enter the onboarding catalog hostname").strip()
49 user = click.prompt("Please enter the onboarding catalog user").strip()
50 password = click.prompt("Please enter the onboarding catalog password").strip()
51 return "postgresql://{user}:{password}@{hostname}:5432/dcae_onboarding_db".format(
52 hostname=hostname, user=user, password=password)
55 '''Returns an initial dict for populating the config'''
56 # Grab the remote config and merge it in
60 server_url = _init_config_server_url()
61 new_config = util.fetch_file_from_web(server_url, "/dcae-cli/config.json")
63 # Failing to pull seed configuration from remote server is not considered
64 # a problem. Just continue and give user the option to set it up
66 if not click.confirm("Could not download initial configuration from remote server. Attempt manually setting up?"):
67 raise ConfigurationInitError("Could not setup dcae-cli configuration")
69 # UPDATE: Keeping the server url even though the config was not found there.
70 new_config["server_url"] = server_url
72 if "db_url" not in new_config or not new_config["db_url"]:
73 # The seed configuration was not provided so manually set up the db
75 new_config["db_url"] = _init_config_db_url()
77 if "active_profile" not in new_config:
78 # The seed configuration was not provided which means the profiles will
79 # be the same. The profile will be hardcoded to a an empty default.
80 new_config["active_profile"] = "default"
86 '''Returns the configuration dictionary'''
87 return get_pref(get_config_path(), _init_config)
90 """Returns the remote server url
92 The remote server holds the artifacts that the dcae-cli requires like the
93 seed config json and seed profiles json, and json schemas.
95 return get_config().get("server_url")
97 def get_docker_logins_key():
98 """Returns the Consul key that Docker logins are stored under
100 Default is "docker_plugin/docker_logins" which matches up with the docker
103 return get_config().get("docker_logins_key", "docker_plugin/docker_logins")
105 # These functions are used to fetch the configurable path to the various json
106 # schema files used in validation.
108 def get_path_component_spec():
109 return get_config().get("path_component_spec",
110 "/schemas/component-specification/dcae-cli-v2/component-spec-schema.json")
112 def get_path_data_format():
113 return get_config().get("path_data_format",
114 "/schemas/data-format/dcae-cli-v1/data-format-schema.json")
116 def get_active_profile():
117 return get_config().get("active_profile", None)
120 def update_config(**kwargs):
121 '''Updates and returns the configuration dictionary'''
122 return update_pref(path=get_config_path(), init_func=get_config, **kwargs)
125 def _reinit_config(init_func):
126 new_config = init_func()
127 config_path = get_config_path()
129 if pref_exists(config_path):
130 existing_config = get_config()
131 # Make sure to clobber existing values and not other way
132 existing_config.update(new_config)
133 new_config = existing_config
135 write_pref(new_config, config_path)
139 return _reinit_config(_init_config)