asdctool/src/main/java/org/openecomp/sdc/asdctool/impl/migration/v1707/jsonmodel/ComponentMigration.java

   1 package org.openecomp.sdc.asdctool.impl.migration.v1707.jsonmodel;
   2
   3 import fj.data.Either;
   4 import org.openecomp.sdc.asdctool.impl.migration.v1707.jsonmodel.relations.RequirementsCapabilitiesMigrationService;
   5 import org.openecomp.sdc.be.dao.jsongraph.types.JsonParseFlagEnum;
   6 import org.openecomp.sdc.be.datatypes.enums.OriginTypeEnum;
   7 import org.openecomp.sdc.be.model.Component;
   8 import org.openecomp.sdc.be.model.ComponentInstance;
   9 import org.openecomp.sdc.be.model.jsontitan.datamodel.ToscaElement;
  10 import org.openecomp.sdc.be.model.jsontitan.operations.ToscaElementLifecycleOperation;
  11 import org.openecomp.sdc.be.model.jsontitan.operations.ToscaOperationFacade;
  12 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
  13 import org.openecomp.sdc.be.model.operations.migration.MigrationMalformedDataLogger;
  14 import org.slf4j.Logger;
  15 import org.slf4j.LoggerFactory;
  16
  17 import javax.annotation.Resource;
  18
  19 import java.util.HashMap;
  20 import java.util.List;
  21 import java.util.Map;
  22 import java.util.stream.Collectors;
  23
  24 import static org.openecomp.sdc.asdctool.impl.migration.v1707.MigrationUtils.handleError;
  25
  26 public abstract class ComponentMigration <T extends Component> extends JsonModelMigration<T> {
  27
  28     private static Logger LOGGER = LoggerFactory.getLogger(ComponentMigration.class);
  29
  30     @Resource(name = "tosca-operation-facade")
  31     private ToscaOperationFacade toscaOperations;
  32
  33     @Resource(name = "req-cap-mig-service")
  34     RequirementsCapabilitiesMigrationService<T> requirementsCapabilitiesMigrationService;
  35
  36     @Resource(name = "invariant-uuid-resolver")
  37     private InvariantUUIDResolver <T> invariantUUIDResolver;
  38
  39     @Resource(name = "node-template-missing-data-resolver")
  40     private NodeTemplateMissingDataResolver nodeTemplateMissingDataResolver;
  41
  42     @Override
  43     boolean save(T element) {
  44         LOGGER.debug(String.format("creating component %s in new graph", element.getName()));
  45         return toscaOperations.createToscaComponent(element)
  46                 .either(savedNode -> true,
  47                         err -> handleError(String.format("failed to create component %s with id %s. reason: %s", element.getName(), element.getUniqueId(), err.name())));
  48     }
  49
  50     @Override
  51     Either<T, StorageOperationStatus> getElementFromNewGraph(T element) {
  52         LOGGER.debug(String.format("checking if component %s already exists on new graph", element.getName()));
  53         return toscaOperations.getToscaElement(element.getUniqueId(), JsonParseFlagEnum.ParseMetadata);
  54     }
  55
  56     @Override
  57     public StorageOperationStatus getNotFoundErrorStatus() {
  58         return StorageOperationStatus.NOT_FOUND;
  59     }
  60
  61     @Override
  62     void doPreMigrationOperation(List<T> elements) {
  63         setMissingInvariantUids(elements);
  64     }
  65
  66     //some invariants uids are missing in production
  67     private void setMissingInvariantUids(List<T> components) {
  68         List<T> missingInvariantCmpts = getComponentsWithNoInvariantUUIDs(components);
  69         for (T missingInvariantCmpt : missingInvariantCmpts) {
  70             missingInvariantCmpt.setInvariantUUID(invariantUUIDResolver.resolveInvariantUUID(components, missingInvariantCmpt));
  71         }
  72     }
  73
  74     private List<T> getComponentsWithNoInvariantUUIDs(List<T> components) {
  75         List<T> cmptsWithoutInvariant = components.stream().filter(c -> c.getInvariantUUID() == null).collect(Collectors.toList());
  76         if (!cmptsWithoutInvariant.isEmpty()) {
  77             cmptsWithoutInvariant.forEach(cmpt -> MigrationMalformedDataLogger.logMalformedDataMsg(String.format("component %s is missing invariant uuid", cmpt.getUniqueId())));
  78         }
  79         return cmptsWithoutInvariant;
  80     }
  81
  82
  83     protected void setMissingTemplateInfo(List<T> components) {
  84         Map<String, ToscaElement> origCompMap = new HashMap<>();
  85         for (T component : components) {
  86                 for (ComponentInstance instance : component.getComponentInstances()){
  87                         nodeTemplateMissingDataResolver.resolveNodeTemplateInfo(instance, origCompMap, component);
  88                 }
  89         }
  90     }
  91
  92
  93
  94
  95
  96
  97 }