fbb67cb9236af401601826b3f6c2e1edcd86ae84
[so.git] /
1 /*-
2  * ============LICENSE_START=======================================================
3  * ONAP - SO
4  * ================================================================================
5  * Copyright (C) 2020 Nokia 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 com.fasterxml.jackson.databind.ObjectMapper;
24 import org.junit.Before;
25 import org.junit.Rule;
26 import org.junit.Test;
27 import org.junit.rules.ExpectedException;
28 import org.junit.runner.RunWith;
29 import org.junit.runners.Parameterized;
30 import org.mockito.InjectMocks;
31 import org.mockito.Mock;
32 import org.mockito.Mockito;
33 import org.mockito.MockitoAnnotations;
34 import org.mockito.Spy;
35 import org.onap.aai.domain.yang.CloudRegion;
36 import org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance;
37 import org.onap.so.bpmn.servicedecomposition.entities.BuildingBlock;
38 import org.onap.so.bpmn.servicedecomposition.entities.ExecuteBuildingBlock;
39 import org.onap.so.bpmn.servicedecomposition.entities.GeneralBuildingBlock;
40 import org.onap.so.bpmn.servicedecomposition.entities.ResourceKey;
41 import org.onap.so.db.catalog.beans.Service;
42 import org.onap.so.serviceinstancebeans.CloudConfiguration;
43 import org.onap.so.serviceinstancebeans.RequestDetails;
44 import java.io.File;
45 import java.util.Arrays;
46 import java.util.Collection;
47 import java.util.Map;
48 import static org.mockito.ArgumentMatchers.any;
49 import static org.mockito.ArgumentMatchers.isA;
50 import static org.mockito.Mockito.doReturn;
51 import static org.mockito.Mockito.times;
52 import static org.mockito.Mockito.verify;
53 import static org.onap.so.bpmn.servicedecomposition.tasks.BaseBBInputSetupTestHelper.prepareLookupKeyMap;
54
55 @RunWith(Parameterized.class)
56 public class BBInputSetupExistingServiceTest {
57     private String requestAction;
58     private String bpmnFlowName;
59     private String key;
60     private static final String RESOURCE_PATH = "src/test/resources/__files/ExecuteBuildingBlock/";
61
62     protected ObjectMapper mapper = new ObjectMapper();
63
64     @Spy
65     @InjectMocks
66     private BBInputSetup SPY_bbInputSetup = new BBInputSetup();
67
68     @Mock
69     private BBInputSetupUtils bbInputSetupUtils;
70
71     @Mock
72     private BBInputSetupMapperLayer bbInputSetupMapperLayer;
73
74     @Rule
75     public ExpectedException expectedException = ExpectedException.none();
76
77     public BBInputSetupExistingServiceTest(String requestAction, String bpmnFlowName, String key) {
78         this.requestAction = requestAction;
79         this.bpmnFlowName = bpmnFlowName;
80         this.key = key;
81     }
82
83     @Before
84     public void setup() {
85         MockitoAnnotations.initMocks(this);
86     }
87
88     @Parameterized.Parameters
89     public static Collection input() {
90         return Arrays
91                 .asList(new Object[][] {{"deleteInstance", "DeleteNetworkBB", "ab153b6e-c364-44c0-bef6-1f2982117f04"},
92                         {"activateInstance", "ActivateNetworkBB", "ab153b6e-c364-44c0-bef6-1f2982117f04"},
93                         {"unassignInstance", "UnassignNetworkBB", "ab153b6e-c364-44c0-bef6-1f2982117f04"},
94                         {"activateFabricConfiguration", "ActivateFabricConfigurationBB",
95                                 "ab153b6e-c364-44c0-bef6-134534656234"}});
96     }
97
98     @Test
99     public void test_getGBBMacro_getGBBMacroExistingService_shouldBeCalled() throws Exception {
100         // given
101         String resourceId = "123";
102         String vnfType = "vnfType";
103         String requestAction = this.requestAction;
104         Service service = Mockito.mock(Service.class);
105         GeneralBuildingBlock gBB = mapper.readValue(new File(RESOURCE_PATH + "GeneralBuildingBlockExpected.json"),
106                 GeneralBuildingBlock.class);
107         ServiceInstance serviceInstance = gBB.getServiceInstance();
108         Map<ResourceKey, String> lookupKeyMap = prepareLookupKeyMap();
109         org.onap.aai.domain.yang.ServiceInstance aaiServiceInstance = new org.onap.aai.domain.yang.ServiceInstance();
110         aaiServiceInstance.setModelVersionId("modelVersionId");
111         CloudConfiguration cloudConfig = new CloudConfiguration();
112         cloudConfig.setLcpCloudRegionId("lcpCloudRegionId");
113         CloudRegion aaiCloudRegion = Mockito.mock(CloudRegion.class);
114
115         RequestDetails requestDetails = mapper
116                 .readValue(new File(RESOURCE_PATH + "RequestDetailsInput_serviceMacro.json"), RequestDetails.class);
117         requestDetails.getRequestParameters().setUserParams(null);
118         requestDetails.setCloudConfiguration(cloudConfig);
119         ExecuteBuildingBlock executeBB = mapper.readValue(new File(RESOURCE_PATH + "ExecuteBuildingBlockSimple.json"),
120                 ExecuteBuildingBlock.class);
121         executeBB.setRequestDetails(requestDetails);
122         BuildingBlock buildingBlock = executeBB.getBuildingBlock();
123         buildingBlock.setBpmnFlowName(this.bpmnFlowName).setKey(this.key);
124
125         doReturn(service).when(bbInputSetupUtils).getCatalogServiceByModelUUID(aaiServiceInstance.getModelVersionId());
126         doReturn(aaiServiceInstance).when(bbInputSetupUtils)
127                 .getAAIServiceInstanceById(lookupKeyMap.get(ResourceKey.SERVICE_INSTANCE_ID));
128         doReturn(serviceInstance).when(SPY_bbInputSetup).getExistingServiceInstance(aaiServiceInstance);
129         doReturn(gBB).when(SPY_bbInputSetup).populateGBBWithSIAndAdditionalInfo(requestDetails, serviceInstance,
130                 executeBB, requestAction, null);
131         doReturn(aaiCloudRegion).when(bbInputSetupUtils).getCloudRegion(requestDetails.getCloudConfiguration());
132         // when
133         SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
134         // then
135         verify(SPY_bbInputSetup, times(1)).getGBBMacroExistingService(isA(ExecuteBuildingBlock.class), any(),
136                 any(String.class), isA(String.class), isA(CloudConfiguration.class));
137     }
138 }
139