# ============LICENSE_START=======================================================
# org.onap.dcae
# ================================================================================
# Copyright (c) 2017-2020 AT&T Intellectual Property. All rights reserved.
# ================================================================================
# 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.
# ============LICENSE_END=========================================================
#
# ECOMP is a trademark and service mark of AT&T Intellectual Property.

# -*- coding: utf-8 -*-
"""
Provides dcae cli config utilities
"""
import os, re

import click
import six

from dcae_cli import util
from dcae_cli import _version
from dcae_cli.util import get_app_dir, get_pref, update_pref, write_pref, pref_exists


class ConfigurationInitError(RuntimeError):
    pass

def get_config_path():
    '''Returns the absolute configuration file path'''
    return os.path.join(get_app_dir(), 'config.json')


def _init_config_server_url():
    return click.prompt("Please enter the remote server url", type=str).strip()

def _init_config_db_url():
    click.echo("Now we need to set up access to the onboarding catalog")
    hostname = click.prompt("Please enter the onboarding catalog hostname").strip()
    user = click.prompt("Please enter the onboarding catalog user").strip()
    password = click.prompt("Please enter the onboarding catalog password").strip()
    return "postgresql://{user}:{password}@{hostname}:5432/dcae_onboarding_db".format(
            hostname=hostname, user=user, password=password)

def _init_config():
    '''Returns an initial dict for populating the config'''
    # Grab the remote config and merge it in
    new_config = {}

    try:
        server_url = _init_config_server_url()
        new_config = util.fetch_file_from_web(server_url, "/dcae-cli/config.json")
    except:
        # Failing to pull seed configuration from remote server is not considered
        # a problem. Just continue and give user the option to set it up
        # themselves.
        if not click.confirm("Could not download initial configuration from remote server. Attempt manually setting up?"):
            raise ConfigurationInitError("Could not setup dcae-cli configuration")

    # UPDATE: Keeping the server url even though the config was not found there.
    new_config["server_url"] = server_url

    if "db_url" not in new_config or not new_config["db_url"]:
        # The seed configuration was not provided so manually set up the db
        # connection
        new_config["db_url"] = _init_config_db_url()

    if "active_profile" not in new_config:
        # The seed configuration was not provided which means the profiles will
        # be the same. The profile will be hardcoded to a an empty default.
        new_config["active_profile"] = "default"

    return new_config


def get_config():
    '''Returns the configuration dictionary'''
    return get_pref(get_config_path(), _init_config)

def get_server_url():
    """Returns the remote server url

    The remote server holds the artifacts that the dcae-cli requires like the
    seed config json and seed profiles json, and json schemas.
    """
    return get_config().get("server_url")

def get_docker_logins_key():
    """Returns the Consul key that Docker logins are stored under

    Default is "docker_plugin/docker_logins" which matches up with the docker
    plugin default.
    """
    return get_config().get("docker_logins_key", "docker_plugin/docker_logins")

# These functions are used to fetch the configurable path to the various json
# schema files used in validation.

def get_path_component_spec():
    return get_config().get("path_component_spec",
            "/schemas/component-specification/dcae-cli-v2/component-spec-schema.json")

def get_path_data_format():
    return get_config().get("path_data_format",
            "/schemas/data-format/dcae-cli-v1/data-format-schema.json")

def get_active_profile():
    return get_config().get("active_profile", None)


def update_config(**kwargs):
    '''Updates and returns the configuration dictionary'''
    return update_pref(path=get_config_path(), init_func=get_config, **kwargs)


def _reinit_config(init_func):
    new_config = init_func()
    config_path = get_config_path()

    if  pref_exists(config_path):
        existing_config = get_config()
        # Make sure to clobber existing values and not other way
        existing_config.update(new_config)
        new_config = existing_config

    write_pref(new_config, config_path)
    return new_config

def reinit_config():
    return _reinit_config(_init_config)