2  * ============LICENSE_START=======================================================
 
   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
 
  11  *      http://www.apache.org/licenses/LICENSE-2.0
 
  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=========================================================
 
  21 package org.onap.so.bpmn.servicedecomposition.tasks;
 
  23 import static org.mockito.ArgumentMatchers.any;
 
  24 import static org.mockito.ArgumentMatchers.isA;
 
  25 import static org.mockito.Mockito.doReturn;
 
  26 import static org.mockito.Mockito.times;
 
  27 import static org.mockito.Mockito.verify;
 
  28 import static org.onap.so.bpmn.servicedecomposition.tasks.BaseBBInputSetupTestHelper.prepareLookupKeyMap;
 
  30 import java.util.Arrays;
 
  31 import java.util.Collection;
 
  33 import org.junit.Before;
 
  34 import org.junit.Rule;
 
  35 import org.junit.Test;
 
  36 import org.junit.rules.ExpectedException;
 
  37 import org.junit.runner.RunWith;
 
  38 import org.junit.runners.Parameterized;
 
  39 import org.mockito.InjectMocks;
 
  40 import org.mockito.Mock;
 
  41 import org.mockito.Mockito;
 
  42 import org.mockito.MockitoAnnotations;
 
  43 import org.mockito.Spy;
 
  44 import org.onap.aai.domain.yang.CloudRegion;
 
  45 import org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance;
 
  46 import org.onap.so.bpmn.servicedecomposition.entities.BuildingBlock;
 
  47 import org.onap.so.bpmn.servicedecomposition.entities.ExecuteBuildingBlock;
 
  48 import org.onap.so.bpmn.servicedecomposition.entities.GeneralBuildingBlock;
 
  49 import org.onap.so.bpmn.servicedecomposition.entities.ResourceKey;
 
  50 import org.onap.so.db.catalog.beans.Service;
 
  51 import org.onap.so.serviceinstancebeans.CloudConfiguration;
 
  52 import org.onap.so.serviceinstancebeans.RequestDetails;
 
  53 import com.fasterxml.jackson.databind.ObjectMapper;
 
  55 @RunWith(Parameterized.class)
 
  56 public class BBInputSetupExistingServiceTest {
 
  57     private String requestAction;
 
  58     private String bpmnFlowName;
 
  60     private static final String RESOURCE_PATH = "src/test/resources/__files/ExecuteBuildingBlock/";
 
  62     protected ObjectMapper mapper = new ObjectMapper();
 
  66     private BBInputSetup SPY_bbInputSetup = new BBInputSetup();
 
  69     private BBInputSetupUtils bbInputSetupUtils;
 
  72     private BBInputSetupMapperLayer bbInputSetupMapperLayer;
 
  75     public ExpectedException expectedException = ExpectedException.none();
 
  77     public BBInputSetupExistingServiceTest(String requestAction, String bpmnFlowName, String key) {
 
  78         this.requestAction = requestAction;
 
  79         this.bpmnFlowName = bpmnFlowName;
 
  85         MockitoAnnotations.initMocks(this);
 
  88     @Parameterized.Parameters
 
  89     public static Collection input() {
 
  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"}});
 
  99     public void test_getGBBMacro_getGBBMacroExistingService_shouldBeCalled() throws Exception {
 
 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);
 
 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);
 
 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(any(BBInputSetupParameter.class));
 
 130         doReturn(aaiCloudRegion).when(bbInputSetupUtils).getCloudRegion(requestDetails.getCloudConfiguration());
 
 132         SPY_bbInputSetup.getGBBMacro(executeBB, requestDetails, lookupKeyMap, requestAction, resourceId, vnfType);
 
 134         verify(SPY_bbInputSetup, times(1)).getGBBMacroExistingService(isA(ExecuteBuildingBlock.class), any(),
 
 135                 any(String.class), isA(String.class), isA(CloudConfiguration.class));