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