gerrit.onap Code Review - sdc.git/blob

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