ab4d8118a5c64143c847da78ee841a748a4f0b8c
[sdc.git] /
1 /*-
2  * ============LICENSE_START=======================================================
3  * SDC
4  * ================================================================================
5  * Copyright (C) 2019 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.openecomp.sdc.be.components.merge.instance;
22
23 import fj.data.Either;
24 import org.junit.Before;
25 import org.junit.Test;
26 import org.mockito.ArgumentCaptor;
27 import org.mockito.InjectMocks;
28 import org.mockito.Mock;
29 import org.mockito.Mockito;
30 import org.mockito.MockitoAnnotations;
31 import org.openecomp.sdc.be.components.impl.exceptions.ByActionStatusComponentException;
32 import org.openecomp.sdc.be.components.impl.exceptions.ComponentException;
33 import org.openecomp.sdc.be.components.utils.ResourceBuilder;
34 import org.openecomp.sdc.be.dao.api.ActionStatus;
35 import org.openecomp.sdc.be.datatypes.enums.ComponentTypeEnum;
36 import org.openecomp.sdc.be.impl.ComponentsUtils;
37 import org.openecomp.sdc.be.model.Component;
38 import org.openecomp.sdc.be.model.ComponentInstance;
39 import org.openecomp.sdc.be.model.ComponentParametersView;
40 import org.openecomp.sdc.be.model.Resource;
41 import org.openecomp.sdc.be.model.Service;
42 import org.openecomp.sdc.be.model.User;
43 import org.openecomp.sdc.be.model.jsonjanusgraph.operations.ToscaOperationFacade;
44 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
45 import org.openecomp.sdc.exception.ResponseFormat;
46
47 import java.util.Arrays;
48
49 import static org.junit.Assert.assertEquals;
50 import static org.junit.Assert.assertFalse;
51 import static org.mockito.Mockito.verify;
52 import static org.mockito.Mockito.when;
53
54 public class ComponentInstanceMergeDataBusinessLogicTest {
55
56     @InjectMocks
57     private ComponentInstanceMergeDataBusinessLogic testInstance;
58
59     @Mock
60     private ToscaOperationFacade toscaOperationFacade;
61
62     @Mock
63     private ComponentsUtils componentsUtils;
64
65     @Mock
66     private ComponentInstanceMergeInterface componentInstanceMergeInterfaceMock1;
67
68     @Mock
69     private ComponentInstanceMergeInterface componentInstanceMergeInterfaceMock2;
70
71     @Before
72     public void setUp() throws Exception {
73         MockitoAnnotations.initMocks(this);
74         testInstance.setComponentInstancesMergeBLs(Arrays.asList(componentInstanceMergeInterfaceMock1, componentInstanceMergeInterfaceMock2));
75     }
76
77     @Test
78     public void saveAllDataBeforeDeleting_allInstanceMergeInterfacesAreCalled() throws Exception {
79         Component container = new Service();
80         ComponentInstance instance = new ComponentInstance();
81         Component instanceOriginResource = new Resource();
82         DataForMergeHolder dataForMergeHolder = testInstance.saveAllDataBeforeDeleting(container, instance, instanceOriginResource);
83         verify(componentInstanceMergeInterfaceMock1).saveDataBeforeMerge(dataForMergeHolder, container, instance, instanceOriginResource);
84         verify(componentInstanceMergeInterfaceMock2).saveDataBeforeMerge(dataForMergeHolder, container, instance, instanceOriginResource);
85     }
86
87     @Test
88     public void mergeComponentUserOrigData_allInstanceMergeInterfacesAreCalled() throws Exception {
89         ArgumentCaptor<ComponentParametersView> componentsFilterCapture = ArgumentCaptor.forClass(ComponentParametersView.class);
90         Service persistedService = new Service();
91         User user = new User();
92         DataForMergeHolder dataHolder = new DataForMergeHolder();
93         when(toscaOperationFacade.getToscaElement(Mockito.eq("newContainerId"), componentsFilterCapture.capture())).thenReturn(Either.left(persistedService));
94         when(componentInstanceMergeInterfaceMock1.mergeDataAfterCreate(user, dataHolder, persistedService, "instId")).thenReturn(persistedService);
95         when(componentInstanceMergeInterfaceMock2.mergeDataAfterCreate(user, dataHolder, persistedService, "instId")).thenReturn(persistedService);
96         Component mergeResult = testInstance.mergeComponentUserOrigData(user, dataHolder, new Service(), "newContainerId", "instId");
97         assertEquals(persistedService, mergeResult);
98         assertComponentFilter(componentsFilterCapture.getValue());
99     }
100
101     @Test(expected = ComponentException.class)
102     public void mergeComponentUserOrigData_failToGetPersistedComponent_doNotTryToMerge() throws Exception {
103         User user = new User();
104         DataForMergeHolder dataHolder = new DataForMergeHolder();
105         ResponseFormat rf = new ResponseFormat();
106         Resource container = new ResourceBuilder().setComponentType(ComponentTypeEnum.SERVICE).build();
107         when(toscaOperationFacade.getToscaElement(Mockito.eq("newContainerId"), Mockito.any(ComponentParametersView.class))).thenReturn(Either.right(StorageOperationStatus.GENERAL_ERROR));
108         when(componentsUtils.convertFromStorageResponse(StorageOperationStatus.GENERAL_ERROR, ComponentTypeEnum.SERVICE)).thenReturn(ActionStatus.GENERAL_ERROR);
109         when(componentsUtils.getResponseFormat(ActionStatus.GENERAL_ERROR)).thenReturn(rf);
110         testInstance.mergeComponentUserOrigData(user, dataHolder, container, "newContainerId", "instId");
111     }
112
113     @Test(expected = ComponentException.class)
114     public void mergeComponentUserOrigData_failOnOneMerge_doNotCallOtherMerge() throws Exception {
115         Service persistedService = new Service();
116         User user = new User();
117         DataForMergeHolder dataHolder = new DataForMergeHolder();
118         ResponseFormat rf = new ResponseFormat();
119         when(toscaOperationFacade.getToscaElement(Mockito.eq("newContainerId"), Mockito.any(ComponentParametersView.class))).thenReturn(Either.left(persistedService));
120         when(componentInstanceMergeInterfaceMock1.mergeDataAfterCreate(user, dataHolder, persistedService, "instId")).thenThrow(new ByActionStatusComponentException(ActionStatus.GENERAL_ERROR));
121         testInstance.mergeComponentUserOrigData(user, dataHolder, new Service(), "newContainerId", "instId");
122     }
123
124     private void assertComponentFilter(ComponentParametersView value) {
125         assertFalse(value.isIgnoreComponentInstances());
126         assertFalse(value.isIgnoreComponentInstancesProperties());
127         assertFalse(value.isIgnoreComponentInstancesInputs());
128         assertFalse(value.isIgnoreArtifacts());
129         assertFalse(value.isIgnoreComponentInstancesInterfaces());
130     }
131
132
133
134 }