catalog-be/src/main/java/org/openecomp/sdc/be/components/merge/instance/ComponentInstanceArtifactsMerge.java

   1 package org.openecomp.sdc.be.components.merge.instance;
   2
   3 import fj.data.Either;
   4 import org.openecomp.sdc.be.components.impl.ArtifactsBusinessLogic;
   5 import org.openecomp.sdc.be.model.ArtifactDefinition;
   6 import org.openecomp.sdc.be.model.Component;
   7 import org.openecomp.sdc.be.model.ComponentInstance;
   8 import org.openecomp.sdc.be.model.Operation;
   9 import org.openecomp.sdc.be.model.User;
  10 import org.openecomp.sdc.be.model.jsontitan.operations.ToscaOperationFacade;
  11 import org.openecomp.sdc.common.api.Constants;
  12 import org.openecomp.sdc.exception.ResponseFormat;
  13 import org.springframework.beans.factory.annotation.Autowired;
  14
  15 import java.util.HashMap;
  16 import java.util.Map;
  17 import java.util.Optional;
  18 import java.util.stream.Collectors;
  19
  20 /**
  21  * Created by chaya on 9/20/2017.
  22  */
  23 @org.springframework.stereotype.Component("ComponentInstanceArtifactsMerge")
  24 public class ComponentInstanceArtifactsMerge implements ComponentInstanceMergeInterface {
  25
  26     @Autowired
  27     ToscaOperationFacade toscaOperationFacade;
  28
  29     @Autowired
  30     ArtifactsBusinessLogic artifactsBusinessLogic;
  31
  32     @Override
  33     public void saveDataBeforeMerge(DataForMergeHolder dataHolder, Component containerComponent, ComponentInstance currentResourceInstance, Component originComponent) {
  34         Map<String, ArtifactDefinition> componentInstancesDeploymentArtifacts = currentResourceInstance.safeGetDeploymentArtifacts();
  35         Map<String, ArtifactDefinition> originalComponentDeploymentArtifacts = originComponent.getDeploymentArtifacts();
  36         Map<String, ArtifactDefinition> deploymentArtifactsCreatedOnTheInstance = componentInstancesDeploymentArtifacts.entrySet()
  37                 .stream()
  38                 .filter(i -> !originalComponentDeploymentArtifacts.containsKey(i.getKey()))
  39                 .collect(Collectors.toMap(p -> p.getKey(), p -> p.getValue()));
  40
  41         dataHolder.setOrigComponentDeploymentArtifactsCreatedOnTheInstance(deploymentArtifactsCreatedOnTheInstance);
  42
  43         Map<String, ArtifactDefinition> componentInstancesInformationalArtifacts = currentResourceInstance.safeGetArtifacts();
  44         Map<String, ArtifactDefinition> originalComponentInformationalArtifacts = originComponent.getArtifacts();
  45         Map<String, ArtifactDefinition> informationalArtifactsCreatedOnTheInstance = componentInstancesInformationalArtifacts.entrySet()
  46                 .stream()
  47                 .filter(i -> !originalComponentInformationalArtifacts.containsKey(i.getKey()))
  48                 .collect(Collectors.toMap(p -> p.getKey(), p -> p.getValue()));
  49         dataHolder.setOrigComponentInformationalArtifactsCreatedOnTheInstance(informationalArtifactsCreatedOnTheInstance);
  50     }
  51
  52     private void addEsIdToArtifactJson(Map<String, Object> artifactJson, String origEsId) {
  53         artifactJson.put(Constants.ARTIFACT_ES_ID, origEsId);
  54     }
  55
  56     @Override
  57     public Either<Component, ResponseFormat> mergeDataAfterCreate(User user, DataForMergeHolder dataHolder, Component updatedContainerComponent, String newInstanceId) {
  58         Map<String, ArtifactDefinition> origInstanceDeploymentArtifactsCreatedOnTheInstance = dataHolder.getOrigComponentDeploymentArtifactsCreatedOnTheInstance();
  59         Map<String, ArtifactDefinition> currentInstanceDeploymentArtifacts = updatedContainerComponent.safeGetComponentInstanceDeploymentArtifacts(newInstanceId);
  60         Map<String, ArtifactDefinition> filteredDeploymentArtifactsToAdd = Optional.ofNullable(origInstanceDeploymentArtifactsCreatedOnTheInstance).orElse(new HashMap<>()).entrySet().stream()
  61                 .filter(artifact -> noArtifactWithTheSameLabel(artifact.getValue().getArtifactLabel(), currentInstanceDeploymentArtifacts))
  62                 .collect(Collectors.toMap(p -> p.getKey(), q -> q.getValue()));
  63         Map<String, ArtifactDefinition> origInstanceInformationalArtifactsCreatedOnTheInstance = dataHolder.getOrigComponentInformationalArtifactsCreatedOnTheInstance();
  64         Map<String, ArtifactDefinition> currentInstanceInformationalArtifacts = updatedContainerComponent.safeGetComponentInstanceInformationalArtifacts(newInstanceId);
  65         Map<String, ArtifactDefinition> filteredInformationalArtifactsToAdd = Optional.ofNullable(origInstanceInformationalArtifactsCreatedOnTheInstance).orElse(new HashMap<>()).entrySet().stream()
  66                 .filter(artifact -> noArtifactWithTheSameLabel(artifact.getValue().getArtifactLabel(), currentInstanceInformationalArtifacts))
  67                 .collect(Collectors.toMap(p -> p.getKey(), q -> q.getValue()));
  68         Map<String, ArtifactDefinition> allFilteredArtifactsToAdd = new HashMap<>();
  69         allFilteredArtifactsToAdd.putAll(filteredDeploymentArtifactsToAdd);
  70         allFilteredArtifactsToAdd.putAll(filteredInformationalArtifactsToAdd);
  71
  72         for (Map.Entry<String, ArtifactDefinition> currentArtifactDefinition :  allFilteredArtifactsToAdd.entrySet()) {
  73             Map<String, Object> jsonForUpdateArtifact = artifactsBusinessLogic.buildJsonForUpdateArtifact(
  74                     currentArtifactDefinition.getValue().getUniqueId(), currentArtifactDefinition.getValue().getArtifactName(),
  75                     currentArtifactDefinition.getValue().getArtifactType(), currentArtifactDefinition.getValue().getArtifactGroupType(),
  76                     currentArtifactDefinition.getValue().getArtifactLabel(), currentArtifactDefinition.getValue().getArtifactDisplayName(),
  77                     currentArtifactDefinition.getValue().getDescription(), currentArtifactDefinition.getValue().getPayloadData(),
  78                     null, currentArtifactDefinition.getValue().getListHeatParameters());
  79             addEsIdToArtifactJson(jsonForUpdateArtifact, currentArtifactDefinition.getValue().getEsId());
  80             Either<Either<ArtifactDefinition, Operation>, ResponseFormat> uploadArtifactToService =
  81                     artifactsBusinessLogic.updateResourceInstanceArtifactNoContent(newInstanceId, updatedContainerComponent,
  82                             user, jsonForUpdateArtifact, artifactsBusinessLogic.new ArtifactOperationInfo(
  83                                     false, false, ArtifactsBusinessLogic.ArtifactOperationEnum.LINK), currentArtifactDefinition.getValue());
  84             if (uploadArtifactToService.isRight()) {
  85                 return Either.right(uploadArtifactToService.right().value());
  86             }
  87             toscaOperationFacade.commit();
  88         }
  89         return Either.left(updatedContainerComponent);
  90     }
  91
  92     private boolean noArtifactWithTheSameLabel(String artifactLabel, Map<String, ArtifactDefinition> currDeploymentArtifacts) {
  93         for (Map.Entry<String, ArtifactDefinition> artifact : currDeploymentArtifacts.entrySet()) {
  94             if (artifact.getValue().getArtifactLabel().equals(artifactLabel)) {
  95                 return false;
  96             }
  97         }
  98         return true;
  99     }
 100 }