1 package org.openecomp.sdc.be.components.validation;
4 import org.apache.commons.lang.StringUtils;
5 import org.openecomp.sdc.be.components.distribution.engine.IDistributionEngine;
6 import org.openecomp.sdc.be.components.impl.ActivationRequestInformation;
7 import org.openecomp.sdc.be.dao.api.ActionStatus;
8 import org.openecomp.sdc.be.datatypes.enums.EnvironmentStatusEnum;
9 import org.openecomp.sdc.be.externalapi.servlet.representation.ServiceDistributionReqInfo;
10 import org.openecomp.sdc.be.impl.ComponentsUtils;
11 import org.openecomp.sdc.be.model.Component;
12 import org.openecomp.sdc.be.model.LifecycleStateEnum;
13 import org.openecomp.sdc.be.model.Service;
14 import org.openecomp.sdc.be.model.User;
15 import org.openecomp.sdc.be.model.jsonjanusgraph.operations.ToscaOperationFacade;
16 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
17 import org.openecomp.sdc.be.resources.data.OperationalEnvironmentEntry;
18 import org.openecomp.sdc.common.log.wrappers.Logger;
19 import org.openecomp.sdc.exception.ResponseFormat;
21 import javax.annotation.Resource;
22 import java.util.Arrays;
23 import java.util.List;
26 * Created by chaya on 10/18/2017.
28 @org.springframework.stereotype.Component("serviceDistributionValidation")
29 public class ServiceDistributionValidation {
30 private static final Logger log = Logger.getLogger(ServiceDistributionValidation.class);
32 private ComponentsUtils componentsUtils;
34 private ToscaOperationFacade toscaOperationFacade;
36 private UserValidations userValidations;
38 private IDistributionEngine distributionEngine;
40 public Either<ActivationRequestInformation, ResponseFormat> validateActivateServiceRequest(String serviceUUID, String opEnvId, User modifier, ServiceDistributionReqInfo data) {
42 validateUserExists(modifier.getUserId());
43 Service serviceToActivate = validateServiceExists(serviceUUID);
44 validateDistributionServiceLifeCycleState(serviceToActivate);
45 OperationalEnvironmentEntry operationalEnvironmentEntry = validateOperationalEnvExists(opEnvId);
46 String workloadContext = validateWorkloadContext(data);
47 ActivationRequestInformation activationRequestInformation = new ActivationRequestInformation(serviceToActivate, workloadContext, operationalEnvironmentEntry.getTenant());
48 return Either.left(activationRequestInformation);
49 } catch (ValidationException e) {
50 log.error("failed while validating activate service UUID {} request. error {}", serviceUUID, e.getExceptionResponseFormat(), e);
51 return Either.right(e.getExceptionResponseFormat());
55 private Service validateServiceExists(String serviceUUID) {
56 if (StringUtils.isEmpty(serviceUUID.trim())) {
57 ResponseFormat responseFormat = componentsUtils.getResponseFormat(ActionStatus.BAD_REQUEST_MISSING_RESOURCE);
58 throw new ValidationException(responseFormat);
60 Either<Component, StorageOperationStatus> latestComponentByUuid = toscaOperationFacade.getLatestServiceByUuid(serviceUUID);
61 if (latestComponentByUuid.isRight()) {
62 log.error("failed retrieving service {}", serviceUUID);
63 ResponseFormat responseFormat = componentsUtils.getResponseFormat(ActionStatus.API_RESOURCE_NOT_FOUND, ApiResourceEnum.SERVICE_ID.getValue());
64 throw new ValidationException(responseFormat);
66 return (Service)latestComponentByUuid.left().value();
69 private String validateWorkloadContext(ServiceDistributionReqInfo data) {
70 String workloadContext = data.getWorkloadContext();
71 if (workloadContext == null || workloadContext.isEmpty()) {
72 log.error("workload context does not exist on data to distribute");
73 ResponseFormat responseFormat = componentsUtils.getResponseFormat(ActionStatus.MISSING_BODY);
74 throw new ValidationException(responseFormat);
76 return workloadContext;
79 private OperationalEnvironmentEntry validateOperationalEnvExists(String opEnvId) {
80 if (StringUtils.isEmpty(opEnvId.trim())) {
81 ResponseFormat responseFormat = componentsUtils.getResponseFormat(ActionStatus.BAD_REQUEST_MISSING_RESOURCE);
82 throw new ValidationException(responseFormat);
84 OperationalEnvironmentEntry operationalEnvironment = distributionEngine.getEnvironmentById(opEnvId);
85 if (operationalEnvironment == null) {
86 return failOnEnvNotExist(opEnvId);
88 if (!operationalEnvironment.getStatus().equals(EnvironmentStatusEnum.COMPLETED.getName())) {
89 log.error("the operational environment is not ready to receive distributions. environment status: {}", operationalEnvironment.getStatus());
90 ResponseFormat responseFormat = componentsUtils.getResponseFormat(ActionStatus.API_RESOURCE_NOT_FOUND , ApiResourceEnum.ENVIRONMENT_ID.getValue());
91 throw new ValidationException(responseFormat);
93 return operationalEnvironment;
96 private OperationalEnvironmentEntry failOnEnvNotExist(String opEnvId) {
97 return ValidationUtils.throwValidationException(componentsUtils.getResponseFormat(ActionStatus.API_RESOURCE_NOT_FOUND, ApiResourceEnum.ENVIRONMENT_ID.getValue()), "failed to get operational environment {}", opEnvId);
100 private void validateServiceState(Service service, List<LifecycleStateEnum> allowedStates) {
101 LifecycleStateEnum state = service.getLifecycleState();
102 if (!allowedStates.contains(state)) {
103 log.error("service {} life cycle state {} is not valid for distribution", service.getUniqueId(), service.getLifecycleState());
104 ResponseFormat responseFormat = componentsUtils.getResponseFormat(ActionStatus.INVALID_SERVICE_STATE);
105 throw new ValidationException(responseFormat);
108 private void validateUserExists(String userId) {
109 userValidations.validateUserExists(userId, "activate Distribution", false);
112 private void validateDistributionServiceLifeCycleState(Service serviceToActivate) {
113 validateServiceState(serviceToActivate,
114 Arrays.asList(LifecycleStateEnum.CERTIFICATION_IN_PROGRESS, LifecycleStateEnum.CERTIFIED));