bpmn/MSOCommonBPMN/src/test/java/org/onap/so/bpmn/servicedecomposition/tasks/BBInputSetupTest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.so.bpmn.servicedecomposition.tasks;
  22
  23 import static com.shazam.shazamcrest.MatcherAssert.assertThat;
  24 import static com.shazam.shazamcrest.matcher.Matchers.sameBeanAs;
  25 import static org.junit.Assert.assertEquals;
  26 import static org.junit.Assert.assertNotNull;
  27 import static org.junit.Assert.assertNull;
  28 import static org.mockito.ArgumentMatchers.any;
  29 import static org.mockito.Matchers.eq;
  30 import static org.mockito.ArgumentMatchers.isA;
  31 import static org.mockito.Mockito.doNothing;
  32 import static org.mockito.Mockito.doReturn;
  33 import static org.mockito.Mockito.times;
  34 import static org.mockito.Mockito.verify;
  35
  36 import java.io.File;
  37 import java.io.IOException;
  38 import java.util.ArrayList;
  39 import java.util.Arrays;
  40 import java.util.HashMap;
  41 import java.util.List;
  42 import java.util.Map;
  43 import java.util.Optional;
  44
  45 import org.camunda.bpm.engine.delegate.DelegateExecution;
  46 import org.junit.Before;
  47 import org.junit.Test;
  48 import org.junit.runner.RunWith;
  49 import org.mockito.ArgumentMatchers;
  50 import org.mockito.Matchers;
  51 import org.mockito.Mock;
  52 import org.mockito.Mockito;
  53 import org.mockito.Spy;
  54 import org.mockito.junit.MockitoJUnitRunner;
  55 import org.onap.so.bpmn.servicedecomposition.bbobjects.CloudRegion;
  56 import org.onap.so.bpmn.servicedecomposition.bbobjects.Collection;
  57 import org.onap.so.bpmn.servicedecomposition.bbobjects.Configuration;
  58 import org.onap.so.bpmn.servicedecomposition.bbobjects.Customer;
  59 import org.onap.so.bpmn.servicedecomposition.bbobjects.GenericVnf;
  60 import org.onap.so.bpmn.servicedecomposition.bbobjects.InstanceGroup;
  61 import org.onap.so.bpmn.servicedecomposition.bbobjects.L3Network;
  62 import org.onap.so.bpmn.servicedecomposition.bbobjects.LineOfBusiness;
  63 import org.onap.so.bpmn.servicedecomposition.bbobjects.OwningEntity;
  64 import org.onap.so.bpmn.servicedecomposition.bbobjects.Platform;
  65 import org.onap.so.bpmn.servicedecomposition.bbobjects.Project;
  66 import org.onap.so.bpmn.servicedecomposition.bbobjects.RouteTableReference;
  67 import org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance;
  68 import org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceSubscription;
  69 import org.onap.so.bpmn.servicedecomposition.bbobjects.VfModule;
  70 import org.onap.so.bpmn.servicedecomposition.bbobjects.VolumeGroup;
  71 import org.onap.so.bpmn.servicedecomposition.entities.BuildingBlock;
  72 import org.onap.so.bpmn.servicedecomposition.entities.ConfigurationResourceKeys;
  73 import org.onap.so.bpmn.servicedecomposition.entities.ExecuteBuildingBlock;
  74 import org.onap.so.bpmn.servicedecomposition.entities.GeneralBuildingBlock;
  75 import org.onap.so.bpmn.servicedecomposition.entities.ResourceKey;
  76 import org.onap.so.bpmn.servicedecomposition.entities.WorkflowResourceIds;
  77 import org.onap.so.bpmn.servicedecomposition.generalobjects.OrchestrationContext;
  78 import org.onap.so.bpmn.servicedecomposition.generalobjects.RequestContext;
  79 import org.onap.so.bpmn.servicedecomposition.modelinfo.ModelInfoCollection;
  80 import org.onap.so.bpmn.servicedecomposition.modelinfo.ModelInfoGenericVnf;
  81 import org.onap.so.bpmn.servicedecomposition.modelinfo.ModelInfoInstanceGroup;
  82 import org.onap.so.bpmn.servicedecomposition.modelinfo.ModelInfoNetwork;
  83 import org.onap.so.bpmn.servicedecomposition.modelinfo.ModelInfoServiceInstance;
  84 import org.onap.so.bpmn.servicedecomposition.modelinfo.ModelInfoVfModule;
  85 import org.onap.so.client.aai.AAICommonObjectMapperProvider;
  86 import org.onap.so.client.aai.AAIObjectType;
  87 import org.onap.so.client.aai.entities.AAIResultWrapper;
  88 import org.onap.so.client.aai.entities.Relationships;
  89 import org.onap.so.client.aai.entities.uri.AAIResourceUri;
  90 import org.onap.so.client.aai.entities.uri.AAIUriFactory;
  91 import org.onap.so.constants.Defaults;
  92 import org.onap.so.db.catalog.beans.CollectionNetworkResourceCustomization;
  93 import org.onap.so.db.catalog.beans.CollectionResource;
  94 import org.onap.so.db.catalog.beans.CollectionResourceCustomization;
  95 import org.onap.so.db.catalog.beans.CollectionResourceInstanceGroupCustomization;
  96 import org.onap.so.db.catalog.beans.ConfigurationResourceCustomization;
  97 import org.onap.so.db.catalog.beans.InstanceGroupType;
  98 import org.onap.so.db.catalog.beans.NetworkCollectionResourceCustomization;
  99 import org.onap.so.db.catalog.beans.NetworkResourceCustomization;
 100 import org.onap.so.db.catalog.beans.OrchestrationStatus;
 101 import org.onap.so.db.catalog.beans.Service;
 102 import org.onap.so.db.catalog.beans.VfModuleCustomization;
 103 import org.onap.so.db.catalog.beans.VnfResourceCustomization;
 104 import org.onap.so.db.catalog.beans.VnfcInstanceGroupCustomization;
 105 import org.onap.so.db.request.beans.InfraActiveRequests;
 106 import org.onap.so.serviceinstancebeans.CloudConfiguration;
 107 import org.onap.so.serviceinstancebeans.ModelInfo;
 108 import org.onap.so.serviceinstancebeans.ModelType;
 109 import org.onap.so.serviceinstancebeans.RelatedInstance;
 110 import org.onap.so.serviceinstancebeans.RelatedInstanceList;
 111 import org.onap.so.serviceinstancebeans.RequestDetails;
 112 import org.onap.so.serviceinstancebeans.RequestInfo;
 113 import org.onap.so.serviceinstancebeans.RequestParameters;
 114 import org.onap.so.serviceinstancebeans.Resources;
 115 import org.onap.so.serviceinstancebeans.SubscriberInfo;
 116
 117 import com.fasterxml.jackson.core.JsonParseException;
 118 import com.fasterxml.jackson.core.JsonProcessingException;
 119 import com.fasterxml.jackson.databind.JsonMappingException;
 120 import com.fasterxml.jackson.databind.ObjectMapper;
 121 @RunWith(MockitoJUnitRunner.class)
 122 public class BBInputSetupTest {
 123         private static final String RESOURCE_PATH = "src/test/resources/__files/ExecuteBuildingBlock/";
 124
 125         protected ObjectMapper mapper = new ObjectMapper();
 126         private static final String CLOUD_OWNER = "CloudOwner";
 127
 128         @Spy
 129         private BBInputSetup SPY_bbInputSetup = new BBInputSetup();
 130
 131         @Mock
 132         private BBInputSetupUtils SPY_bbInputSetupUtils;
 133
 134         @Mock
 135         private CloudInfoFromAAI SPY_cloudInfoFromAAI;
 136
 137         @Spy
 138         private BBInputSetupMapperLayer bbInputSetupMapperLayer;
 139
 140         @Before
 141         public void setup(){
 142                 SPY_bbInputSetup.setBbInputSetupUtils(SPY_bbInputSetupUtils);
 143                 SPY_bbInputSetup.setMapperLayer(bbInputSetupMapperLayer);
 144                 SPY_bbInputSetup.setCloudInfoFromAAI(SPY_cloudInfoFromAAI);
 145         }
 146
 147         @Test
 148         public void testGetVolumeGroupIdRelatedToVfModule() {
 149                 String expected = "volumeGroupId";
 150                 String modelCustomizationId = "modelCustomizationId";
 151                 ModelInfo modelInfo = new ModelInfo();
 152                 modelInfo.setModelCustomizationId(modelCustomizationId);
 153                 String cloudOwner = "cloudOwner";
 154                 String cloudRegionId = "cloudRegionId";
 155                 String volumeGroupId = "volumeGroupId";
 156                 GenericVnf vnf = new GenericVnf();
 157                 VolumeGroup volumeGroup = new VolumeGroup();
 158                 volumeGroup.setVolumeGroupId(expected);
 159                 vnf.getVolumeGroups().add(volumeGroup);
 160                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
 161                 lookupKeyMap.put(ResourceKey.VOLUME_GROUP_ID, null);
 162                 org.onap.aai.domain.yang.VolumeGroup aaiVolumeGroup = new org.onap.aai.domain.yang.VolumeGroup();
 163                 aaiVolumeGroup.setModelCustomizationId(modelCustomizationId);
 164                 doReturn(aaiVolumeGroup).when(SPY_bbInputSetupUtils).getAAIVolumeGroup(cloudOwner, cloudRegionId, volumeGroupId);
 165
 166                 Optional<String> actual = SPY_bbInputSetup.getVolumeGroupIdRelatedToVfModule(vnf, modelInfo, cloudOwner, cloudRegionId, lookupKeyMap);
 167
 168                 assertEquals(expected, actual.get());
 169         }
 170
 171         @Test
 172         public void testGetAlaCarteServiceInstance() throws Exception {
 173                 ServiceInstance expected = mapper.readValue(
 174                                 new File(RESOURCE_PATH + "ServiceInstance_getServiceInstanceNOAAIExpected.json"),
 175                                 ServiceInstance.class);
 176                 RequestDetails requestDetails = new RequestDetails();
 177                 RequestInfo requestInfo = new RequestInfo();
 178                 requestInfo.setInstanceName("SharansInstanceName");
 179                 requestDetails.setRequestInfo(requestInfo);
 180                 Customer customer = new Customer();
 181                 String serviceInstanceId = "SharansInstanceId";
 182                 boolean aLaCarte = true;
 183                 Service service = new Service();
 184                 service.setModelUUID("modelUUID");
 185                 ModelInfoServiceInstance modelInfoServiceInstance = new ModelInfoServiceInstance();
 186                 modelInfoServiceInstance.setModelUuid("modelUUID");
 187                 expected.setModelInfoServiceInstance(modelInfoServiceInstance);
 188                 org.onap.aai.domain.yang.ServiceInstance serviceInstanceAAI = new org.onap.aai.domain.yang.ServiceInstance();
 189                 serviceInstanceAAI.setModelVersionId("modelUUIDDifferent");
 190                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
 191                 String bbName = AssignFlows.SERVICE_INSTANCE.toString();
 192                 Service differentService = new Service();
 193                 differentService.setModelUUID("modelUUIDDifferent");
 194
 195                 doReturn(expected).when(SPY_bbInputSetup).getServiceInstanceHelper(requestDetails, customer, null, null,
 196                                 lookupKeyMap, serviceInstanceId, aLaCarte, service, bbName);
 197                 doReturn(serviceInstanceAAI).when(SPY_bbInputSetupUtils).getAAIServiceInstanceById(serviceInstanceId);
 198                 doReturn(differentService).when(SPY_bbInputSetupUtils)
 199                                 .getCatalogServiceByModelUUID(serviceInstanceAAI.getModelVersionId());
 200                 doReturn(expected.getModelInfoServiceInstance()).when(bbInputSetupMapperLayer)
 201                                 .mapCatalogServiceIntoServiceInstance(differentService);
 202
 203                 ServiceInstance actual = SPY_bbInputSetup.getALaCarteServiceInstance(service, requestDetails, customer, null,
 204                                 null, lookupKeyMap, serviceInstanceId, aLaCarte, bbName);
 205                 assertThat(actual, sameBeanAs(expected));
 206         }
 207
 208         @Test(expected = Exception.class)
 209         public void testGetAlaCarteServiceInstanceException() throws Exception {
 210                 ServiceInstance expected = mapper.readValue(
 211                                 new File(RESOURCE_PATH + "ServiceInstance_getServiceInstanceNOAAIExpected.json"),
 212                                 ServiceInstance.class);
 213                 RequestDetails requestDetails = new RequestDetails();
 214                 RequestInfo requestInfo = new RequestInfo();
 215                 requestInfo.setInstanceName("SharansInstanceName");
 216                 requestDetails.setRequestInfo(requestInfo);
 217                 Customer customer = new Customer();
 218                 String serviceInstanceId = "SharansInstanceId";
 219                 boolean aLaCarte = true;
 220                 Service service = new Service();
 221                 service.setModelUUID("modelUUID");
 222                 ModelInfoServiceInstance modelInfoServiceInstance = new ModelInfoServiceInstance();
 223                 modelInfoServiceInstance.setModelUuid("modelUUID");
 224                 expected.setModelInfoServiceInstance(modelInfoServiceInstance);
 225                 org.onap.aai.domain.yang.ServiceInstance serviceInstanceAAI = new org.onap.aai.domain.yang.ServiceInstance();
 226                 serviceInstanceAAI.setModelVersionId("modelUUIDDifferent");
 227                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
 228                 String bbName = AssignFlows.SERVICE_INSTANCE.toString();
 229                 Service differentService = new Service();
 230                 differentService.setModelUUID("modelUUIDDifferent");
 231
 232                 doReturn(expected).when(SPY_bbInputSetup).getServiceInstanceHelper(requestDetails, customer, null, null,
 233                                 lookupKeyMap, serviceInstanceId, aLaCarte, service, bbName);
 234                 doReturn(serviceInstanceAAI).when(SPY_bbInputSetupUtils).getAAIServiceInstanceById(serviceInstanceId);
 235                 doReturn(null).when(SPY_bbInputSetupUtils)
 236                                 .getCatalogServiceByModelUUID(serviceInstanceAAI.getModelVersionId());
 237
 238                 ServiceInstance actual = SPY_bbInputSetup.getALaCarteServiceInstance(service, requestDetails, customer, null,
 239                                 null, lookupKeyMap, serviceInstanceId, aLaCarte, bbName);
 240                 assertThat(actual, sameBeanAs(expected));
 241         }
 242
 243         @Test
 244         public void testGetCustomerAndServiceSubscription() throws JsonParseException, JsonMappingException, IOException {
 245                 RequestDetails requestDetails = mapper.readValue(
 246                                 new File(RESOURCE_PATH + "RequestDetailsInput_withRelatedInstanceList.json"), RequestDetails.class);
 247                 SubscriberInfo subscriberInfo = new SubscriberInfo();
 248                 subscriberInfo.setGlobalSubscriberId("globalSubscriberId");
 249                 RequestParameters requestParams = new RequestParameters();
 250                 requestParams.setSubscriptionServiceType("subscriptionServiceType");
 251                 requestDetails.setRequestParameters(requestParams);
 252                 requestDetails.setSubscriberInfo(subscriberInfo);
 253                 String resourceId = "resourceId";
 254                 Customer expected = new Customer();
 255                 expected.setGlobalCustomerId("globalCustomerId");
 256                 ServiceSubscription serviceSubscription = new ServiceSubscription();
 257                 serviceSubscription.setServiceType("subscriptionServiceType");
 258
 259                 doReturn(expected).when(this.SPY_bbInputSetup).getCustomerFromRequest(requestDetails);
 260                 doReturn(serviceSubscription).when(this.SPY_bbInputSetup).getServiceSubscription(requestDetails, expected);
 261
 262                 Customer actual = this.SPY_bbInputSetup.getCustomerAndServiceSubscription(requestDetails, resourceId);
 263
 264                 assertThat(actual, sameBeanAs(expected));
 265
 266                 requestDetails.setSubscriberInfo(null);
 267
 268
 269                 assertThat(actual, sameBeanAs(expected));
 270
 271         }
 272
 273         @Test
 274         public void testSetHomingFlag() throws JsonParseException, JsonMappingException, IOException {
 275                 GeneralBuildingBlock expected = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
 276                                 GeneralBuildingBlock.class);
 277                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
 278                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, "vnfId");
 279                 GenericVnf genericVnfExpected = new GenericVnf();
 280                 genericVnfExpected.setVnfId("vnfId");
 281                 genericVnfExpected.setCallHoming(true);
 282                 expected.getCustomer().getServiceSubscription().getServiceInstances().get(0).getVnfs().add(genericVnfExpected);
 283                 boolean homing = true;
 284                 GenericVnf genericVnfActual = new GenericVnf();
 285                 genericVnfActual.setVnfId("vnfId");
 286                 genericVnfActual.setCallHoming(false);
 287                 GeneralBuildingBlock actual = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
 288                                 GeneralBuildingBlock.class);
 289                 actual.getCustomer().getServiceSubscription().getServiceInstances().get(0).getVnfs().add(genericVnfActual);
 290
 291                 SPY_bbInputSetup.setHomingFlag(actual, homing, lookupKeyMap);
 292                 assertThat(actual, sameBeanAs(expected));
 293         }
 294
 295         @Test
 296         public void testGetExecuteBBFromExecution() throws IOException {
 297                 ExecuteBuildingBlock expected = new ExecuteBuildingBlock();
 298                 BuildingBlock bb = new BuildingBlock();
 299                 bb.setBpmnFlowName("AssignServiceInstanceBB");
 300                 expected.setBuildingBlock(bb);
 301                 expected.setRequestId("00032ab7-3fb3-42e5-965d-8ea592502017");
 302                 DelegateExecution execution = Mockito.mock(DelegateExecution.class);
 303                 doReturn(expected).when(execution).getVariable(any(String.class));
 304                 ExecuteBuildingBlock actual = SPY_bbInputSetup.getExecuteBBFromExecution(execution);
 305                 assertThat(actual, sameBeanAs(expected));
 306         }
 307
 308         @Test
 309         public void testGetGBB() throws Exception {
 310                 GeneralBuildingBlock expected = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
 311                                 GeneralBuildingBlock.class);
 312
 313                 ExecuteBuildingBlock executeBB = new ExecuteBuildingBlock();
 314                 executeBB.setRequestId("requestId");
 315                 RequestDetails requestDetails = new RequestDetails();
 316                 ModelInfo modelInfo = new ModelInfo();
 317                 modelInfo.setModelType(ModelType.service);
 318                 requestDetails.setModelInfo(modelInfo);
 319                 RequestParameters requestParams = new RequestParameters();
 320                 requestParams.setaLaCarte(true);
 321                 requestDetails.setRequestParameters(requestParams);
 322                 doReturn(requestDetails).when(SPY_bbInputSetupUtils).getRequestDetails(executeBB.getRequestId());
 323                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
 324                 String resourceId = "123";
 325                 String requestAction = "createInstance";
 326                 doReturn(expected).when(SPY_bbInputSetup).getGBBALaCarteService(executeBB, requestDetails, lookupKeyMap,
 327                                 requestAction, resourceId);
 328                 doNothing().when(SPY_bbInputSetup).populateLookupKeyMapWithIds(executeBB.getWorkflowResourceIds(),lookupKeyMap);
 329                 boolean aLaCarte = true;
 330                 GeneralBuildingBlock actual = SPY_bbInputSetup.getGBB(executeBB, lookupKeyMap, requestAction, aLaCarte,
 331                                 resourceId, null);
 332
 333                 assertThat(actual, sameBeanAs(expected));
 334         }
 335
 336         @Test
 337         public void testGetGBBCM() throws Exception {
 338                 GeneralBuildingBlock expected = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockCMExpected.json"),
 339                                 GeneralBuildingBlock.class);
 340
 341                 ExecuteBuildingBlock executeBB = new ExecuteBuildingBlock();
 342                 executeBB.setRequestId("requestId");
 343                 RequestDetails requestDetails = new RequestDetails();
 344                 requestDetails.setModelInfo(null);
 345                 RequestParameters requestParams = new RequestParameters();
 346                 requestParams.setaLaCarte(true);
 347                 requestDetails.setRequestParameters(requestParams);
 348                 RequestInfo requestInfo = new RequestInfo();
 349                 requestInfo.setSuppressRollback(true);
 350                 requestInfo.setSource("VID");
 351                 requestDetails.setRequestInfo(requestInfo);
 352                 CloudConfiguration cloudConfiguration = new CloudConfiguration();
 353                 cloudConfiguration.setLcpCloudRegionId("myRegionId");
 354                 requestDetails.setCloudConfiguration(cloudConfiguration);
 355                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
 356                 String resourceId = "123";
 357                 String requestAction = "createInstance";
 358
 359                 doReturn(null).when(bbInputSetupMapperLayer).mapAAIGenericVnfIntoGenericVnf(ArgumentMatchers.isNull());
 360                 GeneralBuildingBlock actual = SPY_bbInputSetup.getGBBCM(executeBB, requestDetails, lookupKeyMap, requestAction,
 361                                 resourceId);
 362
 363                 assertThat(actual, sameBeanAs(expected));
 364         }
 365
 366         @Test
 367         public void testGetGBBALaCarteNonService() throws Exception {
 368                 GeneralBuildingBlock expected = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
 369                                 GeneralBuildingBlock.class);
 370                 ExecuteBuildingBlock executeBB = mapper.readValue(new File(RESOURCE_PATH + "ExecuteBuildingBlockSimple.json"),
 371                                 ExecuteBuildingBlock.class);
 372                 RequestDetails requestDetails = mapper.readValue(
 373                                 new File(RESOURCE_PATH + "RequestDetailsInput_withRelatedInstanceList.json"), RequestDetails.class);
 374                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
 375                 String requestAction = "createInstance";
 376                 Service service = Mockito.mock(Service.class);
 377                 ServiceInstance serviceInstance = Mockito.mock(ServiceInstance.class);
 378                 String resourceId = "123";
 379                 String vnfType = "vnfType";
 380                 org.onap.aai.domain.yang.ServiceInstance aaiServiceInstance = new org.onap.aai.domain.yang.ServiceInstance();
 381                 aaiServiceInstance.setModelVersionId("modelVersionId");
 382                 org.onap.aai.domain.yang.CloudRegion aaiCloudRegion = Mockito.mock(org.onap.aai.domain.yang.CloudRegion.class);
 383                 lookupKeyMap.put(ResourceKey.SERVICE_INSTANCE_ID, "instanceId");
 384                 doReturn(service).when(SPY_bbInputSetupUtils).getCatalogServiceByModelUUID(aaiServiceInstance.getModelVersionId());
 385                 doReturn(aaiServiceInstance).when(SPY_bbInputSetupUtils).getAAIServiceInstanceById("instanceId");
 386
 387                 doNothing().when(SPY_bbInputSetup).populateObjectsOnAssignAndCreateFlows(requestDetails, service, "bbName",
 388                                 serviceInstance, lookupKeyMap, resourceId, vnfType);
 389                 doReturn(serviceInstance).when(SPY_bbInputSetup).getExistingServiceInstance(aaiServiceInstance);
 390                 doReturn(expected).when(SPY_bbInputSetup).populateGBBWithSIAndAdditionalInfo(requestDetails, serviceInstance,
 391                                 executeBB, requestAction, null);
 392
 393                 GeneralBuildingBlock actual = SPY_bbInputSetup.getGBBALaCarteNonService(executeBB, requestDetails, lookupKeyMap,
 394                                 requestAction, resourceId, vnfType);
 395
 396                 assertThat(actual, sameBeanAs(expected));
 397         }
 398
 399         @Test(expected = Exception.class)
 400         public void testGetGBBALaCarteNonServiceWithoutServiceModelInfo() throws Exception {
 401                 ExecuteBuildingBlock executeBB = mapper.readValue(new File(RESOURCE_PATH + "ExecuteBuildingBlockSimple.json"),
 402                                 ExecuteBuildingBlock.class);
 403                 RequestDetails requestDetails = mapper.readValue(
 404                                 new File(RESOURCE_PATH + "RequestDetailsInput_withRelatedInstanceList.json"), RequestDetails.class);
 405                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
 406                 String requestAction = "createInstance";
 407                 org.onap.aai.domain.yang.ServiceInstance aaiServiceInstance = new org.onap.aai.domain.yang.ServiceInstance();
 408                 aaiServiceInstance.setModelVersionId("modelVersionId");
 409                 String resourceId = "123";
 410                 String vnfType = "vnfType";
 411
 412                 SPY_bbInputSetup.getGBBALaCarteNonService(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId,
 413                                 vnfType);
 414         }
 415
 416         @Test
 417         public void testGetGBBALaCarteNonServiceWithoutRelatedInstances() throws Exception {
 418                 GeneralBuildingBlock expected = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
 419                                 GeneralBuildingBlock.class);
 420                 ExecuteBuildingBlock executeBB = mapper.readValue(new File(RESOURCE_PATH + "ExecuteBuildingBlockSimple.json"),
 421                                 ExecuteBuildingBlock.class);
 422                 RequestDetails requestDetails = mapper.readValue(
 423                                 new File(RESOURCE_PATH + "RequestDetailsInput_withoutRelatedInstanceList.json"), RequestDetails.class);
 424                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
 425                 String requestAction = "createInstance";
 426                 Service service = Mockito.mock(Service.class);
 427                 String resourceId = "123";
 428                 ServiceInstance serviceInstance = Mockito.mock(ServiceInstance.class);
 429                 org.onap.aai.domain.yang.ServiceInstance aaiServiceInstance = new org.onap.aai.domain.yang.ServiceInstance();
 430                 aaiServiceInstance.setModelVersionId("modelVersionId");
 431                 org.onap.aai.domain.yang.CloudRegion aaiCloudRegion = Mockito.mock(org.onap.aai.domain.yang.CloudRegion.class);
 432                 String vnfType = "vnfType";
 433                 lookupKeyMap.put(ResourceKey.SERVICE_INSTANCE_ID, "instanceId");
 434                 doReturn(service).when(SPY_bbInputSetupUtils).getCatalogServiceByModelUUID(aaiServiceInstance.getModelVersionId());
 435                 doReturn(aaiServiceInstance).when(SPY_bbInputSetupUtils).getAAIServiceInstanceById("instanceId");
 436
 437                 doNothing().when(SPY_bbInputSetup).populateObjectsOnAssignAndCreateFlows(requestDetails, service, "bbName",
 438                                 serviceInstance, lookupKeyMap, resourceId, vnfType);
 439
 440                 doReturn(serviceInstance).when(SPY_bbInputSetup).getExistingServiceInstance(aaiServiceInstance);
 441                 doReturn(expected).when(SPY_bbInputSetup).populateGBBWithSIAndAdditionalInfo(requestDetails, serviceInstance,
 442                                 executeBB, requestAction,null);
 443
 444                 GeneralBuildingBlock actual = SPY_bbInputSetup.getGBBALaCarteNonService(executeBB, requestDetails, lookupKeyMap,
 445                                 requestAction, resourceId, vnfType);
 446
 447                 assertThat(actual, sameBeanAs(expected));
 448         }
 449
 450         @Test
 451         public void testGetGBBALaCarteService() throws Exception {
 452                 GeneralBuildingBlock expected = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
 453                                 GeneralBuildingBlock.class);
 454                 ExecuteBuildingBlock executeBB = mapper.readValue(new File(RESOURCE_PATH + "ExecuteBuildingBlockSimple.json"),
 455                                 ExecuteBuildingBlock.class);
 456                 RequestDetails requestDetails = mapper.readValue(
 457                                 new File(RESOURCE_PATH + "RequestDetailsInput_withRelatedInstanceList.json"), RequestDetails.class);
 458                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
 459
 460                 org.onap.so.serviceinstancebeans.Project requestProject = new org.onap.so.serviceinstancebeans.Project();
 461                 org.onap.so.serviceinstancebeans.OwningEntity requestOwningEntity = new org.onap.so.serviceinstancebeans.OwningEntity();
 462                 requestDetails.setProject(requestProject);
 463                 requestDetails.setOwningEntity(requestOwningEntity);
 464
 465                 Service service = Mockito.mock(Service.class);
 466                 Customer customer = Mockito.mock(Customer.class);
 467                 ServiceSubscription serviceSubscription = Mockito.mock(ServiceSubscription.class);
 468                 Project project = Mockito.mock(Project.class);
 469                 OwningEntity owningEntity = Mockito.mock(OwningEntity.class);
 470                 ServiceInstance serviceInstance = Mockito.mock(ServiceInstance.class);
 471                 String resourceId = "123";
 472                 String requestAction = "createInstance";
 473                 executeBB.setaLaCarte(true);
 474                 executeBB.getBuildingBlock().setBpmnFlowName(AssignFlows.SERVICE_INSTANCE.toString());
 475                 org.onap.aai.domain.yang.CloudRegion aaiCloudRegion = Mockito.mock(org.onap.aai.domain.yang.CloudRegion.class);
 476
 477                 doReturn(service).when(SPY_bbInputSetupUtils)
 478                                 .getCatalogServiceByModelUUID(requestDetails.getModelInfo().getModelVersionId());
 479                 doReturn(project).when(bbInputSetupMapperLayer).mapRequestProject(requestDetails.getProject());
 480                 doReturn(owningEntity).when(bbInputSetupMapperLayer)
 481                                 .mapRequestOwningEntity(requestDetails.getOwningEntity());
 482
 483                 doReturn(customer).when(SPY_bbInputSetup).getCustomerAndServiceSubscription(requestDetails, resourceId);
 484                 doReturn(serviceInstance).when(SPY_bbInputSetup).getALaCarteServiceInstance(service, requestDetails, customer,
 485                                 project, owningEntity, lookupKeyMap, resourceId, Boolean.TRUE.equals(executeBB.isaLaCarte()),
 486                                 executeBB.getBuildingBlock().getBpmnFlowName());
 487                 doReturn(expected).when(SPY_bbInputSetup).populateGBBWithSIAndAdditionalInfo(requestDetails, serviceInstance,
 488                                 executeBB, requestAction, customer);
 489
 490                 GeneralBuildingBlock actual = SPY_bbInputSetup.getGBBALaCarteService(executeBB, requestDetails, lookupKeyMap,
 491                                 requestAction, resourceId);
 492
 493                 assertThat(actual, sameBeanAs(expected));
 494         }
 495
 496         @Test
 497         public void testGetGBBALaCarteServiceFindServiceByModelVersionId() throws Exception {
 498                 GeneralBuildingBlock expected = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
 499                                 GeneralBuildingBlock.class);
 500                 ExecuteBuildingBlock executeBB = mapper.readValue(new File(RESOURCE_PATH + "ExecuteBuildingBlockSimple.json"),
 501                                 ExecuteBuildingBlock.class);
 502                 RequestDetails requestDetails = mapper.readValue(
 503                                 new File(RESOURCE_PATH + "RequestDetailsInput_withRelatedInstanceList.json"), RequestDetails.class);
 504                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
 505
 506                 org.onap.so.serviceinstancebeans.Project requestProject = new org.onap.so.serviceinstancebeans.Project();
 507                 org.onap.so.serviceinstancebeans.OwningEntity requestOwningEntity = new org.onap.so.serviceinstancebeans.OwningEntity();
 508                 requestDetails.setProject(requestProject);
 509                 requestDetails.setOwningEntity(requestOwningEntity);
 510
 511                 Service service = Mockito.mock(Service.class);
 512                 Customer customer = Mockito.mock(Customer.class);
 513                 ServiceSubscription serviceSubscription = Mockito.mock(ServiceSubscription.class);
 514                 Project project = Mockito.mock(Project.class);
 515                 OwningEntity owningEntity = Mockito.mock(OwningEntity.class);
 516                 ServiceInstance serviceInstance = Mockito.mock(ServiceInstance.class);
 517                 String resourceId = "123";
 518                 String requestAction = "createInstance";
 519                 executeBB.setaLaCarte(true);
 520                 executeBB.getBuildingBlock().setBpmnFlowName(AssignFlows.SERVICE_INSTANCE.toString());
 521                 org.onap.aai.domain.yang.CloudRegion aaiCloudRegion = Mockito.mock(org.onap.aai.domain.yang.CloudRegion.class);
 522
 523                 doReturn(null).when(SPY_bbInputSetupUtils)
 524                                 .getCatalogServiceByModelUUID(requestDetails.getModelInfo().getModelVersionId());
 525                 doReturn(service).when(SPY_bbInputSetupUtils).getCatalogServiceByModelVersionAndModelInvariantUUID(
 526                                 requestDetails.getModelInfo().getModelVersion(), requestDetails.getModelInfo().getModelInvariantId());
 527                 doReturn(project).when(bbInputSetupMapperLayer).mapRequestProject(requestDetails.getProject());
 528                 doReturn(owningEntity).when(bbInputSetupMapperLayer)
 529                                 .mapRequestOwningEntity(requestDetails.getOwningEntity());
 530
 531                 doReturn(customer).when(SPY_bbInputSetup).getCustomerAndServiceSubscription(requestDetails, resourceId);
 532                 doReturn(serviceInstance).when(SPY_bbInputSetup).getALaCarteServiceInstance(service, requestDetails, customer,
 533                                 project, owningEntity, lookupKeyMap, resourceId, Boolean.TRUE.equals(executeBB.isaLaCarte()),
 534                                 executeBB.getBuildingBlock().getBpmnFlowName());
 535                 doReturn(expected).when(SPY_bbInputSetup).populateGBBWithSIAndAdditionalInfo(requestDetails, serviceInstance,
 536                                 executeBB, requestAction,customer);
 537
 538                 GeneralBuildingBlock actual = SPY_bbInputSetup.getGBBALaCarteService(executeBB, requestDetails, lookupKeyMap,
 539                                 requestAction, resourceId);
 540
 541                 assertThat(actual, sameBeanAs(expected));
 542         }
 543
 544         @Test
 545         public void testGetGBBALaCarteServiceNoProjectNoOE() throws Exception {
 546                 GeneralBuildingBlock expected = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
 547                                 GeneralBuildingBlock.class);
 548                 ExecuteBuildingBlock executeBB = mapper.readValue(new File(RESOURCE_PATH + "ExecuteBuildingBlockSimple.json"),
 549                                 ExecuteBuildingBlock.class);
 550                 RequestDetails requestDetails = mapper.readValue(
 551                                 new File(RESOURCE_PATH + "RequestDetailsInput_withRelatedInstanceList.json"), RequestDetails.class);
 552                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
 553
 554                 Service service = Mockito.mock(Service.class);
 555                 Customer customer = Mockito.mock(Customer.class);
 556                 ServiceSubscription serviceSubscription = Mockito.mock(ServiceSubscription.class);
 557                 ServiceInstance serviceInstance = Mockito.mock(ServiceInstance.class);
 558                 String resourceId = "123";
 559                 String requestAction = "createInstance";
 560                 executeBB.setaLaCarte(true);
 561                 executeBB.getBuildingBlock().setBpmnFlowName(AssignFlows.SERVICE_INSTANCE.toString());
 562                 org.onap.aai.domain.yang.CloudRegion aaiCloudRegion = Mockito.mock(org.onap.aai.domain.yang.CloudRegion.class);
 563
 564                 Map<String, String> uriKeys = new HashMap<>();
 565                 uriKeys.put("global-customer-id", "globalCustomerId");
 566                 uriKeys.put("service-type", "serviceType");
 567
 568                 doReturn(service).when(SPY_bbInputSetupUtils)
 569                                 .getCatalogServiceByModelUUID(requestDetails.getModelInfo().getModelVersionId());
 570
 571                 doReturn(customer).when(SPY_bbInputSetup).getCustomerAndServiceSubscription(requestDetails, resourceId);
 572
 573                 doReturn(serviceInstance).when(SPY_bbInputSetup).getALaCarteServiceInstance(service, requestDetails, customer,
 574                                 null, null, lookupKeyMap, resourceId, Boolean.TRUE.equals(executeBB.isaLaCarte()),
 575                                 executeBB.getBuildingBlock().getBpmnFlowName());
 576                 doReturn(expected).when(SPY_bbInputSetup).populateGBBWithSIAndAdditionalInfo(requestDetails, serviceInstance,
 577                                 executeBB, requestAction,customer);
 578
 579                 GeneralBuildingBlock actual = SPY_bbInputSetup.getGBBALaCarteService(executeBB, requestDetails, lookupKeyMap,
 580                                 requestAction, resourceId);
 581
 582                 assertThat(actual, sameBeanAs(expected));
 583         }
 584
 585         @Test
 586         public void testGetServiceInstanceHelperCreateScenario() throws Exception {
 587                 RequestDetails requestDetails = new RequestDetails();
 588                 RequestInfo requestInfo = new RequestInfo();
 589                 requestInfo.setInstanceName("SharansInstanceName");
 590                 requestDetails.setRequestInfo(requestInfo);
 591                 Customer customer = new Customer();
 592                 String serviceInstanceId = "SharansInstanceId";
 593                 boolean aLaCarte = true;
 594                 ServiceInstance expected = new ServiceInstance();
 595                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
 596                 Service service = new Service();
 597                 service.setModelUUID("modelUUID");
 598                 String bbName = AssignFlows.SERVICE_INSTANCE.toString();
 599
 600                 doReturn(null).when(SPY_bbInputSetupUtils).getAAIServiceInstanceByName(requestInfo.getInstanceName(), customer);
 601                 doReturn(null).when(SPY_bbInputSetupUtils).getAAIServiceInstanceById(serviceInstanceId);
 602
 603
 604                 doReturn(expected).when(SPY_bbInputSetup).createServiceInstance(requestDetails, null, null,
 605                                 lookupKeyMap, serviceInstanceId);
 606
 607                 ServiceInstance actual = SPY_bbInputSetup.getServiceInstanceHelper(requestDetails, customer, null, null,
 608                                 lookupKeyMap, serviceInstanceId, aLaCarte, service, bbName);
 609                 assertThat(actual, sameBeanAs(expected));
 610         }
 611
 612         @Test
 613         public void testGetServiceInstanceHelperCreateScenarioExisting() throws Exception {
 614                 RequestDetails requestDetails = new RequestDetails();
 615                 RequestInfo requestInfo = new RequestInfo();
 616                 requestInfo.setInstanceName("SharansInstanceName");
 617                 requestDetails.setRequestInfo(requestInfo);
 618                 Customer customer = new Customer();
 619                 String serviceInstanceId = "SharansInstanceId";
 620                 boolean aLaCarte = true;
 621                 Service service = new Service();
 622                 service.setModelUUID("modelUUID");
 623                 ServiceInstance expected = new ServiceInstance();
 624                 org.onap.aai.domain.yang.ServiceInstance serviceInstanceAAI = new org.onap.aai.domain.yang.ServiceInstance();
 625                 serviceInstanceAAI.setModelVersionId("modelUUID");
 626                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
 627                 String bbName = AssignFlows.SERVICE_INSTANCE.toString();
 628
 629                 doReturn(serviceInstanceAAI).when(SPY_bbInputSetupUtils)
 630                                 .getAAIServiceInstanceByName(requestInfo.getInstanceName(), customer);
 631                 doReturn(expected).when(SPY_bbInputSetup).getExistingServiceInstance(serviceInstanceAAI);
 632
 633                 ServiceInstance actual = SPY_bbInputSetup.getServiceInstanceHelper(requestDetails, customer, null, null,
 634                                 lookupKeyMap, serviceInstanceId, aLaCarte, service, bbName);
 635                 assertThat(actual, sameBeanAs(expected));
 636         }
 637
 638         @Test
 639         public void testGetServiceInstanceHelperCreateScenarioExistingNoNameButWithId() throws Exception {
 640                 RequestDetails requestDetails = new RequestDetails();
 641                 RequestInfo requestInfo = new RequestInfo();
 642                 requestInfo.setInstanceName("SharansInstanceName");
 643                 requestDetails.setRequestInfo(requestInfo);
 644                 Customer customer = new Customer();
 645                 String serviceInstanceId = "SharansInstanceId";
 646                 boolean aLaCarte = true;
 647                 Service service = new Service();
 648                 service.setModelUUID("modelUUID");
 649                 ServiceInstance expected = new ServiceInstance();
 650                 org.onap.aai.domain.yang.ServiceInstance serviceInstanceAAI = new org.onap.aai.domain.yang.ServiceInstance();
 651                 serviceInstanceAAI.setModelVersionId("modelUUID");
 652                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
 653                 String bbName = "ActivateServiceInstanceBB";
 654
 655                 doReturn(serviceInstanceAAI).when(SPY_bbInputSetupUtils).getAAIServiceInstanceById(serviceInstanceId);
 656                 doReturn(expected).when(SPY_bbInputSetup).getExistingServiceInstance(serviceInstanceAAI);
 657
 658                 ServiceInstance actual = SPY_bbInputSetup.getServiceInstanceHelper(requestDetails, customer, null, null,
 659                                 lookupKeyMap, serviceInstanceId, aLaCarte, service, bbName);
 660                 assertThat(actual, sameBeanAs(expected));
 661         }
 662
 663         @Test
 664         public void testGetServiceInstanceHelperCreateScenarioExistingNoNameButWithIdDifferentModel() throws Exception {
 665                 RequestDetails requestDetails = new RequestDetails();
 666                 RequestInfo requestInfo = new RequestInfo();
 667                 requestDetails.setRequestInfo(requestInfo);
 668                 Customer customer = new Customer();
 669                 String serviceInstanceId = "SharansInstanceId";
 670                 boolean aLaCarte = true;
 671                 Service service = new Service();
 672                 service.setModelUUID("modelUUID");
 673                 ServiceInstance expected = new ServiceInstance();
 674                 org.onap.aai.domain.yang.ServiceInstance serviceInstanceAAI = new org.onap.aai.domain.yang.ServiceInstance();
 675                 serviceInstanceAAI.setModelVersionId("modelUUIDDifferent");
 676                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
 677                 String bbName = "ActivateServiceInstanceBB";
 678                 Service differentService = new Service();
 679                 differentService.setModelUUID("modelUUIDDifferent");
 680
 681                 doReturn(serviceInstanceAAI).when(SPY_bbInputSetupUtils).getAAIServiceInstanceById(serviceInstanceId);
 682
 683
 684                 ServiceInstance actual = SPY_bbInputSetup.getServiceInstanceHelper(requestDetails, customer, null, null,
 685                                 lookupKeyMap, serviceInstanceId, aLaCarte, service, bbName);
 686                 assertThat(actual, sameBeanAs(expected));
 687         }
 688
 689         @Test(expected = Exception.class)
 690         public void testGetServiceInstanceHelperCreateScenarioExistingNoNameButWithIdExceptionThrown() throws Exception {
 691                 RequestDetails requestDetails = new RequestDetails();
 692                 RequestInfo requestInfo = new RequestInfo();
 693                 requestDetails.setRequestInfo(requestInfo);
 694                 Customer customer = new Customer();
 695                 String serviceInstanceId = "SharansInstanceId";
 696                 boolean aLaCarte = true;
 697                 Service service = new Service();
 698                 service.setModelUUID("modelUUID");
 699                 org.onap.aai.domain.yang.ServiceInstance serviceInstanceAAI = new org.onap.aai.domain.yang.ServiceInstance();
 700                 serviceInstanceAAI.setModelVersionId("modelUUIDDifferent");
 701                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
 702                 String bbName = AssignFlows.SERVICE_INSTANCE.toString();
 703
 704                 ServiceInstance actual = SPY_bbInputSetup.getServiceInstanceHelper(requestDetails, customer, null, null,
 705                                 lookupKeyMap, serviceInstanceId, aLaCarte, service, bbName);
 706         }
 707
 708         @Test
 709         public void testPopulateObjectsOnAssignAndCreateFlows() throws Exception {
 710                 String bbName = AssignFlows.SERVICE_INSTANCE.toString();
 711                 String instanceName = "instanceName";
 712                 String vnfType = "vnfType";
 713                 String resourceId = "networkId";
 714                 Service service = Mockito.mock(Service.class);
 715                 ServiceInstance serviceInstance = Mockito.mock(ServiceInstance.class);
 716                 RequestDetails requestDetails = Mockito.mock(RequestDetails.class);
 717                 ModelInfo modelInfo = Mockito.mock(ModelInfo.class);
 718                 RequestInfo requestInfo = Mockito.mock(RequestInfo.class);
 719                 RelatedInstanceList[] relatedInstanceList = new RelatedInstanceList[] {};
 720                 CloudConfiguration cloudConfiguration = new CloudConfiguration();
 721                 org.onap.so.serviceinstancebeans.Platform platform = Mockito
 722                                 .mock(org.onap.so.serviceinstancebeans.Platform.class);
 723                 org.onap.so.serviceinstancebeans.LineOfBusiness lineOfBusiness = Mockito
 724                                 .mock(org.onap.so.serviceinstancebeans.LineOfBusiness.class);
 725                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
 726
 727                 doNothing().when(SPY_bbInputSetup).populateL3Network(instanceName, modelInfo, service, bbName, serviceInstance,
 728                                 lookupKeyMap, resourceId, null);
 729                 doReturn(modelInfo).when(requestDetails).getModelInfo();
 730                 doReturn(requestInfo).when(requestDetails).getRequestInfo();
 731                 doReturn(instanceName).when(requestInfo).getInstanceName();
 732                 doReturn(platform).when(requestDetails).getPlatform();
 733                 doReturn(lineOfBusiness).when(requestDetails).getLineOfBusiness();
 734                 doReturn(relatedInstanceList).when(requestDetails).getRelatedInstanceList();
 735                 doReturn(cloudConfiguration).when(requestDetails).getCloudConfiguration();
 736
 737                 doReturn(ModelType.network).when(modelInfo).getModelType();
 738                 SPY_bbInputSetup.populateObjectsOnAssignAndCreateFlows(requestDetails, service, bbName, serviceInstance,
 739                                 lookupKeyMap, resourceId, vnfType);
 740                 verify(SPY_bbInputSetup, times(1)).populateL3Network(instanceName, modelInfo, service, bbName, serviceInstance,
 741                                 lookupKeyMap, resourceId, null);
 742                 assertEquals("NetworkId populated", true, lookupKeyMap.get(ResourceKey.NETWORK_ID).equalsIgnoreCase(resourceId));
 743
 744                 doReturn(ModelType.vnf).when(modelInfo).getModelType();
 745                 resourceId = "vnfId";
 746                 doNothing().when(SPY_bbInputSetup).populateGenericVnf(modelInfo, instanceName, platform, lineOfBusiness,
 747                                 service, bbName, serviceInstance, lookupKeyMap, relatedInstanceList, resourceId, vnfType, null);
 748                 SPY_bbInputSetup.populateObjectsOnAssignAndCreateFlows(requestDetails, service, bbName, serviceInstance,
 749                                 lookupKeyMap, resourceId, vnfType);
 750                 verify(SPY_bbInputSetup, times(1)).populateGenericVnf(modelInfo, instanceName, platform, lineOfBusiness,
 751                                 service, bbName, serviceInstance, lookupKeyMap, relatedInstanceList, resourceId, vnfType, null);
 752                 assertEquals("VnfId populated", true, lookupKeyMap.get(ResourceKey.GENERIC_VNF_ID).equalsIgnoreCase(resourceId));
 753
 754                 doReturn(ModelType.volumeGroup).when(modelInfo).getModelType();
 755                 resourceId = "volumeGroupId";
 756                 doNothing().when(SPY_bbInputSetup).populateVolumeGroup(modelInfo, service, bbName, serviceInstance,
 757                                 lookupKeyMap, resourceId, relatedInstanceList, instanceName, vnfType, null);
 758                 SPY_bbInputSetup.populateObjectsOnAssignAndCreateFlows(requestDetails, service, bbName, serviceInstance,
 759                                 lookupKeyMap, resourceId, vnfType);
 760                 verify(SPY_bbInputSetup, times(1)).populateVolumeGroup(modelInfo, service, bbName, serviceInstance,
 761                                 lookupKeyMap, resourceId, relatedInstanceList, instanceName, vnfType, null);
 762                 assertEquals("VolumeGroupId populated", true, lookupKeyMap.get(ResourceKey.VOLUME_GROUP_ID).equalsIgnoreCase(resourceId));
 763
 764                 doReturn(ModelType.vfModule).when(modelInfo).getModelType();
 765                 resourceId = "vfModuleId";
 766                 doNothing().when(SPY_bbInputSetup).populateVfModule(modelInfo, service, bbName, serviceInstance, lookupKeyMap,
 767                                 resourceId, relatedInstanceList, instanceName, null, cloudConfiguration);
 768                 SPY_bbInputSetup.populateObjectsOnAssignAndCreateFlows(requestDetails, service, bbName, serviceInstance,
 769                                 lookupKeyMap, resourceId, vnfType);
 770                 verify(SPY_bbInputSetup, times(1)).populateVfModule(modelInfo, service, bbName, serviceInstance, lookupKeyMap,
 771                                 resourceId, relatedInstanceList, instanceName, null, cloudConfiguration);
 772                 assertEquals("VfModuleId populated", true, lookupKeyMap.get(ResourceKey.VF_MODULE_ID).equalsIgnoreCase(resourceId));
 773         }
 774
 775         @Test
 776         public void testPopulateGBBWithSIAndAdditionalInfo() throws Exception {
 777                 GeneralBuildingBlock expected = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
 778                                 GeneralBuildingBlock.class);
 779                 ExecuteBuildingBlock executeBB = mapper.readValue(new File(RESOURCE_PATH + "ExecuteBuildingBlockSimple.json"),
 780                                 ExecuteBuildingBlock.class);
 781                 RequestDetails requestDetails = mapper.readValue(
 782                                 new File(RESOURCE_PATH + "RequestDetailsInput_withRelatedInstanceList.json"), RequestDetails.class);
 783                 RequestContext requestContext = mapper.readValue(new File(RESOURCE_PATH + "RequestContextExpected.json"),
 784                                 RequestContext.class);
 785                 ServiceInstance serviceInstance = mapper.readValue(
 786                                 new File(RESOURCE_PATH + "ServiceInstance_getServiceInstanceNOAAIExpected.json"),
 787                                 ServiceInstance.class);
 788
 789                 OrchestrationContext orchestrationContext = new OrchestrationContext();
 790                 orchestrationContext.setIsRollbackEnabled(false);
 791
 792                 CloudRegion cloudRegion = new CloudRegion();
 793                 cloudRegion.setCloudOwner("test-owner-name");
 794                 cloudRegion.setLcpCloudRegionId("lcpCloudRegionId");
 795                 cloudRegion.setComplex("complexName");
 796                 cloudRegion.setTenantId("tenantId");
 797
 798                 Map<String, String> uriKeys = new HashMap<>();
 799                 uriKeys.put("global-customer-id","global-customer-id");
 800                 uriKeys.put("service-type","service-type");
 801
 802                 Customer customer = new Customer();
 803                 ServiceSubscription serviceSubscription = new ServiceSubscription();
 804                 serviceSubscription.setServiceType("subscriptionServiceType");
 805                 customer.setGlobalCustomerId("globalCustomerId");
 806                 customer.setSubscriberName("subscriberName");
 807                 customer.setSubscriberType("subscriberType");
 808                 customer.setServiceSubscription(serviceSubscription);
 809
 810                 org.onap.aai.domain.yang.CloudRegion aaiCloudRegion = Mockito.mock(org.onap.aai.domain.yang.CloudRegion.class);
 811
 812                 String requestAction = "createInstance";
 813
 814                 doReturn(uriKeys).when(SPY_bbInputSetupUtils).getURIKeysFromServiceInstance(serviceInstance.getServiceInstanceId());
 815                 doReturn(customer).when(SPY_bbInputSetup).mapCustomer(uriKeys.get("global-customer-id"),uriKeys.get("service-type"));
 816                 doReturn(aaiCloudRegion).when(SPY_bbInputSetupUtils).getCloudRegion(requestDetails.getCloudConfiguration());
 817                 doReturn(orchestrationContext).when(bbInputSetupMapperLayer).mapOrchestrationContext(requestDetails);
 818                 doReturn(requestContext).when(bbInputSetupMapperLayer).mapRequestContext(requestDetails);
 819                 doReturn(cloudRegion).when(bbInputSetupMapperLayer).mapCloudRegion(requestDetails.getCloudConfiguration(), aaiCloudRegion);
 820
 821                 GeneralBuildingBlock actual = SPY_bbInputSetup.populateGBBWithSIAndAdditionalInfo(requestDetails,
 822                                 serviceInstance, executeBB, requestAction, null);
 823
 824                 assertThat(actual, sameBeanAs(expected));
 825         }
 826
 827         @Test
 828         public void testGetServiceInstanceNOAAI() throws Exception {
 829                 ServiceInstance expected = mapper.readValue(
 830                                 new File(RESOURCE_PATH + "ServiceInstance_getServiceInstanceNOAAIExpected.json"),
 831                                 ServiceInstance.class);
 832                 Service service = mapper.readValue(
 833                                 new File(RESOURCE_PATH + "CatalogDBService_getServiceInstanceNOAAIInput.json"), Service.class);
 834                 Customer customer = mapper.readValue(new File(RESOURCE_PATH + "Customer.json"), Customer.class);
 835                 Project project = mapper.readValue(new File(RESOURCE_PATH + "Project.json"), Project.class);
 836                 OwningEntity owningEntity = mapper.readValue(new File(RESOURCE_PATH + "OwningEntity.json"), OwningEntity.class);
 837                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
 838
 839                 ExecuteBuildingBlock executeBB = new ExecuteBuildingBlock();
 840                 executeBB.setaLaCarte(true);
 841                 BuildingBlock buildingBlock = new BuildingBlock();
 842                 buildingBlock.setBpmnFlowName(AssignFlows.SERVICE_INSTANCE.toString());
 843                 executeBB.setBuildingBlock(buildingBlock);
 844                 RequestDetails requestDetails = new RequestDetails();
 845                 RequestInfo reqInfo = new RequestInfo();
 846                 reqInfo.setInstanceName("serviceInstanceName");
 847                 requestDetails.setRequestInfo(reqInfo);
 848                 ModelInfo modelInfo = new ModelInfo();
 849                 modelInfo.setModelType(ModelType.service);
 850                 requestDetails.setModelInfo(modelInfo);
 851                 doReturn(null).when(SPY_bbInputSetupUtils)
 852                                 .getAAIServiceInstanceByName(requestDetails.getRequestInfo().getInstanceName(), customer);
 853                 doReturn(expected.getModelInfoServiceInstance()).when(bbInputSetupMapperLayer)
 854                                 .mapCatalogServiceIntoServiceInstance(service);
 855                 doReturn(null).when(SPY_bbInputSetupUtils).getAAIServiceInstanceById(any(String.class));
 856                 String serviceInstanceId = "3655a595-05d1-433c-93c0-3afd6b572545";
 857                 boolean aLaCarte = true;
 858
 859                 ServiceInstance actual = SPY_bbInputSetup.getALaCarteServiceInstance(service, requestDetails, customer, project,
 860                                 owningEntity, lookupKeyMap, serviceInstanceId, aLaCarte,
 861                                 executeBB.getBuildingBlock().getBpmnFlowName());
 862
 863                 assertThat(actual, sameBeanAs(expected));
 864         }
 865
 866         @Test
 867         public void testGetServiceSubscription() throws IOException {
 868                 ServiceSubscription expected = new ServiceSubscription();
 869                 RequestDetails requestDetails = new RequestDetails();
 870                 RequestParameters params = new RequestParameters();
 871                 params.setSubscriptionServiceType("subscriptionServiceType");
 872                 requestDetails.setRequestParameters(params);
 873                 org.onap.aai.domain.yang.ServiceSubscription aaiServiceSubscription = new org.onap.aai.domain.yang.ServiceSubscription();
 874                 Customer customer = new Customer();
 875                 customer.setGlobalCustomerId("globalCustomerId");
 876                 doReturn(aaiServiceSubscription).when(SPY_bbInputSetupUtils).getAAIServiceSubscription(
 877                                 customer.getGlobalCustomerId(), requestDetails.getRequestParameters().getSubscriptionServiceType());
 878                 doReturn(expected).when(bbInputSetupMapperLayer).mapAAIServiceSubscription(aaiServiceSubscription);
 879
 880                 ServiceSubscription actual = SPY_bbInputSetup.getServiceSubscription(requestDetails, customer);
 881                 assertThat(actual, sameBeanAs(expected));
 882         }
 883
 884         @Test
 885         public void testGetCustomer() throws IOException {
 886                 Customer expected = new Customer();
 887                 RequestDetails requestDetails = new RequestDetails();
 888                 SubscriberInfo subscriberInfo = new SubscriberInfo();
 889                 subscriberInfo.setGlobalSubscriberId("globalSubscriberId");
 890                 requestDetails.setSubscriberInfo(subscriberInfo);
 891                 org.onap.aai.domain.yang.Customer aaiCustomer = new org.onap.aai.domain.yang.Customer();
 892                 doReturn(aaiCustomer).when(SPY_bbInputSetupUtils)
 893                                 .getAAICustomer(requestDetails.getSubscriberInfo().getGlobalSubscriberId());
 894                 doReturn(expected).when(bbInputSetupMapperLayer).mapAAICustomer(aaiCustomer);
 895
 896                 Customer actual = SPY_bbInputSetup.getCustomerFromRequest(requestDetails);
 897                 assertThat(actual, sameBeanAs(expected));
 898         }
 899
 900         @Test
 901         public void testGetExistingServiceInstance() throws Exception {
 902                 org.onap.aai.domain.yang.ServiceInstance serviceInstanceAAI = new org.onap.aai.domain.yang.ServiceInstance();
 903                 ServiceInstance expected = new ServiceInstance();
 904
 905                 doReturn(expected).when(bbInputSetupMapperLayer)
 906                                 .mapAAIServiceInstanceIntoServiceInstance(serviceInstanceAAI);
 907
 908
 909                 ServiceInstance actual = SPY_bbInputSetup.getExistingServiceInstance(serviceInstanceAAI);
 910                 assertThat(actual, sameBeanAs(expected));
 911         }
 912
 913         @Test
 914         public void testPopulateNetworkCollectionAndInstanceGroupAssign() throws Exception {
 915                 Service service = Mockito.mock(Service.class);
 916                 String key = "collectionCustId";
 917                 ServiceInstance serviceInstance = mapper.readValue(
 918                                 new File(RESOURCE_PATH + "ServiceInstance_getServiceInstanceNOAAIExpected.json"),
 919                                 ServiceInstance.class);
 920                 String resourceId = "123";
 921                 Collection collection = SPY_bbInputSetup.createCollection(resourceId);
 922                 InstanceGroup instanceGroup = SPY_bbInputSetup.createInstanceGroup();
 923                 assertNull(serviceInstance.getCollection());
 924                 doReturn(true).when(SPY_bbInputSetup).isVlanTagging(service, key);
 925                 doReturn(collection).when(SPY_bbInputSetup).createCollection(resourceId);
 926                 doReturn(instanceGroup).when(SPY_bbInputSetup).createInstanceGroup();
 927                 doNothing().when(SPY_bbInputSetup).mapCatalogCollection(service, collection, key);
 928
 929                 NetworkCollectionResourceCustomization networkCollection = new NetworkCollectionResourceCustomization();
 930                 networkCollection.setModelCustomizationUUID(key);
 931                 networkCollection.setCollectionResource(new CollectionResource());
 932                 networkCollection.getCollectionResource().setInstanceGroup(new org.onap.so.db.catalog.beans.InstanceGroup());
 933                 networkCollection.getCollectionResource().getInstanceGroup().setToscaNodeType("NetworkCollectionResource");
 934                 networkCollection.getCollectionResource().getInstanceGroup().setType(InstanceGroupType.L3_NETWORK);
 935                 networkCollection.getCollectionResource().getInstanceGroup().setCollectionInstanceGroupCustomizations(new ArrayList<>());
 936                 List<CollectionResourceCustomization> customizations = new ArrayList<>();
 937                 customizations.add(networkCollection);
 938                 doReturn(customizations).when(service).getCollectionResourceCustomizations();
 939
 940                 SPY_bbInputSetup.populateNetworkCollectionAndInstanceGroupAssign(service,
 941                                 AssignFlows.NETWORK_COLLECTION.toString(), serviceInstance, resourceId, key);
 942
 943                 assertNotNull(serviceInstance.getCollection());
 944                 assertNotNull(serviceInstance.getCollection().getInstanceGroup());
 945
 946                 verify(SPY_bbInputSetup, times(1)).mapCatalogCollection(service, serviceInstance.getCollection(), key);
 947                 verify(SPY_bbInputSetup, times(1)).mapCatalogNetworkCollectionInstanceGroup(service,
 948                                 serviceInstance.getCollection().getInstanceGroup(), key);
 949         }
 950
 951         @Test
 952         public void testIsVlanTagging() throws Exception {
 953                 boolean expected = true;
 954                 Service service = Mockito.mock(Service.class);
 955                 String key = "collectionCustId";
 956                 NetworkCollectionResourceCustomization networkCollection = new NetworkCollectionResourceCustomization();
 957                 networkCollection.setModelCustomizationUUID(key);
 958                 networkCollection.setCollectionResource(new CollectionResource());
 959                 networkCollection.getCollectionResource().setInstanceGroup(new org.onap.so.db.catalog.beans.InstanceGroup());
 960                 networkCollection.getCollectionResource().getInstanceGroup().setToscaNodeType("org.openecomp.resource.cr.NetworkCollectionResource1806");
 961                 List<CollectionResourceCustomization> customizations = new ArrayList<>();
 962                 customizations.add(networkCollection);
 963                 doReturn(customizations).when(service).getCollectionResourceCustomizations();
 964                 boolean actual = SPY_bbInputSetup.isVlanTagging(service, key);
 965                 assertEquals("Is Vlan Tagging check.", expected, actual);
 966         }
 967
 968         @Test
 969         public void testPopulateVolumeGroup() throws Exception {
 970                 RequestDetails requestDetails = new RequestDetails();
 971                 RelatedInstanceList ril = new RelatedInstanceList();
 972                 RelatedInstance ri = new RelatedInstance();
 973                 ModelInfo mi = new ModelInfo();
 974                 mi.setModelType(ModelType.vnf);
 975                 mi.setModelCustomizationUuid("vnfModelCustomizationUUID");
 976                 ri.setModelInfo(mi);
 977                 ril.setRelatedInstance(ri);
 978                 requestDetails.setRelatedInstanceList(new RelatedInstanceList[] { ril });
 979
 980                 ModelInfo modelInfo = new ModelInfo();
 981                 modelInfo.setModelType(ModelType.volumeGroup);
 982
 983                 RequestInfo reqInfo = new RequestInfo();
 984                 reqInfo.setInstanceName("volumeGroupName");
 985                 requestDetails.setModelInfo(modelInfo);
 986                 requestDetails.setRequestInfo(reqInfo);
 987
 988                 ServiceInstance serviceInstance = new ServiceInstance();
 989                 GenericVnf vnf = new GenericVnf();
 990                 vnf.setVnfId("genericVnfId");
 991
 992                 VolumeGroup vg = new VolumeGroup();
 993                 vg.setVolumeGroupName("volumeGroupName");
 994                 vg.setVolumeGroupId("volumeGroupId");
 995                 vnf.getVolumeGroups().add(vg);
 996                 serviceInstance.getVnfs().add(vnf);
 997
 998                 Service service = mapper.readValue(
 999                                 new File(RESOURCE_PATH + "CatalogDBService_getServiceInstanceNOAAIInput.json"), Service.class);
1000                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
1001                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, "genericVnfId");
1002
1003                 String bbName = AssignFlows.VOLUME_GROUP.toString();
1004                 String resourceId = "123";
1005                 doNothing().when(SPY_bbInputSetup).mapCatalogVolumeGroup(isA(VolumeGroup.class), eq(modelInfo),
1006                                 eq(service), eq("vnfModelCustomizationUUID"));
1007                 org.onap.aai.domain.yang.GenericVnf aaiGenericVnf = new org.onap.aai.domain.yang.GenericVnf();
1008                 aaiGenericVnf.setModelCustomizationId("vnfModelCustomizationUUID");
1009                 doReturn(aaiGenericVnf).when(SPY_bbInputSetupUtils).getAAIGenericVnf(vnf.getVnfId());
1010
1011                 lookupKeyMap.put(ResourceKey.VOLUME_GROUP_ID, "volumeGroupId");
1012                 SPY_bbInputSetup.populateVolumeGroup(modelInfo, service, bbName, serviceInstance, lookupKeyMap, resourceId,
1013                                 requestDetails.getRelatedInstanceList(), reqInfo.getInstanceName(), null, null);
1014                 verify(SPY_bbInputSetup, times(1)).mapCatalogVolumeGroup(vg, modelInfo, service, "vnfModelCustomizationUUID");
1015                 vnf.getVolumeGroups().clear();
1016                 SPY_bbInputSetup.populateVolumeGroup(modelInfo, service, bbName, serviceInstance, lookupKeyMap, resourceId,
1017                                 requestDetails.getRelatedInstanceList(), reqInfo.getInstanceName(), null, null);
1018                 verify(SPY_bbInputSetup, times(1)).mapCatalogVolumeGroup(vnf.getVolumeGroups().get(0), modelInfo, service,
1019                                 "vnfModelCustomizationUUID");
1020         }
1021
1022         @Test
1023         public void testMapCatalogVolumeGroup() {
1024                 VolumeGroup volumeGroup = new VolumeGroup();
1025                 RequestDetails requestDetails = new RequestDetails();
1026                 ModelInfo modelInfo = new ModelInfo();
1027                 modelInfo.setModelCustomizationUuid("modelCustomizationUUID");
1028                 requestDetails.setModelInfo(modelInfo);
1029                 Service service = new Service();
1030                 VnfResourceCustomization resourceCust = new VnfResourceCustomization();
1031                 resourceCust.setModelCustomizationUUID("vnfModelCustomizationUUID");
1032                 service.getVnfCustomizations().add(resourceCust);
1033                 VfModuleCustomization vfResourceCust = new VfModuleCustomization();
1034                 vfResourceCust.setModelCustomizationUUID("modelCustomizationUUID");
1035                 ModelInfoVfModule modelInfoVfModule = new ModelInfoVfModule();
1036                 resourceCust.getVfModuleCustomizations().add(vfResourceCust);
1037
1038                 doReturn(modelInfoVfModule).when(bbInputSetupMapperLayer).mapCatalogVfModuleToVfModule(vfResourceCust);
1039
1040                 SPY_bbInputSetup.mapCatalogVolumeGroup(volumeGroup, modelInfo, service, "vnfModelCustomizationUUID");
1041
1042                 assertEquals(modelInfoVfModule, volumeGroup.getModelInfoVfModule());
1043         }
1044
1045         @Test
1046         public void testPopulateL3Network() throws JsonParseException, JsonMappingException, IOException {
1047                 String instanceName = "networkName";
1048                 ModelInfo modelInfo = new ModelInfo();
1049                 modelInfo.setModelType(ModelType.network);
1050
1051                 ServiceInstance serviceInstance = new ServiceInstance();
1052                 L3Network network = new L3Network();
1053                 network.setNetworkId("networkId");
1054                 network.setNetworkName("networkName");
1055                 serviceInstance.getNetworks().add(network);
1056                 String resourceId = "123";
1057                 // Mock service
1058                 Service service = mapper.readValue(
1059                                 new File(RESOURCE_PATH + "CatalogDBService_getServiceInstanceNOAAIInput.json"), Service.class);
1060                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
1061                 lookupKeyMap.put(ResourceKey.NETWORK_ID, "networkId");
1062                 String bbName = AssignFlows.NETWORK_A_LA_CARTE.toString();
1063
1064                 doNothing().when(SPY_bbInputSetup).mapCatalogNetwork(network, modelInfo, service);
1065
1066                 SPY_bbInputSetup.populateL3Network(instanceName, modelInfo, service, bbName, serviceInstance, lookupKeyMap,
1067                                 resourceId, null);
1068
1069                 lookupKeyMap.put(ResourceKey.NETWORK_ID, null);
1070
1071                 SPY_bbInputSetup.populateL3Network(instanceName, modelInfo, service, bbName, serviceInstance, lookupKeyMap,
1072                                 resourceId, null);
1073                 verify(SPY_bbInputSetup, times(1)).mapCatalogNetwork(network, modelInfo, service);
1074
1075                 instanceName = "networkName2";
1076                 L3Network network2 = SPY_bbInputSetup.createNetwork(lookupKeyMap, instanceName, resourceId, null);
1077                 SPY_bbInputSetup.populateL3Network(instanceName, modelInfo, service, bbName, serviceInstance, lookupKeyMap,
1078                                 resourceId, null);
1079                 verify(SPY_bbInputSetup, times(2)).mapCatalogNetwork(network2, modelInfo, service);
1080         }
1081
1082         @Test
1083         public void testMapCatalogNetwork() {
1084                 ModelInfoNetwork modelInfoNetwork = new ModelInfoNetwork();
1085                 L3Network network = new L3Network();
1086
1087                 RequestDetails requestDetails = new RequestDetails();
1088                 ModelInfo modelInfo = new ModelInfo();
1089                 modelInfo.setModelCustomizationUuid("modelCustomizationUUID");
1090                 requestDetails.setModelInfo(modelInfo);
1091                 Service service = new Service();
1092                 NetworkResourceCustomization resourceCust = new NetworkResourceCustomization();
1093                 resourceCust.setModelCustomizationUUID("modelCustomizationUUID");
1094                 service.setNetworkCustomizations(Arrays.asList(new NetworkResourceCustomization[] { resourceCust }));
1095
1096                 doReturn(modelInfoNetwork).when(bbInputSetupMapperLayer).mapCatalogNetworkToNetwork(resourceCust);
1097
1098                 SPY_bbInputSetup.mapCatalogNetwork(network, modelInfo, service);
1099
1100                 assertEquals(modelInfoNetwork, network.getModelInfoNetwork());
1101         }
1102
1103         @Test
1104         public void testPopulateConfiguration() throws JsonParseException, JsonMappingException, IOException {
1105                 String instanceName = "configurationName";
1106                 ModelInfo modelInfo = new ModelInfo();
1107                 modelInfo.setModelCustomizationUuid("72d9d1cd-f46d-447a-abdb-451d6fb05fa9");
1108
1109                 ServiceInstance serviceInstance = new ServiceInstance();
1110                 Configuration configuration = new Configuration();
1111                 configuration.setConfigurationId("configurationId");
1112                 configuration.setConfigurationName("configurationName");
1113                 serviceInstance.getConfigurations().add(configuration);
1114                 String resourceId = "configurationId";
1115                 // Mock service
1116                 Service service = mapper.readValue(
1117                                 new File(RESOURCE_PATH + "CatalogDBService_getServiceInstanceNOAAIInput.json"), Service.class);
1118                 ConfigurationResourceCustomization configurationCust = new ConfigurationResourceCustomization();
1119                 configurationCust.setModelCustomizationUUID("72d9d1cd-f46d-447a-abdb-451d6fb05fa9");
1120                 service.getConfigurationCustomizations().add(configurationCust);
1121                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
1122                 lookupKeyMap.put(ResourceKey.CONFIGURATION_ID, "configurationId");
1123                 String bbName = AssignFlows.FABRIC_CONFIGURATION.toString();
1124                 ConfigurationResourceKeys configResourceKeys = new ConfigurationResourceKeys();
1125                 configResourceKeys.setCvnfcCustomizationUUID("cvnfcCustomizationUUID");
1126                 configResourceKeys.setVfModuleCustomizationUUID("vfModuleCustomizationUUID");
1127                 configResourceKeys.setVnfResourceCustomizationUUID("vnfResourceCustomizationUUID");
1128
1129                 doNothing().when(SPY_bbInputSetup).mapCatalogConfiguration(configuration, modelInfo, service, configResourceKeys);
1130
1131                 SPY_bbInputSetup.populateConfiguration(modelInfo, service, bbName, serviceInstance, lookupKeyMap, resourceId,
1132                                 instanceName, configResourceKeys);
1133                 verify(SPY_bbInputSetup, times(1)).mapCatalogConfiguration(configuration, modelInfo, service, configResourceKeys);
1134
1135                 lookupKeyMap.put(ResourceKey.CONFIGURATION_ID, null);
1136
1137                 SPY_bbInputSetup.populateConfiguration(modelInfo, service, bbName, serviceInstance, lookupKeyMap, resourceId,
1138                                 instanceName, configResourceKeys);
1139                 verify(SPY_bbInputSetup, times(2)).mapCatalogConfiguration(configuration, modelInfo, service, configResourceKeys);
1140
1141                 instanceName = "configurationName2";
1142                 resourceId = "resourceId2";
1143                 lookupKeyMap.put(ResourceKey.CONFIGURATION_ID, "configurationId2");
1144                 Configuration configuration2 = SPY_bbInputSetup.createConfiguration(lookupKeyMap, instanceName, resourceId);
1145                 doReturn(configuration2).when(SPY_bbInputSetup).createConfiguration(lookupKeyMap, instanceName, resourceId);
1146                 doNothing().when(SPY_bbInputSetup).mapCatalogConfiguration(configuration2, modelInfo, service, configResourceKeys);
1147                 SPY_bbInputSetup.populateConfiguration(modelInfo, service, bbName, serviceInstance, lookupKeyMap, resourceId,
1148                                 instanceName, configResourceKeys);
1149                 verify(SPY_bbInputSetup, times(1)).mapCatalogConfiguration(configuration2, modelInfo, service, configResourceKeys);
1150         }
1151
1152         @Test
1153         public void testMapCatalogConfiguration() {
1154                 ModelInfoNetwork modelInfoNetwork = new ModelInfoNetwork();
1155                 L3Network network = new L3Network();
1156
1157                 RequestDetails requestDetails = new RequestDetails();
1158                 ModelInfo modelInfo = new ModelInfo();
1159                 modelInfo.setModelCustomizationUuid("modelCustomizationUUID");
1160                 requestDetails.setModelInfo(modelInfo);
1161                 Service service = new Service();
1162                 NetworkResourceCustomization resourceCust = new NetworkResourceCustomization();
1163                 resourceCust.setModelCustomizationUUID("modelCustomizationUUID");
1164                 service.setNetworkCustomizations(Arrays.asList(new NetworkResourceCustomization[] { resourceCust }));
1165
1166                 doReturn(modelInfoNetwork).when(bbInputSetupMapperLayer).mapCatalogNetworkToNetwork(resourceCust);
1167
1168                 SPY_bbInputSetup.mapCatalogNetwork(network, modelInfo, service);
1169
1170                 assertEquals(modelInfoNetwork, network.getModelInfoNetwork());
1171         }
1172
1173         @Test
1174         public void testPopulateGenericVnf() throws JsonParseException, JsonMappingException, IOException {
1175                 org.onap.so.serviceinstancebeans.Platform platform = new org.onap.so.serviceinstancebeans.Platform();
1176                 org.onap.so.serviceinstancebeans.LineOfBusiness lineOfBusiness = new org.onap.so.serviceinstancebeans.LineOfBusiness();
1177                 String instanceName = "vnfName";
1178                 ModelInfo modelInfo = new ModelInfo();
1179                 modelInfo.setModelType(ModelType.vnf);
1180
1181                 ServiceInstance serviceInstance = new ServiceInstance();
1182                 GenericVnf vnf = new GenericVnf();
1183                 vnf.setVnfId("genericVnfId");
1184                 vnf.setVnfName("vnfName");
1185                 serviceInstance.getVnfs().add(vnf);
1186                 String vnfType = "vnfType";
1187                 RequestDetails requestDetails = mapper.readValue(new File(RESOURCE_PATH + "RequestDetails_CreateVnf.json"),
1188                                 RequestDetails.class);
1189
1190                 Service service = mapper.readValue(
1191                                 new File(RESOURCE_PATH + "CatalogDBService_getServiceInstanceNOAAIInput.json"), Service.class);
1192                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
1193                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, "genericVnfId");
1194                 String bbName = AssignFlows.VNF.toString();
1195
1196                 Platform expectedPlatform = new Platform();
1197                 LineOfBusiness expectedLineOfBusiness = new LineOfBusiness();
1198                 String resourceId = "123";
1199                 doReturn(expectedPlatform).when(bbInputSetupMapperLayer).mapRequestPlatform(platform);
1200                 doReturn(expectedLineOfBusiness).when(bbInputSetupMapperLayer).mapRequestLineOfBusiness(lineOfBusiness);
1201                 org.onap.aai.domain.yang.GenericVnf vnfAAI = new org.onap.aai.domain.yang.GenericVnf();
1202                 vnfAAI.setModelCustomizationId("modelCustId");
1203                 doReturn(vnfAAI).when(SPY_bbInputSetupUtils).getAAIGenericVnf(vnf.getVnfId());
1204                 doNothing().when(SPY_bbInputSetup).mapCatalogVnf(vnf, modelInfo, service);
1205                 org.onap.aai.domain.yang.InstanceGroup instanceGroupAAI = new org.onap.aai.domain.yang.InstanceGroup();
1206                 doReturn(instanceGroupAAI).when(SPY_bbInputSetupUtils).getAAIInstanceGroup(any());
1207                 org.onap.so.db.catalog.beans.InstanceGroup catalogInstanceGroup = new org.onap.so.db.catalog.beans.InstanceGroup();
1208                 doReturn(catalogInstanceGroup).when(SPY_bbInputSetupUtils).getCatalogInstanceGroup(any());
1209
1210                 SPY_bbInputSetup.populateGenericVnf(modelInfo, instanceName, platform, lineOfBusiness, service, bbName,
1211                                 serviceInstance, lookupKeyMap, requestDetails.getRelatedInstanceList(), resourceId, vnfType, null);
1212
1213                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, null);
1214
1215                 SPY_bbInputSetup.populateGenericVnf(modelInfo, instanceName, platform, lineOfBusiness, service, bbName,
1216                                 serviceInstance, lookupKeyMap, requestDetails.getRelatedInstanceList(), resourceId, vnfType, null);
1217                 verify(SPY_bbInputSetup, times(1)).mapCatalogVnf(vnf, modelInfo, service);
1218
1219                 instanceName = "vnfName2";
1220                 GenericVnf vnf2 = SPY_bbInputSetup.createGenericVnf(lookupKeyMap, instanceName, platform, lineOfBusiness,
1221                                 resourceId, vnfType, null);
1222                 doReturn(vnf2).when(SPY_bbInputSetup).createGenericVnf(lookupKeyMap, instanceName, platform, lineOfBusiness,
1223                                 resourceId, vnfType, null);
1224                 doNothing().when(SPY_bbInputSetup).mapNetworkCollectionInstanceGroup(vnf2, "{instanceGroupId}");
1225                 doNothing().when(SPY_bbInputSetup).mapVnfcCollectionInstanceGroup(vnf2, modelInfo, service);
1226
1227                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, "genericVnfId2");
1228
1229                 SPY_bbInputSetup.populateGenericVnf(modelInfo, instanceName, platform, lineOfBusiness, service, bbName,
1230                                 serviceInstance, lookupKeyMap, requestDetails.getRelatedInstanceList(), resourceId, vnfType, null);
1231                 verify(SPY_bbInputSetup, times(2)).mapCatalogVnf(vnf2, modelInfo, service);
1232                 verify(SPY_bbInputSetup, times(2)).mapNetworkCollectionInstanceGroup(vnf2, "{instanceGroupId}");
1233                 verify(SPY_bbInputSetup, times(2)).mapVnfcCollectionInstanceGroup(vnf2, modelInfo, service);
1234         }
1235
1236         @Test
1237         public void testMapVnfcCollectionInstanceGroup() {
1238                 VnfResourceCustomization vnfResourceCust = Mockito.mock(VnfResourceCustomization.class);
1239                 GenericVnf genericVnf = new GenericVnf();
1240                 ModelInfo modelInfo = Mockito.mock(ModelInfo.class);
1241                 Service service = Mockito.mock(Service.class);
1242                 List<VnfcInstanceGroupCustomization> vnfcInstanceGroups = new ArrayList<>();
1243                 VnfcInstanceGroupCustomization vnfcInstanceGroupCust = new VnfcInstanceGroupCustomization();
1244                 vnfcInstanceGroupCust.setModelUUID("modelUUID");
1245                 vnfcInstanceGroupCust.setFunction("function");
1246                 vnfcInstanceGroupCust.setDescription("description");
1247                 vnfcInstanceGroups.add(vnfcInstanceGroupCust);
1248                 org.onap.so.db.catalog.beans.InstanceGroup instanceGroup = new org.onap.so.db.catalog.beans.InstanceGroup();
1249                 instanceGroup.setModelUUID("modelUUID");
1250                 ModelInfoInstanceGroup modelInfoInstanceGroup = new ModelInfoInstanceGroup();
1251                 modelInfoInstanceGroup.setModelUUID("modelUUID");
1252                 doReturn(vnfResourceCust).when(SPY_bbInputSetup).getVnfResourceCustomizationFromService(modelInfo, service);
1253                 doReturn(vnfcInstanceGroups).when(vnfResourceCust).getVnfcInstanceGroupCustomizations();
1254                 doReturn(instanceGroup).when(SPY_bbInputSetupUtils).getCatalogInstanceGroup("modelUUID");
1255                 doReturn(modelInfoInstanceGroup).when(bbInputSetupMapperLayer).mapCatalogInstanceGroupToInstanceGroup(null, instanceGroup);
1256
1257                 SPY_bbInputSetup.mapVnfcCollectionInstanceGroup(genericVnf, modelInfo, service);
1258
1259                 assertEquals("Instance Group was created", true, genericVnf.getInstanceGroups().size() == 1);
1260         }
1261         @Test
1262         public void testPopulateGenericVnfWhereVnfTypeIsNull()
1263                         throws JsonParseException, JsonMappingException, IOException {
1264                 org.onap.so.serviceinstancebeans.Platform platform = new org.onap.so.serviceinstancebeans.Platform();
1265                 org.onap.so.serviceinstancebeans.LineOfBusiness lineOfBusiness = new org.onap.so.serviceinstancebeans.LineOfBusiness();
1266                 String instanceName = "vnfName";
1267                 ModelInfo modelInfo = new ModelInfo();
1268                 modelInfo.setModelType(ModelType.vnf);
1269
1270                 ServiceInstance serviceInstance = new ServiceInstance();
1271                 GenericVnf vnf = new GenericVnf();
1272                 vnf.setVnfId("genericVnfId");
1273                 vnf.setVnfName("vnfName");
1274                 serviceInstance.getVnfs().add(vnf);
1275                 String vnfType = null;
1276                 RequestDetails requestDetails = mapper.readValue(new File(RESOURCE_PATH + "RequestDetails_CreateVnf.json"),
1277                                 RequestDetails.class);
1278
1279                 Service service = mapper.readValue(
1280                                 new File(RESOURCE_PATH + "CatalogDBService_getServiceInstanceNOAAIInput.json"), Service.class);
1281                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
1282                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, "genericVnfId");
1283                 String bbName = AssignFlows.VNF.toString();
1284
1285                 Platform expectedPlatform = new Platform();
1286                 LineOfBusiness expectedLineOfBusiness = new LineOfBusiness();
1287                 String resourceId = "123";
1288                 doReturn(expectedPlatform).when(bbInputSetupMapperLayer).mapRequestPlatform(platform);
1289                 doReturn(expectedLineOfBusiness).when(bbInputSetupMapperLayer).mapRequestLineOfBusiness(lineOfBusiness);
1290                 org.onap.aai.domain.yang.GenericVnf vnfAAI = new org.onap.aai.domain.yang.GenericVnf();
1291                 vnfAAI.setModelCustomizationId("modelCustId");
1292                 doReturn(vnfAAI).when(SPY_bbInputSetupUtils).getAAIGenericVnf(vnf.getVnfId());
1293                 doNothing().when(SPY_bbInputSetup).mapCatalogVnf(vnf, modelInfo, service);
1294                 org.onap.aai.domain.yang.InstanceGroup instanceGroupAAI = new org.onap.aai.domain.yang.InstanceGroup();
1295                 doReturn(instanceGroupAAI).when(SPY_bbInputSetupUtils).getAAIInstanceGroup(any());
1296                 org.onap.so.db.catalog.beans.InstanceGroup catalogInstanceGroup = new org.onap.so.db.catalog.beans.InstanceGroup();
1297                 doReturn(catalogInstanceGroup).when(SPY_bbInputSetupUtils).getCatalogInstanceGroup(any());
1298
1299                 SPY_bbInputSetup.populateGenericVnf(modelInfo, instanceName, platform, lineOfBusiness, service, bbName,
1300                                 serviceInstance, lookupKeyMap, requestDetails.getRelatedInstanceList(), resourceId, vnfType, null);
1301
1302                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, null);
1303
1304                 SPY_bbInputSetup.populateGenericVnf(modelInfo, instanceName, platform, lineOfBusiness, service, bbName,
1305                                 serviceInstance, lookupKeyMap, requestDetails.getRelatedInstanceList(), resourceId, vnfType, null);
1306                 verify(SPY_bbInputSetup, times(1)).mapCatalogVnf(vnf, modelInfo, service);
1307
1308                 instanceName = "vnfName2";
1309                 GenericVnf vnf2 = SPY_bbInputSetup.createGenericVnf(lookupKeyMap, instanceName, platform, lineOfBusiness,
1310                                 resourceId, vnfType, null);
1311
1312                 org.onap.aai.domain.yang.GenericVnf vnf2AAI = new org.onap.aai.domain.yang.GenericVnf();
1313                 vnfAAI.setModelCustomizationId("modelCustId2");
1314                 doReturn(vnf2AAI).when(SPY_bbInputSetupUtils).getAAIGenericVnf(vnf2.getVnfId());
1315                 doNothing().when(SPY_bbInputSetup).mapCatalogVnf(vnf2, modelInfo, service);
1316                 doNothing().when(SPY_bbInputSetup).mapNetworkCollectionInstanceGroup(vnf2, "{instanceGroupId}");
1317                 doNothing().when(SPY_bbInputSetup).mapVnfcCollectionInstanceGroup(vnf2, modelInfo, service);
1318                 SPY_bbInputSetup.populateGenericVnf(modelInfo, instanceName, platform, lineOfBusiness, service, bbName,
1319                                 serviceInstance, lookupKeyMap, requestDetails.getRelatedInstanceList(), resourceId, vnfType, null);
1320                 verify(SPY_bbInputSetup, times(2)).mapCatalogVnf(vnf2, modelInfo, service);
1321                 verify(SPY_bbInputSetup, times(2)).mapNetworkCollectionInstanceGroup(vnf2, "{instanceGroupId}");
1322                 verify(SPY_bbInputSetup, times(2)).mapVnfcCollectionInstanceGroup(vnf2, modelInfo, service);
1323         }
1324
1325         @Test
1326         public void testMapCatalogVnf() {
1327                 ModelInfoGenericVnf modelInfoGenericVnf = new ModelInfoGenericVnf();
1328                 GenericVnf genericVnf = new GenericVnf();
1329                 RequestDetails requestDetails = new RequestDetails();
1330                 ModelInfo modelInfo = new ModelInfo();
1331                 modelInfo.setModelCustomizationUuid("modelCustomizationUUID");
1332                 requestDetails.setModelInfo(modelInfo);
1333                 Service service = new Service();
1334                 VnfResourceCustomization resourceCust = new VnfResourceCustomization();
1335                 resourceCust.setModelCustomizationUUID("vnfModelCustomizationUUID");
1336                 service.getVnfCustomizations().add(resourceCust);
1337                 resourceCust.setModelCustomizationUUID("modelCustomizationUUID");
1338
1339                 doReturn(modelInfoGenericVnf).when(bbInputSetupMapperLayer).mapCatalogVnfToVnf(resourceCust);
1340
1341                 SPY_bbInputSetup.mapCatalogVnf(genericVnf, modelInfo, service);
1342
1343                 assertEquals(modelInfoGenericVnf, genericVnf.getModelInfoGenericVnf());
1344         }
1345
1346         @Test
1347         public void testMapCatalogCollectionAndInstanceGroup() {
1348                 ModelInfoCollection modelInfoCollection = new ModelInfoCollection();
1349                 modelInfoCollection.setCollectionFunction("collectionFunction");
1350                 modelInfoCollection.setCollectionRole("collectionRole");
1351                 modelInfoCollection.setCollectionType("collectionType");
1352                 modelInfoCollection.setDescription("description");
1353                 modelInfoCollection.setModelInvariantUUID("modelInvariantUUID");
1354                 modelInfoCollection.setQuantity(0);
1355
1356                 ModelInfoInstanceGroup modelInfoInstanceGroup = new ModelInfoInstanceGroup();
1357                 modelInfoInstanceGroup.setFunction("function");
1358                 modelInfoInstanceGroup.setInstanceGroupRole("instanceGroupRole");
1359                 modelInfoInstanceGroup.setModelInvariantUUID("modelInvariantUUID");
1360                 modelInfoInstanceGroup.setModelUUID("modelUUID");
1361                 modelInfoInstanceGroup.setType("VNFC");
1362                 modelInfoInstanceGroup.setDescription("description");
1363
1364                 InstanceGroup instanceGroup = new InstanceGroup();
1365                 Collection collection = new Collection();
1366                 collection.setInstanceGroup(instanceGroup);
1367
1368                 CollectionResource collectionResource = new CollectionResource();
1369                 org.onap.so.db.catalog.beans.InstanceGroup catalogInstanceGroup = new org.onap.so.db.catalog.beans.InstanceGroup();
1370                 collectionResource.setToscaNodeType("NetworkCollection");
1371                 collectionResource.setInstanceGroup(catalogInstanceGroup);
1372
1373                 CollectionResourceCustomization collectionCust = new NetworkCollectionResourceCustomization();
1374                 collectionCust.setModelCustomizationUUID("modelCustomizationUUID");
1375                 collectionCust.setCollectionResource(collectionResource);
1376
1377                 Service service = new Service();
1378                 service.getCollectionResourceCustomizations().add(collectionCust);
1379                 ServiceInstance serviceInstance = new ServiceInstance();
1380                 serviceInstance.setCollection(collection);
1381
1382                 List<CollectionResourceInstanceGroupCustomization> instanceGroupCustList = new ArrayList<>();
1383                 CollectionResourceInstanceGroupCustomization instanceGroupCust = new CollectionResourceInstanceGroupCustomization();
1384                 instanceGroupCust.setFunction("function");
1385                 instanceGroupCust.setDescription("description");
1386
1387                 doReturn(modelInfoCollection).when(bbInputSetupMapperLayer).mapCatalogCollectionToCollection(collectionCust,
1388                                 collectionResource);
1389
1390                 doReturn(modelInfoInstanceGroup).when(bbInputSetupMapperLayer).mapCatalogInstanceGroupToInstanceGroup(collectionCust,
1391                                 catalogInstanceGroup);
1392
1393                 SPY_bbInputSetup.mapCatalogCollection(service, serviceInstance.getCollection(), "modelCustomizationUUID");
1394                 SPY_bbInputSetup.mapCatalogNetworkCollectionInstanceGroup(service,
1395                                 serviceInstance.getCollection().getInstanceGroup(), collectionCust.getModelCustomizationUUID());
1396
1397                 assertThat(collection.getModelInfoCollection(), sameBeanAs(modelInfoCollection));
1398                 assertThat(instanceGroup.getModelInfoInstanceGroup(), sameBeanAs(modelInfoInstanceGroup));
1399         }
1400
1401         @Test
1402         public void testAddRelationshipsToSI() throws Exception {
1403                 ServiceInstance serviceInstance = new ServiceInstance();
1404                 org.onap.aai.domain.yang.ServiceInstance serviceInstanceAAI = new org.onap.aai.domain.yang.ServiceInstance();
1405                 serviceInstanceAAI.setServiceInstanceId("serviceInstanceId");
1406
1407                 org.onap.aai.domain.yang.RelationshipList relationshipList = new org.onap.aai.domain.yang.RelationshipList();
1408                 org.onap.aai.domain.yang.Relationship relationship = new org.onap.aai.domain.yang.Relationship();
1409                 relationshipList.getRelationship().add(relationship);
1410                 serviceInstanceAAI.setRelationshipList(relationshipList);
1411
1412                 Map<String, String> uriKeys = new HashMap<>();
1413                 uriKeys.put("global-customer-id", "globalCustomerId");
1414                 uriKeys.put("service-type", "serviceType");
1415
1416
1417                 doNothing().when(SPY_bbInputSetup).mapProject(any(), eq(serviceInstance));
1418                 doNothing().when(SPY_bbInputSetup).mapOwningEntity(any(), eq(serviceInstance));
1419                 doNothing().when(SPY_bbInputSetup).mapL3Networks(any(), eq(serviceInstance.getNetworks()));
1420                 doNothing().when(SPY_bbInputSetup).mapGenericVnfs(any(), eq(serviceInstance.getVnfs()));
1421                 doNothing().when(SPY_bbInputSetup).mapCollection(any(), eq(serviceInstance));
1422
1423                 SPY_bbInputSetup.addRelationshipsToSI(serviceInstanceAAI, serviceInstance);
1424
1425                 verify(SPY_bbInputSetup, times(1)).mapProject(any(), eq(serviceInstance));
1426                 verify(SPY_bbInputSetup, times(1)).mapOwningEntity(any(), eq(serviceInstance));
1427                 verify(SPY_bbInputSetup, times(1)).mapL3Networks(any(), eq(serviceInstance.getNetworks()));
1428                 verify(SPY_bbInputSetup, times(1)).mapGenericVnfs(any(), eq(serviceInstance.getVnfs()));
1429                 verify(SPY_bbInputSetup, times(1)).mapCollection(any(), eq(serviceInstance));
1430                 verify(SPY_bbInputSetup, times(1)).mapConfigurations(any(), eq(serviceInstance.getConfigurations()));
1431         }
1432
1433         @Test
1434         public void testMapConfigurations() throws JsonProcessingException {
1435                 org.onap.aai.domain.yang.Configuration expectedAAI = new org.onap.aai.domain.yang.Configuration();
1436                 org.onap.aai.domain.yang.RelationshipList relationshipList = new org.onap.aai.domain.yang.RelationshipList();
1437                 org.onap.aai.domain.yang.Relationship relationship = new org.onap.aai.domain.yang.Relationship();
1438                 relationshipList.getRelationship().add(relationship);
1439                 expectedAAI.setRelationshipList(relationshipList);
1440
1441                 Configuration expected = new Configuration();
1442                 AAIResourceUri aaiResourceUri = AAIUriFactory.createResourceUri(AAIObjectType.CONFIGURATION, "configurationId");
1443                 AAIResultWrapper configurationWrapper = new AAIResultWrapper(
1444                                 new AAICommonObjectMapperProvider().getMapper().writeValueAsString(expectedAAI));
1445
1446                 doReturn(configurationWrapper).when(SPY_bbInputSetupUtils).getAAIResourceDepthOne(aaiResourceUri);
1447                 doReturn(expected).when(bbInputSetupMapperLayer)
1448                                 .mapAAIConfiguration(isA(org.onap.aai.domain.yang.Configuration.class));
1449
1450                 List<Configuration> configurations = new ArrayList<>();
1451
1452                 SPY_bbInputSetup.mapConfigurations(Arrays.asList(new AAIResourceUri[] { aaiResourceUri }), configurations);
1453
1454                 assertEquals(expected, configurations.get(0));
1455         }
1456
1457         @Test
1458         public void testMapGenericVnfs() throws JsonProcessingException {
1459                 org.onap.aai.domain.yang.GenericVnf expectedAAI = new org.onap.aai.domain.yang.GenericVnf();
1460                 org.onap.aai.domain.yang.RelationshipList relationshipList = new org.onap.aai.domain.yang.RelationshipList();
1461                 org.onap.aai.domain.yang.Relationship relationship = new org.onap.aai.domain.yang.Relationship();
1462                 relationshipList.getRelationship().add(relationship);
1463                 expectedAAI.setRelationshipList(relationshipList);
1464
1465                 GenericVnf expected = new GenericVnf();
1466                 AAIResourceUri aaiResourceUri = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, "vnfId");
1467                 AAIResultWrapper vnfWrapper = new AAIResultWrapper(
1468                                 new AAICommonObjectMapperProvider().getMapper().writeValueAsString(expectedAAI));
1469
1470                 doReturn(vnfWrapper).when(SPY_bbInputSetupUtils).getAAIResourceDepthOne(aaiResourceUri);
1471                 doReturn(expected).when(bbInputSetupMapperLayer)
1472                                 .mapAAIGenericVnfIntoGenericVnf(isA(org.onap.aai.domain.yang.GenericVnf.class));
1473                 doNothing().when(SPY_bbInputSetup).mapPlatform(any(), eq(expected));
1474                 doNothing().when(SPY_bbInputSetup).mapLineOfBusiness(any(), eq(expected));
1475                 doReturn(new ArrayList<>()).when(SPY_bbInputSetup).mapVolumeGroups(any());
1476
1477                 List<GenericVnf> genericVnfs = new ArrayList<>();
1478
1479                 SPY_bbInputSetup.mapGenericVnfs(Arrays.asList(new AAIResourceUri[] { aaiResourceUri }), genericVnfs);
1480
1481                 assertEquals(expected, genericVnfs.get(0));
1482                 verify(SPY_bbInputSetup, times(1)).mapPlatform(any(), eq(expected));
1483                 verify(SPY_bbInputSetup, times(1)).mapLineOfBusiness(any(), eq(expected));
1484                 verify(SPY_bbInputSetup, times(1)).mapVolumeGroups(any());
1485         }
1486
1487         @Test
1488         public void testMapVolumeGroups() throws JsonProcessingException {
1489                 org.onap.aai.domain.yang.VolumeGroup expectedAAI = new org.onap.aai.domain.yang.VolumeGroup();
1490
1491                 VolumeGroup expected = new VolumeGroup();
1492                 AAIResultWrapper vnfWrapper = new AAIResultWrapper(
1493                                 new AAICommonObjectMapperProvider().getMapper().writeValueAsString(expectedAAI));
1494
1495                 doReturn(expected).when(bbInputSetupMapperLayer)
1496                                 .mapAAIVolumeGroup(isA(org.onap.aai.domain.yang.VolumeGroup.class));
1497
1498                  List<VolumeGroup> volumeGroupsList =
1499                                  SPY_bbInputSetup.mapVolumeGroups(Arrays.asList(new AAIResultWrapper[] { vnfWrapper }));
1500
1501                 assertEquals(expected, volumeGroupsList.get(0));
1502         }
1503
1504         @Test
1505         public void testMapLineOfBusiness() throws JsonProcessingException {
1506                 org.onap.aai.domain.yang.LineOfBusiness expectedAAI = new org.onap.aai.domain.yang.LineOfBusiness();
1507
1508                 LineOfBusiness expected = new LineOfBusiness();
1509                 AAIResultWrapper vnfWrapper = new AAIResultWrapper(
1510                                 new AAICommonObjectMapperProvider().getMapper().writeValueAsString(expectedAAI));
1511
1512                 doReturn(expected).when(bbInputSetupMapperLayer)
1513                                 .mapAAILineOfBusiness(isA(org.onap.aai.domain.yang.LineOfBusiness.class));
1514
1515                 GenericVnf vnf = new GenericVnf();
1516
1517                 SPY_bbInputSetup.mapLineOfBusiness(Arrays.asList(new AAIResultWrapper[] { vnfWrapper }), vnf);
1518
1519                 assertEquals(expected, vnf.getLineOfBusiness());
1520         }
1521
1522         @Test
1523         public void testMapPlatform() throws JsonProcessingException {
1524                 org.onap.aai.domain.yang.Platform expectedAAI = new org.onap.aai.domain.yang.Platform();
1525
1526                 Platform expected = new Platform();
1527                 AAIResultWrapper vnfWrapper = new AAIResultWrapper(
1528                                 new AAICommonObjectMapperProvider().getMapper().writeValueAsString(expectedAAI));
1529
1530                 doReturn(expected).when(bbInputSetupMapperLayer)
1531                                 .mapAAIPlatform(isA(org.onap.aai.domain.yang.Platform.class));
1532
1533                 GenericVnf vnf = new GenericVnf();
1534
1535                 SPY_bbInputSetup.mapPlatform(Arrays.asList(new AAIResultWrapper[] { vnfWrapper }), vnf);
1536
1537                 assertEquals(expected, vnf.getPlatform());
1538         }
1539
1540         @Test
1541         public void testMapCollection() throws JsonProcessingException {
1542                 List<AAIResultWrapper> collections = new ArrayList<>();
1543                 ServiceInstance serviceInstance = new ServiceInstance();
1544
1545                 org.onap.aai.domain.yang.Collection aaiCollection = new org.onap.aai.domain.yang.Collection();
1546                 org.onap.aai.domain.yang.RelationshipList collectionRelationshipList = new org.onap.aai.domain.yang.RelationshipList();
1547                 org.onap.aai.domain.yang.Relationship collectionInstanceGroupRelationship = new org.onap.aai.domain.yang.Relationship();
1548                 collectionRelationshipList.getRelationship().add(collectionInstanceGroupRelationship);
1549                 aaiCollection.setRelationshipList(collectionRelationshipList);
1550
1551                 collections.add(new AAIResultWrapper(
1552                                 new AAICommonObjectMapperProvider().getMapper().writeValueAsString(aaiCollection)));
1553
1554                 Collection collection = new Collection();
1555                 ModelInfoCollection modelInfoCollection = new ModelInfoCollection();
1556                 List<InstanceGroup> instanceGroupsList = new ArrayList<>();
1557                 InstanceGroup instanceGroup = new InstanceGroup();
1558                 instanceGroupsList.add(instanceGroup);
1559                 NetworkCollectionResourceCustomization networkCollectionCust = Mockito.mock(NetworkCollectionResourceCustomization.class);
1560                 CollectionResource collectionResource = new CollectionResource();
1561                 doReturn(collection).when(bbInputSetupMapperLayer)
1562                                 .mapAAICollectionIntoCollection(isA(org.onap.aai.domain.yang.Collection.class));
1563                 doReturn(instanceGroupsList).when(SPY_bbInputSetup).mapInstanceGroups(any());
1564                 doReturn(networkCollectionCust).when(SPY_bbInputSetupUtils).getCatalogNetworkCollectionResourceCustByID(aaiCollection.getCollectionCustomizationId());
1565                 doReturn(collectionResource).when(networkCollectionCust).getCollectionResource();
1566                 doReturn(modelInfoCollection).when(bbInputSetupMapperLayer).mapCatalogCollectionToCollection(networkCollectionCust, collectionResource);
1567
1568                 SPY_bbInputSetup.mapCollection(collections, serviceInstance);
1569
1570                 assertEquals(collection, serviceInstance.getCollection());
1571                 assertEquals(instanceGroup, collection.getInstanceGroup());
1572
1573                 instanceGroupsList.clear();
1574                 collection = new Collection();
1575
1576                 SPY_bbInputSetup.mapCollection(collections, serviceInstance);
1577                 assertEquals(collection, serviceInstance.getCollection());
1578                 assertNull(collection.getInstanceGroup());
1579         }
1580
1581         @Test
1582         public void testMapL3Networks() throws JsonProcessingException {
1583                 org.onap.aai.domain.yang.L3Network expectedAAI = new org.onap.aai.domain.yang.L3Network();
1584                 org.onap.aai.domain.yang.RelationshipList relationshipList = new org.onap.aai.domain.yang.RelationshipList();
1585                 org.onap.aai.domain.yang.Relationship relationship = new org.onap.aai.domain.yang.Relationship();
1586                 relationshipList.getRelationship().add(relationship);
1587                 expectedAAI.setRelationshipList(relationshipList);
1588
1589                 L3Network expected = new L3Network();
1590                 List<L3Network> l3Networks = new ArrayList<>();
1591                 AAIResultWrapper l3NetworksWrapper = new AAIResultWrapper(
1592                                 new AAICommonObjectMapperProvider().getMapper().writeValueAsString(expectedAAI));
1593                 AAIResourceUri aaiResourceUri = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, "networkId");
1594
1595                 doReturn(l3NetworksWrapper).when(SPY_bbInputSetupUtils).getAAIResourceDepthTwo(aaiResourceUri);
1596                 doReturn(expected).when(bbInputSetupMapperLayer)
1597                                 .mapAAIL3Network(isA(org.onap.aai.domain.yang.L3Network.class));
1598                 doNothing().when(SPY_bbInputSetup).mapNetworkPolicies(any(), eq(expected.getNetworkPolicies()));
1599                 doNothing().when(SPY_bbInputSetup).mapRouteTableReferences(any(),
1600                                 eq(expected.getContrailNetworkRouteTableReferences()));
1601
1602                 SPY_bbInputSetup.mapL3Networks(Arrays.asList(new AAIResourceUri[] { aaiResourceUri }), l3Networks);
1603
1604                 assertEquals(expected, l3Networks.get(0));
1605                 verify(SPY_bbInputSetup, times(1)).mapNetworkPolicies(any(), eq(expected.getNetworkPolicies()));
1606                 verify(SPY_bbInputSetup, times(1)).mapRouteTableReferences(any(),
1607                                 eq(expected.getContrailNetworkRouteTableReferences()));
1608         }
1609
1610         @Test
1611         public void testMapRouteTableReferences() throws JsonProcessingException {
1612                 org.onap.aai.domain.yang.RouteTableReference expectedAAI = new org.onap.aai.domain.yang.RouteTableReference();
1613
1614                 RouteTableReference expected = new RouteTableReference();
1615                 List<RouteTableReference> contrailNetworkRouteTableReferences = new ArrayList<>();
1616                 AAIResultWrapper vnfWrapper = new AAIResultWrapper(
1617                                 new AAICommonObjectMapperProvider().getMapper().writeValueAsString(expectedAAI));
1618
1619                 doReturn(expected).when(bbInputSetupMapperLayer).mapAAIRouteTableReferenceIntoRouteTableReference(
1620                                 isA(org.onap.aai.domain.yang.RouteTableReference.class));
1621
1622                 SPY_bbInputSetup.mapRouteTableReferences(Arrays.asList(new AAIResultWrapper[] { vnfWrapper }),
1623                                 contrailNetworkRouteTableReferences);
1624
1625                 assertEquals(expected, contrailNetworkRouteTableReferences.get(0));
1626         }
1627
1628         @Test
1629         public void testMapOwningEntity() throws JsonProcessingException {
1630                 org.onap.aai.domain.yang.OwningEntity expectedAAI = new org.onap.aai.domain.yang.OwningEntity();
1631
1632                 OwningEntity expected = new OwningEntity();
1633                 AAIResultWrapper vnfWrapper = new AAIResultWrapper(
1634                                 new AAICommonObjectMapperProvider().getMapper().writeValueAsString(expectedAAI));
1635
1636                 doReturn(expected).when(bbInputSetupMapperLayer)
1637                                 .mapAAIOwningEntity(isA(org.onap.aai.domain.yang.OwningEntity.class));
1638
1639                 ServiceInstance serviceInstance = new ServiceInstance();
1640
1641                 SPY_bbInputSetup.mapOwningEntity(Arrays.asList(new AAIResultWrapper[] { vnfWrapper }), serviceInstance);
1642
1643                 assertEquals(expected, serviceInstance.getOwningEntity());
1644         }
1645
1646         @Test
1647         public void testMapProject() throws JsonProcessingException {
1648                 org.onap.aai.domain.yang.Project expectedAAI = new org.onap.aai.domain.yang.Project();
1649
1650                 Project expected = new Project();
1651                 AAIResultWrapper vnfWrapper = new AAIResultWrapper(
1652                                 new AAICommonObjectMapperProvider().getMapper().writeValueAsString(expectedAAI));
1653
1654                 doReturn(expected).when(bbInputSetupMapperLayer).mapAAIProject(isA(org.onap.aai.domain.yang.Project.class));
1655
1656                 ServiceInstance serviceInstance = new ServiceInstance();
1657
1658                 SPY_bbInputSetup.mapProject(Arrays.asList(new AAIResultWrapper[] { vnfWrapper }), serviceInstance);
1659
1660                 assertEquals(expected, serviceInstance.getProject());
1661         }
1662
1663         @Test
1664         public void testMapCustomer() throws Exception {
1665                 org.onap.aai.domain.yang.Customer customerAAI = new org.onap.aai.domain.yang.Customer();
1666                 org.onap.aai.domain.yang.ServiceSubscription serviceSubscriptionAAI = new org.onap.aai.domain.yang.ServiceSubscription();
1667
1668                 Customer expected = new Customer();
1669                 ServiceSubscription serviceSubscription = new ServiceSubscription();
1670
1671                 String globalCustomerId = "globalCustomerId";
1672                 String subscriptionServiceType = "subscriptionServiceType";
1673
1674                 doReturn(customerAAI).when(SPY_bbInputSetupUtils).getAAICustomer(globalCustomerId);
1675                 doReturn(serviceSubscriptionAAI).when(SPY_bbInputSetupUtils).getAAIServiceSubscription(globalCustomerId,
1676                                 subscriptionServiceType);
1677                 doReturn(expected).when(bbInputSetupMapperLayer)
1678                                 .mapAAICustomer(isA(org.onap.aai.domain.yang.Customer.class));
1679                 doReturn(serviceSubscription).when(bbInputSetupMapperLayer)
1680                                 .mapAAIServiceSubscription(isA(org.onap.aai.domain.yang.ServiceSubscription.class));
1681
1682                 Customer actual = SPY_bbInputSetup.mapCustomer(globalCustomerId, subscriptionServiceType);
1683
1684                 assertEquals(expected, actual);
1685                 assertEquals(serviceSubscription, expected.getServiceSubscription());
1686         }
1687
1688         @Test
1689         public void testPopulateLookupKeyMapWithIds() {
1690                 Map<ResourceKey, String> expected = new HashMap<>();
1691                 Map<ResourceKey, String> actual = new HashMap<>();
1692                 String serviceInstanceId = "serviceInstanceId";
1693                 String networkId = "networkId";
1694                 String vnfId = "vnfId";
1695                 String vfModuleId = "vfModuleId";
1696                 String volumeGroupId = "volumeGroupId";
1697                 String configurationId = "configurationId";
1698
1699                 expected.put(ResourceKey.SERVICE_INSTANCE_ID, serviceInstanceId);
1700                 expected.put(ResourceKey.NETWORK_ID, networkId);
1701                 expected.put(ResourceKey.GENERIC_VNF_ID, vnfId);
1702                 expected.put(ResourceKey.VF_MODULE_ID, vfModuleId);
1703                 expected.put(ResourceKey.VOLUME_GROUP_ID, volumeGroupId);
1704                 expected.put(ResourceKey.CONFIGURATION_ID, configurationId);
1705
1706                 WorkflowResourceIds workflowResourceIds = new WorkflowResourceIds();
1707                 workflowResourceIds.setServiceInstanceId(serviceInstanceId);
1708                 workflowResourceIds.setNetworkId(networkId);
1709                 workflowResourceIds.setVnfId(vnfId);
1710                 workflowResourceIds.setVfModuleId(vfModuleId);
1711                 workflowResourceIds.setVolumeGroupId(volumeGroupId);
1712                 workflowResourceIds.setConfigurationId(configurationId);
1713
1714                 SPY_bbInputSetup.populateLookupKeyMapWithIds(workflowResourceIds, actual);
1715
1716                 assertThat(actual, sameBeanAs(expected));
1717         }
1718
1719         @Test
1720         public void testgetGBBMacro() throws Exception {
1721                 GeneralBuildingBlock gBB = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
1722                                 GeneralBuildingBlock.class);
1723                 ExecuteBuildingBlock executeBB = mapper.readValue(new File(RESOURCE_PATH + "ExecuteBuildingBlockSimple.json"),
1724                                 ExecuteBuildingBlock.class);
1725                 RequestDetails requestDetails = mapper
1726                                 .readValue(new File(RESOURCE_PATH + "RequestDetailsInput_serviceMacro.json"), RequestDetails.class);
1727                 InfraActiveRequests request = Mockito.mock(InfraActiveRequests.class);
1728                 org.onap.aai.domain.yang.GenericVnf aaiVnf = new org.onap.aai.domain.yang.GenericVnf();
1729                 aaiVnf.setModelCustomizationId("modelCustId");
1730                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
1731                 lookupKeyMap.put(ResourceKey.NETWORK_ID, "networkId");
1732                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, "vnfId");
1733                 lookupKeyMap.put(ResourceKey.VF_MODULE_ID, "vfModuleId");
1734                 lookupKeyMap.put(ResourceKey.VOLUME_GROUP_ID, "volumeGroupId");
1735                 lookupKeyMap.put(ResourceKey.SERVICE_INSTANCE_ID, "serviceInstanceId");
1736                 lookupKeyMap.put(ResourceKey.CONFIGURATION_ID, "configurationId");
1737                 String resourceId = "123";
1738                 String vnfType = "vnfType";
1739                 Service service = Mockito.mock(Service.class);
1740                 String requestAction = "createInstance";
1741
1742                 ConfigurationResourceKeys configResourceKeys = new ConfigurationResourceKeys();
1743                 configResourceKeys.setCvnfcCustomizationUUID("cvnfcCustomizationUUID");
1744                 configResourceKeys.setVfModuleCustomizationUUID("vfModuleCustomizationUUID");
1745                 configResourceKeys.setVnfResourceCustomizationUUID("vnfResourceCustomizationUUID");
1746                 executeBB.setConfigurationResourceKeys(configResourceKeys);
1747                 doReturn(gBB).when(SPY_bbInputSetup).getGBBALaCarteService(executeBB, requestDetails, lookupKeyMap,
1748                                 requestAction, resourceId);
1749                 doReturn(request).when(SPY_bbInputSetupUtils).getInfraActiveRequest(executeBB.getRequestId());
1750                 doReturn(service).when(SPY_bbInputSetupUtils)
1751                                 .getCatalogServiceByModelUUID(gBB.getServiceInstance().getModelInfoServiceInstance().getModelUuid());
1752                 doNothing().when(SPY_bbInputSetupUtils).updateInfraActiveRequestVnfId(request,
1753                                 lookupKeyMap.get(ResourceKey.GENERIC_VNF_ID));
1754                 doReturn("vnfId").when(SPY_bbInputSetup).getVnfId(executeBB, lookupKeyMap);
1755                 doReturn(aaiVnf).when(SPY_bbInputSetupUtils).getAAIGenericVnf(any(String.class));
1756
1757                 executeBB.getBuildingBlock().setBpmnFlowName(AssignFlows.NETWORK_MACRO.toString());
1758                 executeBB.getBuildingBlock().setKey("ab153b6e-c364-44c0-bef6-1f2982117f04");
1759                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
1760                 verify(SPY_bbInputSetup, times(1)).populateL3Network(any(String.class), isA(ModelInfo.class),
1761                                 isA(Service.class), any(String.class), isA(ServiceInstance.class), any(), any(String.class), any());
1762
1763                 executeBB.getBuildingBlock().setKey("ab153b6e-c364-44c0-bef6-1f2982117f04");
1764                 executeBB.getBuildingBlock().setBpmnFlowName(AssignFlows.VNF.toString());
1765                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
1766                 verify(SPY_bbInputSetup, times(1)).populateGenericVnf(isA(ModelInfo.class), any(String.class),
1767                                 isA(org.onap.so.serviceinstancebeans.Platform.class),
1768                                 isA(org.onap.so.serviceinstancebeans.LineOfBusiness.class), isA(Service.class), any(String.class),
1769                                 isA(ServiceInstance.class), any(), any(), any(String.class), any(String.class), any());
1770
1771                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, null);
1772                 executeBB.getBuildingBlock().setBpmnFlowName(AssignFlows.VF_MODULE.toString());
1773                 executeBB.getBuildingBlock().setKey("a25e8e8c-58b8-4eec-810c-97dcc1f5cb7f");
1774                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
1775                 verify(SPY_bbInputSetup, times(1)).populateVfModule(isA(ModelInfo.class), isA(Service.class), any(String.class),
1776                                 isA(ServiceInstance.class), any(), any(String.class), any(), any(String.class), any(), isA(CloudConfiguration.class));
1777
1778                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, null);
1779                 executeBB.getBuildingBlock().setBpmnFlowName(AssignFlows.VOLUME_GROUP.toString());
1780                 executeBB.getBuildingBlock().setKey("72d9d1cd-f46d-447a-abdb-451d6fb05fa8");
1781                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
1782                 verify(SPY_bbInputSetup, times(1)).populateVolumeGroup(isA(ModelInfo.class), isA(Service.class),
1783                                 any(String.class), isA(ServiceInstance.class), any(), any(String.class),ArgumentMatchers.isNull(),ArgumentMatchers.isNull(),
1784                                 any(String.class), any());
1785
1786                 Configuration configuration = new Configuration();
1787                 configuration.setConfigurationId("configurationId");
1788                 gBB.getServiceInstance().getConfigurations().add(configuration);
1789                 List<ConfigurationResourceCustomization> configurationCustList = new ArrayList<>();
1790                 ConfigurationResourceCustomization configurationCust = new ConfigurationResourceCustomization();
1791                 configurationCust.setModelCustomizationUUID("72d9d1cd-f46d-447a-abdb-451d6fb05fa9");
1792                 doReturn(configurationCustList).when(service).getConfigurationCustomizations();
1793                 configurationCustList.add(configurationCust);
1794                 doNothing().when(SPY_bbInputSetup).populateConfiguration(isA(ModelInfo.class), isA(Service.class),
1795                                 any(String.class), isA(ServiceInstance.class), any(), any(String.class), ArgumentMatchers.isNull(), isA(ConfigurationResourceKeys.class));
1796
1797                 executeBB.getBuildingBlock().setBpmnFlowName("AssignFabricConfigurationBB");
1798                 executeBB.getBuildingBlock().setKey("72d9d1cd-f46d-447a-abdb-451d6fb05fa9");
1799                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
1800                 verify(SPY_bbInputSetup, times(1)).populateConfiguration(isA(ModelInfo.class), isA(Service.class),
1801                                 any(String.class), isA(ServiceInstance.class), any(), any(String.class),ArgumentMatchers.isNull(), isA(ConfigurationResourceKeys.class));
1802         }
1803
1804         @Test
1805         public void testgetGBBMacroCloudConfiguration() throws Exception {
1806                 org.onap.so.serviceinstancebeans.Service serviceMacro = mapper.readValue(
1807                                 new File(RESOURCE_PATH + "ServiceMacroVfModules.json"), org.onap.so.serviceinstancebeans.Service.class);
1808                 CloudConfiguration cloudConfig = null;
1809                 org.onap.aai.domain.yang.CloudRegion aaiCloudRegion = new org.onap.aai.domain.yang.CloudRegion();
1810                 aaiCloudRegion.setCloudOwner("test-owner-name");
1811                 Resources resources = serviceMacro.getResources();
1812                 doReturn(aaiCloudRegion).when(SPY_bbInputSetupUtils).getCloudRegion(any(CloudConfiguration.class));
1813                 CloudRegion expected = new CloudRegion();
1814                 expected.setLcpCloudRegionId("mdt1");
1815                 expected.setCloudOwner("test-owner-name");
1816                 expected.setTenantId("88a6ca3ee0394ade9403f075db23167e");
1817
1818                 CloudRegion actual = SPY_bbInputSetup.getCloudRegionFromMacroRequest(cloudConfig, resources);
1819                 assertThat(actual, sameBeanAs(expected));
1820
1821                 serviceMacro = mapper.readValue(
1822                                 new File(RESOURCE_PATH + "ServiceMacroVnfs.json"), org.onap.so.serviceinstancebeans.Service.class);
1823                 resources = serviceMacro.getResources();
1824
1825                 actual = SPY_bbInputSetup.getCloudRegionFromMacroRequest(cloudConfig, resources);
1826                 assertThat(actual, sameBeanAs(expected));
1827
1828                 serviceMacro = mapper.readValue(
1829                                 new File(RESOURCE_PATH + "ServiceMacroNetworks.json"), org.onap.so.serviceinstancebeans.Service.class);
1830                 resources = serviceMacro.getResources();
1831
1832                 actual = SPY_bbInputSetup.getCloudRegionFromMacroRequest(cloudConfig, resources);
1833                 assertThat(actual, sameBeanAs(expected));
1834
1835                 serviceMacro = mapper.readValue(
1836                                 new File(RESOURCE_PATH + "ServiceMacroNoCloudConfig.json"), org.onap.so.serviceinstancebeans.Service.class);
1837                 resources = serviceMacro.getResources();
1838
1839                 actual = SPY_bbInputSetup.getCloudRegionFromMacroRequest(cloudConfig, resources);
1840                 assertNull(actual);
1841         }
1842
1843         @Test
1844         public void testgetGBBMacroWithEmptyUserParams() throws Exception {
1845                 GeneralBuildingBlock gBB = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
1846                                 GeneralBuildingBlock.class);
1847                 ExecuteBuildingBlock executeBB = mapper.readValue(new File(RESOURCE_PATH + "ExecuteBuildingBlockSimple.json"),
1848                                 ExecuteBuildingBlock.class);
1849                 RequestDetails requestDetails = mapper
1850                                 .readValue(new File(RESOURCE_PATH + "RequestDetailsInput_serviceMacro.json"), RequestDetails.class);
1851                 requestDetails.getRequestParameters().getUserParams().clear();
1852                 InfraActiveRequests request = Mockito.mock(InfraActiveRequests.class);
1853                 org.onap.aai.domain.yang.GenericVnf aaiVnf = new org.onap.aai.domain.yang.GenericVnf();
1854                 aaiVnf.setModelCustomizationId("modelCustId");
1855                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
1856                 lookupKeyMap.put(ResourceKey.NETWORK_ID, "networkId");
1857                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, "vnfId");
1858                 lookupKeyMap.put(ResourceKey.VF_MODULE_ID, "vfModuleId");
1859                 lookupKeyMap.put(ResourceKey.VOLUME_GROUP_ID, "volumeGroupId");
1860                 lookupKeyMap.put(ResourceKey.SERVICE_INSTANCE_ID, "serviceInstanceId");
1861                 String resourceId = "123";
1862                 String vnfType = "vnfType";
1863                 Service service = Mockito.mock(Service.class);
1864                 String requestAction = "createInstance";
1865                 doReturn(gBB).when(SPY_bbInputSetup).getGBBALaCarteService(executeBB, requestDetails, lookupKeyMap,
1866                                 requestAction, resourceId);
1867                 doReturn(service).when(SPY_bbInputSetupUtils)
1868                                 .getCatalogServiceByModelUUID(gBB.getServiceInstance().getModelInfoServiceInstance().getModelUuid());
1869
1870                 executeBB.getBuildingBlock().setBpmnFlowName(AssignFlows.NETWORK_MACRO.toString());
1871                 executeBB.getBuildingBlock().setKey("ab153b6e-c364-44c0-bef6-1f2982117f04");
1872                 executeBB.getBuildingBlock().setIsVirtualLink(Boolean.FALSE);
1873                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
1874                 verify(SPY_bbInputSetup, times(1)).getGBBMacroNoUserParamsCreate(any(ExecuteBuildingBlock.class), any(),
1875                                 any(String.class), any(String.class), any(GeneralBuildingBlock.class), any(Service.class));
1876         }
1877
1878         @Test(expected = Exception.class)
1879         public void testgetGBBMacroException() throws Exception {
1880                 GeneralBuildingBlock gBB = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
1881                                 GeneralBuildingBlock.class);
1882                 ExecuteBuildingBlock executeBB = mapper.readValue(new File(RESOURCE_PATH + "ExecuteBuildingBlockSimple.json"),
1883                                 ExecuteBuildingBlock.class);
1884                 RequestDetails requestDetails = mapper
1885                                 .readValue(new File(RESOURCE_PATH + "RequestDetailsInput_serviceMacro.json"), RequestDetails.class);
1886                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
1887                 String resourceId = "123";
1888                 String vnfType = "vnfType";
1889                 Service service = Mockito.mock(Service.class);
1890                 String requestAction = "createInstance";
1891                 doReturn(null).when(SPY_bbInputSetup).getGBBALaCarteService(executeBB, requestDetails, lookupKeyMap,
1892                                 requestAction, resourceId);
1893
1894                 executeBB.getBuildingBlock().setBpmnFlowName("Network");
1895                 executeBB.getBuildingBlock().setKey("ab153b6e-c364-44c0-bef6-1f2982117f04");
1896                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
1897         }
1898
1899         @Test
1900         public void testgetGBBMacroWithVnfTypeNull() throws Exception {
1901                 GeneralBuildingBlock gBB = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
1902                                 GeneralBuildingBlock.class);
1903                 ExecuteBuildingBlock executeBB = mapper.readValue(new File(RESOURCE_PATH + "ExecuteBuildingBlockSimple.json"),
1904                                 ExecuteBuildingBlock.class);
1905                 RequestDetails requestDetails = mapper
1906                                 .readValue(new File(RESOURCE_PATH + "RequestDetailsInput_serviceMacro.json"), RequestDetails.class);
1907                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
1908                 lookupKeyMap.put(ResourceKey.NETWORK_ID, "networkId");
1909                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, "vnfId");
1910                 lookupKeyMap.put(ResourceKey.VF_MODULE_ID, "vfModuleId");
1911                 lookupKeyMap.put(ResourceKey.VOLUME_GROUP_ID, "volumeGroupId");
1912                 lookupKeyMap.put(ResourceKey.SERVICE_INSTANCE_ID, "serviceInstanceId");
1913                 org.onap.aai.domain.yang.GenericVnf aaiVnf = new org.onap.aai.domain.yang.GenericVnf();
1914                 aaiVnf.setModelCustomizationId("modelCustId");
1915                 InfraActiveRequests request = Mockito.mock(InfraActiveRequests.class);
1916                 String resourceId = "123";
1917                 String vnfType = null;
1918                 Service service = Mockito.mock(Service.class);
1919                 String requestAction = "createInstance";
1920                 doReturn(gBB).when(SPY_bbInputSetup).getGBBALaCarteService(executeBB, requestDetails, lookupKeyMap,
1921                                 requestAction, resourceId);
1922                 doReturn(request).when(SPY_bbInputSetupUtils).getInfraActiveRequest(executeBB.getRequestId());
1923                 doReturn(service).when(SPY_bbInputSetupUtils)
1924                                 .getCatalogServiceByModelUUID(gBB.getServiceInstance().getModelInfoServiceInstance().getModelUuid());
1925                 doNothing().when(SPY_bbInputSetupUtils).updateInfraActiveRequestVnfId(request,
1926                                 lookupKeyMap.get(ResourceKey.GENERIC_VNF_ID));
1927                 doReturn("vnfId").when(SPY_bbInputSetup).getVnfId(executeBB, lookupKeyMap);
1928                 doReturn(aaiVnf).when(SPY_bbInputSetupUtils).getAAIGenericVnf(any(String.class));
1929
1930                 executeBB.getBuildingBlock().setBpmnFlowName(AssignFlows.NETWORK_MACRO.toString());
1931                 executeBB.getBuildingBlock().setKey("ab153b6e-c364-44c0-bef6-1f2982117f04");
1932                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
1933                 verify(SPY_bbInputSetup, times(1)).populateL3Network(any(String.class), isA(ModelInfo.class),
1934                                 isA(Service.class), any(String.class), isA(ServiceInstance.class), any(), any(String.class), any());
1935
1936                 executeBB.getBuildingBlock().setBpmnFlowName(AssignFlows.VNF.toString());
1937                 executeBB.getBuildingBlock().setKey("ab153b6e-c364-44c0-bef6-1f2982117f04");
1938                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
1939                 verify(SPY_bbInputSetup, times(1)).populateGenericVnf(isA(ModelInfo.class), any(String.class),
1940                                 isA(org.onap.so.serviceinstancebeans.Platform.class),
1941                                 isA(org.onap.so.serviceinstancebeans.LineOfBusiness.class), isA(Service.class), any(String.class),
1942                                 isA(ServiceInstance.class), any(),ArgumentMatchers.isNull(), any(String.class), ArgumentMatchers.isNull(), any());
1943
1944                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, null);
1945                 executeBB.getBuildingBlock().setBpmnFlowName(AssignFlows.VF_MODULE.toString());
1946                 executeBB.getBuildingBlock().setKey("a25e8e8c-58b8-4eec-810c-97dcc1f5cb7f");
1947                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
1948                 verify(SPY_bbInputSetup, times(1)).populateVfModule(isA(ModelInfo.class), isA(Service.class), any(String.class),
1949                                 isA(ServiceInstance.class), any(), any(String.class), any(), any(String.class), any(), isA(CloudConfiguration.class));
1950
1951                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, null);
1952                 executeBB.getBuildingBlock().setBpmnFlowName(AssignFlows.VOLUME_GROUP.toString());
1953                 executeBB.getBuildingBlock().setKey("72d9d1cd-f46d-447a-abdb-451d6fb05fa8");
1954                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
1955                 verify(SPY_bbInputSetup, times(1)).populateVolumeGroup(isA(ModelInfo.class), isA(Service.class),
1956                                 any(String.class), isA(ServiceInstance.class), any(), any(String.class), ArgumentMatchers.isNull(), ArgumentMatchers.isNull(),
1957                                 ArgumentMatchers.isNull(), any());
1958         }
1959
1960         @Test
1961         public void testgetGBBMacroGetServiceWithInvariantId() throws Exception {
1962                 GeneralBuildingBlock gBB = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
1963                                 GeneralBuildingBlock.class);
1964                 ExecuteBuildingBlock executeBB = mapper.readValue(new File(RESOURCE_PATH + "ExecuteBuildingBlockSimple.json"),
1965                                 ExecuteBuildingBlock.class);
1966                 RequestDetails requestDetails = mapper
1967                                 .readValue(new File(RESOURCE_PATH + "RequestDetailsInput_serviceMacro.json"), RequestDetails.class);
1968                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
1969                 lookupKeyMap.put(ResourceKey.NETWORK_ID, "networkId");
1970                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, "vnfId");
1971                 lookupKeyMap.put(ResourceKey.VF_MODULE_ID, "vfModuleId");
1972                 lookupKeyMap.put(ResourceKey.VOLUME_GROUP_ID, "volumeGroupId");
1973                 lookupKeyMap.put(ResourceKey.SERVICE_INSTANCE_ID, "serviceInstanceId");
1974                 org.onap.aai.domain.yang.GenericVnf aaiVnf = new org.onap.aai.domain.yang.GenericVnf();
1975                 aaiVnf.setModelCustomizationId("modelCustId");
1976                 InfraActiveRequests request = Mockito.mock(InfraActiveRequests.class);
1977                 String resourceId = "123";
1978                 String vnfType = "vnfType";
1979                 Service service = Mockito.mock(Service.class);
1980                 String requestAction = "createInstance";
1981                 doReturn(gBB).when(SPY_bbInputSetup).getGBBALaCarteService(executeBB, requestDetails, lookupKeyMap,
1982                                 requestAction, resourceId);
1983                 doReturn(request).when(SPY_bbInputSetupUtils).getInfraActiveRequest(executeBB.getRequestId());
1984                 doReturn(service).when(SPY_bbInputSetupUtils)
1985                                 .getCatalogServiceByModelUUID(gBB.getServiceInstance().getModelInfoServiceInstance().getModelUuid());
1986                 doNothing().when(SPY_bbInputSetupUtils).updateInfraActiveRequestVnfId(request,
1987                                 lookupKeyMap.get(ResourceKey.GENERIC_VNF_ID));
1988                 doReturn("vnfId").when(SPY_bbInputSetup).getVnfId(executeBB, lookupKeyMap);
1989                 doReturn(aaiVnf).when(SPY_bbInputSetupUtils).getAAIGenericVnf(any(String.class));
1990
1991                 executeBB.getBuildingBlock().setBpmnFlowName(AssignFlows.NETWORK_MACRO.toString());
1992                 executeBB.getBuildingBlock().setKey("ab153b6e-c364-44c0-bef6-1f2982117f04");
1993                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
1994                 verify(SPY_bbInputSetup, times(1)).populateL3Network(any(String.class), isA(ModelInfo.class),
1995                                 isA(Service.class), any(String.class), isA(ServiceInstance.class), any(), any(String.class), any());
1996
1997                 executeBB.getBuildingBlock().setBpmnFlowName(AssignFlows.VNF.toString());
1998                 executeBB.getBuildingBlock().setKey("ab153b6e-c364-44c0-bef6-1f2982117f04");
1999                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
2000                 verify(SPY_bbInputSetup, times(1)).populateGenericVnf(isA(ModelInfo.class), any(String.class),
2001                                 isA(org.onap.so.serviceinstancebeans.Platform.class),
2002                                 isA(org.onap.so.serviceinstancebeans.LineOfBusiness.class), isA(Service.class), any(String.class),
2003                                 isA(ServiceInstance.class), any(), any(), any(String.class), any(String.class), any());
2004
2005                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, null);
2006                 executeBB.getBuildingBlock().setBpmnFlowName(AssignFlows.VF_MODULE.toString());
2007                 executeBB.getBuildingBlock().setKey("a25e8e8c-58b8-4eec-810c-97dcc1f5cb7f");
2008                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
2009                 verify(SPY_bbInputSetup, times(1)).populateVfModule(isA(ModelInfo.class), isA(Service.class), any(String.class),
2010                                 isA(ServiceInstance.class), any(), any(String.class), any(), any(String.class), any(), isA(CloudConfiguration.class));
2011
2012                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, null);
2013                 executeBB.getBuildingBlock().setBpmnFlowName(AssignFlows.VOLUME_GROUP.toString());
2014                 executeBB.getBuildingBlock().setKey("72d9d1cd-f46d-447a-abdb-451d6fb05fa8");
2015                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
2016                 verify(SPY_bbInputSetup, times(1)).populateVolumeGroup(isA(ModelInfo.class), isA(Service.class),
2017                                 any(String.class), isA(ServiceInstance.class), any(), any(String.class), ArgumentMatchers.isNull(), ArgumentMatchers.isNull(),
2018                                 any(String.class), any());
2019         }
2020
2021         @Test
2022         public void testgetGBBMacroNoUserParamsDeactivateInstnace() throws Exception {
2023                 GeneralBuildingBlock gBB = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
2024                                 GeneralBuildingBlock.class);
2025                 ExecuteBuildingBlock executeBB = mapper.readValue(new File(RESOURCE_PATH + "ExecuteBuildingBlockSimple.json"),
2026                                 ExecuteBuildingBlock.class);
2027                 RequestDetails requestDetails = mapper
2028                                 .readValue(new File(RESOURCE_PATH + "RequestDetailsInput_serviceMacro.json"), RequestDetails.class);
2029                 requestDetails.getRequestParameters().setUserParams(null);
2030                 org.onap.aai.domain.yang.GenericVnf aaiVnf = new org.onap.aai.domain.yang.GenericVnf();
2031                 aaiVnf.setModelCustomizationId("modelCustId");
2032                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
2033                 lookupKeyMap.put(ResourceKey.NETWORK_ID, "networkId");
2034                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, "vnfId");
2035                 lookupKeyMap.put(ResourceKey.VF_MODULE_ID, "vfModuleId");
2036                 lookupKeyMap.put(ResourceKey.VOLUME_GROUP_ID, "volumeGroupId");
2037                 lookupKeyMap.put(ResourceKey.SERVICE_INSTANCE_ID, "serviceInstanceId");
2038                 String resourceId = "123";
2039                 String vnfType = "vnfType";
2040                 Service service = Mockito.mock(Service.class);
2041                 String requestAction = "deactivateInstance";
2042                 doReturn(gBB).when(SPY_bbInputSetup).getGBBALaCarteService(executeBB, requestDetails, lookupKeyMap,
2043                                 requestAction, resourceId);
2044                 doReturn(service).when(SPY_bbInputSetupUtils)
2045                                 .getCatalogServiceByModelUUID(gBB.getServiceInstance().getModelInfoServiceInstance().getModelUuid());
2046                 String generatedId = "12131";
2047
2048                 executeBB.getBuildingBlock().setBpmnFlowName("DeactivateServiceInstanceBB");
2049                 executeBB.getBuildingBlock().setKey("3c40d244-808e-42ca-b09a-256d83d19d0a");
2050                 GeneralBuildingBlock actual = SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap,
2051                                 requestAction, resourceId, vnfType);
2052                 assertThat(actual, sameBeanAs(gBB));
2053         }
2054
2055         @Test
2056         public void testgetGBBMacroNoUserParamsCreateInstance() throws Exception {
2057                 GeneralBuildingBlock gBB = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
2058                                 GeneralBuildingBlock.class);
2059                 ExecuteBuildingBlock executeBB = mapper.readValue(new File(RESOURCE_PATH + "ExecuteBuildingBlockSimple.json"),
2060                                 ExecuteBuildingBlock.class);
2061                 RequestDetails requestDetails = mapper
2062                                 .readValue(new File(RESOURCE_PATH + "RequestDetailsInput_serviceMacro.json"), RequestDetails.class);
2063                 InfraActiveRequests request = Mockito.mock(InfraActiveRequests.class);
2064                 requestDetails.getRequestParameters().setUserParams(null);
2065                 org.onap.aai.domain.yang.GenericVnf aaiVnf = new org.onap.aai.domain.yang.GenericVnf();
2066                 aaiVnf.setModelCustomizationId("modelCustId");
2067                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
2068                 lookupKeyMap.put(ResourceKey.NETWORK_ID, "networkId");
2069                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, "vnfId");
2070                 lookupKeyMap.put(ResourceKey.VF_MODULE_ID, "vfModuleId");
2071                 lookupKeyMap.put(ResourceKey.VOLUME_GROUP_ID, "volumeGroupId");
2072                 lookupKeyMap.put(ResourceKey.SERVICE_INSTANCE_ID, "serviceInstanceId");
2073                 lookupKeyMap.put(ResourceKey.CONFIGURATION_ID, "configurationId");
2074
2075                 ConfigurationResourceKeys configResourceKeys = new ConfigurationResourceKeys();
2076                 configResourceKeys.setCvnfcCustomizationUUID("cvnfcCustomizationUUID");
2077                 configResourceKeys.setVfModuleCustomizationUUID("vfModuleCustomizationUUID");
2078                 configResourceKeys.setVnfResourceCustomizationUUID("vnfResourceCustomizationUUID");
2079                 executeBB.setConfigurationResourceKeys(configResourceKeys);
2080
2081                 String resourceId = "123";
2082                 String vnfType = "vnfType";
2083                 Service service = Mockito.mock(Service.class);
2084                 String requestAction = "createInstance";
2085                 doReturn(gBB).when(SPY_bbInputSetup).getGBBALaCarteService(executeBB, requestDetails, lookupKeyMap,
2086                                 requestAction, resourceId);
2087
2088                 doReturn(service).when(SPY_bbInputSetupUtils)
2089                                                 .getCatalogServiceByModelUUID(gBB.getServiceInstance().getModelInfoServiceInstance().getModelUuid());
2090                 List<NetworkResourceCustomization> networkCustList = new ArrayList<>();
2091                 NetworkResourceCustomization networkCust = Mockito.mock(NetworkResourceCustomization.class);
2092                 doReturn("ab153b6e-c364-44c0-bef6-1f2982117f04").when(networkCust).getModelCustomizationUUID();
2093                 networkCustList.add(networkCust);
2094                 doReturn(networkCustList).when(service).getNetworkCustomizations();
2095                 doNothing().when(SPY_bbInputSetup).populateL3Network(any(), isA(ModelInfo.class), isA(Service.class),
2096                                 any(String.class), isA(ServiceInstance.class), any(), any(String.class), any());
2097
2098                 executeBB.getBuildingBlock().setBpmnFlowName(AssignFlows.NETWORK_MACRO.toString());
2099                 executeBB.getBuildingBlock().setKey("ab153b6e-c364-44c0-bef6-1f2982117f04");
2100                 executeBB.getBuildingBlock().setIsVirtualLink(false);
2101                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
2102                 verify(SPY_bbInputSetup, times(1)).getGBBMacroNoUserParamsCreate(executeBB, lookupKeyMap,
2103                                 executeBB.getBuildingBlock().getBpmnFlowName(), "ab153b6e-c364-44c0-bef6-1f2982117f04", gBB, service);
2104
2105                 CollectionNetworkResourceCustomization collectionNetworkResourceCust = Mockito.mock(CollectionNetworkResourceCustomization.class);
2106                 doReturn(collectionNetworkResourceCust).when(SPY_bbInputSetupUtils).getCatalogCollectionNetworkResourceCustByID(any(String.class));
2107                 NetworkResourceCustomization networkResourceCustomization = Mockito.mock(NetworkResourceCustomization.class);
2108                 doReturn(networkResourceCustomization).when(bbInputSetupMapperLayer).mapCollectionNetworkResourceCustToNetworkResourceCust(collectionNetworkResourceCust);
2109                 ModelInfoNetwork modelInfoNetwork = Mockito.mock(ModelInfoNetwork.class);
2110                 doReturn(modelInfoNetwork ).when(bbInputSetupMapperLayer).mapCatalogNetworkToNetwork(networkResourceCustomization);
2111
2112                 executeBB.getBuildingBlock().setBpmnFlowName(AssignFlows.NETWORK_MACRO.toString());
2113                 executeBB.getBuildingBlock().setKey("ab153b6e-c364-44c0-bef6-1f2982117f04");
2114                 executeBB.getBuildingBlock().setIsVirtualLink(true);
2115                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
2116                 verify(SPY_bbInputSetup, times(2)).getGBBMacroNoUserParamsCreate(executeBB, lookupKeyMap,
2117                                 executeBB.getBuildingBlock().getBpmnFlowName(), "ab153b6e-c364-44c0-bef6-1f2982117f04", gBB, service);
2118
2119                 executeBB.getBuildingBlock().setBpmnFlowName("CreateNetworkBB");
2120                 executeBB.getBuildingBlock().setKey("ab153b6e-c364-44c0-bef6-1f2982117f04");
2121                 executeBB.getBuildingBlock().setIsVirtualLink(true);
2122                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
2123                 verify(SPY_bbInputSetup, times(1)).getGBBMacroNoUserParamsCreate(executeBB, lookupKeyMap,
2124                                 executeBB.getBuildingBlock().getBpmnFlowName(), "ab153b6e-c364-44c0-bef6-1f2982117f04", gBB, service);
2125         }
2126
2127         @Test
2128         public void testgetGBBMacroNoUserParamsOther() throws Exception {
2129                 GeneralBuildingBlock gBB = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
2130                                 GeneralBuildingBlock.class);
2131                 ExecuteBuildingBlock executeBB = mapper.readValue(new File(RESOURCE_PATH + "ExecuteBuildingBlockSimple.json"),
2132                                 ExecuteBuildingBlock.class);
2133                 RequestDetails requestDetails = mapper
2134                                 .readValue(new File(RESOURCE_PATH + "RequestDetailsInput_serviceMacro.json"), RequestDetails.class);
2135                 requestDetails.getRequestParameters().setUserParams(null);
2136                 org.onap.aai.domain.yang.GenericVnf aaiVnf = new org.onap.aai.domain.yang.GenericVnf();
2137                 aaiVnf.setModelCustomizationId("modelCustId");
2138                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
2139                 lookupKeyMap.put(ResourceKey.NETWORK_ID, "networkId");
2140                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, "vnfId");
2141                 lookupKeyMap.put(ResourceKey.VF_MODULE_ID, "vfModuleId");
2142                 lookupKeyMap.put(ResourceKey.VOLUME_GROUP_ID, "volumeGroupId");
2143                 lookupKeyMap.put(ResourceKey.SERVICE_INSTANCE_ID, "serviceInstanceId");
2144                 String resourceId = "123";
2145                 String vnfType = "vnfType";
2146                 Service service = Mockito.mock(Service.class);
2147                 String requestAction = "deleteInstance";
2148                 doReturn(gBB).when(SPY_bbInputSetup).getGBBALaCarteService(executeBB, requestDetails, lookupKeyMap,
2149                                 requestAction, resourceId);
2150                 doReturn(service).when(SPY_bbInputSetupUtils)
2151                                 .getCatalogServiceByModelUUID(gBB.getServiceInstance().getModelInfoServiceInstance().getModelUuid());
2152                 //doReturn(aaiVnf).when(SPY_bbInputSetupUtils).getAAIGenericVnf(any(String.class));
2153
2154                 CloudConfiguration cloudConfig = new CloudConfiguration();
2155                 cloudConfig.setLcpCloudRegionId("lcpCloudRegionId");
2156                 requestDetails.setCloudConfiguration(cloudConfig);
2157                 org.onap.aai.domain.yang.CloudRegion aaiCloudRegion = Mockito.mock(org.onap.aai.domain.yang.CloudRegion.class);
2158                 doReturn(aaiCloudRegion).when(SPY_bbInputSetupUtils).getCloudRegion(requestDetails.getCloudConfiguration());
2159                 executeBB.getBuildingBlock().setBpmnFlowName("DeleteNetworkBB");
2160                 executeBB.getBuildingBlock().setKey("ab153b6e-c364-44c0-bef6-1f2982117f04");
2161                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
2162                 verify(SPY_bbInputSetup, times(1)).getGBBMacroExistingService(isA(ExecuteBuildingBlock.class), any(),
2163                                 any(String.class), any(GeneralBuildingBlock.class), isA(Service.class), isA(String.class),
2164                                 isA(CloudConfiguration.class));
2165
2166                 requestAction = "activateInstance";
2167                 doReturn(gBB).when(SPY_bbInputSetup).getGBBALaCarteService(executeBB, requestDetails, lookupKeyMap,
2168                                 requestAction, resourceId);
2169                 executeBB.getBuildingBlock().setBpmnFlowName("ActivateNetworkBB");
2170                 executeBB.getBuildingBlock().setKey("ab153b6e-c364-44c0-bef6-1f2982117f04");
2171                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
2172                 verify(SPY_bbInputSetup, times(2)).getGBBMacroExistingService(isA(ExecuteBuildingBlock.class), any(),
2173                                 any(String.class), any(GeneralBuildingBlock.class), isA(Service.class), isA(String.class),
2174                                 isA(CloudConfiguration.class));
2175
2176                 requestAction = "unassignInstance";
2177                 doReturn(gBB).when(SPY_bbInputSetup).getGBBALaCarteService(executeBB, requestDetails, lookupKeyMap,
2178                                 requestAction, resourceId);
2179                 executeBB.getBuildingBlock().setBpmnFlowName("UnassignNetworkBB");
2180                 executeBB.getBuildingBlock().setKey("ab153b6e-c364-44c0-bef6-1f2982117f04");
2181                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
2182                 verify(SPY_bbInputSetup, times(3)).getGBBMacroExistingService(isA(ExecuteBuildingBlock.class), any(),
2183                                 any(String.class), any(GeneralBuildingBlock.class), isA(Service.class), isA(String.class),
2184                                 isA(CloudConfiguration.class));
2185
2186                 requestAction = "activateFabricConfiguration";
2187                 doReturn(gBB).when(SPY_bbInputSetup).getGBBALaCarteService(executeBB, requestDetails, lookupKeyMap,
2188                                 requestAction, resourceId);
2189                 executeBB.getBuildingBlock().setBpmnFlowName("ActivateFabricConfigurationBB");
2190                 executeBB.getBuildingBlock().setKey("ab153b6e-c364-44c0-bef6-134534656234");
2191                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
2192                 verify(SPY_bbInputSetup, times(4)).getGBBMacroExistingService(isA(ExecuteBuildingBlock.class), any(),
2193                                 any(String.class), any(GeneralBuildingBlock.class), isA(Service.class), isA(String.class),
2194                                 isA(CloudConfiguration.class));
2195         }
2196
2197         @Test(expected = IllegalArgumentException.class)
2198         public void testgetGBBMacroNoUserParamsOtherException() throws Exception {
2199                 GeneralBuildingBlock gBB = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
2200                                 GeneralBuildingBlock.class);
2201                 ExecuteBuildingBlock executeBB = mapper.readValue(new File(RESOURCE_PATH + "ExecuteBuildingBlockSimple.json"),
2202                                 ExecuteBuildingBlock.class);
2203                 RequestDetails requestDetails = mapper
2204                                 .readValue(new File(RESOURCE_PATH + "RequestDetailsInput_serviceMacro.json"), RequestDetails.class);
2205                 requestDetails.getRequestParameters().setUserParams(null);
2206                 org.onap.aai.domain.yang.GenericVnf aaiVnf = new org.onap.aai.domain.yang.GenericVnf();
2207                 aaiVnf.setModelCustomizationId("modelCustId");
2208                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
2209                 lookupKeyMap.put(ResourceKey.NETWORK_ID, "networkId");
2210                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, "vnfId");
2211                 lookupKeyMap.put(ResourceKey.VF_MODULE_ID, "vfModuleId");
2212                 lookupKeyMap.put(ResourceKey.VOLUME_GROUP_ID, "volumeGroupId");
2213                 lookupKeyMap.put(ResourceKey.SERVICE_INSTANCE_ID, "serviceInstanceId");
2214                 String resourceId = "123";
2215                 String vnfType = "vnfType";
2216                 Service service = Mockito.mock(Service.class);
2217                 String requestAction = "assignInstance";
2218                 doReturn(gBB).when(SPY_bbInputSetup).getGBBALaCarteService(executeBB, requestDetails, lookupKeyMap,
2219                                 requestAction, resourceId);
2220                 doReturn(service).when(SPY_bbInputSetupUtils)
2221                                 .getCatalogServiceByModelUUID(gBB.getServiceInstance().getModelInfoServiceInstance().getModelUuid());
2222                 String generatedId = "12131";
2223
2224                 executeBB.getBuildingBlock().setKey("3c40d244-808e-42ca-b09a-256d83d19d0a");
2225                 SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
2226         }
2227         @Test
2228         public void testgetGBBMacroNoUserParamsExistingService() throws Exception {
2229                 GeneralBuildingBlock gBB = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
2230                                 GeneralBuildingBlock.class);
2231                 ExecuteBuildingBlock executeBB = mapper.readValue(new File(RESOURCE_PATH + "ExecuteBuildingBlockSimple.json"),
2232                                 ExecuteBuildingBlock.class);
2233                 RequestDetails requestDetails = mapper
2234                                 .readValue(new File(RESOURCE_PATH + "RequestDetailsInput_serviceMacro.json"), RequestDetails.class);
2235                 requestDetails.getRequestParameters().setUserParams(null);
2236                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
2237                 lookupKeyMap.put(ResourceKey.NETWORK_ID, "networkId");
2238                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, "vnfId");
2239                 lookupKeyMap.put(ResourceKey.VF_MODULE_ID, "vfModuleId");
2240                 lookupKeyMap.put(ResourceKey.VOLUME_GROUP_ID, "volumeGroupId");
2241                 lookupKeyMap.put(ResourceKey.SERVICE_INSTANCE_ID, "serviceInstanceId");
2242                 lookupKeyMap.put(ResourceKey.CONFIGURATION_ID, "configurationId");
2243                 Service service = Mockito.mock(Service.class);
2244                 CloudConfiguration cloudConfiguration = new CloudConfiguration();
2245                 cloudConfiguration.setLcpCloudRegionId("cloudRegionId");
2246                 String requestAction = "unassignInstance";
2247
2248                 ConfigurationResourceKeys configResourceKeys = new ConfigurationResourceKeys();
2249                 configResourceKeys.setCvnfcCustomizationUUID("cvnfcCustomizationUUID");
2250                 configResourceKeys.setVfModuleCustomizationUUID("vfModuleCustomizationUUID");
2251                 configResourceKeys.setVnfResourceCustomizationUUID("vnfResourceCustomizationUUID");
2252                 executeBB.setConfigurationResourceKeys(configResourceKeys);
2253
2254                 L3Network network = new L3Network();
2255                 network.setNetworkId("networkId");
2256                 gBB.getServiceInstance().getNetworks().add(network);
2257                 org.onap.aai.domain.yang.L3Network aaiNetwork = new org.onap.aai.domain.yang.L3Network();
2258                 aaiNetwork.setModelCustomizationId("modelCustId");
2259                 doReturn(aaiNetwork).when(SPY_bbInputSetupUtils).getAAIL3Network(network.getNetworkId());
2260                 doNothing().when(SPY_bbInputSetup).mapCatalogNetwork(any(L3Network.class), any(ModelInfo.class),
2261                                 any(Service.class));
2262
2263                 executeBB.getBuildingBlock().setBpmnFlowName("DeleteNetworkBB");
2264                 executeBB.getBuildingBlock().setKey("ab153b6e-c364-44c0-bef6-1f2982117f04");
2265                 SPY_bbInputSetup.getGBBMacroExistingService(executeBB, lookupKeyMap,
2266                                 executeBB.getBuildingBlock().getBpmnFlowName(), gBB, service, requestAction, cloudConfiguration);
2267                 verify(SPY_bbInputSetup, times(1)).mapCatalogNetwork(any(L3Network.class), any(ModelInfo.class),
2268                                 any(Service.class));
2269
2270                 GenericVnf vnf = new GenericVnf();
2271                 vnf.setVnfId("vnfId");
2272                 gBB.getServiceInstance().getVnfs().add(vnf);
2273                 org.onap.aai.domain.yang.GenericVnf aaiVnf = new org.onap.aai.domain.yang.GenericVnf();
2274                 aaiVnf.setModelCustomizationId("modelCustId");
2275                 doReturn(aaiVnf).when(SPY_bbInputSetupUtils).getAAIGenericVnf(vnf.getVnfId());
2276                 doNothing().when(SPY_bbInputSetup).mapCatalogVnf(any(GenericVnf.class), any(ModelInfo.class),
2277                                 any(Service.class));
2278
2279                 executeBB.getBuildingBlock().setBpmnFlowName("ActivateVnfBB");
2280                 executeBB.getBuildingBlock().setKey("ab153b6e-c364-44c0-bef6-1f2982117f04");
2281                 SPY_bbInputSetup.getGBBMacroExistingService(executeBB, lookupKeyMap,
2282                                 executeBB.getBuildingBlock().getBpmnFlowName(), gBB, service, requestAction, cloudConfiguration);
2283                 verify(SPY_bbInputSetup, times(1)).mapCatalogVnf(any(GenericVnf.class), any(ModelInfo.class),
2284                                 any(Service.class));
2285
2286                 VfModule vfModule = new VfModule();
2287                 vfModule.setVfModuleId("vfModuleId");
2288                 gBB.getServiceInstance().getVnfs().get(0).getVfModules().add(vfModule);
2289                 org.onap.aai.domain.yang.VfModule aaiVfModule = new org.onap.aai.domain.yang.VfModule();
2290                 aaiVfModule.setModelCustomizationId("modelCustId");
2291                 doReturn(aaiVfModule).when(SPY_bbInputSetupUtils).getAAIVfModule(vnf.getVnfId(), vfModule.getVfModuleId());
2292
2293                 executeBB.getBuildingBlock().setBpmnFlowName("UnassignVfModuleBB");
2294                 executeBB.getBuildingBlock().setKey("a25e8e8c-58b8-4eec-810c-97dcc1f5cb7f");
2295                 SPY_bbInputSetup.getGBBMacroExistingService(executeBB, lookupKeyMap,
2296                                 executeBB.getBuildingBlock().getBpmnFlowName(), gBB, service, requestAction, cloudConfiguration);
2297                 verify(SPY_bbInputSetup, times(2)).mapCatalogVnf(any(GenericVnf.class), any(ModelInfo.class),
2298                                 any(Service.class));
2299                 verify(SPY_bbInputSetup, times(1)).mapCatalogVfModule(any(VfModule.class), any(ModelInfo.class),
2300                                 any(Service.class), any(String.class));
2301
2302                 CloudRegion cloudRegion = new CloudRegion();
2303                 cloudRegion.setLcpCloudRegionId("cloudRegionId");
2304                 cloudRegion.setCloudOwner("CloudOwner");
2305                 doReturn(Optional.of(cloudRegion)).when(SPY_cloudInfoFromAAI).getCloudInfoFromAAI(gBB.getServiceInstance());
2306                 VolumeGroup volumeGroup = new VolumeGroup();
2307                 volumeGroup.setVolumeGroupId("volumeGroupId");
2308                 gBB.getServiceInstance().getVnfs().get(0).getVolumeGroups().add(volumeGroup);
2309                 org.onap.aai.domain.yang.VolumeGroup aaiVolumeGroup = new org.onap.aai.domain.yang.VolumeGroup();
2310                 aaiVolumeGroup.setModelCustomizationId("modelCustId");
2311                 doReturn(aaiVolumeGroup).when(SPY_bbInputSetupUtils).getAAIVolumeGroup(cloudRegion.getCloudOwner(),
2312                                 cloudRegion.getLcpCloudRegionId(), volumeGroup.getVolumeGroupId());
2313
2314                 executeBB.getBuildingBlock().setBpmnFlowName("UnassignVolumeGroupBB");
2315                 executeBB.getBuildingBlock().setKey("72d9d1cd-f46d-447a-abdb-451d6fb05fa8");
2316                 SPY_bbInputSetup.getGBBMacroExistingService(executeBB, lookupKeyMap,
2317                                 executeBB.getBuildingBlock().getBpmnFlowName(), gBB, service, requestAction, null);
2318                 verify(SPY_bbInputSetup, times(3)).mapCatalogVnf(any(GenericVnf.class), any(ModelInfo.class),
2319                                 any(Service.class));
2320                 verify(SPY_bbInputSetup, times(1)).mapCatalogVolumeGroup(isA(VolumeGroup.class), isA(ModelInfo.class),
2321                                 isA(Service.class), isA(String.class));
2322
2323                 Configuration configuration = new Configuration();
2324                 configuration.setConfigurationId("configurationId");
2325                 gBB.getServiceInstance().getConfigurations().add(configuration);
2326                 org.onap.aai.domain.yang.Configuration aaiConfiguration = new org.onap.aai.domain.yang.Configuration();
2327                 aaiConfiguration.setModelCustomizationId("modelCustId");
2328                 doReturn(aaiConfiguration).when(SPY_bbInputSetupUtils).getAAIConfiguration(configuration.getConfigurationId());
2329                 doNothing().when(SPY_bbInputSetup).mapCatalogConfiguration(isA(Configuration.class), isA(ModelInfo.class), isA(Service.class), isA(ConfigurationResourceKeys.class));
2330
2331                 executeBB.getBuildingBlock().setBpmnFlowName("ActivateFabricConfigurationBB");
2332                 executeBB.getBuildingBlock().setKey("72d9d1cd-f46d-447a-abdb-451d6fb05fa9");
2333                 SPY_bbInputSetup.getGBBMacroExistingService(executeBB, lookupKeyMap,
2334                                 executeBB.getBuildingBlock().getBpmnFlowName(), gBB, service, requestAction, cloudConfiguration);
2335                 verify(SPY_bbInputSetup, times(1)).mapCatalogConfiguration(any(Configuration.class), any(ModelInfo.class),
2336                                 any(Service.class), isA(ConfigurationResourceKeys.class));
2337         }
2338
2339         @Test
2340         public void testGetVnfId() {
2341                 String expected = "vnfId";
2342                 ExecuteBuildingBlock executeBB = new ExecuteBuildingBlock();
2343                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
2344                 executeBB.setRequestId("requestId");
2345                 InfraActiveRequests request = new InfraActiveRequests();
2346                 request.setVnfId(expected);
2347                 doReturn(request).when(SPY_bbInputSetupUtils).getInfraActiveRequest(executeBB.getRequestId());
2348
2349                 String actual = SPY_bbInputSetup.getVnfId(executeBB, lookupKeyMap);
2350
2351                 assertEquals("VnfId is set correctly", expected, actual);
2352         }
2353
2354         @Test
2355         public void testCreateVfModule() {
2356                 String vfModuleId = "vfModuleId";
2357                 String instanceName = "vfModuleName";
2358                 Map<String, String> cloudParams = new HashMap<>();
2359                 cloudParams.put("param1", "param1Value");
2360                 VfModule expected = new VfModule();
2361                 expected.setVfModuleId(vfModuleId);
2362                 expected.setVfModuleName(instanceName);
2363                 expected.setCloudParams(cloudParams);
2364                 expected.setOrchestrationStatus(OrchestrationStatus.PRECREATED);
2365                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
2366                 List<Map<String, String>> instanceParams = new ArrayList<>();
2367                 instanceParams.add(cloudParams);
2368
2369                 VfModule actual = SPY_bbInputSetup.createVfModule(lookupKeyMap, vfModuleId, instanceName, instanceParams);
2370
2371                 assertThat(actual, sameBeanAs(expected));
2372                 assertEquals("LookupKeyMap is populated", vfModuleId, lookupKeyMap.get(ResourceKey.VF_MODULE_ID));
2373
2374                 expected.getCloudParams().clear();
2375                 actual = SPY_bbInputSetup.createVfModule(lookupKeyMap, vfModuleId, instanceName, null);
2376                 assertThat(actual, sameBeanAs(expected));
2377         }
2378
2379         @Test
2380         public void testCreateVolumeGroup() {
2381                 String volumeGroupId = "volumeGroupId";
2382                 String instanceName = "vfModuleName";
2383                 String vnfType = "vnfType";
2384                 Map<String, String> cloudParams = new HashMap<>();
2385                 cloudParams.put("param1", "param1Value");
2386                 VolumeGroup expected = new VolumeGroup();
2387                 expected.setVolumeGroupId(volumeGroupId);
2388                 expected.setVolumeGroupName(instanceName);
2389                 expected.setCloudParams(cloudParams);
2390                 expected.setVnfType(vnfType);
2391                 expected.setOrchestrationStatus(OrchestrationStatus.PRECREATED);
2392                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
2393                 List<Map<String, String>> instanceParams = new ArrayList<>();
2394                 instanceParams.add(cloudParams);
2395
2396                 VolumeGroup actual = SPY_bbInputSetup.createVolumeGroup(lookupKeyMap, volumeGroupId, instanceName, vnfType, instanceParams);
2397
2398                 assertThat(actual, sameBeanAs(expected));
2399                 assertEquals("LookupKeyMap is populated", volumeGroupId, lookupKeyMap.get(ResourceKey.VOLUME_GROUP_ID));
2400
2401                 expected.getCloudParams().clear();
2402                 actual = SPY_bbInputSetup.createVolumeGroup(lookupKeyMap, volumeGroupId, instanceName, vnfType, null);
2403                 assertThat(actual, sameBeanAs(expected));
2404         }
2405
2406         @Test
2407         public void testCreateNetwork() {
2408                 String networkId = "networkId";
2409                 String instanceName = "networkName";
2410                 Map<String, String> cloudParams = new HashMap<>();
2411                 cloudParams.put("param1", "param1Value");
2412                 L3Network expected = new L3Network();
2413                 expected.setNetworkId(networkId);
2414                 expected.setNetworkName(instanceName);
2415                 expected.setCloudParams(cloudParams);
2416                 expected.setOrchestrationStatus(OrchestrationStatus.PRECREATED);
2417                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
2418                 List<Map<String, String>> instanceParams = new ArrayList<>();
2419                 instanceParams.add(cloudParams);
2420                 L3Network actual = SPY_bbInputSetup.createNetwork(lookupKeyMap, instanceName, networkId, instanceParams);
2421
2422                 assertThat(actual, sameBeanAs(expected));
2423                 assertEquals("LookupKeyMap is populated", networkId, lookupKeyMap.get(ResourceKey.NETWORK_ID));
2424
2425                 expected.getCloudParams().clear();
2426                 actual = SPY_bbInputSetup.createNetwork(lookupKeyMap, instanceName, networkId, null);
2427                 assertThat(actual, sameBeanAs(expected));
2428         }
2429
2430         @Test
2431         public void testCreateGenericVnf() {
2432                 String vnfId = "vnfId";
2433                 String instanceName = "vnfName";
2434                 String vnfType = "vnfType";
2435                 String platformName = "platformName";
2436                 String lineOfBusinessName = "lineOfBusinessName";
2437                 Platform platform = new Platform();
2438                 platform.setPlatformName(platformName);
2439                 LineOfBusiness lineOfBusiness = new LineOfBusiness();
2440                 lineOfBusiness.setLineOfBusinessName(lineOfBusinessName);
2441                 Map<String, String> cloudParams = new HashMap<>();
2442                 cloudParams.put("param1", "param1Value");
2443                 GenericVnf expected = new GenericVnf();
2444                 expected.setVnfId(vnfId);
2445                 expected.setVnfName(instanceName);
2446                 expected.setVnfType(vnfType);
2447                 expected.setCloudParams(cloudParams);
2448                 expected.setOrchestrationStatus(OrchestrationStatus.PRECREATED);
2449                 expected.setPlatform(platform);
2450                 expected.setLineOfBusiness(lineOfBusiness);
2451                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
2452                 List<Map<String, String>> instanceParams = new ArrayList<>();
2453                 instanceParams.add(cloudParams);
2454                 org.onap.so.serviceinstancebeans.Platform requestPlatform = new org.onap.so.serviceinstancebeans.Platform();
2455                 platform.setPlatformName(platformName);
2456                 org.onap.so.serviceinstancebeans.LineOfBusiness requestLineOfBusiness = new org.onap.so.serviceinstancebeans.LineOfBusiness();
2457                 lineOfBusiness.setLineOfBusinessName(lineOfBusinessName);
2458
2459                 doReturn(platform).when(bbInputSetupMapperLayer).mapRequestPlatform(requestPlatform);
2460                 doReturn(lineOfBusiness).when(bbInputSetupMapperLayer).mapRequestLineOfBusiness(requestLineOfBusiness);
2461
2462                 GenericVnf actual = SPY_bbInputSetup.createGenericVnf(lookupKeyMap, instanceName, requestPlatform, requestLineOfBusiness, vnfId, vnfType, instanceParams);
2463
2464                 assertThat(actual, sameBeanAs(expected));
2465                 assertEquals("LookupKeyMap is populated", vnfId, lookupKeyMap.get(ResourceKey.GENERIC_VNF_ID));
2466
2467                 expected.getCloudParams().clear();
2468                 actual = SPY_bbInputSetup.createGenericVnf(lookupKeyMap, instanceName, requestPlatform, requestLineOfBusiness, vnfId, vnfType, null);
2469                 assertThat(actual, sameBeanAs(expected));
2470         }
2471
2472         @Test
2473         public void testMapCatalogVfModule() {
2474                 String vnfModelCustomizationUUID = "vnfResourceCustUUID";
2475                 String vfModuleCustomizationUUID = "vfModelCustomizationUUID";
2476                 VfModule vfModule = new VfModule();
2477                 ModelInfo modelInfo = new ModelInfo();
2478                 modelInfo.setModelCustomizationUuid(vfModuleCustomizationUUID);
2479                 Service service = new Service();
2480                 VnfResourceCustomization vnfResourceCust = new VnfResourceCustomization();
2481                 vnfResourceCust.setModelCustomizationUUID(vnfModelCustomizationUUID);
2482                 VfModuleCustomization vfModuleCust = new VfModuleCustomization();
2483                 vfModuleCust.setModelCustomizationUUID(vfModuleCustomizationUUID);
2484                 vnfResourceCust.getVfModuleCustomizations().add(vfModuleCust);
2485                 service.getVnfCustomizations().add(vnfResourceCust);
2486                 ModelInfoVfModule modelInfoVfModule = new ModelInfoVfModule();
2487
2488                 doReturn(modelInfoVfModule).when(bbInputSetupMapperLayer).mapCatalogVfModuleToVfModule(vfModuleCust);
2489
2490                 SPY_bbInputSetup.mapCatalogVfModule(vfModule, modelInfo, service, vnfModelCustomizationUUID);
2491
2492                 assertThat(vfModule.getModelInfoVfModule(), sameBeanAs(modelInfoVfModule));
2493
2494                 modelInfo.setModelCustomizationUuid(null);
2495                 modelInfo.setModelCustomizationId(vfModuleCustomizationUUID);
2496
2497                 SPY_bbInputSetup.mapCatalogVfModule(vfModule, modelInfo, service, vnfModelCustomizationUUID);
2498
2499                 assertThat(vfModule.getModelInfoVfModule(), sameBeanAs(modelInfoVfModule));
2500         }
2501
2502         @Test
2503         public void testPopulateVfModule() throws Exception {
2504                 String vnfId = "vnfId";
2505                 String vfModuleId = "vfModuleId";
2506                 String volumeGroupId = "volumeGroupId";
2507                 String vfModuleCustomizationId = "vfModuleCustomizationId";
2508                 ModelInfo modelInfo = new ModelInfo();
2509                 modelInfo.setModelCustomizationId(vfModuleCustomizationId);
2510                 Service service = new Service();
2511                 String bbName = AssignFlows.VF_MODULE.toString();
2512                 ServiceInstance serviceInstance = new ServiceInstance();
2513                 GenericVnf vnf = new GenericVnf();
2514                 vnf.setVnfId(vnfId);
2515                 VolumeGroup volumeGroup = new VolumeGroup();
2516                 volumeGroup.setVolumeGroupId(volumeGroupId);
2517                 vnf.getVolumeGroups().add(volumeGroup);
2518                 serviceInstance.getVnfs().add(vnf);
2519                 Map<ResourceKey, String> lookupKeyMap = new HashMap<>();
2520                 lookupKeyMap.put(ResourceKey.GENERIC_VNF_ID, vnfId);
2521                 String resourceId = vfModuleId;
2522                 RelatedInstanceList[] relatedInstanceList = null;
2523                 String instanceName = "vfModuleName";
2524                 List<Map<String, String>> instanceParams = null;
2525                 CloudConfiguration cloudConfiguration = new CloudConfiguration();
2526
2527                 org.onap.aai.domain.yang.GenericVnf vnfAAI = new org.onap.aai.domain.yang.GenericVnf();
2528                 vnfAAI.setModelCustomizationId("vnfModelCustId");
2529                 org.onap.aai.domain.yang.VolumeGroup volumeGroupAAI = new org.onap.aai.domain.yang.VolumeGroup();
2530                 volumeGroupAAI.setModelCustomizationId(vfModuleCustomizationId);
2531
2532                 doReturn(vnfAAI).when(SPY_bbInputSetupUtils).getAAIGenericVnf(vnf.getVnfId());
2533                 doReturn(volumeGroupAAI).when(SPY_bbInputSetupUtils).getAAIVolumeGroup(CLOUD_OWNER,
2534                                 cloudConfiguration.getLcpCloudRegionId(), volumeGroup.getVolumeGroupId());
2535                 doNothing().when(SPY_bbInputSetup).mapCatalogVnf(isA(GenericVnf.class), isA(ModelInfo.class), isA(Service.class));
2536                 doNothing().when(SPY_bbInputSetup).mapCatalogVfModule(isA(VfModule.class), isA(ModelInfo.class), isA(Service.class), isA(String.class));
2537
2538                 SPY_bbInputSetup.populateVfModule(modelInfo, service, bbName, serviceInstance, lookupKeyMap,
2539                                 resourceId, relatedInstanceList, instanceName, instanceParams, cloudConfiguration);
2540
2541                 assertEquals("Lookup Key Map populated with VfModule Id", vfModuleId, lookupKeyMap.get(ResourceKey.VF_MODULE_ID));
2542                 assertEquals("Lookup Key Map populated with VolumeGroup Id", volumeGroupId, lookupKeyMap.get(ResourceKey.VOLUME_GROUP_ID));
2543         }
2544
2545 }