Synnefo

# 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 GRNET S.A. ``AS IS'' AND ANY EXPRESS

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

# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR

# 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

from django.utils import simplejson as json

from synnefo.api.faults import (BadRequest, ServiceUnavailable,

from synnefo.api.util import (random_password, get_vm, get_nic_from_index,

                              get_network_free_address)

from synnefo.db.pools import EmptyPool

from synnefo.logic import backend

from synnefo.logic.utils import get_rsapi_state

# 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 GRNET S.A. ``AS IS'' AND ANY EXPRESS

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

# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR

# 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

def not_found(request):

    raise BadRequest('Not found.')

@api_method()

def method_not_allowed(request):

    raise BadRequest('Method not allowed')

#

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

# without modification, are permitted provided that the following

import logging

from urlparse import urlparse

from django.views.decorators.csrf import csrf_exempt

from django.conf import settings

    finally:

        conn.close()

@csrf_exempt

def delegate_to_feedback_service(request):

    token = request.META.get('HTTP_X_AUTH_TOKEN')

    headers = {'X-Auth-Token': token}

@csrf_exempt

def delegate_to_user_catalogs_service(request):

    token = request.META.get('HTTP_X_AUTH_TOKEN')

    headers = {'X-Auth-Token': token, 'content-type': 'application/json'}

# 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 GRNET S.A. ``AS IS'' AND ANY EXPRESS

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

# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR

# 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.

def camelCase(s):

    return s[0].lower() + s[1:]

        self.details = details

        self.name = name or camelCase(self.__class__.__name__)

class BadRequest(Fault):

    code = 400

class Unauthorized(Fault):

    code = 401

class ResizeNotAllowed(Fault):

    code = 403

class Forbidden(Fault):

    code = 403

class ItemNotFound(Fault):

    code = 404

class BuildInProgress(Fault):

    code = 409

class OverLimit(Fault):

    code = 413

class BadMediaType(Fault):

    code = 415

class NetworkInUse(Fault):

    code = 421

class ServiceUnavailable(Fault):

    code = 503

# 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 GRNET S.A. ``AS IS'' AND ANY EXPRESS

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

# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR

# 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

log = getLogger('synnefo.api')

    (r'^(?:/|.json|.xml)?$', 'list_flavors'),

    (r'^/detail(?:.json|.xml)?$', 'list_flavors', {'detail': True}),

    (r'^/(\d+)(?:.json|.xml)?$', 'get_flavor_details'),

    log.debug('list_flavors detail=%s', detail)

    active_flavors = Flavor.objects.exclude(deleted=True)

               for flavor in active_flavors.order_by('id')]

    if request.serialization == 'xml':

log = getLogger('synnefo.api')

    (r'^(?:/|.json|.xml)?$', 'demux'),

    (r'^/detail(?:.json|.xml)?$', 'list_images', {'detail': True}),

    (r'^/([\w-]+)(?:.json|.xml)?$', 'image_demux'),

    (r'^/([\w-]+)/meta/(.+?)(?:.json|.xml)?$', 'metadata_item_demux')

)

def demux(request):

    if request.method == 'GET':

        return list_images(request)

    else:

        return method_not_allowed(request)

def image_demux(request, image_id):

    if request.method == 'GET':

        return get_image_details(request, image_id)

    else:

        return method_not_allowed(request)

def metadata_demux(request, image_id):

    if request.method == 'GET':

        return list_metadata(request, image_id)

    else:

        return method_not_allowed(request)

def metadata_item_demux(request, image_id, key):

    if request.method == 'GET':

        return get_metadata_item(request, image_id, key)

    finally:

        backend.close()

@api_method('GET')

def list_images(request, detail=False):

    # Normal Response Codes: 200, 203

