"""
Ansible module for determining if the size of OpenShift image data exceeds a specified limit in an etcd cluster.
"""

from openshift_checks import OpenShiftCheck


class EtcdImageDataSize(OpenShiftCheck):
    """Check that total size of OpenShift image data does not exceed the recommended limit in an etcd cluster"""

    name = "etcd_imagedata_size"
    tags = ["etcd"]

    def run(self):
        etcd_mountpath = self.find_ansible_mount("/var/lib/etcd")
        etcd_avail_diskspace = etcd_mountpath["size_available"]
        etcd_total_diskspace = etcd_mountpath["size_total"]

        etcd_imagedata_size_limit = self.get_var(
            "etcd_max_image_data_size_bytes",
            default=int(0.5 * float(etcd_total_diskspace - etcd_avail_diskspace))
        )

        etcd_is_ssl = self.get_var("openshift", "master", "etcd_use_ssl", default=False)
        etcd_port = self.get_var("openshift", "master", "etcd_port", default=2379)
        etcd_hosts = self.get_var("openshift", "master", "etcd_hosts")

        config_base = self.get_var("openshift", "common", "config_base")

        cert = self.get_var("etcd_client_cert", default=config_base + "/master/master.etcd-client.crt")
        key = self.get_var("etcd_client_key", default=config_base + "/master/master.etcd-client.key")
        ca_cert = self.get_var("etcd_client_ca_cert", default=config_base + "/master/master.etcd-ca.crt")

        for etcd_host in list(etcd_hosts):
            args = {
                "size_limit_bytes": etcd_imagedata_size_limit,
                "paths": ["/openshift.io/images", "/openshift.io/imagestreams"],
                "host": etcd_host,
                "port": etcd_port,
                "protocol": "https" if etcd_is_ssl else "http",
                "version_prefix": "/v2",
                "allow_redirect": True,
                "ca_cert": ca_cert,
                "cert": {
                    "cert": cert,
                    "key": key,
                },
            }

            etcdkeysize = self.execute_module("etcdkeysize", args)

            if etcdkeysize.get("rc", 0) != 0 or etcdkeysize.get("failed"):
                msg = 'Failed to retrieve stats for etcd host "{host}": {reason}'
                reason = etcdkeysize.get("msg")
                if etcdkeysize.get("module_stderr"):
                    reason = etcdkeysize["module_stderr"]

                msg = msg.format(host=etcd_host, reason=reason)
                return {"failed": True, "msg": msg}

            if etcdkeysize["size_limit_exceeded"]:
                limit = self._to_gigabytes(etcd_imagedata_size_limit)
                msg = ("The size of OpenShift image data stored in etcd host "
                       "\"{host}\" exceeds the maximum recommended limit of {limit:.2f} GB. "
                       "Use the `oadm prune images` command to cleanup unused Docker images.")
                return {"failed": True, "msg": msg.format(host=etcd_host, limit=limit)}

        return {}

    @staticmethod
    def _to_gigabytes(byte_size):
        return float(byte_size) / 10.0**9