mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/InstanceManagement.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   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  * Modifications Copyright (c) 2019 Samsung
   9  * ================================================================================
  10  * Licensed under the Apache License, Version 2.0 (the "License");
  11  * you may not use this file except in compliance with the License.
  12  * You may obtain a copy of the License at
  13  *
  14  *      http://www.apache.org/licenses/LICENSE-2.0
  15  *
  16  * Unless required by applicable law or agreed to in writing, software
  17  * distributed under the License is distributed on an "AS IS" BASIS,
  18  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  19  * See the License for the specific language governing permissions and
  20  * limitations under the License.
  21  * ============LICENSE_END=========================================================
  22  */
  23
  24 package org.onap.so.apihandlerinfra;
  25
  26 import io.swagger.annotations.Api;
  27 import io.swagger.annotations.ApiOperation;
  28 import org.apache.http.HttpStatus;
  29 import org.onap.so.apihandler.common.ErrorNumbers;
  30 import org.onap.so.apihandler.common.RequestClientParameter;
  31 import org.onap.so.apihandlerinfra.exceptions.ApiException;
  32 import org.onap.so.apihandlerinfra.exceptions.RequestDbFailureException;
  33 import org.onap.so.apihandlerinfra.exceptions.ValidateException;
  34 import org.onap.so.apihandlerinfra.logging.ErrorLoggerInfo;
  35 import org.onap.so.db.request.beans.InfraActiveRequests;
  36 import org.onap.so.db.request.client.RequestsDbClient;
  37 import org.onap.so.exceptions.ValidationException;
  38 import org.onap.so.logger.ErrorCode;
  39 import org.onap.so.logger.MessageEnum;
  40 import org.onap.so.serviceinstancebeans.ModelType;
  41 import org.onap.so.serviceinstancebeans.RequestReferences;
  42 import org.onap.so.serviceinstancebeans.ServiceInstancesRequest;
  43 import org.onap.so.serviceinstancebeans.ServiceInstancesResponse;
  44 import org.slf4j.Logger;
  45 import org.slf4j.LoggerFactory;
  46 import org.springframework.beans.factory.annotation.Autowired;
  47 import org.springframework.stereotype.Component;
  48
  49 import javax.transaction.Transactional;
  50 import javax.ws.rs.Consumes;
  51 import javax.ws.rs.POST;
  52 import javax.ws.rs.Path;
  53 import javax.ws.rs.PathParam;
  54 import javax.ws.rs.Produces;
  55 import javax.ws.rs.container.ContainerRequestContext;
  56 import javax.ws.rs.core.Context;
  57 import javax.ws.rs.core.MediaType;
  58 import javax.ws.rs.core.Response;
  59 import java.io.IOException;
  60 import java.util.HashMap;
  61
  62 @Component
  63 @Path("/onap/so/infra/instanceManagement")
  64 @Api(value="/onap/so/infra/instanceManagement",description="Infrastructure API Requests for Instance Management")
  65 public class InstanceManagement {
  66
  67         private static Logger logger = LoggerFactory.getLogger(InstanceManagement.class);
  68         private static String uriPrefix = "/instanceManagement/";
  69         private static final String SAVE_TO_DB = "save instance to db";
  70
  71         @Autowired
  72         private RequestsDbClient infraActiveRequestsClient;
  73
  74         @Autowired
  75         private MsoRequest msoRequest;
  76
  77         @Autowired
  78         private RequestHandlerUtils requestHandlerUtils;
  79
  80         @POST
  81         @Path("/{version:[vV][1]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/workflows/{workflowUuid}")
  82         @Consumes(MediaType.APPLICATION_JSON)
  83         @Produces(MediaType.APPLICATION_JSON)
  84         @ApiOperation(value="Execute custom workflow",response=Response.class)
  85         @Transactional
  86         public Response executeCustomWorkflow(String request, @PathParam("version") String version, @PathParam("serviceInstanceId") String serviceInstanceId,
  87                                           @PathParam("vnfInstanceId") String vnfInstanceId, @PathParam("workflowUuid") String workflowUuid, @Context ContainerRequestContext requestContext) throws ApiException {
  88                 String requestId = requestHandlerUtils.getRequestId(requestContext);
  89                 HashMap<String, String> instanceIdMap = new HashMap<>();
  90                 instanceIdMap.put("serviceInstanceId", serviceInstanceId);
  91                 instanceIdMap.put("vnfInstanceId", vnfInstanceId);
  92                 instanceIdMap.put("workflowUuid", workflowUuid);
  93                 return processCustomWorkflowRequest(request, Action.inPlaceSoftwareUpdate, instanceIdMap, version, requestId, requestContext);
  94         }
  95
  96         private Response processCustomWorkflowRequest(String requestJSON, Actions action, HashMap<String, String> instanceIdMap, String version, String requestId, ContainerRequestContext requestContext) throws ApiException {
  97                 String serviceInstanceId = null;
  98                 if (instanceIdMap != null) {
  99                         serviceInstanceId = instanceIdMap.get("serviceInstanceId");
 100                 }
 101                 Boolean aLaCarte = true;
 102                 long startTime = System.currentTimeMillis ();
 103                 ServiceInstancesRequest sir = null;
 104                 String apiVersion = version.substring(1);
 105
 106                 String requestUri = requestHandlerUtils.getRequestUri(requestContext, uriPrefix);
 107
 108                 sir = requestHandlerUtils.convertJsonToServiceInstanceRequest(requestJSON, action, startTime, sir, msoRequest, requestId, requestUri);
 109                 String requestScope = requestHandlerUtils.deriveRequestScope(action, sir, requestUri);
 110                 InfraActiveRequests currentActiveReq =  msoRequest.createRequestObject (sir,  action, requestId, Status.IN_PROGRESS, requestJSON, requestScope);
 111
 112                 try {
 113                         requestHandlerUtils.validateHeaders(requestContext);
 114                 } catch (ValidationException e) {
 115                         logger.error("Exception occurred", e);
 116             ErrorLoggerInfo errorLoggerInfo = new ErrorLoggerInfo.Builder(MessageEnum.APIH_VALIDATION_ERROR, ErrorCode.SchemaError).errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
 117             ValidateException validateException = new ValidateException.Builder(e.getMessage(), HttpStatus.SC_BAD_REQUEST, ErrorNumbers.SVC_BAD_PARAMETER).cause(e)
 118                         .errorInfo(errorLoggerInfo).build();
 119             requestHandlerUtils.updateStatus(currentActiveReq, Status.FAILED, validateException.getMessage());
 120             throw validateException;
 121                 }
 122
 123                 requestHandlerUtils.parseRequest(sir, instanceIdMap, action, version, requestJSON, aLaCarte, requestId, currentActiveReq);
 124                 requestHandlerUtils.setInstanceId(currentActiveReq, requestScope, null, instanceIdMap);
 125
 126                 int requestVersion = Integer.parseInt(version.substring(1));
 127                 String vnfType = msoRequest.getVnfType(sir,requestScope,action,requestVersion);
 128
 129                 if(requestScope.equalsIgnoreCase(ModelType.vnf.name()) && vnfType != null){
 130                         currentActiveReq.setVnfType(vnfType);
 131                 }
 132
 133                 InfraActiveRequests dup = null;
 134                 boolean inProgress = false;
 135
 136                 dup = requestHandlerUtils.duplicateCheck(action, instanceIdMap, startTime, msoRequest, null, requestScope, currentActiveReq);
 137
 138                 if(dup != null){
 139                         inProgress = requestHandlerUtils.camundaHistoryCheck(dup, currentActiveReq);
 140                 }
 141
 142                 if (dup != null && inProgress) {
 143             requestHandlerUtils.buildErrorOnDuplicateRecord(currentActiveReq, action, instanceIdMap, startTime, msoRequest, null, requestScope, dup);
 144                 }
 145                 ServiceInstancesResponse serviceResponse = new ServiceInstancesResponse();
 146
 147                 RequestReferences referencesResponse = new RequestReferences();
 148
 149                 referencesResponse.setRequestId(requestId);
 150
 151                 serviceResponse.setRequestReferences(referencesResponse);
 152                 Boolean isBaseVfModule = false;
 153
 154                 String workflowUuid = null;
 155                 if (instanceIdMap !=null) {
 156                         workflowUuid = instanceIdMap.get("workflowUuid");
 157                 }
 158
 159         RecipeLookupResult recipeLookupResult = getCustomWorkflowUri(workflowUuid);
 160         String serviceInstanceType = requestHandlerUtils.getServiceType(requestScope, sir, true);
 161
 162                 serviceInstanceId = requestHandlerUtils.setServiceInstanceId(requestScope, sir);
 163                 String vnfId = "";
 164
 165                 if(sir.getVnfInstanceId () != null){
 166                         vnfId = sir.getVnfInstanceId ();
 167                 }
 168
 169         try{
 170             infraActiveRequestsClient.save(currentActiveReq);
 171         }catch(Exception e){
 172             ErrorLoggerInfo errorLoggerInfo = new ErrorLoggerInfo.Builder(MessageEnum.APIH_DB_ACCESS_EXC, ErrorCode.DataError).errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
 173             throw new RequestDbFailureException.Builder(SAVE_TO_DB, e.toString(), HttpStatus.SC_INTERNAL_SERVER_ERROR, ErrorNumbers.SVC_DETAILED_SERVICE_ERROR).cause(e)
 174                     .errorInfo(errorLoggerInfo).build();
 175         }
 176
 177                 RequestClientParameter requestClientParameter = null;
 178                 try {
 179                         requestClientParameter = new RequestClientParameter.Builder()
 180                                                 .setRequestId(requestId)
 181                                                 .setBaseVfModule(isBaseVfModule)
 182                                                 .setRecipeTimeout(recipeLookupResult.getRecipeTimeout())
 183                                                 .setRequestAction(action.toString())
 184                                                 .setServiceInstanceId(serviceInstanceId)
 185                                                 .setVnfId(vnfId)
 186                                                 .setServiceType(serviceInstanceType)
 187                                                 .setVnfType(vnfType)
 188                                                 .setRequestDetails(requestHandlerUtils.mapJSONtoMSOStyle(requestJSON, sir, aLaCarte, action))
 189                                                 .setApiVersion(apiVersion)
 190                                                 .setALaCarte(aLaCarte)
 191                                                 .setRequestUri(requestUri)
 192                                                 .build();
 193                 } catch (IOException e) {
 194                         ErrorLoggerInfo errorLoggerInfo = new ErrorLoggerInfo.Builder(MessageEnum.APIH_BPEL_RESPONSE_ERROR, ErrorCode.SchemaError).errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
 195                         throw new ValidateException.Builder("Unable to generate RequestClientParamter object" + e.getMessage(), HttpStatus.SC_INTERNAL_SERVER_ERROR, ErrorNumbers.SVC_BAD_PARAMETER)
 196                           .errorInfo(errorLoggerInfo).build();
 197                 }
 198                 return requestHandlerUtils.postBPELRequest(currentActiveReq, requestClientParameter, recipeLookupResult.getOrchestrationURI(), requestScope);
 199         }
 200
 201     private RecipeLookupResult getCustomWorkflowUri(String workflowUuid) {
 202
 203                 RecipeLookupResult recipeLookupResult = new RecipeLookupResult("/mso/async/services/VnfInPlaceUpdate", 180);
 204                 return recipeLookupResult;
 205         }
 206 }