1 files changed, 195 insertions, 0 deletions
diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/com/nokia/vfcadaptor/vnfmdriver/controller/VnfmDriverController.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/com/nokia/vfcadaptor/vnfmdriver/controller/VnfmDriverController.java
new file mode 100644
index 00000000..ba2641b5
--- /dev/null
+++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/com/nokia/vfcadaptor/vnfmdriver/controller/VnfmDriverController.java
@@ -0,0 +1,195 @@
+/*
+ * Copyright 2016-2017, Nokia Corporation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.nokia.vfcadaptor.vnfmdriver.controller;
+
+import java.io.IOException;
+
+import javax.servlet.http.HttpServletResponse;
+
+import org.apache.http.HttpStatus;
+import org.apache.log4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.MediaType;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+import com.google.gson.Gson;
+import com.nokia.vfcadaptor.exception.VnfmDriverException;
+import com.nokia.vfcadaptor.vnfmdriver.bo.HealVnfRequest;
+import com.nokia.vfcadaptor.vnfmdriver.bo.HealVnfResponse;
+import com.nokia.vfcadaptor.vnfmdriver.bo.InstantiateVnfRequest;
+import com.nokia.vfcadaptor.vnfmdriver.bo.InstantiateVnfResponse;
+import com.nokia.vfcadaptor.vnfmdriver.bo.OperStatusVnfResponse;
+import com.nokia.vfcadaptor.vnfmdriver.bo.QueryVnfResponse;
+import com.nokia.vfcadaptor.vnfmdriver.bo.ScaleVnfRequest;
+import com.nokia.vfcadaptor.vnfmdriver.bo.ScaleVnfResponse;
+import com.nokia.vfcadaptor.vnfmdriver.bo.TerminateVnfRequest;
+import com.nokia.vfcadaptor.vnfmdriver.bo.TerminateVnfResponse;
+import com.nokia.vfcadaptor.vnfmdriver.inf.VnfmDriverMgmrInf;
+
+@Controller
+@RequestMapping(value = "/nokiavnfm/v1")
+public class VnfmDriverController {
+	private Logger logger = Logger.getLogger(VnfmDriverController.class);
+	
+	@Autowired
+	private VnfmDriverMgmrInf vnfmDriverMgmr;
+	
+	private Gson gson = new Gson();
+	
+	@RequestMapping(value = "/{vnfmId}/vnfs", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE, consumes = MediaType.APPLICATION_JSON_VALUE)
+    @ResponseBody
+    public InstantiateVnfResponse instantiateVnf(@RequestBody InstantiateVnfRequest request, @PathVariable("vnfmId") String vnfmId, HttpServletResponse httpResponse)
+    {
+		String jsonString = gson.toJson(request);
+		logger.info("instantiateVnf request: vnfmId = " + vnfmId + ", bodyMessage is " + jsonString);
+		
+		InstantiateVnfResponse response = vnfmDriverMgmr.instantiateVnf(request, vnfmId);
+		
+		httpResponse.setStatus(HttpStatus.SC_CREATED);
+		
+		return response;
+    }
+	
+	@RequestMapping(value = "/{vnfmId}/vnfs/{vnfInstanceId}/terminate", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE, consumes = MediaType.APPLICATION_JSON_VALUE)
+    @ResponseBody
+    public TerminateVnfResponse terminateVnf(@RequestBody TerminateVnfRequest request, @PathVariable("vnfmId") String vnfmId, @PathVariable("vnfInstanceId") String vnfInstanceId, HttpServletResponse httpResponse)
+    {
+		String jsonString = gson.toJson(request);
+		logger.info("terminateVnf request: vnfmId = " + vnfmId + ", vnfInstanceId = " + vnfInstanceId + ", bodyMessage is " + jsonString);
+		
+		try {
+			TerminateVnfResponse response = vnfmDriverMgmr.terminateVnf(request, vnfmId, vnfInstanceId);
+			httpResponse.setStatus(HttpStatus.SC_CREATED);
+			return response;
+		}
+		catch(VnfmDriverException e)
+		{
+			try {
+				httpResponse.setStatus(HttpStatus.SC_BAD_REQUEST);
+				httpResponse.sendError(e.getHttpStatus(), e.getMessage());
+			} catch (IOException e1) {
+				
+			}
+		}
+		
+		return null;
+    }
+	
+	
+	@RequestMapping(value = "/{vnfmId}/vnfs/{vnfInstanceId}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
+    @ResponseBody
+    public QueryVnfResponse queryVnf(@PathVariable("vnfmId") String vnfmId, @PathVariable("vnfInstanceId") String vnfInstanceId, HttpServletResponse httpResponse)
+    {
+		logger.info("queryVnf request: vnfmId = " + vnfmId + ", vnfInstanceId = " + vnfInstanceId);
+		
+		try {
+			QueryVnfResponse response = vnfmDriverMgmr.queryVnf(vnfmId, vnfInstanceId);
+			httpResponse.setStatus(HttpStatus.SC_CREATED);
+			return response;
+		}
+		catch(VnfmDriverException e)
+		{
+			try {
+				httpResponse.setStatus(HttpStatus.SC_BAD_REQUEST);
+				httpResponse.sendError(e.getHttpStatus(), e.getMessage());
+			} catch (IOException e1) {
+				
+			}
+		}
+		
+		return null;
+    }
+	@RequestMapping(value = "/{vnfmId}/jobs/{jobId}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
+    @ResponseBody
+    public OperStatusVnfResponse getOperStatus(@PathVariable("vnfmId") String vnfmId,@PathVariable("jobId") String jobId, HttpServletResponse httpResponse)
+    {
+		logger.info("getOperStatus request: vnfmId = " + vnfmId + ", jobId = " + jobId);
+		
+		try {
+			OperStatusVnfResponse response = vnfmDriverMgmr.getOperStatus(vnfmId, jobId);
+			httpResponse.setStatus(HttpStatus.SC_CREATED);
+			return response;
+		}
+		catch(VnfmDriverException e)
+		{
+			try {
+				httpResponse.sendError(e.getHttpStatus(), e.getMessage());
+			} catch (IOException e1) {
+				
+			}
+		}
+		
+		return null;
+    }
+	
+	
+	@RequestMapping(value = "/{vnfmId}/vnfs/{vnfInstanceId}/scale", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE, consumes = MediaType.APPLICATION_JSON_VALUE)
+    @ResponseBody
+    public ScaleVnfResponse scaleVnf(@RequestBody ScaleVnfRequest request, @PathVariable("vnfmId") String vnfmId, @PathVariable("vnfInstanceId") String vnfInstanceId, HttpServletResponse httpResponse)
+    {
+		String jsonString = gson.toJson(request);
+		logger.info("scaleVnf request: vnfmId = " + vnfmId + ", vnfInstanceId = " + vnfInstanceId + ", bodyMessage is " + jsonString);
+		
+		try {
+			ScaleVnfResponse response = vnfmDriverMgmr.scaleVnf(request, vnfmId, vnfInstanceId);
+			httpResponse.setStatus(HttpStatus.SC_CREATED);
+			return response;
+		}
+		catch(VnfmDriverException e)
+		{
+			try {
+				httpResponse.sendError(e.getHttpStatus(), e.getMessage());
+			} catch (IOException e1) {
+				
+			}
+		}
+		
+		return null;
+    }
+	
+	
+	@RequestMapping(value = "/{vnfmId}/vnfs/{vnfInstanceId}/heal", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE, consumes = MediaType.APPLICATION_JSON_VALUE)
+    @ResponseBody
+    public HealVnfResponse healVnf(@RequestBody HealVnfRequest request, @PathVariable("vnfmId") String vnfmId, @PathVariable("vnfInstanceId") String vnfInstanceId, HttpServletResponse httpResponse)
+    {
+		String jsonString = gson.toJson(request);
+		logger.info("healVnf request: vnfmId = " + vnfmId + ", vnfInstanceId = " + vnfInstanceId + ", bodyMessage is " + jsonString);
+		
+		try {
+			HealVnfResponse response = vnfmDriverMgmr.healVnf(request, vnfmId, vnfInstanceId);
+			httpResponse.setStatus(HttpStatus.SC_CREATED);
+			return response;
+		}
+		catch(VnfmDriverException e)
+		{
+			try {
+				httpResponse.sendError(e.getHttpStatus(), e.getMessage());
+			} catch (IOException e1) {
+				
+			}
+		}
+		
+		return null;
+    }
+
+
+}