catalog-model/src/main/java/org/openecomp/sdc/be/model/jsonjanusgraph/operations/SubstitutionFilterOperation.java

   1 /*
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2020 Nordix Foundation
   4  *  ================================================================================
   5  *  Licensed under the Apache License, Version 2.0 (the "License");
   6  *  you may not use this file except in compliance with the License.
   7  *  You may obtain a copy of the License at
   8  *
   9  *        http://www.apache.org/licenses/LICENSE-2.0
  10  *  Unless required by applicable law or agreed to in writing, software
  11  *  distributed under the License is distributed on an "AS IS" BASIS,
  12  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  *  See the License for the specific language governing permissions and
  14  *  limitations under the License.
  15  *
  16  *  SPDX-License-Identifier: Apache-2.0
  17  *  ============LICENSE_END=========================================================
  18  */
  19 package org.openecomp.sdc.be.model.jsonjanusgraph.operations;
  20
  21 import fj.data.Either;
  22 import java.util.List;
  23 import java.util.Objects;
  24 import org.openecomp.sdc.be.dao.janusgraph.JanusGraphOperationStatus;
  25 import org.openecomp.sdc.be.dao.jsongraph.GraphVertex;
  26 import org.openecomp.sdc.be.dao.jsongraph.types.EdgeLabelEnum;
  27 import org.openecomp.sdc.be.dao.jsongraph.types.JsonParseFlagEnum;
  28 import org.openecomp.sdc.be.dao.jsongraph.types.VertexTypeEnum;
  29 import org.openecomp.sdc.be.datatypes.elements.ListDataDefinition;
  30 import org.openecomp.sdc.be.datatypes.elements.SubstitutionFilterDataDefinition;
  31 import org.openecomp.sdc.be.datatypes.elements.SubstitutionFilterPropertyDataDefinition;
  32 import org.openecomp.sdc.be.datatypes.enums.JsonPresentationFields;
  33 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
  34 import org.openecomp.sdc.be.model.operations.impl.DaoStatusConverter;
  35 import org.openecomp.sdc.common.jsongraph.util.CommonUtility;
  36 import org.openecomp.sdc.common.log.enums.EcompErrorSeverity;
  37 import org.openecomp.sdc.common.log.enums.EcompLoggerErrorCode;
  38 import org.openecomp.sdc.common.log.wrappers.Logger;
  39
  40 @org.springframework.stereotype.Component("substitution-filter-operations")
  41 public class SubstitutionFilterOperation extends BaseOperation {
  42
  43     private static final Logger LOGGER = Logger.getLogger(SubstitutionFilterOperation.class);
  44
  45     public Either<SubstitutionFilterDataDefinition, StorageOperationStatus> createSubstitutionFilter(final String componentId) {
  46         return addOrUpdateSubstitutionFilter(false, componentId, new SubstitutionFilterDataDefinition());
  47     }
  48
  49     public Either<SubstitutionFilterDataDefinition, StorageOperationStatus> deleteConstraint(final String serviceId,
  50                                                                                              final SubstitutionFilterDataDefinition substitutionFilterDataDefinition,
  51                                                                                              final int propertyIndex) {
  52         final ListDataDefinition<SubstitutionFilterPropertyDataDefinition> properties = substitutionFilterDataDefinition.getProperties();
  53         properties.getListToscaDataDefinition().remove(propertyIndex);
  54         substitutionFilterDataDefinition.setProperties(properties);
  55         return addOrUpdateSubstitutionFilter(true, serviceId, substitutionFilterDataDefinition);
  56     }
  57
  58     public Either<SubstitutionFilterDataDefinition, StorageOperationStatus> addPropertyFilter(final String componentId,
  59                                                                                               final SubstitutionFilterDataDefinition substitutionFilterDataDefinition,
  60                                                                                               final SubstitutionFilterPropertyDataDefinition substitutionFilterPropertyDataDefinition) {
  61         final SubstitutionFilterDataDefinition substitutionFilterDataDefinition1 = Objects
  62             .requireNonNullElseGet(substitutionFilterDataDefinition, SubstitutionFilterDataDefinition::new);
  63         final ListDataDefinition<SubstitutionFilterPropertyDataDefinition> properties = Objects
  64             .requireNonNullElseGet(substitutionFilterDataDefinition1.getProperties(), ListDataDefinition::new);
  65         properties.getListToscaDataDefinition().add(substitutionFilterPropertyDataDefinition);
  66         substitutionFilterDataDefinition1.setProperties(properties);
  67         return addOrUpdateSubstitutionFilter(true, componentId, substitutionFilterDataDefinition1);
  68     }
  69
  70     public Either<SubstitutionFilterDataDefinition, StorageOperationStatus> updatePropertyFilters(final String componentId,
  71                                                                                                   final SubstitutionFilterDataDefinition substitutionFilterDataDefinition,
  72                                                                                                   final List<SubstitutionFilterPropertyDataDefinition> substitutionFilterPropertyDataDefinition) {
  73         final ListDataDefinition<SubstitutionFilterPropertyDataDefinition> properties = substitutionFilterDataDefinition.getProperties();
  74         properties.getListToscaDataDefinition().clear();
  75         properties.getListToscaDataDefinition().addAll(substitutionFilterPropertyDataDefinition);
  76         substitutionFilterDataDefinition.setProperties(properties);
  77         return addOrUpdateSubstitutionFilter(true, componentId, substitutionFilterDataDefinition);
  78     }
  79
  80     public Either<SubstitutionFilterDataDefinition, StorageOperationStatus> updatePropertyFilter(final String componentId,
  81                                                                                                  final SubstitutionFilterDataDefinition substitutionFilter,
  82                                                                                                  final SubstitutionFilterPropertyDataDefinition substitutionFilterProperty,
  83                                                                                                  final int index) {
  84         substitutionFilter.getProperties().getListToscaDataDefinition().set(index, substitutionFilterProperty);
  85         return addOrUpdateSubstitutionFilter(true, componentId, substitutionFilter);
  86     }
  87
  88     private Either<SubstitutionFilterDataDefinition, StorageOperationStatus> addOrUpdateSubstitutionFilter(final boolean isUpdateAction,
  89                                                                                                            final String componentId,
  90                                                                                                            final SubstitutionFilterDataDefinition substitutionFilterDataDefinition) {
  91         final Either<GraphVertex, JanusGraphOperationStatus> toscaElementEither = janusGraphDao.getVertexById(componentId, JsonParseFlagEnum.NoParse);
  92         if (toscaElementEither.isRight()) {
  93             final JanusGraphOperationStatus status = toscaElementEither.right().value();
  94             CommonUtility
  95                 .addRecordToLog(LOGGER, CommonUtility.LogLevelEnum.DEBUG, "Failed to get tosca element {} upon adding the properties. Status is {}. ",
  96                     componentId, status);
  97             return Either.right(DaoStatusConverter.convertJanusGraphStatusToStorageStatus(status));
  98         }
  99         final GraphVertex serviceVertex = toscaElementEither.left().value();
 100         substitutionFilterDataDefinition.setID(componentId);
 101         final StorageOperationStatus operationStatus = performUpdateToscaAction(isUpdateAction, serviceVertex,
 102             List.of(substitutionFilterDataDefinition));
 103         if (!StorageOperationStatus.OK.equals(operationStatus)) {
 104             janusGraphDao.rollback();
 105             LOGGER.error(EcompErrorSeverity.ERROR, EcompLoggerErrorCode.BUSINESS_PROCESS_ERROR,
 106                 " Failed to perform tosca update for substitution filter in service {} , component instance {}. status is {}", componentId,
 107                 "componentInstanceId", operationStatus);
 108             return Either.right(operationStatus);
 109         }
 110         janusGraphDao.commit();
 111         return Either.left(substitutionFilterDataDefinition);
 112     }
 113
 114     private StorageOperationStatus performUpdateToscaAction(final boolean isUpdate, final GraphVertex graphVertex,
 115                                                             final List<SubstitutionFilterDataDefinition> toscaDataList) {
 116         if (isUpdate) {
 117             return updateToscaDataOfToscaElement(graphVertex, EdgeLabelEnum.SUBSTITUTION_FILTER_TEMPLATE, VertexTypeEnum.SUBSTITUTION_FILTER_TEMPLATE,
 118                 toscaDataList, JsonPresentationFields.UNIQUE_ID);
 119         } else {
 120             return addToscaDataToToscaElement(graphVertex, EdgeLabelEnum.SUBSTITUTION_FILTER_TEMPLATE, VertexTypeEnum.SUBSTITUTION_FILTER_TEMPLATE,
 121                 toscaDataList, JsonPresentationFields.UNIQUE_ID);
 122         }
 123     }
 124 }