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

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