2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017 - 2018 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Modifications Copyright (c) 2019 Samsung
8 * ================================================================================
9 * Licensed under the Apache License, Version 2.0 (the "License");
10 * you may not use this file except in compliance with the License.
11 * You may obtain a copy of the License at
13 * http://www.apache.org/licenses/LICENSE-2.0
15 * Unless required by applicable law or agreed to in writing, software
16 * distributed under the License is distributed on an "AS IS" BASIS,
17 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
18 * See the License for the specific language governing permissions and
19 * limitations under the License.
20 * ============LICENSE_END=========================================================
23 package org.onap.so.bpmn.infrastructure.workflow.tasks;
25 import static com.shazam.shazamcrest.matcher.Matchers.sameBeanAs;
26 import static org.hamcrest.CoreMatchers.containsString;
27 import static org.hamcrest.CoreMatchers.equalTo;
28 import static org.junit.Assert.assertEquals;
29 import static org.junit.Assert.assertFalse;
30 import static org.junit.Assert.assertNotNull;
31 import static org.junit.Assert.assertNull;
32 import static org.junit.Assert.assertThat;
33 import static org.junit.Assert.assertTrue;
34 import static org.junit.Assert.fail;
35 import static org.mockito.ArgumentMatchers.anyObject;
36 import static org.mockito.ArgumentMatchers.anyString;
37 import static org.mockito.ArgumentMatchers.isA;
38 import static org.mockito.Mockito.doReturn;
39 import static org.mockito.Mockito.when;
40 import com.fasterxml.jackson.databind.ObjectMapper;
41 import java.io.IOException;
42 import java.net.MalformedURLException;
43 import java.nio.file.Files;
44 import java.nio.file.Paths;
45 import java.util.ArrayList;
46 import java.util.Arrays;
47 import java.util.HashSet;
48 import java.util.List;
49 import java.util.Optional;
51 import java.util.UUID;
52 import org.camunda.bpm.engine.delegate.BpmnError;
53 import org.camunda.bpm.engine.delegate.DelegateExecution;
54 import org.camunda.bpm.extension.mockito.delegate.DelegateExecutionFake;
55 import org.javatuples.Pair;
56 import org.junit.Before;
57 import org.junit.Ignore;
58 import org.junit.Rule;
59 import org.junit.Test;
60 import org.junit.rules.ExpectedException;
61 import org.mockito.InjectMocks;
62 import org.mockito.Mock;
63 import org.mockito.Spy;
64 import org.onap.aai.domain.yang.GenericVnf;
65 import org.onap.aai.domain.yang.L3Network;
66 import org.onap.aai.domain.yang.Relationship;
67 import org.onap.aai.domain.yang.RelationshipList;
68 import org.onap.aai.domain.yang.ServiceInstance;
69 import org.onap.aai.domain.yang.VfModule;
70 import org.onap.aai.domain.yang.VfModules;
71 import org.onap.aai.domain.yang.VolumeGroup;
72 import org.onap.so.bpmn.BaseTaskTest;
73 import org.onap.so.bpmn.servicedecomposition.bbobjects.Collection;
74 import org.onap.so.bpmn.servicedecomposition.bbobjects.Configuration;
75 import org.onap.so.bpmn.servicedecomposition.entities.BuildingBlock;
76 import org.onap.so.bpmn.servicedecomposition.entities.ExecuteBuildingBlock;
77 import org.onap.so.bpmn.servicedecomposition.entities.WorkflowResourceIds;
78 import org.onap.so.bpmn.servicedecomposition.modelinfo.ModelInfoVfModule;
79 import org.onap.so.client.aai.AAIObjectType;
80 import org.onap.so.client.aai.entities.AAIResultWrapper;
81 import org.onap.so.client.aai.entities.Relationships;
82 import org.onap.so.client.aai.entities.uri.AAIResourceUri;
83 import org.onap.so.client.aai.entities.uri.AAIUriFactory;
84 import org.onap.so.db.catalog.beans.CollectionNetworkResourceCustomization;
85 import org.onap.so.db.catalog.beans.CollectionResource;
86 import org.onap.so.db.catalog.beans.CollectionResourceCustomization;
87 import org.onap.so.db.catalog.beans.CollectionResourceInstanceGroupCustomization;
88 import org.onap.so.db.catalog.beans.ConfigurationResource;
89 import org.onap.so.db.catalog.beans.CvnfcConfigurationCustomization;
90 import org.onap.so.db.catalog.beans.CvnfcCustomization;
91 import org.onap.so.db.catalog.beans.HeatEnvironment;
92 import org.onap.so.db.catalog.beans.HeatTemplate;
93 import org.onap.so.db.catalog.beans.InstanceGroup;
94 import org.onap.so.db.catalog.beans.NetworkCollectionResourceCustomization;
95 import org.onap.so.db.catalog.beans.NetworkResourceCustomization;
96 import org.onap.so.db.catalog.beans.Service;
97 import org.onap.so.db.catalog.beans.VfModuleCustomization;
98 import org.onap.so.db.catalog.beans.macro.NorthBoundRequest;
99 import org.onap.so.db.catalog.beans.macro.OrchestrationFlow;
100 import org.onap.so.db.request.beans.InfraActiveRequests;
101 import org.onap.so.db.request.beans.RequestProcessingData;
102 import org.onap.so.serviceinstancebeans.RequestDetails;
103 import org.onap.so.serviceinstancebeans.RequestParameters;
104 import org.onap.so.serviceinstancebeans.ServiceInstancesRequest;
105 import org.onap.so.serviceinstancebeans.SubscriberInfo;
106 import org.springframework.core.env.Environment;
108 public class WorkflowActionTest extends BaseTaskTest {
112 protected Environment environment;
114 protected WorkflowAction workflowAction;
115 private DelegateExecution execution;
120 protected WorkflowAction SPY_workflowAction;
123 public ExpectedException thrown = ExpectedException.none();
125 private String RESOURCE_PATH = "src/test/resources/__files/";
128 public void before() throws Exception {
129 execution = new DelegateExecutionFake();
130 org.onap.aai.domain.yang.ServiceInstance servInstance = new org.onap.aai.domain.yang.ServiceInstance();
131 servInstance.setServiceInstanceId("TEST");
132 when(bbSetupUtils.getAAIServiceInstanceByName(anyString(), anyObject())).thenReturn(servInstance);
133 workflowAction.setBbInputSetupUtils(bbSetupUtils);
134 workflowAction.setBbInputSetup(bbInputSetup);
141 public void selectExecutionListALaCarteNetworkCreateTest() throws Exception {
142 String gAction = "createInstance";
143 String resource = "Network";
144 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
145 execution.setVariable("requestAction", gAction);
147 new String(Files.readAllBytes(Paths.get("src/test/resources/__files/Macro/ServiceMacroAssign.json")));
148 execution.setVariable("bpmnRequest", bpmnRequest);
149 execution.setVariable("aLaCarte", true);
150 execution.setVariable("apiVersion", "7");
151 execution.setVariable("requestUri", "v6/networks/123");
153 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
154 List<OrchestrationFlow> orchFlows =
155 createFlowList("AssignNetwork1802BB", "CreateNetworkBB", "ActivateNetworkBB");
156 northBoundRequest.setOrchestrationFlowList(orchFlows);
158 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
159 true, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
160 workflowAction.selectExecutionList(execution);
161 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
162 assertEqualsBulkFlowName(ebbs, "AssignNetwork1802BB", "CreateNetworkBB", "ActivateNetworkBB");
166 public void selectExecutionListALaCarteNetworkDeleteTest() throws Exception {
167 String gAction = "deleteInstance";
168 String resource = "Network";
169 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
170 execution.setVariable("requestAction", gAction);
172 new String(Files.readAllBytes(Paths.get("src/test/resources/__files/Macro/ServiceMacroAssign.json")));
173 execution.setVariable("bpmnRequest", bpmnRequest);
174 execution.setVariable("aLaCarte", true);
175 execution.setVariable("apiVersion", "7");
176 execution.setVariable("requestUri", "v6/networks/123");
178 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
179 List<OrchestrationFlow> orchFlows =
180 createFlowList("DeactivateNetworkBB", "DeleteNetworkBB", "UnassignNetwork1802BB");
181 northBoundRequest.setOrchestrationFlowList(orchFlows);
183 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
184 true, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
185 workflowAction.selectExecutionList(execution);
186 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
187 assertEqualsBulkFlowName(ebbs, "DeactivateNetworkBB", "DeleteNetworkBB", "UnassignNetwork1802BB");
191 public void selectExecutionListALaCarteServiceCreateTest() throws Exception {
192 String gAction = "createInstance";
193 String resource = "Service";
194 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
195 execution.setVariable("requestAction", gAction);
197 new String(Files.readAllBytes(Paths.get("src/test/resources/__files/Macro/ServiceMacroAssign.json")));
198 execution.setVariable("bpmnRequest", bpmnRequest);
199 execution.setVariable("aLaCarte", true);
200 execution.setVariable("apiVersion", "7");
201 execution.setVariable("requestUri", "v6/serviceInstances/123");
204 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
205 List<OrchestrationFlow> orchFlows = createFlowList("AssignServiceInstanceBB", "ActivateServiceInstanceBB");
206 northBoundRequest.setOrchestrationFlowList(orchFlows);
208 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
209 true, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
210 workflowAction.selectExecutionList(execution);
211 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
212 assertEqualsBulkFlowName(ebbs, "AssignServiceInstanceBB", "ActivateServiceInstanceBB");
216 * SERVICE MACRO TESTS
219 public void selectExecutionListServiceMacroAssignTest() throws Exception {
220 String gAction = "assignInstance";
221 String resource = "Service";
222 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
223 execution.setVariable("requestAction", gAction);
225 new String(Files.readAllBytes(Paths.get("src/test/resources/__files/Macro/ServiceMacroAssign.json")));
226 execution.setVariable("bpmnRequest", bpmnRequest);
227 execution.setVariable("aLaCarte", false);
228 execution.setVariable("apiVersion", "7");
229 execution.setVariable("requestUri", "v6/serviceInstances/123");
232 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
233 List<OrchestrationFlow> orchFlows = createFlowList("AssignServiceInstanceBB", "AssignNetworkBB", "AssignVnfBB",
234 "AssignVolumeGroupBB", "AssignVfModuleBB");
235 northBoundRequest.setOrchestrationFlowList(orchFlows);
237 VfModuleCustomization vfModuleCustomization = new VfModuleCustomization();
238 vfModuleCustomization.setModelCustomizationUUID("a25e8e8c-58b8-4eec-810c-97dcc1f5cb7f");
239 HeatEnvironment volumeHeatEnv = new HeatEnvironment();
240 vfModuleCustomization.setVolumeHeatEnv(volumeHeatEnv);
241 org.onap.so.db.catalog.beans.VfModule vfModule = new org.onap.so.db.catalog.beans.VfModule();
242 HeatTemplate volumeHeatTemplate = new HeatTemplate();
243 vfModule.setVolumeHeatTemplate(volumeHeatTemplate);
244 vfModuleCustomization.setVfModule(vfModule);
246 VfModuleCustomization vfModuleCustomization2 = new VfModuleCustomization();
247 vfModuleCustomization2.setModelCustomizationUUID("72d9d1cd-f46d-447a-abdb-451d6fb05fa8");
248 HeatEnvironment heatEnvironment = new HeatEnvironment();
249 vfModuleCustomization2.setHeatEnvironment(heatEnvironment);
250 org.onap.so.db.catalog.beans.VfModule vfModule2 = new org.onap.so.db.catalog.beans.VfModule();
251 HeatTemplate moduleHeatTemplate = new HeatTemplate();
252 vfModule2.setModuleHeatTemplate(moduleHeatTemplate);
253 vfModuleCustomization2.setVfModule(vfModule2);
255 VfModuleCustomization vfModuleCustomization3 = vfModuleCustomization2;
256 vfModuleCustomization3.setModelCustomizationUUID("72d9d1cd-f46d-447a-abdb-451d6fb05fa8");
258 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
259 false, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
260 when(catalogDbClient.getVfModuleCustomizationByModelCuztomizationUUID("a25e8e8c-58b8-4eec-810c-97dcc1f5cb7f"))
261 .thenReturn(vfModuleCustomization);
262 when(catalogDbClient.getVfModuleCustomizationByModelCuztomizationUUID("72d9d1cd-f46d-447a-abdb-451d6fb05fa8"))
263 .thenReturn(vfModuleCustomization2);
264 when(catalogDbClient.getVfModuleCustomizationByModelCuztomizationUUID("da4d4327-fb7d-4311-ac7a-be7ba60cf969"))
265 .thenReturn(vfModuleCustomization3);
266 workflowAction.selectExecutionList(execution);
267 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
268 assertEqualsBulkFlowName(ebbs, "AssignServiceInstanceBB", "AssignVnfBB", "AssignVolumeGroupBB",
269 "AssignVfModuleBB", "AssignVfModuleBB", "AssignVfModuleBB");
273 public void selectExecutionListServiceMacroAssignNoCloudTest() throws Exception {
274 String gAction = "assignInstance";
275 String resource = "Service";
276 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
277 execution.setVariable("requestAction", gAction);
278 String bpmnRequest = new String(
279 Files.readAllBytes(Paths.get("src/test/resources/__files/Macro/ServiceMacroAssignNoCloud.json")));
280 execution.setVariable("bpmnRequest", bpmnRequest);
281 execution.setVariable("aLaCarte", false);
282 execution.setVariable("apiVersion", "7");
283 execution.setVariable("requestUri", "v6/serviceInstances/123");
286 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
287 List<OrchestrationFlow> orchFlows = createFlowList("AssignServiceInstanceBB", "AssignNetworkBB", "AssignVnfBB",
288 "AssignVolumeGroupBB", "AssignVfModuleBB");
289 northBoundRequest.setOrchestrationFlowList(orchFlows);
291 VfModuleCustomization vfModuleCustomization = new VfModuleCustomization();
292 vfModuleCustomization.setModelCustomizationUUID("a25e8e8c-58b8-4eec-810c-97dcc1f5cb7f");
293 HeatEnvironment volumeHeatEnv = new HeatEnvironment();
294 vfModuleCustomization.setVolumeHeatEnv(volumeHeatEnv);
295 org.onap.so.db.catalog.beans.VfModule vfModule = new org.onap.so.db.catalog.beans.VfModule();
296 HeatTemplate volumeHeatTemplate = new HeatTemplate();
297 vfModule.setVolumeHeatTemplate(volumeHeatTemplate);
298 vfModuleCustomization.setVfModule(vfModule);
300 VfModuleCustomization vfModuleCustomization2 = new VfModuleCustomization();
301 vfModuleCustomization2.setModelCustomizationUUID("72d9d1cd-f46d-447a-abdb-451d6fb05fa8");
302 HeatEnvironment heatEnvironment = new HeatEnvironment();
303 vfModuleCustomization2.setHeatEnvironment(heatEnvironment);
304 org.onap.so.db.catalog.beans.VfModule vfModule2 = new org.onap.so.db.catalog.beans.VfModule();
305 HeatTemplate moduleHeatTemplate = new HeatTemplate();
306 vfModule2.setModuleHeatTemplate(moduleHeatTemplate);
307 vfModuleCustomization2.setVfModule(vfModule2);
309 VfModuleCustomization vfModuleCustomization3 = vfModuleCustomization2;
310 vfModuleCustomization3.setModelCustomizationUUID("72d9d1cd-f46d-447a-abdb-451d6fb05fa8");
312 when(environment.getProperty("org.onap.so.cloud-owner")).thenReturn("att-aic");
313 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
314 false, "att-aic")).thenReturn(northBoundRequest);
315 when(catalogDbClient.getVfModuleCustomizationByModelCuztomizationUUID("a25e8e8c-58b8-4eec-810c-97dcc1f5cb7f"))
316 .thenReturn(vfModuleCustomization);
317 when(catalogDbClient.getVfModuleCustomizationByModelCuztomizationUUID("72d9d1cd-f46d-447a-abdb-451d6fb05fa8"))
318 .thenReturn(vfModuleCustomization2);
319 when(catalogDbClient.getVfModuleCustomizationByModelCuztomizationUUID("da4d4327-fb7d-4311-ac7a-be7ba60cf969"))
320 .thenReturn(vfModuleCustomization3);
321 workflowAction.selectExecutionList(execution);
322 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
323 assertEqualsBulkFlowName(ebbs, "AssignServiceInstanceBB", "AssignVnfBB", "AssignVolumeGroupBB",
324 "AssignVfModuleBB", "AssignVfModuleBB", "AssignVfModuleBB");
328 public void selectExecutionListServiceMacroActivateTest() throws Exception {
329 String gAction = "activateInstance";
330 String resource = "Service";
331 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
332 execution.setVariable("requestAction", gAction);
333 String bpmnRequest = new String(Files
334 .readAllBytes(Paths.get("src/test/resources/__files/Macro/ServiceMacroActivateDeleteUnassign.json")));
335 execution.setVariable("bpmnRequest", bpmnRequest);
336 execution.setVariable("aLaCarte", false);
337 execution.setVariable("apiVersion", "7");
338 execution.setVariable("requestUri", "v6/serviceInstances/si0");
341 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
342 List<OrchestrationFlow> orchFlows =
343 createFlowList("CreateNetworkBB", "ActivateNetworkBB", "CreateVolumeGroupBB", "ActivateVolumeGroupBB",
344 "CreateVfModuleBB", "ActivateVfModuleBB", "ActivateVnfBB", "ActivateServiceInstanceBB");
345 northBoundRequest.setOrchestrationFlowList(orchFlows);
347 ServiceInstance serviceInstanceAAI = new ServiceInstance();
348 serviceInstanceAAI.setServiceInstanceId("si0");
349 org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance serviceInstanceMSO =
350 new org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance();
351 org.onap.so.bpmn.servicedecomposition.bbobjects.GenericVnf vnf =
352 new org.onap.so.bpmn.servicedecomposition.bbobjects.GenericVnf();
353 vnf.setVnfId("vnf0");
356 org.onap.so.bpmn.servicedecomposition.bbobjects.VfModule vfModule = buildVfModule();
357 vnf.getVfModules().add(vfModule);
358 org.onap.so.bpmn.servicedecomposition.bbobjects.VfModule vfModule2 = buildVfModule();
359 vnf.getVfModules().add(vfModule2);
361 org.onap.so.bpmn.servicedecomposition.bbobjects.VolumeGroup volumeGroup =
362 new org.onap.so.bpmn.servicedecomposition.bbobjects.VolumeGroup();
363 volumeGroup.setVolumeGroupId("volumeGroup0");
364 vnf.getVolumeGroups().add(volumeGroup);
366 serviceInstanceMSO.getVnfs().add(vnf);
368 doReturn(serviceInstanceAAI).when(bbSetupUtils).getAAIServiceInstanceById("si0");
369 doReturn(serviceInstanceMSO).when(bbInputSetup).getExistingServiceInstance(serviceInstanceAAI);
370 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
371 false, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
372 workflowAction.selectExecutionList(execution);
373 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
374 assertEqualsBulkFlowName(ebbs, "CreateVolumeGroupBB", "ActivateVolumeGroupBB", "CreateVfModuleBB",
375 "CreateVfModuleBB", "ActivateVfModuleBB", "ActivateVfModuleBB", "ActivateVnfBB",
376 "ActivateServiceInstanceBB");
377 assertEquals("volumeGroup0", ebbs.get(0).getWorkflowResourceIds().getVolumeGroupId());
378 assertEquals("volumeGroup0", ebbs.get(1).getWorkflowResourceIds().getVolumeGroupId());
379 assertEquals("testVfModuleId1", ebbs.get(2).getWorkflowResourceIds().getVfModuleId());
380 assertEquals("testVfModuleId2", ebbs.get(3).getWorkflowResourceIds().getVfModuleId());
381 assertEquals("testVfModuleId1", ebbs.get(4).getWorkflowResourceIds().getVfModuleId());
382 assertEquals("testVfModuleId2", ebbs.get(5).getWorkflowResourceIds().getVfModuleId());
383 assertEquals("vnf0", ebbs.get(6).getWorkflowResourceIds().getVnfId());
384 assertEquals("si0", ebbs.get(7).getWorkflowResourceIds().getServiceInstanceId());
389 public void selectExecutionListServiceMacroDeactivateTest() throws Exception {
390 String gAction = "deactivateInstance";
391 String resource = "Service";
392 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
393 execution.setVariable("requestAction", gAction);
394 String bpmnRequest = new String(Files
395 .readAllBytes(Paths.get("src/test/resources/__files/Macro/ServiceMacroActivateDeleteUnassign.json")));
396 execution.setVariable("bpmnRequest", bpmnRequest);
397 execution.setVariable("aLaCarte", false);
398 execution.setVariable("apiVersion", "7");
399 execution.setVariable("requestUri", "v6/serviceInstances/123");
402 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
403 List<OrchestrationFlow> orchFlows = createFlowList("DeactivateServiceInstanceBB");
404 northBoundRequest.setOrchestrationFlowList(orchFlows);
406 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
407 false, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
408 workflowAction.selectExecutionList(execution);
409 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
410 assertEquals(ebbs.get(0).getBuildingBlock().getBpmnFlowName(), "DeactivateServiceInstanceBB");
414 public void selectExecutionListServiceMacroEmptyServiceTest() throws Exception {
415 String gAction = "createInstance";
416 String resource = "Service";
417 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
418 execution.setVariable("requestAction", gAction);
419 String bpmnRequest = new String(Files
420 .readAllBytes(Paths.get("src/test/resources/__files/Macro/ServiceMacroActivateDeleteUnassign.json")));
421 execution.setVariable("bpmnRequest", bpmnRequest);
422 execution.setVariable("aLaCarte", false);
423 execution.setVariable("apiVersion", "7");
424 execution.setVariable("requestUri", "v6/serviceInstances/123");
427 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
428 northBoundRequest.setIsToplevelflow(true);
429 List<OrchestrationFlow> orchFlows = createFlowList("AssignServiceInstanceBB", "CreateNetworkCollectionBB",
430 "AssignNetworkBB", "AssignVnfBB", "AssignVolumeGroupBB", "AssignVfModuleBB", "CreateNetworkBB",
431 "ActivateNetworkBB", "CreateVolumeGroupBB", "ActivateVolumeGroupBB", "CreateVfModuleBB",
432 "ActivateVfModuleBB", "AssignFabricConfigurationBB", "ActivateFabricConfigurationBB", "ActivateVnfBB",
433 "ActivateNetworkCollectionBB", "ActivateServiceInstanceBB");
434 northBoundRequest.setOrchestrationFlowList(orchFlows);
436 Service service = new Service();
437 doReturn(service).when(catalogDbClient).getServiceByID("3c40d244-808e-42ca-b09a-256d83d19d0a");
438 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
439 false, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
440 workflowAction.selectExecutionList(execution);
441 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
442 assertEqualsBulkFlowName(ebbs, "AssignServiceInstanceBB", "ActivateServiceInstanceBB");
446 public void selectExecutionListServiceMacroCreateJustNetworkTest() throws Exception {
447 String gAction = "createInstance";
448 String resource = "Service";
449 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
450 execution.setVariable("requestAction", gAction);
451 String bpmnRequest = new String(Files
452 .readAllBytes(Paths.get("src/test/resources/__files/Macro/ServiceMacroActivateDeleteUnassign.json")));
453 execution.setVariable("bpmnRequest", bpmnRequest);
454 execution.setVariable("aLaCarte", false);
455 execution.setVariable("apiVersion", "7");
456 execution.setVariable("requestUri", "v6/serviceInstances/123");
459 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
460 northBoundRequest.setIsToplevelflow(true);
461 List<OrchestrationFlow> orchFlows = createFlowList("AssignServiceInstanceBB", "CreateNetworkCollectionBB",
462 "AssignNetworkBB", "AssignVnfBB", "AssignVolumeGroupBB", "AssignVfModuleBB", "CreateNetworkBB",
463 "ActivateNetworkBB", "CreateVolumeGroupBB", "ActivateVolumeGroupBB", "CreateVfModuleBB",
464 "ActivateVfModuleBB", "AssignFabricConfigurationBB", "ActivateFabricConfigurationBB", "ActivateVnfBB",
465 "ActivateNetworkCollectionBB", "ActivateServiceInstanceBB");
466 northBoundRequest.setOrchestrationFlowList(orchFlows);
468 Service service = new Service();
469 NetworkResourceCustomization networkCustomization = new NetworkResourceCustomization();
470 networkCustomization.setModelCustomizationUUID("1234");
471 service.getNetworkCustomizations().add(networkCustomization);
472 doReturn(service).when(catalogDbClient).getServiceByID("3c40d244-808e-42ca-b09a-256d83d19d0a");
473 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
474 false, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
475 workflowAction.selectExecutionList(execution);
476 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
477 assertEqualsBulkFlowName(ebbs, "AssignServiceInstanceBB", "AssignNetworkBB", "CreateNetworkBB",
478 "ActivateNetworkBB", "ActivateServiceInstanceBB");
482 public void selectExecutionListServiceMacroCreateWithNetworkCollectionTest() throws Exception {
483 String gAction = "createInstance";
484 String resource = "Service";
485 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
486 execution.setVariable("requestAction", gAction);
487 String bpmnRequest = new String(Files
488 .readAllBytes(Paths.get("src/test/resources/__files/Macro/ServiceMacroActivateDeleteUnassign.json")));
489 execution.setVariable("bpmnRequest", bpmnRequest);
490 execution.setVariable("aLaCarte", false);
491 execution.setVariable("apiVersion", "7");
492 execution.setVariable("requestUri", "v6/serviceInstances/123");
495 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
496 northBoundRequest.setIsToplevelflow(true);
497 List<OrchestrationFlow> orchFlows = createFlowList("AssignServiceInstanceBB", "CreateNetworkCollectionBB",
498 "AssignNetworkBB", "AssignVnfBB", "AssignVolumeGroupBB", "AssignVfModuleBB", "CreateNetworkBB",
499 "ActivateNetworkBB", "CreateVolumeGroupBB", "ActivateVolumeGroupBB", "CreateVfModuleBB",
500 "ActivateVfModuleBB", "AssignFabricConfigurationBB", "ActivateFabricConfigurationBB", "ActivateVnfBB",
501 "ActivateNetworkCollectionBB", "ActivateServiceInstanceBB");
502 northBoundRequest.setOrchestrationFlowList(orchFlows);
504 Service service = new Service();
505 List<NetworkResourceCustomization> networkCustomizations = new ArrayList<>();
506 NetworkResourceCustomization networkCust = new NetworkResourceCustomization();
507 networkCust.setModelCustomizationUUID("123");
508 networkCustomizations.add(networkCust);
509 service.setNetworkCustomizations(networkCustomizations);
510 NetworkCollectionResourceCustomization collectionResourceCustomization =
511 new NetworkCollectionResourceCustomization();
512 collectionResourceCustomization.setModelCustomizationUUID("123");
514 CollectionResource collectionResource = new CollectionResource();
515 collectionResource.setToscaNodeType("NetworkCollection");
516 InstanceGroup instanceGroup = new InstanceGroup();
517 instanceGroup.setToscaNodeType("NetworkCollectionResource");
518 instanceGroup.setCollectionNetworkResourceCustomizations(new ArrayList<>());
519 CollectionNetworkResourceCustomization collectionNetworkResourceCust =
520 new CollectionNetworkResourceCustomization();
521 collectionNetworkResourceCust.setModelCustomizationUUID("123");
522 collectionNetworkResourceCust.setNetworkResourceCustomization(collectionResourceCustomization);
523 instanceGroup.getCollectionNetworkResourceCustomizations().add(collectionNetworkResourceCust);
524 List<CollectionResourceInstanceGroupCustomization> collectionInstanceGroupCustomizations = new ArrayList<>();
525 CollectionResourceInstanceGroupCustomization collectionInstanceGroupCustomization =
526 new CollectionResourceInstanceGroupCustomization();
527 collectionInstanceGroupCustomization.setModelCustomizationUUID("123");
528 collectionInstanceGroupCustomization.setSubInterfaceNetworkQuantity(3);
529 collectionInstanceGroupCustomizations.add(collectionInstanceGroupCustomization);
530 collectionInstanceGroupCustomization.setInstanceGroup(instanceGroup);
531 collectionInstanceGroupCustomization.setCollectionResourceCust(collectionResourceCustomization);
532 instanceGroup.setCollectionInstanceGroupCustomizations(collectionInstanceGroupCustomizations);
533 collectionResource.setInstanceGroup(instanceGroup);
534 collectionResourceCustomization.setCollectionResource(collectionResource);;
535 service.getCollectionResourceCustomizations().add(collectionResourceCustomization);
536 doReturn(service).when(catalogDbClient).getServiceByID("3c40d244-808e-42ca-b09a-256d83d19d0a");
537 doReturn(collectionResourceCustomization).when(catalogDbClient)
538 .getNetworkCollectionResourceCustomizationByID("123");
539 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
540 false, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
541 workflowAction.selectExecutionList(execution);
542 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
543 assertEqualsBulkFlowName(ebbs, "AssignServiceInstanceBB", "CreateNetworkCollectionBB", "AssignNetworkBB",
544 "CreateNetworkBB", "ActivateNetworkBB", "AssignNetworkBB", "CreateNetworkBB", "ActivateNetworkBB",
545 "AssignNetworkBB", "CreateNetworkBB", "ActivateNetworkBB", "ActivateNetworkCollectionBB",
546 "ActivateServiceInstanceBB");
547 assertEquals("Network id not empty", !ebbs.get(2).getWorkflowResourceIds().getNetworkId().isEmpty(), true);
548 assertEquals("Network id not empty", !ebbs.get(3).getWorkflowResourceIds().getNetworkId().isEmpty(), true);
549 assertEquals("Network id not empty", !ebbs.get(4).getWorkflowResourceIds().getNetworkId().isEmpty(), true);
550 assertEquals("Network id same for AssignNetworkBB CreateNetworkBB ActivateNetworkBB",
551 ebbs.get(2).getWorkflowResourceIds().getNetworkId() == ebbs.get(3).getWorkflowResourceIds()
553 && ebbs.get(3).getWorkflowResourceIds().getNetworkId() == ebbs.get(4).getWorkflowResourceIds()
556 assertEquals("Network id not empty", !ebbs.get(5).getWorkflowResourceIds().getNetworkId().isEmpty(), true);
557 assertEquals("Network id not empty", !ebbs.get(6).getWorkflowResourceIds().getNetworkId().isEmpty(), true);
558 assertEquals("Network id not empty", !ebbs.get(7).getWorkflowResourceIds().getNetworkId().isEmpty(), true);
559 assertEquals("Network id same for AssignNetworkBB CreateNetworkBB ActivateNetworkBB",
560 ebbs.get(5).getWorkflowResourceIds().getNetworkId() == ebbs.get(6).getWorkflowResourceIds()
562 && ebbs.get(6).getWorkflowResourceIds().getNetworkId() == ebbs.get(7).getWorkflowResourceIds()
565 assertEquals("Network id not empty", !ebbs.get(8).getWorkflowResourceIds().getNetworkId().isEmpty(), true);
566 assertEquals("Network id not empty", !ebbs.get(9).getWorkflowResourceIds().getNetworkId().isEmpty(), true);
567 assertEquals("Network id not empty", !ebbs.get(10).getWorkflowResourceIds().getNetworkId().isEmpty(), true);
568 assertEquals("Network id same for AssignNetworkBB CreateNetworkBB ActivateNetworkBB",
569 ebbs.get(8).getWorkflowResourceIds().getNetworkId() == ebbs.get(9).getWorkflowResourceIds()
571 && ebbs.get(9).getWorkflowResourceIds().getNetworkId() == ebbs.get(10).getWorkflowResourceIds()
577 public void selectExecutionListServiceMacroCreateWithUserParams() throws Exception {
578 String gAction = "createInstance";
579 String resource = "Service";
580 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
581 execution.setVariable("requestAction", gAction);
583 new String(Files.readAllBytes(Paths.get("src/test/resources/__files/Macro/ServiceMacroAssign.json")));
584 execution.setVariable("bpmnRequest", bpmnRequest);
585 execution.setVariable("aLaCarte", false);
586 execution.setVariable("apiVersion", "7");
587 execution.setVariable("requestUri", "v6/serviceInstances/123");
590 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
591 List<OrchestrationFlow> orchFlows = createFlowList("AssignServiceInstanceBB", "CreateNetworkCollectionBB",
592 "AssignNetworkBB", "AssignVnfBB", "AssignVolumeGroupBB", "AssignVfModuleBB", "CreateNetworkBB",
593 "ActivateNetworkBB", "CreateVolumeGroupBB", "ActivateVolumeGroupBB", "CreateVfModuleBB",
594 "ActivateVfModuleBB", "AssignFabricConfigurationBB", "ActivateFabricConfigurationBB", "ActivateVnfBB",
595 "ActivateNetworkCollectionBB", "ActivateServiceInstanceBB");
596 northBoundRequest.setOrchestrationFlowList(orchFlows);
598 Service service = new Service();
599 service.setModelUUID("3c40d244-808e-42ca-b09a-256d83d19d0a");
601 VfModuleCustomization vfModuleCustomization = new VfModuleCustomization();
602 vfModuleCustomization.setModelCustomizationUUID("a25e8e8c-58b8-4eec-810c-97dcc1f5cb7f");
603 HeatEnvironment volumeHeatEnv = new HeatEnvironment();
604 vfModuleCustomization.setVolumeHeatEnv(volumeHeatEnv);
605 org.onap.so.db.catalog.beans.VfModule vfModule = new org.onap.so.db.catalog.beans.VfModule();
606 HeatTemplate volumeHeatTemplate = new HeatTemplate();
607 vfModule.setVolumeHeatTemplate(volumeHeatTemplate);
608 vfModuleCustomization.setVfModule(vfModule);
610 VfModuleCustomization vfModuleCustomization2 = new VfModuleCustomization();
611 vfModuleCustomization2.setModelCustomizationUUID("72d9d1cd-f46d-447a-abdb-451d6fb05fa8");
612 HeatEnvironment heatEnvironment = new HeatEnvironment();
613 vfModuleCustomization2.setHeatEnvironment(heatEnvironment);
614 org.onap.so.db.catalog.beans.VfModule vfModule2 = new org.onap.so.db.catalog.beans.VfModule();
615 HeatTemplate moduleHeatTemplate = new HeatTemplate();
616 vfModule2.setModuleHeatTemplate(moduleHeatTemplate);
617 vfModuleCustomization2.setVfModule(vfModule2);
619 VfModuleCustomization vfModuleCustomization3 = vfModuleCustomization2;
620 vfModuleCustomization3.setModelCustomizationUUID("72d9d1cd-f46d-447a-abdb-451d6fb05fa8");
622 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
623 false, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
624 when(catalogDbClient.getVfModuleCustomizationByModelCuztomizationUUID("a25e8e8c-58b8-4eec-810c-97dcc1f5cb7f"))
625 .thenReturn(vfModuleCustomization);
626 when(catalogDbClient.getVfModuleCustomizationByModelCuztomizationUUID("72d9d1cd-f46d-447a-abdb-451d6fb05fa8"))
627 .thenReturn(vfModuleCustomization2);
628 when(catalogDbClient.getVfModuleCustomizationByModelCuztomizationUUID("da4d4327-fb7d-4311-ac7a-be7ba60cf969"))
629 .thenReturn(vfModuleCustomization3);
630 when(catalogDbClient.getServiceByID("3c40d244-808e-42ca-b09a-256d83d19d0a")).thenReturn(service);
631 workflowAction.selectExecutionList(execution);
632 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
633 assertEqualsBulkFlowName(ebbs, "AssignServiceInstanceBB", "AssignVnfBB", "AssignVolumeGroupBB",
634 "AssignVfModuleBB", "AssignVfModuleBB", "AssignVfModuleBB", "CreateVolumeGroupBB",
635 "ActivateVolumeGroupBB", "CreateVfModuleBB", "CreateVfModuleBB", "CreateVfModuleBB",
636 "ActivateVfModuleBB", "ActivateVfModuleBB", "ActivateVfModuleBB", "ActivateVnfBB",
637 "ActivateServiceInstanceBB");
638 assertEquals(3, ebbs.get(0).getWorkflowResourceIds().getServiceInstanceId().length());
639 int randomUUIDLength = UUID.randomUUID().toString().length();
640 assertEquals(randomUUIDLength, ebbs.get(1).getWorkflowResourceIds().getVnfId().length());
641 assertEquals(randomUUIDLength, ebbs.get(2).getWorkflowResourceIds().getVolumeGroupId().length());
642 assertEquals(randomUUIDLength, ebbs.get(3).getWorkflowResourceIds().getVfModuleId().length());
643 assertEquals(randomUUIDLength, ebbs.get(4).getWorkflowResourceIds().getVfModuleId().length());
644 assertEquals(randomUUIDLength, ebbs.get(5).getWorkflowResourceIds().getVfModuleId().length());
645 assertEquals(randomUUIDLength, ebbs.get(6).getWorkflowResourceIds().getVolumeGroupId().length());
646 assertEquals(randomUUIDLength, ebbs.get(7).getWorkflowResourceIds().getVolumeGroupId().length());
647 assertEquals(randomUUIDLength, ebbs.get(8).getWorkflowResourceIds().getVfModuleId().length());
648 assertEquals(randomUUIDLength, ebbs.get(9).getWorkflowResourceIds().getVfModuleId().length());
649 assertEquals(randomUUIDLength, ebbs.get(10).getWorkflowResourceIds().getVfModuleId().length());
650 assertEquals(randomUUIDLength, ebbs.get(11).getWorkflowResourceIds().getVfModuleId().length());
651 assertEquals(randomUUIDLength, ebbs.get(12).getWorkflowResourceIds().getVfModuleId().length());
652 assertEquals(randomUUIDLength, ebbs.get(13).getWorkflowResourceIds().getVfModuleId().length());
653 assertEquals(randomUUIDLength, ebbs.get(14).getWorkflowResourceIds().getVnfId().length());
654 assertEquals(3, ebbs.get(0).getWorkflowResourceIds().getServiceInstanceId().length());
655 assertEquals(true, execution.getVariable("homing"));
659 public void selectExecutionListServiceMacroDeleteTest() throws Exception {
660 String gAction = "deleteInstance";
661 String resource = "Service";
662 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
663 execution.setVariable("requestAction", gAction);
664 String bpmnRequest = new String(Files
665 .readAllBytes(Paths.get("src/test/resources/__files/Macro/ServiceMacroActivateDeleteUnassign.json")));
666 execution.setVariable("bpmnRequest", bpmnRequest);
667 execution.setVariable("aLaCarte", false);
668 execution.setVariable("apiVersion", "7");
669 execution.setVariable("requestUri", "v6/serviceInstances/123");
672 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
673 List<OrchestrationFlow> orchFlows = createFlowList("DeactivateVfModuleBB", "DeleteVfModuleBB",
674 "DeactivateVolumeGroupBB", "DeleteVolumeGroupBB", "DeactivateVnfBB", "DeactivateNetworkBB",
675 "DeleteNetworkBB", "DeleteNetworkCollectionBB", "DeactivateServiceInstanceBB", "UnassignVfModuleBB",
676 "UnassignVolumeGroupBB", "UnassignVnfBB", "UnassignNetworkBB", "UnassignServiceInstanceBB");
677 northBoundRequest.setOrchestrationFlowList(orchFlows);
679 ServiceInstance serviceInstanceAAI = new ServiceInstance();
680 serviceInstanceAAI.setServiceInstanceId("aaisi123");
681 org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance serviceInstanceMSO =
682 new org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance();
683 org.onap.so.bpmn.servicedecomposition.bbobjects.GenericVnf vnf =
684 new org.onap.so.bpmn.servicedecomposition.bbobjects.GenericVnf();
685 vnf.setVnfId("vnfId123");
687 org.onap.so.bpmn.servicedecomposition.bbobjects.VfModule vfModule = buildVfModule();
688 vnf.getVfModules().add(vfModule);
689 org.onap.so.bpmn.servicedecomposition.bbobjects.VfModule vfModule2 = buildVfModule();
690 vnf.getVfModules().add(vfModule2);
692 org.onap.so.bpmn.servicedecomposition.bbobjects.VolumeGroup volumeGroup =
693 new org.onap.so.bpmn.servicedecomposition.bbobjects.VolumeGroup();
694 volumeGroup.setVolumeGroupId("vg123");
695 vnf.getVolumeGroups().add(volumeGroup);
697 serviceInstanceMSO.getVnfs().add(vnf);
699 doReturn(serviceInstanceAAI).when(bbSetupUtils).getAAIServiceInstanceById("123");
700 doReturn(serviceInstanceMSO).when(bbInputSetup).getExistingServiceInstance(serviceInstanceAAI);
701 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
702 false, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
703 workflowAction.selectExecutionList(execution);
704 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
705 assertEqualsBulkFlowName(ebbs, "DeactivateVfModuleBB", "DeactivateVfModuleBB", "DeleteVfModuleBB",
706 "DeleteVfModuleBB", "DeactivateVolumeGroupBB", "DeleteVolumeGroupBB", "DeactivateVnfBB",
707 "DeactivateServiceInstanceBB", "UnassignVfModuleBB", "UnassignVfModuleBB", "UnassignVolumeGroupBB",
708 "UnassignVnfBB", "UnassignServiceInstanceBB");
712 public void selectExecutionListServiceMacroUnassignTest() throws Exception {
713 String gAction = "unassignInstance";
714 String resource = "Service";
715 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
716 execution.setVariable("requestAction", gAction);
717 String bpmnRequest = new String(Files
718 .readAllBytes(Paths.get("src/test/resources/__files/Macro/ServiceMacroActivateDeleteUnassign.json")));
719 execution.setVariable("bpmnRequest", bpmnRequest);
720 execution.setVariable("aLaCarte", false);
721 execution.setVariable("apiVersion", "7");
722 execution.setVariable("requestUri", "v6/serviceInstances/123");
725 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
726 List<OrchestrationFlow> orchFlows = createFlowList("UnassignVfModuleBB", "UnassignVolumeGroupBB",
727 "UnassignVnfBB", "UnassignNetworkBB", "UnassignServiceInstanceBB");
728 northBoundRequest.setOrchestrationFlowList(orchFlows);
730 ServiceInstance serviceInstanceAAI = new ServiceInstance();
731 serviceInstanceAAI.setServiceInstanceId("aaisi123");
732 org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance serviceInstanceMSO =
733 new org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance();
734 org.onap.so.bpmn.servicedecomposition.bbobjects.GenericVnf vnf =
735 new org.onap.so.bpmn.servicedecomposition.bbobjects.GenericVnf();
736 vnf.setVnfId("vnfId123");
738 org.onap.so.bpmn.servicedecomposition.bbobjects.VfModule vfModule = buildVfModule();
739 vnf.getVfModules().add(vfModule);
740 org.onap.so.bpmn.servicedecomposition.bbobjects.VfModule vfModule2 = buildVfModule();
741 vnf.getVfModules().add(vfModule2);
743 org.onap.so.bpmn.servicedecomposition.bbobjects.VolumeGroup volumeGroup =
744 new org.onap.so.bpmn.servicedecomposition.bbobjects.VolumeGroup();
745 volumeGroup.setVolumeGroupId("vg123");
746 vnf.getVolumeGroups().add(volumeGroup);
748 serviceInstanceMSO.getVnfs().add(vnf);
750 doReturn(serviceInstanceAAI).when(bbSetupUtils).getAAIServiceInstanceById("123");
751 doReturn(serviceInstanceMSO).when(bbInputSetup).getExistingServiceInstance(serviceInstanceAAI);
752 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
753 false, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
754 workflowAction.selectExecutionList(execution);
755 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
756 assertEqualsBulkFlowName(ebbs, "UnassignVfModuleBB", "UnassignVfModuleBB", "UnassignVolumeGroupBB",
757 "UnassignVnfBB", "UnassignServiceInstanceBB");
761 public void selectExecutionListServiceMacroDeleteNetworkCollectionTest() throws Exception {
762 String gAction = "deleteInstance";
763 String resource = "Service";
764 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
765 execution.setVariable("requestAction", gAction);
766 String bpmnRequest = new String(Files
767 .readAllBytes(Paths.get("src/test/resources/__files/Macro/ServiceMacroActivateDeleteUnassign.json")));
768 execution.setVariable("bpmnRequest", bpmnRequest);
769 execution.setVariable("aLaCarte", false);
770 execution.setVariable("apiVersion", "7");
771 execution.setVariable("requestUri", "v6/serviceInstances/123");
774 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
775 List<OrchestrationFlow> orchFlows = createFlowList("DeactivateVfModuleBB", "DeleteVfModuleBB",
776 "DeactivateVolumeGroupBB", "DeleteVolumeGroupBB", "DeactivateVnfBB", "DeactivateNetworkBB",
777 "DeleteNetworkBB", "DeleteNetworkCollectionBB", "DeactivateServiceInstanceBB", "UnassignVfModuleBB",
778 "UnassignVolumeGroupBB", "UnassignVnfBB", "UnassignNetworkBB", "UnassignServiceInstanceBB");
779 northBoundRequest.setOrchestrationFlowList(orchFlows);
781 ServiceInstance serviceInstanceAAI = new ServiceInstance();
782 serviceInstanceAAI.setServiceInstanceId("aaisi123");
783 org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance serviceInstanceMSO =
784 new org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance();
786 org.onap.so.bpmn.servicedecomposition.bbobjects.L3Network network =
787 new org.onap.so.bpmn.servicedecomposition.bbobjects.L3Network();
788 network.setNetworkId("123");
789 serviceInstanceMSO.getNetworks().add(network);
790 org.onap.so.bpmn.servicedecomposition.bbobjects.L3Network network2 =
791 new org.onap.so.bpmn.servicedecomposition.bbobjects.L3Network();
792 network2.setNetworkId("321");
793 serviceInstanceMSO.getNetworks().add(network2);
795 Collection collection = new Collection();
796 serviceInstanceMSO.setCollection(collection);
798 doReturn(serviceInstanceAAI).when(bbSetupUtils).getAAIServiceInstanceById("123");
799 doReturn(serviceInstanceMSO).when(bbInputSetup).getExistingServiceInstance(serviceInstanceAAI);
800 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
801 false, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
802 workflowAction.selectExecutionList(execution);
803 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
804 assertEqualsBulkFlowName(ebbs, "DeactivateNetworkBB", "DeleteNetworkBB", "UnassignNetworkBB",
805 "DeactivateNetworkBB", "DeleteNetworkBB", "UnassignNetworkBB", "DeleteNetworkCollectionBB",
806 "DeactivateServiceInstanceBB", "UnassignServiceInstanceBB");
810 public void selectExecutionListVnfMacroRecreateTest() throws Exception {
811 String gAction = "recreateInstance";
812 String resource = "Vnf";
813 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
814 execution.setVariable("requestAction", gAction);
816 new String(Files.readAllBytes(Paths.get("src/test/resources/__files/Macro/VnfMacroReplace.json")));
817 execution.setVariable("bpmnRequest", bpmnRequest);
818 execution.setVariable("aLaCarte", false);
819 execution.setVariable("apiVersion", "7");
820 execution.setVariable("requestUri", "v7/serviceInstances/123/vnfs/1234/recreate");
821 execution.setVariable("serviceInstanceId", "123");
822 execution.setVariable("vnfId", "1234");
824 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
825 List<OrchestrationFlow> orchFlows = createFlowList("AAICheckVnfInMaintBB", "AAISetVnfInMaintBB",
826 "DeactivateFabricConfigurationBB", "UnassignFabricConfigurationBB", "DeactivateVfModuleBB",
827 "DeleteVfModuleBB", "DeactivateVnfBB", "CreateVfModuleBB", "ActivateVfModuleBB",
828 "AssignFabricConfigurationBB", "ActivateFabricConfigurationBB", "ActivateVnfBB", "SDNOVnfHealthCheckBB",
829 "AAIUnsetVnfInMaintBB");
830 northBoundRequest.setOrchestrationFlowList(orchFlows);
832 ServiceInstance serviceInstanceAAI = new ServiceInstance();
833 serviceInstanceAAI.setServiceInstanceId("123");
834 org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance serviceInstanceMSO =
835 new org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance();
836 org.onap.so.bpmn.servicedecomposition.bbobjects.GenericVnf vnf =
837 new org.onap.so.bpmn.servicedecomposition.bbobjects.GenericVnf();
838 vnf.setVnfId("1234");
840 org.onap.so.bpmn.servicedecomposition.bbobjects.VfModule vfModule =
841 new org.onap.so.bpmn.servicedecomposition.bbobjects.VfModule();
842 vfModule.setVfModuleId("vfModule1");
843 vnf.getVfModules().add(vfModule);
844 org.onap.so.bpmn.servicedecomposition.bbobjects.VfModule vfModule2 =
845 new org.onap.so.bpmn.servicedecomposition.bbobjects.VfModule();
846 vfModule2.setVfModuleId("vfModule2");
847 vnf.getVfModules().add(vfModule2);
849 serviceInstanceMSO.getVnfs().add(vnf);
851 doReturn(serviceInstanceAAI).when(bbSetupUtils).getAAIServiceInstanceById("123");
852 doReturn(serviceInstanceMSO).when(bbInputSetup).getExistingServiceInstance(serviceInstanceAAI);
853 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
854 false, "cloud-owner")).thenReturn(northBoundRequest);
855 workflowAction.selectExecutionList(execution);
856 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
857 assertEqualsBulkFlowName(ebbs, "AAICheckVnfInMaintBB", "AAISetVnfInMaintBB", "DeactivateVfModuleBB",
858 "DeactivateVfModuleBB", "DeleteVfModuleBB", "DeleteVfModuleBB", "DeactivateVnfBB", "CreateVfModuleBB",
859 "CreateVfModuleBB", "ActivateVfModuleBB", "ActivateVfModuleBB", "ActivateVnfBB", "SDNOVnfHealthCheckBB",
860 "AAIUnsetVnfInMaintBB");
864 public void selectExecutionListVnfMacroReplaceTest() throws Exception {
865 String gAction = "replaceInstance";
866 String resource = "Vnf";
867 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
868 execution.setVariable("requestAction", gAction);
870 new String(Files.readAllBytes(Paths.get("src/test/resources/__files/Macro/VnfMacroReplace.json")));
871 execution.setVariable("bpmnRequest", bpmnRequest);
872 execution.setVariable("aLaCarte", false);
873 execution.setVariable("apiVersion", "7");
874 execution.setVariable("requestUri", "v7/serviceInstances/123/vnfs/1234/replace");
875 execution.setVariable("serviceInstanceId", "123");
876 execution.setVariable("vnfId", "1234");
878 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
879 List<OrchestrationFlow> orchFlows = createFlowList("AAICheckVnfInMaintBB", "AAISetVnfInMaintBB",
880 "DeactivateFabricConfigurationBB", "UnassignFabricConfigurationBB", "DeactivateVfModuleBB",
881 "DeleteVfModuleBB", "DeactivateVnfBB", "ChangeModelVfModuleBB", "CreateVfModuleBB",
882 "ActivateVfModuleBB", "AssignFabricConfigurationBB", "ActivateFabricConfigurationBB",
883 "ChangeModelVnfBB", "ActivateVnfBB", "ChangeModelServiceInstanceBB", "SDNOVnfHealthCheckBB",
884 "AAIUnsetVnfInMaintBB");
885 northBoundRequest.setOrchestrationFlowList(orchFlows);
887 ServiceInstance serviceInstanceAAI = new ServiceInstance();
888 serviceInstanceAAI.setServiceInstanceId("123");
889 org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance serviceInstanceMSO =
890 new org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance();
891 org.onap.so.bpmn.servicedecomposition.bbobjects.GenericVnf vnf =
892 new org.onap.so.bpmn.servicedecomposition.bbobjects.GenericVnf();
893 vnf.setVnfId("1234");
894 org.onap.so.bpmn.servicedecomposition.bbobjects.VfModule vfModule =
895 new org.onap.so.bpmn.servicedecomposition.bbobjects.VfModule();
896 vfModule.setVfModuleId("vfModule1");
897 vnf.getVfModules().add(vfModule);
898 org.onap.so.bpmn.servicedecomposition.bbobjects.VfModule vfModule2 =
899 new org.onap.so.bpmn.servicedecomposition.bbobjects.VfModule();
900 vfModule2.setVfModuleId("vfModule2");
901 vnf.getVfModules().add(vfModule2);
902 serviceInstanceMSO.getVnfs().add(vnf);
903 VfModule vfModuleAAI = new VfModule();
904 vfModuleAAI.setVfModuleId("vfModule2");
905 RelationshipList relationshipList = new RelationshipList();
906 Relationship relationship = new Relationship();
907 relationshipList.getRelationship().add(relationship);
908 vfModuleAAI.setRelationshipList(relationshipList);
909 Relationships relationships = new Relationships("abc");
910 Configuration config = new Configuration();
911 config.setConfigurationId("configId");
912 Optional<Configuration> configOp = Optional.of(config);
913 Optional<Relationships> relationshipsOp = Optional.of(relationships);
915 doReturn(relationshipsOp).when(workflowActionUtils).extractRelationshipsVnfc(isA(Relationships.class));
916 doReturn(configOp).when(workflowActionUtils).extractRelationshipsConfiguration(isA(Relationships.class));
917 doReturn(vfModuleAAI).when(bbSetupUtils).getAAIVfModule("1234", "vfModule2");
918 doReturn(serviceInstanceAAI).when(bbSetupUtils).getAAIServiceInstanceById("123");
919 doReturn(serviceInstanceMSO).when(bbInputSetup).getExistingServiceInstance(serviceInstanceAAI);
920 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
921 false, "cloud-owner")).thenReturn(northBoundRequest);
922 workflowAction.selectExecutionList(execution);
923 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
924 assertEqualsBulkFlowName(ebbs, "AAICheckVnfInMaintBB", "AAISetVnfInMaintBB", "DeactivateFabricConfigurationBB",
925 "UnassignFabricConfigurationBB", "DeactivateVfModuleBB", "DeactivateVfModuleBB", "DeleteVfModuleBB",
926 "DeleteVfModuleBB", "DeactivateVnfBB", "ChangeModelVfModuleBB", "ChangeModelVfModuleBB",
927 "CreateVfModuleBB", "CreateVfModuleBB", "ActivateVfModuleBB", "ActivateVfModuleBB",
928 "AssignFabricConfigurationBB", "ActivateFabricConfigurationBB", "ChangeModelVnfBB", "ActivateVnfBB",
929 "ChangeModelServiceInstanceBB", "SDNOVnfHealthCheckBB", "AAIUnsetVnfInMaintBB");
934 public void selectExecutionListNetworkCollectionMacroCreate() throws Exception {
935 String gAction = "createInstance";
936 String resource = "NetworkCollection";
937 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
938 execution.setVariable("requestAction", gAction);
939 String bpmnRequest = new String(
940 Files.readAllBytes(Paths.get("src/test/resources/__files/Macro/CreateNetworkCollection.json")));
941 execution.setVariable("bpmnRequest", bpmnRequest);
942 execution.setVariable("aLaCarte", false);
943 execution.setVariable("apiVersion", "7");
944 execution.setVariable("requestUri", "v6/serviceInstances/123/networkCollections/123");
947 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
948 List<OrchestrationFlow> orchFlows = createFlowList("CreateNetworkCollectionBB", "AssignNetworkBB",
949 "CreateNetworkBB", "ActivateNetworkBB", "ActivateNetworkCollectionBB");
950 northBoundRequest.setOrchestrationFlowList(orchFlows);
952 Service service = new Service();
953 CollectionResourceCustomization collectionResourceCustomization = new CollectionResourceCustomization();
954 CollectionResource collectionResource = new CollectionResource();
955 collectionResource.setToscaNodeType("Data NetworkCollection Data");
956 collectionResourceCustomization.setCollectionResource(collectionResource);
957 service.getCollectionResourceCustomizations().add(collectionResourceCustomization);
959 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
960 false, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
961 when(catalogDbClient.getServiceByID("3c40d244-808e-42ca-b09a-256d83d19d0a")).thenReturn(service);
962 workflowAction.selectExecutionList(execution);
963 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
964 assertEqualsBulkFlowName(ebbs, "CreateNetworkCollectionBB", "AssignNetworkBB", "CreateNetworkBB",
965 "ActivateNetworkBB", "AssignNetworkBB", "CreateNetworkBB", "ActivateNetworkBB",
966 "ActivateNetworkCollectionBB");
971 public void selectExecutionListNetworkCollectionMacroDelete() throws Exception {
972 String gAction = "deleteInstance";
973 String resource = "NetworkCollection";
974 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
975 execution.setVariable("requestAction", gAction);
976 String bpmnRequest = new String(
977 Files.readAllBytes(Paths.get("src/test/resources/__files/Macro/CreateNetworkCollection.json")));
978 execution.setVariable("bpmnRequest", bpmnRequest);
979 execution.setVariable("aLaCarte", false);
980 execution.setVariable("apiVersion", "7");
981 execution.setVariable("requestUri", "v6/serviceInstances/123/networkCollections/123");
983 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
984 List<OrchestrationFlow> orchFlows = createFlowList("DeactivateNetworkBB", "DeleteNetworkBB",
985 "UnassignNetworkBB", "DeactivateNetworkCollectionBB", "DeleteNetworkCollectionBB");
986 northBoundRequest.setOrchestrationFlowList(orchFlows);
988 Service service = new Service();
989 CollectionResourceCustomization collectionResourceCustomization = new CollectionResourceCustomization();
990 CollectionResource collectionResource = new CollectionResource();
991 collectionResource.setToscaNodeType("Data NetworkCollection Data");
992 collectionResourceCustomization.setCollectionResource(collectionResource);
993 service.getCollectionResourceCustomizations().add(collectionResourceCustomization);
995 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
996 false, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
997 when(catalogDbClient.getServiceByID("3c40d244-808e-42ca-b09a-256d83d19d0a")).thenReturn(service);
998 workflowAction.selectExecutionList(execution);
999 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
1000 assertEqualsBulkFlowName(ebbs, "DeactivateNetworkBB", "DeleteNetworkBB", "UnassignNetworkBB",
1001 "DeactivateNetworkBB", "DeleteNetworkBB", "UnassignNetworkBB", "DeactivateNetworkCollectionBB",
1002 "DeleteNetworkCollectionBB");
1006 public void selectExecutionListALaCarteVfModuleNoFabricCreateTest() throws Exception {
1007 String gAction = "createInstance";
1008 String resource = "VfModule";
1009 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
1010 execution.setVariable("requestAction", gAction);
1011 String bpmnRequest =
1012 new String(Files.readAllBytes(Paths.get("src/test/resources/__files/VfModuleCreateWithFabric.json")));
1013 execution.setVariable("bpmnRequest", bpmnRequest);
1014 execution.setVariable("aLaCarte", true);
1015 execution.setVariable("apiVersion", "7");
1016 execution.setVariable("requestUri",
1017 "v7/serviceInstances/f647e3ef-6d2e-4cd3-bff4-8df4634208de/vnfs/b80b16a5-f80d-4ffa-91c8-bd47c7438a3d/vfModules");
1020 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
1021 List<OrchestrationFlow> orchFlows = createFlowList("AssignVfModuleBB", "CreateVfModuleBB", "ActivateVfModuleBB",
1022 "AssignFabricConfigurationBB", "ActivateFabricConfigurationBB");
1023 northBoundRequest.setOrchestrationFlowList(orchFlows);
1025 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
1026 true, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
1027 workflowAction.selectExecutionList(execution);
1028 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
1029 assertEqualsBulkFlowName(ebbs, "AssignVfModuleBB", "CreateVfModuleBB", "ActivateVfModuleBB");
1033 public void selectExecutionListALaCarteVfModuleFabricCreateTest() throws Exception {
1034 String gAction = "createInstance";
1035 String resource = "VfModule";
1036 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
1037 execution.setVariable("requestAction", gAction);
1038 String bpmnRequest =
1039 new String(Files.readAllBytes(Paths.get("src/test/resources/__files/VfModuleCreateWithFabric.json")));
1040 execution.setVariable("bpmnRequest", bpmnRequest);
1041 execution.setVariable("aLaCarte", true);
1042 execution.setVariable("apiVersion", "7");
1043 execution.setVariable("requestUri",
1044 "v7/serviceInstances/f647e3ef-6d2e-4cd3-bff4-8df4634208de/vnfs/b80b16a5-f80d-4ffa-91c8-bd47c7438a3d/vfModules");
1046 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
1047 List<OrchestrationFlow> orchFlows = createFlowList("AssignVfModuleBB", "CreateVfModuleBB", "ActivateVfModuleBB",
1048 "AssignFabricConfigurationBB", "ActivateFabricConfigurationBB");
1049 northBoundRequest.setOrchestrationFlowList(orchFlows);
1051 List<CvnfcCustomization> cvnfcCustomizations = new ArrayList<CvnfcCustomization>();
1052 CvnfcCustomization cvnfcCustomization = new CvnfcCustomization();
1053 CvnfcConfigurationCustomization vnfVfmoduleCvnfcConfigurationCustomization =
1054 new CvnfcConfigurationCustomization();
1055 ConfigurationResource configurationResource = new ConfigurationResource();
1056 configurationResource.setToscaNodeType("FabricConfiguration");
1057 vnfVfmoduleCvnfcConfigurationCustomization.setConfigurationResource(configurationResource);
1058 vnfVfmoduleCvnfcConfigurationCustomization.setModelInstanceName("modelInstanceName1");
1059 vnfVfmoduleCvnfcConfigurationCustomization.setCvnfcCustomization(cvnfcCustomization);
1060 List<CvnfcConfigurationCustomization> custSet = new ArrayList<CvnfcConfigurationCustomization>();
1061 custSet.add(vnfVfmoduleCvnfcConfigurationCustomization);
1062 cvnfcCustomization.setCvnfcConfigurationCustomization(custSet);
1063 cvnfcCustomization.setDescription("description");
1064 cvnfcCustomizations.add(cvnfcCustomization);
1066 CvnfcCustomization cvnfcCustomization2 = new CvnfcCustomization();
1067 CvnfcConfigurationCustomization vnfVfmoduleCvnfcConfigurationCustomization2 =
1068 new CvnfcConfigurationCustomization();
1069 ConfigurationResource configurationResource2 = new ConfigurationResource();
1070 configurationResource2.setToscaNodeType("FabricConfiguration");
1071 vnfVfmoduleCvnfcConfigurationCustomization2.setConfigurationResource(configurationResource2);
1072 vnfVfmoduleCvnfcConfigurationCustomization2.setModelInstanceName("modelInstanceName2");
1073 vnfVfmoduleCvnfcConfigurationCustomization2.setCvnfcCustomization(cvnfcCustomization2);
1074 List<CvnfcConfigurationCustomization> custSet2 = new ArrayList<CvnfcConfigurationCustomization>();
1075 custSet2.add(vnfVfmoduleCvnfcConfigurationCustomization2);
1076 cvnfcCustomization2.setCvnfcConfigurationCustomization(custSet2);
1077 cvnfcCustomization2.setDescription("description2");
1078 cvnfcCustomizations.add(cvnfcCustomization2);
1080 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
1081 true, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
1082 // when(catalogDbClient.getCvnfcCustomizationByVnfCustomizationUUIDAndVfModuleCustomizationUUID("fc25201d-36d6-43a3-8d39-fdae88e526ae",
1083 // "9a6d01fd-19a7-490a-9800-460830a12e0b")).thenReturn(cvnfcCustomizations);
1084 workflowAction.selectExecutionList(execution);
1085 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
1086 assertEqualsBulkFlowName(ebbs, "AssignVfModuleBB", "CreateVfModuleBB", "ActivateVfModuleBB",
1087 "AssignFabricConfigurationBB", "ActivateFabricConfigurationBB", "AssignFabricConfigurationBB",
1088 "ActivateFabricConfigurationBB");
1092 public void selectExecutionListALaCarteVfModuleFabricDeleteTest() throws Exception {
1093 String gAction = "deleteInstance";
1094 String resource = "VfModule";
1095 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
1096 execution.setVariable("requestAction", gAction);
1097 String bpmnRequest =
1098 new String(Files.readAllBytes(Paths.get("src/test/resources/__files/VfModuleCreateWithFabric.json")));
1099 execution.setVariable("bpmnRequest", bpmnRequest);
1100 execution.setVariable("aLaCarte", true);
1101 execution.setVariable("apiVersion", "7");
1102 execution.setVariable("requestUri",
1103 "v7/serviceInstances/f647e3ef-6d2e-4cd3-bff4-8df4634208de/vnfs/b80b16a5-f80d-4ffa-91c8-bd47c7438a3d/vfModules");
1105 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
1106 List<OrchestrationFlow> orchFlows = createFlowList("DeactivateVfModuleBB", "DeleteVfModuleBB",
1107 "UnassignVfModuleBB", "DeactivateFabricConfigurationBB", "UnassignFabricConfigurationBB");
1108 northBoundRequest.setOrchestrationFlowList(orchFlows);
1110 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
1111 true, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
1113 org.onap.aai.domain.yang.GenericVnf vnf = new org.onap.aai.domain.yang.GenericVnf();
1114 vnf.setVnfId("vnf0");
1115 vnf.setModelCustomizationId("modelCustomizationId");
1116 when(bbSetupUtils.getAAIGenericVnf(anyObject())).thenReturn(vnf);
1118 org.onap.aai.domain.yang.VfModule vfModule = new org.onap.aai.domain.yang.VfModule();
1119 vfModule.setModelCustomizationId("modelCustomizationId");
1120 when(bbSetupUtils.getAAIVfModule(anyObject(), anyObject())).thenReturn(vfModule);
1122 List<org.onap.aai.domain.yang.Vnfc> vnfcs = new ArrayList<org.onap.aai.domain.yang.Vnfc>();
1123 org.onap.aai.domain.yang.Vnfc vnfc = new org.onap.aai.domain.yang.Vnfc();
1124 vnfc.setModelInvariantId("modelInvariantId");
1125 vnfc.setVnfcName("testVnfcName");
1127 doReturn(vnfcs).when(SPY_workflowAction).getRelatedResourcesInVfModule(anyObject(), anyObject(), anyObject(),
1130 List<org.onap.aai.domain.yang.Configuration> configurations =
1131 new ArrayList<org.onap.aai.domain.yang.Configuration>();
1132 org.onap.aai.domain.yang.Configuration configuration = new org.onap.aai.domain.yang.Configuration();
1133 configuration.setConfigurationId("configurationId");
1134 configuration.setModelCustomizationId("modelCustimizationId");
1135 configuration.setConfigurationName("testConfigurationName");
1136 configurations.add(configuration);
1137 doReturn(configurations).when(SPY_workflowAction).getRelatedResourcesInVnfc(anyObject(), anyObject(),
1140 doReturn("testName").when(SPY_workflowAction).getVnfcNameForConfiguration(anyObject());
1142 SPY_workflowAction.selectExecutionList(execution);
1143 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
1144 assertEqualsBulkFlowName(ebbs, "DeactivateFabricConfigurationBB", "UnassignFabricConfigurationBB",
1145 "DeactivateVfModuleBB", "DeleteVfModuleBB", "UnassignVfModuleBB");
1149 public void selectExecutionListALaCarteVfModuleNoFabricDeleteTest() throws Exception {
1150 String gAction = "deleteInstance";
1151 String resource = "VfModule";
1152 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
1153 execution.setVariable("requestAction", gAction);
1154 String bpmnRequest =
1155 new String(Files.readAllBytes(Paths.get("src/test/resources/__files/VfModuleCreateWithFabric.json")));
1156 execution.setVariable("bpmnRequest", bpmnRequest);
1157 execution.setVariable("aLaCarte", true);
1158 execution.setVariable("apiVersion", "7");
1159 execution.setVariable("requestUri",
1160 "v7/serviceInstances/f647e3ef-6d2e-4cd3-bff4-8df4634208de/vnfs/b80b16a5-f80d-4ffa-91c8-bd47c7438a3d/vfModules");
1162 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
1163 List<OrchestrationFlow> orchFlows = createFlowList("DeactivateVfModuleBB", "DeleteVfModuleBB",
1164 "UnassignVfModuleBB", "DeactivateFabricConfigurationBB", "UnassignFabricConfigurationBB");
1165 northBoundRequest.setOrchestrationFlowList(orchFlows);
1167 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
1168 true, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
1170 org.onap.aai.domain.yang.GenericVnf vnf = new org.onap.aai.domain.yang.GenericVnf();
1171 vnf.setVnfId("vnf0");
1172 vnf.setModelCustomizationId("modelCustomizationId");
1173 when(bbSetupUtils.getAAIGenericVnf(anyObject())).thenReturn(vnf);
1175 org.onap.aai.domain.yang.VfModule vfModule = new org.onap.aai.domain.yang.VfModule();
1176 vfModule.setModelCustomizationId("modelCustomizationId");
1177 when(bbSetupUtils.getAAIVfModule(anyObject(), anyObject())).thenReturn(vfModule);
1179 List<org.onap.aai.domain.yang.Vnfc> vnfcs = new ArrayList<org.onap.aai.domain.yang.Vnfc>();
1180 org.onap.aai.domain.yang.Vnfc vnfc = new org.onap.aai.domain.yang.Vnfc();
1181 vnfc.setModelInvariantId("modelInvariantId");
1182 vnfc.setVnfcName("testVnfcName");
1184 doReturn(vnfcs).when(SPY_workflowAction).getRelatedResourcesInVfModule(anyObject(), anyObject(), anyObject(),
1187 List<org.onap.aai.domain.yang.Configuration> configurations =
1188 new ArrayList<org.onap.aai.domain.yang.Configuration>();
1189 org.onap.aai.domain.yang.Configuration configuration = new org.onap.aai.domain.yang.Configuration();
1190 doReturn(configurations).when(SPY_workflowAction).getRelatedResourcesInVnfc(anyObject(), anyObject(),
1193 doReturn("testName").when(SPY_workflowAction).getVnfcNameForConfiguration(anyObject());
1195 SPY_workflowAction.selectExecutionList(execution);
1196 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
1197 assertEqualsBulkFlowName(ebbs, "DeactivateVfModuleBB", "DeleteVfModuleBB", "UnassignVfModuleBB");
1201 public void selectExecutionListMacroResumeTest() throws Exception {
1202 String gAction = "createInstance";
1203 String resource = "Service";
1204 execution.setVariable("mso-request-id", "00f704ca-c5e5-4f95-a72c-6889db7b0688");
1205 execution.setVariable("requestAction", gAction);
1206 String bpmnRequest =
1207 new String(Files.readAllBytes(Paths.get("src/test/resources/__files/Macro/ServiceMacroAssign.json")));
1208 execution.setVariable("bpmnRequest", bpmnRequest);
1209 execution.setVariable("aLaCarte", false);
1210 execution.setVariable("apiVersion", "7");
1211 execution.setVariable("requestUri", "v6/serviceInstances/123");
1213 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
1214 List<OrchestrationFlow> orchFlows = createFlowList("AssignServiceInstanceBB");
1215 northBoundRequest.setOrchestrationFlowList(orchFlows);
1217 Service service = new Service();
1218 service.setModelUUID("3c40d244-808e-42ca-b09a-256d83d19d0a");
1220 ServiceInstance si = new ServiceInstance();
1222 when(bbSetupUtils.getAAIServiceInstanceById("123")).thenReturn(si);
1223 when(catalogDbClient.getServiceByID("3c40d244-808e-42ca-b09a-256d83d19d0a")).thenReturn(service);
1225 String flowsToExecuteString =
1226 "[{\"buildingBlock\":{\"mso-id\":\"2f9ddc4b-4dcf-4129-a35f-be1625ae0176\",\"bpmn-flow-name\":\"AssignServiceInstanceBB\",\"key\":\"7adc7c29-21a3-40a2-b8b6-5d4ad08b68e9\",\"is-virtual-link\":false,\"virtual-link-key\":null},\"requestId\":\"9c944122-d161-4280-8594-48c06a9d96d5\",\"apiVersion\":\"7\",\"resourceId\":\"d1d35800-783d-42d3-82f6-d654c5054a6e\",\"requestAction\":\"deleteInstance\",\"vnfType\":\"\",\"aLaCarte\":true,\"homing\":false,\"workflowResourceIds\":{\"serviceInstanceId\":\"ff9dae72-05bb-4277-ad2b-1b082467c138\",\"vnfId\":\"84a29830-e533-4f20-a838-910c740bf24c\",\"networkId\":\"\",\"volumeGroupId\":\"\",\"vfModuleId\":\"d1d35800-783d-42d3-82f6-d654c5054a6e\",\"networkCollectionId\":null,\"configurationId\":\"10f8a3a3-91bf-4821-9515-c01b2864dff0\",\"instanceGroupId\":\"\"},\"requestDetails\":{\"modelInfo\":{\"modelCustomizationName\":\"McmrNcUpVnf20191..cr_mccm_fc_base..module-0\",\"modelInvariantId\":\"8028fcc0-96dc-427d-a4de-4536245943da\",\"modelType\":\"vfModule\",\"modelId\":\"00d15ebb-c80e-43c1-80f0-90c40dde70b0\",\"modelName\":\"McmrNcUpVnf20191..cr_mccm_fc_base..module-0\",\"modelVersion\":\"1\",\"modelCustomizationUuid\":\"7adc7c29-21a3-40a2-b8b6-5d4ad08b68e9\",\"modelVersionId\":\"00d15ebb-c80e-43c1-80f0-90c40dde70b0\",\"modelCustomizationId\":\"7adc7c29-21a3-40a2-b8b6-5d4ad08b68e9\",\"modelUuid\":\"00d15ebb-c80e-43c1-80f0-90c40dde70b0\",\"modelInvariantUuid\":\"8028fcc0-96dc-427d-a4de-4536245943da\",\"modelInstanceName\":\"McmrNcUpVnf20191..cr_mccm_fc_base..module-0\"},\"requestInfo\":{\"source\":\"VID\",\"suppressRollback\":false,\"requestorId\":\"pj8646\"},\"cloudConfiguration\":{\"tenantId\":\"e2a6af59d1cb43b2874e943bbbf8470a\",\"cloudOwner\":\"att-nc\",\"lcpCloudRegionId\":\"auk51b\"},\"requestParameters\":{\"testApi\":\"GR_API\"}},\"configurationResourceKeys\":{\"vfModuleCustomizationUUID\":\"7adc7c29-21a3-40a2-b8b6-5d4ad08b68e9\",\"vnfResourceCustomizationUUID\":\"a80f05b8-d651-44af-b999-8ed78fb4582f\",\"cvnfcCustomizationUUID\":\"69cce457-9ffd-4359-962b-0596a1e83ad1\",\"vnfcName\":\"zauk51bmcmr01mcm001\"}}]";
1227 ObjectMapper om = new ObjectMapper();
1228 List<ExecuteBuildingBlock> flowsToExecute = null;
1230 ExecuteBuildingBlock[] asArray = om.readValue(flowsToExecuteString, ExecuteBuildingBlock[].class);
1231 flowsToExecute = Arrays.asList(asArray);
1232 } catch (Exception e) {
1233 e.printStackTrace();
1236 when(bbSetupUtils.loadOriginalFlowExecutionPath(anyString())).thenReturn(flowsToExecute);
1238 workflowAction.selectExecutionList(execution);
1239 List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
1240 assertEqualsBulkFlowName(ebbs, "AssignServiceInstanceBB");
1244 public void getRelatedResourcesInVfModuleTest() throws Exception {
1245 org.onap.aai.domain.yang.Vnfc vnfc = new org.onap.aai.domain.yang.Vnfc();
1246 vnfc.setModelInvariantId("modelInvariantId");
1247 vnfc.setVnfcName("testVnfcName");
1249 String vfncPayload =
1250 new String(Files.readAllBytes(Paths.get(RESOURCE_PATH + "/BuildingBlocks/vnfcResponse.json")));
1251 AAIResultWrapper vfncWrapper = new AAIResultWrapper(vfncPayload);
1253 String configurationPayload =
1254 new String(Files.readAllBytes(Paths.get(RESOURCE_PATH + "/BuildingBlocks/configurationResponse.json")));
1255 AAIResultWrapper configurationWrapper = new AAIResultWrapper(configurationPayload);
1256 List<AAIResultWrapper> configurationResultWrappers = new ArrayList<AAIResultWrapper>();
1257 configurationResultWrappers.add(configurationWrapper);
1259 AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.VNFC, vnfc.getVnfcName());
1260 when(bbSetupUtils.getAAIResourceDepthOne(uri)).thenReturn(vfncWrapper);
1262 doReturn(configurationResultWrappers).when(SPY_workflowAction).getResultWrappersFromRelationships(anyObject(),
1264 List<org.onap.aai.domain.yang.Configuration> configurationsList = SPY_workflowAction.getRelatedResourcesInVnfc(
1265 vnfc, org.onap.aai.domain.yang.Configuration.class, AAIObjectType.CONFIGURATION);
1266 assertEquals(1, configurationsList.size());
1267 assertEquals("testConfigurationId", configurationsList.get(0).getConfigurationId());
1271 * WorkflowActionBB Tests
1275 public void pluralTest() {
1276 List<String> items = Arrays.asList("serviceInstances, Service", "vnfs, Vnf", "vfModules, VfModule",
1277 "networks, Network", "invalidNames, invalidNames");
1278 items.forEach(item -> {
1279 String[] split = item.split(",");
1280 String type = split[0].trim();
1281 String expected = split[1].trim();
1282 assertThat(workflowAction.convertTypeFromPlural(type), equalTo(expected));
1287 public void sortExecutionPathByObjectForVlanTaggingCreateTest() throws Exception {
1288 List<ExecuteBuildingBlock> executeFlows = new ArrayList<>();
1289 ExecuteBuildingBlock ebb = new ExecuteBuildingBlock();
1290 BuildingBlock bb = new BuildingBlock();
1291 bb.setBpmnFlowName("AssignNetworkBB");
1293 ebb.setBuildingBlock(bb);
1294 executeFlows.add(ebb);
1295 ExecuteBuildingBlock ebb2 = new ExecuteBuildingBlock();
1296 BuildingBlock bb2 = new BuildingBlock();
1297 bb2.setBpmnFlowName("AssignNetworkBB");
1299 ebb2.setBuildingBlock(bb2);
1300 executeFlows.add(ebb2);
1301 ExecuteBuildingBlock ebb3 = new ExecuteBuildingBlock();
1302 BuildingBlock bb3 = new BuildingBlock();
1303 bb3.setBpmnFlowName("CreateNetworkBB");
1305 ebb3.setBuildingBlock(bb3);
1306 executeFlows.add(ebb3);
1307 ExecuteBuildingBlock ebb4 = new ExecuteBuildingBlock();
1308 BuildingBlock bb4 = new BuildingBlock();
1309 bb4.setBpmnFlowName("CreateNetworkBB");
1311 ebb4.setBuildingBlock(bb4);
1312 executeFlows.add(ebb4);
1313 ExecuteBuildingBlock ebb5 = new ExecuteBuildingBlock();
1314 BuildingBlock bb5 = new BuildingBlock();
1315 bb5.setBpmnFlowName("ActivateNetworkBB");
1317 ebb5.setBuildingBlock(bb5);
1318 executeFlows.add(ebb5);
1319 ExecuteBuildingBlock ebb6 = new ExecuteBuildingBlock();
1320 BuildingBlock bb6 = new BuildingBlock();
1321 bb6.setBpmnFlowName("ActivateNetworkBB");
1323 ebb6.setBuildingBlock(bb6);
1324 executeFlows.add(ebb6);
1326 List<ExecuteBuildingBlock> sorted =
1327 workflowAction.sortExecutionPathByObjectForVlanTagging(executeFlows, "createInstance");
1328 assertEqualsBulkFlowName(sorted, "AssignNetworkBB", "CreateNetworkBB", "ActivateNetworkBB", "AssignNetworkBB",
1329 "CreateNetworkBB", "ActivateNetworkBB");
1333 public void sortExecutionPathByObjectForVlanTaggingDeleteTest() throws Exception {
1334 List<ExecuteBuildingBlock> executeFlows = new ArrayList<>();
1335 ExecuteBuildingBlock ebb = new ExecuteBuildingBlock();
1336 BuildingBlock bb = new BuildingBlock();
1337 bb.setBpmnFlowName("DeactivateNetworkBB");
1339 ebb.setBuildingBlock(bb);
1340 executeFlows.add(ebb);
1341 ExecuteBuildingBlock ebb2 = new ExecuteBuildingBlock();
1342 BuildingBlock bb2 = new BuildingBlock();
1343 bb2.setBpmnFlowName("DeactivateNetworkBB");
1345 ebb2.setBuildingBlock(bb2);
1346 executeFlows.add(ebb2);
1347 ExecuteBuildingBlock ebb3 = new ExecuteBuildingBlock();
1348 BuildingBlock bb3 = new BuildingBlock();
1349 bb3.setBpmnFlowName("DeleteNetworkBB");
1351 ebb3.setBuildingBlock(bb3);
1352 executeFlows.add(ebb3);
1353 ExecuteBuildingBlock ebb4 = new ExecuteBuildingBlock();
1354 BuildingBlock bb4 = new BuildingBlock();
1355 bb4.setBpmnFlowName("DeleteNetworkBB");
1357 ebb4.setBuildingBlock(bb4);
1358 executeFlows.add(ebb4);
1359 ExecuteBuildingBlock ebb5 = new ExecuteBuildingBlock();
1360 BuildingBlock bb5 = new BuildingBlock();
1361 bb5.setBpmnFlowName("UnassignNetworkBB");
1363 ebb5.setBuildingBlock(bb5);
1364 executeFlows.add(ebb5);
1365 ExecuteBuildingBlock ebb6 = new ExecuteBuildingBlock();
1366 BuildingBlock bb6 = new BuildingBlock();
1367 bb6.setBpmnFlowName("UnassignNetworkBB");
1369 ebb6.setBuildingBlock(bb6);
1370 executeFlows.add(ebb6);
1372 List<ExecuteBuildingBlock> sorted =
1373 workflowAction.sortExecutionPathByObjectForVlanTagging(executeFlows, "deleteInstance");
1374 assertEqualsBulkFlowName(sorted, "DeactivateNetworkBB", "DeleteNetworkBB", "UnassignNetworkBB",
1375 "DeactivateNetworkBB", "DeleteNetworkBB", "UnassignNetworkBB");
1379 public void queryNorthBoundRequestCatalogDbNestedTest() throws MalformedURLException {
1380 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
1381 List<OrchestrationFlow> orchFlows = createFlowList("AAICheckVnfInMaintBB", "AAISetVnfInMaintBB",
1382 "VNF-Macro-Replace", "SDNOVnfHealthCheckBB", "AAIUnsetVnfInMaintBB");
1383 northBoundRequest.setOrchestrationFlowList(orchFlows);
1384 List<OrchestrationFlow> macroFlows = createFlowList("DeactivateVfModuleBB", "DeleteVfModuleBB",
1385 "DeactivateVnfBB", "CreateVfModuleBB", "ActivateVfModuleBB", "ActivateVnfBB");
1387 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner("replaceInstance",
1388 "Vnf", false, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
1389 when(catalogDbClient.getOrchestrationFlowByAction("VNF-Macro-Replace")).thenReturn(macroFlows);
1390 List<OrchestrationFlow> flows = workflowAction.queryNorthBoundRequestCatalogDb(execution, "replaceInstance",
1391 WorkflowType.VNF, false, "my-custom-cloud-owner");
1392 assertEquals(flows.get(0).getFlowName(), "AAICheckVnfInMaintBB");
1393 assertEquals(flows.get(1).getFlowName(), "AAISetVnfInMaintBB");
1394 assertEquals(flows.get(2).getFlowName(), "DeactivateVfModuleBB");
1395 assertEquals(flows.get(3).getFlowName(), "DeleteVfModuleBB");
1396 assertEquals(flows.get(4).getFlowName(), "DeactivateVnfBB");
1397 assertEquals(flows.get(5).getFlowName(), "CreateVfModuleBB");
1398 assertEquals(flows.get(6).getFlowName(), "ActivateVfModuleBB");
1399 assertEquals(flows.get(7).getFlowName(), "ActivateVnfBB");
1400 assertEquals(flows.get(8).getFlowName(), "SDNOVnfHealthCheckBB");
1401 assertEquals(flows.get(9).getFlowName(), "AAIUnsetVnfInMaintBB");
1405 public void queryNorthBoundRequestCatalogDbTransportTest() throws MalformedURLException {
1406 NorthBoundRequest northBoundRequest = new NorthBoundRequest();
1407 List<OrchestrationFlow> orchFlows = createFlowList("AssignServiceInstanceBB");
1408 northBoundRequest.setOrchestrationFlowList(orchFlows);
1409 when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwnerAndServiceType(
1410 "createInstance", "Service", true, "my-custom-cloud-owner", "TRANSPORT")).thenReturn(northBoundRequest);
1412 List<OrchestrationFlow> flows = workflowAction.queryNorthBoundRequestCatalogDb(execution, "createInstance",
1413 WorkflowType.SERVICE, true, "my-custom-cloud-owner", "TRANSPORT");
1414 assertEquals(flows.get(0).getFlowName(), "AssignServiceInstanceBB");
1418 public void extractResourceIdAndTypeFromUriTest() {
1419 String uri = "/v6/serviceInstances/123";
1420 String uri2 = "/v6/serviceInstances/123/vnfs/1234";
1421 String uri3 = "/v6/serviceInstances";
1422 String uri4 = "/v6/serviceInstances/assign";
1423 String uri5 = "'/v6/serviceInstances/123/vnfs";
1424 String uri6 = "/v6/serviceInstances/123/vnfs/1234/someAction";
1425 String uri7 = "/v6/serviceInstances/123/vnfs/1234/vfModules/5678/replace";
1426 String uri8 = "/v6/serviceInstances/123/vnfs/1234/vfModules/scaleOut";
1427 Resource expected1 = new Resource(WorkflowType.SERVICE, "123", true);
1428 Resource expected2 = new Resource(WorkflowType.VNF, "1234", false);
1429 Resource expected3 = new Resource(WorkflowType.VNF, "1234", false);
1430 Resource expected4 = new Resource(WorkflowType.VFMODULE, "5678", false);
1431 Resource result = workflowAction.extractResourceIdAndTypeFromUri(uri);
1432 assertEquals(expected1.getResourceId(), result.getResourceId());
1433 assertEquals(expected1.getResourceType(), result.getResourceType());
1434 result = workflowAction.extractResourceIdAndTypeFromUri(uri2);
1435 assertEquals(expected2.getResourceId(), result.getResourceId());
1436 assertEquals(expected2.getResourceType(), result.getResourceType());
1437 result = workflowAction.extractResourceIdAndTypeFromUri(uri3);
1438 assertEquals("Service", result.getResourceType().toString());
1439 assertEquals(UUID.randomUUID().toString().length(), result.getResourceId().length());
1440 result = workflowAction.extractResourceIdAndTypeFromUri(uri4);
1441 assertEquals("Service", result.getResourceType().toString());
1442 assertEquals(UUID.randomUUID().toString().length(), result.getResourceId().length());
1443 result = workflowAction.extractResourceIdAndTypeFromUri(uri5);
1444 assertEquals("Vnf", result.getResourceType().toString());
1445 assertEquals(UUID.randomUUID().toString().length(), result.getResourceId().length());
1446 result = workflowAction.extractResourceIdAndTypeFromUri(uri6);
1447 assertEquals(expected3.getResourceId(), result.getResourceId());
1448 assertEquals(expected3.getResourceType(), result.getResourceType());
1449 result = workflowAction.extractResourceIdAndTypeFromUri(uri7);
1450 assertEquals(expected4.getResourceId(), result.getResourceId());
1451 assertEquals(expected4.getResourceType(), result.getResourceType());
1452 result = workflowAction.extractResourceIdAndTypeFromUri(uri8);
1453 assertEquals(UUID.randomUUID().toString().length(), result.getResourceId().length());
1454 assertEquals("VfModule", result.getResourceType().toString());
1459 public void extractResourceIdAndTypeFromUriInvalidTypeTest() {
1460 this.expectedException.expect(IllegalArgumentException.class);
1461 this.expectedException.expectMessage(containsString("Uri could not be parsed. No type found."));
1462 workflowAction.extractResourceIdAndTypeFromUri("/v6/serviceInstances/123/vnfs/1234/vfmodules/5678/replace");
1466 public void extractResourceIdAndTypeFromUriInvalidUriTest() {
1467 this.expectedException.expect(IllegalArgumentException.class);
1468 this.expectedException.expectMessage(containsString("Uri could not be parsed:"));
1469 workflowAction.extractResourceIdAndTypeFromUri("something that doesn't match anything");
1473 public void isUriResumeTest() {
1474 assertTrue(workflowAction.isUriResume(
1475 "http://localhost:9100/onap/so/infra/orchestrationRequests/v7/requests/2f8ab587-ef6a-4456-b7b2-d73f9363dabd/resume"));
1476 assertFalse(workflowAction.isUriResume("/v6/serviceInstances/123/vnfs/1234/vfmodules/5678/replace"));
1480 public void isRequestMacroServiceResumeTest() {
1481 ServiceInstance si = new ServiceInstance();
1482 when(bbSetupUtils.getAAIServiceInstanceById(anyString())).thenReturn(si);
1483 assertFalse(workflowAction.isRequestMacroServiceResume(false, WorkflowType.SERVICE, "createInstance", ""));
1484 assertTrue(workflowAction.isRequestMacroServiceResume(false, WorkflowType.SERVICE, "createInstance", "123"));
1488 public void populateResourceIdsFromApiHandlerTest() {
1489 execution.setVariable("serviceInstanceId", "123");
1490 execution.setVariable("vnfId", "888");
1491 WorkflowResourceIds x = workflowAction.populateResourceIdsFromApiHandler(execution);
1492 assertEquals("123", x.getServiceInstanceId());
1493 assertEquals("888", x.getVnfId());
1494 assertNull(x.getVolumeGroupId());
1498 public void validateResourceIdInAAITest() throws Exception {
1500 RequestDetails reqDetails = new RequestDetails();
1501 SubscriberInfo subInfo = new SubscriberInfo();
1502 subInfo.setGlobalSubscriberId("id123");
1503 reqDetails.setSubscriberInfo(subInfo);
1504 RequestParameters reqParams = new RequestParameters();
1505 reqParams.setSubscriptionServiceType("subServiceType123");
1506 reqDetails.setRequestParameters(reqParams);
1507 WorkflowResourceIds workflowResourceIds = new WorkflowResourceIds();
1508 ServiceInstance si = new ServiceInstance();
1509 si.setServiceInstanceId("siId123");
1510 Optional<ServiceInstance> siOp = Optional.of(si);
1511 when(bbSetupUtils.getAAIServiceInstanceByName("id123", "subServiceType123", "siName123")).thenReturn(siOp);
1512 when(bbSetupUtils.getAAIServiceInstanceByName("id123", "subServiceType123", "111111"))
1513 .thenReturn(Optional.empty());
1514 String id = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.SERVICE, "siName123",
1515 reqDetails, workflowResourceIds);
1516 assertEquals("siId123", id);
1517 String id2 = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.SERVICE, "111111",
1518 reqDetails, workflowResourceIds);
1519 assertEquals("generatedId123", id2);
1522 L3Network network = new L3Network();
1523 network.setNetworkId("id123");
1524 network.setNetworkName("name123");
1525 workflowResourceIds.setServiceInstanceId("siId123");
1526 Optional<L3Network> opNetwork = Optional.of(network);
1527 when(bbSetupUtils.getRelatedNetworkByNameFromServiceInstance("siId123", "name123")).thenReturn(opNetwork);
1528 when(bbSetupUtils.getRelatedNetworkByNameFromServiceInstance("siId123", "111111")).thenReturn(Optional.empty());
1529 id = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.NETWORK, "name123", reqDetails,
1530 workflowResourceIds);
1531 assertEquals("id123", id);
1532 id2 = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.NETWORK, "111111", reqDetails,
1533 workflowResourceIds);
1534 assertEquals("generatedId123", id2);
1537 GenericVnf vnf = new GenericVnf();
1538 vnf.setVnfId("id123");
1539 vnf.setVnfName("vnfName123");
1540 Optional<GenericVnf> opVnf = Optional.of(vnf);
1541 when(bbSetupUtils.getRelatedVnfByNameFromServiceInstance("siId123", "name123")).thenReturn(opVnf);
1542 when(bbSetupUtils.getRelatedVnfByNameFromServiceInstance("siId123", "111111")).thenReturn(Optional.empty());
1543 id = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.VNF, "name123", reqDetails,
1544 workflowResourceIds);
1545 assertEquals("id123", id);
1546 id2 = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.VNF, "111111", reqDetails,
1547 workflowResourceIds);
1548 assertEquals("generatedId123", id2);
1551 VfModules vfModules = new VfModules();
1552 VfModule vfModule = new VfModule();
1553 vfModule.setVfModuleId("id123");
1554 vfModule.setVfModuleName("name123");
1555 vfModules.getVfModule().add(vfModule);
1556 vnf.setVfModules(vfModules);
1557 workflowResourceIds.setVnfId("id123");
1558 when(bbSetupUtils.getAAIGenericVnf("id123")).thenReturn(vnf);
1559 id = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.VFMODULE, "name123", reqDetails,
1560 workflowResourceIds);
1561 assertEquals("id123", id);
1563 GenericVnf vnf2 = new GenericVnf();
1564 VfModules vfModules2 = new VfModules();
1565 VfModule vfModule2 = new VfModule();
1566 vfModule2.setVfModuleId("id123");
1567 vfModule2.setVfModuleName("name123");
1568 vfModules2.getVfModule().add(vfModule2);
1569 vnf2.setVfModules(vfModules2);
1570 workflowResourceIds.setVnfId("id111");
1571 when(bbSetupUtils.getAAIGenericVnf("id111")).thenReturn(vnf2);
1572 id2 = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.VFMODULE, "111111", reqDetails,
1573 workflowResourceIds);
1574 assertEquals("generatedId123", id2);
1577 VolumeGroup volumeGroup = new VolumeGroup();
1578 volumeGroup.setVolumeGroupId("id123");
1579 volumeGroup.setVolumeGroupName("name123");
1580 workflowResourceIds.setVnfId("id123");
1581 Optional<VolumeGroup> opVolumeGroup = Optional.of(volumeGroup);
1582 when(bbSetupUtils.getRelatedVolumeGroupByNameFromVnf("id123", "name123")).thenReturn(opVolumeGroup);
1583 id = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.VOLUMEGROUP, "name123", reqDetails,
1584 workflowResourceIds);
1585 assertEquals("id123", id);
1587 workflowResourceIds.setVnfId("id444");
1588 when(bbSetupUtils.getAAIGenericVnf("id444")).thenReturn(vnf);
1589 when(bbSetupUtils.getRelatedVolumeGroupByNameFromVfModule("id123", "id123", "111111"))
1590 .thenReturn(opVolumeGroup);
1591 when(bbSetupUtils.getRelatedVolumeGroupByNameFromVnf("id444", "111111")).thenReturn(Optional.empty());
1592 id2 = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.VOLUMEGROUP, "111111", reqDetails,
1593 workflowResourceIds);
1594 assertEquals("id123", id2);
1598 public void handleRuntimeExceptionTest() {
1599 execution.setVariable("BPMN_javaExpMsg", "test runtime error message");
1600 execution.setVariable("testProcessKey", "testProcessKeyValue");
1602 workflowAction.handleRuntimeException(execution);
1603 } catch (BpmnError wfe) {
1604 assertEquals("MSOWorkflowException", wfe.getErrorCode());
1610 public void traverseCatalogDbServiceMultipleNetworkTest() throws IOException, VrfBondingServiceException {
1611 execution.setVariable("testProcessKey", "testProcessKeyValue");
1612 Service service = new Service();
1613 List<NetworkResourceCustomization> networkCustomizations = new ArrayList<>();
1614 NetworkResourceCustomization networkCust = new NetworkResourceCustomization();
1615 networkCust.setModelCustomizationUUID("123");
1616 networkCustomizations.add(networkCust);
1617 service.setNetworkCustomizations(networkCustomizations);
1618 NetworkCollectionResourceCustomization collectionResourceCustomization =
1619 new NetworkCollectionResourceCustomization();
1620 collectionResourceCustomization.setModelCustomizationUUID("123");
1621 CollectionResource collectionResource = new CollectionResource();
1622 collectionResource.setToscaNodeType("NetworkCollection");
1623 InstanceGroup instanceGroup = new InstanceGroup();
1624 List<CollectionResourceInstanceGroupCustomization> collectionInstanceGroupCustomizations = new ArrayList<>();
1625 CollectionResourceInstanceGroupCustomization collectionInstanceGroupCustomization =
1626 new CollectionResourceInstanceGroupCustomization();
1627 collectionInstanceGroupCustomization.setSubInterfaceNetworkQuantity(3);
1628 collectionInstanceGroupCustomizations.add(collectionInstanceGroupCustomization);
1629 instanceGroup.setCollectionInstanceGroupCustomizations(collectionInstanceGroupCustomizations);
1630 collectionResource.setInstanceGroup(instanceGroup);
1631 collectionResourceCustomization.setCollectionResource(collectionResource);;
1632 service.setModelUUID("abc");
1633 service.getCollectionResourceCustomizations().add(collectionResourceCustomization);
1634 service.getCollectionResourceCustomizations().add(collectionResourceCustomization);
1635 doReturn(service).when(catalogDbClient).getServiceByID("3c40d244-808e-42ca-b09a-256d83d19d0a");
1636 doReturn(collectionResourceCustomization).when(catalogDbClient)
1637 .getNetworkCollectionResourceCustomizationByID("123");
1638 String bpmnRequest = new String(Files
1639 .readAllBytes(Paths.get("src/test/resources/__files/Macro/ServiceMacroActivateDeleteUnassign.json")));
1640 ObjectMapper mapper = new ObjectMapper();
1641 ServiceInstancesRequest sIRequest = mapper.readValue(bpmnRequest, ServiceInstancesRequest.class);
1642 List<Resource> resourceCounter = new ArrayList<>();
1643 thrown.expect(BpmnError.class);
1644 List<Pair<WorkflowType, String>> aaiResourceIds = new ArrayList<>();
1645 workflowAction.traverseCatalogDbService(execution, sIRequest, resourceCounter, aaiResourceIds);
1649 public void sortVfModulesByBaseFirstTest() {
1650 List<Resource> resources = new ArrayList<>();
1651 Resource resource1 = new Resource(WorkflowType.VFMODULE, "111", false);
1652 resource1.setBaseVfModule(false);
1653 resources.add(resource1);
1654 Resource resource2 = new Resource(WorkflowType.VFMODULE, "222", false);
1655 resource2.setBaseVfModule(false);
1656 resources.add(resource2);
1657 Resource resource3 = new Resource(WorkflowType.VFMODULE, "333", false);
1658 resource3.setBaseVfModule(true);
1659 resources.add(resource3);
1660 List<Resource> result = workflowAction.sortVfModulesByBaseFirst(resources);
1661 assertEquals("333", result.get(0).getResourceId());
1662 assertEquals("222", result.get(1).getResourceId());
1663 assertEquals("111", result.get(2).getResourceId());
1667 public void sortVfModulesByBaseLastTest() {
1668 List<Resource> resources = new ArrayList<>();
1669 Resource resource1 = new Resource(WorkflowType.VFMODULE, "111", false);
1670 resource1.setBaseVfModule(true);
1671 resources.add(resource1);
1672 Resource resource2 = new Resource(WorkflowType.VFMODULE, "222", false);
1673 resource2.setBaseVfModule(false);
1674 resources.add(resource2);
1675 Resource resource3 = new Resource(WorkflowType.VFMODULE, "333", false);
1676 resource3.setBaseVfModule(false);
1677 resources.add(resource3);
1678 List<Resource> result = workflowAction.sortVfModulesByBaseLast(resources);
1679 assertEquals("333", result.get(0).getResourceId());
1680 assertEquals("222", result.get(1).getResourceId());
1681 assertEquals("111", result.get(2).getResourceId());
1685 public void findCatalogNetworkCollectionTest() {
1686 Service service = new Service();
1687 NetworkCollectionResourceCustomization networkCustomization = new NetworkCollectionResourceCustomization();
1688 networkCustomization.setModelCustomizationUUID("123");
1689 service.getCollectionResourceCustomizations().add(networkCustomization);
1690 doReturn(networkCustomization).when(catalogDbClient).getNetworkCollectionResourceCustomizationByID("123");
1691 CollectionResourceCustomization customization = workflowAction.findCatalogNetworkCollection(execution, service);
1692 assertNotNull(customization);
1696 public void findCatalogNetworkCollectionEmptyTest() {
1697 Service service = new Service();
1698 NetworkCollectionResourceCustomization networkCustomization = new NetworkCollectionResourceCustomization();
1699 networkCustomization.setModelCustomizationUUID("123");
1700 service.getCollectionResourceCustomizations().add(networkCustomization);
1701 CollectionResourceCustomization customization = workflowAction.findCatalogNetworkCollection(execution, service);
1702 assertNull(customization);
1706 public void findCatalogNetworkCollectionMoreThanOneTest() {
1707 Service service = new Service();
1708 NetworkCollectionResourceCustomization networkCustomization1 = new NetworkCollectionResourceCustomization();
1709 networkCustomization1.setModelCustomizationUUID("123");
1710 NetworkCollectionResourceCustomization networkCustomization2 = new NetworkCollectionResourceCustomization();
1711 networkCustomization2.setModelCustomizationUUID("321");
1712 service.getCollectionResourceCustomizations().add(networkCustomization1);
1713 service.getCollectionResourceCustomizations().add(networkCustomization2);
1714 doReturn(networkCustomization1).when(catalogDbClient).getNetworkCollectionResourceCustomizationByID("123");
1715 doReturn(networkCustomization2).when(catalogDbClient).getNetworkCollectionResourceCustomizationByID("321");
1716 workflowAction.findCatalogNetworkCollection(execution, service);
1717 assertEquals("Found multiple Network Collections in the Service model, only one per Service is supported.",
1718 execution.getVariable("WorkflowActionErrorMessage"));
1722 public void verifyLackOfNullPointerExceptionForNullResource() {
1723 ExecuteBuildingBlock result = null;
1725 result = workflowAction.buildExecuteBuildingBlock(new OrchestrationFlow(), null, null, null, null, null,
1726 false, null, null, null, false, null, true);
1727 } catch (NullPointerException e) {
1728 fail("NullPointerException should not be thrown when 'resource' is null");
1730 assertNotNull(result);
1734 public void traverseAAIServiceTest() {
1735 List<Resource> resourceCounter = new ArrayList<>();
1736 String resourceId = "si0";
1737 List<Pair<WorkflowType, String>> aaiResourceIds = new ArrayList<>();
1739 ServiceInstance serviceInstanceAAI = new ServiceInstance();
1740 serviceInstanceAAI.setServiceInstanceId(resourceId);
1742 org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance serviceInstance = setServiceInstance();
1750 Configuration config = new Configuration();
1751 config.setConfigurationId("testConfigurationId2");
1752 serviceInstance.getConfigurations().add(config);
1754 Relationship relationship1 = new Relationship();
1755 relationship1.setRelatedTo("vnfc");
1756 RelationshipList relationshipList1 = new RelationshipList();
1757 relationshipList1.getRelationship().add(relationship1);
1759 Relationship relationship2 = new Relationship();
1760 relationship2.setRelatedTo("vpn-binding");
1761 RelationshipList relationshipList2 = new RelationshipList();
1762 relationshipList2.getRelationship().add(relationship2);
1764 org.onap.aai.domain.yang.Configuration aaiConfiguration1 = new org.onap.aai.domain.yang.Configuration();
1765 aaiConfiguration1.setConfigurationId("testConfigurationId");
1766 aaiConfiguration1.setRelationshipList(relationshipList1);
1768 org.onap.aai.domain.yang.Configuration aaiConfiguration2 = new org.onap.aai.domain.yang.Configuration();
1769 aaiConfiguration2.setConfigurationId("testConfigurationId2");
1770 aaiConfiguration2.setRelationshipList(relationshipList1);
1773 doReturn(serviceInstanceAAI).when(bbSetupUtils).getAAIServiceInstanceById(resourceId);
1774 doReturn(serviceInstance).when(bbInputSetup).getExistingServiceInstance(serviceInstanceAAI);
1775 doReturn(Optional.of(aaiConfiguration1)).when(aaiConfigurationResources)
1776 .getConfiguration("testConfigurationId");
1777 doReturn(Optional.of(aaiConfiguration2)).when(aaiConfigurationResources)
1778 .getConfiguration("testConfigurationId2");
1779 workflowAction.traverseAAIService(execution, resourceCounter, resourceId, aaiResourceIds);
1780 assertEquals(8, resourceCounter.size());
1781 assertTrue(resourceCounter.get(2).isBaseVfModule());
1782 assertThat(aaiResourceIds, sameBeanAs(getExpectedResourceIds()));
1783 } catch (Exception e) {
1784 fail("Unexpected exception was thrown.");
1788 private List<Pair<WorkflowType, String>> getExpectedResourceIds() {
1789 List<Pair<WorkflowType, String>> resourceIds = new ArrayList<>();
1790 resourceIds.add(new Pair<WorkflowType, String>(WorkflowType.VNF, "testVnfId1"));
1791 resourceIds.add(new Pair<WorkflowType, String>(WorkflowType.VFMODULE, "testVfModuleId1"));
1792 resourceIds.add(new Pair<WorkflowType, String>(WorkflowType.VOLUMEGROUP, "testVolumeGroupId1"));
1793 resourceIds.add(new Pair<WorkflowType, String>(WorkflowType.NETWORK, "testNetworkId1"));
1794 resourceIds.add(new Pair<WorkflowType, String>(WorkflowType.NETWORKCOLLECTION, "testId"));
1795 resourceIds.add(new Pair<WorkflowType, String>(WorkflowType.CONFIGURATION, "testConfigurationId"));
1796 resourceIds.add(new Pair<WorkflowType, String>(WorkflowType.CONFIGURATION, "testConfigurationId2"));
1800 private List<OrchestrationFlow> createFlowList(String... flowNames) {
1801 List<OrchestrationFlow> result = new ArrayList<>();
1802 for (String flowName : flowNames) {
1803 OrchestrationFlow orchFlow = new OrchestrationFlow();
1804 orchFlow.setFlowName(flowName);
1805 result.add(orchFlow);
1810 private void assertEqualsBulkFlowName(List<ExecuteBuildingBlock> ebbs, String... flowNames) {
1811 for (int i = 0; i < ebbs.size(); i++) {
1812 assertEquals(ebbs.get(i).getBuildingBlock().getBpmnFlowName(), flowNames[i]);
Code Review / so.git / blob