/*
 * 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 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.Context;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
import javax.ws.rs.core.SecurityContext;

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.northbound.commons.exception.UnauthorizedException;
import org.opendaylight.controller.northbound.commons.utils.NorthboundUtils;
import org.opendaylight.controller.sal.authorization.Privilege;
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);

    private String username;

    @Context
    public void setSecurityContext(SecurityContext context) {
        username = context.getUserPrincipal().getName();
    }

    protected String getUserName() {
        return username;
    }

    /**
     * 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) {
        if (!NorthboundUtils.isAuthorized(
                getUserName(), containerName, Privilege.READ, this)) {
            throw new UnauthorizedException(
                    "User is not authorized to perform this operation on container "
                            + 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) {

        if (!NorthboundUtils.isAuthorized(
                getUserName(), containerName, Privilege.READ, this)) {
            throw new UnauthorizedException(
                    "User is not authorized to perform this operation on container "
                            + containerName);
        }
        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 (!NorthboundUtils.isAuthorized(
                getUserName(), containerName, Privilege.WRITE, this)) {
            throw new UnauthorizedException(
                    "User is not authorized to perform this operation on container "
                            + containerName);
        }
        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());
        }

        if (!NorthboundUtils.isAuthorized(
                getUserName(), containerName, Privilege.WRITE, this)) {
            throw new UnauthorizedException(
                    "User is not authorized to perform this operation on container "
                            + containerName);
        }

        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); }
     */
}