log = getLogger('synnefo.api')

    (r'^(?:/|.json|.xml)?$', 'demux'),

    (r'^/detail(?:.json|.xml)?$', 'list_networks', {'detail': True}),

    (r'^/(\w+)(?:.json|.xml)?$', 'network_demux'),

        d['public'] = network.public

        attachments = [util.construct_nic_id(nic)

                                              .order_by('machine')]

        d['attachments'] = {'values': attachments}

    return d

        try:

            mode, link, mac_prefix, tags = util.values_from_flavor(flavor)

            network = Network.objects.create(

        except EmptyPool:

            log.error("Failed to allocate resources for network of type: %s",

                      flavor)

    if net.machines.all():  # Nics attached on network

        raise NetworkInUse('Machines are connected to network.')

    net.action = 'DESTROY'

    net.save()

from logging import getLogger

log = getLogger('synnefo.api')

    (r'^(?:/|.json|.xml)?$', 'demux'),

    (r'^/detail(?:.json|.xml)?$', 'list_servers', {'detail': True}),

    (r'^/(\d+)(?:.json|.xml)?$', 'server_demux'),

    if detail:

        d['status'] = get_rsapi_state(vm)

        d['progress'] = 100 if get_rsapi_state(vm) == 'ACTIVE' \

        d['hostId'] = vm.hostid

        d['updated'] = util.isoformat(vm.updated)

        d['created'] = util.isoformat(vm.created)

    else:

        user_vms = user_vms.filter(deleted=False)

               for server in user_vms.order_by('id')]

    if request.serialization == 'xml':

# additional server actions

ARBITRARY_ACTIONS = ['console', 'firewallProfile']

@util.api_method('POST')

def server_action(request, server_id):

    req = util.get_request_dict(request)

    log.debug('server_action %s %s', server_id, req)

    if len(req) != 1:

        raise faults.BadRequest("Malformed request")

            content_type = 'application/json'

        with astakos_user(user):

            response = self.client.put(url, params, content_type=content_type,

        return response

    def assertSuccess(self, response):

# 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 GRNET S.A. ``AS IS'' AND ANY EXPRESS

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

# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR

# 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

#

# The OpenStack Compute API v1.1

#

    (r'^servers', include(servers)),

    (r'^flavors', include(flavors)),

    (r'^images', include(images)),

)

    (r'^(?:.json|.xml|.atom)?$', versions_list),

    (r'^v1.1/', include(api11_patterns)),

    (r'^.+', not_found),

)

    properties = img.get('properties', {})

    image['backend_id'] = img['location']

    image['format'] = img['disk_format']

                             for key, val in properties.items())

    image['checksum'] = img['checksum']

    matching_nics = vm.nics.filter(index=nic_index)

    matching_nics_len = len(matching_nics)

    if matching_nics_len < 1:

    elif matching_nics_len > 1:

        raise BadMediaType('NIC index conflict on VM')

    nic = matching_nics[0]

    if request.serialization == 'xml':

        data = render_to_string('fault.xml', {'fault': fault})

    else:

        data = json.dumps(d)

    resp = HttpResponse(data, status=fault.code)

    """Verify that a a list of personalities is well formed"""

    if len(personality) > settings.MAX_PERSONALITY:

        raise OverLimit("Maximum number of personalities"

    for p in personality:

        # Verify that personalities are well-formed

        try:

        disk_template, provider = disk_template.split("_", 1)

    return disk_template, provider

def values_from_flavor(flavor):

    """Get Ganeti connectivity info from flavor type.

    from synnefo.db.models import VirtualMachine, Network

    keypairusernames = PublicKeyPair.objects.filter().values_list('user',

    serverusernames = VirtualMachine.objects.filter().values_list('userid',

    networkusernames = Network.objects.filter().values_list('userid',

                                                            flat=True)

# Copyright 2011 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 GRNET S.A. ``AS IS'' AND ANY EXPRESS

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

# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR

# 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

    #                       unauthorized (401),

    #                       badRequest (400),

    #                       overLimit(413)

    log.debug('version_details %s', api_version)

    # We hardcode to v1.1 since it is the only one we support

    version = VERSION_1_1.copy()