2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2020 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.impl;
23 import static org.junit.Assert.assertEquals;
24 import static org.mockito.ArgumentMatchers.anyString;
25 import static org.mockito.ArgumentMatchers.eq;
26 import static org.mockito.Mockito.when;
28 import fj.data.Either;
29 import java.util.ArrayList;
30 import java.util.Arrays;
31 import java.util.Collections;
32 import java.util.List;
33 import javax.servlet.ServletContext;
34 import org.junit.Before;
35 import org.mockito.Mockito;
36 import org.openecomp.sdc.ElementOperationMock;
37 import org.openecomp.sdc.be.auditing.impl.AuditingManager;
38 import org.openecomp.sdc.be.components.distribution.engine.DistributionEngine;
39 import org.openecomp.sdc.be.components.impl.exceptions.ComponentException;
40 import org.openecomp.sdc.be.components.impl.generic.GenericTypeBusinessLogic;
41 import org.openecomp.sdc.be.components.path.ForwardingPathValidator;
42 import org.openecomp.sdc.be.components.validation.ServiceDistributionValidation;
43 import org.openecomp.sdc.be.components.validation.UserValidations;
44 import org.openecomp.sdc.be.components.validation.component.ComponentContactIdValidator;
45 import org.openecomp.sdc.be.components.validation.component.ComponentDescriptionValidator;
46 import org.openecomp.sdc.be.components.validation.component.ComponentFieldValidator;
47 import org.openecomp.sdc.be.components.validation.component.ComponentIconValidator;
48 import org.openecomp.sdc.be.components.validation.component.ComponentNameValidator;
49 import org.openecomp.sdc.be.components.validation.component.ComponentProjectCodeValidator;
50 import org.openecomp.sdc.be.components.validation.component.ComponentTagsValidator;
51 import org.openecomp.sdc.be.components.validation.component.ComponentValidator;
52 import org.openecomp.sdc.be.components.validation.service.ServiceCategoryValidator;
53 import org.openecomp.sdc.be.components.validation.service.ServiceEnvironmentContextValidator;
54 import org.openecomp.sdc.be.components.validation.service.ServiceFieldValidator;
55 import org.openecomp.sdc.be.components.validation.service.ServiceFunctionValidator;
56 import org.openecomp.sdc.be.components.validation.service.ServiceInstantiationTypeValidator;
57 import org.openecomp.sdc.be.components.validation.service.ServiceNamingPolicyValidator;
58 import org.openecomp.sdc.be.components.validation.service.ServiceRoleValidator;
59 import org.openecomp.sdc.be.components.validation.service.ServiceTypeValidator;
60 import org.openecomp.sdc.be.components.validation.service.ServiceValidator;
61 import org.openecomp.sdc.be.dao.api.ActionStatus;
62 import org.openecomp.sdc.be.dao.cassandra.AuditCassandraDao;
63 import org.openecomp.sdc.be.dao.janusgraph.JanusGraphDao;
64 import org.openecomp.sdc.be.datamodel.utils.UiComponentDataConverter;
65 import org.openecomp.sdc.be.datatypes.enums.ComponentTypeEnum;
66 import org.openecomp.sdc.be.datatypes.enums.JsonPresentationFields;
67 import org.openecomp.sdc.be.datatypes.enums.NodeTypeEnum;
68 import org.openecomp.sdc.be.facade.operations.CatalogOperation;
69 import org.openecomp.sdc.be.impl.ComponentsUtils;
70 import org.openecomp.sdc.be.impl.WebAppContextWrapper;
71 import org.openecomp.sdc.be.model.ArtifactDefinition;
72 import org.openecomp.sdc.be.model.Component;
73 import org.openecomp.sdc.be.model.Resource;
74 import org.openecomp.sdc.be.model.Service;
75 import org.openecomp.sdc.be.model.User;
76 import org.openecomp.sdc.be.model.category.CategoryDefinition;
77 import org.openecomp.sdc.be.model.jsonjanusgraph.operations.ToscaOperationFacade;
78 import org.openecomp.sdc.be.model.operations.api.IElementOperation;
79 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
80 import org.openecomp.sdc.be.model.operations.impl.GraphLockOperation;
81 import org.openecomp.sdc.be.resources.data.auditing.DistributionDeployEvent;
82 import org.openecomp.sdc.be.resources.data.auditing.DistributionNotificationEvent;
83 import org.openecomp.sdc.be.resources.data.auditing.ResourceAdminEvent;
84 import org.openecomp.sdc.be.user.Role;
85 import org.openecomp.sdc.be.user.UserBusinessLogic;
86 import org.openecomp.sdc.common.api.ArtifactGroupTypeEnum;
87 import org.openecomp.sdc.common.api.Constants;
88 import org.openecomp.sdc.exception.ResponseFormat;
89 import org.springframework.web.context.WebApplicationContext;
91 public class ServiceBussinessLogicBaseTestSetup extends BaseBusinessLogicMock{
93 protected ServiceBusinessLogic bl;
94 protected static final String SERVICE_CATEGORY = "Mobility";
95 protected static final String INSTANTIATION_TYPE = "A-la-carte";
96 protected final ServletContext servletContext = Mockito.mock(ServletContext.class);
97 protected UserBusinessLogic mockUserAdmin = Mockito.mock(UserBusinessLogic.class);
98 protected WebAppContextWrapper webAppContextWrapper = Mockito.mock(WebAppContextWrapper.class);
99 protected WebApplicationContext webAppContext = Mockito.mock(WebApplicationContext.class);
100 protected ResponseFormatManager responseManager = null;
101 protected ComponentsUtils componentsUtils = new ComponentsUtils(Mockito.mock(AuditingManager.class));
102 protected AuditCassandraDao auditingDao = Mockito.mock(AuditCassandraDao.class);
103 protected ArtifactsBusinessLogic artifactBl = Mockito.mock(ArtifactsBusinessLogic.class);
104 protected GraphLockOperation graphLockOperation = Mockito.mock(GraphLockOperation.class);
105 protected JanusGraphDao mockJanusGraphDao = Mockito.mock(JanusGraphDao.class);
106 protected ToscaOperationFacade toscaOperationFacade = Mockito.mock(ToscaOperationFacade.class);
107 protected GenericTypeBusinessLogic genericTypeBusinessLogic = Mockito.mock(GenericTypeBusinessLogic.class);
108 protected UserValidations userValidations = Mockito.mock(UserValidations.class);
109 protected ResourceAdminEvent auditArchive1 = Mockito.mock(ResourceAdminEvent.class);
110 protected CatalogOperation catalogOperation = Mockito.mock(CatalogOperation.class);
111 protected ResourceAdminEvent auditArchive2 = Mockito.mock(ResourceAdminEvent.class);
112 protected ResourceAdminEvent auditRestore = Mockito.mock(ResourceAdminEvent.class);
113 IElementOperation mockElementDao = new ElementOperationMock();
114 DistributionEngine distributionEngine = Mockito.mock(DistributionEngine.class);
115 ServiceDistributionValidation serviceDistributionValidation = Mockito.mock(ServiceDistributionValidation.class);
116 ComponentInstanceBusinessLogic componentInstanceBusinessLogic = Mockito.mock(ComponentInstanceBusinessLogic.class);
117 ForwardingPathValidator forwardingPathValidator = Mockito.mock(ForwardingPathValidator.class);
118 UiComponentDataConverter uiComponentDataConverter = Mockito.mock(UiComponentDataConverter.class);
119 protected ServiceTypeValidator serviceTypeValidator = new ServiceTypeValidator(componentsUtils);
120 protected ServiceCategoryValidator serviceCategoryValidator = new ServiceCategoryValidator(componentsUtils, mockElementDao);
121 protected ServiceRoleValidator serviceRoleValidator = new ServiceRoleValidator(componentsUtils);
122 protected ServiceFunctionValidator serviceFunctionValidator = new ServiceFunctionValidator(componentsUtils);
123 protected ServiceInstantiationTypeValidator serviceInstantiationTypeValidator = new ServiceInstantiationTypeValidator(componentsUtils);
124 protected ComponentDescriptionValidator componentDescriptionValidator = new ComponentDescriptionValidator(componentsUtils);
125 protected ComponentProjectCodeValidator componentProjectCodeValidator = new ComponentProjectCodeValidator(componentsUtils);
126 protected ComponentIconValidator componentIconValidator = new ComponentIconValidator(componentsUtils);
127 protected ComponentContactIdValidator componentContactIdValidator = new ComponentContactIdValidator(componentsUtils);
128 protected ComponentTagsValidator componentTagsValidator = new ComponentTagsValidator(componentsUtils);
129 protected ComponentNameValidator componentNameValidator = new ComponentNameValidator(componentsUtils, toscaOperationFacade);
130 protected final ComponentValidator componentValidator = Mockito.mock(ComponentValidator.class);
131 protected ServiceValidator serviceValidator = createServiceValidator();
133 protected User user = null;
134 protected Resource genericService = null;
136 protected static final String CERTIFIED_VERSION = "1.0";
137 protected static final String UNCERTIFIED_VERSION = "0.2";
138 protected static final String COMPONNET_ID = "myUniqueId";
139 protected static final String GENERIC_SERVICE_NAME = "org.openecomp.resource.abstract.nodes.service";
141 protected static final String SERVICE_ROLE = JsonPresentationFields.SERVICE_ROLE.getPresentation();
142 protected static final String SERVICE_TYPE = JsonPresentationFields.SERVICE_TYPE.getPresentation();
143 protected static final String SERVICE_FUNCTION = JsonPresentationFields.SERVICE_FUNCTION.getPresentation();
145 public ServiceBussinessLogicBaseTestSetup() {
149 protected ServiceValidator createServiceValidator() {
150 List<ComponentFieldValidator> componentFieldValidators = Arrays.asList(componentContactIdValidator,
151 componentDescriptionValidator,
152 componentIconValidator, componentNameValidator,
153 new ComponentProjectCodeValidator(componentsUtils),
154 componentTagsValidator);
156 List<ServiceFieldValidator> serviceFieldValidators = Arrays.asList(serviceCategoryValidator, new ServiceEnvironmentContextValidator(),
157 serviceInstantiationTypeValidator, new ServiceNamingPolicyValidator(componentsUtils),
158 serviceRoleValidator, serviceTypeValidator);
159 return new ServiceValidator(componentsUtils, componentFieldValidators, serviceFieldValidators);
165 public void setup() {
168 IElementOperation mockElementDao = new ElementOperationMock();
170 // User data and management
172 user.setUserId("jh0003");
173 user.setFirstName("Jimmi");
174 user.setLastName("Hendrix");
175 user.setRole(Role.ADMIN.name());
177 when(mockUserAdmin.getUser("jh0003", false)).thenReturn(user);
178 when(userValidations.validateUserExists(eq("jh0003"))).thenReturn(user);
179 when(userValidations.validateUserNotEmpty(eq(user), anyString())).thenReturn(user);
180 // when(userValidations.validateUserRole(user))
181 // Servlet Context attributes
182 when(servletContext.getAttribute(Constants.CONFIGURATION_MANAGER_ATTR)).thenReturn(configurationManager);
183 // when(servletContext.getAttribute(Constants.SERVICE_OPERATION_MANAGER)).thenReturn(new ServiceOperation());
184 when(servletContext.getAttribute(Constants.WEB_APPLICATION_CONTEXT_WRAPPER_ATTR)).thenReturn(webAppContextWrapper);
185 when(webAppContextWrapper.getWebAppContext(servletContext)).thenReturn(webAppContext);
186 when(webAppContext.getBean(IElementOperation.class)).thenReturn(mockElementDao);
187 when(graphLockOperation.lockComponent(Mockito.anyString(), Mockito.eq(NodeTypeEnum.Service))).thenReturn(StorageOperationStatus.OK);
188 when(graphLockOperation.lockComponentByName(Mockito.anyString(), Mockito.eq(NodeTypeEnum.Service))).thenReturn(StorageOperationStatus.OK);
189 when(catalogOperation.updateCatalog(Mockito.any(), Mockito.any())).thenReturn(ActionStatus.OK);
190 // artifact bussinesslogic
191 ArtifactDefinition artifactDef = new ArtifactDefinition();
192 when(artifactBl.createArtifactPlaceHolderInfo(Mockito.any(), Mockito.anyString(), Mockito.anyMap(), Mockito.any(User.class), Mockito.any(ArtifactGroupTypeEnum.class))).thenReturn(artifactDef);
195 Service serviceResponse = createServiceObject(true);
196 Either<Component, StorageOperationStatus> eitherCreate = Either.left(serviceResponse);
197 when(toscaOperationFacade.createToscaComponent(Mockito.any(Component.class))).thenReturn(eitherCreate);
198 Either<Boolean, StorageOperationStatus> eitherCount = Either.left(false);
199 when(toscaOperationFacade.validateComponentNameExists("Service", null, ComponentTypeEnum.SERVICE)).thenReturn(eitherCount);
200 Either<Boolean, StorageOperationStatus> eitherCountExist = Either.left(true);
201 when(toscaOperationFacade.validateComponentNameExists("alreadyExist", null, ComponentTypeEnum.SERVICE)).thenReturn(eitherCountExist);
202 when(userValidations.validateUserExists(user)).thenReturn(user);
204 genericService = setupGenericServiceMock();
205 Either<Resource, StorageOperationStatus> findLatestGeneric = Either.left(genericService);
206 when(toscaOperationFacade.getLatestCertifiedNodeTypeByToscaResourceName(GENERIC_SERVICE_NAME)).thenReturn(findLatestGeneric);
209 bl = new ServiceBusinessLogic(elementDao, groupOperation, groupInstanceOperation,
210 groupTypeOperation, groupBusinessLogic, interfaceOperation, interfaceLifecycleTypeOperation,
211 artifactBl, distributionEngine, componentInstanceBusinessLogic,
212 serviceDistributionValidation, forwardingPathValidator, uiComponentDataConverter,
213 artifactToscaOperation, componentContactIdValidator,
214 componentNameValidator, componentTagsValidator, componentValidator,
215 componentIconValidator, componentProjectCodeValidator, componentDescriptionValidator);
216 bl.setComponentContactIdValidator(componentContactIdValidator);
217 bl.setComponentIconValidator(componentIconValidator);
218 bl.setComponentTagsValidator(componentTagsValidator);
219 bl.setComponentNameValidator(componentNameValidator);
220 bl.setComponentDescriptionValidator(componentDescriptionValidator);
221 bl.setComponentProjectCodeValidator(componentProjectCodeValidator);
222 bl.setServiceCategoryValidator(serviceCategoryValidator);
223 bl.setServiceTypeValidator(serviceTypeValidator);
224 bl.setServiceFunctionValidator(serviceFunctionValidator);
225 bl.setElementDao(mockElementDao);
226 bl.setUserAdmin(mockUserAdmin);
227 bl.setArtifactBl(artifactBl);
228 bl.setServiceValidator(createServiceValidator());
229 bl.setGraphLockOperation(graphLockOperation);
230 bl.setJanusGraphDao(mockJanusGraphDao);
231 bl.setToscaOperationFacade(toscaOperationFacade);
232 bl.setGenericTypeBusinessLogic(genericTypeBusinessLogic);
233 bl.setComponentsUtils(componentsUtils);
234 bl.setCassandraAuditingDao(auditingDao);
235 bl.setUserValidations(userValidations);
236 bl.setCatalogOperations(catalogOperation);
238 mockAuditingDaoLogic();
240 responseManager = ResponseFormatManager.getInstance();
245 protected Resource setupGenericServiceMock(){
246 Resource genericService = new Resource();
247 genericService.setVersion("1.0");
248 genericService.setToscaResourceName(GENERIC_SERVICE_NAME);
249 return genericService;
252 protected Service createServiceObject(boolean afterCreate) {
253 Service service = new Service();
254 service.setUniqueId("sid");
255 service.setName("Service");
256 CategoryDefinition category = new CategoryDefinition();
257 category.setName(SERVICE_CATEGORY);
258 category.setIcons(Collections.singletonList("defaulticon"));
259 List<CategoryDefinition> categories = new ArrayList<>();
260 categories.add(category);
261 service.setCategories(categories);
262 service.setInstantiationType(INSTANTIATION_TYPE);
264 service.setDescription("description");
265 List<String> tgs = new ArrayList<>();
266 tgs.add(service.getName());
267 service.setTags(tgs);
268 // service.setVendorName("Motorola");
269 // service.setVendorRelease("1.0.0");
270 service.setIcon("defaulticon");
271 // service.setState(LifecycleStateEnum.NOT_CERTIFIED_CHECKOUT);
272 service.setContactId("aa1234");
273 service.setProjectCode("12345");
274 service.setEcompGeneratedNaming(true);
277 service.setVersion("0.1");
278 service.setUniqueId(service.getName() + ":" + service.getVersion());
279 service.setCreatorUserId(user.getUserId());
280 service.setCreatorFullName(user.getFirstName() + " " + user.getLastName());
285 private void mockAuditingDaoLogic() {
286 final ResourceAdminEvent createResourceAudit = new ResourceAdminEvent();
287 createResourceAudit.setModifier("Carlos Santana(cs0008)");
288 createResourceAudit.setCurrState("NOT_CERTIFIED_CHECKOUT");
289 createResourceAudit.setCurrVersion("0.1");
290 createResourceAudit.setServiceInstanceId("82eddd99-0bd9-4742-ab0a-1bdb5e262a05");
291 createResourceAudit.setRequestId("3e65cea1-7403-4bc7-b461-e2544d83799f");
292 createResourceAudit.setDesc("OK");
293 createResourceAudit.setResourceType("Resource");
294 createResourceAudit.setStatus("201");
295 createResourceAudit.setPrevVersion("");
296 createResourceAudit.setAction("Create");
297 // fields.put("TIMESTAMP", "2015-11-22 09:19:12.977");
298 createResourceAudit.setPrevState("");
299 createResourceAudit.setResourceName("MyTestResource");
300 // createResourceAudit.setFields(fields);
302 final ResourceAdminEvent checkInResourceAudit = new ResourceAdminEvent();
303 checkInResourceAudit.setModifier("Carlos Santana(cs0008)");
304 checkInResourceAudit.setCurrState("NOT_CERTIFIED_CHECKIN");
305 checkInResourceAudit.setCurrVersion("0.1");
306 checkInResourceAudit.setServiceInstanceId("82eddd99-0bd9-4742-ab0a-1bdb5e262a05");
307 checkInResourceAudit.setRequestId("ffacbf5d-eeb1-43c6-a310-37fe7e1cc091");
308 checkInResourceAudit.setDesc("OK");
309 checkInResourceAudit.setComment("Stam");
310 checkInResourceAudit.setResourceType("Resource");
311 checkInResourceAudit.setStatus("200");
312 checkInResourceAudit.setPrevVersion("0.1");
313 checkInResourceAudit.setAction("Checkin");
314 // fields.put("TIMESTAMP", "2015-11-22 09:25:03.797");
315 checkInResourceAudit.setPrevState("NOT_CERTIFIED_CHECKOUT");
316 checkInResourceAudit.setResourceName("MyTestResource");
318 final ResourceAdminEvent checkOutResourceAudit = new ResourceAdminEvent();
319 checkOutResourceAudit.setModifier("Carlos Santana(cs0008)");
320 checkOutResourceAudit.setCurrState("NOT_CERTIFIED_CHECKOUT");
321 checkOutResourceAudit.setCurrVersion("0.2");
322 checkOutResourceAudit.setServiceInstanceId("82eddd99-0bd9-4742-ab0a-1bdb5e262a05");
323 checkOutResourceAudit.setRequestId("7add5078-4c16-4d74-9691-cc150e3c96b8");
324 checkOutResourceAudit.setDesc("OK");
325 checkOutResourceAudit.setComment("");
326 checkOutResourceAudit.setResourceType("Resource");
327 checkOutResourceAudit.setStatus("200");
328 checkOutResourceAudit.setPrevVersion("0.1");
329 checkOutResourceAudit.setAction("Checkout");
330 // fields.put("TIMESTAMP", "2015-11-22 09:39:41.024");
331 checkOutResourceAudit.setPrevState("NOT_CERTIFIED_CHECKIN");
332 checkOutResourceAudit.setResourceName("MyTestResource");
333 // checkOutResourceAudit.setFields(fields);
335 // Mockito.doAnswer(new Answer<Either<List<ESTimeBasedEvent>,
336 // ActionStatus> >() {
337 // public Either<List<ESTimeBasedEvent>, ActionStatus>
338 // answer(InvocationOnMock invocation) {
339 // final Either<List<ESTimeBasedEvent>, ActionStatus> either;
340 // final List<ESTimeBasedEvent> list;
341 // Object[] args = invocation.getArguments();
342 // Map<AuditingFieldsKey, Object> filterMap =
343 // (Map<AuditingFieldsKey, Object>) args[0];
344 // if( filterMap.equals(FILTER_MAP_CERTIFIED_VERSION) ){
346 // ArrayList<ESTimeBasedEvent>(){{add(createResourceAudit);add(checkInResourceAudit);add(checkOutResourceAudit);}};
347 // either = Either.left(list);
350 // else if( filterMap.equals(FILTER_MAP_UNCERTIFIED_VERSION_PREV) ){
351 // list = new ArrayList<ESTimeBasedEvent>();
352 // either = Either.left(list);
354 // else if( filterMap.equals(FILTER_MAP_UNCERTIFIED_VERSION_CURR) ){
356 // ArrayList<ESTimeBasedEvent>(){{/*add(createResourceAudit);add(checkInResourceAudit);*/add(checkOutResourceAudit);}};
357 // either = Either.left(list);
364 // }).when(auditingDao).getFilteredResourceAdminAuditingEvents(Mockito.anyMap());
367 List<ResourceAdminEvent> list = new ArrayList<ResourceAdminEvent>() {
369 add(createResourceAudit);
370 add(checkInResourceAudit);
371 add(checkOutResourceAudit);
374 Either<List<ResourceAdminEvent>, ActionStatus> result = Either.left(list);
375 Mockito.when(auditingDao.getByServiceInstanceId(Mockito.anyString())).thenReturn(result);
377 List<ResourceAdminEvent> listPrev = new ArrayList<>();
378 Either<List<ResourceAdminEvent>, ActionStatus> resultPrev = Either.left(listPrev);
379 Mockito.when(auditingDao.getAuditByServiceIdAndPrevVersion(Mockito.anyString(), Mockito.anyString())).thenReturn(resultPrev);
381 List<ResourceAdminEvent> listCurr = new ArrayList<ResourceAdminEvent>() {
383 add(checkOutResourceAudit);
386 Either<List<ResourceAdminEvent>, ActionStatus> resultCurr = Either.left(listCurr);
387 Mockito.when(auditingDao.getAuditByServiceIdAndCurrVersion(Mockito.anyString(), Mockito.anyString())).thenReturn(resultCurr);
389 Either<List<ResourceAdminEvent>, ActionStatus> archiveAuditList = Either.left(Arrays.asList(auditArchive1, auditArchive2));
390 when(auditingDao.getArchiveAuditByServiceInstanceId(anyString())).thenReturn(archiveAuditList);
392 Either<List<ResourceAdminEvent>, ActionStatus> restoreAuditList = Either.left(Collections.singletonList(auditRestore));
393 when(auditingDao.getRestoreAuditByServiceInstanceId(anyString())).thenReturn(restoreAuditList);
397 protected void setupBeforeDeploy(String notifyAction, String requestAction, String did) {
399 DistributionNotificationEvent notifyEvent = new DistributionNotificationEvent();
400 notifyEvent.setAction(notifyAction);
401 notifyEvent.setDid(did);
402 notifyEvent.setStatus("200");
404 ResourceAdminEvent requestEvent = new ResourceAdminEvent();
405 requestEvent.setAction(requestAction);
406 requestEvent.setDid(did);
407 requestEvent.setStatus("200");
409 List<DistributionNotificationEvent> notifyResults = Collections.singletonList(notifyEvent);
410 Either<List<DistributionNotificationEvent>, ActionStatus> eitherNotify = Either.left(notifyResults);
412 Mockito.when(auditingDao.getDistributionNotify(Mockito.anyString(), Mockito.eq(notifyAction))).thenReturn(eitherNotify);
414 List<ResourceAdminEvent> requestResults = Collections.singletonList(requestEvent);
415 Either<List<ResourceAdminEvent>, ActionStatus> eitherRequest = Either.left(requestResults);
416 Mockito.when(auditingDao.getDistributionRequest(Mockito.anyString(), Mockito.eq(requestAction))).thenReturn(eitherRequest);
418 Either<Component, StorageOperationStatus> eitherService = Either.left(createServiceObject(true));
419 Mockito.when(toscaOperationFacade.getToscaElement(Mockito.anyString())).thenReturn(eitherService);
421 Either<List<DistributionDeployEvent>, ActionStatus> emptyEventList = Either.left(Collections.emptyList());
422 Mockito.when(auditingDao.getDistributionDeployByStatus(Mockito.anyString(), Mockito.eq("DResult"), Mockito.anyString())).thenReturn(emptyEventList);
425 private void assertResponse(Either<Service, ResponseFormat> createResponse, ActionStatus expectedStatus, String... variables) {
426 assertResponse(createResponse.right().value(), expectedStatus, variables);
429 protected void assertComponentException(ComponentException e, ActionStatus expectedStatus, String... variables) {
430 ResponseFormat actualResponse = e.getResponseFormat() != null ?
431 e.getResponseFormat() : componentsUtils.getResponseFormat(e.getActionStatus(), e.getParams());
432 assertResponse(actualResponse, expectedStatus, variables);
435 protected void assertResponse(ResponseFormat actualResponse, ActionStatus expectedStatus, String... variables) {
436 ResponseFormat expectedResponse = responseManager.getResponseFormat(expectedStatus, variables);
437 assertEquals(expectedResponse.getStatus(), actualResponse.getStatus());
438 assertEquals("assert error description", expectedResponse.getFormattedMessage(), actualResponse.getFormattedMessage());