Sync Integ to Master
[sdc.git] / catalog-be / src / main / java / org / openecomp / sdc / be / components / lifecycle / StartCertificationTransition.java
1 /*-
2  * ============LICENSE_START=======================================================
3  * SDC
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
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.lifecycle;
22
23 import java.util.Arrays;
24
25 import org.openecomp.sdc.be.components.impl.ComponentBusinessLogic;
26 import org.openecomp.sdc.be.config.BeEcompErrorManager;
27 import org.openecomp.sdc.be.dao.api.ActionStatus;
28 import org.openecomp.sdc.be.dao.jsongraph.TitanDao;
29 import org.openecomp.sdc.be.datatypes.enums.ComponentTypeEnum;
30 import org.openecomp.sdc.be.datatypes.enums.ResourceTypeEnum;
31 import org.openecomp.sdc.be.impl.ComponentsUtils;
32 import org.openecomp.sdc.be.model.Component;
33 import org.openecomp.sdc.be.model.LifeCycleTransitionEnum;
34 import org.openecomp.sdc.be.model.LifecycleStateEnum;
35 import org.openecomp.sdc.be.model.User;
36 import org.openecomp.sdc.be.model.jsontitan.datamodel.ToscaElement;
37 import org.openecomp.sdc.be.model.jsontitan.operations.ToscaElementLifecycleOperation;
38 import org.openecomp.sdc.be.model.jsontitan.operations.ToscaOperationFacade;
39 import org.openecomp.sdc.be.model.jsontitan.utils.ModelConverter;
40 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
41 import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum;
42 import org.openecomp.sdc.be.user.Role;
43 import org.openecomp.sdc.exception.ResponseFormat;
44 import org.slf4j.Logger;
45 import org.slf4j.LoggerFactory;
46
47 import fj.data.Either;
48
49 public class StartCertificationTransition extends LifeCycleTransition {
50
51     private static final Logger log = LoggerFactory.getLogger(StartCertificationTransition.class);
52
53     public StartCertificationTransition(ComponentsUtils componentUtils, ToscaElementLifecycleOperation lifecycleOperation, ToscaOperationFacade toscaOperationFacade, TitanDao titanDao) {
54         super(componentUtils, lifecycleOperation, toscaOperationFacade,  titanDao);
55
56         // authorized roles
57         Role[] rsrcServiceStartCertificationRoles = { Role.ADMIN, Role.TESTER };
58         addAuthorizedRoles(ComponentTypeEnum.RESOURCE, Arrays.asList(rsrcServiceStartCertificationRoles));
59         addAuthorizedRoles(ComponentTypeEnum.SERVICE, Arrays.asList(rsrcServiceStartCertificationRoles));
60         // TODO to be later defined for product
61
62         //additional authorized roles for resource type
63         Role[] resourceRoles = { Role.DESIGNER};
64         addResouceAuthorizedRoles(ResourceTypeEnum.VFCMT, Arrays.asList(resourceRoles));
65     }
66
67     @Override
68     public LifeCycleTransitionEnum getName() {
69         return LifeCycleTransitionEnum.START_CERTIFICATION;
70     }
71
72     @Override
73     public AuditingActionEnum getAuditingAction() {
74         return AuditingActionEnum.START_CERTIFICATION_RESOURCE;
75     }
76
77     @Override
78     public Either<? extends Component, ResponseFormat> changeState(ComponentTypeEnum componentType, Component component, ComponentBusinessLogic componentBl, User modifier, User owner, boolean shouldLock, boolean inTransaction) {
79
80         log.debug("start performing certification test for resource {}", component.getUniqueId());
81         Either<? extends Component, ResponseFormat> result = null;
82         try{
83             Either<ToscaElement, StorageOperationStatus> stateChangeResult = lifeCycleOperation.startCertificationToscaElement(component.getUniqueId(), modifier.getUserId(), owner.getUserId());
84             if (stateChangeResult.isRight()) {
85                 log.debug("start certification failed on graph");
86                 StorageOperationStatus response = stateChangeResult.right().value();
87                 ActionStatus actionStatus = componentUtils.convertFromStorageResponse(response);
88
89                 if (response.equals(StorageOperationStatus.ENTITY_ALREADY_EXISTS)) {
90                     actionStatus = ActionStatus.COMPONENT_VERSION_ALREADY_EXIST;
91                 }
92                 ResponseFormat responseFormat = componentUtils.getResponseFormatByComponent(actionStatus, component, componentType);
93                 result =  Either.right(responseFormat);
94             }
95             else {
96                 result =  Either.left(ModelConverter.convertFromToscaElement(stateChangeResult.left().value()));
97             }
98         } finally {
99             if (result == null || result.isRight()) {
100                 BeEcompErrorManager.getInstance().logBeDaoSystemError("Change LifecycleState");
101                 if (inTransaction == false) {
102                     log.debug("operation failed. do rollback");
103                     titanDao.rollback();
104                 }
105             } else {
106                 if (inTransaction == false) {
107                     log.debug("operation success. do commit");
108                     titanDao.commit();
109                 }
110             }
111         }
112         return result;
113     }
114
115     @Override
116     public Either<Boolean, ResponseFormat> validateBeforeTransition(Component component, ComponentTypeEnum componentType, User modifier, User owner, LifecycleStateEnum oldState, LifecycleChangeInfoWithAction lifecycleChangeInfo) {
117         String componentName = component.getComponentMetadataDefinition().getMetadataDataDefinition().getName();
118         log.debug("validate before start certification test. resource name={}, oldState={}, owner userId={}", componentName, oldState, owner.getUserId());
119
120         // validate user
121         Either<Boolean, ResponseFormat> userValidationResponse = userRoleValidation(modifier,component, componentType, lifecycleChangeInfo);
122         if (userValidationResponse.isRight()) {
123             return userValidationResponse;
124         }
125
126         if (oldState.equals(LifecycleStateEnum.NOT_CERTIFIED_CHECKIN) || oldState.equals(LifecycleStateEnum.NOT_CERTIFIED_CHECKOUT)) {
127             ResponseFormat error = componentUtils.getResponseFormat(ActionStatus.COMPONENT_NOT_READY_FOR_CERTIFICATION, componentName, componentType.name().toLowerCase());
128             return Either.right(error);
129         }
130
131         if (oldState.equals(LifecycleStateEnum.CERTIFIED)) {
132             ResponseFormat error = componentUtils.getResponseFormat(ActionStatus.COMPONENT_ALREADY_CERTIFIED, componentName, componentType.name().toLowerCase(), owner.getFirstName(), owner.getLastName(), owner.getUserId());
133             return Either.right(error);
134         }
135
136         if (oldState.equals(LifecycleStateEnum.CERTIFICATION_IN_PROGRESS)) {
137             ResponseFormat error = componentUtils.getResponseFormat(ActionStatus.COMPONENT_IN_CERT_IN_PROGRESS_STATE, componentName, componentType.name().toLowerCase(), owner.getFirstName(), owner.getLastName(), owner.getUserId());
138             return Either.right(error);
139         }
140
141         return Either.left(true);
142     }
143
144 }