nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/vnfmdriver/controller/VnfmDriverController.java

   1 /*
   2  * Copyright 2016-2017, Nokia Corporation
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  *     http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16
  17 package org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.controller;
  18
  19 import java.io.IOException;
  20
  21 import javax.servlet.http.HttpServletResponse;
  22
  23 import org.apache.commons.io.IOUtils;
  24 import org.apache.http.HttpStatus;
  25 import org.onap.vfc.nfvo.driver.vnfm.svnfm.exception.VnfmDriverException;
  26 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.HealVnfRequest;
  27 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.HealVnfResponse;
  28 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.InstantiateVnfRequest;
  29 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.InstantiateVnfResponse;
  30 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.OperStatusVnfResponse;
  31 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.QueryVnfResponse;
  32 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.ScaleVnfRequest;
  33 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.ScaleVnfResponse;
  34 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.TerminateVnfRequest;
  35 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.TerminateVnfResponse;
  36 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.inf.VnfmDriverMgmrInf;
  37 import org.slf4j.Logger;
  38 import org.slf4j.LoggerFactory;
  39 import org.springframework.beans.factory.annotation.Autowired;
  40 import org.springframework.http.MediaType;
  41 import org.springframework.stereotype.Controller;
  42 import org.springframework.web.bind.annotation.PathVariable;
  43 import org.springframework.web.bind.annotation.RequestBody;
  44 import org.springframework.web.bind.annotation.RequestMapping;
  45 import org.springframework.web.bind.annotation.RequestMethod;
  46 import org.springframework.web.bind.annotation.ResponseBody;
  47
  48 import com.google.gson.Gson;
  49
  50 @Controller
  51 @RequestMapping(value = "/api/nokiavnfmdriver/v1")
  52 public class VnfmDriverController {
  53         private static final Logger logger = LoggerFactory.getLogger(VnfmDriverController.class);
  54
  55         @Autowired
  56         private VnfmDriverMgmrInf vnfmDriverMgmr;
  57
  58         private Gson gson = new Gson();
  59
  60         @RequestMapping(value = "/swagger.json", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
  61         @ResponseBody
  62         public String apidoc() throws IOException {
  63         ClassLoader classLoader = getClass().getClassLoader();
  64         return IOUtils.toString(classLoader.getResourceAsStream("swagger.json"));
  65     }
  66
  67         @RequestMapping(value = "/{vnfmId}/vnfs", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE, consumes = MediaType.APPLICATION_JSON_VALUE)
  68     @ResponseBody
  69     public InstantiateVnfResponse instantiateVnf(@RequestBody InstantiateVnfRequest request, @PathVariable("vnfmId") String vnfmId, HttpServletResponse httpResponse)
  70     {
  71                 String jsonString = gson.toJson(request);
  72                 logger.info("instantiateVnf request: vnfmId = " + vnfmId + ", bodyMessage is " + jsonString);
  73
  74                 InstantiateVnfResponse response = vnfmDriverMgmr.instantiateVnf(request, vnfmId);
  75
  76                 logger.info("VnfmDriverController --> instantiateVnf response is " + gson.toJson(response));
  77
  78                 httpResponse.setStatus(HttpStatus.SC_CREATED);
  79
  80                 return response;
  81     }
  82
  83         @RequestMapping(value = "/{vnfmId}/vnfs/{vnfInstanceId}/terminate", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE, consumes = MediaType.APPLICATION_JSON_VALUE)
  84     @ResponseBody
  85     public TerminateVnfResponse terminateVnf(@RequestBody TerminateVnfRequest request, @PathVariable("vnfmId") String vnfmId, @PathVariable("vnfInstanceId") String vnfInstanceId, HttpServletResponse httpResponse)
  86     {
  87                 String jsonString = gson.toJson(request);
  88                 logger.info("terminateVnf request: vnfmId = " + vnfmId + ", vnfInstanceId = " + vnfInstanceId + ", bodyMessage is " + jsonString);
  89
  90                 try {
  91                         TerminateVnfResponse response = vnfmDriverMgmr.terminateVnf(request, vnfmId, vnfInstanceId);
  92                         httpResponse.setStatus(HttpStatus.SC_CREATED);
  93
  94                         logger.info("VnfmDriverController --> terminateVnf response is " + gson.toJson(response));
  95                         return response;
  96                 }
  97                 catch(VnfmDriverException e)
  98                 {
  99                         processControllerException(httpResponse, e);
 100                 }
 101
 102                 return null;
 103     }
 104
 105
 106         @RequestMapping(value = "/{vnfmId}/vnfs/{vnfInstanceId}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
 107     @ResponseBody
 108     public QueryVnfResponse queryVnf(@PathVariable("vnfmId") String vnfmId, @PathVariable("vnfInstanceId") String vnfInstanceId, HttpServletResponse httpResponse)
 109     {
 110                 logger.info("queryVnf request: vnfmId = " + vnfmId + ", vnfInstanceId = " + vnfInstanceId);
 111
 112                 try {
 113                         QueryVnfResponse response = vnfmDriverMgmr.queryVnf(vnfmId, vnfInstanceId);
 114                         httpResponse.setStatus(HttpStatus.SC_CREATED);
 115                         logger.info("VnfmDriverController --> queryVnf response is " + gson.toJson(response));
 116                         return response;
 117                 }
 118                 catch(VnfmDriverException e)
 119                 {
 120                         processControllerException(httpResponse, e);
 121                 }
 122
 123                 return null;
 124     }
 125         @RequestMapping(value = "/{vnfmId}/jobs/{jobId}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
 126     @ResponseBody
 127     public OperStatusVnfResponse getOperStatus(@PathVariable("vnfmId") String vnfmId,@PathVariable("jobId") String jobId, HttpServletResponse httpResponse)
 128     {
 129                 logger.info("getOperStatus request: vnfmId = " + vnfmId + ", jobId = " + jobId);
 130
 131                 try {
 132                         OperStatusVnfResponse response = vnfmDriverMgmr.getOperStatus(vnfmId, jobId);
 133                         httpResponse.setStatus(HttpStatus.SC_CREATED);
 134
 135                         logger.info("VnfmDriverController --> getOperStatus response is " + gson.toJson(response));
 136                         return response;
 137                 }
 138                 catch(VnfmDriverException e)
 139                 {
 140                         processControllerException(httpResponse, e);
 141                 }
 142
 143                 return null;
 144     }
 145
 146
 147         @RequestMapping(value = "/{vnfmId}/vnfs/{vnfInstanceId}/scale", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE, consumes = MediaType.APPLICATION_JSON_VALUE)
 148     @ResponseBody
 149     public ScaleVnfResponse scaleVnf(@RequestBody ScaleVnfRequest request, @PathVariable("vnfmId") String vnfmId, @PathVariable("vnfInstanceId") String vnfInstanceId, HttpServletResponse httpResponse)
 150     {
 151                 String jsonString = gson.toJson(request);
 152                 logger.info("scaleVnf request: vnfmId = " + vnfmId + ", vnfInstanceId = " + vnfInstanceId + ", bodyMessage is " + jsonString);
 153
 154                 try {
 155                         ScaleVnfResponse response = vnfmDriverMgmr.scaleVnf(request, vnfmId, vnfInstanceId);
 156                         httpResponse.setStatus(HttpStatus.SC_CREATED);
 157                         logger.info("VnfmDriverController --> scaleVnf response is " + gson.toJson(response));
 158                         return response;
 159                 }
 160                 catch(VnfmDriverException e)
 161                 {
 162                         processControllerException(httpResponse, e);
 163                 }
 164
 165                 return null;
 166     }
 167
 168
 169         @RequestMapping(value = "/{vnfmId}/vnfs/{vnfInstanceId}/heal", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE, consumes = MediaType.APPLICATION_JSON_VALUE)
 170     @ResponseBody
 171     public HealVnfResponse healVnf(@RequestBody HealVnfRequest request, @PathVariable("vnfmId") String vnfmId, @PathVariable("vnfInstanceId") String vnfInstanceId, HttpServletResponse httpResponse)
 172     {
 173                 String jsonString = gson.toJson(request);
 174                 logger.info("healVnf request: vnfmId = " + vnfmId + ", vnfInstanceId = " + vnfInstanceId + ", bodyMessage is " + jsonString);
 175
 176                 try {
 177                         HealVnfResponse response = vnfmDriverMgmr.healVnf(request, vnfmId, vnfInstanceId);
 178                         httpResponse.setStatus(HttpStatus.SC_CREATED);
 179                         logger.info("VnfmDriverController --> healVnf response is " + gson.toJson(response));
 180                         return response;
 181                 }
 182                 catch(VnfmDriverException e)
 183                 {
 184                         processControllerException(httpResponse, e);
 185                 }
 186
 187                 return null;
 188     }
 189
 190         private void processControllerException(HttpServletResponse httpResponse, VnfmDriverException e) {
 191                 try {
 192                         logger.error(" VnfmDriverController --> processControllerException", e);
 193                         httpResponse.setStatus(HttpStatus.SC_BAD_REQUEST);
 194                         httpResponse.sendError(e.getHttpStatus(), e.getMessage());
 195                 } catch (IOException e1) {
 196                         logger.error("VnfmDriverController --> processControllerException error to sendError ", e1);
 197                 }
 198         }
 199 }