Synnefo

#

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

# without modification, are permitted provided that the following

# interpreted as representing official policies, either expressed

# or implied, of GRNET S.A.

from django import dispatch

from django.conf import settings

from django.conf.urls.defaults import patterns

from django.template.loader import render_to_string

from django.utils import simplejson as json

from synnefo.api import util

from synnefo.api.actions import server_actions

from synnefo.db.models import (VirtualMachine, VirtualMachineMetadata,

                               NetworkInterface)

from synnefo.logic.backend import create_instance, delete_instance

server_created = dispatch.Signal(providing_args=["created_vm_params"])

from logging import getLogger

urlpatterns = patterns(

    'synnefo.api.servers',

    elif request.method == 'POST':

        return create_server(request)

    else:

def server_demux(request, server_id):

    elif request.method == 'DELETE':

        return delete_server(request, server_id)

    else:

def metadata_demux(request, server_id):

    elif request.method == 'POST':

        return update_metadata(request, server_id)

    else:

def metadata_item_demux(request, server_id, key):

    elif request.method == 'DELETE':

        return delete_metadata_item(request, server_id, key)

    else:

def nic_to_dict(nic):

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

            else vm.buildpercentage

        d['hostId'] = vm.hostid

        d['flavorRef'] = vm.flavor.id

        d['imageRef'] = vm.imageid

        d['suspended'] = vm.suspended

        # format source date if set

        formatted_source_date = None

        if diagnostic.source_date:

        entry = {

            'source': diagnostic.source,

            'message': diagnostic.message,

            'details': diagnostic.details,

            'level': diagnostic.level,

    return HttpResponse(json.dumps(diagnostics_dict), status=status)

def get_server_diagnostics(request, server_id):

    """

    Virtual machine diagnostics api view.

    return render_diagnostics(request, diagnostics)

def list_servers(request, detail=False):

    # Normal Response Codes: 200, 203

    # Error Response Codes: computeFault (400, 500),

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

    user_vms = VirtualMachine.objects.filter(userid=request.user_uniq)

    if since:

        user_vms = user_vms.filter(updated__gte=since)

    return HttpResponse(data, status=200)

# Use manual transactions. Backend and IP pool allocations need exclusive

# access (SELECT..FOR UPDATE). Running create_server with commit_on_success

# would result in backends and public networks to be locked until the job is

    #                       serverCapacityUnavailable (503),

    #                       overLimit (413)

    try:

        log.info('create_server %s', req)

        user_id = request.user_uniq

    return respsone

def get_server_details(request, server_id):

    # Normal Response Codes: 200, 203

    # Error Response Codes: computeFault (400, 500),

    return render_server(request, server)

def update_server_name(request, server_id):

    # Normal Response Code: 204

    # Error Response Codes: computeFault (400, 500),

    #                       buildInProgress (409),

    #                       overLimit (413)

    log.info('update_server_name %s %s', server_id, req)

    try:

    return HttpResponse(status=204)

@transaction.commit_on_success

def delete_server(request, server_id):

    # Normal Response Codes: 204

ARBITRARY_ACTIONS = ['console', 'firewallProfile']

def server_action(request, server_id):

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

    if len(req) != 1:

    vm.save()

def list_addresses(request, server_id):

    # Normal Response Codes: 200, 203

    # Error Response Codes: computeFault (400, 500),

    return HttpResponse(data, status=200)

def list_addresses_by_network(request, server_id, network_id):

    # Normal Response Codes: 200, 203

    # Error Response Codes: computeFault (400, 500),

    return HttpResponse(data, status=200)

def list_metadata(request, server_id):

    # Normal Response Codes: 200, 203

    # Error Response Codes: computeFault (400, 500),

    return util.render_metadata(request, metadata, use_values=True, status=200)

def update_metadata(request, server_id):

    # Normal Response Code: 201

    # Error Response Codes: computeFault (400, 500),

    #                       badMediaType(415),

    #                       overLimit (413)

    log.info('update_server_metadata %s %s', server_id, req)

    vm = util.get_vm(server_id, request.user_uniq, non_suspended=True)

    try:

    return util.render_metadata(request, vm_meta, status=201)

def get_metadata_item(request, server_id, key):

    # Normal Response Codes: 200, 203

    # Error Response Codes: computeFault (400, 500),

    return util.render_meta(request, d, status=200)

@transaction.commit_on_success

def create_metadata_item(request, server_id, key):

    # Normal Response Code: 201

    #                       badMediaType(415),

    #                       overLimit (413)

    log.info('create_server_metadata_item %s %s %s', server_id, key, req)

    vm = util.get_vm(server_id, request.user_uniq, non_suspended=True)

    try:

    return util.render_meta(request, d, status=201)

@transaction.commit_on_success

def delete_metadata_item(request, server_id, key):

    # Normal Response Code: 204

    return HttpResponse(status=204)

def server_stats(request, server_id):

    # Normal Response Codes: 200

    # Error Response Codes: computeFault (400, 500),