/*
 * Copyright (c) 2013 Cisco Systems, Inc. and others.  All rights reserved.
 *
 * This program and the accompanying materials are made available under the
 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
 * and is available at http://www.eclipse.org/legal/epl-v10.html
 */
package org.opendaylight.controller.subnets.northbound;

import java.util.ArrayList;
import java.util.List;

import javax.ws.rs.DELETE;
import javax.ws.rs.GET;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.Produces;
import javax.ws.rs.QueryParam;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;

import org.codehaus.enunciate.jaxrs.ResponseCode;
import org.codehaus.enunciate.jaxrs.StatusCodes;
import org.codehaus.enunciate.jaxrs.TypeHint;
import org.opendaylight.controller.northbound.commons.RestMessages;
import org.opendaylight.controller.northbound.commons.exception.InternalServerErrorException;
import org.opendaylight.controller.northbound.commons.exception.ResourceNotFoundException;
import org.opendaylight.controller.sal.utils.ServiceHelper;
import org.opendaylight.controller.sal.utils.Status;
import org.opendaylight.controller.switchmanager.ISwitchManager;
import org.opendaylight.controller.switchmanager.SubnetConfig;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

@Path("/")
public class SubnetsNorthboundJAXRS {
    protected static final Logger logger = LoggerFactory
            .getLogger(SubnetsNorthboundJAXRS.class);

