gerrit.onap Code Review - sdc.git/blob

   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.NetworkDao;
  14 import org.openecomp.sdc.vendorsoftwareproduct.dao.impl.zusammen.convertor.ElementToNetworkConvertor;
  15 import org.openecomp.sdc.vendorsoftwareproduct.dao.type.NetworkEntity;
  16 import org.openecomp.sdc.versioning.dao.types.Version;
  17 import org.openecomp.types.ElementPropertyName;
  18
  19 import java.io.ByteArrayInputStream;
  20 import java.util.ArrayList;
  21 import java.util.Collection;
  22 import java.util.Collections;
  23 import java.util.Optional;
  24 import java.util.stream.Collectors;
  25
  26 import static org.openecomp.core.zusammen.api.ZusammenUtil.buildElement;
  27 import static org.openecomp.core.zusammen.api.ZusammenUtil.buildStructuralElement;
  28 import static org.openecomp.core.zusammen.api.ZusammenUtil.createSessionContext;
  29
  30 public class NetworkDaoZusammenImpl implements NetworkDao {
  31
  32   private ZusammenAdaptor zusammenAdaptor;
  33
  34   public NetworkDaoZusammenImpl(ZusammenAdaptor zusammenAdaptor) {
  35     this.zusammenAdaptor = zusammenAdaptor;
  36   }
  37
  38   @Override
  39   public void registerVersioning(String versionableEntityType) {
  40     // registerVersioning not implemented for NetworkDaoZusammenImpl
  41   }
  42
  43   @Override
  44   public Collection<NetworkEntity> list(NetworkEntity network) {
  45     SessionContext context = createSessionContext();
  46     ElementContext elementContext =
  47         new ElementContext(network.getVspId(), network.getVersion().getId());
  48
  49     Optional<ElementInfo> vspModel = zusammenAdaptor
  50         .getElementInfoByName(context, elementContext, null, ElementType.VspModel.name());
  51     if (!vspModel.isPresent()) {
  52       return new ArrayList<>();
  53     }
  54
  55     return zusammenAdaptor.listElementsByName(context, elementContext, vspModel.get().getId(),
  56         ElementType.Networks.name()).stream()
  57         .map(new ElementToNetworkConvertor()::convert)
  58         .map(entity -> {
  59           entity.setVspId(network.getVspId());
  60           entity.setVersion(network.getVersion());
  61           return entity;
  62         })
  63         .collect(Collectors.toList());
  64   }
  65
  66   @Override
  67   public void create(NetworkEntity network) {
  68     ZusammenElement networkElement = buildNetworkElement(network, Action.CREATE);
  69
  70     ZusammenElement networksElement = buildStructuralElement(ElementType.Networks, Action.IGNORE);
  71     networksElement.setSubElements(Collections.singletonList(networkElement));
  72
  73     ZusammenElement vspModel = buildStructuralElement(ElementType.VspModel, Action.IGNORE);
  74     vspModel.addSubElement(networksElement);
  75
  76     SessionContext context = createSessionContext();
  77     Element savedElement = zusammenAdaptor
  78         .saveElement(context, new ElementContext(network.getVspId(), network.getVersion().getId()),
  79             vspModel, "Create network");
  80     network.setId(savedElement.getSubElements().iterator().next()
  81         .getSubElements().iterator().next().getElementId().getValue());
  82   }
  83
  84   @Override
  85   public void update(NetworkEntity network) {
  86     ZusammenElement networkElement = buildNetworkElement(network, Action.UPDATE);
  87
  88     SessionContext context = createSessionContext();
  89     zusammenAdaptor
  90         .saveElement(context, new ElementContext(network.getVspId(), network.getVersion().getId()),
  91             networkElement, String.format("Update network with id %s", network.getId()));
  92   }
  93
  94   @Override
  95   public NetworkEntity get(NetworkEntity network) {
  96     SessionContext context = createSessionContext();
  97
  98     Optional<Element> element =
  99         zusammenAdaptor.getElement(context,
 100             new ElementContext(network.getVspId(), network.getVersion().getId()), network.getId());
 101
 102     if (element.isPresent()) {
 103       ElementToNetworkConvertor convertor = new ElementToNetworkConvertor();
 104       NetworkEntity entity = convertor.convert(element.get());
 105       entity.setVspId(network.getVspId());
 106       entity.setVersion(network.getVersion());
 107       return entity;
 108     } else {
 109       return null;
 110     }
 111   }
 112
 113   @Override
 114   public void delete(NetworkEntity network) {
 115     ZusammenElement networkElement = buildElement(new Id(network.getId()), Action.DELETE);
 116
 117     SessionContext context = createSessionContext();
 118     zusammenAdaptor
 119         .saveElement(context, new ElementContext(network.getVspId(), network.getVersion().getId()),
 120             networkElement, String.format("Delete network with id %s", network.getId()));
 121   }
 122
 123
 124   @Override
 125   public void deleteAll(String vspId, Version version) {
 126     SessionContext context = createSessionContext();
 127     ElementContext elementContext = new ElementContext(vspId, version.getId());
 128
 129     Collection<ElementInfo> vspModelSubs = zusammenAdaptor
 130         .listElementsByName(context, elementContext, null, ElementType.VspModel.name());
 131
 132     Optional<ElementInfo> networksElement = vspModelSubs.stream()
 133         .filter(elementInfo -> elementInfo.getInfo() != null
 134             && ElementType.Networks.name().equals(elementInfo.getInfo().getName()))
 135         .findFirst();
 136     if (!networksElement.isPresent()) {
 137       return;
 138     }
 139
 140     ZusammenElement networks = buildElement(networksElement.get().getId(), Action.IGNORE);
 141     networks.setSubElements(networksElement.get().getSubElements().stream()
 142         .map(network -> buildElement(network.getId(), Action.DELETE))
 143         .collect(Collectors.toList()));
 144
 145     zusammenAdaptor.saveElement(context, elementContext, networks, "Delete all networks");
 146   }
 147
 148   private ZusammenElement buildNetworkElement(NetworkEntity network, Action action) {
 149     ZusammenElement networkElement =
 150         buildElement(network.getId() == null ? null : new Id(network.getId()), action);
 151     Info info = new Info();
 152     info.addProperty(ElementPropertyName.elementType.name(), ElementType.Network);
 153     info.addProperty(ElementPropertyName.compositionData.name(), network.getCompositionData());
 154     networkElement.setInfo(info);
 155     networkElement.setData(new ByteArrayInputStream(network.getCompositionData().getBytes()));
 156     return networkElement;
 157   }
 158 }