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