2 * ============LICENSE_START=======================================================
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
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.openecomp.sdc.be.components;
23 import com.google.common.collect.Sets;
24 import fj.data.Either;
25 import org.junit.Before;
26 import org.mockito.Mockito;
27 import org.openecomp.sdc.ElementOperationMock;
28 import org.openecomp.sdc.be.auditing.impl.AuditingManager;
29 import org.openecomp.sdc.be.components.impl.ArtifactsBusinessLogic;
30 import org.openecomp.sdc.be.components.impl.ResponseFormatManager;
31 import org.openecomp.sdc.be.components.impl.ServiceBusinessLogic;
32 import org.openecomp.sdc.be.components.impl.generic.GenericTypeBusinessLogic;
33 import org.openecomp.sdc.be.config.ConfigurationManager;
34 import org.openecomp.sdc.be.dao.api.ActionStatus;
35 import org.openecomp.sdc.be.dao.cassandra.AuditCassandraDao;
36 import org.openecomp.sdc.be.dao.jsongraph.JanusGraphDao;
37 import org.openecomp.sdc.be.datatypes.elements.ForwardingPathDataDefinition;
38 import org.openecomp.sdc.be.datatypes.elements.ForwardingPathElementDataDefinition;
39 import org.openecomp.sdc.be.datatypes.enums.ComponentTypeEnum;
40 import org.openecomp.sdc.be.datatypes.enums.NodeTypeEnum;
41 import org.openecomp.sdc.be.impl.ComponentsUtils;
42 import org.openecomp.sdc.be.impl.WebAppContextWrapper;
43 import org.openecomp.sdc.be.model.*;
44 import org.openecomp.sdc.be.model.category.CategoryDefinition;
45 import org.openecomp.sdc.be.model.jsonjanusgraph.operations.ForwardingPathOperation;
46 import org.openecomp.sdc.be.model.jsonjanusgraph.operations.ToscaOperationFacade;
47 import org.openecomp.sdc.be.model.operations.api.IElementOperation;
48 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
49 import org.openecomp.sdc.be.model.operations.impl.CacheMangerOperation;
50 import org.openecomp.sdc.be.model.operations.impl.GraphLockOperation;
51 import org.openecomp.sdc.be.resources.data.auditing.ResourceAdminEvent;
52 import org.openecomp.sdc.be.user.Role;
53 import org.openecomp.sdc.be.user.UserBusinessLogic;
54 import org.openecomp.sdc.common.api.ArtifactGroupTypeEnum;
55 import org.openecomp.sdc.common.api.ConfigurationSource;
56 import org.openecomp.sdc.common.api.Constants;
57 import org.openecomp.sdc.common.datastructure.AuditingFieldsKey;
58 import org.openecomp.sdc.common.impl.ExternalConfiguration;
59 import org.openecomp.sdc.common.impl.FSConfigurationSource;
60 import org.springframework.web.context.WebApplicationContext;
62 import javax.servlet.ServletContext;
63 import java.util.ArrayList;
64 import java.util.HashMap;
65 import java.util.List;
68 import static org.mockito.ArgumentMatchers.any;
69 import static org.mockito.Mockito.when;
71 public abstract class BaseServiceBusinessLogicTest {
72 private static final String SERVICE_CATEGORY = "Mobility";
73 final ServletContext servletContext = Mockito.mock(ServletContext.class);
74 UserBusinessLogic mockUserAdmin = Mockito.mock(UserBusinessLogic.class);
75 WebAppContextWrapper webAppContextWrapper = Mockito.mock(WebAppContextWrapper.class);
76 WebApplicationContext webAppContext = Mockito.mock(WebApplicationContext.class);
77 ServiceBusinessLogic bl = new ServiceBusinessLogic();
78 ResponseFormatManager responseManager = null;
79 IElementOperation mockElementDao;
80 ComponentsUtils componentsUtils;
81 AuditCassandraDao auditingDao = Mockito.mock(AuditCassandraDao.class);
82 ArtifactsBusinessLogic artifactBl = Mockito.mock(ArtifactsBusinessLogic.class);
83 GraphLockOperation graphLockOperation = Mockito.mock(GraphLockOperation.class);
84 JanusGraphDao mockJanusGraphDao = Mockito.mock(JanusGraphDao.class);
85 ToscaOperationFacade toscaOperationFacade = Mockito.mock(ToscaOperationFacade.class);
86 CacheMangerOperation cacheManager = Mockito.mock(CacheMangerOperation.class);
87 GenericTypeBusinessLogic genericTypeBusinessLogic = Mockito.mock(GenericTypeBusinessLogic.class);
88 ForwardingPathOperation forwardingPathOperation = Mockito.mock(ForwardingPathOperation.class);
91 Service serviceResponse = null;
92 Resource genericService = null;
94 protected static final String CERTIFIED_VERSION = "1.0";
95 protected static final String UNCERTIFIED_VERSION = "0.2";
96 protected static final String COMPONNET_ID = "myUniqueId";
97 protected static final String GENERIC_SERVICE_NAME = "org.openecomp.resource.abstract.nodes.service";
98 protected static Map<AuditingFieldsKey, Object> FILTER_MAP_CERTIFIED_VERSION = new HashMap<>();
99 protected static Map<AuditingFieldsKey, Object> FILTER_MAP_UNCERTIFIED_VERSION_CURR = new HashMap<>();
100 protected static Map<AuditingFieldsKey, Object> FILTER_MAP_UNCERTIFIED_VERSION_PREV = new HashMap<>();
102 public void setup() {
104 ExternalConfiguration.setAppName("catalog-be");
105 // init Configuration
106 String appConfigDir = "src/test/resources/config/catalog-be";
107 ConfigurationSource configurationSource = new FSConfigurationSource(ExternalConfiguration.getChangeListener(), appConfigDir);
108 ConfigurationManager configurationManager = new ConfigurationManager(configurationSource);
109 componentsUtils = new ComponentsUtils(Mockito.mock(AuditingManager.class));
112 mockElementDao = new ElementOperationMock();
114 // User data and management
116 user.setUserId("jh0003");
117 user.setFirstName("Jimmi");
118 user.setLastName("Hendrix");
119 user.setRole(Role.ADMIN.name());
121 Either<User, ActionStatus> eitherGetUser = Either.left(user);
122 when(mockUserAdmin.getUser("jh0003", false)).thenReturn(eitherGetUser);
124 // Servlet Context attributes
125 when(servletContext.getAttribute(Constants.CONFIGURATION_MANAGER_ATTR)).thenReturn(configurationManager);
126 when(servletContext.getAttribute(Constants.WEB_APPLICATION_CONTEXT_WRAPPER_ATTR)).thenReturn(webAppContextWrapper);
127 when(webAppContextWrapper.getWebAppContext(servletContext)).thenReturn(webAppContext);
128 when(webAppContext.getBean(IElementOperation.class)).thenReturn(mockElementDao);
129 when(graphLockOperation.lockComponent(Mockito.anyString(), Mockito.eq(NodeTypeEnum.Service))).thenReturn(StorageOperationStatus.OK);
130 when(graphLockOperation.lockComponentByName(Mockito.anyString(), Mockito.eq(NodeTypeEnum.Service))).thenReturn(StorageOperationStatus.OK);
132 // artifact bussinesslogic
133 ArtifactDefinition artifactDef = new ArtifactDefinition();
134 when(artifactBl.createArtifactPlaceHolderInfo(Mockito.anyString(), Mockito.anyString(), Mockito.anyMap(), Mockito.any(User.class), Mockito.any(ArtifactGroupTypeEnum.class))).thenReturn(artifactDef);
137 serviceResponse = createServiceObject(true);
138 Either<Component, StorageOperationStatus> eitherCreate = Either.left(serviceResponse);
139 when(toscaOperationFacade.createToscaComponent(Mockito.any(Component.class))).thenReturn(eitherCreate);
140 Either<Boolean, StorageOperationStatus> eitherCount = Either.left(false);
141 when(toscaOperationFacade.validateComponentNameExists("Service", null, ComponentTypeEnum.SERVICE)).thenReturn(eitherCount);
142 Either<Boolean, StorageOperationStatus> eitherCountExist = Either.left(true);
143 when(toscaOperationFacade.validateComponentNameExists("alreadyExist", null, ComponentTypeEnum.SERVICE)).thenReturn(eitherCountExist);
145 genericService = setupGenericServiceMock();
146 Either<Resource, StorageOperationStatus> findLatestGeneric = Either.left(genericService);
147 when(toscaOperationFacade.getLatestCertifiedNodeTypeByToscaResourceName(GENERIC_SERVICE_NAME)).thenReturn(findLatestGeneric);
150 when(forwardingPathOperation.addForwardingPath(any(),any())).thenReturn(Either.left(createMockPath()));
151 when(forwardingPathOperation.updateForwardingPath(any(),any())).thenReturn(Either.left(createMockPath()));
152 when(forwardingPathOperation.deleteForwardingPath(any(),any())).thenReturn(Either.left(Sets.newHashSet("Wow-It-Works")));
153 when(toscaOperationFacade.getToscaElement("delete_forward_test")).thenReturn(Either.left(createServiceObject(true)));
155 bl = new ServiceBusinessLogic();
156 bl.setElementDao(mockElementDao);
157 bl.setUserAdmin(mockUserAdmin);
158 bl.setArtifactBl(artifactBl);
159 bl.setGraphLockOperation(graphLockOperation);
160 bl.setJanusGraphGenericDao(mockJanusGraphDao);
161 bl.setToscaOperationFacade(toscaOperationFacade);
162 bl.setGenericTypeBusinessLogic(genericTypeBusinessLogic);
163 bl.setComponentsUtils(componentsUtils);
164 bl.setCassandraAuditingDao(auditingDao);
165 bl.setCacheManagerOperation(cacheManager);
166 bl.setForwardingPathOperation(forwardingPathOperation);
167 bl.setToscaOperationFacade(toscaOperationFacade);
168 mockAuditingDaoLogic();
170 responseManager = ResponseFormatManager.getInstance();
174 protected Component createNewService() {
176 Service service = new Service();
178 service.setName("serviceName");
179 service.setUniqueId("serviceUniqueId");
180 List<ComponentInstance> componentInstances = new ArrayList<>();
181 ComponentInstance ci;
182 for(int i= 0; i<listSize; ++i){
183 ci = new ComponentInstance();
184 ci.setName("ciName" + i);
185 ci.setUniqueId("ciId" + i);
186 List<GroupInstance> groupInstances= new ArrayList<>();
188 for(int j = 0; j<listSize; ++j){
189 gi = new GroupInstance();
190 gi.setName(ci.getName( )+ "giName" + j);
191 gi.setUniqueId(ci.getName() + "giId" + j);
192 groupInstances.add(gi);
194 ci.setGroupInstances(groupInstances);
195 componentInstances.add(ci);
197 service.setComponentInstances(componentInstances);
201 private void mockAuditingDaoLogic() {
202 FILTER_MAP_CERTIFIED_VERSION.put(AuditingFieldsKey.AUDIT_SERVICE_INSTANCE_ID, COMPONNET_ID);
203 FILTER_MAP_UNCERTIFIED_VERSION_CURR.put(AuditingFieldsKey.AUDIT_SERVICE_INSTANCE_ID, COMPONNET_ID);
204 FILTER_MAP_UNCERTIFIED_VERSION_PREV.put(AuditingFieldsKey.AUDIT_SERVICE_INSTANCE_ID, COMPONNET_ID);
206 FILTER_MAP_UNCERTIFIED_VERSION_CURR.put(AuditingFieldsKey.AUDIT_RESOURCE_CURR_VERSION, UNCERTIFIED_VERSION);
207 FILTER_MAP_UNCERTIFIED_VERSION_PREV.put(AuditingFieldsKey.AUDIT_RESOURCE_PREV_VERSION, UNCERTIFIED_VERSION);
209 final ResourceAdminEvent createResourceAudit = new ResourceAdminEvent();
210 createResourceAudit.setModifier("Carlos Santana(cs0008)");
211 createResourceAudit.setCurrState("NOT_CERTIFIED_CHECKOUT");
212 createResourceAudit.setCurrVersion("0.1");
213 createResourceAudit.setServiceInstanceId("82eddd99-0bd9-4742-ab0a-1bdb5e262a05");
214 createResourceAudit.setRequestId("3e65cea1-7403-4bc7-b461-e2544d83799f");
215 createResourceAudit.setDesc("OK");
216 createResourceAudit.setResourceType("Resource");
217 createResourceAudit.setStatus("201");
218 createResourceAudit.setPrevVersion("");
219 createResourceAudit.setAction("Create");
220 createResourceAudit.setPrevState("");
221 createResourceAudit.setResourceName("MyTestResource");
223 final ResourceAdminEvent checkInResourceAudit = new ResourceAdminEvent();
224 checkInResourceAudit.setModifier("Carlos Santana(cs0008)");
225 checkInResourceAudit.setCurrState("NOT_CERTIFIED_CHECKIN");
226 checkInResourceAudit.setCurrVersion("0.1");
227 checkInResourceAudit.setServiceInstanceId("82eddd99-0bd9-4742-ab0a-1bdb5e262a05");
228 checkInResourceAudit.setRequestId("ffacbf5d-eeb1-43c6-a310-37fe7e1cc091");
229 checkInResourceAudit.setDesc("OK");
230 checkInResourceAudit.setComment("Stam");
231 checkInResourceAudit.setResourceType("Resource");
232 checkInResourceAudit.setStatus("200");
233 checkInResourceAudit.setPrevVersion("0.1");
234 checkInResourceAudit.setAction("Checkin");
235 checkInResourceAudit.setPrevState("NOT_CERTIFIED_CHECKOUT");
236 checkInResourceAudit.setResourceName("MyTestResource");
238 final ResourceAdminEvent checkOutResourceAudit = new ResourceAdminEvent();
239 checkOutResourceAudit.setModifier("Carlos Santana(cs0008)");
240 checkOutResourceAudit.setCurrState("NOT_CERTIFIED_CHECKOUT");
241 checkOutResourceAudit.setCurrVersion("0.2");
242 checkOutResourceAudit.setServiceInstanceId("82eddd99-0bd9-4742-ab0a-1bdb5e262a05");
243 checkOutResourceAudit.setRequestId("7add5078-4c16-4d74-9691-cc150e3c96b8");
244 checkOutResourceAudit.setDesc("OK");
245 checkOutResourceAudit.setComment("");
246 checkOutResourceAudit.setResourceType("Resource");
247 checkOutResourceAudit.setStatus("200");
248 checkOutResourceAudit.setPrevVersion("0.1");
249 checkOutResourceAudit.setAction("Checkout");
250 checkOutResourceAudit.setPrevState("NOT_CERTIFIED_CHECKIN");
251 checkOutResourceAudit.setResourceName("MyTestResource");
252 List<ResourceAdminEvent> list = new ArrayList<ResourceAdminEvent>() {
254 add(createResourceAudit);
255 add(checkInResourceAudit);
256 add(checkOutResourceAudit);
259 Either<List<ResourceAdminEvent>, ActionStatus> result = Either.left(list);
260 Mockito.when(auditingDao.getByServiceInstanceId(Mockito.anyString())).thenReturn(result);
262 List<ResourceAdminEvent> listPrev = new ArrayList<>();
263 Either<List<ResourceAdminEvent>, ActionStatus> resultPrev = Either.left(listPrev);
264 Mockito.when(auditingDao.getAuditByServiceIdAndPrevVersion(Mockito.anyString(), Mockito.anyString())).thenReturn(resultPrev);
266 List<ResourceAdminEvent> listCurr = new ArrayList<ResourceAdminEvent>() {
268 add(checkOutResourceAudit);
271 Either<List<ResourceAdminEvent>, ActionStatus> resultCurr = Either.left(listCurr);
272 Mockito.when(auditingDao.getAuditByServiceIdAndCurrVersion(Mockito.anyString(), Mockito.anyString())).thenReturn(resultCurr);
275 protected Service createServiceObject(boolean afterCreate) {
276 Service service = new Service();
277 service.setName("Service");
278 CategoryDefinition category = new CategoryDefinition();
279 category.setName(SERVICE_CATEGORY);
280 List<CategoryDefinition> categories = new ArrayList<>();
281 categories.add(category);
282 service.setCategories(categories);
284 service.setDescription("description");
285 List<String> tgs = new ArrayList<>();
286 tgs.add(service.getName());
287 service.setTags(tgs);
288 service.setIcon("MyIcon");
289 service.setContactId("aa1234");
290 service.setProjectCode("12345");
293 service.setVersion("0.1");
294 service.setUniqueId(service.getName() + ":" + service.getVersion());
295 service.setCreatorUserId(user.getUserId());
296 service.setCreatorFullName(user.getFirstName() + " " + user.getLastName());
301 protected Resource setupGenericServiceMock(){
302 Resource genericService = new Resource();
303 genericService.setVersion("1.0");
304 genericService.setToscaResourceName(GENERIC_SERVICE_NAME);
305 return genericService;
308 protected static ForwardingPathDataDefinition forwardingPathDataDefinition;
310 protected static ForwardingPathDataDefinition createMockPath() {
311 if (forwardingPathDataDefinition != null){
312 return forwardingPathDataDefinition ;
314 forwardingPathDataDefinition = new ForwardingPathDataDefinition("Yoyo");
315 forwardingPathDataDefinition.setUniqueId(java.util.UUID.randomUUID().toString());
316 forwardingPathDataDefinition.setDestinationPortNumber("414155");
317 forwardingPathDataDefinition.setProtocol("http");
318 org.openecomp.sdc.be.datatypes.elements.ListDataDefinition<org.openecomp.sdc.be.datatypes.elements.ForwardingPathElementDataDefinition> forwardingPathElementDataDefinitionListDataDefinition = new org.openecomp.sdc.be.datatypes.elements.ListDataDefinition<>();
319 forwardingPathElementDataDefinitionListDataDefinition.add(new ForwardingPathElementDataDefinition("fromNode","toNode", "333","444","2222","5555"));
320 forwardingPathElementDataDefinitionListDataDefinition.add(new ForwardingPathElementDataDefinition("toNode","toNode2", "4444","44444","4","44"));
321 forwardingPathDataDefinition.setPathElements(forwardingPathElementDataDefinitionListDataDefinition);
322 return forwardingPathDataDefinition;