bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/adapter/vnfm/tasks/VnfmAdapterCreateVnfTask.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2019 Nordix Foundation.
   4  * ================================================================================
   5  * Licensed under the Apache License, Version 2.0 (the "License");
   6  * you may not use this file except in compliance with the License.
   7  * You may obtain a copy of the License at
   8  *
   9  *      http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  * Unless required by applicable law or agreed to in writing, software
  12  * distributed under the License is distributed on an "AS IS" BASIS,
  13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  * See the License for the specific language governing permissions and
  15  * limitations under the License.
  16  *
  17  * SPDX-License-Identifier: Apache-2.0
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.so.bpmn.infrastructure.adapter.vnfm.tasks;
  22
  23 import static org.onap.so.bpmn.infrastructure.adapter.vnfm.tasks.Constants.CREATE_VNF_REQUEST_PARAM_NAME;
  24 import static org.onap.so.bpmn.infrastructure.adapter.vnfm.tasks.Constants.CREATE_VNF_RESPONSE_PARAM_NAME;
  25 import static org.onap.so.bpmn.infrastructure.adapter.vnfm.tasks.Constants.DOT;
  26 import static org.onap.so.bpmn.infrastructure.adapter.vnfm.tasks.Constants.SPACE;
  27 import static org.onap.so.bpmn.infrastructure.adapter.vnfm.tasks.Constants.UNDERSCORE;
  28 import static org.onap.so.bpmn.servicedecomposition.entities.ResourceKey.GENERIC_VNF_ID;
  29
  30 import org.onap.so.bpmn.common.BuildingBlockExecution;
  31 import org.onap.so.bpmn.servicedecomposition.bbobjects.CloudRegion;
  32 import org.onap.so.bpmn.servicedecomposition.bbobjects.GenericVnf;
  33 import org.onap.so.bpmn.servicedecomposition.entities.GeneralBuildingBlock;
  34 import org.onap.so.bpmn.servicedecomposition.modelinfo.ModelInfoGenericVnf;
  35 import org.onap.so.bpmn.servicedecomposition.tasks.ExtractPojosForBB;
  36 import org.onap.so.client.exception.ExceptionBuilder;
  37 import org.onap.vnfmadapter.v1.model.CreateVnfRequest;
  38 import org.onap.vnfmadapter.v1.model.CreateVnfResponse;
  39 import org.onap.vnfmadapter.v1.model.Tenant;
  40 import org.slf4j.Logger;
  41 import org.slf4j.LoggerFactory;
  42 import org.springframework.beans.factory.annotation.Autowired;
  43 import org.springframework.stereotype.Component;
  44
  45 import com.google.common.base.Optional;
  46
  47 /**
  48  * This class is executed from EtsiVnfInstantiateBB building block and it sends the create request
  49  * to the VNFM adapter
  50  *
  51  * @author waqas.ikram@est.tech
  52  */
  53 @Component
  54 public class VnfmAdapterCreateVnfTask {
  55
  56     private static final Logger LOGGER = LoggerFactory.getLogger(VnfmAdapterCreateVnfTask.class);
  57
  58     private final ExtractPojosForBB extractPojosForBB;
  59     private final ExceptionBuilder exceptionUtil;
  60     private final VnfmAdapterServiceProvider vnfmAdapterServiceProvider;
  61
  62     @Autowired
  63     public VnfmAdapterCreateVnfTask(final ExceptionBuilder exceptionUtil, final ExtractPojosForBB extractPojosForBB,
  64             final VnfmAdapterServiceProvider vnfmAdapterServiceProvider) {
  65         this.exceptionUtil = exceptionUtil;
  66         this.extractPojosForBB = extractPojosForBB;
  67         this.vnfmAdapterServiceProvider = vnfmAdapterServiceProvider;
  68     }
  69
  70     /**
  71      * Create {@link CreateVnfRequest} object with required fields and store it in
  72      * {@link org.camunda.bpm.engine.delegate.DelegateExecution}
  73      *
  74      * @param execution {@link org.onap.so.bpmn.common.DelegateExecutionImpl}
  75      */
  76     public void buildCreateVnfRequest(final BuildingBlockExecution execution) {
  77         try {
  78             LOGGER.debug("Executing buildCreateVnfRequest  ...");
  79
  80             final GeneralBuildingBlock buildingBlock = execution.getGeneralBuildingBlock();
  81             final CloudRegion cloudRegion = buildingBlock.getCloudRegion();
  82
  83             final GenericVnf vnf = extractPojosForBB.extractByKey(execution, GENERIC_VNF_ID);
  84             final ModelInfoGenericVnf modelInfoGenericVnf = vnf.getModelInfoGenericVnf();
  85
  86             final CreateVnfRequest createVnfRequest = new CreateVnfRequest();
  87
  88             createVnfRequest.setName(getName(vnf.getVnfName(), modelInfoGenericVnf.getModelInstanceName()));
  89             createVnfRequest.setTenant(getTenant(cloudRegion));
  90
  91             LOGGER.info("CreateVnfRequest : {}", createVnfRequest);
  92
  93             execution.setVariable(CREATE_VNF_REQUEST_PARAM_NAME, createVnfRequest);
  94
  95             LOGGER.debug("Finished executing buildCreateVnfRequest ...");
  96         } catch (final Exception exception) {
  97             LOGGER.error("Unable to execute buildCreateVnfRequest", exception);
  98             exceptionUtil.buildAndThrowWorkflowException(execution, 1200, exception);
  99         }
 100     }
 101
 102     /**
 103      * Invoke VNFM adapter to create and instantiate VNF
 104      *
 105      * @param execution {@link org.onap.so.bpmn.common.DelegateExecutionImpl}
 106      */
 107     public void invokeVnfmAdapter(final BuildingBlockExecution execution) {
 108         try {
 109             LOGGER.debug("Executing invokeVnfmAdapter  ...");
 110             final CreateVnfRequest request = execution.getVariable(CREATE_VNF_REQUEST_PARAM_NAME);
 111
 112             final GenericVnf vnf = extractPojosForBB.extractByKey(execution, GENERIC_VNF_ID);
 113
 114             final Optional<CreateVnfResponse> response =
 115                     vnfmAdapterServiceProvider.invokeCreateInstantiationRequest(vnf.getVnfId(), request);
 116
 117             if (!response.isPresent()) {
 118                 final String errorMessage = "Unexpected error while processing create and instantiation request";
 119                 LOGGER.error(errorMessage);
 120                 exceptionUtil.buildAndThrowWorkflowException(execution, 1201, errorMessage);
 121             }
 122
 123             final CreateVnfResponse vnfResponse = response.get();
 124
 125             LOGGER.debug("Vnf instantiation response: {}", vnfResponse);
 126             execution.setVariable(CREATE_VNF_RESPONSE_PARAM_NAME, vnfResponse);
 127
 128             LOGGER.debug("Finished executing invokeVnfmAdapter ...");
 129         } catch (final Exception exception) {
 130             LOGGER.error("Unable to invoke create and instantiation request", exception);
 131             exceptionUtil.buildAndThrowWorkflowException(execution, 1202, exception);
 132         }
 133     }
 134
 135     private Tenant getTenant(final CloudRegion cloudRegion) {
 136         final Tenant tenant = new Tenant();
 137         tenant.setCloudOwner(cloudRegion.getCloudOwner());
 138         tenant.setRegionName(cloudRegion.getLcpCloudRegionId());
 139         tenant.setTenantId(cloudRegion.getTenantId());
 140         return tenant;
 141     }
 142
 143     private String getName(final String vnfName, final String modelInstanceName) {
 144         if (modelInstanceName != null) {
 145             return (vnfName + DOT + modelInstanceName).replaceAll(SPACE, UNDERSCORE);
 146         }
 147         return vnfName != null ? vnfName.replaceAll(SPACE, UNDERSCORE) : vnfName;
 148     }
 149
 150 }