openecomp-be/lib/openecomp-sdc-vendor-software-product-lib/openecomp-sdc-vendor-software-product-core/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/dao/impl/zusammen/ComponentDependencyModelDaoZusammenImpl.java

   1 package org.openecomp.sdc.vendorsoftwareproduct.dao.impl.zusammen;
   2
   3 import com.amdocs.zusammen.adaptor.inbound.api.types.item.Element;
   4 import com.amdocs.zusammen.adaptor.inbound.api.types.item.ElementInfo;
   5 import com.amdocs.zusammen.adaptor.inbound.api.types.item.ZusammenElement;
   6 import com.amdocs.zusammen.datatypes.Id;
   7 import com.amdocs.zusammen.datatypes.SessionContext;
   8 import com.amdocs.zusammen.datatypes.item.Action;
   9 import com.amdocs.zusammen.datatypes.item.ElementContext;
  10 import com.amdocs.zusammen.datatypes.item.Info;
  11 import org.openecomp.core.zusammen.api.ZusammenAdaptor;
  12 import org.openecomp.sdc.datatypes.model.ElementType;
  13 import org.openecomp.sdc.logging.api.Logger;
  14 import org.openecomp.sdc.logging.api.LoggerFactory;
  15 import org.openecomp.sdc.vendorsoftwareproduct.dao.ComponentDependencyModelDao;
  16 import org.openecomp.sdc.vendorsoftwareproduct.dao.impl.zusammen.convertor.ElementToComponentDependencyModelConvertor;
  17 import org.openecomp.sdc.vendorsoftwareproduct.dao.type.ComponentDependencyModelEntity;
  18 import org.openecomp.types.ElementPropertyName;
  19
  20 import java.util.ArrayList;
  21 import java.util.Collection;
  22 import java.util.Optional;
  23 import java.util.stream.Collectors;
  24
  25 import static org.openecomp.core.zusammen.api.ZusammenUtil.buildElement;
  26 import static org.openecomp.core.zusammen.api.ZusammenUtil.buildStructuralElement;
  27 import static org.openecomp.core.zusammen.api.ZusammenUtil.createSessionContext;
  28
  29 /**
  30  * Created by ayalaben on 5/16/2017.
  31  */
  32 public class ComponentDependencyModelDaoZusammenImpl implements ComponentDependencyModelDao {
  33
  34   private static final Logger logger =
  35       LoggerFactory.getLogger(OrchestrationTemplateCandidateDaoZusammenImpl.class);
  36
  37   private ZusammenAdaptor zusammenAdaptor;
  38
  39   public ComponentDependencyModelDaoZusammenImpl(ZusammenAdaptor zusammenAdaptor) {
  40     this.zusammenAdaptor = zusammenAdaptor;
  41   }
  42
  43   @Override
  44   public ComponentDependencyModelEntity get(ComponentDependencyModelEntity dependency) {
  45
  46     SessionContext context = createSessionContext();
  47     ElementContext elementContext =
  48         new ElementContext(dependency.getVspId(), dependency.getVersion().getId());
  49
  50     Optional<ElementInfo> componentDependencyElement =
  51         zusammenAdaptor.getElementInfo(context, elementContext, new Id(dependency.getId()));
  52
  53     if (componentDependencyElement.isPresent()) {
  54       ElementToComponentDependencyModelConvertor convertor = new
  55           ElementToComponentDependencyModelConvertor();
  56
  57       ComponentDependencyModelEntity entity = convertor.convert(componentDependencyElement.get());
  58       entity.setVspId(dependency.getVspId());
  59       entity.setVersion(dependency.getVersion());
  60       return entity;
  61     }
  62
  63     return null;
  64   }
  65
  66   @Override
  67   public void create(ComponentDependencyModelEntity dependency) {
  68     ZusammenElement componentDependency =
  69         buildComponentDependencyElement(dependency, Action.CREATE);
  70
  71     ZusammenElement componentDependencies =
  72         buildStructuralElement(ElementType.ComponentDependencies, Action.IGNORE);
  73     componentDependencies.addSubElement(componentDependency);
  74
  75     ZusammenElement vspModel = buildStructuralElement(ElementType.VspModel, Action.IGNORE);
  76     vspModel.addSubElement(componentDependencies);
  77
  78     SessionContext context = createSessionContext();
  79     ElementContext elementContext =
  80         new ElementContext(dependency.getVspId(), dependency.getVersion().getId());
  81
  82     Element compDepsSavedElement = zusammenAdaptor
  83         .saveElement(context, elementContext, vspModel, "Create component dependency model");
  84
  85     dependency.setId(compDepsSavedElement.getSubElements().iterator().next()
  86         .getSubElements().iterator().next().getElementId().getValue());
  87   }
  88
  89   @Override
  90   public void update(ComponentDependencyModelEntity dependency) {
  91     ZusammenElement componentDependencyElement =
  92         buildComponentDependencyElement(dependency, Action.UPDATE);
  93
  94     SessionContext context = createSessionContext();
  95     ElementContext elementContext =
  96         new ElementContext(dependency.getVspId(), dependency.getVersion().getId());
  97
  98     zusammenAdaptor.saveElement(context, elementContext, componentDependencyElement,
  99         String.format("Update component dependency model with id %s", dependency.getId()));
 100   }
 101
 102   @Override
 103   public void delete(ComponentDependencyModelEntity dependency) {
 104     ZusammenElement componentDependencyElement =
 105         buildElement(new Id(dependency.getId()), Action.DELETE);
 106
 107     SessionContext context = createSessionContext();
 108     ElementContext elementContext =
 109         new ElementContext(dependency.getVspId(), dependency.getVersion().getId());
 110
 111     zusammenAdaptor.saveElement(context, elementContext, componentDependencyElement,
 112         String.format("Delete component dependency model with id %s", dependency.getId()));
 113   }
 114
 115   @Override
 116   public void registerVersioning(String versionableEntityType) {
 117     //not implemented?
 118   }
 119
 120   @Override
 121   public Collection<ComponentDependencyModelEntity> list(
 122       ComponentDependencyModelEntity dependency) {
 123     SessionContext context = createSessionContext();
 124     ElementContext elementContext =
 125         new ElementContext(dependency.getVspId(), dependency.getVersion().getId());
 126
 127     Optional<ElementInfo> vspModel = zusammenAdaptor
 128         .getElementInfoByName(context, elementContext, null, ElementType.VspModel.name());
 129     if (!vspModel.isPresent()) {
 130       return new ArrayList<>();
 131     }
 132
 133     ElementToComponentDependencyModelConvertor convertor =
 134         new ElementToComponentDependencyModelConvertor();
 135     return zusammenAdaptor.listElementsByName(context, elementContext, vspModel.get().getId(),
 136         ElementType.ComponentDependencies.name()).stream()
 137         .map(elementInfo -> {
 138           ComponentDependencyModelEntity entity = convertor.convert(elementInfo);
 139           entity.setVspId(dependency.getVspId());
 140           entity.setVersion(dependency.getVersion());
 141           entity.setId(elementInfo.getId().getValue());
 142           return entity;
 143         })
 144         .collect(Collectors.toList());
 145   }
 146
 147   private ZusammenElement buildComponentDependencyElement(ComponentDependencyModelEntity compDep,
 148                                                           Action action) {
 149     ZusammenElement componentDependencyElement =
 150         buildElement(compDep.getId() == null ? null : new Id(compDep.getId()), action);
 151
 152     Info info = new Info();
 153     info.addProperty(ElementPropertyName.elementType.name(), ElementType.ComponentDependency);
 154     //info.addProperty(ComponentDependencyModelPropertyName.id.name(), entity.getId());
 155     info.addProperty(ComponentDependencyModelPropertyName.relation.name(), compDep.getRelation());
 156     info.addProperty(ComponentDependencyModelPropertyName.sourcecomponent_id.name(),
 157         compDep.getSourceComponentId());
 158     info.addProperty(ComponentDependencyModelPropertyName.targetcomponent_id.name(),
 159         compDep.getTargetComponentId());
 160
 161     componentDependencyElement.setInfo(info);
 162
 163     return componentDependencyElement;
 164   }
 165
 166   private enum ComponentDependencyModelPropertyName {
 167     id,
 168     relation,
 169     sourcecomponent_id,
 170     targetcomponent_id,
 171   }
 172 }