asdctool/src/main/java/org/openecomp/sdc/asdctool/impl/migration/v1707/jsonmodel/ComponentMigration.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.asdctool.impl.migration.v1707.jsonmodel;
  22
  23 import fj.data.Either;
  24 import org.openecomp.sdc.asdctool.impl.migration.v1707.jsonmodel.relations.RequirementsCapabilitiesMigrationService;
  25 import org.openecomp.sdc.be.dao.jsongraph.types.JsonParseFlagEnum;
  26 import org.openecomp.sdc.be.datatypes.enums.OriginTypeEnum;
  27 import org.openecomp.sdc.be.model.ArtifactDefinition;
  28 import org.openecomp.sdc.be.model.Component;
  29 import org.openecomp.sdc.be.model.ComponentInstance;
  30 import org.openecomp.sdc.be.model.GroupDefinition;
  31 import org.openecomp.sdc.be.model.GroupInstance;
  32 import org.openecomp.sdc.be.model.jsontitan.datamodel.ToscaElement;
  33 import org.openecomp.sdc.be.model.jsontitan.operations.ToscaElementLifecycleOperation;
  34 import org.openecomp.sdc.be.model.jsontitan.operations.ToscaOperationFacade;
  35 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
  36 import org.openecomp.sdc.be.model.operations.migration.MigrationMalformedDataLogger;
  37 import org.openecomp.sdc.common.api.ArtifactTypeEnum;
  38 import org.openecomp.sdc.common.api.Constants;
  39 import org.slf4j.Logger;
  40 import org.slf4j.LoggerFactory;
  41
  42 import javax.annotation.Resource;
  43
  44 import java.util.ArrayList;
  45 import java.util.HashMap;
  46 import java.util.List;
  47 import java.util.Map;
  48 import java.util.stream.Collectors;
  49
  50 import static org.openecomp.sdc.asdctool.impl.migration.v1707.MigrationUtils.handleError;
  51
  52 public abstract class ComponentMigration <T extends Component> extends JsonModelMigration<T> {
  53
  54     private static Logger LOGGER = LoggerFactory.getLogger(ComponentMigration.class);
  55
  56     @Resource(name = "tosca-operation-facade")
  57     private ToscaOperationFacade toscaOperations;
  58
  59     @Resource(name = "req-cap-mig-service")
  60     RequirementsCapabilitiesMigrationService<T> requirementsCapabilitiesMigrationService;
  61
  62     @Resource(name = "invariant-uuid-resolver")
  63     private InvariantUUIDResolver <T> invariantUUIDResolver;
  64
  65     @Resource(name = "node-template-missing-data-resolver")
  66     private NodeTemplateMissingDataResolver nodeTemplateMissingDataResolver;
  67
  68     @Override
  69     boolean save(T element) {
  70         LOGGER.debug(String.format("creating component %s in new graph", element.getName()));
  71         return toscaOperations.createToscaComponent(element)
  72                 .either(savedNode -> true,
  73                         err -> handleError(String.format("failed to create component %s with id %s. reason: %s", element.getName(), element.getUniqueId(), err.name())));
  74     }
  75
  76     @Override
  77     Either<T, StorageOperationStatus> getElementFromNewGraph(T element) {
  78         LOGGER.debug(String.format("checking if component %s already exists on new graph", element.getName()));
  79         return toscaOperations.getToscaElement(element.getUniqueId(), JsonParseFlagEnum.ParseMetadata);
  80     }
  81
  82     @Override
  83     public StorageOperationStatus getNotFoundErrorStatus() {
  84         return StorageOperationStatus.NOT_FOUND;
  85     }
  86
  87     @Override
  88     void doPreMigrationOperation(List<T> elements) {
  89         setMissingInvariantUids(elements);
  90     }
  91
  92     //some invariants uids are missing in production
  93     private void setMissingInvariantUids(List<T> components) {
  94         List<T> missingInvariantCmpts = getComponentsWithNoInvariantUUIDs(components);
  95         for (T missingInvariantCmpt : missingInvariantCmpts) {
  96             missingInvariantCmpt.setInvariantUUID(invariantUUIDResolver.resolveInvariantUUID(components, missingInvariantCmpt));
  97         }
  98     }
  99
 100     private List<T> getComponentsWithNoInvariantUUIDs(List<T> components) {
 101         List<T> cmptsWithoutInvariant = components.stream().filter(c -> c.getInvariantUUID() == null).collect(Collectors.toList());
 102         if (!cmptsWithoutInvariant.isEmpty()) {
 103             cmptsWithoutInvariant.forEach(cmpt -> MigrationMalformedDataLogger.logMalformedDataMsg(String.format("component %s is missing invariant uuid", cmpt.getUniqueId())));
 104         }
 105         return cmptsWithoutInvariant;
 106     }
 107
 108
 109     protected void setMissingTemplateInfo(List<T> components) {
 110         Map<String, ToscaElement> origCompMap = new HashMap<>();
 111         for (T component : components) {
 112             List<ComponentInstance> instances = component.getComponentInstances();
 113             if(null != instances) {
 114                 for (ComponentInstance instance : instances) {
 115                     nodeTemplateMissingDataResolver.resolveNodeTemplateInfo(instance, origCompMap, component);
 116                     nodeTemplateMissingDataResolver.fixVFGroupInstances(component, instance);
 117                 }
 118             }
 119                 nodeTemplateMissingDataResolver.fixVFGroups(component);
 120         }
 121     }
 122
 123
 124
 125
 126
 127
 128
 129
 130
 131
 132 }