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