import base64
import json
import requests


def get_configuration(consul_host, consul_port, key):
    url = "http://{}:{}/v1/kv/{}".format(consul_host, consul_port, key)
    req = requests.get(url)
    if req.status_code != 200:
        raise Exception("xxx")
    data = req.json()
    if len(data) == 1:
        data = data[0]
        return {data["Key"]: json.loads(base64.b64decode(data["Value"]).decode("utf-8"))}
    else:
        return [
            {item["Key"]: json.loads(base64.b64decode(item["Value"]).decode("utf-8"))}
            for item in data
        ]


def get_config_data(consul_host, consul_port):
    conf_data = dict()
    conf_data['manager_host'] = get_configuration(consul_host, consul_port,
                                                  'components/manager')['components/manager']['external']['hostname']
    conf_data['manager_port'] = get_configuration(consul_host, consul_port,
                                                  'components/manager')['components/manager']['external']['port']
    # conf_data['authz_host'] = get_configuration(consul_host, consul_port,
    #                                             'components/interface')['components/interface']['external']['hostname']
    # conf_data['authz_port'] = get_configuration(consul_host, consul_port,
    #                                             'components/interface')['components/interface']['external']['port']
    conf_data['keystone_host'] = get_configuration(consul_host, consul_port,
                                                   'openstack/keystone')['openstack/keystone']['external']['url']
    # conf_data['keystone_port'] = '5000'
    conf_data['keystone_user'] = get_configuration(consul_host, consul_port,
                                                   'openstack/keystone')['openstack/keystone']['user']
    conf_data['keystone_password'] = get_configuration(consul_host, consul_port,
                                                       'openstack/keystone')['openstack/keystone']['password']
    conf_data['keystone_project'] = get_configuration(consul_host, consul_port,
                                                      'openstack/keystone')['openstack/keystone']['project']
    return conf_data

# get_conf_data('88.88.88.2', '30005')
# get_conf_data('127.0.0.1', 8082)