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