# Copyright 2015 rpaas authors. All rights reserved.
# Use of this source code is governed by a BSD-style
# license that can be found in the LICENSE file.

import consul

from . import nginx

ACL_TEMPLATE = """key "{service_name}/{instance_name}" {{
    policy = "read"
}}

key "{service_name}/{instance_name}/status" {{
    policy = "write"
}}

service "nginx" {{
    policy = "write"
}}
"""


class ConsulManager(object):

    def __init__(self, config):
        host = config.get("CONSUL_HOST")
        port = int(config.get("CONSUL_PORT", "8500"))
        token = config.get("CONSUL_TOKEN")
        self.client = consul.Consul(host=host, port=port, token=token)
        self.config_manager = nginx.ConfigManager(config)
        self.service_name = config.get("RPAAS_SERVICE_NAME", "rpaas")

    def generate_token(self, instance_name):
        rules = ACL_TEMPLATE.format(service_name=self.service_name,
                                    instance_name=instance_name)
        acl_name = "{}/{}/token".format(self.service_name, instance_name)
        return self.client.acl.create(name=acl_name, rules=rules)

    def destroy_token(self, acl_id):
        self.client.acl.destroy(acl_id)

    def destroy_instance(self, instance_name):
        self.client.kv.delete(self._key(instance_name), recurse=True)

    def write_healthcheck(self, instance_name):
        self.client.kv.put(self._key(instance_name, "healthcheck"), "true")

    def remove_healthcheck(self, instance_name):
        self.client.kv.delete(self._key(instance_name, "healthcheck"))

    def service_healthcheck(self):
        _, instances = self.client.health.service("nginx", tag=self.service_name)
        return instances

    def list_node(self):
        _, nodes = self.client.catalog.nodes(dc='dc1')
        return nodes

    def remove_node(self, name):
        self.agent.force_leave(name)

    def write_location(self, instance_name, path, destination=None, content=None):
        if content:
            content = content.strip()
        else:
            content = self.config_manager.generate_host_config(path, destination)
        self.client.kv.put(self._location_key(instance_name, path), content)

    def remove_location(self, instance_name, path):
        self.client.kv.delete(self._location_key(instance_name, path))

    def write_block(self, instance_name, block_name, content):
        content = self._block_header_footer(content, block_name)
        self.client.kv.put(self._block_key(instance_name, block_name), content)

    def remove_block(self, instance_name, block_name):
        self.write_block(instance_name, block_name, "")

    def list_blocks(self, instance_name, block_name=None):
        blocks = self.client.kv.get(self._block_key(instance_name, block_name),
                                    recurse=True)
        block_list = []
        if blocks[1]:
            for block in blocks[1]:
                block_name = block['Key'].split('/')[-2]
                block_value = self._block_header_footer(block['Value'], block_name,  True)
                block_list.append({'block_name': block_name, 'content': block_value})
        return block_list

    def _block_header_footer(self, content, block_name, remove=False):
        begin_block = "## Begin custom RpaaS {} block ##\n".format(block_name)
        end_block = "## End custom RpaaS {} block ##".format(block_name)
        if remove:
            content = content.replace(begin_block, "")
            content = content.replace(end_block, "")
            return content
        content_block = begin_block + content.strip() + '\n' + end_block
        return content_block

    def get_certificate(self, instance_name):
        cert = self.client.kv.get(self._ssl_cert_key(instance_name))[1]
        key = self.client.kv.get(self._ssl_key_key(instance_name))[1]
        if not cert or not key:
            raise ValueError("certificate not defined")
        return cert["Value"], key["Value"]

    def set_certificate(self, instance_name, cert_data, key_data):
        self.client.kv.put(self._ssl_cert_key(instance_name), cert_data.replace("\r\n", "\n"))
        self.client.kv.put(self._ssl_key_key(instance_name), key_data.replace("\r\n", "\n"))

    def _ssl_cert_key(self, instance_name):
        return self._key(instance_name, "ssl/cert")

    def _ssl_key_key(self, instance_name):
        return self._key(instance_name, "ssl/key")

    def _location_key(self, instance_name, path):
        location_key = "ROOT"
        if path != "/":
            location_key = path.replace("/", "___")
        return self._key(instance_name, "locations/" + location_key)

    def _block_key(self, instance_name, block_name=None):
        block_key = "ROOT"
        if block_name:
            block_path_key = self._key(instance_name,
                                       "blocks/%s/%s" % (block_name,
                                                         block_key))
        else:
            block_path_key = self._key(instance_name, "blocks")
        return block_path_key

    def _key(self, instance_name, suffix=None):
        key = "{}/{}".format(self.service_name, instance_name)
        if suffix:
            key += "/" + suffix
        return key

@@ -1766,16 +1766,8 @@
 des(
-dc='dc1'
 )%0A  

fix hardcoded dc for list_node