    /**
     * List all the subnets in a given container
     *
     * @param containerName container in which we want to query the subnets
     *
     * @return a List of SubnetConfig
     */
    @Path("/{containerName}")
    @GET
    @Produces( { MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
    @StatusCodes( { @ResponseCode(code = 404, condition = "The containerName passed was not found") })
    @TypeHint(SubnetConfigs.class)
    public SubnetConfigs listSubnets(
            @PathParam("containerName") String containerName) {
        ISwitchManager switchManager = null;
        switchManager = (ISwitchManager) ServiceHelper.getInstance(
                ISwitchManager.class, containerName, this);
        if (switchManager == null) {
            throw new ResourceNotFoundException(RestMessages.NOCONTAINER
                    .toString());
        }
        return new SubnetConfigs(switchManager.getSubnetsConfigList());
    }

    /**
     * List the configuration of a subnet in a given container
     *
     * @param containerName container in which we want to query the
     * subnet
     * @param subnetName of the subnet being queried
     *
     * @return a SubnetConfig
     */
    @Path("/{containerName}/{subnetName}")
    @GET
    @Produces( { MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
    @StatusCodes( {
            @ResponseCode(code = 404, condition = "The containerName passed was not found"),
            @ResponseCode(code = 404, condition = "Subnet does not exist") })
    @TypeHint(SubnetConfig.class)
    public SubnetConfig listSubnet(
            @PathParam("containerName") String containerName,
            @PathParam("subnetName") String subnetName) {
        ISwitchManager switchManager = null;
        switchManager = (ISwitchManager) ServiceHelper.getInstance(
                ISwitchManager.class, containerName, this);
        if (switchManager == null) {
            throw new ResourceNotFoundException(RestMessages.NOCONTAINER
                    .toString());
        }
        SubnetConfig res = switchManager.getSubnetConfig(subnetName);
        if (res == null) {
            throw new ResourceNotFoundException(RestMessages.NOSUBNET
                    .toString());
        } else {
            return res;
        }
    }

    /**
     * Add/Update a subnet to a container
     *
     * @param containerName container in which we want to add/update the
     * subnet
     * @param subnetName that has to be added
     * @param subnet pair default gateway IP/mask that identify the
     * subnet being added modified
     *
     */
    @Path("/{containerName}/{subnetName}")
    @POST
    @StatusCodes( {
            @ResponseCode(code = 404, condition = "The containerName passed was not found"),
            @ResponseCode(code = 404, condition = "Invalid Data passed"),
            @ResponseCode(code = 201, condition = "Subnet added/modified"),
            @ResponseCode(code = 500, condition = "Addition of subnet failed") })
    public Response addSubnet(@PathParam("containerName") String containerName,
            @PathParam("subnetName") String subnetName,
            @QueryParam("subnet") String subnet) {
        if (subnetName == null) {
            throw new ResourceNotFoundException(RestMessages.INVALIDDATA.toString());
        }
        if (subnet == null) {
            throw new ResourceNotFoundException(RestMessages.INVALIDDATA.toString());
        }
        ISwitchManager switchManager = null;
        switchManager = (ISwitchManager) ServiceHelper.getInstance(
                ISwitchManager.class, containerName, this);
        if (switchManager == null) {
            throw new ResourceNotFoundException(RestMessages.NOCONTAINER.toString());
        }

        SubnetConfig cfgObject = new SubnetConfig(subnetName, subnet,
                new ArrayList<String>(0));
        Status status = switchManager.addSubnet(cfgObject);
        if (status.isSuccess()) {
            return Response.status(Response.Status.CREATED).build();
        }
        throw new InternalServerErrorException(status.getDescription());
    }

    /**
     * Delete a subnet from a container
     *
     * @param containerName container in which we want to delete the
     * subnet by name
     * @param subnetName of the subnet to be remove.
     *
     */
    @Path("/{containerName}/{subnetName}")
    @DELETE
    @StatusCodes( {
            @ResponseCode(code = 404, condition = "The containerName passed was not found"),
            @ResponseCode(code = 500, condition = "Removal of subnet failed") })
    public Response removeSubnet(
            @PathParam("containerName") String containerName,
            @PathParam("subnetName") String subnetName) {
        if (subnetName == null) {
            throw new ResourceNotFoundException(RestMessages.INVALIDDATA
                    .toString());
        }
        ISwitchManager switchManager = null;
        switchManager = (ISwitchManager) ServiceHelper.getInstance(
                ISwitchManager.class, containerName, this);
        if (switchManager == null) {
            throw new ResourceNotFoundException(RestMessages.NOCONTAINER
                    .toString());
        }
        Status status = switchManager.removeSubnet(subnetName);
        if (status.isSuccess()) {
            return Response.status(Response.Status.OK).build();
        }
        throw new InternalServerErrorException(status.getDescription());
    }

    /* /\** */
    /*  * */
    /*  * Add or remove switch ports to a subnet */
    /*  * */
    /*  * POST subnets/green/sw */
    /*  * */
    /*  * @param model */
    /*  * @param containerName */
    /*  * @param name */
    /*  * @param subnet: the subnet name name */
    /*  * @param switchports: datapath ID/port list => xx:xx:xx:xx:xx:xx:xx:xx/a,b,c-m,r-t,y */
    /*  * @return */
    /*  *\/ */
    /* @RequestMapping(value = "/{containerName}/{name}", method = RequestMethod.POST) */
    /* public View addSwitchports(Map<String, Object> model, */
    /*         @PathVariable(value = "containerName") String containerName, */
    /*         @PathVariable(value = "name") String name, */
    /*         @RequestParam(value = "nodeports") String nodePorts, */
    /*         @RequestParam(value = "action") String action) { */

    /*     checkDefaultDisabled(containerName); */

    /*     ISwitchManager switchManager = null; */
    /*     try { */
    /*         BundleContext bCtx = FrameworkUtil.getBundle(this.getClass()) */
    /*                 .getBundleContext(); */

    /*         ServiceReference[] services = bCtx.getServiceReferences( */
    /*                 ISwitchManager.class.getName(), "(containerName=" */
    /*                         + containerName + ")"); */

    /*         if (services != null) { */
    /*             switchManager = (ISwitchManager) bCtx.getService(services[0]); */
    /*             logger.debug("Switch manager reference is:" + switchManager); */
    /*         } */
    /*     } catch (Exception e) { */
    /*         logger.error("Switch Manager reference is NULL"); */
    /*     } */

    /*     checkContainerExists(switchManager); */

    /*     String ret; */
    /*     if (action.equals("add")) { */
    /*         ret = switchManager.addPortsToSubnet(name, nodePorts); */
    /*     } else if (action.equals("remove")) { */
    /*         ret = switchManager.removePortsFromSubnet(name, nodePorts); */
    /*     } else { */
    /*         throw new UnsupportedMediaTypeException(RestMessages.UNKNOWNACTION */
    /*                 .toString() */
    /*                 + ": " + action); */
    /*     } */

    /*     return returnViewOrThrowConflicEx(model, ret); */
    /* } */
}