1 package org.openecomp.vid.mso;
3 import com.fasterxml.jackson.databind.DeserializationFeature;
4 import com.fasterxml.jackson.databind.ObjectMapper;
5 import org.apache.commons.io.IOUtils;
6 import org.apache.commons.lang3.NotImplementedException;
7 import org.openecomp.portalsdk.core.logging.logic.EELFLoggerDelegate;
8 import org.openecomp.vid.mso.rest.*;
10 import java.io.InputStream;
11 import java.text.DateFormat;
12 import java.text.SimpleDateFormat;
13 import java.util.ArrayList;
14 import java.util.Date;
15 import java.util.List;
18 * Created by pickjonathan on 21/06/2017.
20 public class MsoLocalClientNew implements MsoInterface {
26 EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(MsoLocalClient.class);
29 * The Constant dateFormat.
31 final static DateFormat dateFormat = new SimpleDateFormat("HH:mm:ss:SSSS");
35 public MsoResponseWrapper createSvcInstance(RequestDetails requestDetails, String endpoint) throws Exception {
37 String methodName = "createSvcInstance ";
38 logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
39 MsoResponseWrapper w = createInstance(requestDetails, "");
44 public MsoResponseWrapper createInstance(RequestDetails request, String path) throws Exception {
45 String methodName = "createInstance";
46 logger.debug(dateFormat.format(new Date()) + "<== " + methodName + " start");
49 RestObject<String> restObjStr = new RestObject<String>();
51 String str = new String();
55 final InputStream asdcServicesFile = MsoLocalClient.class.getClassLoader().getResourceAsStream("mso_create_instance_response.json");
57 restObjStr.setStatusCode(200);
58 restObjStr.set(IOUtils.toString(asdcServicesFile));
60 MsoResponseWrapper w = MsoUtil.wrapResponse(restObjStr);
63 } catch (Exception e) {
64 logger.error(EELFLoggerDelegate.errorLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
65 logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
71 public MsoResponseWrapper createVnf(RequestDetails requestDetails, String endpoint) throws Exception {
76 public MsoResponseWrapper createNwInstance(RequestDetails requestDetails, String endpoint) throws Exception {
81 public MsoResponseWrapper createVolumeGroupInstance(RequestDetails requestDetails, String path) throws Exception {
86 public MsoResponseWrapper createVfModuleInstance(RequestDetails requestDetails, String endpoint) throws Exception {
91 public MsoResponseWrapper deleteSvcInstance(RequestDetails requestDetails, String endpoint) throws Exception {
96 public MsoResponseWrapper deleteVnf(RequestDetails requestDetails, String endpoint) throws Exception {
101 public MsoResponseWrapper deleteVfModule(RequestDetails requestDetails, String endpoint) throws Exception {
106 public MsoResponseWrapper deleteVolumeGroupInstance(RequestDetails requestDetails, String endpoint) throws Exception {
111 public MsoResponseWrapper deleteNwInstance(RequestDetails requestDetails, String endpoint) throws Exception {
116 public void getOrchestrationRequest(String t, String sourceId, String endpoint, RestObject restObject) throws Exception { }
119 public MsoResponseWrapper getOrchestrationRequestsForDashboard(String t, String sourceId, String endpoint, RestObject restObject) throws Exception {
120 String methodName = "getOrchestrationRequestsForDashboard";
121 logger.debug(dateFormat.format(new Date()) + "<== " + methodName + " start");
125 final InputStream asdcServicesFile = MsoLocalClient.class.getClassLoader().getResourceAsStream("mso_get_orchestration_requests.json");
127 restObject.setStatusCode(200);
128 restObject.set(IOUtils.toString(asdcServicesFile));
130 MsoResponseWrapper w = MsoUtil.wrapResponse(restObject);
133 } catch (Exception e) {
134 logger.error(EELFLoggerDelegate.errorLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
135 logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
140 public void activateServiceInstance(RequestDetails requestDetails, String t, String sourceId, String endpoint, RestObject<String> restObject) throws Exception{
141 String methodName = "activateServiceInstance";
142 logger.debug(dateFormat.format(new Date()) + "<== " + methodName + " start");
146 final InputStream asdcServicesFile = MsoLocalClient.class.getClassLoader().getResourceAsStream("mso_activate_service_instance.json");
148 restObject.setStatusCode(200);
149 restObject.set(IOUtils.toString(asdcServicesFile));
151 } catch (Exception e) {
152 logger.error(EELFLoggerDelegate.errorLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
153 logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
160 public MsoResponseWrapper getManualTasksByRequestId(String t, String sourceId, String endpoint, RestObject restObject) throws Exception {
161 String methodName = "getManualTasksByRequestId";
162 logger.debug(dateFormat.format(new Date()) + "<== " + methodName + " start");
166 final InputStream asdcServicesFile = MsoLocalClient.class.getClassLoader().getResourceAsStream("mso_get_manual_task_by_request_id.json");
168 restObject.setStatusCode(200);
169 restObject.set(IOUtils.toString(asdcServicesFile));
171 MsoResponseWrapper w = MsoUtil.wrapResponse(restObject);
174 } catch (Exception e) {
175 logger.error(EELFLoggerDelegate.errorLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
176 logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
182 public MsoResponseWrapper completeManualTask(RequestDetails requestDetails, String t, String sourceId, String endpoint, RestObject restObject) throws Exception {
183 String methodName = "getManualTasksByRequestId";
184 logger.debug(dateFormat.format(new Date()) + "<== " + methodName + " start");
188 final InputStream asdcServicesFile = MsoLocalClient.class.getClassLoader().getResourceAsStream("mso_complete_manual_task.json");
190 restObject.setStatusCode(200);
191 restObject.set(IOUtils.toString(asdcServicesFile));
193 MsoResponseWrapper w = MsoUtil.wrapResponse(restObject);
196 } catch (Exception e) {
197 logger.error(EELFLoggerDelegate.errorLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
198 logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
204 public MsoResponseWrapper replaceVnf(org.openecomp.vid.changeManagement.RequestDetails requestDetails, String vnf_endpoint) throws Exception {
205 throw new NotImplementedException("Function was not implemented at this point.");
211 public MsoResponseWrapper updateVnf(org.openecomp.vid.changeManagement.RequestDetails requestDetails,
212 String vnf_endpoint) {
213 // TODO Auto-generated method stub