2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
6 * Copyright (C) 2017 Huawei Technologies Co., Ltd. All rights reserved.
7 * ================================================================================
8 * Licensed under the Apache License, Version 2.0 (the "License");
9 * you may not use this file except in compliance with the License.
10 * You may obtain a copy of the License at
12 * http://www.apache.org/licenses/LICENSE-2.0
14 * Unless required by applicable law or agreed to in writing, software
15 * distributed under the License is distributed on an "AS IS" BASIS,
16 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17 * See the License for the specific language governing permissions and
18 * limitations under the License.
19 * ============LICENSE_END=========================================================
21 package org.openecomp.mso.apihandlerinfra;
23 import java.text.SimpleDateFormat;
24 import java.util.ArrayList;
25 import java.util.List;
28 import javax.ws.rs.Consumes;
29 import javax.ws.rs.GET;
30 import javax.ws.rs.POST;
31 import javax.ws.rs.Path;
32 import javax.ws.rs.PathParam;
33 import javax.ws.rs.Produces;
34 import javax.ws.rs.core.Context;
35 import javax.ws.rs.core.MediaType;
36 import javax.ws.rs.core.MultivaluedMap;
37 import javax.ws.rs.core.Response;
38 import javax.ws.rs.core.UriInfo;
40 import org.apache.http.HttpStatus;
41 import org.codehaus.jackson.map.ObjectMapper;
42 import org.openecomp.mso.apihandler.common.ErrorNumbers;
43 import org.openecomp.mso.apihandlerinfra.e2eserviceinstancebeans.E2ERequest;
44 import org.openecomp.mso.apihandlerinfra.e2eserviceinstancebeans.GetE2EServiceInstanceResponse;
45 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.GetOrchestrationListResponse;
46 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.GetOrchestrationResponse;
47 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.InstanceReferences;
48 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.Request;
49 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.RequestDetails;
50 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.RequestList;
51 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.RequestStatus;
52 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.ServiceInstancesRequest;
53 import org.openecomp.mso.logger.MessageEnum;
54 import org.openecomp.mso.logger.MsoAlarmLogger;
55 import org.openecomp.mso.logger.MsoLogger;
56 import org.openecomp.mso.requestsdb.InfraActiveRequests;
57 import org.openecomp.mso.requestsdb.OperationStatus;
58 import org.openecomp.mso.requestsdb.RequestsDatabase;
60 import com.wordnik.swagger.annotations.Api;
61 import com.wordnik.swagger.annotations.ApiOperation;
64 @Api(value = "/", description = "API Requests for Orchestration requests")
65 public class OrchestrationRequests {
67 public final static String MSO_PROP_APIHANDLER_INFRA = "MSO_PROP_APIHANDLER_INFRA";
69 private static MsoLogger msoLogger = MsoLogger.getMsoLogger(MsoLogger.Catalog.APIH);
71 private static MsoAlarmLogger alarmLogger = new MsoAlarmLogger();
73 private RequestsDatabase requestsDB = RequestsDatabase.getInstance();
78 public OrchestrationRequests() {
79 // TODO Auto-generated constructor stub
83 @Path("orchestrationRequests/{version:[vV][2-5]}/{requestId}")
84 @ApiOperation(value = "Find Orchestrated Requests for a given requestId", response = Response.class)
85 @Produces(MediaType.APPLICATION_JSON)
86 public Response getOrchestrationRequest(@PathParam("requestId") String requestId,
87 @PathParam("version") String version) {
89 GetOrchestrationResponse orchestrationResponse = new GetOrchestrationResponse();
91 MsoRequest msoRequest = new MsoRequest(requestId);
93 long startTime = System.currentTimeMillis();
95 InfraActiveRequests requestDB = null;
98 requestDB = requestsDB.getRequestFromInfraActive(requestId);
100 } catch (Exception e) {
101 msoLogger.error(MessageEnum.APIH_DB_ACCESS_EXC, MSO_PROP_APIHANDLER_INFRA, "", "",
102 MsoLogger.ErrorCode.AvailabilityError,
103 "Exception while communciate with Request DB - Infra Request Lookup", e);
104 msoRequest.setStatus(org.openecomp.mso.apihandlerinfra.vnfbeans.RequestStatusType.FAILED);
105 Response response = msoRequest.buildServiceErrorResponse(HttpStatus.SC_NOT_FOUND,
106 MsoException.ServiceException, e.getMessage(), ErrorNumbers.NO_COMMUNICATION_TO_REQUESTS_DB, null);
107 alarmLogger.sendAlarm("MsoDatabaseAccessError", MsoAlarmLogger.CRITICAL,
108 Messages.errors.get(ErrorNumbers.NO_COMMUNICATION_TO_REQUESTS_DB));
109 msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DBAccessError,
110 "Exception while communciate with Request DB");
111 msoLogger.debug("End of the transaction, the final response is: " + (String) response.getEntity());
116 if (requestDB == null) {
117 Response resp = msoRequest.buildServiceErrorResponse(HttpStatus.SC_NO_CONTENT,
118 MsoException.ServiceException, "Orchestration RequestId " + requestId + " is not found in DB",
119 ErrorNumbers.SVC_DETAILED_SERVICE_ERROR, null);
120 msoLogger.error(MessageEnum.APIH_BPEL_COMMUNICATE_ERROR, MSO_PROP_APIHANDLER_INFRA, "", "",
121 MsoLogger.ErrorCode.BusinessProcesssError,
122 "Null response from RequestDB when searching by RequestId");
123 msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DataNotFound,
124 "Null response from RequestDB when searching by RequestId");
125 msoLogger.debug("End of the transaction, the final response is: " + (String) resp.getEntity());
130 Request request = mapInfraActiveRequestToRequest(requestDB);
132 orchestrationResponse.setRequest(request);
134 return Response.status(200).entity(orchestrationResponse).build();
140 @Path("orchestrationRequests/{version:[vV][2-5]}")
141 @ApiOperation(value = "Find Orchestrated Requests for a URI Information", response = Response.class)
142 @Produces(MediaType.APPLICATION_JSON)
143 public Response getOrchestrationRequest(@Context UriInfo ui, @PathParam("version") String version) {
145 long startTime = System.currentTimeMillis();
147 MsoRequest msoRequest = new MsoRequest();
149 MultivaluedMap<String, String> queryParams = ui.getQueryParameters();
151 List<InfraActiveRequests> activeRequests = null;
153 GetOrchestrationListResponse orchestrationList = null;
157 Map<String, List<String>> orchestrationMap = msoRequest.getOrchestrationFilters(queryParams);
159 activeRequests = requestsDB.getOrchestrationFiltersFromInfraActive(orchestrationMap);
161 orchestrationList = new GetOrchestrationListResponse();
163 List<RequestList> requestLists = new ArrayList<RequestList>();
165 for (InfraActiveRequests infraActive : activeRequests) {
167 Request request = mapInfraActiveRequestToRequest(infraActive);
168 RequestList requestList = new RequestList();
169 requestList.setRequest(request);
171 requestLists.add(requestList);
175 orchestrationList.setRequestList(requestLists);
177 } catch (Exception e) {
178 msoLogger.debug("Get Orchestration Request with Filters Failed : ", e);
179 Response response = msoRequest.buildServiceErrorResponse(HttpStatus.SC_INTERNAL_SERVER_ERROR,
180 MsoException.ServiceException, "Get Orchestration Request with Filters Failed. " + e.getMessage(),
181 ErrorNumbers.SVC_GENERAL_SERVICE_ERROR, null);
182 msoLogger.error(MessageEnum.APIH_GENERAL_EXCEPTION, MSO_PROP_APIHANDLER_INFRA, "", "",
183 MsoLogger.ErrorCode.BusinessProcesssError, "Get Orchestration Request with Filters Failed : " + e);
184 msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DataError,
185 "Get Orchestration Request with Filters Failed");
186 msoLogger.debug("End of the transaction, the final response is: " + (String) response.getEntity());
190 return Response.status(200).entity(orchestrationList).build();
194 @Path("orchestrationRequests/{version: [vV][3-5]}/{requestId}/unlock")
195 @Consumes(MediaType.APPLICATION_JSON)
196 @Produces(MediaType.APPLICATION_JSON)
197 @ApiOperation(value = "Unlock Orchestrated Requests for a given requestId", response = Response.class)
198 public Response unlockOrchestrationRequest(String requestJSON, @PathParam("requestId") String requestId,
199 @PathParam("version") String version) {
201 MsoRequest msoRequest = new MsoRequest(requestId);
203 long startTime = System.currentTimeMillis();
204 msoLogger.debug("requestId is: " + requestId);
206 InfraActiveRequests requestDB = null;
207 Request request = null;
209 msoLogger.debug("requestId is: " + requestId);
210 ServiceInstancesRequest sir = null;
213 ObjectMapper mapper = new ObjectMapper();
214 sir = mapper.readValue(requestJSON, ServiceInstancesRequest.class);
216 } catch (Exception e) {
217 msoLogger.debug("Mapping of request to JSON object failed : ", e);
218 Response response = msoRequest.buildServiceErrorResponse(HttpStatus.SC_BAD_REQUEST,
219 MsoException.ServiceException, "Mapping of request to JSON object failed. " + e.getMessage(),
220 ErrorNumbers.SVC_BAD_PARAMETER, null);
221 if (msoRequest.getRequestId() != null) {
222 msoLogger.debug("Mapping of request to JSON object failed");
224 msoLogger.error(MessageEnum.APIH_REQUEST_VALIDATION_ERROR, MSO_PROP_APIHANDLER_INFRA, "", "",
225 MsoLogger.ErrorCode.SchemaError, requestJSON, e);
226 msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.SchemaError,
227 "Mapping of request to JSON object failed");
228 msoLogger.debug("End of the transaction, the final response is: " + (String) response.getEntity());
233 msoRequest.parseOrchestration(sir);
234 } catch (Exception e) {
235 msoLogger.debug("Validation failed: ", e);
236 Response response = msoRequest.buildServiceErrorResponse(HttpStatus.SC_BAD_REQUEST,
237 MsoException.ServiceException, "Error parsing request. " + e.getMessage(),
238 ErrorNumbers.SVC_BAD_PARAMETER, null);
239 if (msoRequest.getRequestId() != null) {
240 msoLogger.debug("Logging failed message to the database");
242 msoLogger.error(MessageEnum.APIH_REQUEST_VALIDATION_ERROR, MSO_PROP_APIHANDLER_INFRA, "", "",
243 MsoLogger.ErrorCode.SchemaError, requestJSON, e);
244 msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.SchemaError,
245 "Validation of the input request failed");
246 msoLogger.debug("End of the transaction, the final response is: " + (String) response.getEntity());
251 requestDB = requestsDB.getRequestFromInfraActive(requestId);
253 if (requestDB == null) {
254 Response resp = msoRequest.buildServiceErrorResponse(HttpStatus.SC_NOT_FOUND,
255 MsoException.ServiceException, "Orchestration RequestId " + requestId + " is not found in DB",
256 ErrorNumbers.SVC_DETAILED_SERVICE_ERROR, null);
257 msoLogger.error(MessageEnum.APIH_DB_ATTRIBUTE_NOT_FOUND, MSO_PROP_APIHANDLER_INFRA, "", "",
258 MsoLogger.ErrorCode.BusinessProcesssError,
259 "Null response from RequestDB when searching by RequestId");
260 msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DataNotFound,
261 "Null response from RequestDB when searching by RequestId");
262 msoLogger.debug("End of the transaction, the final response is: " + (String) resp.getEntity());
266 request = mapInfraActiveRequestToRequest(requestDB);
267 RequestStatus reqStatus = request.getRequestStatus();
268 Status status = Status.valueOf(reqStatus.getRequestState());
269 if (status == Status.IN_PROGRESS || status == Status.PENDING) {
270 msoRequest.setStatus(org.openecomp.mso.apihandlerinfra.vnfbeans.RequestStatusType.UNLOCKED);
271 reqStatus.setRequestState(Status.UNLOCKED.toString());
272 requestsDB.updateInfraStatus(requestId, Status.UNLOCKED.toString(),
273 Constants.MODIFIED_BY_APIHANDLER);
275 msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc,
276 "RequestId " + requestId + " has been unlocked");
279 Response resp = msoRequest.buildServiceErrorResponse(HttpStatus.SC_BAD_REQUEST,
280 MsoException.ServiceException, "Orchestration RequestId " + requestId + " has a status of "
281 + status + " and can not be unlocked",
282 ErrorNumbers.SVC_DETAILED_SERVICE_ERROR, null);
283 msoLogger.error(MessageEnum.APIH_DB_ATTRIBUTE_NOT_FOUND, MSO_PROP_APIHANDLER_INFRA, "", "",
284 MsoLogger.ErrorCode.DataError, "Orchestration RequestId " + requestId + " has a status of "
285 + status + " and can not be unlocked");
286 msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DataError,
287 "Orchestration RequestId " + requestId + " has a status of " + status
288 + " and can not be unlocked");
289 msoLogger.debug("End of the transaction, the final response is: " + (String) resp.getEntity());
293 } catch (Exception e) {
294 msoLogger.error(MessageEnum.APIH_DB_ACCESS_EXC, MSO_PROP_APIHANDLER_INFRA, "", "",
295 MsoLogger.ErrorCode.AvailabilityError,
296 "Exception while communciate with Request DB - Infra Request Lookup", e);
297 msoRequest.setStatus(org.openecomp.mso.apihandlerinfra.vnfbeans.RequestStatusType.FAILED);
298 Response response = msoRequest.buildServiceErrorResponse(HttpStatus.SC_NOT_FOUND,
299 MsoException.ServiceException, e.getMessage(), ErrorNumbers.NO_COMMUNICATION_TO_REQUESTS_DB, null);
300 alarmLogger.sendAlarm("MsoDatabaseAccessError", MsoAlarmLogger.CRITICAL,
301 Messages.errors.get(ErrorNumbers.NO_COMMUNICATION_TO_REQUESTS_DB));
302 msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DBAccessError,
303 "Exception while communciate with Request DB");
304 msoLogger.debug("End of the transaction, the final response is: " + (String) response.getEntity());
309 return Response.status(HttpStatus.SC_NO_CONTENT).entity("").build();
312 private Request mapInfraActiveRequestToRequest(InfraActiveRequests requestDB) {
314 Request request = new Request();
316 ObjectMapper mapper = new ObjectMapper();
317 // mapper.configure(Feature.WRAP_ROOT_VALUE, true);
319 request.setRequestId(requestDB.getRequestId());
320 request.setRequestScope(requestDB.getRequestScope());
321 request.setRequestType(requestDB.getRequestAction());
323 InstanceReferences ir = new InstanceReferences();
324 if (requestDB.getNetworkId() != null)
325 ir.setNetworkInstanceId(requestDB.getNetworkId());
326 if (requestDB.getNetworkName() != null)
327 ir.setNetworkInstanceName(requestDB.getNetworkName());
328 if (requestDB.getServiceInstanceId() != null)
329 ir.setServiceInstanceId(requestDB.getServiceInstanceId());
330 if (requestDB.getServiceInstanceName() != null)
331 ir.setServiceInstanceName(requestDB.getServiceInstanceName());
332 if (requestDB.getVfModuleId() != null)
333 ir.setVfModuleInstanceId(requestDB.getVfModuleId());
334 if (requestDB.getVfModuleName() != null)
335 ir.setVfModuleInstanceName(requestDB.getVfModuleName());
336 if (requestDB.getVnfId() != null)
337 ir.setVnfInstanceId(requestDB.getVnfId());
338 if (requestDB.getVnfName() != null)
339 ir.setVnfInstanceName(requestDB.getVnfName());
340 if (requestDB.getVolumeGroupId() != null)
341 ir.setVolumeGroupInstanceId(requestDB.getVolumeGroupId());
342 if (requestDB.getVolumeGroupName() != null)
343 ir.setVolumeGroupInstanceName(requestDB.getVolumeGroupName());
344 if (requestDB.getRequestorId() != null)
345 ir.setRequestorId(requestDB.getRequestorId());
347 request.setInstanceReferences(ir);
349 String requestBody = requestDB.getRequestBody();
351 RequestDetails requestDetails = null;
354 requestDetails = mapper.readValue(requestBody, RequestDetails.class);
356 } catch (Exception e) {
357 msoLogger.debug("Exception caught mapping requestBody to RequestDetails", e);
360 request.setRequestDetails(requestDetails);
361 String startTimeStamp = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss").format(requestDB.getStartTime())
363 request.setStartTime(startTimeStamp);
365 RequestStatus status = new RequestStatus();
366 if (requestDB.getStatusMessage() != null) {
367 status.setStatusMessage(requestDB.getStatusMessage());
370 if (requestDB.getEndTime() != null) {
371 String endTimeStamp = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss").format(requestDB.getEndTime())
373 status.setFinishTime(endTimeStamp);
376 if (requestDB.getRequestStatus() != null) {
377 status.setRequestState(requestDB.getRequestStatus());
380 if (requestDB.getProgress() != null) {
381 status.setPercentProgress(requestDB.getProgress().intValue());
384 request.setRequestStatus(status);