2 * ============LICENSE_START=======================================================
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
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=========================================================
19 * Modifications copyright (c) 2019 Nokia
20 * ================================================================================
22 package org.openecomp.sdc.be.components;
24 import com.google.common.collect.Sets;
25 import fj.data.Either;
26 import org.junit.Before;
27 import org.mockito.Mockito;
28 import org.openecomp.sdc.ElementOperationMock;
29 import org.openecomp.sdc.be.auditing.impl.AuditingManager;
30 import org.openecomp.sdc.be.components.distribution.engine.IDistributionEngine;
31 import org.openecomp.sdc.be.components.impl.ArtifactsBusinessLogic;
32 import org.openecomp.sdc.be.components.impl.ComponentInstanceBusinessLogic;
33 import org.openecomp.sdc.be.components.impl.ResponseFormatManager;
34 import org.openecomp.sdc.be.components.impl.ServiceBusinessLogic;
35 import org.openecomp.sdc.be.components.impl.ServiceBusinessLogicTest;
36 import org.openecomp.sdc.be.components.impl.generic.GenericTypeBusinessLogic;
37 import org.openecomp.sdc.be.components.path.ForwardingPathValidator;
38 import org.openecomp.sdc.be.components.utils.ComponentBusinessLogicMock;
39 import org.openecomp.sdc.be.components.validation.NodeFilterValidator;
40 import org.openecomp.sdc.be.components.validation.ServiceDistributionValidation;
41 import org.openecomp.sdc.be.config.ConfigurationManager;
42 import org.openecomp.sdc.be.dao.api.ActionStatus;
43 import org.openecomp.sdc.be.dao.cassandra.AuditCassandraDao;
44 import org.openecomp.sdc.be.dao.jsongraph.JanusGraphDao;
45 import org.openecomp.sdc.be.datamodel.utils.UiComponentDataConverter;
46 import org.openecomp.sdc.be.datatypes.elements.ForwardingPathDataDefinition;
47 import org.openecomp.sdc.be.datatypes.elements.ForwardingPathElementDataDefinition;
48 import org.openecomp.sdc.be.datatypes.enums.ComponentTypeEnum;
49 import org.openecomp.sdc.be.datatypes.enums.NodeTypeEnum;
50 import org.openecomp.sdc.be.impl.ComponentsUtils;
51 import org.openecomp.sdc.be.impl.WebAppContextWrapper;
52 import org.openecomp.sdc.be.model.ArtifactDefinition;
53 import org.openecomp.sdc.be.model.Component;
54 import org.openecomp.sdc.be.model.ComponentInstance;
55 import org.openecomp.sdc.be.model.GroupInstance;
56 import org.openecomp.sdc.be.model.Resource;
57 import org.openecomp.sdc.be.model.Service;
58 import org.openecomp.sdc.be.model.User;
59 import org.openecomp.sdc.be.model.category.CategoryDefinition;
60 import org.openecomp.sdc.be.model.jsonjanusgraph.operations.ForwardingPathOperation;
61 import org.openecomp.sdc.be.model.jsonjanusgraph.operations.NodeFilterOperation;
62 import org.openecomp.sdc.be.model.jsonjanusgraph.operations.ToscaOperationFacade;
63 import org.openecomp.sdc.be.model.operations.api.IElementOperation;
64 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
65 import org.openecomp.sdc.be.model.operations.impl.GraphLockOperation;
66 import org.openecomp.sdc.be.resources.data.auditing.ResourceAdminEvent;
67 import org.openecomp.sdc.be.user.Role;
68 import org.openecomp.sdc.be.user.UserBusinessLogic;
69 import org.openecomp.sdc.common.api.ArtifactGroupTypeEnum;
70 import org.openecomp.sdc.common.api.ConfigurationSource;
71 import org.openecomp.sdc.common.api.Constants;
72 import org.openecomp.sdc.common.datastructure.AuditingFieldsKey;
73 import org.openecomp.sdc.common.impl.ExternalConfiguration;
74 import org.openecomp.sdc.common.impl.FSConfigurationSource;
75 import org.slf4j.Logger;
76 import org.slf4j.LoggerFactory;
77 import org.springframework.web.context.WebApplicationContext;
79 import javax.servlet.ServletContext;
80 import java.util.ArrayList;
81 import java.util.HashMap;
82 import java.util.List;
85 import static org.mockito.ArgumentMatchers.any;
86 import static org.mockito.Mockito.when;
88 public abstract class BaseServiceBusinessLogicTest extends ComponentBusinessLogicMock {
89 private static final Logger log = LoggerFactory.getLogger(ServiceBusinessLogicTest.class);
90 private static final String SERVICE_CATEGORY = "Mobility";
91 private final ServletContext servletContext = Mockito.mock(ServletContext.class);
92 private UserBusinessLogic mockUserAdmin = Mockito.mock(UserBusinessLogic.class);
93 private WebAppContextWrapper webAppContextWrapper = Mockito.mock(WebAppContextWrapper.class);
94 private WebApplicationContext webAppContext = Mockito.mock(WebApplicationContext.class);
95 protected final IDistributionEngine distributionEngine = Mockito.mock(IDistributionEngine.class);
96 protected final ComponentInstanceBusinessLogic componentInstanceBusinessLogic = Mockito.mock(ComponentInstanceBusinessLogic.class);
97 protected final ServiceDistributionValidation serviceDistributionValidation = Mockito.mock(ServiceDistributionValidation.class);
98 protected final ForwardingPathValidator forwardingPathValidator = Mockito.mock(ForwardingPathValidator.class);
99 protected final UiComponentDataConverter uiComponentDataConverter = Mockito.mock(UiComponentDataConverter.class);
100 protected final NodeFilterOperation serviceFilterOperation = Mockito.mock(NodeFilterOperation.class);
101 protected final NodeFilterValidator serviceFilterValidator = Mockito.mock(NodeFilterValidator.class);
102 private ServiceBusinessLogic bl;
103 private ResponseFormatManager responseManager = null;
104 private IElementOperation mockElementDao;
105 private ComponentsUtils componentsUtils;
106 private AuditCassandraDao auditingDao = Mockito.mock(AuditCassandraDao.class);
107 private ArtifactsBusinessLogic artifactBl = Mockito.mock(ArtifactsBusinessLogic.class);
108 private GraphLockOperation graphLockOperation = Mockito.mock(GraphLockOperation.class);
109 private JanusGraphDao mockJanusGraphDao = Mockito.mock(JanusGraphDao.class);
110 private ToscaOperationFacade toscaOperationFacade = Mockito.mock(ToscaOperationFacade.class);
111 private GenericTypeBusinessLogic genericTypeBusinessLogic = Mockito.mock(GenericTypeBusinessLogic.class);
112 private ForwardingPathOperation forwardingPathOperation = Mockito.mock(ForwardingPathOperation.class);
115 Service serviceResponse = null;
116 Resource genericService = null;
118 protected static final String CERTIFIED_VERSION = "1.0";
119 protected static final String UNCERTIFIED_VERSION = "0.2";
120 protected static final String COMPONNET_ID = "myUniqueId";
121 protected static final String GENERIC_SERVICE_NAME = "org.openecomp.resource.abstract.nodes.service";
122 protected static Map<AuditingFieldsKey, Object> FILTER_MAP_CERTIFIED_VERSION = new HashMap<>();
123 protected static Map<AuditingFieldsKey, Object> FILTER_MAP_UNCERTIFIED_VERSION_CURR = new HashMap<>();
124 protected static Map<AuditingFieldsKey, Object> FILTER_MAP_UNCERTIFIED_VERSION_PREV = new HashMap<>();
126 public void setup() {
128 ExternalConfiguration.setAppName("catalog-be");
129 // init Configuration
130 String appConfigDir = "src/test/resources/config/catalog-be";
131 ConfigurationSource configurationSource = new FSConfigurationSource(ExternalConfiguration.getChangeListener(), appConfigDir);
132 ConfigurationManager configurationManager = new ConfigurationManager(configurationSource);
133 componentsUtils = new ComponentsUtils(Mockito.mock(AuditingManager.class));
136 mockElementDao = new ElementOperationMock();
138 // User data and management
140 user.setUserId("jh0003");
141 user.setFirstName("Jimmi");
142 user.setLastName("Hendrix");
143 user.setRole(Role.ADMIN.name());
145 when(mockUserAdmin.getUser("jh0003", false)).thenReturn(user);
147 // Servlet Context attributes
148 when(servletContext.getAttribute(Constants.CONFIGURATION_MANAGER_ATTR)).thenReturn(configurationManager);
149 // when(servletContext.getAttribute(Constants.SERVICE_OPERATION_MANAGER)).thenReturn(new ServiceOperation());
150 when(servletContext.getAttribute(Constants.WEB_APPLICATION_CONTEXT_WRAPPER_ATTR)).thenReturn(webAppContextWrapper);
151 when(webAppContextWrapper.getWebAppContext(servletContext)).thenReturn(webAppContext);
152 when(webAppContext.getBean(IElementOperation.class)).thenReturn(mockElementDao);
153 when(graphLockOperation.lockComponent(Mockito.anyString(), Mockito.eq(NodeTypeEnum.Service))).thenReturn(StorageOperationStatus.OK);
154 when(graphLockOperation.lockComponentByName(Mockito.anyString(), Mockito.eq(NodeTypeEnum.Service))).thenReturn(StorageOperationStatus.OK);
156 // artifact bussinesslogic
157 ArtifactDefinition artifactDef = new ArtifactDefinition();
158 when(artifactBl.createArtifactPlaceHolderInfo(Mockito.anyString(), Mockito.anyString(), Mockito.anyMap(), Mockito.any(User.class), Mockito.any(ArtifactGroupTypeEnum.class))).thenReturn(artifactDef);
161 serviceResponse = createServiceObject(true);
162 Either<Component, StorageOperationStatus> eitherCreate = Either.left(serviceResponse);
163 when(toscaOperationFacade.createToscaComponent(Mockito.any(Component.class))).thenReturn(eitherCreate);
164 Either<Boolean, StorageOperationStatus> eitherCount = Either.left(false);
165 when(toscaOperationFacade.validateComponentNameExists("Service", null, ComponentTypeEnum.SERVICE)).thenReturn(eitherCount);
166 Either<Boolean, StorageOperationStatus> eitherCountExist = Either.left(true);
167 when(toscaOperationFacade.validateComponentNameExists("alreadyExist", null, ComponentTypeEnum.SERVICE)).thenReturn(eitherCountExist);
169 genericService = setupGenericServiceMock();
170 Either<Resource, StorageOperationStatus> findLatestGeneric = Either.left(genericService);
171 when(toscaOperationFacade.getLatestCertifiedNodeTypeByToscaResourceName(GENERIC_SERVICE_NAME)).thenReturn(findLatestGeneric);
174 when(forwardingPathOperation.addForwardingPath(any(),any())).thenReturn(Either.left(createMockPath()));
175 when(forwardingPathOperation.updateForwardingPath(any(),any())).thenReturn(Either.left(createMockPath()));
176 when(forwardingPathOperation.deleteForwardingPath(any(),any())).thenReturn(Either.left(Sets.newHashSet("Wow-It-Works")));
177 when(toscaOperationFacade.getToscaElement("delete_forward_test")).thenReturn(Either.left(createServiceObject(true)));
179 bl = new ServiceBusinessLogic(elementDao, groupOperation, groupInstanceOperation,
180 groupTypeOperation, groupBusinessLogic, interfaceOperation, interfaceLifecycleTypeOperation,
181 artifactsBusinessLogic, distributionEngine, componentInstanceBusinessLogic,
182 serviceDistributionValidation, forwardingPathValidator, uiComponentDataConverter,
183 serviceFilterOperation, serviceFilterValidator, artifactToscaOperation, componentContactIdValidator, componentNameValidator,
184 componentTagsValidator, componentValidator, componentIconValidator, componentProjectCodeValidator, componentDescriptionValidator);
185 bl.setUserAdmin(mockUserAdmin);
186 bl.setGraphLockOperation(graphLockOperation);
187 bl.setJanusGraphDao(mockJanusGraphDao);
188 bl.setToscaOperationFacade(toscaOperationFacade);
189 bl.setGenericTypeBusinessLogic(genericTypeBusinessLogic);
190 bl.setComponentsUtils(componentsUtils);
191 bl.setCassandraAuditingDao(auditingDao);
192 bl.setForwardingPathOperation(forwardingPathOperation);
193 bl.setToscaOperationFacade(toscaOperationFacade);
194 mockAuditingDaoLogic();
196 responseManager = ResponseFormatManager.getInstance();
200 protected Component createNewService() {
202 Service service = new Service();
204 service.setName("serviceName");
205 service.setUniqueId("serviceUniqueId");
206 List<ComponentInstance> componentInstances = new ArrayList<>();
207 ComponentInstance ci;
208 for(int i= 0; i<listSize; ++i){
209 ci = new ComponentInstance();
210 ci.setName("ciName" + i);
211 ci.setUniqueId("ciId" + i);
212 List<GroupInstance> groupInstances= new ArrayList<>();
214 for(int j = 0; j<listSize; ++j){
215 gi = new GroupInstance();
216 gi.setName(ci.getName( )+ "giName" + j);
217 gi.setUniqueId(ci.getName() + "giId" + j);
218 groupInstances.add(gi);
220 ci.setGroupInstances(groupInstances);
221 componentInstances.add(ci);
223 service.setComponentInstances(componentInstances);
227 private void mockAuditingDaoLogic() {
228 FILTER_MAP_CERTIFIED_VERSION.put(AuditingFieldsKey.AUDIT_SERVICE_INSTANCE_ID, COMPONNET_ID);
229 FILTER_MAP_UNCERTIFIED_VERSION_CURR.put(AuditingFieldsKey.AUDIT_SERVICE_INSTANCE_ID, COMPONNET_ID);
230 FILTER_MAP_UNCERTIFIED_VERSION_PREV.put(AuditingFieldsKey.AUDIT_SERVICE_INSTANCE_ID, COMPONNET_ID);
232 FILTER_MAP_UNCERTIFIED_VERSION_CURR.put(AuditingFieldsKey.AUDIT_RESOURCE_CURR_VERSION, UNCERTIFIED_VERSION);
233 FILTER_MAP_UNCERTIFIED_VERSION_PREV.put(AuditingFieldsKey.AUDIT_RESOURCE_PREV_VERSION, UNCERTIFIED_VERSION);
235 final ResourceAdminEvent createResourceAudit = new ResourceAdminEvent();
236 createResourceAudit.setModifier("Carlos Santana(cs0008)");
237 createResourceAudit.setCurrState("NOT_CERTIFIED_CHECKOUT");
238 createResourceAudit.setCurrVersion("0.1");
239 createResourceAudit.setServiceInstanceId("82eddd99-0bd9-4742-ab0a-1bdb5e262a05");
240 createResourceAudit.setRequestId("3e65cea1-7403-4bc7-b461-e2544d83799f");
241 createResourceAudit.setDesc("OK");
242 createResourceAudit.setResourceType("Resource");
243 createResourceAudit.setStatus("201");
244 createResourceAudit.setPrevVersion("");
245 createResourceAudit.setAction("Create");
246 // fields.put("TIMESTAMP", "2015-11-22 09:19:12.977");
247 createResourceAudit.setPrevState("");
248 createResourceAudit.setResourceName("MyTestResource");
249 // createResourceAudit.setFields(fields);
251 final ResourceAdminEvent checkInResourceAudit = new ResourceAdminEvent();
252 checkInResourceAudit.setModifier("Carlos Santana(cs0008)");
253 checkInResourceAudit.setCurrState("NOT_CERTIFIED_CHECKIN");
254 checkInResourceAudit.setCurrVersion("0.1");
255 checkInResourceAudit.setServiceInstanceId("82eddd99-0bd9-4742-ab0a-1bdb5e262a05");
256 checkInResourceAudit.setRequestId("ffacbf5d-eeb1-43c6-a310-37fe7e1cc091");
257 checkInResourceAudit.setDesc("OK");
258 checkInResourceAudit.setComment("Stam");
259 checkInResourceAudit.setResourceType("Resource");
260 checkInResourceAudit.setStatus("200");
261 checkInResourceAudit.setPrevVersion("0.1");
262 checkInResourceAudit.setAction("Checkin");
263 // fields.put("TIMESTAMP", "2015-11-22 09:25:03.797");
264 checkInResourceAudit.setPrevState("NOT_CERTIFIED_CHECKOUT");
265 checkInResourceAudit.setResourceName("MyTestResource");
267 final ResourceAdminEvent checkOutResourceAudit = new ResourceAdminEvent();
268 checkOutResourceAudit.setModifier("Carlos Santana(cs0008)");
269 checkOutResourceAudit.setCurrState("NOT_CERTIFIED_CHECKOUT");
270 checkOutResourceAudit.setCurrVersion("0.2");
271 checkOutResourceAudit.setServiceInstanceId("82eddd99-0bd9-4742-ab0a-1bdb5e262a05");
272 checkOutResourceAudit.setRequestId("7add5078-4c16-4d74-9691-cc150e3c96b8");
273 checkOutResourceAudit.setDesc("OK");
274 checkOutResourceAudit.setComment("");
275 checkOutResourceAudit.setResourceType("Resource");
276 checkOutResourceAudit.setStatus("200");
277 checkOutResourceAudit.setPrevVersion("0.1");
278 checkOutResourceAudit.setAction("Checkout");
279 // fields.put("TIMESTAMP", "2015-11-22 09:39:41.024");
280 checkOutResourceAudit.setPrevState("NOT_CERTIFIED_CHECKIN");
281 checkOutResourceAudit.setResourceName("MyTestResource");
282 // checkOutResourceAudit.setFields(fields);
284 List<ResourceAdminEvent> list = new ArrayList<ResourceAdminEvent>() {
286 add(createResourceAudit);
287 add(checkInResourceAudit);
288 add(checkOutResourceAudit);
291 Either<List<ResourceAdminEvent>, ActionStatus> result = Either.left(list);
292 Mockito.when(auditingDao.getByServiceInstanceId(Mockito.anyString())).thenReturn(result);
294 List<ResourceAdminEvent> listPrev = new ArrayList<>();
295 Either<List<ResourceAdminEvent>, ActionStatus> resultPrev = Either.left(listPrev);
296 Mockito.when(auditingDao.getAuditByServiceIdAndPrevVersion(Mockito.anyString(), Mockito.anyString())).thenReturn(resultPrev);
298 List<ResourceAdminEvent> listCurr = new ArrayList<ResourceAdminEvent>() {
300 add(checkOutResourceAudit);
303 Either<List<ResourceAdminEvent>, ActionStatus> resultCurr = Either.left(listCurr);
304 Mockito.when(auditingDao.getAuditByServiceIdAndCurrVersion(Mockito.anyString(), Mockito.anyString())).thenReturn(resultCurr);
308 protected Service createServiceObject(boolean afterCreate) {
309 Service service = new Service();
310 service.setName("Service");
311 CategoryDefinition category = new CategoryDefinition();
312 category.setName(SERVICE_CATEGORY);
313 List<CategoryDefinition> categories = new ArrayList<>();
314 categories.add(category);
315 service.setCategories(categories);
317 service.setDescription("description");
318 List<String> tgs = new ArrayList<>();
319 tgs.add(service.getName());
320 service.setTags(tgs);
321 // service.setVendorName("Motorola");
322 // service.setVendorRelease("1.0.0");
323 service.setIcon("MyIcon");
324 // service.setState(LifecycleStateEnum.NOT_CERTIFIED_CHECKOUT);
325 service.setContactId("aa1234");
326 service.setProjectCode("12345");
329 service.setVersion("0.1");
330 service.setUniqueId(service.getName() + ":" + service.getVersion());
331 service.setCreatorUserId(user.getUserId());
332 service.setCreatorFullName(user.getFirstName() + " " + user.getLastName());
337 protected Resource setupGenericServiceMock(){
338 Resource genericService = new Resource();
339 genericService.setVersion("1.0");
340 genericService.setToscaResourceName(GENERIC_SERVICE_NAME);
341 return genericService;
344 protected static ForwardingPathDataDefinition forwardingPathDataDefinition;
346 protected static ForwardingPathDataDefinition createMockPath() {
347 if (forwardingPathDataDefinition != null){
348 return forwardingPathDataDefinition ;
350 forwardingPathDataDefinition = new ForwardingPathDataDefinition("Yoyo");
351 forwardingPathDataDefinition.setUniqueId(java.util.UUID.randomUUID().toString());
352 forwardingPathDataDefinition.setDestinationPortNumber("414155");
353 forwardingPathDataDefinition.setProtocol("http");
354 org.openecomp.sdc.be.datatypes.elements.ListDataDefinition<org.openecomp.sdc.be.datatypes.elements.ForwardingPathElementDataDefinition> forwardingPathElementDataDefinitionListDataDefinition = new org.openecomp.sdc.be.datatypes.elements.ListDataDefinition<>();
355 forwardingPathElementDataDefinitionListDataDefinition.add(new ForwardingPathElementDataDefinition("fromNode","toNode", "333","444","2222","5555"));
356 forwardingPathElementDataDefinitionListDataDefinition.add(new ForwardingPathElementDataDefinition("toNode","toNode2", "4444","44444","4","44"));
357 forwardingPathDataDefinition.setPathElements(forwardingPathElementDataDefinitionListDataDefinition);
358 return forwardingPathDataDefinition;