catalog-be/src/main/java/org/openecomp/sdc/be/components/merge/resource/ResourceDataMergeBusinessLogic.java

   1 package org.openecomp.sdc.be.components.merge.resource;
   2
   3 import org.openecomp.sdc.be.components.merge.ComponentsMergeCommand;
   4 import org.openecomp.sdc.be.dao.api.ActionStatus;
   5 import org.openecomp.sdc.be.model.Resource;
   6 import org.openecomp.sdc.common.log.wrappers.Logger;
   7 import org.springframework.stereotype.Component;
   8
   9 import java.util.List;
  10
  11 @Component
  12 public class ResourceDataMergeBusinessLogic implements MergeResourceBusinessLogic {
  13
  14     private static final Logger log = Logger.getLogger(ResourceDataMergeBusinessLogic.class);
  15     public static final int FIRST_COMMAND = 0;
  16     public static final int LAST_COMMAND = Integer.MAX_VALUE;
  17     public static final int ANY_ORDER_COMMAND = 1;
  18
  19     private MergeCommandsFactory mergeCommandsFactory;
  20
  21     public ResourceDataMergeBusinessLogic(MergeCommandsFactory mergeCommandsFactory) {
  22         this.mergeCommandsFactory = mergeCommandsFactory;
  23     }
  24
  25     @Override
  26     public ActionStatus mergeResourceEntities(Resource oldResource, Resource newResource) {
  27         if (oldResource == null) {
  28             return ActionStatus.OK;
  29         }
  30         return mergeCommandsFactory.getMergeCommands(oldResource, newResource)
  31                 .either(mergeCommands -> executeMergeCommands(oldResource, newResource, mergeCommands),
  32                         err -> err);
  33     }
  34
  35     private ActionStatus executeMergeCommands(Resource oldResource, Resource newResource, List<? extends ComponentsMergeCommand> componentMergingCommands) {
  36         for (ComponentsMergeCommand componentMergeCommand : componentMergingCommands) {
  37             ActionStatus mergeStatus = componentMergeCommand.mergeComponents(oldResource, newResource);
  38             if (mergeStatus != ActionStatus.OK) {
  39                 log.error("failed on merge command {} of resource {} status is {}", componentMergeCommand.description(), newResource.getUniqueId(), mergeStatus);
  40                 return mergeStatus;
  41             }
  42         }
  43         return ActionStatus.OK;
  44     }
  45
  46 }