# Copyright 2014 Budapest University of Technology and Economics (BME IK)
#
# This file is part of CIRCLE Cloud.
#
# CIRCLE is free software: you can redistribute it and/or modify it under
# the terms of the GNU General Public License as published by the Free
# Software Foundation, either version 3 of the License, or (at your option)
# any later version.
#
# CIRCLE is distributed in the hope that it will be useful, but WITHOUT ANY
# WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
# FOR A PARTICULAR PURPOSE.  See the GNU General Public License for more
# details.
#
# You should have received a copy of the GNU General Public License along
# with CIRCLE.  If not, see <http://www.gnu.org/licenses/>.

import logging
from django.utils import timezone
from datetime import timedelta
from django.utils.translation import ugettext_noop
from django.conf import settings

from manager.mancelery import celery
from vm.models import Node, Instance

logger = logging.getLogger(__name__)


@celery.task(ignore_result=True)
def update_domain_states():
    nodes = Node.objects.filter(enabled=True).all()
    for node in nodes:
        node.update_vm_states()


@celery.task(ignore_result=True)
def garbage_collector(offset=timezone.timedelta(seconds=20)):
    """Garbage collector for instances.

    Suspends and destroys expired instances.

    :param timeout: Seconds before TimeOut exception
    :type timeout: int
    """
    now = timezone.now()
    grace_period = timezone.timedelta(hours=0)
    work_package = 20
    logger.debug("Garbage_collector START")
    for i in Instance.objects.filter(destroyed_at=None).all():
        logger.debug("Garbage_collector work_package:%d %s: %s:", work_package, i.pk, now > i.time_of_delete)
        if i.time_of_delete and now > i.time_of_delete + grace_period and work_package > 0:
            logger.debug("Garbage_collector delete")
            work_package -= 1
            i.destroy._async(system=True)
            logger.info("Expired instance %d destroyed.", i.pk)
            try:
                i.owner.profile.notify(
                    ugettext_noop('%(instance)s destroyed'),
                    ugettext_noop(
                        'Your instance <a href="%(url)s">%(instance)s</a> '
                        'has been destroyed due to expiration.'),
                    instance=i.name, url=i.get_absolute_url())
            except Exception as e:
                logger.debug('Could not notify owner of instance %d .%s',
                             i.pk, str(e))
        elif i.time_of_suspend and now > i.time_of_suspend and i.state == 'RUNNING' and work_package > 0:
            work_package -= 1
            logger.debug("Garbage_collector suspend")
            logger.info("Expired instance %d suspended." % i.pk)
            try:
                i.sleep._async(system=True)
                i.owner.profile.notify(
                    ugettext_noop('%(instance)s suspended'),
                    ugettext_noop(
                        'Your instance <a href="%(url)s">%(instance)s</a> '
                        'has been suspended due to expiration. '
                        'You can resume or destroy it.'),
                    instance=i.name, url=i.get_absolute_url())
            except ActivityInProgressError:
                logger.error("Expired instance %d can't be destroyed due the AtctivityInPorgressError.", i.pk)
            except Exception as e:
                logger.info('Could not notify owner of instance %d .%s',
                             i.pk, str(e))
        elif i.is_expiring():
            logger.debug("Instance %d expires soon." % i.pk)
            i.notify_owners_about_expiration()
        else:
            logger.debug("Instance %d didn't expire. work_package:%d", i.pk, work_package)
    logger.debug("Garbage_collector END work_package:%d", work_package)

@celery.task(ignore_result=True)
def auto_migrate():
    """Auto migration task for runtime scaling
    """
    time_limit = settings.AUTO_MIGRATION_TIME_LIMIT_IN_HOURS
    available_time = timedelta(hours=int(time_limit))
    deadline = timezone.now() + available_time
    while timezone.now() < deadline:
        migrate_one()


def migrate_one():
    """Migrate a VM syncronously.

        The target node chosen by the scheduler.
    """
    nodes = [n for n in Node.objects.filter(enabled=True) if n.online]
    node_max_cpu = max(nodes, key=lambda x: x.cpu_usage / x.cpu_weight)
    node_max_ram = max(nodes, key=lambda x: x.ram_usage / x.ram_weight)
    if node_max_cpu.cpu_usage > node_max_ram.ram_usage:
        try:
            instance_to_migrate = max(Instance.objects.filter(node=node_max_cpu.pk),
                                      key=lambda x: x.cpu_usage())
            instance_to_migrate.migrate(system=True)
        except Instance.MonitorUnavailableException:
            instance_to_migrate = max(Instance.objects.filter(node=node_max_cpu.pk),
                                      key=(lambda x: x.get_vm_desc()["vcpu"] *
                                           x.get_vm_desc()["cpu_share"]))
            instance_to_migrate.migrate(system=True)
    else:
        try:
            instance_to_migrate = max(Instance.objects.filter(node=node_max_ram.pk),
                                      key=lambda x: x.ram_usage())
            instance_to_migrate.migrate(system=True)
        except Instance.MonitorUnavailableException:
            instance_to_migrate = max(Instance.objects.filter(node=node_max_cpu.pk),
                                      key=lambda x: x.get_vm_desc()["memory"])
            instance_to_migrate.migrate(system=True)
