gerrit.onap Code Review - so.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   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
  12  *
  13  *      http://www.apache.org/licenses/LICENSE-2.0
  14  *
  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=========================================================
  21  */
  22
  23 package org.onap.so.bpmn.infrastructure.workflow.tasks;
  24
  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.HashMap;
  48 import java.util.List;
  49 import java.util.Map;
  50 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.GenericVnfs;
  66 import org.onap.aai.domain.yang.L3Network;
  67 import org.onap.aai.domain.yang.Relationship;
  68 import org.onap.aai.domain.yang.RelationshipList;
  69 import org.onap.aai.domain.yang.ServiceInstance;
  70 import org.onap.aai.domain.yang.ServiceInstances;
  71 import org.onap.aai.domain.yang.VfModule;
  72 import org.onap.aai.domain.yang.VfModules;
  73 import org.onap.aai.domain.yang.VolumeGroup;
  74 import org.onap.so.bpmn.BaseTaskTest;
  75 import org.onap.so.bpmn.servicedecomposition.bbobjects.Collection;
  76 import org.onap.so.bpmn.servicedecomposition.bbobjects.Configuration;
  77 import org.onap.so.bpmn.servicedecomposition.entities.BuildingBlock;
  78 import org.onap.so.bpmn.servicedecomposition.entities.ExecuteBuildingBlock;
  79 import org.onap.so.bpmn.servicedecomposition.entities.WorkflowResourceIds;
  80 import org.onap.so.bpmn.servicedecomposition.tasks.exceptions.DuplicateNameException;
  81 import org.onap.so.client.aai.AAIObjectType;
  82 import org.onap.so.client.aai.entities.AAIResultWrapper;
  83 import org.onap.so.client.aai.entities.Relationships;
  84 import org.onap.so.client.aai.entities.uri.AAIResourceUri;
  85 import org.onap.so.client.aai.entities.uri.AAIUriFactory;
  86 import org.onap.so.db.catalog.beans.CollectionNetworkResourceCustomization;
  87 import org.onap.so.db.catalog.beans.CollectionResource;
  88 import org.onap.so.db.catalog.beans.CollectionResourceCustomization;
  89 import org.onap.so.db.catalog.beans.CollectionResourceInstanceGroupCustomization;
  90 import org.onap.so.db.catalog.beans.ConfigurationResource;
  91 import org.onap.so.db.catalog.beans.CvnfcConfigurationCustomization;
  92 import org.onap.so.db.catalog.beans.CvnfcCustomization;
  93 import org.onap.so.db.catalog.beans.HeatEnvironment;
  94 import org.onap.so.db.catalog.beans.HeatTemplate;
  95 import org.onap.so.db.catalog.beans.InstanceGroup;
  96 import org.onap.so.db.catalog.beans.NetworkCollectionResourceCustomization;
  97 import org.onap.so.db.catalog.beans.NetworkResourceCustomization;
  98 import org.onap.so.db.catalog.beans.Service;
  99 import org.onap.so.db.catalog.beans.VfModuleCustomization;
 100 import org.onap.so.db.catalog.beans.macro.NorthBoundRequest;
 101 import org.onap.so.db.catalog.beans.macro.OrchestrationFlow;
 102 import org.onap.so.serviceinstancebeans.ModelInfo;
 103 import org.onap.so.serviceinstancebeans.RequestDetails;
 104 import org.onap.so.serviceinstancebeans.RequestParameters;
 105 import org.onap.so.serviceinstancebeans.ServiceInstancesRequest;
 106 import org.onap.so.serviceinstancebeans.SubscriberInfo;
 107 import org.springframework.core.env.Environment;
 108
 109 public class WorkflowActionTest extends BaseTaskTest {
 110
 111
 112     @Mock
 113     protected Environment environment;
 114     @InjectMocks
 115     protected WorkflowAction workflowAction;
 116     private DelegateExecution execution;
 117
 118     @InjectMocks
 119     @Spy
 120     protected WorkflowAction SPY_workflowAction;
 121
 122     @Rule
 123     public ExpectedException thrown = ExpectedException.none();
 124
 125     private String RESOURCE_PATH = "src/test/resources/__files/";
 126
 127     @Before
 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);
 135     }
 136
 137     /**
 138      * ALACARTE TESTS
 139      */
 140     @Test
 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);
 146         String bpmnRequest =
 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");
 152
 153         NorthBoundRequest northBoundRequest = new NorthBoundRequest();
 154         List<OrchestrationFlow> orchFlows =
 155                 createFlowList("AssignNetwork1802BB", "CreateNetworkBB", "ActivateNetworkBB");
 156         northBoundRequest.setOrchestrationFlowList(orchFlows);
 157
 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");
 163     }
 164
 165     @Test
 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);
 171         String bpmnRequest =
 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");
 177
 178         NorthBoundRequest northBoundRequest = new NorthBoundRequest();
 179         List<OrchestrationFlow> orchFlows =
 180                 createFlowList("DeactivateNetworkBB", "DeleteNetworkBB", "UnassignNetwork1802BB");
 181         northBoundRequest.setOrchestrationFlowList(orchFlows);
 182
 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");
 188     }
 189
 190     @Test
 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);
 196         String bpmnRequest =
 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");
 202
 203
 204         NorthBoundRequest northBoundRequest = new NorthBoundRequest();
 205         List<OrchestrationFlow> orchFlows = createFlowList("AssignServiceInstanceBB", "ActivateServiceInstanceBB");
 206         northBoundRequest.setOrchestrationFlowList(orchFlows);
 207
 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");
 213     }
 214
 215     /**
 216      * SERVICE MACRO TESTS
 217      */
 218     @Test
 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);
 224         String bpmnRequest =
 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");
 230
 231
 232         NorthBoundRequest northBoundRequest = new NorthBoundRequest();
 233         List<OrchestrationFlow> orchFlows = createFlowList("AssignServiceInstanceBB", "AssignNetworkBB", "AssignVnfBB",
 234                 "AssignVolumeGroupBB", "AssignVfModuleBB");
 235         northBoundRequest.setOrchestrationFlowList(orchFlows);
 236
 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);
 245
 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);
 254
 255         VfModuleCustomization vfModuleCustomization3 = vfModuleCustomization2;
 256         vfModuleCustomization3.setModelCustomizationUUID("72d9d1cd-f46d-447a-abdb-451d6fb05fa8");
 257
 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");
 270     }
 271
 272     @Test
 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");
 284
 285
 286         NorthBoundRequest northBoundRequest = new NorthBoundRequest();
 287         List<OrchestrationFlow> orchFlows = createFlowList("AssignServiceInstanceBB", "AssignNetworkBB", "AssignVnfBB",
 288                 "AssignVolumeGroupBB", "AssignVfModuleBB");
 289         northBoundRequest.setOrchestrationFlowList(orchFlows);
 290
 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);
 299
 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);
 308
 309         VfModuleCustomization vfModuleCustomization3 = vfModuleCustomization2;
 310         vfModuleCustomization3.setModelCustomizationUUID("72d9d1cd-f46d-447a-abdb-451d6fb05fa8");
 311
 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");
 325     }
 326
 327     @Test
 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");
 339
 340
 341         NorthBoundRequest northBoundRequest = new NorthBoundRequest();
 342         List<OrchestrationFlow> orchFlows =
 343                 createFlowList("CreateNetworkBB", "ActivateNetworkBB", "CreateVolumeGroupBB", "ActivateVolumeGroupBB",
 344                         "CreateVfModuleBB", "ActivateVfModuleBB", "ActivateVnfBB", "ActivateServiceInstanceBB");
 345         northBoundRequest.setOrchestrationFlowList(orchFlows);
 346
 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");
 354
 355
 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);
 360
 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);
 365
 366         serviceInstanceMSO.getVnfs().add(vnf);
 367
 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());
 385
 386     }
 387
 388     @Test
 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");
 400
 401
 402         NorthBoundRequest northBoundRequest = new NorthBoundRequest();
 403         List<OrchestrationFlow> orchFlows = createFlowList("DeactivateServiceInstanceBB");
 404         northBoundRequest.setOrchestrationFlowList(orchFlows);
 405
 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");
 411     }
 412
 413     @Test
 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");
 425
 426
 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);
 435
 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");
 443     }
 444
 445     @Test
 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");
 457
 458
 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);
 467
 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");
 479     }
 480
 481     @Test
 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");
 493
 494
 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);
 503
 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");
 513
 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()
 552                         .getNetworkId()
 553                         && ebbs.get(3).getWorkflowResourceIds().getNetworkId() == ebbs.get(4).getWorkflowResourceIds()
 554                                 .getNetworkId(),
 555                 true);
 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()
 561                         .getNetworkId()
 562                         && ebbs.get(6).getWorkflowResourceIds().getNetworkId() == ebbs.get(7).getWorkflowResourceIds()
 563                                 .getNetworkId(),
 564                 true);
 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()
 570                         .getNetworkId()
 571                         && ebbs.get(9).getWorkflowResourceIds().getNetworkId() == ebbs.get(10).getWorkflowResourceIds()
 572                                 .getNetworkId(),
 573                 true);
 574     }
 575
 576     @Test
 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);
 582         String bpmnRequest =
 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");
 588
 589
 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);
 597
 598         Service service = new Service();
 599         service.setModelUUID("3c40d244-808e-42ca-b09a-256d83d19d0a");
 600
 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);
 609
 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);
 618
 619         VfModuleCustomization vfModuleCustomization3 = vfModuleCustomization2;
 620         vfModuleCustomization3.setModelCustomizationUUID("72d9d1cd-f46d-447a-abdb-451d6fb05fa8");
 621
 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"));
 656     }
 657
 658     @Test
 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");
 670
 671
 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);
 678
 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");
 686
 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);
 691
 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);
 696
 697         serviceInstanceMSO.getVnfs().add(vnf);
 698
 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");
 709     }
 710
 711     @Test
 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");
 723
 724
 725         NorthBoundRequest northBoundRequest = new NorthBoundRequest();
 726         List<OrchestrationFlow> orchFlows = createFlowList("UnassignVfModuleBB", "UnassignVolumeGroupBB",
 727                 "UnassignVnfBB", "UnassignNetworkBB", "UnassignServiceInstanceBB");
 728         northBoundRequest.setOrchestrationFlowList(orchFlows);
 729
 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");
 737
 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);
 742
 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);
 747
 748         serviceInstanceMSO.getVnfs().add(vnf);
 749
 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");
 758     }
 759
 760     @Test
 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");
 772
 773
 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);
 780
 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();
 785
 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);
 794
 795         Collection collection = new Collection();
 796         serviceInstanceMSO.setCollection(collection);
 797
 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");
 807     }
 808
 809     @Test
 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);
 815         String bpmnRequest =
 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");
 823
 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);
 831
 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");
 839
 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);
 848
 849         serviceInstanceMSO.getVnfs().add(vnf);
 850
 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");
 861     }
 862
 863     @Test
 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);
 869         String bpmnRequest =
 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");
 877
 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);
 886
 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);
 914
 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");
 930     }
 931
 932     @Ignore
 933     @Test
 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");
 945
 946
 947         NorthBoundRequest northBoundRequest = new NorthBoundRequest();
 948         List<OrchestrationFlow> orchFlows = createFlowList("CreateNetworkCollectionBB", "AssignNetworkBB",
 949                 "CreateNetworkBB", "ActivateNetworkBB", "ActivateNetworkCollectionBB");
 950         northBoundRequest.setOrchestrationFlowList(orchFlows);
 951
 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);
 958
 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");
 967     }
 968
 969     @Ignore
 970     @Test
 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");
 982
 983         NorthBoundRequest northBoundRequest = new NorthBoundRequest();
 984         List<OrchestrationFlow> orchFlows = createFlowList("DeactivateNetworkBB", "DeleteNetworkBB",
 985                 "UnassignNetworkBB", "DeactivateNetworkCollectionBB", "DeleteNetworkCollectionBB");
 986         northBoundRequest.setOrchestrationFlowList(orchFlows);
 987
 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);
 994
 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");
