tapi/src/main/java/org/opendaylight/transportpce/tapi/topology/ConvertORTopoToTapiTopo.java

   1 /*
   2  * Copyright © 2019 Orange, Inc. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.transportpce.tapi.topology;
   9
  10 import java.nio.charset.Charset;
  11 import java.util.ArrayList;
  12 import java.util.Collection;
  13 import java.util.Collections;
  14 import java.util.HashMap;
  15 import java.util.HashSet;
  16 import java.util.Iterator;
  17 import java.util.List;
  18 import java.util.Map;
  19 import java.util.Map.Entry;
  20 import java.util.Set;
  21 import java.util.UUID;
  22 import java.util.stream.Collectors;
  23 import org.opendaylight.transportpce.tapi.TapiStringConstants;
  24 import org.opendaylight.transportpce.tapi.utils.TapiLink;
  25 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev230526.Link1;
  26 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev230526.TerminationPoint1;
  27 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev191129.State;
  28 import org.opendaylight.yang.gen.v1.http.org.openroadm.equipment.states.types.rev191129.AdminStates;
  29 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev230526.xpdr.odu.switching.pools.OduSwitchingPools;
  30 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev230526.xpdr.odu.switching.pools.OduSwitchingPoolsBuilder;
  31 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev230526.xpdr.odu.switching.pools.odu.switching.pools.NonBlockingList;
  32 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev230526.xpdr.odu.switching.pools.odu.switching.pools.NonBlockingListBuilder;
  33 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev230526.xpdr.odu.switching.pools.odu.switching.pools.NonBlockingListKey;
  34 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev230526.OpenroadmNodeType;
  35 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev230526.OpenroadmTpType;
  36 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev230526.xpdr.tp.supported.interfaces.SupportedInterfaceCapability;
  37 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev230526.Node1;
  38 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.Node;
  39 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.TpId;
  40 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPoint;
  41 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.AdministrativeState;
  42 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.ForwardingDirection;
  43 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.LAYERPROTOCOLQUALIFIER;
  44 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.LayerProtocolName;
  45 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.LifecycleState;
  46 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.OperationalState;
  47 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.PortDirection;
  48 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.PortRole;
  49 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.TerminationDirection;
  50 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.TerminationState;
  51 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.Uuid;
  52 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.global._class.Name;
  53 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.global._class.NameBuilder;
  54 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.global._class.NameKey;
  55 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.dsr.rev181210.DIGITALSIGNALTYPE100GigE;
  56 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.dsr.rev181210.DIGITALSIGNALTYPE10GigELAN;
  57 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.odu.rev181210.ODUTYPEODU2;
  58 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.odu.rev181210.ODUTYPEODU2E;
  59 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.odu.rev181210.ODUTYPEODU4;
  60 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.photonic.media.rev181210.PHOTONICLAYERQUALIFIEROMS;
  61 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.photonic.media.rev181210.PHOTONICLAYERQUALIFIEROTSi;
  62 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.ForwardingRule;
  63 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.RuleType;
  64 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.link.NodeEdgePoint;
  65 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.link.NodeEdgePointBuilder;
  66 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.link.NodeEdgePointKey;
  67 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.NodeRuleGroup;
  68 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.NodeRuleGroupBuilder;
  69 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.NodeRuleGroupKey;
  70 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.OwnedNodeEdgePoint;
  71 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.OwnedNodeEdgePointBuilder;
  72 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.OwnedNodeEdgePointKey;
  73 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.edge.point.MappedServiceInterfacePoint;
  74 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.edge.point.MappedServiceInterfacePointBuilder;
  75 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.edge.point.MappedServiceInterfacePointKey;
  76 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.Rule;
  77 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.RuleBuilder;
  78 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.RuleKey;
  79 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Link;
  80 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.LinkBuilder;
  81 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.LinkKey;
  82 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.NodeBuilder;
  83 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.NodeKey;
  84 import org.opendaylight.yangtools.yang.common.Uint16;
  85 import org.slf4j.Logger;
  86 import org.slf4j.LoggerFactory;
  87
  88
  89 public class ConvertORTopoToTapiTopo {
  90
  91     private static final Logger LOG = LoggerFactory.getLogger(ConvertORTopoToTapiTopo.class);
  92     private String ietfNodeId;
  93     private OpenroadmNodeType ietfNodeType;
  94     private AdminStates ietfNodeAdminState;
  95     private State ietfNodeOperState;
  96     private List<TerminationPoint> oorClientPortList;
  97     private List<TerminationPoint> oorNetworkPortList;
  98     private OduSwitchingPools oorOduSwitchingPool;
  99     private Uuid tapiTopoUuid;
 100     private Map<NodeKey, org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node>
 101         tapiNodes;
 102     private Map<LinkKey, Link> tapiLinks;
 103     private Map<String, Uuid> uuidMap;
 104     private final TapiLink tapiLink;
 105
 106
 107     public ConvertORTopoToTapiTopo(Uuid tapiTopoUuid, TapiLink tapiLink) {
 108         this.tapiTopoUuid = tapiTopoUuid;
 109         this.tapiNodes = new HashMap<>();
 110         this.tapiLinks = new HashMap<>();
 111         this.uuidMap = new HashMap<>();
 112         this.tapiLink = tapiLink;
 113     }
 114
 115     public void convertNode(Node ietfNode, List<String> networkPorts) {
 116         this.ietfNodeId = ietfNode.getNodeId().getValue();
 117         if (ietfNode.augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev230526.Node1.class)
 118                 == null) {
 119             return;
 120         }
 121         this.ietfNodeType = ietfNode.augmentation(
 122             org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev230526.Node1.class).getNodeType();
 123         this.ietfNodeAdminState = ietfNode.augmentation(
 124                 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev230526.Node1.class)
 125             .getAdministrativeState();
 126         this.ietfNodeOperState = ietfNode.augmentation(
 127                 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev230526.Node1.class)
 128             .getOperationalState();
 129         this.oorNetworkPortList = ietfNode.augmentation(
 130                 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class)
 131             .getTerminationPoint().values().stream()
 132             .filter(tp -> tp.augmentation(TerminationPoint1.class).getTpType().getIntValue()
 133                 == OpenroadmTpType.XPONDERNETWORK.getIntValue()
 134                 && networkPorts.contains(tp.getTpId().getValue()))
 135             .sorted((tp1, tp2) -> tp1.getTpId().getValue().compareTo(tp2.getTpId().getValue()))
 136             .collect(Collectors.toList());
 137         if (!OpenroadmNodeType.TPDR.equals(this.ietfNodeType)) {
 138             this.oorOduSwitchingPool = ietfNode.augmentation(Node1.class).getSwitchingPools().getOduSwitchingPools()
 139                 .values().stream().findFirst().orElseThrow();
 140             this.oorClientPortList = ietfNode.augmentation(
 141                 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class)
 142                 .getTerminationPoint().values().stream()
 143                 .filter(tp -> tp.augmentation(TerminationPoint1.class).getTpType().getIntValue()
 144                     == OpenroadmTpType.XPONDERCLIENT.getIntValue())
 145                 .sorted((tp1, tp2) -> tp1.getTpId().getValue().compareTo(tp2.getTpId().getValue()))
 146                 .collect(Collectors.toList());
 147         } else {
 148             this.oorOduSwitchingPool = createOduSwitchingPoolForTp100G();
 149             List<TpId> tpList = this.oorOduSwitchingPool.getNonBlockingList().values().stream()
 150                 .flatMap(nbl -> nbl.getTpList().stream())
 151                 .collect(Collectors.toList());
 152             this.oorClientPortList = ietfNode.augmentation(
 153                 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class)
 154                 .getTerminationPoint().values().stream()
 155                 .filter(tp -> tp.augmentation(TerminationPoint1.class).getTpType().getIntValue()
 156                     == OpenroadmTpType.XPONDERCLIENT.getIntValue() && tpList.contains(tp.getTpId()))
 157                 .sorted((tp1, tp2) -> tp1.getTpId().getValue().compareTo(tp2.getTpId().getValue()))
 158                 .collect(Collectors.toList());
 159             this.oorClientPortList.forEach(tp -> LOG.info("tp = {}", tp.getTpId()));
 160         }
 161
 162         // node creation [DSR/ODU]
 163         LOG.info("creation of a DSR/ODU node for {}", this.ietfNodeId);
 164         Uuid nodeUuid = new Uuid(UUID.nameUUIDFromBytes((String.join("+", this.ietfNodeId,
 165             TapiStringConstants.DSR)).getBytes(Charset.forName("UTF-8"))).toString());
 166         this.uuidMap.put(String.join("+", this.ietfNodeId, TapiStringConstants.DSR), nodeUuid);
 167         Name nameDsr = new NameBuilder().setValueName("dsr/odu node name")
 168             .setValue(String.join("+", this.ietfNodeId, TapiStringConstants.DSR)).build();
 169         Name nameNodeType = new NameBuilder().setValueName("Node Type")
 170             .setValue(this.ietfNodeType.getName()).build();
 171         Set<LayerProtocolName> dsrLayerProtocols = Set.of(LayerProtocolName.DSR, LayerProtocolName.ODU);
 172         org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology
 173             .Node dsrNode = createTapiNode(Map.of(nameDsr.key(), nameDsr, nameNodeType.key(), nameNodeType),
 174             dsrLayerProtocols);
 175         tapiNodes.put(dsrNode.key(), dsrNode);
 176
 177         // node creation [otsi]
 178         LOG.info("creation of an OTSi node for {}", this.ietfNodeId);
 179         nodeUuid = new Uuid(UUID.nameUUIDFromBytes((String.join("+", this.ietfNodeId, TapiStringConstants.OTSI))
 180             .getBytes(Charset.forName("UTF-8"))).toString());
 181         this.uuidMap.put(String.join("+", this.ietfNodeId, TapiStringConstants.OTSI), nodeUuid);
 182         Name nameOtsi =  new NameBuilder().setValueName("otsi node name")
 183             .setValue(String.join("+", this.ietfNodeId, TapiStringConstants.OTSI)).build();
 184         Set<LayerProtocolName> otsiLayerProtocols = Set.of(LayerProtocolName.PHOTONICMEDIA);
 185         org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology
 186             .Node otsiNode = createTapiNode(Map.of(nameOtsi.key(), nameOtsi, nameNodeType.key(), nameNodeType),
 187             otsiLayerProtocols);
 188         tapiNodes.put(otsiNode.key(), otsiNode);
 189
 190         // transitional link cration between network nep of DSR/ODU node and iNep of otsi node
 191         LOG.info("creation of transitional links between DSR/ODU and OTSi nodes");
 192         createTapiTransitionalLinks();
 193     }
 194
 195     public void convertLinks(Map<
 196             org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network
 197                 .LinkKey,
 198             org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network
 199                 .Link> otnLinkMap) {
 200         List<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network
 201             .Link> otnLinkList = new ArrayList<>(otnLinkMap.values());
 202         Collections.sort(otnLinkList, (l1, l2) -> l1.getLinkId().getValue()
 203             .compareTo(l2.getLinkId().getValue()));
 204         List<String> linksToNotConvert = new ArrayList<>();
 205         LOG.info("creation of {} otn links", otnLinkMap.size() / 2);
 206         for (org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network
 207                 .Link otnlink : otnLinkList) {
 208             if (!linksToNotConvert.contains(otnlink.getLinkId().getValue())) {
 209                 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks
 210                     .network.Link oppositeLink = otnLinkMap.get(new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns
 211                         .yang.ietf.network.topology.rev180226.networks.network.LinkKey(otnlink.augmentation(Link1.class)
 212                     .getOppositeLink()));
 213
 214                 AdminStates oppLnkAdmState = null;
 215                 State oppLnkOpState = null;
 216                 String oppositeLinkId = null;
 217                 if (oppositeLink != null) {
 218                     oppLnkAdmState = oppositeLink.augmentation(Link1.class).getAdministrativeState();
 219                     oppLnkOpState = oppositeLink.augmentation(Link1.class).getOperationalState();
 220                     oppositeLinkId = oppositeLink.getLinkId().getValue();
 221                 }
 222                 String adminState =
 223                     otnlink.augmentation(Link1.class).getAdministrativeState() == null
 224                         || oppLnkAdmState == null
 225                     ? null
 226                     : this.tapiLink.setTapiAdminState(
 227                         otnlink.augmentation(Link1.class).getAdministrativeState(), oppLnkAdmState).getName();
 228                 String operState = otnlink.augmentation(Link1.class).getOperationalState() == null
 229                         || oppLnkOpState == null
 230                     ? null
 231                     : this.tapiLink.setTapiOperationalState(
 232                         otnlink.augmentation(Link1.class).getOperationalState(), oppLnkOpState).getName();
 233
 234                 String prefix = otnlink.getLinkId().getValue().split("-")[0];
 235                 String nodesQual = prefix.equals("OTU4") ? TapiStringConstants.OTSI : TapiStringConstants.DSR;
 236                 String tpsQual = prefix.equals("OTU4") ? TapiStringConstants.I_OTSI : TapiStringConstants.E_ODU;
 237                 LayerProtocolName layerProtocolName = prefix.equals("OTU4") ? LayerProtocolName.PHOTONICMEDIA
 238                     : LayerProtocolName.ODU;
 239
 240                 Link tapLink = this.tapiLink.createTapiLink(otnlink.getSource().getSourceNode().getValue(),
 241                     otnlink.getSource().getSourceTp().getValue(), otnlink.getDestination().getDestNode().getValue(),
 242                     otnlink.getDestination().getDestTp().getValue(), TapiStringConstants.OTN_XPDR_XPDR_LINK, nodesQual,
 243                     nodesQual, tpsQual, tpsQual, adminState, operState, Set.of(layerProtocolName),
 244                     Set.of(layerProtocolName.getName()), this.tapiTopoUuid);
 245                 linksToNotConvert.add(oppositeLinkId);
 246                 tapiLinks.put(tapLink.key(), tapLink);
 247             }
 248         }
 249     }
 250
 251     public void convertRoadmInfrastructure() {
 252         LOG.info("abstraction of the ROADM infrastructure towards a photonic node");
 253         Uuid nodeUuid = new Uuid(UUID.nameUUIDFromBytes(TapiStringConstants.RDM_INFRA
 254             .getBytes(Charset.forName("UTF-8"))).toString());
 255         Name nodeName =  new NameBuilder().setValueName("otsi node name").setValue(TapiStringConstants.RDM_INFRA)
 256             .build();
 257         Name nameNodeType = new NameBuilder().setValueName("Node Type")
 258             .setValue(OpenroadmNodeType.ROADM.getName()).build();
 259         Set<LayerProtocolName> nodeLayerProtocols = Set.of(LayerProtocolName.PHOTONICMEDIA);
 260
 261         List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node> tapiPhotonicNodes
 262             = pruneTapiPhotonicNodes();
 263         Map<String, String> photonicNepUuisMap = convertListNodeWithListNepToMapForUuidAndName(tapiPhotonicNodes);
 264         // nep creation for rdm infra abstraction node
 265         Map<OwnedNodeEdgePointKey, OwnedNodeEdgePoint> onepMap = createNepForRdmNode(photonicNepUuisMap.size());
 266         // node rule group creation
 267         Map<NodeRuleGroupKey, NodeRuleGroup> nodeRuleGroupList
 268             = createNodeRuleGroupForRdmNode(nodeUuid, onepMap.values());
 269         // build RDM infra node abstraction
 270         org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node rdmNode = new NodeBuilder()
 271             .setUuid(nodeUuid)
 272             .setName(Map.of(nodeName.key(), nodeName, nameNodeType.key(), nameNodeType))
 273             .setLayerProtocolName(nodeLayerProtocols)
 274             .setAdministrativeState(AdministrativeState.UNLOCKED)
 275             .setOperationalState(OperationalState.ENABLED)
 276             .setLifecycleState(LifecycleState.INSTALLED)
 277             .setOwnedNodeEdgePoint(onepMap)
 278             .setNodeRuleGroup(nodeRuleGroupList)
 279             .build();
 280         tapiNodes.put(rdmNode.key(), rdmNode);
 281
 282         // OMS link creation between photonoci nodes and RDM infra abstraction node
 283         Map<String, String> rdmInfraNepUuisMap = convertListNodeWithListNepToMapForUuidAndName(List.of(rdmNode));
 284         if (photonicNepUuisMap.size() != rdmInfraNepUuisMap.size()) {
 285             LOG.warn("Unable to build OMS links between photonics nodes and RDM infrasctructure abstraction");
 286         } else {
 287             createTapiOmsLinks(photonicNepUuisMap, rdmInfraNepUuisMap);
 288         }
 289     }
 290
 291     private OduSwitchingPools createOduSwitchingPoolForTp100G() {
 292         Map<NonBlockingListKey, NonBlockingList> nblMap = new HashMap<>();
 293         int count = 1;
 294         for (TerminationPoint tp : this.oorNetworkPortList) {
 295             TpId tpid1 = tp.getTpId();
 296             TpId tpid2 = tp.augmentation(
 297                     org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev230526.TerminationPoint1.class)
 298                 .getAssociatedConnectionMapTp().iterator().next();
 299             Set<TpId> tpList = new HashSet<>();
 300             tpList.add(tpid1);
 301             tpList.add(tpid2);
 302             NonBlockingList nbl = new NonBlockingListBuilder()
 303                 .setNblNumber(Uint16.valueOf(count))
 304                 .setTpList(tpList)
 305                 .build();
 306             nblMap.put(nbl.key(), nbl);
 307             count++;
 308         }
 309         return new OduSwitchingPoolsBuilder()
 310             .setNonBlockingList(nblMap)
 311             .setSwitchingPoolNumber(Uint16.valueOf(1))
 312             .build();
 313     }
 314
 315     private List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node>
 316             pruneTapiPhotonicNodes() {
 317         List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node>
 318             prunedTapiPhotonicNodes = new ArrayList<>();
 319         List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node> tapiPhotonicNodes
 320             = this.tapiNodes.values().stream()
 321             .filter(n -> LayerProtocolName.PHOTONICMEDIA.equals(n.getLayerProtocolName().stream().findFirst()
 322                     .orElseThrow()))
 323             .collect(Collectors.toList());
 324         for (org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node node
 325             : tapiPhotonicNodes) {
 326             Map<OwnedNodeEdgePointKey, OwnedNodeEdgePoint> onepM = new HashMap<>();
 327             for (Map.Entry<OwnedNodeEdgePointKey, OwnedNodeEdgePoint> entry : node.getOwnedNodeEdgePoint().entrySet()) {
 328                 if (entry.getValue().getName().values().stream()
 329                     .filter(name -> name.getValueName().startsWith("eNodeEdgePoint")).count() > 0) {
 330                     onepM.put(entry.getKey(), entry.getValue());
 331                 }
 332             }
 333             org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node prunedNode
 334                 = new NodeBuilder(node).setOwnedNodeEdgePoint(onepM).build();
 335             prunedTapiPhotonicNodes.add(prunedNode);
 336         }
 337         return prunedTapiPhotonicNodes;
 338     }
 339
 340     private Map<String, String> convertListNodeWithListNepToMapForUuidAndName(
 341         List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node> nodes) {
 342         Map<String, String> uuidNameMap = new HashMap<>();
 343         for (org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node node : nodes) {
 344             for (OwnedNodeEdgePoint nep : node.nonnullOwnedNodeEdgePoint().values()) {
 345                 String nodeUuid = node.getUuid().getValue();
 346                 String nepUuid = nep.getUuid().getValue();
 347                 String nodeName = node.getName().get(new NameKey("otsi node name")).getValue();
 348                 String nepName = nep.getName().get(new NameKey(nep.getName().keySet().stream().findFirst()
 349                         .orElseThrow()))
 350                     .getValue();
 351                 uuidNameMap.put(String.join("--", nodeUuid, nepUuid), String.join("--", nodeName, nepName));
 352             }
 353         }
 354         return uuidNameMap;
 355     }
 356
 357     private org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node
 358             createTapiNode(Map<NameKey, Name> nodeNames, Set<LayerProtocolName> layerProtocols) {
 359         Uuid nodeUuid = null;
 360         Map<OwnedNodeEdgePointKey, OwnedNodeEdgePoint> onepl = new HashMap<>();
 361         Map<NodeRuleGroupKey, NodeRuleGroup> nodeRuleGroupList = new HashMap<>();
 362         Map<RuleKey, Rule> ruleList = new HashMap<>();
 363         Rule rule = new RuleBuilder()
 364             .setLocalId("forward")
 365             .setForwardingRule(ForwardingRule.MAYFORWARDACROSSGROUP)
 366             .setRuleType(RuleType.FORWARDING)
 367             .build();
 368         ruleList.put(rule.key(), rule);
 369         if (layerProtocols.contains(LayerProtocolName.DSR)) {
 370             nodeUuid = getNodeUuid4Dsr(onepl, nodeRuleGroupList, ruleList);
 371         } else if (layerProtocols.contains(LayerProtocolName.PHOTONICMEDIA)) {
 372             nodeUuid = getNodeUuid4Photonic(onepl, nodeRuleGroupList, ruleList);
 373         } else {
 374             LOG.error("Undefined LayerProtocolName for {} node {}", nodeNames.get(nodeNames.keySet().iterator().next())
 375                 .getValueName(), nodeNames.get(nodeNames.keySet().iterator().next()).getValue());
 376         }
 377         return new NodeBuilder()
 378             .setUuid(nodeUuid)
 379             .setName(nodeNames)
 380             .setLayerProtocolName(layerProtocols)
 381             .setAdministrativeState(this.tapiLink.setTapiAdminState(this.ietfNodeAdminState.getName()))
 382             .setOperationalState(this.tapiLink.setTapiOperationalState(this.ietfNodeOperState.getName()))
 383             .setLifecycleState(LifecycleState.INSTALLED)
 384             .setOwnedNodeEdgePoint(onepl)
 385             .setNodeRuleGroup(nodeRuleGroupList)
 386             .build();
 387     }
 388
 389     private Uuid getNodeUuid4Photonic(Map<OwnedNodeEdgePointKey, OwnedNodeEdgePoint> onepl,
 390                                       Map<NodeRuleGroupKey, NodeRuleGroup> nodeRuleGroupList,
 391                                       Map<RuleKey, Rule> ruleList) {
 392         Uuid nodeUuid;
 393         nodeUuid = this.uuidMap.get(String.join("+", this.ietfNodeId, TapiStringConstants.OTSI));
 394         // iNep creation on otsi node
 395         for (int i = 0; i < oorNetworkPortList.size(); i++) {
 396             Uuid nepUuid1 = new Uuid(UUID.nameUUIDFromBytes(
 397                     (String.join("+", this.ietfNodeId, TapiStringConstants.I_OTSI,
 398                         oorNetworkPortList.get(i).getTpId().getValue())).getBytes(Charset.forName("UTF-8")))
 399                 .toString());
 400             this.uuidMap.put(String.join("+", this.ietfNodeId, TapiStringConstants.I_OTSI,
 401                 oorNetworkPortList.get(i).getTpId().getValue()), nepUuid1);
 402             Name onedName = new NameBuilder()
 403                 .setValueName("iNodeEdgePoint")
 404                 .setValue(String.join("+", this.ietfNodeId, TapiStringConstants.I_OTSI,
 405                     oorNetworkPortList.get(i).getTpId().getValue()))
 406                 .build();
 407
 408             OwnedNodeEdgePoint onep = createNep(oorNetworkPortList.get(i), Map.of(onedName.key(), onedName),
 409                 LayerProtocolName.PHOTONICMEDIA, LayerProtocolName.PHOTONICMEDIA, true,
 410                 String.join("+", this.ietfNodeId, TapiStringConstants.I_OTSI));
 411             onepl.put(onep.key(), onep);
 412         }
 413         // eNep creation on otsi node
 414         for (int i = 0; i < oorNetworkPortList.size(); i++) {
 415             Uuid nepUuid2 = new Uuid(UUID.nameUUIDFromBytes(
 416                     (String.join("+", this.ietfNodeId, TapiStringConstants.E_OTSI,
 417                         oorNetworkPortList.get(i).getTpId().getValue())).getBytes(Charset.forName("UTF-8")))
 418                 .toString());
 419             this.uuidMap.put(String.join("+", this.ietfNodeId, TapiStringConstants.E_OTSI,
 420                 oorNetworkPortList.get(i).getTpId().getValue()), nepUuid2);
 421             Name onedName = new NameBuilder()
 422                 .setValueName("eNodeEdgePoint")
 423                 .setValue(String.join("+", this.ietfNodeId, TapiStringConstants.E_OTSI,
 424                     oorNetworkPortList.get(i).getTpId().getValue()))
 425                 .build();
 426
 427             OwnedNodeEdgePoint onep = createNep(oorNetworkPortList.get(i), Map.of(onedName.key(), onedName),
 428                 LayerProtocolName.PHOTONICMEDIA, LayerProtocolName.PHOTONICMEDIA, true,
 429                 String.join("+", this.ietfNodeId, TapiStringConstants.E_OTSI));
 430             onepl.put(onep.key(), onep);
 431         }
 432         // create NodeRuleGroup
 433         int count = 1;
 434         for (TerminationPoint tp : this.oorNetworkPortList) {
 435             Map<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePointKey,
 436                 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePoint>
 437                 nepList = new HashMap<>();
 438             org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group
 439                 .NodeEdgePoint inep = new org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210
 440                 .node.rule.group.NodeEdgePointBuilder()
 441                 .setTopologyUuid(tapiTopoUuid)
 442                 .setNodeUuid(this.uuidMap.get(String.join("+", this.ietfNodeId, TapiStringConstants.OTSI)))
 443                 .setNodeEdgePointUuid(
 444                     this.uuidMap.get(String.join("+", this.ietfNodeId, TapiStringConstants.I_OTSI,
 445                         tp.getTpId().getValue()))).build();
 446             org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group
 447                 .NodeEdgePoint enep = new org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210
 448                 .node.rule.group.NodeEdgePointBuilder()
 449                 .setTopologyUuid(tapiTopoUuid)
 450                 .setNodeUuid(this.uuidMap.get(String.join("+", this.ietfNodeId, TapiStringConstants.OTSI)))
 451                 .setNodeEdgePointUuid(
 452                     this.uuidMap.get(String.join("+", this.ietfNodeId, TapiStringConstants.E_OTSI,
 453                         tp.getTpId().getValue())))
 454                 .build();
 455             nepList.put(inep.key(), inep);
 456             nepList.put(enep.key(), enep);
 457             NodeRuleGroup nodeRuleGroup = new NodeRuleGroupBuilder()
 458                 .setUuid(new Uuid(
 459                     UUID.nameUUIDFromBytes(("otsi node rule group " + count).getBytes(Charset.forName("UTF-8")))
 460                         .toString()))
 461                 .setRule(ruleList)
 462                 .setNodeEdgePoint(nepList)
 463                 .build();
 464             nodeRuleGroupList.put(nodeRuleGroup.key(), nodeRuleGroup);
 465             count++;
 466         }
 467         return nodeUuid;
 468     }
 469
 470     private Uuid getNodeUuid4Dsr(Map<OwnedNodeEdgePointKey, OwnedNodeEdgePoint> onepl,
 471                                  Map<NodeRuleGroupKey, NodeRuleGroup> nodeRuleGroupList, Map<RuleKey, Rule> ruleList) {
 472         Uuid nodeUuid;
 473         nodeUuid = this.uuidMap.get(String.join("+", this.ietfNodeId, TapiStringConstants.DSR));
 474         // client nep creation on DSR/ODU node
 475         for (int i = 0; i < oorClientPortList.size(); i++) {
 476             Uuid nepUuid = new Uuid(UUID.nameUUIDFromBytes(
 477                 (String.join("+", this.ietfNodeId, TapiStringConstants.DSR,
 478                     oorClientPortList.get(i).getTpId().getValue())).getBytes(Charset.forName("UTF-8"))).toString());
 479             this.uuidMap.put(String.join("+", this.ietfNodeId, TapiStringConstants.DSR,
 480                 oorClientPortList.get(i).getTpId().getValue()), nepUuid);
 481             NameBuilder nameBldr = new NameBuilder().setValue(String.join("+", this.ietfNodeId, TapiStringConstants.DSR,
 482                 oorClientPortList.get(i).getTpId().getValue()));
 483             Name name;
 484             if (OpenroadmNodeType.TPDR.equals(this.ietfNodeType)) {
 485                 name = nameBldr.setValueName("100G-tpdr").build();
 486             } else {
 487                 name = nameBldr.setValueName("NodeEdgePoint_C").build();
 488             }
 489
 490             OwnedNodeEdgePoint onep = createNep(oorClientPortList.get(i), Map.of(name.key(), name),
 491                 LayerProtocolName.ETH, LayerProtocolName.DSR, true, String.join("+", this.ietfNodeId,
 492                     TapiStringConstants.DSR));
 493             onepl.put(onep.key(), onep);
 494         }
 495         // network nep creation on DSR/ODU node
 496         for (int i = 0; i < oorNetworkPortList.size(); i++) {
 497             Uuid nepUuid = new Uuid(UUID.nameUUIDFromBytes(
 498                 (String.join("+", this.ietfNodeId, TapiStringConstants.I_ODU,
 499                     oorNetworkPortList.get(i).getTpId().getValue())).getBytes(Charset.forName("UTF-8"))).toString());
 500             this.uuidMap.put(String.join("+", this.ietfNodeId, TapiStringConstants.I_ODU,
 501                 oorNetworkPortList.get(i).getTpId().getValue()), nepUuid);
 502             Name onedName = new NameBuilder()
 503                 .setValueName("iNodeEdgePoint_N")
 504                 .setValue(String.join("+", this.ietfNodeId, TapiStringConstants.I_ODU,
 505                     oorNetworkPortList.get(i).getTpId().getValue()))
 506                 .build();
 507
 508             OwnedNodeEdgePoint onep = createNep(oorNetworkPortList.get(i), Map.of(onedName.key(), onedName),
 509                 LayerProtocolName.ODU, LayerProtocolName.DSR, true, String.join("+", this.ietfNodeId,
 510                     TapiStringConstants.I_ODU));
 511             onepl.put(onep.key(), onep);
 512         }
 513         // create NodeRuleGroup
 514         int count = 1;
 515         for (NonBlockingList nbl : this.oorOduSwitchingPool.nonnullNonBlockingList().values()) {
 516             Map<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePointKey,
 517                 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePoint>
 518                 nepList = new HashMap<>();
 519             for (TpId tp : nbl.getTpList()) {
 520                 if (this.uuidMap.containsKey(String.join("+", this.ietfNodeId, TapiStringConstants.DSR,
 521                         tp.getValue())) || this.uuidMap.containsKey(String.join(
 522                     "+", this.ietfNodeId, TapiStringConstants.I_ODU, tp.getValue()))) {
 523                     String qual = tp.getValue().contains("CLIENT") ? TapiStringConstants.DSR
 524                         : TapiStringConstants.I_ODU;
 525                     org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePoint
 526                         nep = new org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group
 527                         .NodeEdgePointBuilder()
 528                         .setTopologyUuid(tapiTopoUuid)
 529                         .setNodeUuid(this.uuidMap.get(String.join("+", this.ietfNodeId,
 530                             TapiStringConstants.DSR)))
 531                         .setNodeEdgePointUuid(this.uuidMap.get(String.join("+", this.ietfNodeId,
 532                             qual, tp.getValue())))
 533                         .build();
 534                     nepList.put(nep.key(), nep);
 535                 }
 536             }
 537             NodeRuleGroup nodeRuleGroup = new NodeRuleGroupBuilder()
 538                 .setUuid(new Uuid(
 539                     UUID.nameUUIDFromBytes(("dsr node rule group " + count).getBytes(Charset.forName("UTF-8")))
 540                         .toString()))
 541                 .setRule(ruleList)
 542                 .setNodeEdgePoint(nepList)
 543                 .build();
 544             nodeRuleGroupList.put(nodeRuleGroup.key(), nodeRuleGroup);
 545             count++;
 546         }
 547         return nodeUuid;
 548     }
 549
 550     private OwnedNodeEdgePoint createNep(TerminationPoint oorTp, Map<NameKey, Name> nepNames,
 551                                          LayerProtocolName nepProtocol, LayerProtocolName nodeProtocol,
 552                                          boolean withSip, String keyword) {
 553         String key = String.join("+", keyword, oorTp.getTpId().getValue());
 554         AdministrativeState adminState = (oorTp.augmentation(TerminationPoint1.class).getAdministrativeState() != null)
 555             ? this.tapiLink.setTapiAdminState(oorTp.augmentation(TerminationPoint1.class).getAdministrativeState()
 556                 .getName())
 557             : null;
 558         OperationalState operState = (oorTp.augmentation(TerminationPoint1.class).getOperationalState() != null)
 559             ? this.tapiLink.setTapiOperationalState(oorTp.augmentation(TerminationPoint1.class).getOperationalState()
 560                 .getName())
 561             : null;
 562         OwnedNodeEdgePointBuilder onepBldr = new OwnedNodeEdgePointBuilder()
 563             .setUuid(this.uuidMap.get(key))
 564             .setLayerProtocolName(nepProtocol)
 565             .setName(nepNames)
 566             .setSupportedCepLayerProtocolQualifier(createSupportedCepLayerProtocolQualifier(oorTp, nodeProtocol))
 567             .setLinkPortDirection(PortDirection.BIDIRECTIONAL)
 568             .setLinkPortRole(PortRole.SYMMETRIC)
 569             .setAdministrativeState(adminState)
 570             .setOperationalState(operState)
 571             .setLifecycleState(LifecycleState.INSTALLED)
 572             .setTerminationDirection(TerminationDirection.BIDIRECTIONAL)
 573             .setTerminationState(TerminationState.TERMINATEDBIDIRECTIONAL);
 574         if (withSip) {
 575             onepBldr.setMappedServiceInterfacePoint(createSIP(1, oorTp, keyword));
 576         }
 577         return onepBldr.build();
 578     }
 579
 580     private Map<OwnedNodeEdgePointKey, OwnedNodeEdgePoint> createNepForRdmNode(int nbNep) {
 581         Map<OwnedNodeEdgePointKey, OwnedNodeEdgePoint> onepMap = new HashMap<>();
 582         for (int i = 1; i <= nbNep; i++) {
 583             Uuid nepUuid = new Uuid(UUID.nameUUIDFromBytes((String.join("+", "roadm node", "nep", String.valueOf(i)))
 584                 .getBytes(Charset.forName("UTF-8"))).toString());
 585             Name nepName = new NameBuilder()
 586                 .setValueName("NodeEdgePoint name")
 587                 .setValue(new StringBuilder("NodeEdgePoint_").append(i).toString())
 588                 .build();
 589             OwnedNodeEdgePoint onep = new OwnedNodeEdgePointBuilder()
 590                 .setUuid(nepUuid)
 591                 .setLayerProtocolName(LayerProtocolName.PHOTONICMEDIA)
 592                 .setName(Map.of(nepName.key(), nepName))
 593                 .setSupportedCepLayerProtocolQualifier(Set.of(PHOTONICLAYERQUALIFIEROMS.VALUE))
 594                 .setLinkPortDirection(PortDirection.BIDIRECTIONAL).setLinkPortRole(PortRole.SYMMETRIC)
 595                 .setAdministrativeState(AdministrativeState.UNLOCKED).setOperationalState(OperationalState.ENABLED)
 596                 .setLifecycleState(LifecycleState.INSTALLED).setTerminationDirection(TerminationDirection.BIDIRECTIONAL)
 597                 .setTerminationState(TerminationState.TERMINATEDBIDIRECTIONAL)
 598                 .build();
 599             onepMap.put(onep.key(), onep);
 600         }
 601         return onepMap;
 602     }
 603
 604     private Map<NodeRuleGroupKey, NodeRuleGroup> createNodeRuleGroupForRdmNode(Uuid nodeUuid,
 605                                                                                Collection<OwnedNodeEdgePoint> onepl) {
 606         Map<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePointKey,
 607             org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePoint>
 608             nepMap = new HashMap<>();
 609         for (OwnedNodeEdgePoint onep : onepl) {
 610             org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePoint
 611                 nep = new org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group
 612                     .NodeEdgePointBuilder()
 613                 .setTopologyUuid(tapiTopoUuid)
 614                 .setNodeUuid(nodeUuid)
 615                 .setNodeEdgePointUuid(onep.key().getUuid())
 616                 .build();
 617             nepMap.put(nep.key(), nep);
 618         }
 619         Map<NodeRuleGroupKey, NodeRuleGroup> nodeRuleGroupMap = new HashMap<>();
 620         Map<RuleKey, Rule> ruleList = new HashMap<>();
 621         Rule rule = new RuleBuilder()
 622             .setLocalId("forward")
 623             .setForwardingRule(ForwardingRule.MAYFORWARDACROSSGROUP)
 624             .setRuleType(RuleType.FORWARDING)
 625             .build();
 626         ruleList.put(rule.key(), rule);
 627         NodeRuleGroup nodeRuleGroup = new NodeRuleGroupBuilder()
 628             .setUuid(new Uuid(UUID.nameUUIDFromBytes(("rdm infra node rule group").getBytes(Charset.forName("UTF-8")))
 629                 .toString()))
 630             .setRule(ruleList)
 631             .setNodeEdgePoint(nepMap)
 632             .build();
 633         nodeRuleGroupMap.put(nodeRuleGroup.key(), nodeRuleGroup);
 634         return nodeRuleGroupMap;
 635     }
 636
 637     private Map<MappedServiceInterfacePointKey, MappedServiceInterfacePoint> createSIP(int nb, TerminationPoint tp,
 638                                                                                        String nodeId) {
 639         Map<MappedServiceInterfacePointKey, MappedServiceInterfacePoint> msipl = new HashMap<>();
 640         for (int i = 0; i < nb; i++) {
 641             MappedServiceInterfacePoint msip = new MappedServiceInterfacePointBuilder()
 642                 .setServiceInterfacePointUuid(new Uuid(UUID.nameUUIDFromBytes((String.join("+", "SIP", nodeId,
 643                     tp.getTpId().getValue())).getBytes(Charset.forName("UTF-8"))).toString()))
 644                 .build();
 645             msipl.put(msip.key(), msip);
 646         }
 647         return msipl;
 648     }
 649
 650     private Set<LAYERPROTOCOLQUALIFIER>
 651             createSupportedCepLayerProtocolQualifier(TerminationPoint tp, LayerProtocolName lpn) {
 652         Set<LAYERPROTOCOLQUALIFIER> sclpqSet = new HashSet<>();
 653         Collection<SupportedInterfaceCapability> sicList = tp.augmentation(
 654                 org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev230526.TerminationPoint1.class)
 655             .getTpSupportedInterfaces()
 656             .getSupportedInterfaceCapability().values();
 657         for (SupportedInterfaceCapability sic : sicList) {
 658             String ifCapType = sic.getIfCapType().toString().split("\\{")[0];
 659             switch (lpn.getName()) {
 660                 case "DSR":
 661                     switch (ifCapType) {
 662                         case "If10GEODU2e":
 663                             sclpqSet.add(ODUTYPEODU2E.VALUE);
 664                             sclpqSet.add(DIGITALSIGNALTYPE10GigELAN.VALUE);
 665                             break;
 666                         case "If10GEODU2":
 667                             sclpqSet.add(ODUTYPEODU2.VALUE);
 668                             sclpqSet.add(DIGITALSIGNALTYPE10GigELAN.VALUE);
 669                             break;
 670                         case "If10GE":
 671                             sclpqSet.add(DIGITALSIGNALTYPE10GigELAN.VALUE);
 672                             break;
 673                         case "If100GEODU4":
 674                             sclpqSet.add(DIGITALSIGNALTYPE100GigE.VALUE);
 675                             sclpqSet.add(ODUTYPEODU4.VALUE);
 676                             break;
 677                         case "If100GE":
 678                             sclpqSet.add(DIGITALSIGNALTYPE100GigE.VALUE);
 679                             break;
 680                         case "IfOCHOTU4ODU4":
 681                         case "IfOCH":
 682                             sclpqSet.add(ODUTYPEODU4.VALUE);
 683                             break;
 684                         default:
 685                             LOG.error("IfCapability type not managed");
 686                             break;
 687                     }
 688                     break;
 689                 case "PHOTONIC_MEDIA":
 690                     if (ifCapType.equals("IfOCHOTU4ODU4") || ifCapType.equals("IfOCH")) {
 691                         sclpqSet.add(PHOTONICLAYERQUALIFIEROTSi.VALUE);
 692                         sclpqSet.add(PHOTONICLAYERQUALIFIEROMS.VALUE);
 693                     }
 694                     break;
 695                 default:
 696                     LOG.error("Layer Protocol Name is unknown");
 697                     break;
 698             }
 699         }
 700         return sclpqSet;
 701     }
 702
 703     private void createTapiTransitionalLinks() {
 704         for (TerminationPoint tp : this.oorNetworkPortList) {
 705             Link transiLink = tapiLink.createTapiLink(this.ietfNodeId, tp.getTpId().getValue(), this.ietfNodeId,
 706                 tp.getTpId().getValue(), TapiStringConstants.TRANSITIONAL_LINK, TapiStringConstants.DSR,
 707                 TapiStringConstants.OTSI, TapiStringConstants.I_ODU, TapiStringConstants.I_OTSI,
 708                 "inService", "inService", Set.of(LayerProtocolName.ODU, LayerProtocolName.PHOTONICMEDIA),
 709                 Set.of(LayerProtocolName.ODU.getName(), LayerProtocolName.PHOTONICMEDIA.getName()),
 710                 this.tapiTopoUuid);
 711             this.tapiLinks.put(transiLink.key(), transiLink);
 712         }
 713     }
 714
 715     private void createTapiOmsLinks(Map<String, String> photonicNepUuisMap, Map<String, String> rdmInfraNepUuisMap) {
 716         Iterator<Entry<String, String>> it1 = photonicNepUuisMap.entrySet().iterator();
 717         Iterator<Entry<String, String>> it2 = rdmInfraNepUuisMap.entrySet().iterator();
 718         while (it1.hasNext()) {
 719             Map<NodeEdgePointKey, NodeEdgePoint> nepMap = new HashMap<>();
 720             Map.Entry<String, String> photonicEntry = it1.next();
 721             Map.Entry<String, String> rdmEntry = it2.next();
 722             Uuid sourceUuidTp = new Uuid(photonicEntry.getKey().split("--")[1]);
 723             Uuid sourceUuidNode = new Uuid(photonicEntry.getKey().split("--")[0]);
 724             Uuid destUuidTp = new Uuid(rdmEntry.getKey().split("--")[1]);
 725             Uuid destUuidNode = new Uuid(rdmEntry.getKey().split("--")[0]);
 726             NodeEdgePoint sourceNep = new NodeEdgePointBuilder()
 727                 .setTopologyUuid(this.tapiTopoUuid)
 728                 .setNodeUuid(sourceUuidNode)
 729                 .setNodeEdgePointUuid(sourceUuidTp)
 730                 .build();
 731             nepMap.put(sourceNep.key(), sourceNep);
 732             NodeEdgePoint destNep = new NodeEdgePointBuilder()
 733                 .setTopologyUuid(this.tapiTopoUuid)
 734                 .setNodeUuid(destUuidNode)
 735                 .setNodeEdgePointUuid(destUuidTp)
 736                 .build();
 737             nepMap.put(destNep.key(), destNep);
 738             Name linkName = new NameBuilder().setValueName("OMS link name")
 739                 .setValue(String.join(" and ", photonicEntry.getValue(), rdmEntry.getValue()))
 740                 .build();
 741             Link omsLink = new LinkBuilder()
 742                 .setUuid(new Uuid(
 743                     UUID.nameUUIDFromBytes((String.join(" and ", photonicEntry.getValue(), rdmEntry.getValue()))
 744                             .getBytes(Charset.forName("UTF-8")))
 745                         .toString()))
 746                 .setName(Map.of(linkName.key(), linkName))
 747                 .setLayerProtocolName(Set.of(LayerProtocolName.PHOTONICMEDIA))
 748                 .setNodeEdgePoint(nepMap)
 749                 .setDirection(ForwardingDirection.BIDIRECTIONAL)
 750                 .build();
 751             this.tapiLinks.put(omsLink.key(), omsLink);
 752         }
 753     }
 754
 755     public Map<NodeKey, org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node>
 756             getTapiNodes() {
 757         return tapiNodes;
 758     }
 759
 760     public Map<LinkKey, Link> getTapiLinks() {
 761         return tapiLinks;
 762     }
 763 }