Synnefo

# Copyright 2013 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

# PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A 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 logging import getLogger

from snf_django.lib import api

from snf_django.lib.api import faults

from django.http import HttpResponse

from django.utils import simplejson as json

from snf_django.lib.api import utils

from models import Subnet

log = getLogger('synnefo.neutron')

def demux(request):

    if request.method == 'GET':

        return list_subnets(request)

    elif request.method == 'POST':

        #return create_network(request)

        return HttpResponse("in subnet POST")

    else:

        return api.api_method_not_allowed(request)

def subnet_demux(request, offset):

    if request.method == 'GET':

        #return get_network(request,offset)

        return HttpResponse("in subnet det get")

    elif request.method == 'DELETE':

        #return delete_network(request,offset)

        return HttpResponse("in subnet det delete")

    elif request.method == 'PUT':

        #return update_network(request,offset)

        return HttpResponse("in subnet det put")

    else:

        return api.api_method_not_allowed(request)

@api.api_method(http_method='GET', user_required=True, logger=log)

def list_subnets(request):

    '''Placeholder'''

    log.debug('list_subnets')

    user_subnets = Subnet.objects.filter(network__userid=request.user_uniq)

    subnets_dict = [subnet_to_dict(user_subnets)

                    for net in user_subnets.order_by('name')]

    data = json.dumps({'subnets': subnets_dict})

    return HttpResponse(data, status=200)

@api.api_method(http_method='POST', user_required=True, logger=log)

def create_subnet(request):

    '''Placeholder'''

    dic = utils.get_request_dict(request)

    try:

        subnet = dic['subnet']

        network_id = subnet['network_id']

        cidr = subnet['cidr']

    except KeyError:

        raise api.faults.BadRequest("Malformed request")

    ipversion = subnet.get('ip_version', '4')

    if ipversion != 4 or ipversion != 6:

        raise api.faults.BadRequests("Malformed IP version type")

    dhcp = subnet.get('enable_dhcp', True)

    name = subnet.get('name', None)

    # Returns the first available ip in the subnet

    potential_gateway = ipaddr.IPv4Network(cidr).network + 1

    gateway = subnet.get('gateway_ip', potential_gateway)

    ddnew_net = Network(name=name, user_id=user_id)

    new_net.save()

    net_dic = network_to_dict(new_net)

    data = json.dumps({'network': net_dic})

    #try:

    #    sub = Subnet.objects.create(name=name, network_id=network_id,

    #                                cidr=cidr, ipversion=ipversion,

    #                                gateway=gateway)

    return HttpResponse("test world")

    #return 1

@api.api_method(http_method='GET', user_required=True, logger=log)

def get_subnet(request, offset):

    '''Placeholder'''

    try:

        subnet = Subnet.objects.get(id=offset)

    except Subnet.DoesNotExist:

        raise api.faults.ItemNotFound("Subnet not found")

    subnet_dic = subnet_to_dict(subnet)

    data = json.dumps({'subnet': subnet_dic})

    return HttpResponse(data, status=200)

@api.api_method(http_method='DELETE', user_required=True, logger=log)

def delete_subnet(request, offset):

    '''Placeholder'''

    try:

        subnet = Subnet.objects.get(id=offset)

    except Subnet.DoesNotExist:

        raise api.faults.ItemNotFound("Subnet not found")

        # Add support for 409 error, subnet in use

    subnet.delete()

    return HttpResponse(status=204)

@api.api_method(http_method='PUT', user_required=True, logger=log)

def update_network(request, offset):

    try:

        net = Network.objects.get(id=offset)

    except Network.DoesNotExist:

        raise api.faults.ItemNotFound("Network not found")

    info = utils.get_request_dict(request)

    updatable = set(["name", "driver"])

    try:

        new_vals = info["network"]

    except Keyerror:

        raise api.faults.BadRequest()

    for key, val in new_vals.iteritems():

        if key in updatable:

            setattr(net, key, val)

        else:

            raise api.faults.BadRequest()

        net.save()

    net_dic = network_to_dict(net)

    data = json.dumps({"network": net_dic})

    return HttpResponse(data)

def subnet_to_dict(subnet):

    '''Returns a dictionary containing the info of a subnet'''

    dic = dict(id=subnet.subnet_id, network_id=subnet.network.id,

               name=subnet.name, tenant_id=subnet.network.userid,

               gateway_ip=subnet.gateway, ip_version=subnet.ipversion,

               cidr=subnet.cidr, enable_dhcp=subnet.dhcp,

               dns_nameservers=subnet.dns)

               # , allocation_pools=subnet.pools,

               # host_routes=subneth.ostroutes, snf-gateway6=subnet.gateway6,

               # snf-subnet6=subnet.subnet6)

    return dic