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     @PUT
 436     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}")
 437     @Consumes(MediaType.APPLICATION_JSON)
 438     @Produces(MediaType.APPLICATION_JSON)
 439     @Operation(description = "Update VNF on a specified version, serviceInstance and vnfInstance",
 440             responses = @ApiResponse(
 441                     content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 442     @Transactional
 443     public Response updateVnfInstance(String request, @PathParam("version") String version,
 444             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 445             @Context ContainerRequestContext requestContext) throws ApiException {
 446         String requestId = requestHandlerUtils.getRequestId(requestContext);
 447         HashMap<String, String> instanceIdMap = new HashMap<>();
 448         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 449         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 450         return serviceInstances(request, Action.updateInstance, instanceIdMap, version, requestId,
 451                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 452     }
 453
 454     @POST
 455     @Path("/{version:[vV][6-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/applyUpdatedConfig")
 456     @Consumes(MediaType.APPLICATION_JSON)
 457     @Produces(MediaType.APPLICATION_JSON)
 458     @Operation(description = "Apply updated configuration", responses = @ApiResponse(
 459             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 460     public Response applyUpdatedConfig(String request, @PathParam("version") String version,
 461             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 462             @Context ContainerRequestContext requestContext) throws ApiException {
 463         String requestId = requestHandlerUtils.getRequestId(requestContext);
 464         HashMap<String, String> instanceIdMap = new HashMap<>();
 465         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 466         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 467         return serviceInstances(request, Action.applyUpdatedConfig, instanceIdMap, version, requestId,
 468                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 469     }
 470
 471     @POST
 472     @Path("/{version:[vV][7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/recreate")
 473     @Consumes(MediaType.APPLICATION_JSON)
 474     @Produces(MediaType.APPLICATION_JSON)
 475     @Operation(description = "Recreate VNF Instance", responses = @ApiResponse(
 476             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 477     public Response recreateVnfInstance(String request, @PathParam("version") String version,
 478             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 479             @Context ContainerRequestContext requestContext) throws ApiException {
 480         String requestId = requestHandlerUtils.getRequestId(requestContext);
 481         HashMap<String, String> instanceIdMap = new HashMap<>();
 482         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 483         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 484         return serviceInstances(request, Action.recreateInstance, instanceIdMap, version, requestId,
 485                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 486     }
 487
 488     @DELETE
 489     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}")
 490     @Consumes(MediaType.APPLICATION_JSON)
 491     @Produces(MediaType.APPLICATION_JSON)
 492     @Operation(description = "Delete provided VNF instance", responses = @ApiResponse(
 493             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 494     @Transactional
 495     public Response deleteVnfInstance(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.deleteInstance, instanceIdMap, version, requestId,
 503                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 504     }
 505
 506     @POST
 507     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/vfModules")
 508     @Consumes(MediaType.APPLICATION_JSON)
 509     @Produces(MediaType.APPLICATION_JSON)
 510     @Operation(description = "Create VfModule on a specified version, serviceInstance and vnfInstance",
 511             responses = @ApiResponse(
 512                     content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 513     @Transactional
 514     public Response createVfModuleInstance(String request, @PathParam("version") String version,
 515             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 516             @Context ContainerRequestContext requestContext) throws ApiException {
 517         String requestId = requestHandlerUtils.getRequestId(requestContext);
 518         HashMap<String, String> instanceIdMap = new HashMap<>();
 519         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 520         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 521         return serviceInstances(request, Action.createInstance, instanceIdMap, version, requestId,
 522                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 523     }
 524
 525     @POST
 526     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/vfModules/{vfmoduleInstanceId}/replace")
 527     @Consumes(MediaType.APPLICATION_JSON)
 528     @Produces(MediaType.APPLICATION_JSON)
 529     @Operation(description = "Create VfModule on a specified version, serviceInstance and vnfInstance",
 530             responses = @ApiResponse(
 531                     content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 532     @Transactional
 533     public Response replaceVfModuleInstance(String request, @PathParam("version") String version,
 534             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 535             @PathParam("vfmoduleInstanceId") String vfmoduleInstanceId, @Context ContainerRequestContext requestContext)
 536             throws ApiException {
 537         String requestId = requestHandlerUtils.getRequestId(requestContext);
 538         HashMap<String, String> instanceIdMap = new HashMap<>();
 539         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 540         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 541         instanceIdMap.put("vfModuleInstanceId", vfmoduleInstanceId);
 542         return serviceInstances(request, Action.replaceInstance, instanceIdMap, version, requestId,
 543                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 544     }
 545
 546     @PUT
 547     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/vfModules/{vfmoduleInstanceId}")
 548     @Consumes(MediaType.APPLICATION_JSON)
 549     @Produces(MediaType.APPLICATION_JSON)
 550     @Operation(description = "Update VfModule on a specified version, serviceInstance, vnfInstance and vfModule",
 551             responses = @ApiResponse(
 552                     content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 553     @Transactional
 554     public Response updateVfModuleInstance(String request, @PathParam("version") String version,
 555             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 556             @PathParam("vfmoduleInstanceId") String vfmoduleInstanceId, @Context ContainerRequestContext requestContext)
 557             throws ApiException {
 558         String requestId = requestHandlerUtils.getRequestId(requestContext);
 559         HashMap<String, String> instanceIdMap = new HashMap<>();
 560         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 561         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 562         instanceIdMap.put("vfModuleInstanceId", vfmoduleInstanceId);
 563         return serviceInstances(request, Action.updateInstance, instanceIdMap, version, requestId,
 564                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 565     }
 566
 567     @POST
 568     @Path("/{version:[vV][6-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/inPlaceSoftwareUpdate")
 569     @Consumes(MediaType.APPLICATION_JSON)
 570     @Produces(MediaType.APPLICATION_JSON)
 571     @Operation(description = "Perform VNF software update", responses = @ApiResponse(
 572             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 573     @Transactional
 574     public Response inPlaceSoftwareUpdate(String request, @PathParam("version") String version,
 575             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 576             @Context ContainerRequestContext requestContext) throws ApiException {
 577         String requestId = requestHandlerUtils.getRequestId(requestContext);
 578         HashMap<String, String> instanceIdMap = new HashMap<>();
 579         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 580         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 581         return serviceInstances(request, Action.inPlaceSoftwareUpdate, instanceIdMap, version, requestId,
 582                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 583     }
 584
 585     @DELETE
 586     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/vfModules/{vfmoduleInstanceId}")
 587     @Consumes(MediaType.APPLICATION_JSON)
 588     @Produces(MediaType.APPLICATION_JSON)
 589     @Operation(description = "Delete provided VfModule instance", responses = @ApiResponse(
 590             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 591     @Transactional
 592     public Response deleteVfModuleInstance(String request, @PathParam("version") String version,
 593             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 594             @PathParam("vfmoduleInstanceId") String vfmoduleInstanceId, @Context ContainerRequestContext requestContext)
 595             throws ApiException {
 596         String requestId = requestHandlerUtils.getRequestId(requestContext);
 597         HashMap<String, String> instanceIdMap = new HashMap<>();
 598         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 599         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 600         instanceIdMap.put("vfModuleInstanceId", vfmoduleInstanceId);
 601         return serviceInstances(request, Action.deleteInstance, instanceIdMap, version, requestId,
 602                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 603     }
 604
 605     @POST
 606     @Path("/{version:[vV][7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/vfModules/{vfmoduleInstanceId}/deactivateAndCloudDelete")
 607     @Consumes(MediaType.APPLICATION_JSON)
 608     @Produces(MediaType.APPLICATION_JSON)
 609     @Operation(description = "Deactivate and Cloud Delete VfModule instance", responses = @ApiResponse(
 610             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 611     @Transactional
 612     public Response deactivateAndCloudDeleteVfModuleInstance(String request, @PathParam("version") String version,
 613             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 614             @PathParam("vfmoduleInstanceId") String vfmoduleInstanceId, @Context ContainerRequestContext requestContext)
 615             throws ApiException {
 616         String requestId = requestHandlerUtils.getRequestId(requestContext);
 617         HashMap<String, String> instanceIdMap = new HashMap<>();
 618         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 619         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 620         instanceIdMap.put("vfModuleInstanceId", vfmoduleInstanceId);
 621         Response response = serviceInstances(request, Action.deactivateAndCloudDelete, instanceIdMap, version,
 622                 requestId, requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 623         return response;
 624     }
 625
 626     @POST
 627     @Path("/{version:[vV][7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/vfModules/scaleOut")
 628     @Consumes(MediaType.APPLICATION_JSON)
 629     @Produces(MediaType.APPLICATION_JSON)
 630     @Operation(description = "VF Auto Scale Out", responses = @ApiResponse(
 631             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 632     @Transactional
 633     public Response scaleOutVfModule(String request, @PathParam("version") String version,
 634             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 635             @Context ContainerRequestContext requestContext) throws ApiException {
 636         String requestId = requestHandlerUtils.getRequestId(requestContext);
 637         HashMap<String, String> instanceIdMap = new HashMap<>();
 638         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 639         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 640         return serviceInstances(request, Action.scaleOut, instanceIdMap, version, requestId,
 641                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 642     }
 643
 644     @POST
 645     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/volumeGroups")
 646     @Consumes(MediaType.APPLICATION_JSON)
 647     @Produces(MediaType.APPLICATION_JSON)
 648     @Operation(description = "Create VolumeGroup on a specified version, serviceInstance, vnfInstance",
 649             responses = @ApiResponse(
 650                     content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 651     @Transactional
 652     public Response createVolumeGroupInstance(String request, @PathParam("version") String version,
 653             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 654             @Context ContainerRequestContext requestContext) throws ApiException {
 655         String requestId = requestHandlerUtils.getRequestId(requestContext);
 656         HashMap<String, String> instanceIdMap = new HashMap<>();
 657         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 658         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 659         return serviceInstances(request, Action.createInstance, instanceIdMap, version, requestId,
 660                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 661     }
 662
 663     @PUT
 664     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/volumeGroups/{volumeGroupInstanceId}")
 665     @Consumes(MediaType.APPLICATION_JSON)
 666     @Produces(MediaType.APPLICATION_JSON)
 667     @Operation(description = "Update VolumeGroup on a specified version, serviceInstance, vnfInstance and volumeGroup",
 668             responses = @ApiResponse(
 669                     content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 670     @Transactional
 671     public Response updateVolumeGroupInstance(String request, @PathParam("version") String version,
 672             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 673             @PathParam("volumeGroupInstanceId") String volumeGroupInstanceId,
 674             @Context ContainerRequestContext requestContext) throws ApiException {
 675         String requestId = requestHandlerUtils.getRequestId(requestContext);
 676         HashMap<String, String> instanceIdMap = new HashMap<>();
 677         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 678         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 679         instanceIdMap.put("volumeGroupInstanceId", volumeGroupInstanceId);
 680         return serviceInstances(request, Action.updateInstance, instanceIdMap, version, requestId,
 681                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 682     }
 683
 684     @DELETE
 685     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/volumeGroups/{volumeGroupInstanceId}")
 686     @Consumes(MediaType.APPLICATION_JSON)
 687     @Produces(MediaType.APPLICATION_JSON)
 688     @Operation(description = "Delete provided VolumeGroup instance", responses = @ApiResponse(
 689             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 690     @Transactional
 691     public Response deleteVolumeGroupInstance(String request, @PathParam("version") String version,
 692             @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId,
 693             @PathParam("volumeGroupInstanceId") String volumeGroupInstanceId,
 694             @Context ContainerRequestContext requestContext) throws ApiException {
 695         String requestId = requestHandlerUtils.getRequestId(requestContext);
 696         HashMap<String, String> instanceIdMap = new HashMap<>();
 697         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 698         instanceIdMap.put("vnfInstanceId", vnfInstanceId);
 699         instanceIdMap.put("volumeGroupInstanceId", volumeGroupInstanceId);
 700         return serviceInstances(request, Action.deleteInstance, instanceIdMap, version, requestId,
 701                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 702     }
 703
 704     @POST
 705     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/networks")
 706     @Consumes(MediaType.APPLICATION_JSON)
 707     @Produces(MediaType.APPLICATION_JSON)
 708     @Operation(description = "Create NetworkInstance on a specified version and serviceInstance ",
 709             responses = @ApiResponse(
 710                     content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 711     @Transactional
 712     public Response createNetworkInstance(String request, @PathParam("version") String version,
 713             @PathParam("serviceInstanceId") String serviceInstanceId, @Context ContainerRequestContext requestContext)
 714             throws ApiException {
 715         String requestId = requestHandlerUtils.getRequestId(requestContext);
 716         HashMap<String, String> instanceIdMap = new HashMap<>();
 717         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 718         return serviceInstances(request, Action.createInstance, instanceIdMap, version, requestId,
 719                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 720     }
 721
 722     @PUT
 723     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/networks/{networkInstanceId}")
 724     @Consumes(MediaType.APPLICATION_JSON)
 725     @Produces(MediaType.APPLICATION_JSON)
 726     @Operation(description = "Update VolumeGroup on a specified version, serviceInstance, networkInstance",
 727             responses = @ApiResponse(
 728                     content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 729     @Transactional
 730     public Response updateNetworkInstance(String request, @PathParam("version") String version,
 731             @PathParam("serviceInstanceId") String serviceInstanceId,
 732             @PathParam("networkInstanceId") String networkInstanceId, @Context ContainerRequestContext requestContext)
 733             throws ApiException {
 734         String requestId = requestHandlerUtils.getRequestId(requestContext);
 735         HashMap<String, String> instanceIdMap = new HashMap<>();
 736         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 737         instanceIdMap.put("networkInstanceId", networkInstanceId);
 738         return serviceInstances(request, Action.updateInstance, instanceIdMap, version, requestId,
 739                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 740     }
 741
 742     @DELETE
 743     @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/networks/{networkInstanceId}")
 744     @Consumes(MediaType.APPLICATION_JSON)
 745     @Produces(MediaType.APPLICATION_JSON)
 746     @Operation(description = "Delete provided Network instance", responses = @ApiResponse(
 747             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 748     @Transactional
 749     public Response deleteNetworkInstance(String request, @PathParam("version") String version,
 750             @PathParam("serviceInstanceId") String serviceInstanceId,
 751             @PathParam("networkInstanceId") String networkInstanceId, @Context ContainerRequestContext requestContext)
 752             throws ApiException {
 753         String requestId = requestHandlerUtils.getRequestId(requestContext);
 754         HashMap<String, String> instanceIdMap = new HashMap<>();
 755         instanceIdMap.put("serviceInstanceId", serviceInstanceId);
 756         instanceIdMap.put("networkInstanceId", networkInstanceId);
 757         return serviceInstances(request, Action.deleteInstance, instanceIdMap, version, requestId,
 758                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 759     }
 760
 761     @POST
 762     @Path("/{version:[vV][7]}/instanceGroups")
 763     @Consumes(MediaType.APPLICATION_JSON)
 764     @Produces(MediaType.APPLICATION_JSON)
 765     @Operation(description = "Create instanceGroups", responses = @ApiResponse(
 766             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 767     @Transactional
 768     public Response createInstanceGroups(String request, @PathParam("version") String version,
 769             @Context ContainerRequestContext requestContext) throws ApiException {
 770         String requestId = requestHandlerUtils.getRequestId(requestContext);
 771         return serviceInstances(request, Action.createInstance, null, version, requestId,
 772                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 773     }
 774
 775     @DELETE
 776     @Path("/{version:[vV][7]}/instanceGroups/{instanceGroupId}")
 777     @Consumes(MediaType.APPLICATION_JSON)
 778     @Produces(MediaType.APPLICATION_JSON)
 779     @Operation(description = "Delete instanceGroup", responses = @ApiResponse(
 780             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 781     @Transactional
 782     public Response deleteInstanceGroups(@PathParam("version") String version,
 783             @PathParam("instanceGroupId") String instanceGroupId, @Context ContainerRequestContext requestContext)
 784             throws ApiException {
 785         String requestId = requestHandlerUtils.getRequestId(requestContext);
 786         HashMap<String, String> instanceIdMap = new HashMap<>();
 787         instanceIdMap.put(CommonConstants.INSTANCE_GROUP_INSTANCE_ID, instanceGroupId);
 788         return deleteInstanceGroups(Action.deleteInstance, instanceIdMap, version, requestId,
 789                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix), requestContext);
 790     }
 791
 792     @POST
 793     @Path("/{version:[vV][7]}/instanceGroups/{instanceGroupId}/addMembers")
 794     @Consumes(MediaType.APPLICATION_JSON)
 795     @Produces(MediaType.APPLICATION_JSON)
 796     @Operation(description = "Add instanceGroup members", responses = @ApiResponse(
 797             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 798     @Transactional
 799     public Response addInstanceGroupMembers(String request, @PathParam("version") String version,
 800             @PathParam("instanceGroupId") String instanceGroupId, @Context ContainerRequestContext requestContext)
 801             throws ApiException {
 802         String requestId = requestHandlerUtils.getRequestId(requestContext);
 803         HashMap<String, String> instanceIdMap = new HashMap<>();
 804         instanceIdMap.put(CommonConstants.INSTANCE_GROUP_INSTANCE_ID, instanceGroupId);
 805         return serviceInstances(request, Action.addMembers, instanceIdMap, version, requestId,
 806                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 807     }
 808
 809     @POST
 810     @Path("/{version:[vV][7]}/instanceGroups/{instanceGroupId}/removeMembers")
 811     @Consumes(MediaType.APPLICATION_JSON)
 812     @Produces(MediaType.APPLICATION_JSON)
 813     @Operation(description = "Remove instanceGroup members", responses = @ApiResponse(
 814             content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
 815     @Transactional
 816     public Response removeInstanceGroupMembers(String request, @PathParam("version") String version,
 817             @PathParam("instanceGroupId") String instanceGroupId, @Context ContainerRequestContext requestContext)
 818             throws ApiException {
 819         String requestId = requestHandlerUtils.getRequestId(requestContext);
 820         HashMap<String, String> instanceIdMap = new HashMap<>();
 821         instanceIdMap.put(CommonConstants.INSTANCE_GROUP_INSTANCE_ID, instanceGroupId);
 822         return serviceInstances(request, Action.removeMembers, instanceIdMap, version, requestId,
 823                 requestHandlerUtils.getRequestUri(requestContext, uriPrefix));
 824     }
 825
 826     /**
 827      * This method is used for POST a request to the BPEL client (BPMN).
 828      *
 829      * Convert the requestJson to ServiceInstanceRequest(sir), create the msoRequest object, check whether this request
 830      * is already being processed in requestdb for duplicate check.
 831      *
 832      * Based on the alacarte flag, sir and msoRequest will do the recipe lookup from the service and servicerecipe table
 833      * of catalogdb, and get the OrchestrationURI.
 834      *
 835      * If the present request is not the duplicate request then this request will be saved in the requestdb. and will
 836      * POST a request to the BPMN engine at the OrchestrationURI fetched.
 837      *
 838      * @param requestJSON Json fetched as body in the API call
 839      * @param action Type of action to be performed
 840      * @param instanceIdMap Map of instance ids of service/vnf/vf/configuration etc..
 841      * @param version Supported version of API
 842      * @param requestId Unique id for the request
 843      * @param requestUri
 844      * @return response object
 845      * @throws ApiException
 846      */
 847     public Response serviceInstances(String requestJSON, Actions action, HashMap<String, String> instanceIdMap,
 848             String version, String requestId, String requestUri) throws ApiException {
 849         return serviceInstances(requestJSON, action, instanceIdMap, version, requestId, requestUri, null);
 850
 851     }
 852
 853     public Response serviceInstances(String requestJSON, Actions action, HashMap<String, String> instanceIdMap,
 854             String version, String requestId, String requestUri, HashMap<String, String> queryParams)
 855             throws ApiException {
 856         String serviceInstanceId;
 857         Boolean aLaCarte = null;
 858         ServiceInstancesRequest sir;
 859         String apiVersion = version.substring(1);
 860
 861         sir = requestHandlerUtils.convertJsonToServiceInstanceRequest(requestJSON, action, requestId, requestUri);
 862         action = handleReplaceInstance(action, sir);
 863
 864         String requestScope = requestHandlerUtils.deriveRequestScope(action, sir, requestUri);
 865         try {
 866             requestValidatorListenerRunner.runValidations(requestUri, instanceIdMap, sir, queryParams, action);
 867         } catch (ApiException e) {
 868             msoRequest.createErrorRequestRecord(Status.FAILED, requestId, e.getMessage(), action, requestScope,
 869                     requestJSON, requestHandlerUtils
 870                             .getServiceInstanceIdForValidationError(sir, instanceIdMap, requestScope).orElse(null),
 871                     sir);
 872             throw e;
 873         }
 874
 875         InfraActiveRequests currentActiveReq =
 876                 msoRequest.createRequestObject(sir, action, requestId, Status.IN_PROGRESS, requestJSON, requestScope);
 877         if (sir.getRequestDetails().getRequestParameters() != null) {
 878             aLaCarte = sir.getRequestDetails().getRequestParameters().getALaCarte();
 879         }
 880
 881         requestHandlerUtils.parseRequest(sir, instanceIdMap, action, version, requestJSON, aLaCarte, requestId,
 882                 currentActiveReq);
 883         if ((action == Action.replaceInstance || action == Action.replaceInstanceRetainAssignments)
 884                 && (requestScope.equals(ModelType.vnf.toString()) || requestScope.equals(ModelType.vfModule.toString()))
 885                 && sir.getRequestDetails().getCloudConfiguration() == null) {
 886             CloudConfiguration cloudConfiguration =
 887                     getCloudConfigurationOnReplace(requestScope, instanceIdMap, currentActiveReq);
 888             sir.getRequestDetails().setCloudConfiguration(cloudConfiguration);
 889             setCloudConfigurationCurrentActiveRequest(cloudConfiguration, currentActiveReq);
 890         }
 891         requestHandlerUtils.setInstanceId(currentActiveReq, requestScope, null, instanceIdMap);
 892
 893         String instanceName = null;
 894         if (sir.getRequestDetails().getRequestInfo() != null) {
 895             instanceName = sir.getRequestDetails().getRequestInfo().getInstanceName();
 896         }
 897         boolean alaCarteFlag = msoRequest.getAlacarteFlag(sir);
 898         String vnfType = msoRequest.getVnfType(sir, requestScope);
 899         String networkType = msoRequest.getNetworkType(sir, requestScope);
 900         String sdcServiceModelVersion = msoRequest.getSDCServiceModelVersion(sir);
 901         String vfModuleType = msoRequest.getVfModuleType(sir, requestScope);
 902
 903         if (requestScope.equalsIgnoreCase(ModelType.vnf.name()) && vnfType != null) {
 904             currentActiveReq.setVnfType(vnfType);
 905         } else if (requestScope.equalsIgnoreCase(ModelType.network.name()) && networkType != null) {
 906             currentActiveReq.setNetworkType(networkType);
 907         }
 908
 909         requestHandlerUtils.checkForDuplicateRequests(action, instanceIdMap, requestScope, currentActiveReq,
 910                 instanceName);
 911
 912         ServiceInstancesResponse serviceResponse = new ServiceInstancesResponse();
 913
 914         RequestReferences referencesResponse = new RequestReferences();
 915
 916         referencesResponse.setRequestId(requestId);
 917
 918         serviceResponse.setRequestReferences(referencesResponse);
 919         RecipeLookupResult recipeLookupResult =
 920                 requestHandlerUtils.getServiceInstanceOrchestrationURI(sir, action, alaCarteFlag, currentActiveReq);
 921         String serviceInstanceType = requestHandlerUtils.getServiceType(requestScope, sir, alaCarteFlag);
 922
 923         ModelInfo modelInfo = sir.getRequestDetails().getModelInfo();
 924         ModelType modelType = requestHandlerUtils.getModelType(action, modelInfo);
 925
 926         Boolean isBaseVfModule = false;
 927
 928         if (modelType.equals(ModelType.vfModule)) {
 929             isBaseVfModule = requestHandlerUtils.getIsBaseVfModule(modelInfo, action, vnfType, sdcServiceModelVersion,
 930                     currentActiveReq);
 931         }
 932
 933         serviceInstanceId = requestHandlerUtils.setServiceInstanceId(requestScope, sir);
 934         String vnfId = "";
 935         String vfModuleId = "";
 936         String volumeGroupId = "";
 937         String networkId = "";
 938         String pnfCorrelationId = "";
 939         String instanceGroupId = null;
 940
 941         if (sir.getVnfInstanceId() != null) {
 942             vnfId = sir.getVnfInstanceId();
 943         }
 944
 945         if (sir.getVfModuleInstanceId() != null) {
 946             vfModuleId = sir.getVfModuleInstanceId();
 947         }
 948
 949         if (sir.getVolumeGroupInstanceId() != null) {
 950             volumeGroupId = sir.getVolumeGroupInstanceId();
 951         }
 952
 953         if (sir.getNetworkInstanceId() != null) {
 954             networkId = sir.getNetworkInstanceId();
 955         }
 956         if (sir.getInstanceGroupId() != null) {
 957             instanceGroupId = sir.getInstanceGroupId();
 958         }
 959
 960         pnfCorrelationId = getPnfCorrelationId(sir);
 961
 962         try {
 963             infraActiveRequestsClient.save(currentActiveReq);
 964         } catch (Exception e) {
 965             logger.error("Exception occurred", e);
 966             ErrorLoggerInfo errorLoggerInfo =
 967                     new ErrorLoggerInfo.Builder(MessageEnum.APIH_DB_ACCESS_EXC, ErrorCode.DataError)
 968                             .errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
 969             throw new RequestDbFailureException.Builder(SAVE_TO_DB, e.toString(), HttpStatus.SC_INTERNAL_SERVER_ERROR,
 970                     ErrorNumbers.SVC_DETAILED_SERVICE_ERROR).cause(e).errorInfo(errorLoggerInfo).build();
 971         }
 972
 973         if (!requestScope.equalsIgnoreCase(ModelType.service.name()) && action != Action.recreateInstance
 974                 && !requestScope.equalsIgnoreCase(ModelType.vnf.name())) {
 975             aLaCarte = true;
 976         } else if (aLaCarte == null) {
 977             aLaCarte = false;
 978         }
 979
 980
 981         RequestClientParameter requestClientParameter;
 982         try {
 983             requestClientParameter = new RequestClientParameter.Builder().setRequestId(requestId)
 984                     .setBaseVfModule(isBaseVfModule).setRecipeTimeout(recipeLookupResult.getRecipeTimeout())
 985                     .setRequestAction(action.toString()).setServiceInstanceId(serviceInstanceId)
 986                     .setPnfCorrelationId(pnfCorrelationId).setVnfId(vnfId).setVfModuleId(vfModuleId)
 987                     .setVolumeGroupId(volumeGroupId).setNetworkId(networkId).setServiceType(serviceInstanceType)
 988                     .setVnfType(vnfType).setVfModuleType(vfModuleType).setNetworkType(networkType)
 989                     .setRequestDetails(requestHandlerUtils.mapJSONtoMSOStyle(requestJSON, sir, aLaCarte, action))
 990                     .setApiVersion(apiVersion).setALaCarte(aLaCarte).setRequestUri(requestUri)
 991                     .setInstanceGroupId(instanceGroupId).build();
 992         } catch (IOException e) {
 993             logger.error("Exception occurred", e);
 994             ErrorLoggerInfo errorLoggerInfo =
 995                     new ErrorLoggerInfo.Builder(MessageEnum.APIH_BPEL_RESPONSE_ERROR, ErrorCode.SchemaError)
 996                             .errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
 997             throw new ValidateException.Builder("Unable to generate RequestClientParamter object" + e.getMessage(),
 998                     HttpStatus.SC_INTERNAL_SERVER_ERROR, ErrorNumbers.SVC_BAD_PARAMETER).errorInfo(errorLoggerInfo)
 999                             .build();
1000         }
1001         return requestHandlerUtils.postBPELRequest(currentActiveReq, requestClientParameter,
1002                 recipeLookupResult.getOrchestrationURI(), requestScope);
1003     }
1004
1005     /**
1006      * @param action
1007      * @param sir
1008      * @return
1009      */
1010     protected Actions handleReplaceInstance(Actions action, ServiceInstancesRequest sir) {
1011         if (action != null && action.equals(Action.replaceInstance)
1012                 && sir.getRequestDetails().getRequestParameters().getRetainAssignments() != null
1013                 && sir.getRequestDetails().getRequestParameters().getRetainAssignments()) {
1014             action = Action.replaceInstanceRetainAssignments;
1015         }
1016         return action;
1017     }
1018
1019     /**
1020      * This method deletes the Instance Groups.
1021      *
1022      * This method will check whether the request is not duplicate in requestdb. if its not then will save as a new
1023      * request. And will send a POST request to BEPL client to delete the Insatnce Groups.
1024      *
1025      * @param action
1026      * @param instanceIdMap
1027      * @param version
1028      * @param requestId
1029      * @param requestUri
1030      * @param requestContext
1031      * @return
1032      * @throws ApiException
1033      */
1034     public Response deleteInstanceGroups(Actions action, HashMap<String, String> instanceIdMap, String version,
1035             String requestId, String requestUri, ContainerRequestContext requestContext) throws ApiException {
1036         String instanceGroupId = instanceIdMap.get(CommonConstants.INSTANCE_GROUP_INSTANCE_ID);
1037         Boolean aLaCarte = true;
1038         String apiVersion = version.substring(1);
1039         ServiceInstancesRequest sir = new ServiceInstancesRequest();
1040         sir.setInstanceGroupId(instanceGroupId);
1041
1042         String requestScope = ModelType.instanceGroup.toString();
1043         InfraActiveRequests currentActiveReq =
1044                 msoRequest.createRequestObject(sir, action, requestId, Status.IN_PROGRESS, null, requestScope);
1045         requestHandlerUtils.setInstanceId(currentActiveReq, requestScope, null, instanceIdMap);
1046         try {
1047             requestHandlerUtils.validateHeaders(requestContext);
1048         } catch (ValidationException e) {
1049             logger.error("Exception occurred", e);
1050             ErrorLoggerInfo errorLoggerInfo =
1051                     new ErrorLoggerInfo.Builder(MessageEnum.APIH_VALIDATION_ERROR, ErrorCode.SchemaError)
1052                             .errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
1053             ValidateException validateException =
1054                     new ValidateException.Builder(e.getMessage(), HttpStatus.SC_BAD_REQUEST,
1055                             ErrorNumbers.SVC_BAD_PARAMETER).cause(e).errorInfo(errorLoggerInfo).build();
1056             requestHandlerUtils.updateStatus(currentActiveReq, Status.FAILED, validateException.getMessage());
1057             throw validateException;
1058         }
1059
1060         requestHandlerUtils.checkForDuplicateRequests(action, instanceIdMap, requestScope, currentActiveReq, null);
1061
1062         ServiceInstancesResponse serviceResponse = new ServiceInstancesResponse();
1063
1064         RequestReferences referencesResponse = new RequestReferences();
1065
1066         referencesResponse.setRequestId(requestId);
1067
1068         serviceResponse.setRequestReferences(referencesResponse);
1069         Boolean isBaseVfModule = false;
1070
1071         RecipeLookupResult recipeLookupResult = new RecipeLookupResult("/mso/async/services/WorkflowActionBB", 180);
1072
1073         try {
1074             infraActiveRequestsClient.save(currentActiveReq);
1075         } catch (Exception e) {
1076             logger.error("Exception occurred", e);
1077             ErrorLoggerInfo errorLoggerInfo =
1078                     new ErrorLoggerInfo.Builder(MessageEnum.APIH_DB_ACCESS_EXC, ErrorCode.DataError)
1079                             .errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
1080             throw new RequestDbFailureException.Builder(SAVE_TO_DB, e.toString(), HttpStatus.SC_INTERNAL_SERVER_ERROR,
1081                     ErrorNumbers.SVC_DETAILED_SERVICE_ERROR).cause(e).errorInfo(errorLoggerInfo).build();
1082         }
1083
1084         RequestClientParameter requestClientParameter = new RequestClientParameter.Builder().setRequestId(requestId)
1085                 .setBaseVfModule(isBaseVfModule).setRecipeTimeout(recipeLookupResult.getRecipeTimeout())
1086                 .setRequestAction(action.toString()).setApiVersion(apiVersion).setALaCarte(aLaCarte)
1087                 .setRequestUri(requestUri).setInstanceGroupId(instanceGroupId).build();
1088
1089
1090         return requestHandlerUtils.postBPELRequest(currentActiveReq, requestClientParameter,
1091                 recipeLookupResult.getOrchestrationURI(), requestScope);
1092     }
1093
1094     protected String getPnfCorrelationId(ServiceInstancesRequest sir) {
1095         return Optional.of(sir).map(ServiceInstancesRequest::getRequestDetails)
1096                 .map(RequestDetails::getRequestParameters).map(parameters -> parameters.getUserParamValue("pnfId"))
1097                 .orElse("");
1098     }
1099
1100     private Response configurationRecipeLookup(String requestJSON, Action action, HashMap<String, String> instanceIdMap,
1101             String version, String requestId, String requestUri) throws ApiException {
1102         String serviceInstanceId;
1103         Boolean aLaCarte = null;
1104         String apiVersion = version.substring(1);
1105         ServiceInstancesRequest sir;
1106
1107         sir = requestHandlerUtils.convertJsonToServiceInstanceRequest(requestJSON, action, requestId, requestUri);
1108         String requestScope = requestHandlerUtils.deriveRequestScope(action, sir, requestUri);
1109         InfraActiveRequests currentActiveReq =
1110                 msoRequest.createRequestObject(sir, action, requestId, Status.IN_PROGRESS, requestJSON, requestScope);
1111         if (sir.getRequestDetails().getRequestParameters() != null) {
1112             aLaCarte = sir.getRequestDetails().getRequestParameters().getALaCarte();
1113         }
1114
1115         requestHandlerUtils.parseRequest(sir, instanceIdMap, action, version, requestJSON, aLaCarte, requestId,
1116                 currentActiveReq);
1117         requestHandlerUtils.setInstanceId(currentActiveReq, requestScope, null, instanceIdMap);
1118         String instanceName = sir.getRequestDetails().getRequestInfo().getInstanceName();
1119
1120         requestHandlerUtils.checkForDuplicateRequests(action, instanceIdMap, requestScope, currentActiveReq,
1121                 instanceName);
1122
1123         ServiceInstancesResponse serviceResponse = new ServiceInstancesResponse();
1124         RequestReferences referencesResponse = new RequestReferences();
1125         referencesResponse.setRequestId(requestId);
1126         serviceResponse.setRequestReferences(referencesResponse);
1127
1128         String orchestrationUri = env.getProperty(CommonConstants.ALACARTE_ORCHESTRATION);
1129         String timeOut = env.getProperty(CommonConstants.ALACARTE_RECIPE_TIMEOUT);
1130
1131         if (StringUtils.isBlank(orchestrationUri) || StringUtils.isBlank(timeOut)) {
1132             String error = StringUtils.isBlank(orchestrationUri) ? "ALaCarte Orchestration URI not found in properties"
1133                     : "ALaCarte Recipe Timeout not found in properties";
1134
1135             ErrorLoggerInfo errorLoggerInfo =
1136                     new ErrorLoggerInfo.Builder(MessageEnum.APIH_DB_ATTRIBUTE_NOT_FOUND, ErrorCode.DataError)
1137                             .errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
1138
1139             ValidateException validateException = new ValidateException.Builder(error, HttpStatus.SC_NOT_FOUND,
1140                     ErrorNumbers.SVC_GENERAL_SERVICE_ERROR).errorInfo(errorLoggerInfo).build();
1141
1142             requestHandlerUtils.updateStatus(currentActiveReq, Status.FAILED, validateException.getMessage());
1143
1144             throw validateException;
1145
1146         }
1147
1148         serviceInstanceId = "";
1149         String configurationId = "";
1150         String pnfCorrelationId = "";
1151
1152         if (sir.getServiceInstanceId() != null) {
1153             serviceInstanceId = sir.getServiceInstanceId();
1154         }
1155
1156         if (sir.getConfigurationId() != null) {
1157             configurationId = sir.getConfigurationId();
1158         }
1159
1160         pnfCorrelationId = getPnfCorrelationId(sir);
1161
1162         try {
1163             infraActiveRequestsClient.save(currentActiveReq);
1164         } catch (Exception e) {
1165             ErrorLoggerInfo errorLoggerInfo =
1166                     new ErrorLoggerInfo.Builder(MessageEnum.APIH_DB_ACCESS_EXC, ErrorCode.DataError)
1167                             .errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
1168             throw new RequestDbFailureException.Builder(SAVE_TO_DB, e.toString(), HttpStatus.SC_INTERNAL_SERVER_ERROR,
1169                     ErrorNumbers.SVC_DETAILED_SERVICE_ERROR).cause(e).errorInfo(errorLoggerInfo).build();
1170         }
1171
1172         if (!requestScope.equalsIgnoreCase(ModelType.service.name())) {
1173             aLaCarte = true;
1174         } else if (aLaCarte == null) {
1175             aLaCarte = false;
1176         }
1177         RequestClientParameter requestClientParameter = null;
1178         try {
1179             requestClientParameter = new RequestClientParameter.Builder().setRequestId(requestId).setBaseVfModule(false)
1180                     .setRecipeTimeout(Integer.parseInt(timeOut)).setRequestAction(action.toString())
1181                     .setServiceInstanceId(serviceInstanceId).setPnfCorrelationId(pnfCorrelationId)
1182                     .setConfigurationId(configurationId)
1183                     .setRequestDetails(requestHandlerUtils.mapJSONtoMSOStyle(requestJSON, sir, aLaCarte, action))
1184                     .setApiVersion(apiVersion).setALaCarte(aLaCarte).setRequestUri(requestUri).build();
1185         } catch (IOException e) {
1186             ErrorLoggerInfo errorLoggerInfo =
1187                     new ErrorLoggerInfo.Builder(MessageEnum.APIH_BPEL_RESPONSE_ERROR, ErrorCode.SchemaError)
1188                             .errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
1189             throw new ValidateException.Builder("Unable to generate RequestClientParamter object" + e.getMessage(),
1190                     HttpStatus.SC_INTERNAL_SERVER_ERROR, ErrorNumbers.SVC_BAD_PARAMETER).errorInfo(errorLoggerInfo)
1191                             .build();
1192         }
1193
1194         return requestHandlerUtils.postBPELRequest(currentActiveReq, requestClientParameter, orchestrationUri,
1195                 requestScope);
1196     }
1197
1198     protected CloudConfiguration getCloudConfigurationOnReplace(String requestScope,
1199             HashMap<String, String> instanceIdMap, InfraActiveRequests currentActiveReq) throws ApiException {
1200         logger.debug("Replace request is missing cloudConfiguration, autofilling from create.");
1201         CloudConfiguration cloudConfiguration = null;
1202         if (requestScope.equals(ModelType.vfModule.toString())) {
1203             cloudConfiguration = bpmnRequestBuilder.getCloudConfigurationVfModuleReplace(
1204                     instanceIdMap.get("vnfInstanceId"), instanceIdMap.get("vfModuleInstanceId"));
1205         } else {
1206             cloudConfiguration = bpmnRequestBuilder.mapCloudConfigurationVnf(instanceIdMap.get("vnfInstanceId"));
1207         }
1208
1209         if (cloudConfiguration == null) {
1210             String errorMessage = "CloudConfiguration not found during autofill for replace request.";
1211             logger.error(errorMessage);
1212             updateStatus(currentActiveReq, Status.FAILED, errorMessage);
1213             throw new CloudConfigurationNotFoundException(
1214                     "CloudConfiguration not found during autofill for replace request.");
1215         }
1216         return cloudConfiguration;
1217     }
1218
1219     protected void setCloudConfigurationCurrentActiveRequest(CloudConfiguration cloudConfiguration,
1220             InfraActiveRequests currentActiveRequest) {
1221         if (cloudConfiguration.getLcpCloudRegionId() != null) {
1222             currentActiveRequest.setCloudRegion(cloudConfiguration.getLcpCloudRegionId());
1223         }
1224
1225         if (cloudConfiguration.getTenantId() != null) {
1226             currentActiveRequest.setTenantId(cloudConfiguration.getTenantId());
1227         }
1228     }
1229 }