opendaylight/northbound/networkconfiguration/neutron/src/main/java/org/opendaylight/controller/networkconfig/neutron/northbound/NeutronLoadBalancerPoolMembersNorthbound.java

   1 /*
   2  * Copyright (C) 2014 Red Hat, Inc.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8
   9 package org.opendaylight.controller.networkconfig.neutron.northbound;
  10
  11 import org.codehaus.enunciate.jaxrs.ResponseCode;
  12 import org.codehaus.enunciate.jaxrs.StatusCodes;
  13 import org.opendaylight.controller.networkconfig.neutron.INeutronLoadBalancerPoolMemberAware;
  14 import org.opendaylight.controller.networkconfig.neutron.INeutronLoadBalancerPoolMemberCRUD;
  15 import org.opendaylight.controller.networkconfig.neutron.NeutronCRUDInterfaces;
  16 import org.opendaylight.controller.networkconfig.neutron.NeutronLoadBalancerPoolMember;
  17 import org.opendaylight.controller.northbound.commons.RestMessages;
  18 import org.opendaylight.controller.northbound.commons.exception.BadRequestException;
  19 import org.opendaylight.controller.northbound.commons.exception.ServiceUnavailableException;
  20 import org.opendaylight.controller.sal.utils.ServiceHelper;
  21
  22 import javax.ws.rs.Consumes;
  23 import javax.ws.rs.GET;
  24 import javax.ws.rs.PUT;
  25 import javax.ws.rs.Path;
  26 import javax.ws.rs.Produces;
  27 import javax.ws.rs.QueryParam;
  28 import javax.ws.rs.core.MediaType;
  29 import javax.ws.rs.core.Response;
  30 import java.util.ArrayList;
  31 import java.util.HashMap;
  32 import java.util.Iterator;
  33 import java.util.List;
  34
  35
  36 @Path("/pools/{loadBalancerPoolID}/members")
  37 public class NeutronLoadBalancerPoolMembersNorthbound {
  38
  39     private NeutronLoadBalancerPoolMember extractFields(NeutronLoadBalancerPoolMember o, List<String> fields) {
  40         return o.extractFields(fields);
  41     }
  42 /**
  43  * Returns a list of all LoadBalancerPool
  44  */
  45 @GET
  46 @Produces({MediaType.APPLICATION_JSON})
  47 @StatusCodes({
  48         @ResponseCode(code = 200, condition = "Operation successful"),
  49         @ResponseCode(code = 401, condition = "Unauthorized"),
  50         @ResponseCode(code = 501, condition = "Not Implemented")})
  51
  52 public Response listMembers(
  53         // return fields
  54         @QueryParam("fields") List<String> fields,
  55         // OpenStack LoadBalancerPool attributes
  56         @QueryParam("id") String queryLoadBalancerPoolMemberID,
  57         @QueryParam("tenant_id") String queryLoadBalancerPoolMemberTenantID,
  58         @QueryParam("address") String queryLoadBalancerPoolMemberAddress,
  59         @QueryParam("protocol_port") String queryLoadBalancerPoolMemberProtoPort,
  60         @QueryParam("admin_state_up") String queryLoadBalancerPoolMemberAdminStateUp,
  61         @QueryParam("weight") String queryLoadBalancerPoolMemberWeight,
  62         @QueryParam("subnet_id") String queryLoadBalancerPoolMemberSubnetID,
  63         @QueryParam("status") String queryLoadBalancerPoolMemberStatus,
  64
  65         // pagination
  66         @QueryParam("limit") String limit,
  67         @QueryParam("marker") String marker,
  68         @QueryParam("page_reverse") String pageReverse
  69         // sorting not supported
  70 ) {
  71     INeutronLoadBalancerPoolMemberCRUD loadBalancerPoolMemberInterface = NeutronCRUDInterfaces
  72             .getINeutronLoadBalancerPoolMemberCRUD(this);
  73     if (loadBalancerPoolMemberInterface == null) {
  74         throw new ServiceUnavailableException("LoadBalancerPool CRUD Interface "
  75                 + RestMessages.SERVICEUNAVAILABLE.toString());
  76     }
  77     List<NeutronLoadBalancerPoolMember> allLoadBalancerPoolMembers = loadBalancerPoolMemberInterface
  78             .getAllNeutronLoadBalancerPoolMembers();
  79     List<NeutronLoadBalancerPoolMember> ans = new ArrayList<NeutronLoadBalancerPoolMember>();
  80     Iterator<NeutronLoadBalancerPoolMember> i = allLoadBalancerPoolMembers.iterator();
  81     while (i.hasNext()) {
  82         NeutronLoadBalancerPoolMember nsg = i.next();
  83         if ((queryLoadBalancerPoolMemberID == null ||
  84                 queryLoadBalancerPoolMemberID.equals(nsg.getPoolMemberID())) &&
  85                 (queryLoadBalancerPoolMemberTenantID == null ||
  86                         queryLoadBalancerPoolMemberTenantID.equals(nsg.getPoolMemberTenantID())) &&
  87                 (queryLoadBalancerPoolMemberAddress == null ||
  88                         queryLoadBalancerPoolMemberAddress.equals(nsg.getPoolMemberAddress())) &&
  89                 (queryLoadBalancerPoolMemberAdminStateUp == null ||
  90                         queryLoadBalancerPoolMemberAdminStateUp.equals(nsg.getPoolMemberAdminStateIsUp())) &&
  91                 (queryLoadBalancerPoolMemberWeight == null ||
  92                         queryLoadBalancerPoolMemberWeight.equals(nsg.getPoolMemberWeight())) &&
  93                 (queryLoadBalancerPoolMemberSubnetID == null ||
  94                         queryLoadBalancerPoolMemberSubnetID.equals(nsg.getPoolMemberSubnetID())) &&
  95                 (queryLoadBalancerPoolMemberStatus == null ||
  96                         queryLoadBalancerPoolMemberStatus.equals(nsg.getPoolMemberStatus()))) {
  97             if (fields.size() > 0) {
  98                 ans.add(extractFields(nsg, fields));
  99             } else {
 100                 ans.add(nsg);
 101             }
 102         }
 103     }
 104     return Response.status(200).entity(
 105             new INeutronLoadBalancerPoolMemberRequest(ans)).build();
 106 }
 107
 108 /**
 109  * Adds a Member to an LBaaS Pool member
 110  */
 111 @Path("/pools/{loadBalancerPoolID}/members")
 112 @PUT
 113 @Produces({MediaType.APPLICATION_JSON})
 114 @Consumes({MediaType.APPLICATION_JSON})
 115 @StatusCodes({
 116         @ResponseCode(code = 200, condition = "Operation successful"),
 117         @ResponseCode(code = 401, condition = "Unauthorized"),
 118         @ResponseCode(code = 404, condition = "Not Found"),
 119         @ResponseCode(code = 501, condition = "Not Implemented")})
 120 public Response createLoadBalancerPoolMember(  INeutronLoadBalancerPoolMemberRequest input) {
 121
 122     INeutronLoadBalancerPoolMemberCRUD loadBalancerPoolMemberInterface = NeutronCRUDInterfaces.getINeutronLoadBalancerPoolMemberCRUD(
 123             this);
 124     if (loadBalancerPoolMemberInterface == null) {
 125         throw new ServiceUnavailableException("LoadBalancerPoolMember CRUD Interface "
 126                 + RestMessages.SERVICEUNAVAILABLE.toString());
 127     }
 128     if (input.isSingleton()) {
 129         NeutronLoadBalancerPoolMember singleton = input.getSingleton();
 130
 131         /*
 132          *  Verify that the LoadBalancerPoolMember doesn't already exist.
 133          */
 134         if (loadBalancerPoolMemberInterface.neutronLoadBalancerPoolMemberExists(
 135                 singleton.getPoolMemberID())) {
 136             throw new BadRequestException("LoadBalancerPoolMember UUID already exists");
 137         }
 138         loadBalancerPoolMemberInterface.addNeutronLoadBalancerPoolMember(singleton);
 139
 140         Object[] instances = ServiceHelper.getGlobalInstances(INeutronLoadBalancerPoolMemberAware.class, this, null);
 141         if (instances != null) {
 142             for (Object instance : instances) {
 143                 INeutronLoadBalancerPoolMemberAware service = (INeutronLoadBalancerPoolMemberAware) instance;
 144                 int status = service.canCreateNeutronLoadBalancerPoolMember(singleton);
 145                 if (status < 200 || status > 299) {
 146                     return Response.status(status).build();
 147                 }
 148             }
 149         }
 150         loadBalancerPoolMemberInterface.addNeutronLoadBalancerPoolMember(singleton);
 151         if (instances != null) {
 152             for (Object instance : instances) {
 153                 INeutronLoadBalancerPoolMemberAware service = (INeutronLoadBalancerPoolMemberAware) instance;
 154                 service.neutronLoadBalancerPoolMemberCreated(singleton);
 155             }
 156         }
 157     } else {
 158         List<NeutronLoadBalancerPoolMember> bulk = input.getBulk();
 159         Iterator<NeutronLoadBalancerPoolMember> i = bulk.iterator();
 160         HashMap<String, NeutronLoadBalancerPoolMember> testMap = new HashMap<String, NeutronLoadBalancerPoolMember>();
 161         Object[] instances = ServiceHelper.getGlobalInstances(INeutronLoadBalancerPoolMemberAware.class, this, null);
 162         while (i.hasNext()) {
 163             NeutronLoadBalancerPoolMember test = i.next();
 164
 165             /*
 166              *  Verify that the firewall doesn't already exist
 167              */
 168
 169             if (loadBalancerPoolMemberInterface.neutronLoadBalancerPoolMemberExists(
 170                     test.getPoolMemberID())) {
 171                 throw new BadRequestException("Load Balancer PoolMember UUID already is already created");
 172             }
 173             if (testMap.containsKey(test.getPoolMemberID())) {
 174                 throw new BadRequestException("Load Balancer PoolMember UUID already exists");
 175             }
 176             if (instances != null) {
 177                 for (Object instance : instances) {
 178                     INeutronLoadBalancerPoolMemberAware service = (INeutronLoadBalancerPoolMemberAware) instance;
 179                     int status = service.canCreateNeutronLoadBalancerPoolMember(test);
 180                     if (status < 200 || status > 299) {
 181                         return Response.status(status).build();
 182                     }
 183                 }
 184             }
 185         }
 186         /*
 187          * now, each element of the bulk request can be added to the cache
 188          */
 189         i = bulk.iterator();
 190         while (i.hasNext()) {
 191             NeutronLoadBalancerPoolMember test = i.next();
 192             loadBalancerPoolMemberInterface.addNeutronLoadBalancerPoolMember(test);
 193             if (instances != null) {
 194                 for (Object instance : instances) {
 195                     INeutronLoadBalancerPoolMemberAware service = (INeutronLoadBalancerPoolMemberAware) instance;
 196                     service.neutronLoadBalancerPoolMemberCreated(test);
 197                 }
 198             }
 199         }
 200     }
 201     return Response.status(201).entity(input).build();
 202 }
 203 }