mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/ServiceInstances.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  * Modifications Copyright (c) 2023 Nordix Foundation.
  11  * ================================================================================
  12  * Licensed under the Apache License, Version 2.0 (the "License");
  13  * you may not use this file except in compliance with the License.
  14  * You may obtain a copy of the License at
  15  *
  16  *      http://www.apache.org/licenses/LICENSE-2.0
  17  *
  18  * Unless required by applicable law or agreed to in writing, software
  19  * distributed under the License is distributed on an "AS IS" BASIS,
  20  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  21  * See the License for the specific language governing permissions and
  22  * limitations under the License.
  23  * ============LICENSE_END=========================================================
  24  */
  25
  26 package org.onap.so.apihandlerinfra;
  27
  28 import java.io.IOException;
  29 import java.util.HashMap;
  30 import java.util.Optional;
  31 import java.util.stream.Collectors;
  32 import javax.transaction.Transactional;
  33 import javax.ws.rs.Consumes;
  34 import javax.ws.rs.DELETE;
  35 import javax.ws.rs.POST;
  36 import javax.ws.rs.PUT;
  37 import javax.ws.rs.Path;
  38 import javax.ws.rs.PathParam;
  39 import javax.ws.rs.Produces;
  40 import javax.ws.rs.container.ContainerRequestContext;
  41 import javax.ws.rs.core.Context;
  42 import javax.ws.rs.core.MediaType;
  43 import javax.ws.rs.core.Response;
  44 import org.apache.commons.lang.StringUtils;
  45 import org.apache.http.HttpStatus;
  46 import org.onap.logging.filter.base.ErrorCode;
  47 import org.onap.so.apihandler.common.CommonConstants;
  48 import org.onap.so.apihandler.common.ErrorNumbers;
  49 import org.onap.so.apihandler.common.RequestClientParameter;
  50 import org.onap.so.apihandlerinfra.exceptions.ApiException;
  51 import org.onap.so.apihandlerinfra.exceptions.RequestDbFailureException;
  52 import org.onap.so.apihandlerinfra.exceptions.ValidateException;
  53 import org.onap.so.apihandlerinfra.infra.rest.BpmnRequestBuilder;
  54 import org.onap.so.apihandlerinfra.infra.rest.exception.CloudConfigurationNotFoundException;
  55 import org.onap.so.apihandlerinfra.infra.rest.handler.AbstractRestHandler;
  56 import org.onap.so.apihandlerinfra.infra.rest.validators.RequestValidatorListenerRunner;
  57 import org.onap.so.apihandlerinfra.logging.ErrorLoggerInfo;
  58 import org.onap.so.constants.Status;
  59 import org.onap.so.db.catalog.client.CatalogDbClient;
  60 import org.onap.so.db.request.beans.InfraActiveRequests;
  61 import org.onap.so.db.request.client.RequestsDbClient;
  62 import org.onap.so.exceptions.ValidationException;
  63 import org.onap.so.logger.MessageEnum;
  64 import org.onap.so.serviceinstancebeans.CloudConfiguration;
  65 import org.onap.so.serviceinstancebeans.ModelInfo;
  66 import org.onap.so.serviceinstancebeans.ModelType;
  67 import org.onap.so.serviceinstancebeans.RequestDetails;
  68 import org.onap.so.serviceinstancebeans.RequestReferences;
  69 import org.onap.so.serviceinstancebeans.ServiceInstancesRequest;
  70 import org.onap.so.serviceinstancebeans.ServiceInstancesResponse;
  71 import org.slf4j.Logger;
  72 import org.slf4j.LoggerFactory;
  73 import org.springframework.beans.factory.annotation.Autowired;
  74 import org.springframework.core.env.Environment;
  75 import org.springframework.stereotype.Component;
  76 import org.springframework.web.client.RestTemplate;
  77 import io.swagger.v3.oas.annotations.OpenAPIDefinition;
  78 import io.swagger.v3.oas.annotations.Operation;
  79 import io.swagger.v3.oas.annotations.info.Info;
  80 import io.swagger.v3.oas.annotations.media.ArraySchema;
  81 import io.swagger.v3.oas.annotations.media.Content;
  82 import io.swagger.v3.oas.annotations.media.Schema;
  83 import io.swagger.v3.oas.annotations.responses.ApiResponse;
  84
  85 @Component
  86 @Path("/onap/so/infra/serviceInstantiation")
  87 @OpenAPIDefinition(info = @Info(title = "/onap/so/infra/serviceInstantiation",
  88         description = "Infrastructure API Requests for Service Instances"))
  89 public class ServiceInstances extends AbstractRestHandler {
  90
  91     private static Logger logger = LoggerFactory.getLogger(MsoRequest.class);
  92     private static String uriPrefix = "/serviceInstantiation/";
  93     private static final String SAVE_TO_DB = "save instance to db";
  94
  95     @Autowired
  96     private Environment env;
  97
  98     @Autowired
  99     private RestTemplate restTemplate;
 100
 101     @Autowired
 102     private CatalogDbClient catalogDbClient;
 103
 104     @Autowired
 105     private RequestsDbClient infraActiveRequestsClient;
 106
 107     @Autowired
 108     private MsoRequest msoRequest;
 109
 110     @Autowired
 111     private RequestHandlerUtils requestHandlerUtils;
 112
 113     @Autowired
 114     private RequestValidatorListenerRunner requestValidatorListenerRunner;
 115
 116     @Autowired
 117     private BpmnRequestBuilder bpmnRequestBuilder;
 118
 119     @POST
 120     @Path("/{version:[vV][5-7]}/serviceInstances")
 121     @Consumes(MediaType.APPLICATION_JSON)
 122     @Produces(MediaType.APPLICATION_JSON)
 123     @Operation(description = "Create a Service Instance on a version provided", responses = @ApiResponse(
 124             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 125     @Transactional
 126     public Response createServiceInstance(String request, @PathParam("version") String version,
 127             @Context ContainerRequestContext requestContext) throws ApiException {
 128         String requestId = requestHandlerUtils.getRequestId(requestContext);
 129         return serviceInstances(request, Action.createInstance, null, version, requestId,
 130                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 131     }
 132
 133     @POST
 134     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/activate")
 135     @Consumes(MediaType.APPLICATION_JSON)
 136     @Produces(MediaType.APPLICATION_JSON)
 137     @Operation(description = "Activate provided Service Instance", responses = @ApiResponse(
 138             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 139     @Transactional
 140     public Response activateServiceInstance(String request, @PathParam("version") String version,
 141             @PathParam("serviceInstanceId") String serviceInstanceId, @Context ContainerRequestContext requestContext)
 142             throws ApiException {
 143         String requestId = requestHandlerUtils.getRequestId(requestContext);
 144         HashMap<String, String> instanceIdMap = new HashMap<>();
 145         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 146         return serviceInstances(request, Action.activateInstance, instanceIdMap, version, requestId,
 147                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 148     }
 149
 150     @POST
 151     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/deactivate")
 152     @Consumes(MediaType.APPLICATION_JSON)
 153     @Produces(MediaType.APPLICATION_JSON)
 154     @Operation(description = "Deactivate provided Service Instance", responses = @ApiResponse(
 155             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 156     @Transactional
 157     public Response deactivateServiceInstance(String request, @PathParam("version") String version,
 158             @PathParam("serviceInstanceId") String serviceInstanceId, @Context ContainerRequestContext requestContext)
 159             throws ApiException {
 160         String requestId = requestHandlerUtils.getRequestId(requestContext);
 161         HashMap<String, String> instanceIdMap = new HashMap<>();
 162         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 163         return serviceInstances(request, Action.deactivateInstance, instanceIdMap, version, requestId,
 164                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 165     }
 166
 167     @DELETE
 168     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}")
 169     @Consumes(MediaType.APPLICATION_JSON)
 170     @Produces(MediaType.APPLICATION_JSON)
 171     @Operation(description = "Delete provided Service Instance", responses = @ApiResponse(
 172             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 173     @Transactional
 174     public Response deleteServiceInstance(String request, @PathParam("version") String version,
 175             @PathParam("serviceInstanceId") String serviceInstanceId, @Context ContainerRequestContext requestContext)
 176             throws ApiException {
 177         String requestId = requestHandlerUtils.getRequestId(requestContext);
 178         HashMap<String, String> instanceIdMap = new HashMap<>();
 179         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 180         return serviceInstances(request, Action.deleteInstance, instanceIdMap, version, requestId,
 181                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 182     }
 183
 184     @POST
 185     @Path("/{version:[vV][7]}/serviceInstances/assign")
 186     @Consumes(MediaType.APPLICATION_JSON)
 187     @Produces(MediaType.APPLICATION_JSON)
 188     @Operation(description = "Assign Service Instance", responses = @ApiResponse(
 189             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 190     @Transactional
 191     public Response assignServiceInstance(String request, @PathParam("version") String version,
 192             @Context ContainerRequestContext requestContext) throws ApiException {
 193         String requestId = requestHandlerUtils.getRequestId(requestContext);
 194         return serviceInstances(request, Action.assignInstance, null, version, requestId,
 195                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 196     }
 197
 198     @POST
 199     @Path("/{version:[vV][7]}/serviceInstances/{serviceInstanceId}/unassign")
 200     @Consumes(MediaType.APPLICATION_JSON)
 201     @Produces(MediaType.APPLICATION_JSON)
 202     @Operation(description = "Unassign Service Instance", responses = @ApiResponse(
 203             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 204     @Transactional
 205     public Response unassignServiceInstance(String request, @PathParam("version") String version,
 206             @PathParam("serviceInstanceId") String serviceInstanceId, @Context ContainerRequestContext requestContext)
 207             throws ApiException {
 208         String requestId = requestHandlerUtils.getRequestId(requestContext);
 209         HashMap<String, String> instanceIdMap = new HashMap<>();
 210         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 211         return serviceInstances(request, Action.unassignInstance, instanceIdMap, version, requestId,
 212                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 213     }
 214
 215     @POST
 216     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/configurations")
 217     @Consumes(MediaType.APPLICATION_JSON)
 218     @Produces(MediaType.APPLICATION_JSON)
 219     @Operation(description = "Create Port Mirroring Configuration", responses = @ApiResponse(
 220             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 221     @Transactional
 222     public Response createPortConfiguration(String request, @PathParam("version") String version,
 223             @PathParam("serviceInstanceId") String serviceInstanceId, @Context ContainerRequestContext requestContext)
 224             throws ApiException {
 225         String requestId = requestHandlerUtils.getRequestId(requestContext);
 226         HashMap<String, String> instanceIdMap = new HashMap<>();
 227         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 228         return configurationRecipeLookup(request, Action.createInstance, instanceIdMap, version, requestId,
 229                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 230     }
 231
 232     @DELETE
 233     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/configurations/{configurationInstanceId}")
 234     @Consumes(MediaType.APPLICATION_JSON)
 235     @Produces(MediaType.APPLICATION_JSON)
 236     @Operation(description = "Delete provided Port", responses = @ApiResponse(
 237             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 238     @Transactional
 239     public Response deletePortConfiguration(String request, @PathParam("version") String version,
 240             @PathParam("serviceInstanceId") String serviceInstanceId,
 241             @PathParam("configurationInstanceId") String configurationInstanceId,
 242             @Context ContainerRequestContext requestContext) throws ApiException {
 243         String requestId = requestHandlerUtils.getRequestId(requestContext);
 244         HashMap<String, String> instanceIdMap = new HashMap<>();
 245         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 246         instanceIdMap.put("configurationInstanceId", configurationInstanceId);
 247         return configurationRecipeLookup(request, Action.deleteInstance, instanceIdMap, version, requestId,
 248                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 249     }
 250
 251     @POST
 252     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/configurations/{configurationInstanceId}/enablePort")
 253     @Consumes(MediaType.APPLICATION_JSON)
 254     @Produces(MediaType.APPLICATION_JSON)
 255     @Operation(description = "Enable Port Mirroring", responses = @ApiResponse(
 256             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 257     @Transactional
 258     public Response enablePort(String request, @PathParam("version") String version,
 259             @PathParam("serviceInstanceId") String serviceInstanceId,
 260             @PathParam("configurationInstanceId") String configurationInstanceId,
 261             @Context ContainerRequestContext requestContext) throws ApiException {
 262         String requestId = requestHandlerUtils.getRequestId(requestContext);
 263         HashMap<String, String> instanceIdMap = new HashMap<>();
 264         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 265         instanceIdMap.put("configurationInstanceId", configurationInstanceId);
 266         return configurationRecipeLookup(request, Action.enablePort, instanceIdMap, version, requestId,
 267                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 268     }
 269
 270     @POST
 271     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/configurations/{configurationInstanceId}/disablePort")
 272     @Consumes(MediaType.APPLICATION_JSON)
 273     @Produces(MediaType.APPLICATION_JSON)
 274     @Operation(description = "Disable Port Mirroring", responses = @ApiResponse(
 275             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 276     @Transactional
 277     public Response disablePort(String request, @PathParam("version") String version,
 278             @PathParam("serviceInstanceId") String serviceInstanceId,
 279             @PathParam("configurationInstanceId") String configurationInstanceId,
 280             @Context ContainerRequestContext requestContext) throws ApiException {
 281         String requestId = requestHandlerUtils.getRequestId(requestContext);
 282         HashMap<String, String> instanceIdMap = new HashMap<>();
 283         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 284         instanceIdMap.put("configurationInstanceId", configurationInstanceId);
 285         return configurationRecipeLookup(request, Action.disablePort, instanceIdMap, version, requestId,
 286                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 287     }
 288
 289     @POST
 290     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/configurations/{configurationInstanceId}/activate")
 291     @Consumes(MediaType.APPLICATION_JSON)
 292     @Produces(MediaType.APPLICATION_JSON)
 293     @Operation(description = "Activate Port Mirroring", responses = @ApiResponse(
 294             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 295     @Transactional
 296     public Response activatePort(String request, @PathParam("version") String version,
 297             @PathParam("serviceInstanceId") String serviceInstanceId,
 298             @PathParam("configurationInstanceId") String configurationInstanceId,
 299             @Context ContainerRequestContext requestContext) throws ApiException {
 300         String requestId = requestHandlerUtils.getRequestId(requestContext);
 301         HashMap<String, String> instanceIdMap = new HashMap<>();
 302         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 303         instanceIdMap.put("configurationInstanceId", configurationInstanceId);
 304         return configurationRecipeLookup(request, Action.activateInstance, instanceIdMap, version, requestId,
 305                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 306     }
 307
 308     @POST
 309     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/configurations/{configurationInstanceId}/deactivate")
 310     @Consumes(MediaType.APPLICATION_JSON)
 311     @Produces(MediaType.APPLICATION_JSON)
 312     @Operation(description = "Deactivate Port Mirroring", responses = @ApiResponse(
 313             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 314     @Transactional
 315     public Response deactivatePort(String request, @PathParam("version") String version,
 316             @PathParam("serviceInstanceId") String serviceInstanceId,
 317             @PathParam("configurationInstanceId") String configurationInstanceId,
 318             @Context ContainerRequestContext requestContext) throws ApiException {
 319         String requestId = requestHandlerUtils.getRequestId(requestContext);
 320         HashMap<String, String> instanceIdMap = new HashMap<>();
 321         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 322         instanceIdMap.put("configurationInstanceId", configurationInstanceId);
 323         return configurationRecipeLookup(request, Action.deactivateInstance, instanceIdMap, version, requestId,
 324                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 325     }
 326
 327     @POST
 328     @Path("/{version:[vV][6-7]}/serviceInstances/{serviceInstanceId}/addRelationships")
 329     @Consumes(MediaType.APPLICATION_JSON)
 330     @Produces(MediaType.APPLICATION_JSON)
 331     @Operation(description = "Add Relationships to a Service Instance", responses = @ApiResponse(
 332             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 333     @Transactional
 334     public Response addRelationships(String request, @PathParam("version") String version,
 335             @PathParam("serviceInstanceId") String serviceInstanceId, @Context ContainerRequestContext requestContext)
 336             throws ApiException {
 337         String requestId = requestHandlerUtils.getRequestId(requestContext);
 338         HashMap<String, String> instanceIdMap = new HashMap<>();
 339         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 340         return configurationRecipeLookup(request, Action.addRelationships, instanceIdMap, version, requestId,
 341                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 342     }
 343
 344     @POST
 345     @Path("/{version:[vV][6-7]}/serviceInstances/{serviceInstanceId}/removeRelationships")
 346     @Consumes(MediaType.APPLICATION_JSON)
 347     @Produces(MediaType.APPLICATION_JSON)
 348     @Operation(description = "Remove Relationships from Service Instance", responses = @ApiResponse(
 349             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 350     @Transactional
 351     public Response removeRelationships(String request, @PathParam("version") String version,
 352             @PathParam("serviceInstanceId") String serviceInstanceId, @Context ContainerRequestContext requestContext)
 353             throws ApiException {
 354         String requestId = requestHandlerUtils.getRequestId(requestContext);
 355         HashMap<String, String> instanceIdMap = new HashMap<>();
 356         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 357         return configurationRecipeLookup(request, Action.removeRelationships, instanceIdMap, version, requestId,
 358                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 359     }
 360
 361     @POST
 362     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs")
 363     @Consumes(MediaType.APPLICATION_JSON)
 364     @Produces(MediaType.APPLICATION_JSON)
 365     @Operation(description = "Create VNF on a specified version and serviceInstance", responses = @ApiResponse(
 366             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 367     @Transactional
 368     public Response createVnfInstance(String request, @PathParam("version") String version,
 369             @PathParam("serviceInstanceId") String serviceInstanceId, @Context ContainerRequestContext requestContext)
 370             throws ApiException {
 371         String requestId = requestHandlerUtils.getRequestId(requestContext);
 372         HashMap<String, String> instanceIdMap = new HashMap<>();
 373         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 374         try {
 375             return serviceInstances(request, Action.createInstance, instanceIdMap, version, requestId,
 376                     requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 377         } catch (Exception e) {
 378             logger.error("Error in vnf", e);
 379             throw e;
 380         }
 381     }
 382
 383     @POST
 384     @Path("/{version:[vV][7]}/serviceInstances/{serviceInstanceId}/cnfs")
 385     @Consumes(MediaType.APPLICATION_JSON)
 386     @Produces(MediaType.APPLICATION_JSON)
 387     @Operation(description = "Create CNF on a specified version and serviceInstance", responses = @ApiResponse(
 388             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 389     @Transactional
 390     public Response createCnfInstance(String request, @PathParam("version") String version,
 391             @PathParam("serviceInstanceId") String serviceInstanceId, @Context ContainerRequestContext requestContext)
 392             throws ApiException {
 393         String requestId = requestHandlerUtils.getRequestId(requestContext);
 394         HashMap<String, String> instanceIdMap = new HashMap<>();
 395         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 396         try {
 397             return serviceInstances(request, Action.createInstance, instanceIdMap, version, requestId,
 398                     requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 399         } catch (Exception e) {
 400             logger.error("Error in cnf", e);
 401             throw e;
 402         }
 403     }
 404
 405     @DELETE
 406     @Path("/{version:[vV][7]}/serviceInstances/{serviceInstanceId}/cnfs/{cnfInstanceId}")
 407     @Consumes(MediaType.APPLICATION_JSON)
 408     @Produces(MediaType.APPLICATION_JSON)
 409     @Operation(description = "Delete provided for CNF instance", responses = @ApiResponse(
 410             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 411     @Transactional
 412     public Response deleteCnfInstance(String request, @PathParam("version") String version,
 413             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("cnfInstanceId") String cnfInstanceId,
 414             @Context ContainerRequestContext requestContext) throws ApiException {
 415         logger.debug("Inside API Handler to perform delete CNF Instance");
 416         String requestId = requestHandlerUtils.getRequestId(requestContext);
 417         HashMap<String, String> instanceIdMap = new HashMap<>();
 418         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 419         instanceIdMap.put("vnfInstanceId", cnfInstanceId);
 420         return serviceInstances(request, Action.deleteInstance, instanceIdMap, version, requestId,
 421                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 422     }
 423
 424     @POST
 425     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/upgrade")
 426     @Consumes(MediaType.APPLICATION_JSON)
 427     @Produces(MediaType.APPLICATION_JSON)
 428     @Operation(description = "Upgrade a Service Instance to newer model", responses = @ApiResponse(
 429             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 430     @Transactional
 431     public Response upgradeServiceInstance(String request, @PathParam("version") String version,
 432             @PathParam("serviceInstanceId") String serviceInstanceId, @Context ContainerRequestContext requestContext)
 433             throws ApiException {
 434         String requestId = requestHandlerUtils.getRequestId(requestContext);
 435         HashMap<String, String> instanceIdMap = new HashMap<>();
 436         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 437
 438         return serviceInstances(request, Action.upgradeInstance, instanceIdMap, version, requestId,
 439                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 440     }
 441
 442     @POST
 443     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/replace")
 444     @Consumes(MediaType.APPLICATION_JSON)
 445     @Produces(MediaType.APPLICATION_JSON)
 446     @Operation(description = "Replace provided VNF instance", responses = @ApiResponse(
 447             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 448     @Transactional
 449     public Response replaceVnfInstance(String request, @PathParam("version") String version,
 450             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 451             @Context ContainerRequestContext requestContext) throws ApiException {
 452         String requestId = requestHandlerUtils.getRequestId(requestContext);
 453         HashMap<String, String> instanceIdMap = new HashMap<>();
 454         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 455         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 456         return serviceInstances(request, Action.replaceInstance, instanceIdMap, version, requestId,
 457                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 458     }
 459
 460     @POST
 461     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/healthcheck")
 462     @Consumes(MediaType.APPLICATION_JSON)
 463     @Produces(MediaType.APPLICATION_JSON)
 464     @Operation(description = "HealthCheck for provided VNF instance", responses = @ApiResponse(
 465             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 466     @Transactional
 467     public Response cnfHealthCheck(String request, @PathParam("version") String version,
 468             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 469             @Context ContainerRequestContext requestContext) throws ApiException {
 470         String requestId = requestHandlerUtils.getRequestId(requestContext);
 471         HashMap<String, String> instanceIdMap = new HashMap<>();
 472         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 473         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 474         return serviceInstances(request, Action.healthCheck, instanceIdMap, version, requestId,
 475                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 476     }
 477
 478     @POST
 479     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/upgradeCnf")
 480     @Consumes(MediaType.APPLICATION_JSON)
 481     @Produces(MediaType.APPLICATION_JSON)
 482     @Operation(description = "Upgrade CNF instance", responses = @ApiResponse(
 483             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 484     @Transactional
 485     public Response cnfUpgrade(String request, @PathParam("version") String version,
 486             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 487             @Context ContainerRequestContext requestContext) throws ApiException {
 488         String requestId = requestHandlerUtils.getRequestId(requestContext);
 489         HashMap<String, String> instanceIdMap = new HashMap<>();
 490         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 491         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 492         return serviceInstances(request, Action.upgradeCnf, instanceIdMap, version, requestId,
 493                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 494     }
 495
 496     @PUT
 497     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}")
 498     @Consumes(MediaType.APPLICATION_JSON)
 499     @Produces(MediaType.APPLICATION_JSON)
 500     @Operation(description = "Update VNF on a specified version, serviceInstance and vnfInstance",
 501             responses = @ApiResponse(
 502                     content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 503     @Transactional
 504     public Response updateVnfInstance(String request, @PathParam("version") String version,
 505             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 506             @Context ContainerRequestContext requestContext) throws ApiException {
 507         String requestId = requestHandlerUtils.getRequestId(requestContext);
 508         HashMap<String, String> instanceIdMap = new HashMap<>();
 509         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 510         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 511         return serviceInstances(request, Action.updateInstance, instanceIdMap, version, requestId,
 512                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 513     }
 514
 515     @POST
 516     @Path("/{version:[vV][6-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/applyUpdatedConfig")
 517     @Consumes(MediaType.APPLICATION_JSON)
 518     @Produces(MediaType.APPLICATION_JSON)
 519     @Operation(description = "Apply updated configuration", responses = @ApiResponse(
 520             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 521     public Response applyUpdatedConfig(String request, @PathParam("version") String version,
 522             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 523             @Context ContainerRequestContext requestContext) throws ApiException {
 524         String requestId = requestHandlerUtils.getRequestId(requestContext);
 525         HashMap<String, String> instanceIdMap = new HashMap<>();
 526         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 527         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 528         return serviceInstances(request, Action.applyUpdatedConfig, instanceIdMap, version, requestId,
 529                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 530     }
 531
 532     @POST
 533     @Path("/{version:[vV][7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/recreate")
 534     @Consumes(MediaType.APPLICATION_JSON)
 535     @Produces(MediaType.APPLICATION_JSON)
 536     @Operation(description = "Recreate VNF Instance", responses = @ApiResponse(
 537             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 538     public Response recreateVnfInstance(String request, @PathParam("version") String version,
 539             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 540             @Context ContainerRequestContext requestContext) throws ApiException {
 541         String requestId = requestHandlerUtils.getRequestId(requestContext);
 542         HashMap<String, String> instanceIdMap = new HashMap<>();
 543         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 544         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 545         return serviceInstances(request, Action.recreateInstance, instanceIdMap, version, requestId,
 546                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 547     }
 548
 549     @DELETE
 550     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}")
 551     @Consumes(MediaType.APPLICATION_JSON)
 552     @Produces(MediaType.APPLICATION_JSON)
 553     @Operation(description = "Delete provided VNF instance", responses = @ApiResponse(
 554             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 555     @Transactional
 556     public Response deleteVnfInstance(String request, @PathParam("version") String version,
 557             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 558             @Context ContainerRequestContext requestContext) throws ApiException {
 559         String requestId = requestHandlerUtils.getRequestId(requestContext);
 560         HashMap<String, String> instanceIdMap = new HashMap<>();
 561         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 562         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 563         return serviceInstances(request, Action.deleteInstance, instanceIdMap, version, requestId,
 564                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 565     }
 566
 567     @POST
 568     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/vfModules")
 569     @Consumes(MediaType.APPLICATION_JSON)
 570     @Produces(MediaType.APPLICATION_JSON)
 571     @Operation(description = "Create VfModule on a specified version, serviceInstance and vnfInstance",
 572             responses = @ApiResponse(
 573                     content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 574     @Transactional
 575     public Response createVfModuleInstance(String request, @PathParam("version") String version,
 576             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 577             @Context ContainerRequestContext requestContext) throws ApiException {
 578         String requestId = requestHandlerUtils.getRequestId(requestContext);
 579         HashMap<String, String> instanceIdMap = new HashMap<>();
 580         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 581         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 582         return serviceInstances(request, Action.createInstance, instanceIdMap, version, requestId,
 583                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 584     }
 585
 586     @POST
 587     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/vfModules/{vfmoduleInstanceId}/replace")
 588     @Consumes(MediaType.APPLICATION_JSON)
 589     @Produces(MediaType.APPLICATION_JSON)
 590     @Operation(description = "Create VfModule on a specified version, serviceInstance and vnfInstance",
 591             responses = @ApiResponse(
 592                     content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 593     @Transactional
 594     public Response replaceVfModuleInstance(String request, @PathParam("version") String version,
 595             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 596             @PathParam("vfmoduleInstanceId") String vfmoduleInstanceId, @Context ContainerRequestContext requestContext)
 597             throws ApiException {
 598         String requestId = requestHandlerUtils.getRequestId(requestContext);
 599         HashMap<String, String> instanceIdMap = new HashMap<>();
 600         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 601         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 602         instanceIdMap.put("vfModuleInstanceId", vfmoduleInstanceId);
 603         return serviceInstances(request, Action.replaceInstance, instanceIdMap, version, requestId,
 604                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 605     }
 606
 607     @PUT
 608     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/vfModules/{vfmoduleInstanceId}")
 609     @Consumes(MediaType.APPLICATION_JSON)
 610     @Produces(MediaType.APPLICATION_JSON)
 611     @Operation(description = "Update VfModule on a specified version, serviceInstance, vnfInstance and vfModule",
 612             responses = @ApiResponse(
 613                     content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 614     @Transactional
 615     public Response updateVfModuleInstance(String request, @PathParam("version") String version,
 616             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 617             @PathParam("vfmoduleInstanceId") String vfmoduleInstanceId, @Context ContainerRequestContext requestContext)
 618             throws ApiException {
 619         String requestId = requestHandlerUtils.getRequestId(requestContext);
 620         HashMap<String, String> instanceIdMap = new HashMap<>();
 621         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 622         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 623         instanceIdMap.put("vfModuleInstanceId", vfmoduleInstanceId);
 624         return serviceInstances(request, Action.updateInstance, instanceIdMap, version, requestId,
 625                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 626     }
 627
 628     @POST
 629     @Path("/{version:[vV][6-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/inPlaceSoftwareUpdate")
 630     @Consumes(MediaType.APPLICATION_JSON)
 631     @Produces(MediaType.APPLICATION_JSON)
 632     @Operation(description = "Perform VNF software update", responses = @ApiResponse(
 633             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 634     @Transactional
 635     public Response inPlaceSoftwareUpdate(String request, @PathParam("version") String version,
 636             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 637             @Context ContainerRequestContext requestContext) throws ApiException {
 638         String requestId = requestHandlerUtils.getRequestId(requestContext);
 639         HashMap<String, String> instanceIdMap = new HashMap<>();
 640         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 641         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 642         return serviceInstances(request, Action.inPlaceSoftwareUpdate, instanceIdMap, version, requestId,
 643                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 644     }
 645
 646     @DELETE
 647     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/vfModules/{vfmoduleInstanceId}")
 648     @Consumes(MediaType.APPLICATION_JSON)
 649     @Produces(MediaType.APPLICATION_JSON)
 650     @Operation(description = "Delete provided VfModule instance", responses = @ApiResponse(
 651             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 652     @Transactional
 653     public Response deleteVfModuleInstance(String request, @PathParam("version") String version,
 654             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 655             @PathParam("vfmoduleInstanceId") String vfmoduleInstanceId, @Context ContainerRequestContext requestContext)
 656             throws ApiException {
 657         String requestId = requestHandlerUtils.getRequestId(requestContext);
 658         HashMap<String, String> instanceIdMap = new HashMap<>();
 659         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 660         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 661         instanceIdMap.put("vfModuleInstanceId", vfmoduleInstanceId);
 662         return serviceInstances(request, Action.deleteInstance, instanceIdMap, version, requestId,
 663                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 664     }
 665
 666     @POST
 667     @Path("/{version:[vV][7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/vfModules/{vfmoduleInstanceId}/deactivateAndCloudDelete")
 668     @Consumes(MediaType.APPLICATION_JSON)
 669     @Produces(MediaType.APPLICATION_JSON)
 670     @Operation(description = "Deactivate and Cloud Delete VfModule instance", responses = @ApiResponse(
 671             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 672     @Transactional
 673     public Response deactivateAndCloudDeleteVfModuleInstance(String request, @PathParam("version") String version,
 674             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 675             @PathParam("vfmoduleInstanceId") String vfmoduleInstanceId, @Context ContainerRequestContext requestContext)
 676             throws ApiException {
 677         String requestId = requestHandlerUtils.getRequestId(requestContext);
 678         HashMap<String, String> instanceIdMap = new HashMap<>();
 679         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 680         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 681         instanceIdMap.put("vfModuleInstanceId", vfmoduleInstanceId);
 682         Response response = serviceInstances(request, Action.deactivateAndCloudDelete, instanceIdMap, version,
 683                 requestId, requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 684         return response;
 685     }
 686
 687     @POST
 688     @Path("/{version:[vV][7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/vfModules/scaleOut")
 689     @Consumes(MediaType.APPLICATION_JSON)
 690     @Produces(MediaType.APPLICATION_JSON)
 691     @Operation(description = "VF Auto Scale Out", responses = @ApiResponse(
 692             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 693     @Transactional
 694     public Response scaleOutVfModule(String request, @PathParam("version") String version,
 695             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 696             @Context ContainerRequestContext requestContext) throws ApiException {
 697         String requestId = requestHandlerUtils.getRequestId(requestContext);
 698         HashMap<String, String> instanceIdMap = new HashMap<>();
 699         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 700         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 701         return serviceInstances(request, Action.scaleOut, instanceIdMap, version, requestId,
 702                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 703     }
 704
 705     @POST
 706     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/volumeGroups")
 707     @Consumes(MediaType.APPLICATION_JSON)
 708     @Produces(MediaType.APPLICATION_JSON)
 709     @Operation(description = "Create VolumeGroup on a specified version, serviceInstance, vnfInstance",
 710             responses = @ApiResponse(
 711                     content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 712     @Transactional
 713     public Response createVolumeGroupInstance(String request, @PathParam("version") String version,
 714             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 715             @Context ContainerRequestContext requestContext) throws ApiException {
 716         String requestId = requestHandlerUtils.getRequestId(requestContext);
 717         HashMap<String, String> instanceIdMap = new HashMap<>();
 718         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 719         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 720         return serviceInstances(request, Action.createInstance, instanceIdMap, version, requestId,
 721                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 722     }
 723
 724     @PUT
 725     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/volumeGroups/{volumeGroupInstanceId}")
 726     @Consumes(MediaType.APPLICATION_JSON)
 727     @Produces(MediaType.APPLICATION_JSON)
 728     @Operation(description = "Update VolumeGroup on a specified version, serviceInstance, vnfInstance and volumeGroup",
 729             responses = @ApiResponse(
 730                     content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 731     @Transactional
 732     public Response updateVolumeGroupInstance(String request, @PathParam("version") String version,
 733             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 734             @PathParam("volumeGroupInstanceId") String volumeGroupInstanceId,
 735             @Context ContainerRequestContext requestContext) throws ApiException {
 736         String requestId = requestHandlerUtils.getRequestId(requestContext);
 737         HashMap<String, String> instanceIdMap = new HashMap<>();
 738         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 739         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 740         instanceIdMap.put("volumeGroupInstanceId", volumeGroupInstanceId);
 741         return serviceInstances(request, Action.updateInstance, instanceIdMap, version, requestId,
 742                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 743     }
 744
 745     @DELETE
 746     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/volumeGroups/{volumeGroupInstanceId}")
 747     @Consumes(MediaType.APPLICATION_JSON)
 748     @Produces(MediaType.APPLICATION_JSON)
 749     @Operation(description = "Delete provided VolumeGroup instance", responses = @ApiResponse(
 750             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 751     @Transactional
 752     public Response deleteVolumeGroupInstance(String request, @PathParam("version") String version,
 753             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 754             @PathParam("volumeGroupInstanceId") String volumeGroupInstanceId,
 755             @Context ContainerRequestContext requestContext) throws ApiException {
 756         String requestId = requestHandlerUtils.getRequestId(requestContext);
 757         HashMap<String, String> instanceIdMap = new HashMap<>();
 758         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 759         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 760         instanceIdMap.put("volumeGroupInstanceId", volumeGroupInstanceId);
 761         return serviceInstances(request, Action.deleteInstance, instanceIdMap, version, requestId,
 762                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 763     }
 764
 765
 766     @POST
 767     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/pnfs")
 768     @Consumes(MediaType.APPLICATION_JSON)
 769     @Produces(MediaType.APPLICATION_JSON)
 770     @Operation(description = "Create VNF on a specified version and serviceInstance", responses = @ApiResponse(
 771             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 772     @Transactional
 773     public Response createPnfInstance(String request, @PathParam("version") String version,
 774             @PathParam("serviceInstanceId") String serviceInstanceId, @Context ContainerRequestContext requestContext)
 775             throws ApiException {
 776         String requestId = requestHandlerUtils.getRequestId(requestContext);
 777         HashMap<String, String> instanceIdMap = new HashMap<>();
 778         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 779         try {
 780             return serviceInstances(request, Action.createInstance, instanceIdMap, version, requestId,
 781                     requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 782         } catch (Exception e) {
 783             logger.error("Error in pnf", e);
 784             throw e;
 785         }
 786     }
 787
 788
 789     @DELETE
 790     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/pnfs/{pnfInstanceId}")
 791     @Consumes(MediaType.APPLICATION_JSON)
 792     @Produces(MediaType.APPLICATION_JSON)
 793     @Operation(description = "Create PNF on a specified version and serviceInstance", responses = @ApiResponse(
 794             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 795     @Transactional
 796     public Response deletePnfInstance(String request, @PathParam("version") String version,
 797             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("pnfInstanceId") String pnfInstanceId,
 798             @Context ContainerRequestContext requestContext) throws ApiException {
 799         String requestId = requestHandlerUtils.getRequestId(requestContext);
 800         HashMap<String, String> instanceIdMap = new HashMap<>();
 801         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 802         instanceIdMap.put("pnfInstanceId", pnfInstanceId);
 803         try {
 804             return serviceInstances(request, Action.deleteInstance, instanceIdMap, version, requestId,
 805                     requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 806         } catch (Exception e) {
 807             logger.error("Error in pnf", e);
 808             throw e;
 809         }
 810     }
 811
 812     @POST
 813     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/networks")
 814     @Consumes(MediaType.APPLICATION_JSON)
 815     @Produces(MediaType.APPLICATION_JSON)
 816     @Operation(description = "Create NetworkInstance on a specified version and serviceInstance ",
 817             responses = @ApiResponse(
 818                     content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 819     @Transactional
 820     public Response createNetworkInstance(String request, @PathParam("version") String version,
 821             @PathParam("serviceInstanceId") String serviceInstanceId, @Context ContainerRequestContext requestContext)
 822             throws ApiException {
 823         String requestId = requestHandlerUtils.getRequestId(requestContext);
 824         HashMap<String, String> instanceIdMap = new HashMap<>();
 825         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 826         return serviceInstances(request, Action.createInstance, instanceIdMap, version, requestId,
 827                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 828     }
 829
 830     @PUT
 831     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/networks/{networkInstanceId}")
 832     @Consumes(MediaType.APPLICATION_JSON)
 833     @Produces(MediaType.APPLICATION_JSON)
 834     @Operation(description = "Update VolumeGroup on a specified version, serviceInstance, networkInstance",
 835             responses = @ApiResponse(
 836                     content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 837     @Transactional
 838     public Response updateNetworkInstance(String request, @PathParam("version") String version,
 839             @PathParam("serviceInstanceId") String serviceInstanceId,
 840             @PathParam("networkInstanceId") String networkInstanceId, @Context ContainerRequestContext requestContext)
 841             throws ApiException {
 842         String requestId = requestHandlerUtils.getRequestId(requestContext);
 843         HashMap<String, String> instanceIdMap = new HashMap<>();
 844         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 845         instanceIdMap.put("networkInstanceId", networkInstanceId);
 846         return serviceInstances(request, Action.updateInstance, instanceIdMap, version, requestId,
 847                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 848     }
 849
 850     @DELETE
 851     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/networks/{networkInstanceId}")
 852     @Consumes(MediaType.APPLICATION_JSON)
 853     @Produces(MediaType.APPLICATION_JSON)
 854     @Operation(description = "Delete provided Network instance", responses = @ApiResponse(
 855             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 856     @Transactional
 857     public Response deleteNetworkInstance(String request, @PathParam("version") String version,
 858             @PathParam("serviceInstanceId") String serviceInstanceId,
 859             @PathParam("networkInstanceId") String networkInstanceId, @Context ContainerRequestContext requestContext)
 860             throws ApiException {
 861         String requestId = requestHandlerUtils.getRequestId(requestContext);
 862         HashMap<String, String> instanceIdMap = new HashMap<>();
 863         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 864         instanceIdMap.put("networkInstanceId", networkInstanceId);
 865         return serviceInstances(request, Action.deleteInstance, instanceIdMap, version, requestId,
 866                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 867     }
 868
 869     @POST
 870     @Path("/{version:[vV][7]}/instanceGroups")
 871     @Consumes(MediaType.APPLICATION_JSON)
 872     @Produces(MediaType.APPLICATION_JSON)
 873     @Operation(description = "Create instanceGroups", responses = @ApiResponse(
 874             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 875     @Transactional
 876     public Response createInstanceGroups(String request, @PathParam("version") String version,
 877             @Context ContainerRequestContext requestContext) throws ApiException {
 878         String requestId = requestHandlerUtils.getRequestId(requestContext);
 879         return serviceInstances(request, Action.createInstance, null, version, requestId,
 880                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 881     }
 882
 883     @DELETE
 884     @Path("/{version:[vV][7]}/instanceGroups/{instanceGroupId}")
 885     @Consumes(MediaType.APPLICATION_JSON)
 886     @Produces(MediaType.APPLICATION_JSON)
 887     @Operation(description = "Delete instanceGroup", responses = @ApiResponse(
 888             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 889     @Transactional
 890     public Response deleteInstanceGroups(@PathParam("version") String version,
 891             @PathParam("instanceGroupId") String instanceGroupId, @Context ContainerRequestContext requestContext)
 892             throws ApiException {
 893         String requestId = requestHandlerUtils.getRequestId(requestContext);
 894         HashMap<String, String> instanceIdMap = new HashMap<>();
 895         instanceIdMap.put(CommonConstants.INSTANCE_GROUP_INSTANCE_ID, instanceGroupId);
 896         return deleteInstanceGroups(Action.deleteInstance, instanceIdMap, version, requestId,
 897                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix), requestContext);
 898     }
 899
 900     @POST
 901     @Path("/{version:[vV][7]}/instanceGroups/{instanceGroupId}/addMembers")
 902     @Consumes(MediaType.APPLICATION_JSON)
 903     @Produces(MediaType.APPLICATION_JSON)
 904     @Operation(description = "Add instanceGroup members", responses = @ApiResponse(
 905             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 906     @Transactional
 907     public Response addInstanceGroupMembers(String request, @PathParam("version") String version,
 908             @PathParam("instanceGroupId") String instanceGroupId, @Context ContainerRequestContext requestContext)
 909             throws ApiException {
 910         String requestId = requestHandlerUtils.getRequestId(requestContext);
 911         HashMap<String, String> instanceIdMap = new HashMap<>();
 912         instanceIdMap.put(CommonConstants.INSTANCE_GROUP_INSTANCE_ID, instanceGroupId);
 913         return serviceInstances(request, Action.addMembers, instanceIdMap, version, requestId,
 914                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 915     }
 916
 917     @POST
 918     @Path("/{version:[vV][7]}/instanceGroups/{instanceGroupId}/removeMembers")
 919     @Consumes(MediaType.APPLICATION_JSON)
 920     @Produces(MediaType.APPLICATION_JSON)
 921     @Operation(description = "Remove instanceGroup members", responses = @ApiResponse(
 922             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 923     @Transactional
 924     public Response removeInstanceGroupMembers(String request, @PathParam("version") String version,
 925             @PathParam("instanceGroupId") String instanceGroupId, @Context ContainerRequestContext requestContext)
 926             throws ApiException {
 927         String requestId = requestHandlerUtils.getRequestId(requestContext);
 928         HashMap<String, String> instanceIdMap = new HashMap<>();
 929         instanceIdMap.put(CommonConstants.INSTANCE_GROUP_INSTANCE_ID, instanceGroupId);
 930         return serviceInstances(request, Action.removeMembers, instanceIdMap, version, requestId,
 931                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 932     }
 933
 934     /**
 935      * This method is used for POST a request to the BPEL client (BPMN).
 936      *
 937      * Convert the requestJson to ServiceInstanceRequest(sir), create the msoRequest object, check whether this request
 938      * is already being processed in requestdb for duplicate check.
 939      *
 940      * Based on the alacarte flag, sir and msoRequest will do the recipe lookup from the service and servicerecipe table
 941      * of catalogdb, and get the OrchestrationURI.
 942      *
 943      * If the present request is not the duplicate request then this request will be saved in the requestdb. and will
 944      * POST a request to the BPMN engine at the OrchestrationURI fetched.
 945      *
 946      * @param requestJSON Json fetched as body in the API call
 947      * @param action Type of action to be performed
 948      * @param instanceIdMap Map of instance ids of service/vnf/vf/configuration etc..
 949      * @param version Supported version of API
 950      * @param requestId Unique id for the request
 951      * @param requestUri
 952      * @return response object
 953      * @throws ApiException
 954      */
 955     public Response serviceInstances(String requestJSON, Actions action, HashMap<String, String> instanceIdMap,
 956             String version, String requestId, String requestUri) throws ApiException {
 957         return serviceInstances(requestJSON, action, instanceIdMap, version, requestId, requestUri, null);
 958
 959     }
 960
 961     public Response serviceInstances(String requestJSON, Actions action, HashMap<String, String> instanceIdMap,
 962             String version, String requestId, String requestUri, HashMap<String, String> queryParams)
 963             throws ApiException {
 964         String serviceInstanceId;
 965         Boolean aLaCarte = null;
 966         ServiceInstancesRequest sir;
 967         String apiVersion = version.substring(1);
 968
 969         sir = requestHandlerUtils.convertJsonToServiceInstanceRequest(requestJSON, action, requestId, requestUri);
 970         action = handleReplaceInstance(action, sir);
 971
 972         String requestScope = requestHandlerUtils.deriveRequestScope(action, sir, requestUri);
 973         try {
 974             requestValidatorListenerRunner.runValidations(requestUri, instanceIdMap, sir, queryParams, action);
 975         } catch (ApiException e) {
 976             msoRequest.createErrorRequestRecord(Status.FAILED, requestId, e.getMessage(), action, requestScope,
 977                     requestJSON, requestHandlerUtils
 978                             .getServiceInstanceIdForValidationError(sir, instanceIdMap, requestScope).orElse(null),
 979                     sir);
 980             throw e;
 981         }
 982
 983         InfraActiveRequests currentActiveReq =
 984                 msoRequest.createRequestObject(sir, action, requestId, Status.IN_PROGRESS, requestJSON, requestScope);
 985         if (sir.getRequestDetails().getRequestParameters() != null) {
 986             aLaCarte = sir.getRequestDetails().getRequestParameters().getALaCarte();
 987         }
 988
 989         requestHandlerUtils.parseRequest(sir, instanceIdMap, action, version, requestJSON, aLaCarte, requestId,
 990                 currentActiveReq);
 991         if ((action == Action.replaceInstance || action == Action.replaceInstanceRetainAssignments)
 992                 && (requestScope.equals(ModelType.vnf.toString()) || requestScope.equals(ModelType.vfModule.toString())
 993                         || requestScope.equals(ModelType.cnf.toString()))
 994                 && sir.getRequestDetails().getCloudConfiguration() == null) {
 995             CloudConfiguration cloudConfiguration =
 996                     getCloudConfigurationOnReplace(requestScope, instanceIdMap, currentActiveReq);
 997             sir.getRequestDetails().setCloudConfiguration(cloudConfiguration);
 998             setCloudConfigurationCurrentActiveRequest(cloudConfiguration, currentActiveReq);
 999         }
1000         requestHandlerUtils.setInstanceId(currentActiveReq, requestScope, null, instanceIdMap);
1001
1002         String instanceName = null;
1003         if (sir.getRequestDetails().getRequestInfo() != null) {
1004             instanceName = sir.getRequestDetails().getRequestInfo().getInstanceName();
1005         }
1006         boolean alaCarteFlag = msoRequest.getAlacarteFlag(sir);
1007         String vnfType = msoRequest.getVnfType(sir, requestScope);
1008         String networkType = msoRequest.getNetworkType(sir, requestScope);
1009         String sdcServiceModelVersion = msoRequest.getSDCServiceModelVersion(sir);
1010         String vfModuleType = msoRequest.getVfModuleType(sir, requestScope);
1011
1012         if (requestScope.equalsIgnoreCase(ModelType.vnf.name()) && vnfType != null) {
1013             currentActiveReq.setVnfType(vnfType);
1014         } else if (requestScope.equalsIgnoreCase(ModelType.network.name()) && networkType != null) {
1015             currentActiveReq.setNetworkType(networkType);
1016         }
1017
1018         requestHandlerUtils.checkForDuplicateRequests(action, instanceIdMap, requestScope, currentActiveReq,
1019                 instanceName);
1020
1021         ServiceInstancesResponse serviceResponse = new ServiceInstancesResponse();
1022
1023         RequestReferences referencesResponse = new RequestReferences();
1024
1025         referencesResponse.setRequestId(requestId);
1026
1027         serviceResponse.setRequestReferences(referencesResponse);
1028         RecipeLookupResult recipeLookupResult =
1029                 requestHandlerUtils.getServiceInstanceOrchestrationURI(sir, action, alaCarteFlag, currentActiveReq);
1030         String serviceInstanceType = requestHandlerUtils.getServiceType(requestScope, sir, alaCarteFlag);
1031
1032         ModelInfo modelInfo = sir.getRequestDetails().getModelInfo();
1033         ModelType modelType = requestHandlerUtils.getModelType(action, modelInfo);
1034
1035         Boolean isBaseVfModule = false;
1036
1037         if (modelType.equals(ModelType.vfModule)) {
1038             isBaseVfModule = requestHandlerUtils.getIsBaseVfModule(modelInfo, action, vnfType, sdcServiceModelVersion,
1039                     currentActiveReq);
1040         }
1041
1042         serviceInstanceId = requestHandlerUtils.setServiceInstanceId(requestScope, sir);
1043         String vnfId = "";
1044         String vfModuleId = "";
1045         String volumeGroupId = "";
1046         String networkId = "";
1047         String pnfCorrelationId = "";
1048         String instanceGroupId = null;
1049
1050         if (sir.getVnfInstanceId() != null) {
1051             vnfId = sir.getVnfInstanceId();
1052         }
1053
1054         if (sir.getVfModuleInstanceId() != null) {
1055             vfModuleId = sir.getVfModuleInstanceId();
1056         }
1057
1058         if (sir.getVolumeGroupInstanceId() != null) {
1059             volumeGroupId = sir.getVolumeGroupInstanceId();
1060         }
1061
1062         if (sir.getNetworkInstanceId() != null) {
1063             networkId = sir.getNetworkInstanceId();
1064         }
1065         if (sir.getInstanceGroupId() != null) {
1066             instanceGroupId = sir.getInstanceGroupId();
1067         }
1068
1069         pnfCorrelationId = getPnfCorrelationId(sir);
1070
1071         try {
1072             infraActiveRequestsClient.save(currentActiveReq);
1073         } catch (Exception e) {
1074             logger.error("Exception occurred", e);
1075             ErrorLoggerInfo errorLoggerInfo =
1076                     new ErrorLoggerInfo.Builder(MessageEnum.APIH_DB_ACCESS_EXC, ErrorCode.DataError)
1077                             .errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
1078             throw new RequestDbFailureException.Builder(SAVE_TO_DB, e.toString(), HttpStatus.SC_INTERNAL_SERVER_ERROR,
1079                     ErrorNumbers.SVC_DETAILED_SERVICE_ERROR).cause(e).errorInfo(errorLoggerInfo).build();
1080         }
1081
1082         if (!requestScope.equalsIgnoreCase(ModelType.service.name()) && action != Action.recreateInstance
1083                 && !requestScope.equalsIgnoreCase(ModelType.vnf.name())
1084                 && !requestScope.equalsIgnoreCase(ModelType.pnf.name())) {
1085             aLaCarte = true;
1086         } else if (aLaCarte == null) {
1087             aLaCarte = false;
1088         }
1089
1090
1091         RequestClientParameter requestClientParameter;
1092         try {
1093             requestClientParameter = new RequestClientParameter.Builder().setRequestId(requestId)
1094                     .setBaseVfModule(isBaseVfModule).setRecipeTimeout(recipeLookupResult.getRecipeTimeout())
1095                     .setRequestAction(action.toString()).setServiceInstanceId(serviceInstanceId)
1096                     .setPnfCorrelationId(pnfCorrelationId).setVnfId(vnfId).setVfModuleId(vfModuleId)
1097                     .setVolumeGroupId(volumeGroupId).setNetworkId(networkId).setServiceType(serviceInstanceType)
1098                     .setVnfType(vnfType).setVfModuleType(vfModuleType).setNetworkType(networkType)
1099                     .setRequestDetails(requestHandlerUtils.mapJSONtoMSOStyle(requestJSON, sir, aLaCarte, action))
1100                     .setApiVersion(apiVersion).setALaCarte(aLaCarte).setRequestUri(requestUri)
1101                     .setInstanceGroupId(instanceGroupId).build();
1102         } catch (IOException e) {
1103             logger.error("Exception occurred", e);
1104             ErrorLoggerInfo errorLoggerInfo =
1105                     new ErrorLoggerInfo.Builder(MessageEnum.APIH_BPEL_RESPONSE_ERROR, ErrorCode.SchemaError)
1106                             .errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
1107             throw new ValidateException.Builder("Unable to generate RequestClientParamter object" + e.getMessage(),
1108                     HttpStatus.SC_INTERNAL_SERVER_ERROR, ErrorNumbers.SVC_BAD_PARAMETER).errorInfo(errorLoggerInfo)
1109                             .build();
1110         }
1111         return requestHandlerUtils.postBPELRequest(currentActiveReq, requestClientParameter,
1112                 recipeLookupResult.getOrchestrationURI(), requestScope);
1113     }
1114
1115     /**
1116      * @param action
1117      * @param sir
1118      * @return
1119      */
1120     protected Actions handleReplaceInstance(Actions action, ServiceInstancesRequest sir) {
1121         if (action != null && action.equals(Action.replaceInstance)
1122                 && sir.getRequestDetails().getRequestParameters().getRetainAssignments() != null
1123                 && sir.getRequestDetails().getRequestParameters().getRetainAssignments()) {
1124             action = Action.replaceInstanceRetainAssignments;
1125         }
1126         return action;
1127     }
1128
1129     /**
1130      * This method deletes the Instance Groups.
1131      *
1132      * This method will check whether the request is not duplicate in requestdb. if its not then will save as a new
1133      * request. And will send a POST request to BEPL client to delete the Insatnce Groups.
1134      *
1135      * @param action
1136      * @param instanceIdMap
1137      * @param version
1138      * @param requestId
1139      * @param requestUri
1140      * @param requestContext
1141      * @return
1142      * @throws ApiException
1143      */
1144     public Response deleteInstanceGroups(Actions action, HashMap<String, String> instanceIdMap, String version,
1145             String requestId, String requestUri, ContainerRequestContext requestContext) throws ApiException {
1146         String instanceGroupId = instanceIdMap.get(CommonConstants.INSTANCE_GROUP_INSTANCE_ID);
1147         Boolean aLaCarte = true;
1148         String apiVersion = version.substring(1);
1149         ServiceInstancesRequest sir = new ServiceInstancesRequest();
1150         sir.setInstanceGroupId(instanceGroupId);
1151
1152         String requestScope = ModelType.instanceGroup.toString();
1153         InfraActiveRequests currentActiveReq =
1154                 msoRequest.createRequestObject(sir, action, requestId, Status.IN_PROGRESS, null, requestScope);
1155         requestHandlerUtils.setInstanceId(currentActiveReq, requestScope, null, instanceIdMap);
1156         try {
1157             requestHandlerUtils.validateHeaders(requestContext);
1158         } catch (ValidationException e) {
1159             logger.error("Exception occurred", e);
1160             ErrorLoggerInfo errorLoggerInfo =
1161                     new ErrorLoggerInfo.Builder(MessageEnum.APIH_VALIDATION_ERROR, ErrorCode.SchemaError)
1162                             .errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
1163             ValidateException validateException =
1164                     new ValidateException.Builder(e.getMessage(), HttpStatus.SC_BAD_REQUEST,
1165                             ErrorNumbers.SVC_BAD_PARAMETER).cause(e).errorInfo(errorLoggerInfo).build();
1166             requestHandlerUtils.updateStatus(currentActiveReq, Status.FAILED, validateException.getMessage());
1167             throw validateException;
1168         }
1169
1170         requestHandlerUtils.checkForDuplicateRequests(action, instanceIdMap, requestScope, currentActiveReq, null);
1171
1172         ServiceInstancesResponse serviceResponse = new ServiceInstancesResponse();
1173
1174         RequestReferences referencesResponse = new RequestReferences();
1175
1176         referencesResponse.setRequestId(requestId);
1177
1178         serviceResponse.setRequestReferences(referencesResponse);
1179         Boolean isBaseVfModule = false;
1180
1181         RecipeLookupResult recipeLookupResult = new RecipeLookupResult("/mso/async/services/WorkflowActionBB", 180);
1182
1183         try {
1184             infraActiveRequestsClient.save(currentActiveReq);
1185         } catch (Exception e) {
1186             logger.error("Exception occurred", e);
1187             ErrorLoggerInfo errorLoggerInfo =
1188                     new ErrorLoggerInfo.Builder(MessageEnum.APIH_DB_ACCESS_EXC, ErrorCode.DataError)
1189                             .errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
1190             throw new RequestDbFailureException.Builder(SAVE_TO_DB, e.toString(), HttpStatus.SC_INTERNAL_SERVER_ERROR,
1191                     ErrorNumbers.SVC_DETAILED_SERVICE_ERROR).cause(e).errorInfo(errorLoggerInfo).build();
1192         }
1193
1194         RequestClientParameter requestClientParameter = new RequestClientParameter.Builder().setRequestId(requestId)
1195                 .setBaseVfModule(isBaseVfModule).setRecipeTimeout(recipeLookupResult.getRecipeTimeout())
1196                 .setRequestAction(action.toString()).setApiVersion(apiVersion).setALaCarte(aLaCarte)
1197                 .setRequestUri(requestUri).setInstanceGroupId(instanceGroupId).build();
1198
1199
1200         return requestHandlerUtils.postBPELRequest(currentActiveReq, requestClientParameter,
1201                 recipeLookupResult.getOrchestrationURI(), requestScope);
1202     }
1203
1204     protected String getPnfCorrelationId(ServiceInstancesRequest sir) {
1205         return Optional.of(sir).map(ServiceInstancesRequest::getRequestDetails)
1206                 .map(RequestDetails::getRequestParameters).map(parameters -> parameters.getUserParamValue("pnfId"))
1207                 .orElse("");
1208     }
1209
1210     private Response configurationRecipeLookup(String requestJSON, Action action, HashMap<String, String> instanceIdMap,
1211             String version, String requestId, String requestUri) throws ApiException {
1212         String serviceInstanceId;
1213         Boolean aLaCarte = null;
1214         String apiVersion = version.substring(1);
1215         ServiceInstancesRequest sir;
1216
1217         sir = requestHandlerUtils.convertJsonToServiceInstanceRequest(requestJSON, action, requestId, requestUri);
1218         String requestScope = requestHandlerUtils.deriveRequestScope(action, sir, requestUri);
1219         InfraActiveRequests currentActiveReq =
1220                 msoRequest.createRequestObject(sir, action, requestId, Status.IN_PROGRESS, requestJSON, requestScope);
1221         if (sir.getRequestDetails().getRequestParameters() != null) {
1222             aLaCarte = sir.getRequestDetails().getRequestParameters().getALaCarte();
1223         }
1224
1225         requestHandlerUtils.parseRequest(sir, instanceIdMap, action, version, requestJSON, aLaCarte, requestId,
1226                 currentActiveReq);
1227         requestHandlerUtils.setInstanceId(currentActiveReq, requestScope, null, instanceIdMap);
1228         String instanceName = sir.getRequestDetails().getRequestInfo().getInstanceName();
1229
1230         requestHandlerUtils.checkForDuplicateRequests(action, instanceIdMap, requestScope, currentActiveReq,
1231                 instanceName);
1232
1233         ServiceInstancesResponse serviceResponse = new ServiceInstancesResponse();
1234         RequestReferences referencesResponse = new RequestReferences();
1235         referencesResponse.setRequestId(requestId);
1236         serviceResponse.setRequestReferences(referencesResponse);
1237
1238         String orchestrationUri = env.getProperty(CommonConstants.ALACARTE_ORCHESTRATION);
1239         String timeOut = env.getProperty(CommonConstants.ALACARTE_RECIPE_TIMEOUT);
1240
1241         if (StringUtils.isBlank(orchestrationUri) || StringUtils.isBlank(timeOut)) {
1242             String error = StringUtils.isBlank(orchestrationUri) ? "ALaCarte Orchestration URI not found in properties"
1243                     : "ALaCarte Recipe Timeout not found in properties";
1244
1245             ErrorLoggerInfo errorLoggerInfo =
1246                     new ErrorLoggerInfo.Builder(MessageEnum.APIH_DB_ATTRIBUTE_NOT_FOUND, ErrorCode.DataError)
1247                             .errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
1248
1249             ValidateException validateException = new ValidateException.Builder(error, HttpStatus.SC_NOT_FOUND,
1250                     ErrorNumbers.SVC_GENERAL_SERVICE_ERROR).errorInfo(errorLoggerInfo).build();
1251
1252             requestHandlerUtils.updateStatus(currentActiveReq, Status.FAILED, validateException.getMessage());
1253
1254             throw validateException;
1255
1256         }
1257
1258         serviceInstanceId = "";
1259         String configurationId = "";
1260         String pnfCorrelationId = "";
1261
1262         if (sir.getServiceInstanceId() != null) {
1263             serviceInstanceId = sir.getServiceInstanceId();
1264         }
1265
1266         if (sir.getConfigurationId() != null) {
1267             configurationId = sir.getConfigurationId();
1268         }
1269
1270         pnfCorrelationId = getPnfCorrelationId(sir);
1271
1272         try {
1273             infraActiveRequestsClient.save(currentActiveReq);
1274         } catch (Exception e) {
1275             ErrorLoggerInfo errorLoggerInfo =
1276                     new ErrorLoggerInfo.Builder(MessageEnum.APIH_DB_ACCESS_EXC, ErrorCode.DataError)
1277                             .errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
1278             throw new RequestDbFailureException.Builder(SAVE_TO_DB, e.toString(), HttpStatus.SC_INTERNAL_SERVER_ERROR,
1279                     ErrorNumbers.SVC_DETAILED_SERVICE_ERROR).cause(e).errorInfo(errorLoggerInfo).build();
1280         }
1281
1282         if (!requestScope.equalsIgnoreCase(ModelType.service.name())) {
1283             aLaCarte = true;
1284         } else if (aLaCarte == null) {
1285             aLaCarte = false;
1286         }
1287         RequestClientParameter requestClientParameter = null;
1288         try {
1289             requestClientParameter = new RequestClientParameter.Builder().setRequestId(requestId).setBaseVfModule(false)
1290                     .setRecipeTimeout(Integer.parseInt(timeOut)).setRequestAction(action.toString())
1291                     .setServiceInstanceId(serviceInstanceId).setPnfCorrelationId(pnfCorrelationId)
1292                     .setConfigurationId(configurationId)
1293                     .setRequestDetails(requestHandlerUtils.mapJSONtoMSOStyle(requestJSON, sir, aLaCarte, action))
1294                     .setApiVersion(apiVersion).setALaCarte(aLaCarte).setRequestUri(requestUri).build();
1295         } catch (IOException e) {
1296             ErrorLoggerInfo errorLoggerInfo =
1297                     new ErrorLoggerInfo.Builder(MessageEnum.APIH_BPEL_RESPONSE_ERROR, ErrorCode.SchemaError)
1298                             .errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
1299             throw new ValidateException.Builder("Unable to generate RequestClientParamter object" + e.getMessage(),
1300                     HttpStatus.SC_INTERNAL_SERVER_ERROR, ErrorNumbers.SVC_BAD_PARAMETER).errorInfo(errorLoggerInfo)
1301                             .build();
1302         }
1303
1304         return requestHandlerUtils.postBPELRequest(currentActiveReq, requestClientParameter, orchestrationUri,
1305                 requestScope);
1306     }
1307
1308     protected CloudConfiguration getCloudConfigurationOnReplace(String requestScope,
1309             HashMap<String, String> instanceIdMap, InfraActiveRequests currentActiveReq) throws ApiException {
1310         logger.debug("Replace request is missing cloudConfiguration, autofilling from create.");
1311         CloudConfiguration cloudConfiguration = null;
1312         if (requestScope.equals(ModelType.vfModule.toString())) {
1313             cloudConfiguration = bpmnRequestBuilder.getCloudConfigurationVfModuleReplace(
1314                     instanceIdMap.get("vnfInstanceId"), instanceIdMap.get("vfModuleInstanceId"));
1315         } else {
1316             cloudConfiguration = bpmnRequestBuilder.mapCloudConfigurationVnf(instanceIdMap.get("vnfInstanceId"));
1317         }
1318
1319         if (cloudConfiguration == null) {
1320             String errorMessage = "CloudConfiguration not found during autofill for replace request.";
1321             logger.error(errorMessage);
1322             updateStatus(currentActiveReq, Status.FAILED, errorMessage);
1323             throw new CloudConfigurationNotFoundException(
1324                     "CloudConfiguration not found during autofill for replace request.");
1325         }
1326         return cloudConfiguration;
1327     }
1328
1329     protected void setCloudConfigurationCurrentActiveRequest(CloudConfiguration cloudConfiguration,
1330             InfraActiveRequests currentActiveRequest) {
1331         if (cloudConfiguration.getLcpCloudRegionId() != null) {
1332             currentActiveRequest.setCloudRegion(cloudConfiguration.getLcpCloudRegionId());
1333         }
1334
1335         if (cloudConfiguration.getTenantId() != null) {
1336             currentActiveRequest.setTenantId(cloudConfiguration.getTenantId());
1337         }
1338     }
1339 }