1003     }
1004
1005     @Test
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");
1018
1019
1020         NorthBoundRequest northBoundRequest = new NorthBoundRequest();
1021         List<OrchestrationFlow> orchFlows = createFlowList("AssignVfModuleBB", "CreateVfModuleBB", "ActivateVfModuleBB",
1022                 "AssignFabricConfigurationBB", "ActivateFabricConfigurationBB");
1023         northBoundRequest.setOrchestrationFlowList(orchFlows);
1024
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");
1030     }
1031
1032     @Test
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");
1045
1046         NorthBoundRequest northBoundRequest = new NorthBoundRequest();
1047         List<OrchestrationFlow> orchFlows = createFlowList("AssignVfModuleBB", "CreateVfModuleBB", "ActivateVfModuleBB",
1048                 "AssignFabricConfigurationBB", "ActivateFabricConfigurationBB");
1049         northBoundRequest.setOrchestrationFlowList(orchFlows);
1050
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);
1065
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);
1079
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");
1089     }
1090
1091     @Test
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");
1104
1105         NorthBoundRequest northBoundRequest = new NorthBoundRequest();
1106         List<OrchestrationFlow> orchFlows = createFlowList("DeactivateVfModuleBB", "DeleteVfModuleBB",
1107                 "UnassignVfModuleBB", "DeactivateFabricConfigurationBB", "UnassignFabricConfigurationBB");
1108         northBoundRequest.setOrchestrationFlowList(orchFlows);
1109
1110         when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
1111                 true, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
1112
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);
1117
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);
1121
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");
1126         vnfcs.add(vnfc);
1127         doReturn(vnfcs).when(SPY_workflowAction).getRelatedResourcesInVfModule(anyObject(), anyObject(), anyObject(),
1128                 anyObject());
1129
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(),
1138                 anyObject());
1139
1140         doReturn("testName").when(SPY_workflowAction).getVnfcNameForConfiguration(anyObject());
1141
1142         SPY_workflowAction.selectExecutionList(execution);
1143         List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
1144         assertEqualsBulkFlowName(ebbs, "DeactivateFabricConfigurationBB", "UnassignFabricConfigurationBB",
1145                 "DeactivateVfModuleBB", "DeleteVfModuleBB", "UnassignVfModuleBB");
1146     }
1147
1148     @Test
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");
1161
1162         NorthBoundRequest northBoundRequest = new NorthBoundRequest();
1163         List<OrchestrationFlow> orchFlows = createFlowList("DeactivateVfModuleBB", "DeleteVfModuleBB",
1164                 "UnassignVfModuleBB", "DeactivateFabricConfigurationBB", "UnassignFabricConfigurationBB");
1165         northBoundRequest.setOrchestrationFlowList(orchFlows);
1166
1167         when(catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(gAction, resource,
1168                 true, "my-custom-cloud-owner")).thenReturn(northBoundRequest);
1169
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);
1174
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);
1178
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");
1183         vnfcs.add(vnfc);
1184         doReturn(vnfcs).when(SPY_workflowAction).getRelatedResourcesInVfModule(anyObject(), anyObject(), anyObject(),
1185                 anyObject());
1186
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(),
1191                 anyObject());
1192
1193         doReturn("testName").when(SPY_workflowAction).getVnfcNameForConfiguration(anyObject());
1194
1195         SPY_workflowAction.selectExecutionList(execution);
1196         List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
1197         assertEqualsBulkFlowName(ebbs, "DeactivateVfModuleBB", "DeleteVfModuleBB", "UnassignVfModuleBB");
1198     }
1199
1200     @Test
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");
1212
1213         NorthBoundRequest northBoundRequest = new NorthBoundRequest();
1214         List<OrchestrationFlow> orchFlows = createFlowList("AssignServiceInstanceBB");
1215         northBoundRequest.setOrchestrationFlowList(orchFlows);
1216
1217         Service service = new Service();
1218         service.setModelUUID("3c40d244-808e-42ca-b09a-256d83d19d0a");
1219
1220         ServiceInstance si = new ServiceInstance();
1221
1222         when(bbSetupUtils.getAAIServiceInstanceById("123")).thenReturn(si);
1223         when(catalogDbClient.getServiceByID("3c40d244-808e-42ca-b09a-256d83d19d0a")).thenReturn(service);
1224
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;
1229         try {
1230             ExecuteBuildingBlock[] asArray = om.readValue(flowsToExecuteString, ExecuteBuildingBlock[].class);
1231             flowsToExecute = Arrays.asList(asArray);
1232         } catch (Exception e) {
1233             e.printStackTrace();
1234         }
1235
1236         when(bbSetupUtils.loadOriginalFlowExecutionPath(anyString())).thenReturn(flowsToExecute);
1237
1238         workflowAction.selectExecutionList(execution);
1239         List<ExecuteBuildingBlock> ebbs = (List<ExecuteBuildingBlock>) execution.getVariable("flowsToExecute");
1240         assertEqualsBulkFlowName(ebbs, "AssignServiceInstanceBB");
1241     }
1242
1243     @Test
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");
1248
1249         String vfncPayload =
1250                 new String(Files.readAllBytes(Paths.get(RESOURCE_PATH + "/BuildingBlocks/vnfcResponse.json")));
1251         AAIResultWrapper vfncWrapper = new AAIResultWrapper(vfncPayload);
1252
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);
1258
1259         AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.VNFC, vnfc.getVnfcName());
1260         when(bbSetupUtils.getAAIResourceDepthOne(uri)).thenReturn(vfncWrapper);
1261
1262         doReturn(configurationResultWrappers).when(SPY_workflowAction).getResultWrappersFromRelationships(anyObject(),
1263                 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());
1268     }
1269
1270     /**
1271      * WorkflowActionBB Tests
1272      */
1273
1274     @Test
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));
1283         });
1284     }
1285
1286     @Test
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");
1292         bb.setKey("0");
1293         ebb.setBuildingBlock(bb);
1294         executeFlows.add(ebb);
1295         ExecuteBuildingBlock ebb2 = new ExecuteBuildingBlock();
1296         BuildingBlock bb2 = new BuildingBlock();
1297         bb2.setBpmnFlowName("AssignNetworkBB");
1298         bb2.setKey("1");
1299         ebb2.setBuildingBlock(bb2);
1300         executeFlows.add(ebb2);
1301         ExecuteBuildingBlock ebb3 = new ExecuteBuildingBlock();
1302         BuildingBlock bb3 = new BuildingBlock();
1303         bb3.setBpmnFlowName("CreateNetworkBB");
1304         bb3.setKey("0");
1305         ebb3.setBuildingBlock(bb3);
1306         executeFlows.add(ebb3);
1307         ExecuteBuildingBlock ebb4 = new ExecuteBuildingBlock();
1308         BuildingBlock bb4 = new BuildingBlock();
1309         bb4.setBpmnFlowName("CreateNetworkBB");
1310         bb4.setKey("1");
1311         ebb4.setBuildingBlock(bb4);
1312         executeFlows.add(ebb4);
1313         ExecuteBuildingBlock ebb5 = new ExecuteBuildingBlock();
1314         BuildingBlock bb5 = new BuildingBlock();
1315         bb5.setBpmnFlowName("ActivateNetworkBB");
1316         bb5.setKey("0");
1317         ebb5.setBuildingBlock(bb5);
1318         executeFlows.add(ebb5);
1319         ExecuteBuildingBlock ebb6 = new ExecuteBuildingBlock();
1320         BuildingBlock bb6 = new BuildingBlock();
1321         bb6.setBpmnFlowName("ActivateNetworkBB");
1322         bb6.setKey("1");
1323         ebb6.setBuildingBlock(bb6);
1324         executeFlows.add(ebb6);
1325
1326         List<ExecuteBuildingBlock> sorted =
1327                 workflowAction.sortExecutionPathByObjectForVlanTagging(executeFlows, "createInstance");
1328         assertEqualsBulkFlowName(sorted, "AssignNetworkBB", "CreateNetworkBB", "ActivateNetworkBB", "AssignNetworkBB",
1329                 "CreateNetworkBB", "ActivateNetworkBB");
1330     }
1331
1332     @Test
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");
1338         bb.setKey("0");
1339         ebb.setBuildingBlock(bb);
1340         executeFlows.add(ebb);
1341         ExecuteBuildingBlock ebb2 = new ExecuteBuildingBlock();
1342         BuildingBlock bb2 = new BuildingBlock();
1343         bb2.setBpmnFlowName("DeactivateNetworkBB");
1344         bb2.setKey("1");
1345         ebb2.setBuildingBlock(bb2);
1346         executeFlows.add(ebb2);
1347         ExecuteBuildingBlock ebb3 = new ExecuteBuildingBlock();
1348         BuildingBlock bb3 = new BuildingBlock();
1349         bb3.setBpmnFlowName("DeleteNetworkBB");
1350         bb3.setKey("0");
1351         ebb3.setBuildingBlock(bb3);
1352         executeFlows.add(ebb3);
1353         ExecuteBuildingBlock ebb4 = new ExecuteBuildingBlock();
1354         BuildingBlock bb4 = new BuildingBlock();
1355         bb4.setBpmnFlowName("DeleteNetworkBB");
1356         bb4.setKey("1");
1357         ebb4.setBuildingBlock(bb4);
1358         executeFlows.add(ebb4);
1359         ExecuteBuildingBlock ebb5 = new ExecuteBuildingBlock();
1360         BuildingBlock bb5 = new BuildingBlock();
1361         bb5.setBpmnFlowName("UnassignNetworkBB");
1362         bb5.setKey("0");
1363         ebb5.setBuildingBlock(bb5);
1364         executeFlows.add(ebb5);
1365         ExecuteBuildingBlock ebb6 = new ExecuteBuildingBlock();
1366         BuildingBlock bb6 = new BuildingBlock();
1367         bb6.setBpmnFlowName("UnassignNetworkBB");
1368         bb6.setKey("1");
1369         ebb6.setBuildingBlock(bb6);
1370         executeFlows.add(ebb6);
1371
1372         List<ExecuteBuildingBlock> sorted =
1373                 workflowAction.sortExecutionPathByObjectForVlanTagging(executeFlows, "deleteInstance");
1374         assertEqualsBulkFlowName(sorted, "DeactivateNetworkBB", "DeleteNetworkBB", "UnassignNetworkBB",
1375                 "DeactivateNetworkBB", "DeleteNetworkBB", "UnassignNetworkBB");
1376     }
1377
1378     @Test
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");
1386
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");
1402     }
1403
1404     @Test
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);
1411
1412         List<OrchestrationFlow> flows = workflowAction.queryNorthBoundRequestCatalogDb(execution, "createInstance",
1413                 WorkflowType.SERVICE, true, "my-custom-cloud-owner", "TRANSPORT");
1414         assertEquals(flows.get(0).getFlowName(), "AssignServiceInstanceBB");
1415     }
1416
1417     @Test
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());
1455
1456     }
1457
1458     @Test
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");
1463     }
1464
1465     @Test
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");
1470     }
1471
1472     @Test
1473     public void extractResourceIdAndTypeFromUriResumeTest() {
1474         Resource resource = workflowAction.extractResourceIdAndTypeFromUri(
1475                 "http://localhost:9100/onap/so/infra/serviceInstantiation/v7/serviceInstances/4ff87c63-461b-4d83-8121-d351e6db216c/vnfs/eea9b93b-b5b9-4fad-9c35-12d52e4b683f/vfModules/33cb74cd-9cb3-4090-a3c0-1b8c8e235847/resume");
1476         assertEquals(resource.getResourceId(), "33cb74cd-9cb3-4090-a3c0-1b8c8e235847");
1477     }
1478
1479     @Test
1480     public void isUriResumeTest() {
1481         assertTrue(workflowAction.isUriResume(
1482                 "http://localhost:9100/onap/so/infra/orchestrationRequests/v7/requests/2f8ab587-ef6a-4456-b7b2-d73f9363dabd/resume"));
1483         assertTrue(workflowAction.isUriResume(
1484                 "        http://localhost:9100/onap/so/infra/serviceInstantiation/v7/serviceInstances/4ff87c63-461b-4d83-8121-d351e6db216c/vnfs/eea9b93b-b5b9-4fad-9c35-12d52e4b683f/vfModules/33cb74cd-9cb3-4090-a3c0-1b8c8e235847/resume"));
1485
1486         assertFalse(workflowAction.isUriResume("/v6/serviceInstances/123/vnfs/1234/vfmodules/5678/replace"));
1487     }
1488
1489     @Test
1490     public void isRequestMacroServiceResumeTest() {
1491         ServiceInstance si = new ServiceInstance();
1492         when(bbSetupUtils.getAAIServiceInstanceById(anyString())).thenReturn(si);
1493         assertFalse(workflowAction.isRequestMacroServiceResume(false, WorkflowType.SERVICE, "createInstance", ""));
1494         assertTrue(workflowAction.isRequestMacroServiceResume(false, WorkflowType.SERVICE, "createInstance", "123"));
1495     }
1496
1497     @Test
1498     public void populateResourceIdsFromApiHandlerTest() {
1499         execution.setVariable("serviceInstanceId", "123");
1500         execution.setVariable("vnfId", "888");
1501         WorkflowResourceIds x = workflowAction.populateResourceIdsFromApiHandler(execution);
1502         assertEquals("123", x.getServiceInstanceId());
1503         assertEquals("888", x.getVnfId());
1504         assertNull(x.getVolumeGroupId());
1505     }
1506
1507     private RequestDetails setupRequestDetails(String globalSubscriberId, String subscriptionServiceType,
1508             String modelCustomizationId) {
1509         RequestDetails reqDetails = new RequestDetails();
1510         SubscriberInfo subInfo = new SubscriberInfo();
1511         subInfo.setGlobalSubscriberId(globalSubscriberId);
1512         reqDetails.setSubscriberInfo(subInfo);
1513         RequestParameters reqParams = new RequestParameters();
1514         reqParams.setSubscriptionServiceType(subscriptionServiceType);
1515         reqDetails.setRequestParameters(reqParams);
1516         ModelInfo modelInfo = new ModelInfo();
1517         modelInfo.setModelCustomizationId(modelCustomizationId);
1518         reqDetails.setModelInfo(modelInfo);
1519         return reqDetails;
1520     }
1521
1522     @Test
1523     public void validateVnfResourceIdInAAITest() throws Exception {
1524         RequestDetails reqDetails = setupRequestDetails("id123", "subServiceType123", "1234567");
1525         WorkflowResourceIds workflowResourceIds = new WorkflowResourceIds();
1526         workflowResourceIds.setServiceInstanceId("siId123");
1527         // Vnf
1528         GenericVnf vnf = new GenericVnf();
1529         vnf.setVnfId("id123");
1530         vnf.setVnfName("vnfName123");
1531         vnf.setModelCustomizationId("1234567");
1532         Optional<GenericVnf> opVnf = Optional.of(vnf);
1533         GenericVnf vnf2 = new GenericVnf();
1534         vnf2.setVnfId("id123");
1535         vnf2.setVnfName("vnfName222");
1536         vnf2.setModelCustomizationId("222");
1537         Optional<GenericVnf> opVnf2 = Optional.of(vnf2);
1538         when(bbSetupUtils.getRelatedVnfByNameFromServiceInstance("siId123", "vnfName123")).thenReturn(opVnf);
1539         when(bbSetupUtils.getRelatedVnfByNameFromServiceInstance("siId123", "vnfName222")).thenReturn(opVnf2);
1540         when(bbSetupUtils.getRelatedVnfByNameFromServiceInstance("siId123", "111111")).thenReturn(Optional.empty());
1541         String id = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.VNF, "vnfName123", reqDetails,
1542                 workflowResourceIds);
1543         assertEquals("id123", id);
1544         String id2 = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.VNF, "111111", reqDetails,
1545                 workflowResourceIds);
1546         assertEquals("generatedId123", id2);
1547
1548         this.expectedException.expect(DuplicateNameException.class);
1549         this.expectedException.expectMessage(containsString(
1550                 "generic-vnf with name (vnfName222), same parent and different customization id (222) already exists. The name must be unique."));
1551         workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.VNF, "vnfName222", reqDetails,
1552                 workflowResourceIds);
1553     }
1554
1555     @Test
1556     public void validateVnfResourceNameInAAITest() throws Exception {
1557         RequestDetails reqDetails = setupRequestDetails("id123", "subServiceType123", "1234567");
1558         WorkflowResourceIds workflowResourceIds = new WorkflowResourceIds();
1559         workflowResourceIds.setServiceInstanceId("siId123");
1560
1561         // Vnf
1562         GenericVnfs genericVnfs = new GenericVnfs();
1563         GenericVnf vnf3 = new GenericVnf();
1564         vnf3.setVnfId("id123");
1565         vnf3.setVnfName("vnfName333");
1566         genericVnfs.getGenericVnf().add(vnf3);
1567         when(bbSetupUtils.getRelatedVnfByNameFromServiceInstance("siId123", "vnfName333")).thenReturn(Optional.empty());
1568         when(bbSetupUtils.getAAIVnfsGloballyByName("vnfName333")).thenReturn(genericVnfs);
1569
1570         this.expectedException.expect(DuplicateNameException.class);
1571         this.expectedException.expectMessage(containsString(
1572                 "generic-vnf with name (vnfName333) id (id123) and different parent relationship already exists. The name must be unique."));
1573         workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.VNF, "vnfName333", reqDetails,
1574                 workflowResourceIds);
1575     }
1576
1577     @Test
1578     public void validateNetworkResourceIdInAAITest() throws Exception {
1579         RequestDetails reqDetails = setupRequestDetails("id123", "subServiceType123", "1234567");
1580         WorkflowResourceIds workflowResourceIds = new WorkflowResourceIds();
1581         workflowResourceIds.setServiceInstanceId("siId123");
1582
1583         // Network
1584         L3Network network = new L3Network();
1585         network.setNetworkId("id123");
1586         network.setNetworkName("name123");
1587         network.setModelCustomizationId("1234567");
1588         workflowResourceIds.setServiceInstanceId("siId123");
1589         Optional<L3Network> opNetwork = Optional.of(network);
1590         L3Network network2 = new L3Network();
1591         network2.setNetworkId("id123");
1592         network2.setNetworkName("networkName222");
1593         network2.setModelCustomizationId("222");
1594         Optional<L3Network> opNetwork2 = Optional.of(network2);
1595         when(bbSetupUtils.getRelatedNetworkByNameFromServiceInstance("siId123", "name123")).thenReturn(opNetwork);
1596         when(bbSetupUtils.getRelatedNetworkByNameFromServiceInstance("siId123", "networkName222"))
1597                 .thenReturn(opNetwork2);
1598         when(bbSetupUtils.getRelatedNetworkByNameFromServiceInstance("siId123", "111111")).thenReturn(Optional.empty());
1599         String id = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.NETWORK, "name123",
1600                 reqDetails, workflowResourceIds);
1601         assertEquals("id123", id);
1602         String id2 = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.NETWORK, "111111",
1603                 reqDetails, workflowResourceIds);
1604         assertEquals("generatedId123", id2);
1605
1606         this.expectedException.expect(DuplicateNameException.class);
1607         this.expectedException.expectMessage(containsString(
1608                 "l3Network with name (networkName222), same parent and different customization id (222) already exists. The name must be unique."));
1609         workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.NETWORK, "networkName222", reqDetails,
1610                 workflowResourceIds);
1611     }
1612
1613     @Test
1614     public void validateNetworkResourceNameExistsInAAITest() throws Exception {
1615         RequestDetails reqDetails = setupRequestDetails("id123", "subServiceType123", "1234567");
1616         WorkflowResourceIds workflowResourceIds = new WorkflowResourceIds();
1617         workflowResourceIds.setServiceInstanceId("siId123");
1618
1619         // Network
1620         L3Network network = new L3Network();
1621         network.setNetworkId("id123");
1622         network.setNetworkName("name123");
1623         network.setModelCustomizationId("1234567");
1624         workflowResourceIds.setServiceInstanceId("siId123");
1625
1626         when(bbSetupUtils.getRelatedNetworkByNameFromServiceInstance("networkName333", "111111"))
1627                 .thenReturn(Optional.empty());
1628         when(bbSetupUtils.existsAAINetworksGloballyByName("networkName333")).thenReturn(true);
1629
1630         this.expectedException.expect(DuplicateNameException.class);
1631         this.expectedException.expectMessage(containsString(
1632                 "l3Network with name (networkName333) id (siId123) and different parent relationship already exists. The name must be unique."));
1633         workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.NETWORK, "networkName333", reqDetails,
1634                 workflowResourceIds);
1635     }
1636
1637     @Test
1638     public void validateVfModuleResourceIdInAAITest() throws Exception {
1639         RequestDetails reqDetails = setupRequestDetails("id123", "subServiceType123", "1234567");
1640         WorkflowResourceIds workflowResourceIds = new WorkflowResourceIds();
1641         workflowResourceIds.setServiceInstanceId("siId123");
1642
1643         GenericVnf vnf = new GenericVnf();
1644         vnf.setVnfId("id123");
1645         vnf.setVnfName("vnfName123");
1646         vnf.setModelCustomizationId("222");
1647
1648         // VfModule
1649         VfModules vfModules = new VfModules();
1650         VfModule vfModule = new VfModule();
1651         vfModule.setVfModuleId("id123");
1652         vfModule.setVfModuleName("name123");
1653         vfModule.setModelCustomizationId("1234567");
1654         vfModules.getVfModule().add(vfModule);
1655         vnf.setVfModules(vfModules);
1656         workflowResourceIds.setVnfId("id123");
1657         when(bbSetupUtils.getAAIGenericVnf("id123")).thenReturn(vnf);
1658         String id = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.VFMODULE, "name123",
1659                 reqDetails, workflowResourceIds);
1660         assertEquals("id123", id);
1661
1662         GenericVnf vnf1 = new GenericVnf();
1663         VfModules vfModules2 = new VfModules();
1664         VfModule vfModule2 = new VfModule();
1665         vfModule2.setVfModuleId("id123");
1666         vfModule2.setVfModuleName("vFModName222");
1667         vfModule2.setModelCustomizationId("222");
1668         vfModules2.getVfModule().add(vfModule2);
1669         vnf1.setVfModules(vfModules2);
1670         workflowResourceIds.setVnfId("id111");
1671         when(bbSetupUtils.getAAIGenericVnf("id111")).thenReturn(vnf1);
1672         String id2 = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.VFMODULE, "111111",
1673                 reqDetails, workflowResourceIds);
1674         assertEquals("generatedId123", id2);
1675
1676         this.expectedException.expect(DuplicateNameException.class);
1677         this.expectedException.expectMessage(containsString(
1678                 "vfModule with name (vFModName222), same parent and different customization id (1234567) already exists. The name must be unique."));
1679         workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.VFMODULE, "vFModName222", reqDetails,
1680                 workflowResourceIds);
1681
1682     }
1683
1684     @Test
1685     public void validateVolumeGroupResourceIdInAAITest() throws Exception {
1686         RequestDetails reqDetails = setupRequestDetails("id123", "subServiceType123", "1234567");
1687         WorkflowResourceIds workflowResourceIds = new WorkflowResourceIds();
1688         workflowResourceIds.setServiceInstanceId("siId123");
1689
1690         GenericVnf vnf = new GenericVnf();
1691         vnf.setVnfId("id123");
1692         vnf.setVnfName("vnfName123");
1693         vnf.setModelCustomizationId("1234567");
1694
1695         GenericVnf vnf2 = new GenericVnf();
1696         vnf2.setVnfId("id123");
1697         vnf2.setVnfName("vnfName123");
1698         vnf2.setModelCustomizationId("222");
1699
1700         // VolumeGroup
1701         VolumeGroup volumeGroup = new VolumeGroup();
1702         volumeGroup.setVolumeGroupId("id123");
1703         volumeGroup.setVolumeGroupName("name123");
1704         workflowResourceIds.setVnfId("id123");
1705         Optional<VolumeGroup> opVolumeGroup = Optional.of(volumeGroup);
1706
1707         workflowResourceIds.setVnfId("id123");
1708
1709         when(bbSetupUtils.getAAIGenericVnf("id123")).thenReturn(vnf);
1710         when(bbSetupUtils.getRelatedVolumeGroupByNameFromVnf("id123", "name123")).thenReturn(opVolumeGroup);
1711         String id = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.VOLUMEGROUP, "name123",
1712                 reqDetails, workflowResourceIds);
1713         assertEquals("id123", id);
1714
1715         when(bbSetupUtils.getAAIGenericVnf("id123")).thenReturn(vnf2);
1716         when(bbSetupUtils.getRelatedVolumeGroupByNameFromVfModule("id123", "id123", "111111"))
1717                 .thenReturn(opVolumeGroup);
1718
1719         when(bbSetupUtils.getRelatedVolumeGroupByNameFromVnf("id123", "111111")).thenReturn(Optional.empty());
1720         String id2 = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.VOLUMEGROUP, "111111",
1721                 reqDetails, workflowResourceIds);
1722         assertEquals("generatedId123", id2);
1723     }
1724
1725     @Test
1726     public void validateConfigurationResourceIdInAAITest() throws Exception {
1727         RequestDetails reqDetails = setupRequestDetails("id123", "subServiceType123", "1234567");
1728         WorkflowResourceIds workflowResourceIds = new WorkflowResourceIds();
1729         workflowResourceIds.setServiceInstanceId("siId123");
1730
1731         // Configuration
1732         org.onap.aai.domain.yang.Configuration configuration = new org.onap.aai.domain.yang.Configuration();
1733         configuration.setConfigurationId("id123");
1734         configuration.setConfigurationName("name123");
1735         configuration.setModelCustomizationId("1234567");
1736         Optional<org.onap.aai.domain.yang.Configuration> opConfiguration = Optional.of(configuration);
1737
1738         org.onap.aai.domain.yang.Configuration configuration2 = new org.onap.aai.domain.yang.Configuration();
1739         configuration2.setConfigurationId("id123");
1740         configuration2.setConfigurationName("name123");
1741         configuration2.setModelCustomizationId("222");
1742         Optional<org.onap.aai.domain.yang.Configuration> opConfiguration2 = Optional.of(configuration2);
1743
1744         workflowResourceIds.setVnfId("id123");
1745
1746         when(bbSetupUtils.getRelatedConfigurationByNameFromServiceInstance("siId123", "name123"))
1747                 .thenReturn(opConfiguration);
1748         String id = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.CONFIGURATION, "name123",
1749                 reqDetails, workflowResourceIds);
1750         assertEquals("id123", id);
1751
1752         when(bbSetupUtils.getRelatedConfigurationByNameFromServiceInstance("siId123", "111111"))
1753                 .thenReturn(Optional.empty());
1754         String id2 = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.CONFIGURATION, "111111",
1755                 reqDetails, workflowResourceIds);
1756         assertEquals("generatedId123", id2);
1757
1758         when(bbSetupUtils.getRelatedConfigurationByNameFromServiceInstance("siId123", "name222"))
1759                 .thenReturn(opConfiguration2);
1760         this.expectedException.expect(DuplicateNameException.class);
1761         this.expectedException.expectMessage(containsString(
1762                 "configuration with name (name222), same parent and different customization id (id123) already exists. The name must be unique."));
1763         workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.CONFIGURATION, "name222", reqDetails,
1764                 workflowResourceIds);
1765     }
1766
1767     @Test
1768     public void validateServiceInstanceResourceIdInAAITest() throws Exception {
1769         WorkflowResourceIds workflowResourceIds = new WorkflowResourceIds();
1770         workflowResourceIds.setServiceInstanceId("siId123");
1771         RequestDetails reqDetails = setupRequestDetails("id123", "subServiceType123", "1234567");
1772         reqDetails.getModelInfo().setModelVersionId("1234567");
1773
1774         ServiceInstance si = new ServiceInstance();
1775         si.setServiceInstanceId("siId123");
1776         si.setModelVersionId("1234567");
1777         ServiceInstances serviceInstances = new ServiceInstances();
1778         serviceInstances.getServiceInstance().add(si);
1779         Optional<ServiceInstance> siOp = Optional.of(si);
1780         ServiceInstance si2 = new ServiceInstance();
1781         si2.setServiceInstanceId("siId222");
1782         si2.setModelVersionId("22222");
1783         si2.setServiceInstanceName("siName222");
1784         Optional<ServiceInstance> siOp2 = Optional.of(si2);
1785         ServiceInstances serviceInstances2 = new ServiceInstances();
1786         serviceInstances2.getServiceInstance().add(si2);
1787
1788         when(bbSetupUtils.getAAIServiceInstanceByName("id123", "subServiceType123", "siName123")).thenReturn(siOp);
1789         when(bbSetupUtils.getAAIServiceInstanceByName("id123", "subServiceType123", "siName222")).thenReturn(siOp2);
1790         when(bbSetupUtils.getAAIServiceInstanceByName("id123", "subServiceType123", "111111"))
1791                 .thenReturn(Optional.empty());
1792
1793         when(bbSetupUtils.getAAIServiceInstancesGloballyByName("siName123")).thenReturn(serviceInstances);
1794         String id = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.SERVICE, "siName123",
1795                 reqDetails, workflowResourceIds);
1796         assertEquals("siId123", id);
1797         String id2 = workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.SERVICE, "111111",
1798                 reqDetails, workflowResourceIds);
1799         assertEquals("generatedId123", id2);
1800
1801         when(bbSetupUtils.getAAIServiceInstancesGloballyByName("siName222")).thenReturn(serviceInstances2);
1802         this.expectedException.expect(DuplicateNameException.class);
1803         this.expectedException.expectMessage(containsString(
1804                 "serviceInstance with name (siName222) and different version id (1234567) already exists. The name must be unique."));
1805         workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.SERVICE, "siName222", reqDetails,
1806                 workflowResourceIds);
1807     }
1808
1809     @Test
1810     public void validateServiceInstanceResourceIdInAAIMultipleTest() throws Exception {
1811         WorkflowResourceIds workflowResourceIds = new WorkflowResourceIds();
1812         workflowResourceIds.setServiceInstanceId("siId123");
1813         RequestDetails reqDetails = setupRequestDetails("id123", "subServiceType123", "1234567");
1814         reqDetails.getModelInfo().setModelVersionId("1234567");
1815
1816         ServiceInstance si = new ServiceInstance();
1817         si.setServiceInstanceId("siId123");
1818         si.setModelVersionId("1234567");
1819         ServiceInstances serviceInstances = new ServiceInstances();
1820         serviceInstances.getServiceInstance().add(si);
1821
1822         ServiceInstance si2 = new ServiceInstance();
1823         si2.setServiceInstanceId("siId222");
1824         si2.setModelVersionId("22222");
1825         si2.setServiceInstanceName("siName222");
1826         serviceInstances.getServiceInstance().add(si2);
1827
1828         when(bbSetupUtils.getAAIServiceInstanceByName("id123", "subServiceType123", "siId123"))
1829                 .thenReturn(Optional.empty());
1830
1831         when(bbSetupUtils.getAAIServiceInstancesGloballyByName("siName123")).thenReturn(serviceInstances);
1832
1833         this.expectedException.expect(DuplicateNameException.class);
1834         this.expectedException.expectMessage(containsString(
1835                 "serviceInstance with name (siName123) and multiple combination of model-version-id + service-type + global-customer-id already exists. The name must be unique."));
1836         workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.SERVICE, "siName123", reqDetails,
1837                 workflowResourceIds);
1838     }
1839
1840     @Test
1841     public void validateServiceInstanceResourceIdInAAIExistsTest() throws Exception {
1842         WorkflowResourceIds workflowResourceIds = new WorkflowResourceIds();
1843         workflowResourceIds.setServiceInstanceId("siId123");
1844         RequestDetails reqDetails = setupRequestDetails("id123", "subServiceType123", "1234567");
1845         reqDetails.getModelInfo().setModelVersionId("1234567");
1846
1847         ServiceInstance si = new ServiceInstance();
1848         si.setServiceInstanceId("siId123");
1849         si.setModelVersionId("1234567");
1850         ServiceInstances serviceInstances = new ServiceInstances();
1851         serviceInstances.getServiceInstance().add(si);
1852
1853         when(bbSetupUtils.getAAIServiceInstanceByName("id123", "subServiceType123", "siId123"))
1854                 .thenReturn(Optional.empty());
1855
1856         when(bbSetupUtils.getAAIServiceInstancesGloballyByName("siName123")).thenReturn(serviceInstances);
1857
1858         Map<String, String> uriKeys = new HashMap<>();
1859         uriKeys.put("global-customer-id", "globalCustomerId");
1860         uriKeys.put("service-type", "serviceType");
1861
1862         when(bbSetupUtils.getURIKeysFromServiceInstance("siId123")).thenReturn(uriKeys);
1863
1864         this.expectedException.expect(DuplicateNameException.class);
1865         this.expectedException.expectMessage(containsString(
1866                 "serviceInstance with name (siName123) and global-customer-id (globalCustomerId), service-type (serviceType), model-version-id (1234567) already exists. The name must be unique."));
1867         workflowAction.validateResourceIdInAAI("generatedId123", WorkflowType.SERVICE, "siName123", reqDetails,
1868                 workflowResourceIds);
1869     }
1870
1871     @Test
1872     public void handleRuntimeExceptionTest() {
1873         execution.setVariable("BPMN_javaExpMsg", "test runtime error message");
1874         execution.setVariable("testProcessKey", "testProcessKeyValue");
1875         try {
1876             workflowAction.handleRuntimeException(execution);
1877         } catch (BpmnError wfe) {
1878             assertEquals("MSOWorkflowException", wfe.getErrorCode());
1879         }
1880     }
1881
1882     @Ignore
1883     @Test
1884     public void traverseCatalogDbServiceMultipleNetworkTest() throws IOException, VrfBondingServiceException {
1885         execution.setVariable("testProcessKey", "testProcessKeyValue");
1886         Service service = new Service();
1887         List<NetworkResourceCustomization> networkCustomizations = new ArrayList<>();
1888         NetworkResourceCustomization networkCust = new NetworkResourceCustomization();
1889         networkCust.setModelCustomizationUUID("123");
1890         networkCustomizations.add(networkCust);
1891         service.setNetworkCustomizations(networkCustomizations);
1892         NetworkCollectionResourceCustomization collectionResourceCustomization =
1893                 new NetworkCollectionResourceCustomization();
1894         collectionResourceCustomization.setModelCustomizationUUID("123");
1895         CollectionResource collectionResource = new CollectionResource();
1896         collectionResource.setToscaNodeType("NetworkCollection");
1897         InstanceGroup instanceGroup = new InstanceGroup();
1898         List<CollectionResourceInstanceGroupCustomization> collectionInstanceGroupCustomizations = new ArrayList<>();
1899         CollectionResourceInstanceGroupCustomization collectionInstanceGroupCustomization =
1900                 new CollectionResourceInstanceGroupCustomization();
1901         collectionInstanceGroupCustomization.setSubInterfaceNetworkQuantity(3);
1902         collectionInstanceGroupCustomizations.add(collectionInstanceGroupCustomization);
1903         instanceGroup.setCollectionInstanceGroupCustomizations(collectionInstanceGroupCustomizations);
1904         collectionResource.setInstanceGroup(instanceGroup);
1905         collectionResourceCustomization.setCollectionResource(collectionResource);;
1906         service.setModelUUID("abc");
1907         service.getCollectionResourceCustomizations().add(collectionResourceCustomization);
1908         service.getCollectionResourceCustomizations().add(collectionResourceCustomization);
1909         doReturn(service).when(catalogDbClient).getServiceByID("3c40d244-808e-42ca-b09a-256d83d19d0a");
1910         doReturn(collectionResourceCustomization).when(catalogDbClient)
1911                 .getNetworkCollectionResourceCustomizationByID("123");
1912         String bpmnRequest = new String(Files
1913                 .readAllBytes(Paths.get("src/test/resources/__files/Macro/ServiceMacroActivateDeleteUnassign.json")));
1914         ObjectMapper mapper = new ObjectMapper();
1915         ServiceInstancesRequest sIRequest = mapper.readValue(bpmnRequest, ServiceInstancesRequest.class);
1916         List<Resource> resourceCounter = new ArrayList<>();
1917         thrown.expect(BpmnError.class);
1918         List<Pair<WorkflowType, String>> aaiResourceIds = new ArrayList<>();
1919         workflowAction.traverseCatalogDbService(execution, sIRequest, resourceCounter, aaiResourceIds);
1920     }
1921
1922     @Test
1923     public void sortVfModulesByBaseFirstTest() {
1924         List<Resource> resources = new ArrayList<>();
1925         Resource resource1 = new Resource(WorkflowType.VFMODULE, "111", false);
1926         resource1.setBaseVfModule(false);
1927         resources.add(resource1);
1928         Resource resource2 = new Resource(WorkflowType.VFMODULE, "222", false);
1929         resource2.setBaseVfModule(false);
1930         resources.add(resource2);
1931         Resource resource3 = new Resource(WorkflowType.VFMODULE, "333", false);
1932         resource3.setBaseVfModule(true);
1933         resources.add(resource3);
1934         List<Resource> result = workflowAction.sortVfModulesByBaseFirst(resources);
1935         assertEquals("333", result.get(0).getResourceId());
1936         assertEquals("222", result.get(1).getResourceId());
1937         assertEquals("111", result.get(2).getResourceId());
1938     }
1939
1940     @Test
1941     public void sortVfModulesByBaseLastTest() {
1942         List<Resource> resources = new ArrayList<>();
1943         Resource resource1 = new Resource(WorkflowType.VFMODULE, "111", false);
1944         resource1.setBaseVfModule(true);
1945         resources.add(resource1);
1946         Resource resource2 = new Resource(WorkflowType.VFMODULE, "222", false);
1947         resource2.setBaseVfModule(false);
1948         resources.add(resource2);
1949         Resource resource3 = new Resource(WorkflowType.VFMODULE, "333", false);
1950         resource3.setBaseVfModule(false);
1951         resources.add(resource3);
1952         List<Resource> result = workflowAction.sortVfModulesByBaseLast(resources);
1953         assertEquals("333", result.get(0).getResourceId());
1954         assertEquals("222", result.get(1).getResourceId());
1955         assertEquals("111", result.get(2).getResourceId());
1956     }
1957
1958     @Test
1959     public void findCatalogNetworkCollectionTest() {
1960         Service service = new Service();
1961         NetworkCollectionResourceCustomization networkCustomization = new NetworkCollectionResourceCustomization();
1962         networkCustomization.setModelCustomizationUUID("123");
1963         service.getCollectionResourceCustomizations().add(networkCustomization);
1964         doReturn(networkCustomization).when(catalogDbClient).getNetworkCollectionResourceCustomizationByID("123");
1965         CollectionResourceCustomization customization = workflowAction.findCatalogNetworkCollection(execution, service);
1966         assertNotNull(customization);
1967     }
1968
1969     @Test
1970     public void findCatalogNetworkCollectionEmptyTest() {
1971         Service service = new Service();
1972         NetworkCollectionResourceCustomization networkCustomization = new NetworkCollectionResourceCustomization();
1973         networkCustomization.setModelCustomizationUUID("123");
1974         service.getCollectionResourceCustomizations().add(networkCustomization);
1975         CollectionResourceCustomization customization = workflowAction.findCatalogNetworkCollection(execution, service);
1976         assertNull(customization);
1977     }
1978
1979     @Test
1980     public void findCatalogNetworkCollectionMoreThanOneTest() {
1981         Service service = new Service();
1982         NetworkCollectionResourceCustomization networkCustomization1 = new NetworkCollectionResourceCustomization();
1983         networkCustomization1.setModelCustomizationUUID("123");
1984         NetworkCollectionResourceCustomization networkCustomization2 = new NetworkCollectionResourceCustomization();
1985         networkCustomization2.setModelCustomizationUUID("321");
1986         service.getCollectionResourceCustomizations().add(networkCustomization1);
1987         service.getCollectionResourceCustomizations().add(networkCustomization2);
1988         doReturn(networkCustomization1).when(catalogDbClient).getNetworkCollectionResourceCustomizationByID("123");
1989         doReturn(networkCustomization2).when(catalogDbClient).getNetworkCollectionResourceCustomizationByID("321");
1990         workflowAction.findCatalogNetworkCollection(execution, service);
1991         assertEquals("Found multiple Network Collections in the Service model, only one per Service is supported.",
1992                 execution.getVariable("WorkflowActionErrorMessage"));
1993     }
1994
1995     @Test
1996     public void verifyLackOfNullPointerExceptionForNullResource() {
1997         ExecuteBuildingBlock result = null;
1998         try {
1999             result = workflowAction.buildExecuteBuildingBlock(new OrchestrationFlow(), null, null, null, null, null,
2000                     false, null, null, null, false, null, true);
2001         } catch (NullPointerException e) {
2002             fail("NullPointerException should not be thrown when 'resource' is null");
2003         }
2004         assertNotNull(result);
2005     }
2006
2007     @Test
2008     public void traverseAAIServiceTest() {
2009         List<Resource> resourceCounter = new ArrayList<>();
2010         String resourceId = "si0";
2011         List<Pair<WorkflowType, String>> aaiResourceIds = new ArrayList<>();
2012
2013         ServiceInstance serviceInstanceAAI = new ServiceInstance();
2014         serviceInstanceAAI.setServiceInstanceId(resourceId);
2015
2016         org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance serviceInstance = setServiceInstance();
2017         setGenericVnf();
2018         setVfModule(true);
2019         setVolumeGroup();
2020         setL3Network();
2021         setCollection();
2022         setConfiguration();
2023
2024         Configuration config = new Configuration();
2025         config.setConfigurationId("testConfigurationId2");
2026         serviceInstance.getConfigurations().add(config);
2027
2028         Relationship relationship1 = new Relationship();
2029         relationship1.setRelatedTo("vnfc");
2030         RelationshipList relationshipList1 = new RelationshipList();
2031         relationshipList1.getRelationship().add(relationship1);
2032
2033         Relationship relationship2 = new Relationship();
2034         relationship2.setRelatedTo("vpn-binding");
2035         RelationshipList relationshipList2 = new RelationshipList();
2036         relationshipList2.getRelationship().add(relationship2);
2037
2038         org.onap.aai.domain.yang.Configuration aaiConfiguration1 = new org.onap.aai.domain.yang.Configuration();
2039         aaiConfiguration1.setConfigurationId("testConfigurationId");
2040         aaiConfiguration1.setRelationshipList(relationshipList1);
2041
2042         org.onap.aai.domain.yang.Configuration aaiConfiguration2 = new org.onap.aai.domain.yang.Configuration();
2043         aaiConfiguration2.setConfigurationId("testConfigurationId2");
2044         aaiConfiguration2.setRelationshipList(relationshipList1);
2045
2046         try {
2047             doReturn(serviceInstanceAAI).when(bbSetupUtils).getAAIServiceInstanceById(resourceId);
2048             doReturn(serviceInstance).when(bbInputSetup).getExistingServiceInstance(serviceInstanceAAI);
2049             doReturn(Optional.of(aaiConfiguration1)).when(aaiConfigurationResources)
2050                     .getConfiguration("testConfigurationId");
2051             doReturn(Optional.of(aaiConfiguration2)).when(aaiConfigurationResources)
2052                     .getConfiguration("testConfigurationId2");
2053             workflowAction.traverseAAIService(execution, resourceCounter, resourceId, aaiResourceIds);
2054             assertEquals(8, resourceCounter.size());
2055             assertTrue(resourceCounter.get(2).isBaseVfModule());
2056             assertThat(aaiResourceIds, sameBeanAs(getExpectedResourceIds()));
2057         } catch (Exception e) {
2058             fail("Unexpected exception was thrown.");
2059         }
2060     }
2061
2062     private List<Pair<WorkflowType, String>> getExpectedResourceIds() {
2063         List<Pair<WorkflowType, String>> resourceIds = new ArrayList<>();
2064         resourceIds.add(new Pair<WorkflowType, String>(WorkflowType.VNF, "testVnfId1"));
2065         resourceIds.add(new Pair<WorkflowType, String>(WorkflowType.VFMODULE, "testVfModuleId1"));
2066         resourceIds.add(new Pair<WorkflowType, String>(WorkflowType.VOLUMEGROUP, "testVolumeGroupId1"));
2067         resourceIds.add(new Pair<WorkflowType, String>(WorkflowType.NETWORK, "testNetworkId1"));
2068         resourceIds.add(new Pair<WorkflowType, String>(WorkflowType.NETWORKCOLLECTION, "testId"));
2069         resourceIds.add(new Pair<WorkflowType, String>(WorkflowType.CONFIGURATION, "testConfigurationId"));
2070         resourceIds.add(new Pair<WorkflowType, String>(WorkflowType.CONFIGURATION, "testConfigurationId2"));
2071         return resourceIds;
2072     }
2073
2074     private List<OrchestrationFlow> createFlowList(String... flowNames) {
2075         List<OrchestrationFlow> result = new ArrayList<>();
2076         for (String flowName : flowNames) {
2077             OrchestrationFlow orchFlow = new OrchestrationFlow();
2078             orchFlow.setFlowName(flowName);
2079             result.add(orchFlow);
2080         }
2081         return result;
2082     }
2083
2084     private void assertEqualsBulkFlowName(List<ExecuteBuildingBlock> ebbs, String... flowNames) {
2085         for (int i = 0; i < ebbs.size(); i++) {
2086             assertEquals(ebbs.get(i).getBuildingBlock().getBpmnFlowName(), flowNames[i]);
2087         }
2088     }
2089 }