Synnefo

# -*- coding: utf-8 -*-

#

# API configuration

#####################

# URL of the Quotaholder

QUOTAHOLDER_URL = "http://127.0.0.1:8008/api/quotaholder/v"

# Copyright 2012 GRNET S.A. All rights reserved.

#

# Redistribution and use in source and binary forms, with or without

# modification, are permitted provided that the following conditions

# are met:

#

#   1. Redistributions of source code must retain the above copyright

#      notice, this list of conditions and the following disclaimer.

#

#  2. Redistributions in binary form must reproduce the above copyright

#     notice, this list of conditions and the following disclaimer in the

#     documentation and/or other materials provided with the distribution.

#

# THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND

# ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE

# IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE

# ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE

# FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL

# DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS

# OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)

# HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT

# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY

# OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF

# SUCH DAMAGE.

#

# The views and conclusions contained in the software and documentation are

# those of the authors and should not be interpreted as representing official

# policies, either expressed or implied, of GRNET S.A.

from functools import wraps

from contextlib import contextmanager

from synnefo.settings import QUOTAHOLDER_URL

from synnefo.db.models import QuotaHolderSerial

from synnefo.api.faults import OverLimit

from commissioning.clients.quotaholder import QuotaholderHTTP

from commissioning.api.exception import (CommissionException, NoCapacityError,

                                         NoQuantityError)

import logging

log = logging.getLogger(__name__)

@contextmanager

def get_quota_holder():

    """Context manager for using a QuotaHolder."""

    quotaholder = QuotaholderHTTP(QUOTAHOLDER_URL)

    try:

        yield quotaholder

    finally:

        pass

def uses_commission(func):

    """Decorator for wrapping functions that needs commission.

    All decorated functions must take as first argument the `serials` list in

    order to extend them with the needed serial numbers, as return by the

    Quotaholder

    On successful competition of the decorated function, all serials are

    accepted to the quotaholder, otherwise they are rejected.

    """

    @wraps(func)

    def wrapper(*args, **kwargs):

        try:

            serials = []

            ret = func(serials, *args, **kwargs)

            if serials:

                accept_commission(serials)

            return ret

        except CommissionException:

            log.exception("Unexpected error")

        except:

            if serials:

                reject_commission(serials=serials)

            raise

    return wrapper

## FIXME: Wrap the following two functions inside transaction ?

def accept_commission(serials):

    """Accept a list of pending commissions.

    @param serials: List of QuotaHolderSerial objects

    """

    # Update the DB if needed

    log.critical("Serials are %s", serials)

    for s in serials:

        if s.pending:

            s.accepted = True

            s.save()

    with get_quota_holder() as qh:

        qh.accept_commission(context={},

                             clientkey='cyclades',

                             serials=[s.serial for s in serials])

def reject_commission(serials):

    """Reject a list of pending commissions.

    @param serials: List of QuotaHolderSerial objects

    """

    # Update the DB if needed

    for s in serials:

        if s.pending:

            s.rejected = True

            s.save()

    with get_quota_holder() as qh:

        qh.reject_commission(context={},

                             clientkey='cyclades',

                             serials=[s.serial for s in serials])

def issue_commission(**commission_info):

    """Issue a new commission to the quotaholder.

    Issue a new commission to the quotaholder, and create the

    corresponing QuotaHolderSerial object in DB.

    """

    with get_quota_holder() as qh:

        try:

            serial = qh.issue_commission(**commission_info)

        except (NoCapacityError, NoQuantityError):

            raise OverLimit("Limit exceeded for your account")

    db_serial = QuotaHolderSerial.objects.create(serial=serial)

    return db_serial

# Wrapper functions for issuing commissions for each resource type.  Each

# functions creates the `commission_info` dictionary as expected by the

# `issue_commision` function. Commissions for deleting a resource, are the same

# as for creating the same resource, but with negative resource sizes.

def issue_vm_commission(user, flavor, delete=False):

    resources = get_server_resources(flavor)

    commission_info = create_commission(user, resources, delete)

    return issue_commission(**commission_info)

def get_server_resources(flavor):

    return {'vm': 1,

            'cpu': flavor.cpu,

            'disk': flavor.disk,

            # 'public_ip': 1,

            #'disk_template': flavor.disk_template,

            'ram': flavor.ram}

def issue_network_commission(user, delete=False):

    resources = get_network_resources()

    commission_info = create_commission(user, resources, delete)

    return issue_commission(**commission_info)

def get_network_resources():

    return {"network.private": 1}

def invert_resources(resources_dict):

    return dict((r, -s) for r, s in resources_dict.items())

def create_commission(user, resources, delete=False):

    if delete:

        resources = invert_resources(resources)

    provisions = [('system', 'cyclades.' + r, s)

                  for r, s in resources.items()]

    log.debug("Provisions are %s", provisions)

    return  {"context":    {},

             "target":     user,

             "key":        "",

             "clientkey":  "cyclades",

             "owner":      "",

             "ownerkey":   "",

             "name":       "",

             "provisions": provisions}