catalog-be/src/main/java/org/openecomp/sdc/be/components/merge/group/ComponentGroupMergeCommand.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * SDC
   4  * ================================================================================
   5  * Copyright (C) 2019 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.merge.group;
  22
  23 import org.openecomp.sdc.be.components.merge.ComponentsGlobalMergeCommand;
  24 import org.openecomp.sdc.be.components.merge.VspComponentsMergeCommand;
  25 import org.openecomp.sdc.be.dao.api.ActionStatus;
  26 import org.openecomp.sdc.be.impl.ComponentsUtils;
  27 import org.openecomp.sdc.be.model.Component;
  28 import org.openecomp.sdc.be.model.ComponentInstance;
  29 import org.openecomp.sdc.be.model.GroupDefinition;
  30 import org.openecomp.sdc.be.model.jsonjanusgraph.operations.GroupsOperation;
  31 import org.openecomp.sdc.common.log.wrappers.Logger;
  32 import org.springframework.core.annotation.Order;
  33
  34 import java.util.List;
  35 import java.util.Map;
  36 import java.util.Optional;
  37
  38 import static java.util.stream.Collectors.toList;
  39 import static java.util.stream.Collectors.toMap;
  40 import static org.apache.commons.collections.CollectionUtils.isEmpty;
  41 import static org.apache.commons.collections.MapUtils.isEmpty;
  42 import static org.openecomp.sdc.be.components.merge.resource.ResourceDataMergeBusinessLogic.FIRST_COMMAND;
  43
  44 @org.springframework.stereotype.Component
  45 @Order(FIRST_COMMAND)//must run before policies merge command
  46 public class ComponentGroupMergeCommand implements VspComponentsMergeCommand, ComponentsGlobalMergeCommand {
  47
  48     private static final Logger log = Logger.getLogger(ComponentGroupMergeCommand.class);
  49     private final GroupsOperation groupsOperation;
  50     private final ComponentsUtils componentsUtils;
  51
  52     public ComponentGroupMergeCommand(GroupsOperation groupsOperation, ComponentsUtils componentsUtils) {
  53         this.groupsOperation = groupsOperation;
  54         this.componentsUtils = componentsUtils;
  55     }
  56
  57     @Override
  58     public String description() {
  59         return "merge group from old component to new component";
  60     }
  61
  62     @Override
  63     public ActionStatus mergeComponents(Component prevComponent, Component currentComponent) {
  64         log.debug("#mergeComponents - merging user defined groups to component {}", currentComponent.getUniqueId());
  65         if (isEmpty(prevComponent.getGroups())) {
  66             return ActionStatus.OK;
  67         }
  68         List<GroupDefinition> prevUserDefinedGroups = getAllPreviouslyUserDefinedGroups(prevComponent, currentComponent);
  69         if (isEmpty(prevUserDefinedGroups)) {
  70             return ActionStatus.OK;
  71         }
  72         updateGroupsMembers(prevUserDefinedGroups, prevComponent, currentComponent);
  73         return associateGroupsToComponent(currentComponent, prevUserDefinedGroups);
  74
  75     }
  76
  77     private List<GroupDefinition> getAllPreviouslyUserDefinedGroups(Component prevComponent, Component currCmpt) {
  78         return prevComponent.getGroups()
  79                 .stream()
  80                 .filter(GroupDefinition::isUserDefined)
  81                 .filter(group -> !currCmpt.containsGroupWithInvariantName(group.getInvariantName()))
  82                 .collect(toList());
  83     }
  84
  85     private void updateGroupsMembers(List<GroupDefinition> prevUserDefinedGroups, Component prevComponent, Component currentComponent) {
  86         log.debug("#updateGroupsMembers - updating groups member with members taken from component {}", currentComponent.getUniqueId());
  87         prevUserDefinedGroups.forEach(grp -> grp.setMembers(resolveNewGroupMembers(grp, prevComponent, currentComponent)));
  88     }
  89
  90     private Map<String, String> resolveNewGroupMembers(GroupDefinition grp, Component prevComponent, Component currentComponent) {
  91         log.debug("#resolveNewGroupMembers - updating group member for group {}", grp.getUniqueId());
  92         Map<String, String> prevGroupMembers = grp.getMembers();
  93         if (isEmpty(prevGroupMembers)) {
  94             return null;
  95         }
  96         return findNewInstancesByPrevInstancesNames(prevComponent, currentComponent, prevGroupMembers);
  97     }
  98
  99     private Map<String, String> findNewInstancesByPrevInstancesNames(Component prevComponent, Component currentComponent, Map<String, String> prevGroupMembers) {
 100         return prevGroupMembers.values()
 101                 .stream()
 102                 .map(prevComponent::getComponentInstanceById)
 103                 .filter(Optional::isPresent)
 104                 .map(Optional::get)
 105                 .map(prevInstance -> currentComponent.getComponentInstanceByName(prevInstance.getName()))
 106                 .filter(Optional::isPresent)
 107                 .map(Optional::get)
 108                 .collect(toMap(ComponentInstance::getName, ComponentInstance::getUniqueId));
 109     }
 110
 111     private ActionStatus associateGroupsToComponent(Component currentComponent, List<GroupDefinition> prevUserDefinedGroups) {
 112         currentComponent.addGroups(prevUserDefinedGroups);
 113         return groupsOperation.addGroups(currentComponent, prevUserDefinedGroups)
 114                 .either(addedGroups -> ActionStatus.OK,
 115                         componentsUtils::convertFromStorageResponse);
 116     }
 117
 118
 119
 120
 121 }