catalog-be/src/main/java/org/openecomp/sdc/be/components/merge/instance/ComponentInstanceArtifactsMerge.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 package org.openecomp.sdc.be.components.merge.instance;
  21
  22 import java.util.HashMap;
  23 import java.util.Map;
  24 import java.util.Objects;
  25 import java.util.Optional;
  26 import java.util.stream.Collectors;
  27 import org.openecomp.sdc.be.components.impl.ArtifactsBusinessLogic;
  28 import org.openecomp.sdc.be.components.impl.artifact.ArtifactOperationInfo;
  29 import org.openecomp.sdc.be.model.ArtifactDefinition;
  30 import org.openecomp.sdc.be.model.Component;
  31 import org.openecomp.sdc.be.model.ComponentInstance;
  32 import org.openecomp.sdc.be.model.User;
  33 import org.openecomp.sdc.be.model.jsonjanusgraph.operations.ToscaOperationFacade;
  34 import org.openecomp.sdc.common.api.ArtifactTypeEnum;
  35 import org.openecomp.sdc.common.api.Constants;
  36 import org.springframework.beans.factory.annotation.Autowired;
  37
  38 /**
  39  * Created by chaya on 9/20/2017.
  40  */
  41 @org.springframework.stereotype.Component("ComponentInstanceArtifactsMerge")
  42 public class ComponentInstanceArtifactsMerge implements ComponentInstanceMergeInterface {
  43
  44     @Autowired
  45     ToscaOperationFacade toscaOperationFacade;
  46     @Autowired
  47     ArtifactsBusinessLogic artifactsBusinessLogic;
  48
  49     @Override
  50     public void saveDataBeforeMerge(DataForMergeHolder dataHolder, Component containerComponent, ComponentInstance currentResourceInstance,
  51                                     Component originComponent) {
  52         Map<String, ArtifactDefinition> componentInstancesDeploymentArtifacts = currentResourceInstance.safeGetDeploymentArtifacts();
  53         Map<String, ArtifactDefinition> originalComponentDeploymentArtifacts = originComponent.getDeploymentArtifacts();
  54         Map<String, ArtifactDefinition> deploymentArtifactsCreatedOnTheInstance = componentInstancesDeploymentArtifacts.entrySet().stream()
  55             .filter(i -> !originalComponentDeploymentArtifacts.containsKey(i.getKey()))
  56             .filter(i -> !ArtifactTypeEnum.VF_MODULES_METADATA.getType().equals(i.getValue().getArtifactType()))
  57             .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
  58         dataHolder.setOrigComponentDeploymentArtifactsCreatedOnTheInstance(deploymentArtifactsCreatedOnTheInstance);
  59 //        dataHolder.setComponentInstanceDeploymentArtifactsTimeOut(componentInstancesDeploymentArtifacts.entrySet().stream()
  60
  61 //                .collect(Collectors.toMap(Map.Entry::getKey, artifact -> artifact.getValue().getTimeout())));
  62         dataHolder.setComponentInstanceDeploymentArtifactsTimeOut(componentInstancesDeploymentArtifacts.entrySet().stream()
  63             .collect(HashMap::new, (map, entry) -> map.put(entry.getKey(), entry.getValue().getTimeout()), HashMap::putAll));
  64         Map<String, ArtifactDefinition> componentInstancesInformationalArtifacts = currentResourceInstance.safeGetArtifacts();
  65         Map<String, ArtifactDefinition> originalComponentInformationalArtifacts = originComponent.getArtifacts();
  66         Map<String, ArtifactDefinition> informationalArtifactsCreatedOnTheInstance = componentInstancesInformationalArtifacts.entrySet().stream()
  67             .filter(i -> !originalComponentInformationalArtifacts.containsKey(i.getKey()))
  68             .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
  69         dataHolder.setOrigComponentInformationalArtifactsCreatedOnTheInstance(informationalArtifactsCreatedOnTheInstance);
  70     }
  71
  72     private void addEsIdToArtifactJson(Map<String, Object> artifactJson, String origEsId) {
  73         artifactJson.put(Constants.ARTIFACT_ES_ID, origEsId);
  74     }
  75
  76     @Override
  77     public Component mergeDataAfterCreate(User user, DataForMergeHolder dataHolder, Component updatedContainerComponent, String newInstanceId) {
  78         Map<String, ArtifactDefinition> origInstanceDeploymentArtifactsCreatedOnTheInstance = dataHolder
  79             .getOrigComponentDeploymentArtifactsCreatedOnTheInstance();
  80         Map<String, ArtifactDefinition> currentInstanceDeploymentArtifacts = updatedContainerComponent
  81             .safeGetComponentInstanceDeploymentArtifacts(newInstanceId);
  82         Map<String, ArtifactDefinition> filteredDeploymentArtifactsToAdd = Optional.ofNullable(origInstanceDeploymentArtifactsCreatedOnTheInstance)
  83             .orElse(new HashMap<>()).entrySet().stream()
  84             .filter(artifact -> noArtifactWithTheSameLabel(artifact.getValue().getArtifactLabel(), currentInstanceDeploymentArtifacts))
  85             .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
  86         Map<String, ArtifactDefinition> updatedTimeOutDeploymentArtifacts = getUpdatedTimeOutDeploymentArtifacts(dataHolder,
  87             currentInstanceDeploymentArtifacts);
  88         Map<String, ArtifactDefinition> origInstanceInformationalArtifactsCreatedOnTheInstance = dataHolder
  89             .getOrigComponentInformationalArtifactsCreatedOnTheInstance();
  90         Map<String, ArtifactDefinition> currentInstanceInformationalArtifacts = updatedContainerComponent
  91             .safeGetComponentInstanceInformationalArtifacts(newInstanceId);
  92         Map<String, ArtifactDefinition> filteredInformationalArtifactsToAdd = Optional
  93             .ofNullable(origInstanceInformationalArtifactsCreatedOnTheInstance).orElse(new HashMap<>()).entrySet().stream()
  94             .filter(artifact -> noArtifactWithTheSameLabel(artifact.getValue().getArtifactLabel(), currentInstanceInformationalArtifacts))
  95             .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
  96         Map<String, ArtifactDefinition> allFilteredArtifactsToAdd = new HashMap<>();
  97         allFilteredArtifactsToAdd.putAll(filteredDeploymentArtifactsToAdd);
  98         allFilteredArtifactsToAdd.putAll(updatedTimeOutDeploymentArtifacts);
  99         allFilteredArtifactsToAdd.putAll(filteredInformationalArtifactsToAdd);
 100         for (Map.Entry<String, ArtifactDefinition> currentArtifactDefinition : allFilteredArtifactsToAdd.entrySet()) {
 101             Map<String, Object> jsonForUpdateArtifact = artifactsBusinessLogic
 102                 .buildJsonForUpdateArtifact(currentArtifactDefinition.getValue().getUniqueId(),
 103                     currentArtifactDefinition.getValue().getArtifactName(), currentArtifactDefinition.getValue().getArtifactType(),
 104                     currentArtifactDefinition.getValue().getArtifactGroupType(), currentArtifactDefinition.getValue().getArtifactLabel(),
 105                     currentArtifactDefinition.getValue().getArtifactDisplayName(), currentArtifactDefinition.getValue().getDescription(),
 106                     currentArtifactDefinition.getValue().getPayloadData(), null, currentArtifactDefinition.getValue().getListHeatParameters());
 107             addEsIdToArtifactJson(jsonForUpdateArtifact, currentArtifactDefinition.getValue().getEsId());
 108             artifactsBusinessLogic.updateResourceInstanceArtifactNoContent(newInstanceId, updatedContainerComponent, user, jsonForUpdateArtifact,
 109                 new ArtifactOperationInfo(false, false, ArtifactsBusinessLogic.ArtifactOperationEnum.LINK), currentArtifactDefinition.getValue());
 110         }
 111         return updatedContainerComponent;
 112     }
 113
 114     private Map<String, ArtifactDefinition> getUpdatedTimeOutDeploymentArtifacts(DataForMergeHolder dataHolder,
 115                                                                                  Map<String, ArtifactDefinition> currentInstanceDeploymentArtifacts) {
 116         return currentInstanceDeploymentArtifacts.entrySet().stream().filter(
 117             artifact -> Objects.isNull(artifact.getValue().getTimeout()) || !artifact.getValue().getTimeout()
 118                 .equals(dataHolder.getComponentInstanceDeploymentArtifactsTimeOut().get(artifact.getKey()))).collect(Collectors
 119             .toMap(Map.Entry::getKey,
 120                 artifact -> mergeTimeOut(artifact.getValue(), dataHolder.getComponentInstanceDeploymentArtifactsTimeOut().get(artifact.getKey()))));
 121     }
 122
 123     private ArtifactDefinition mergeTimeOut(ArtifactDefinition artifact, Integer updatedTimeOut) {
 124         artifact.setTimeout(updatedTimeOut);
 125         return artifact;
 126     }
 127
 128     private boolean noArtifactWithTheSameLabel(String artifactLabel, Map<String, ArtifactDefinition> currDeploymentArtifacts) {
 129         for (Map.Entry<String, ArtifactDefinition> artifact : currDeploymentArtifacts.entrySet()) {
 130             if (artifact.getValue().getArtifactLabel().equals(artifactLabel)) {
 131                 return false;
 132             }
 133         }
 134         return true;
 135     }
 136 }