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);