catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/GroupTypeImportManager.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.impl;
  22
  23 import java.util.ArrayList;
  24 import java.util.List;
  25 import java.util.Map;
  26 import java.util.Set;
  27 import java.util.function.Consumer;
  28 import java.util.stream.Collectors;
  29
  30 import javax.annotation.Resource;
  31
  32 import org.apache.commons.lang3.tuple.ImmutablePair;
  33 import org.openecomp.sdc.be.components.impl.CommonImportManager.ElementTypeEnum;
  34 import org.openecomp.sdc.be.components.impl.ImportUtils.ToscaTagNamesEnum;
  35 import org.openecomp.sdc.be.config.BeEcompErrorManager;
  36 import org.openecomp.sdc.be.dao.api.ActionStatus;
  37 import org.openecomp.sdc.be.impl.ComponentsUtils;
  38 import org.openecomp.sdc.be.model.GroupTypeDefinition;
  39 import org.openecomp.sdc.be.model.PropertyDefinition;
  40 import org.openecomp.sdc.be.model.operations.api.IGroupTypeOperation;
  41 import org.openecomp.sdc.be.model.operations.api.IResourceOperation;
  42 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
  43 import org.openecomp.sdc.be.model.operations.impl.PropertyOperation;
  44 import org.openecomp.sdc.exception.ResponseFormat;
  45 import org.slf4j.Logger;
  46 import org.slf4j.LoggerFactory;
  47 import org.springframework.stereotype.Component;
  48
  49 import fj.data.Either;
  50
  51 @Component("groupTypeImportManager")
  52 public class GroupTypeImportManager {
  53
  54         public static void main(String[] args) {
  55
  56                 List<PropertyDefinition> properties = new ArrayList<>();
  57                 PropertyDefinition propertyDefintion = new PropertyDefinition();
  58                 propertyDefintion.setName("aaa");
  59                 properties.add(propertyDefintion);
  60
  61                 List<String> allParentsProps = new ArrayList<>();
  62                 allParentsProps.add("aaa");
  63                 allParentsProps.add("bbb");
  64
  65                 Set<String> alreadyExistPropsCollection = properties.stream().filter(p -> allParentsProps.contains(p.getName())).map(p -> p.getName()).collect(Collectors.toSet());
  66                 System.out.println(alreadyExistPropsCollection);
  67
  68         }
  69
  70         private static Logger log = LoggerFactory.getLogger(GroupTypeImportManager.class.getName());
  71         @Resource
  72         private PropertyOperation propertyOperation;
  73         @Resource
  74         private IGroupTypeOperation groupTypeOperation;
  75         @Resource
  76         private ComponentsUtils componentsUtils;
  77         @Resource
  78         private IResourceOperation resourceOperation;
  79
  80         @Resource
  81         private CommonImportManager commonImportManager;
  82
  83         public Either<List<ImmutablePair<GroupTypeDefinition, Boolean>>, ResponseFormat> createGroupTypes(String groupTypesYml) {
  84                 return commonImportManager.createElementTypes(groupTypesYml, elementTypeYml -> createGroupTypesFromYml(elementTypeYml), groupTypesList -> createGroupTypesByDao(groupTypesList), ElementTypeEnum.GroupType);
  85         }
  86
  87         private Either<List<GroupTypeDefinition>, ActionStatus> createGroupTypesFromYml(String groupTypesYml) {
  88
  89                 return commonImportManager.createElementTypesFromYml(groupTypesYml, (groupTypeName, groupTypeJsonData) -> createGroupType(groupTypeName, groupTypeJsonData));
  90         }
  91
  92         private Either<List<ImmutablePair<GroupTypeDefinition, Boolean>>, ResponseFormat> createGroupTypesByDao(List<GroupTypeDefinition> groupTypesToCreate) {
  93                 return commonImportManager.createElementTypesByDao(groupTypesToCreate, groupType -> validateGroupType(groupType), groupType -> new ImmutablePair<>(ElementTypeEnum.GroupType, groupType.getType()),
  94                                 groupTypeName -> groupTypeOperation.getLatestGroupTypeByType(groupTypeName), groupType -> groupTypeOperation.addGroupType(groupType), null);
  95         }
  96
  97         private Either<ActionStatus, ResponseFormat> validateGroupType(GroupTypeDefinition groupType) {
  98                 Either<ActionStatus, ResponseFormat> result = Either.left(ActionStatus.OK);
  99                 if (groupType.getMembers() != null) {
 100                         if (groupType.getMembers().isEmpty()) {
 101                                 ResponseFormat responseFormat = componentsUtils.getResponseFormat(ActionStatus.GROUP_MEMBER_EMPTY, groupType.getType());
 102                                 result = Either.right(responseFormat);
 103                         } else {
 104                                 for (String member : groupType.getMembers()) {
 105                                         // Verify that such Resource exist
 106                                         Either<org.openecomp.sdc.be.model.Resource, StorageOperationStatus> eitherMemberExist = resourceOperation.getLatestByToscaResourceName(member, false);
 107                                         if (eitherMemberExist.isRight()) {
 108                                                 StorageOperationStatus operationStatus = eitherMemberExist.right().value();
 109                                                 log.debug("Error when fetching parent resource {}, error: {}", member, operationStatus);
 110                                                 ActionStatus convertFromStorageResponse = componentsUtils.convertFromStorageResponse(operationStatus);
 111                                                 BeEcompErrorManager.getInstance().logBeComponentMissingError("Import GroupType", "resource", member);
 112                                                 result = Either.right(componentsUtils.getResponseFormat(convertFromStorageResponse, member));
 113                                                 break;
 114                                         }
 115                                 }
 116
 117                         }
 118                 }
 119                 return result;
 120         }
 121
 122         private GroupTypeDefinition createGroupType(String groupTypeName, Map<String, Object> toscaJson) {
 123
 124                 GroupTypeDefinition groupType = new GroupTypeDefinition();
 125
 126                 if (toscaJson != null) {
 127                         // Description
 128                         final Consumer<String> descriptionSetter = description -> groupType.setDescription(description);
 129                         commonImportManager.setField(toscaJson, ToscaTagNamesEnum.DESCRIPTION.getElementName(), descriptionSetter);
 130                         // Derived From
 131                         final Consumer<String> derivedFromSetter = derivedFrom -> groupType.setDerivedFrom(derivedFrom);
 132                         commonImportManager.setField(toscaJson, ToscaTagNamesEnum.DERIVED_FROM.getElementName(), derivedFromSetter);
 133                         // Properties
 134                         commonImportManager.setProperties(toscaJson, (values) -> groupType.setProperties(values));
 135                         // Metadata
 136                         final Consumer<Map<String, String>> metadataSetter = metadata -> groupType.setMetadata(metadata);
 137                         commonImportManager.setField(toscaJson, ToscaTagNamesEnum.METADATA.getElementName(), metadataSetter);
 138                         // Members
 139                         final Consumer<List<String>> membersSetter = members -> groupType.setMembers(members);
 140                         commonImportManager.setField(toscaJson, ToscaTagNamesEnum.MEMBERS.getElementName(), membersSetter);
 141
 142                         groupType.setType(groupTypeName);
 143
 144                         groupType.setHighestVersion(true);
 145
 146                         groupType.setVersion(ImportUtils.Constants.FIRST_CERTIFIED_VERSION_VERSION);
 147                 }
 148                 return groupType;
 149         }
 150
 151 }