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

from synnefo.logic import networks

import ipaddr

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_subnet(request, offset)

    elif request.method == 'DELETE':

        return delete_network(request, offset)

    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):

    '''List all subnets of a user'''

    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):

    '''Create a subnet'''

    user_id = request.user_uniq

    try:

        dic = utils.get_request_dict(request)

        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 not in [4, 6]:

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

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

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

    # FIX ME, SNF:gateway6 vs gateway6

    gateway6 = subnet.get('SNF:gateway6', None)

    subnet6 = subnet.get('SNF:subnet6', None)

    # Returns the first available ip in the subnet

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

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

    networks.validate_network_params(subnet, gateway, subnet6, gateway6)

    try:

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

                                    cidr=cidr, ipversion=ipversion,

                                    gateway=gateway, gateway6=gateway6,

                                    subnet6=subnet6)

    # FIX ME

    except:

        print "Error"

    return HttpResponse("test")

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

def get_subnet(request, offset):

    '''Show info of a specific subnet'''

    try:

        subnet = Subnet.objects.get(subnet_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):

    '''Delete a subnet'''

    try:

        subnet = Subnet.objects.get(subnet_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)

def subnet_to_dict(subnet):

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

    # FIX ME, allocation pools

    dic = dict({'id': subnet.sunbet_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': [], 'host_routes': [],

                'allocation_pools': [], 'SNF:gateway6': subnet.gateway6,

                'SNF:subnet6': subnet.subnet6})

#    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=[], allocation_pools=[], host_routes=[],

#               snf-gateway6=subnet.gateway6, snf-subnet6=subnet.subnet6)

    return dic