2  * ============LICENSE_START=======================================================
 
   4  * ================================================================================
 
   5  * Copyright (C) 2019 TechMahindra.
 
   6  * Copyright (C) 2019 Nokia.
 
   7  * ================================================================================
 
   8  * Licensed under the Apache License, Version 2.0 (the "License");
 
   9  * you may not use this file except in compliance with the License.
 
  10  * You may obtain a copy of the License at
 
  12  *      http://www.apache.org/licenses/LICENSE-2.0
 
  14  * Unless required by applicable law or agreed to in writing, software
 
  15  * distributed under the License is distributed on an "AS IS" BASIS,
 
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 
  17  * See the License for the specific language governing permissions and
 
  18  * limitations under the License.
 
  19  * ============LICENSE_END=========================================================
 
  22 package org.onap.so.bpmn.infrastructure.flowspecific.tasks;
 
  24 import static org.assertj.core.api.Assertions.assertThat;
 
  25 import static org.mockito.Mockito.mock;
 
  26 import static org.mockito.Mockito.when;
 
  27 import com.fasterxml.jackson.databind.JsonNode;
 
  28 import com.fasterxml.jackson.databind.ObjectMapper;
 
  29 import java.util.ArrayList;
 
  30 import java.util.HashMap;
 
  31 import java.util.List;
 
  33 import org.camunda.bpm.engine.delegate.DelegateExecution;
 
  34 import org.camunda.bpm.extension.mockito.delegate.DelegateExecutionFake;
 
  35 import org.junit.Before;
 
  36 import org.junit.Test;
 
  37 import org.onap.so.bpmn.common.BuildingBlockExecution;
 
  38 import org.onap.so.bpmn.common.DelegateExecutionImpl;
 
  39 import org.onap.so.bpmn.servicedecomposition.bbobjects.GenericVnf;
 
  40 import org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance;
 
  41 import org.onap.so.bpmn.servicedecomposition.entities.GeneralBuildingBlock;
 
  42 import org.onap.so.bpmn.servicedecomposition.entities.ResourceKey;
 
  43 import org.onap.so.bpmn.servicedecomposition.generalobjects.RequestContext;
 
  44 import org.onap.so.bpmn.servicedecomposition.generalobjects.RequestParameters;
 
  45 import org.onap.so.bpmn.servicedecomposition.modelinfo.ModelInfoGenericVnf;
 
  46 import org.onap.so.bpmn.servicedecomposition.modelinfo.ModelInfoServiceInstance;
 
  47 import org.onap.so.bpmn.servicedecomposition.tasks.ExtractPojosForBB;
 
  48 import org.onap.so.client.cds.beans.AbstractCDSPropertiesBean;
 
  49 import org.onap.so.client.exception.ExceptionBuilder;
 
  51 public class ConfigAssignVnfTest {
 
  53     private static final String GENERIC_VNF_ID = "vnfId_configVnfTest";
 
  54     private static final String GENERIC_VNF_NAME = "vnfName_configVnfTest";
 
  55     private static final String VNF_MODEL_CUSTOMIZATION_UUID = "0c1ac643-377e-475b-be50-6be65f91a7ad";
 
  56     private static final String SERVICE_INSTANCE_ID = "serviceInst_configTest";
 
  57     private static final String SERVICE_MODEL_UUID = "5af91c26-8418-4d3f-944c-965842deda94";
 
  58     private static final String TARGET_VNF_MODEL_CUSTOMIZATION_UUID = "0c1ac643-377e-475b-be50-6be65f91a7ad";
 
  59     private static final String GENERAL_BLOCK_EXECUTION_MAP_KEY = "gBBInput";
 
  60     private static final int THE_NUMBER_OF_EXPECTED_CONFIG_PROPERTIES = 8;
 
  62     private static final String USER_PARAMS_FROM_REQUEST = "{\"resources\":{\"vnfs\":["
 
  63             + "{\"modelInfo\":{\"modelCustomizationId\":\"" + VNF_MODEL_CUSTOMIZATION_UUID + "\"},"
 
  64             + "\"instanceParams\":[{\"paramName1\":\"paramValue1\",\"paramName2\":\"paramValue2\"},{\"paramName3\":\"paramValue3\"}]},"
 
  65             + "{\"modelInfo\":{\"modelCustomizationId\":\"2d1ac656-377e-467b-be50-6ce65f66a7ca\"},"
 
  66             + "\"instanceParams\":[{\"parName4\":\"parValue4\",\"parName5\":\"parValue5\"}]}]}}\n";
 
  69     private ConfigAssignVnf testedObject;
 
  71     private BuildingBlockExecution buildingBlockExecution;
 
  72     private ExtractPojosForBB extractPojosForBB;
 
  76         buildingBlockExecution = createBuildingBlockExecution();
 
  77         extractPojosForBB = mock(ExtractPojosForBB.class);
 
  78         testedObject = new ConfigAssignVnf(extractPojosForBB, new ExceptionBuilder());
 
  82     public void prepareAbstractCDSPropertiesBean_success() throws Exception {
 
  84         when(extractPojosForBB.extractByKey(buildingBlockExecution, ResourceKey.GENERIC_VNF_ID))
 
  85                 .thenReturn(createGenericVnf());
 
  86         when(extractPojosForBB.extractByKey(buildingBlockExecution, ResourceKey.SERVICE_INSTANCE_ID))
 
  87                 .thenReturn(createServiceInstance());
 
  89         testedObject.preProcessAbstractCDSProcessing(buildingBlockExecution);
 
  91         verifyConfigAssignPropertiesJsonContent();
 
  94     private void verifyConfigAssignPropertiesJsonContent() throws Exception {
 
  95         AbstractCDSPropertiesBean abstractCDSPropertiesBean = buildingBlockExecution.getVariable("executionObject");
 
  96         String payload = abstractCDSPropertiesBean.getRequestObject();
 
  97         ObjectMapper mapper = new ObjectMapper();
 
  98         JsonNode payloadJson = mapper.readTree(payload);
 
  99         JsonNode configAssignPropertiesNode = payloadJson.findValue("config-assign-properties");
 
 100         assertThat(configAssignPropertiesNode.size()).isEqualTo(THE_NUMBER_OF_EXPECTED_CONFIG_PROPERTIES);
 
 101         assertThat(configAssignPropertiesNode.get("service-instance-id").asText()).isEqualTo(SERVICE_INSTANCE_ID);
 
 102         assertThat(configAssignPropertiesNode.get("vnf-id").asText()).isEqualTo(GENERIC_VNF_ID);
 
 103         assertThat(configAssignPropertiesNode.get("vnf-name").asText()).isEqualTo(GENERIC_VNF_NAME);
 
 104         assertThat(configAssignPropertiesNode.get("service-model-uuid").asText()).isEqualTo(SERVICE_MODEL_UUID);
 
 105         assertThat(configAssignPropertiesNode.get("vnf-customization-uuid").asText())
 
 106                 .isEqualTo(VNF_MODEL_CUSTOMIZATION_UUID);
 
 107         assertThat(configAssignPropertiesNode.has("paramName1")).isTrue();
 
 108         assertThat(configAssignPropertiesNode.get("paramName1").asText()).isEqualTo("paramValue1");
 
 109         assertThat(configAssignPropertiesNode.has("paramName2")).isTrue();
 
 110         assertThat(configAssignPropertiesNode.get("paramName2").asText()).isEqualTo("paramValue2");
 
 111         assertThat(configAssignPropertiesNode.has("paramName3")).isTrue();
 
 112         assertThat(configAssignPropertiesNode.get("paramName3").asText()).isEqualTo("paramValue3");
 
 115     private BuildingBlockExecution createBuildingBlockExecution() {
 
 116         DelegateExecution execution = new DelegateExecutionFake();
 
 117         execution.setVariable(GENERAL_BLOCK_EXECUTION_MAP_KEY, createGeneralBuildingBlock());
 
 118         return new DelegateExecutionImpl(execution);
 
 121     private ServiceInstance createServiceInstance() {
 
 122         ServiceInstance serviceInstance = new ServiceInstance();
 
 123         serviceInstance.setServiceInstanceId(SERVICE_INSTANCE_ID);
 
 124         ModelInfoServiceInstance modelInfoServiceInstance = new ModelInfoServiceInstance();
 
 125         modelInfoServiceInstance.setModelUuid(SERVICE_MODEL_UUID);
 
 126         serviceInstance.setModelInfoServiceInstance(modelInfoServiceInstance);
 
 127         return serviceInstance;
 
 130     private GenericVnf createGenericVnf() {
 
 131         GenericVnf genericVnf = new GenericVnf();
 
 132         genericVnf.setVnfId(GENERIC_VNF_ID);
 
 133         genericVnf.setVnfName(GENERIC_VNF_NAME);
 
 134         ModelInfoGenericVnf modelInfoGenericVnf = new ModelInfoGenericVnf();
 
 135         modelInfoGenericVnf.setModelCustomizationUuid(TARGET_VNF_MODEL_CUSTOMIZATION_UUID);
 
 136         modelInfoGenericVnf.setBlueprintName("blueprintTest");
 
 137         modelInfoGenericVnf.setBlueprintVersion("blueprintVerTest");
 
 138         genericVnf.setModelInfoGenericVnf(modelInfoGenericVnf);
 
 142     private GeneralBuildingBlock createGeneralBuildingBlock() {
 
 143         GeneralBuildingBlock generalBuildingBlock = new GeneralBuildingBlock();
 
 144         RequestContext requestContext = new RequestContext();
 
 145         RequestParameters requestParameters = new RequestParameters();
 
 146         requestParameters.setUserParams(createRequestUserParams());
 
 147         requestContext.setRequestParameters(requestParameters);
 
 148         generalBuildingBlock.setRequestContext(requestContext);
 
 149         return generalBuildingBlock;
 
 152     private List<Map<String, Object>> createRequestUserParams() {
 
 153         List<Map<String, Object>> userParams = new ArrayList<>();
 
 154         Map<String, Object> userParamMap = new HashMap<>();
 
 155         userParamMap.put("service", USER_PARAMS_FROM_REQUEST);
 
 156         userParams.add(userParamMap);