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