networkmodel/src/main/java/org/opendaylight/transportpce/networkmodel/util/OpenRoadmOtnTopology.java

   1 /*
   2  * Copyright © 2020 Orange. 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
   9 package org.opendaylight.transportpce.networkmodel.util;
  10
  11 import com.google.common.collect.ImmutableMap;
  12 import java.util.ArrayList;
  13 import java.util.HashMap;
  14 import java.util.List;
  15 import java.util.Map;
  16 import java.util.stream.Collectors;
  17 import org.eclipse.jdt.annotation.Nullable;
  18 import org.opendaylight.transportpce.common.NetworkUtils;
  19 import org.opendaylight.transportpce.networkmodel.dto.OtnTopoNode;
  20 import org.opendaylight.transportpce.networkmodel.dto.TopologyShard;
  21 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220114.mapping.Mapping;
  22 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220114.network.Nodes;
  23 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev191129.State;
  24 import org.opendaylight.yang.gen.v1.http.org.openroadm.device.types.rev191129.XpdrNodeTypes;
  25 import org.opendaylight.yang.gen.v1.http.org.openroadm.equipment.states.types.rev191129.AdminStates;
  26 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev200327.xpdr.odu.switching.pools.OduSwitchingPools;
  27 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev200327.xpdr.odu.switching.pools.OduSwitchingPoolsBuilder;
  28 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev200327.xpdr.odu.switching.pools.OduSwitchingPoolsKey;
  29 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev200327.xpdr.odu.switching.pools.odu.switching.pools.NonBlockingList;
  30 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev200327.xpdr.odu.switching.pools.odu.switching.pools.NonBlockingListBuilder;
  31 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev200327.xpdr.odu.switching.pools.odu.switching.pools.NonBlockingListKey;
  32 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.OpenroadmLinkType;
  33 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.OpenroadmNodeType;
  34 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.OpenroadmTpType;
  35 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.xpdr.tp.supported.interfaces.SupportedInterfaceCapability;
  36 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.xpdr.tp.supported.interfaces.SupportedInterfaceCapabilityBuilder;
  37 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.xpdr.tp.supported.interfaces.SupportedInterfaceCapabilityKey;
  38 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.ODTU4TsAllocated;
  39 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.ODTUCnTs;
  40 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.ODU0;
  41 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.ODU2;
  42 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.ODU2e;
  43 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.ODU4;
  44 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.OdtuTypeIdentity;
  45 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.OduRateIdentity;
  46 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.Link1;
  47 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.Link1Builder;
  48 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.Node1;
  49 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.Node1Builder;
  50 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.TerminationPoint1;
  51 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.TerminationPoint1Builder;
  52 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.SwitchingPools;
  53 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.SwitchingPoolsBuilder;
  54 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.TpBandwidthSharing;
  55 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.TpBandwidthSharingBuilder;
  56 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.XpdrAttributes;
  57 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.XpdrAttributesBuilder;
  58 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.termination.point.TpSupportedInterfaces;
  59 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.termination.point.TpSupportedInterfacesBuilder;
  60 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.termination.point.XpdrTpPortConnectionAttributesBuilder;
  61 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.SupportedIfCapability;
  62 import org.opendaylight.yang.gen.v1.http.org.openroadm.switching.pool.types.rev191129.SwitchingPoolTypes;
  63 import org.opendaylight.yang.gen.v1.http.org.openroadm.xponder.rev200529.xpdr.otn.tp.attributes.OdtuTpnPool;
  64 import org.opendaylight.yang.gen.v1.http.org.openroadm.xponder.rev200529.xpdr.otn.tp.attributes.OdtuTpnPoolBuilder;
  65 import org.opendaylight.yang.gen.v1.http.transportpce.topology.rev220123.OtnLinkType;
  66 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NetworkId;
  67 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NodeId;
  68 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.Node;
  69 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeBuilder;
  70 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeKey;
  71 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNode;
  72 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeBuilder;
  73 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeKey;
  74 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.TpId;
  75 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.Link;
  76 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkBuilder;
  77 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPoint;
  78 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointBuilder;
  79 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointKey;
  80 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.termination.point.SupportingTerminationPoint;
  81 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.termination.point.SupportingTerminationPointBuilder;
  82 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.termination.point.SupportingTerminationPointKey;
  83 import org.opendaylight.yangtools.yang.common.Uint16;
  84 import org.opendaylight.yangtools.yang.common.Uint32;
  85 import org.slf4j.Logger;
  86 import org.slf4j.LoggerFactory;
  87
  88 public final class OpenRoadmOtnTopology {
  89
  90     private static final Logger LOG = LoggerFactory.getLogger(OpenRoadmOtnTopology.class);
  91     private static final String CLIENT = "-CLIENT";
  92     private static final String NETWORK = "-NETWORK";
  93     private static final String XPDR = "-XPDR";
  94     private static final int NB_TRIB_PORTS = 80;
  95     private static final int NB_TRIB_SLOTS = 80;
  96     private static final int NB_TRIB_SLOT_PER_10GE = 8;
  97
  98     private OpenRoadmOtnTopology() {
  99     }
 100
 101     public static TopologyShard createTopologyShard(Nodes mappingNode) {
 102         List<Node> nodes = new ArrayList<>();
 103         List<Link> links = new ArrayList<>();
 104         Map<Integer, OtnTopoNode> xpdrMap = convertPortMappingToOtnNodeList(mappingNode);
 105         for (OtnTopoNode node : xpdrMap.values()) {
 106             switch (node.getNodeType()) {
 107                 case Tpdr:
 108                     nodes.add(createTpdr(node));
 109                     break;
 110                 case Mpdr:
 111                     nodes.add(createMuxpdr(node));
 112                     break;
 113                 case Switch:
 114                     nodes.add(createSwitch(node));
 115                     break;
 116                 default:
 117                     LOG.error("unknown otn node type {}", node.getNodeType().getName());
 118                     return null;
 119             }
 120         }
 121         return new TopologyShard(nodes, links);
 122     }
 123
 124     public static TopologyShard createOtnLinks(String nodeA, String tpA, String nodeZ, String tpZ,
 125         OtnLinkType linkType) {
 126         List<Link> links = null;
 127         if (OtnLinkType.OTU4.equals(linkType) || OtnLinkType.OTUC4.equals(linkType)) {
 128             links = initialiseOtnLinks(nodeA, tpA, nodeZ, tpZ, linkType);
 129         }
 130         return new TopologyShard(null, links);
 131     }
 132
 133     public static TopologyShard createOtnLinks(
 134             org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915.renderer.rpc.result.sp
 135                 .Link notifLink,
 136             OtnLinkType linkType) {
 137
 138         return new TopologyShard(null, initialiseOtnLinks(notifLink.getATermination().getNodeId(),
 139             notifLink.getATermination().getTpId(), notifLink.getZTermination().getNodeId(),
 140             notifLink.getZTermination().getTpId(), linkType));
 141     }
 142
 143     public static TopologyShard createOtnLinks(
 144             org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915.renderer.rpc.result.sp
 145                 .Link notifLink,
 146             List<Link> supportedOtu4links,
 147             List<TerminationPoint> supportedTPs,
 148             OtnLinkType linkType) {
 149
 150         List<Link> links;
 151         switch (linkType) {
 152             case OTU4:
 153             case OTUC4:
 154                 links = initialiseOtnLinks(
 155                         notifLink.getATermination().getNodeId(), notifLink.getATermination().getTpId(),
 156                         notifLink.getZTermination().getNodeId(), notifLink.getZTermination().getTpId(), linkType);
 157                 return new TopologyShard(null, links);
 158             case ODTU4:
 159             case ODUC4:
 160                 links = initialiseOtnLinks(
 161                     notifLink.getATermination().getNodeId(), notifLink.getATermination().getTpId(),
 162                     notifLink.getZTermination().getNodeId(), notifLink.getZTermination().getTpId(), linkType);
 163                 links.addAll(updateOtnLinkBwParameters(supportedOtu4links, linkType));
 164                 List<TerminationPoint> updatedTPs = new ArrayList<>();
 165                 for (TerminationPoint tp : supportedTPs) {
 166                     updatedTPs.add(updateTp(tp, true, linkType));
 167                 }
 168                 return new TopologyShard(null, links, updatedTPs);
 169             default:
 170                 return null;
 171         }
 172     }
 173
 174     public static TopologyShard createOtnLinks(List<Link> suppOtuLinks, List<TerminationPoint> oldTps,
 175             OtnLinkType linkType) {
 176         List<Link> links = new ArrayList<>();
 177         for (Link link : suppOtuLinks) {
 178             if (link.augmentation(Link1.class) == null) {
 179                 LOG.error("Error with otn parameters of supported link {}", link.getLinkId().getValue());
 180                 continue;
 181             }
 182             if (OtnLinkType.ODTU4.equals(linkType)
 183                 && link.augmentation(Link1.class).getAvailableBandwidth().equals(Uint32.valueOf(100000))) {
 184                 links.add(updateOtnLinkBwParameters(link, 0L, 100000L));
 185             } else if (OtnLinkType.ODUC4.equals(linkType)
 186                 && link.augmentation(Link1.class).getAvailableBandwidth().equals(Uint32.valueOf(400000))) {
 187                 links.add(updateOtnLinkBwParameters(link, 0L, 400000L));
 188             } else if (OtnLinkType.ODUC3.equals(linkType)
 189                 && link.augmentation(Link1.class).getAvailableBandwidth().equals(Uint32.valueOf(300000))) {
 190                 links.add(updateOtnLinkBwParameters(link, 0L, 300000L));
 191             } else if (OtnLinkType.ODUC2.equals(linkType)
 192                 && link.augmentation(Link1.class).getAvailableBandwidth().equals(Uint32.valueOf(200000))) {
 193                 links.add(updateOtnLinkBwParameters(link, 0L, 200000L));
 194             } else {
 195                 LOG.error("Unsupported OTN Link Type link or unsufficient available bandwith: {}",
 196                     link.getLinkId().getValue());
 197             }
 198             //TODO use a Map here instead of multiple else-if-blocks
 199         }
 200         if (links.size() == 2) {
 201             links.addAll(initialiseOtnLinks(suppOtuLinks.get(0).getSource().getSourceNode().getValue(),
 202                 suppOtuLinks.get(0).getSource().getSourceTp().getValue(),
 203                 suppOtuLinks.get(0).getDestination().getDestNode().getValue(),
 204                 suppOtuLinks.get(0).getDestination().getDestTp().getValue(),
 205                 linkType));
 206         }
 207         List<TerminationPoint> tps = new ArrayList<>();
 208         for (TerminationPoint tp : oldTps) {
 209             tps.add(updateTp(tp, true, linkType));
 210         }
 211         if (links.size() == 4 && tps.size() == 2) {
 212             return new TopologyShard(null, links, tps);
 213         } else {
 214             return new TopologyShard(null, null, null);
 215         }
 216     }
 217
 218     public static TopologyShard updateOtnLinks(List<Link> suppOduLinks, List<TerminationPoint> oldTps,
 219         Uint32 serviceRate, Short tribPortNb, Short minTribSlotNb, Short maxTribSlotNb, boolean isDeletion) {
 220         List<Link> links = new ArrayList<>();
 221         Long bwIncr;
 222         switch (serviceRate.intValue()) {
 223             case 1:
 224                 bwIncr = 1000L;
 225                 break;
 226             case 10:
 227                 bwIncr = 10000L;
 228                 break;
 229             case 100:
 230                 bwIncr = 100000L;
 231                 break;
 232             default:
 233                 LOG.warn("Error with not managed service rate {}", serviceRate.toString());
 234                 return new TopologyShard(null, null, null);
 235         }
 236         for (Link link : suppOduLinks) {
 237             if (link.augmentation(Link1.class) != null && link.augmentation(Link1.class).getAvailableBandwidth() != null
 238                 && link.augmentation(Link1.class).getUsedBandwidth() != null) {
 239                 Uint32 avlBw = link.augmentation(Link1.class).getAvailableBandwidth();
 240                 Uint32 usedBw = link.augmentation(Link1.class).getUsedBandwidth();
 241                 if (avlBw.toJava() < bwIncr) {
 242                     bwIncr = 0L;
 243                 }
 244                 if (isDeletion) {
 245                     links.add(updateOtnLinkBwParameters(link, avlBw.toJava() + bwIncr,
 246                         usedBw.toJava() - bwIncr));
 247                 } else {
 248                     links.add(updateOtnLinkBwParameters(link, avlBw.toJava() - bwIncr,
 249                         usedBw.toJava() + bwIncr));
 250                 }
 251             } else {
 252                 LOG.error("Error with otn parameters of supported link {}", link.getLinkId().getValue());
 253             }
 254         }
 255         List<TerminationPoint> tps = new ArrayList<>();
 256         for (TerminationPoint tp : oldTps) {
 257             if (bwIncr != 0) {
 258                 tps.add(updateNodeTpTsPool(tp, serviceRate, tribPortNb, minTribSlotNb, maxTribSlotNb, isDeletion));
 259             }
 260         }
 261         if (!links.isEmpty() && !tps.isEmpty()) {
 262             return new TopologyShard(null, links, tps);
 263         } else {
 264             LOG.error("unable to update otn links");
 265             return new TopologyShard(null, null, null);
 266         }
 267     }
 268
 269     public static TopologyShard updateOtnLinks(List<Link> suppOtuLinks, boolean isDeletion) {
 270         List<Link> links = new ArrayList<>();
 271         for (Link link : suppOtuLinks) {
 272             if (link.augmentation(Link1.class) == null
 273                 || link.augmentation(Link1.class).getAvailableBandwidth() == null
 274                 || link.augmentation(Link1.class).getUsedBandwidth() == null) {
 275                 LOG.error("Error with otn parameters of supported link {}", link.getLinkId().getValue());
 276             } else {
 277                 if (isDeletion) {
 278                     links.add(updateOtnLinkBwParameters(link, Long.valueOf(100000), Long.valueOf(0)));
 279                 } else {
 280                     links.add(updateOtnLinkBwParameters(link, Long.valueOf(0), Long.valueOf(100000)));
 281                 }
 282             }
 283         }
 284         if (links.isEmpty()) {
 285             LOG.error("unable to update otn links");
 286             return new TopologyShard(null, null, null);
 287         } else {
 288             return new TopologyShard(null, links, null);
 289         }
 290     }
 291
 292     public static TopologyShard deleteOtnLinks(List<Link> suppOtuLinks, List<TerminationPoint> oldTps,
 293             OtnLinkType linkType) {
 294         List<Link> links = new ArrayList<>();
 295         OtnLinkType otnLinkType = null;
 296         for (Link link : suppOtuLinks) {
 297             if (link.augmentation(Link1.class) != null && link.augmentation(
 298                     org.opendaylight.yang.gen.v1.http.transportpce.topology.rev220123.Link1.class) != null) {
 299                 otnLinkType = link.augmentation(
 300                         org.opendaylight.yang.gen.v1.http.transportpce.topology.rev220123.Link1.class).getOtnLinkType();
 301                 if (OtnLinkType.OTU4.equals(otnLinkType)) {
 302                     links.add(updateOtnLinkBwParameters(link, 100000L, 0L));
 303                 } else if (OtnLinkType.OTUC4.equals(otnLinkType)) {
 304                     links.add(updateOtnLinkBwParameters(link, 400000L, 0L));
 305                 } else {
 306                     LOG.warn("Unexpected otn-link-type {} for link {}", otnLinkType, link.getLinkId());
 307                 }
 308             } else {
 309                 LOG.error("Error with otn parameters of supported link {}", link.getLinkId().getValue());
 310                 return new TopologyShard(null, null, null);
 311             }
 312         }
 313         List<TerminationPoint> tps = new ArrayList<>();
 314         for (TerminationPoint tp : oldTps) {
 315             tps.add(updateTp(tp, false, linkType));
 316         }
 317         if (!links.isEmpty() && !tps.isEmpty()) {
 318             return new TopologyShard(null, links, tps);
 319         } else {
 320             return new TopologyShard(null, null, null);
 321         }
 322     }
 323
 324     private static List<Link> initialiseOtnLinks(String nodeA, String tpA, String nodeZ, String tpZ,
 325             OtnLinkType linkType) {
 326         List<Link> links = new ArrayList<>();
 327         String nodeATopo = formatNodeName(nodeA, tpA);
 328         String nodeZTopo = formatNodeName(nodeZ, tpZ);
 329         org.opendaylight.yang.gen.v1.http.transportpce.topology.rev220123.Link1 tpceLink1
 330             = new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev220123.Link1Builder()
 331             .setOtnLinkType(linkType).build();
 332         Link1Builder otnLink1Bldr = new Link1Builder()
 333             .setUsedBandwidth(Uint32.valueOf(0));
 334         switch (linkType) {
 335             case OTU4:
 336             case ODTU4:
 337                 otnLink1Bldr.setAvailableBandwidth(Uint32.valueOf(100000));
 338                 break;
 339             case OTUC4:
 340             case ODUC4:
 341                 otnLink1Bldr.setAvailableBandwidth(Uint32.valueOf(400000));
 342                 break;
 343             default:
 344                 LOG.error("unable to set available bandwidth to unknown link type");
 345                 break;
 346         }
 347         // create link A-Z
 348         LinkBuilder ietfLinkAZBldr = TopologyUtils.createLink(nodeATopo, nodeZTopo, tpA, tpZ, linkType.getName());
 349         ietfLinkAZBldr
 350             .addAugmentation(tpceLink1)
 351             .addAugmentation(otnLink1Bldr.build())
 352             .addAugmentation(
 353                 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Link1Builder(
 354                         ietfLinkAZBldr.augmentation(
 355                             org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Link1.class))
 356                         .setLinkType(OpenroadmLinkType.OTNLINK)
 357                         .setOperationalState(State.InService)
 358                         .setAdministrativeState(AdminStates.InService)
 359                         .build());
 360         links.add(ietfLinkAZBldr.build());
 361         // create link Z-A
 362         LinkBuilder ietfLinkZABldr = TopologyUtils.createLink(nodeZTopo, nodeATopo, tpZ, tpA, linkType.getName());
 363         ietfLinkZABldr
 364             .addAugmentation(tpceLink1)
 365             .addAugmentation(otnLink1Bldr.build())
 366             .addAugmentation(
 367                 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Link1Builder(
 368                         ietfLinkZABldr.augmentation(
 369                             org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Link1.class))
 370                         .setLinkType(OpenroadmLinkType.OTNLINK)
 371                         .setOperationalState(State.InService)
 372                         .setAdministrativeState(AdminStates.InService)
 373                         .build());
 374         links.add(ietfLinkZABldr.build());
 375         return links;
 376     }
 377
 378     private static Link updateOtnLinkBwParameters(Link link, Long availBw, Long usedBw) {
 379         LOG.debug("in updateOtnLinkBwParameters with availBw = {}, usedBw = {}", availBw, usedBw);
 380         LinkBuilder updatedLinkBldr = new LinkBuilder(link);
 381         Link1Builder updatedLink1Bldr = new Link1Builder(link.augmentation(Link1.class))
 382             .setAvailableBandwidth(Uint32.valueOf(availBw))
 383             .setUsedBandwidth(Uint32.valueOf(usedBw));
 384         updatedLinkBldr.addAugmentation(updatedLink1Bldr.build());
 385         return updatedLinkBldr.build();
 386     }
 387
 388     private static List<Link> updateOtnLinkBwParameters(List<Link> supportedLinks, OtnLinkType linkType) {
 389         LOG.debug("in updateOtnLinkBwParameters with supportedLinks = {}, linkType = {}", supportedLinks, linkType);
 390         Uint32 usedBw;
 391         switch (linkType) {
 392             case ODTU4:
 393                 usedBw = Uint32.valueOf(100000);
 394                 break;
 395             case ODUC4:
 396                 usedBw = Uint32.valueOf(400000);
 397                 break;
 398             default:
 399                 usedBw = Uint32.valueOf(0);
 400                 break;
 401         }
 402         List<Link> updatedlinks = new ArrayList<>();
 403         for (Link link : supportedLinks) {
 404             LinkBuilder updatedLinkBldr = new LinkBuilder(link);
 405             updatedLinkBldr.addAugmentation(new Link1Builder(link.augmentation(Link1.class))
 406                 .setAvailableBandwidth(Uint32.valueOf(0))
 407                 .setUsedBandwidth(usedBw)
 408                 .build());
 409             updatedlinks.add(updatedLinkBldr.build());
 410         }
 411         return updatedlinks;
 412     }
 413
 414     private static TerminationPoint updateTp(TerminationPoint originalTp, boolean addingTsTpnPoolTermination,
 415             OtnLinkType linkType) {
 416         LOG.debug("in updateTp");
 417         TerminationPointBuilder tpBldr = new TerminationPointBuilder(originalTp);
 418         TerminationPoint1Builder otnTp1Bldr = new TerminationPoint1Builder(
 419             tpBldr.augmentation(TerminationPoint1.class));
 420         XpdrTpPortConnectionAttributesBuilder xtpcaBldr = new XpdrTpPortConnectionAttributesBuilder(otnTp1Bldr
 421             .getXpdrTpPortConnectionAttributes());
 422         if (addingTsTpnPoolTermination) {
 423             List<Uint16> tsPool = new ArrayList<>();
 424             for (int i = 1; i <= NB_TRIB_SLOTS; i++) {
 425                 tsPool.add(Uint16.valueOf(i));
 426             }
 427             xtpcaBldr.setTsPool(tsPool);
 428             List<Uint16> tpnPool = new ArrayList<>();
 429             int nbTribPort = NB_TRIB_PORTS;
 430             if (OtnLinkType.ODUC4.equals(linkType)) {
 431                 nbTribPort = 4;
 432             }
 433             for (int i = 1; i <= nbTribPort; i++) {
 434                 tpnPool.add(Uint16.valueOf(i));
 435             }
 436             OdtuTpnPool oduTpnPool = new OdtuTpnPoolBuilder().setOdtuType(ODTU4TsAllocated.class)
 437                 .setTpnPool(tpnPool).build();
 438             xtpcaBldr.setOdtuTpnPool(ImmutableMap.of(oduTpnPool.key(),oduTpnPool));
 439         } else {
 440             xtpcaBldr.setTsPool(null);
 441             xtpcaBldr.setOdtuTpnPool(ImmutableMap.of());
 442         }
 443         return tpBldr.addAugmentation(otnTp1Bldr.setXpdrTpPortConnectionAttributes(xtpcaBldr.build()).build()).build();
 444     }
 445
 446     private static TerminationPoint updateNodeTpTsPool(TerminationPoint tp, Uint32 serviceRate, Short tribPortNb,
 447         Short minTribSlotNb, Short maxTribSlotNb, boolean isDeletion) {
 448         LOG.debug("in updateNodeTpTsPool");
 449         TerminationPointBuilder tpBldr = new TerminationPointBuilder(tp);
 450         @Nullable
 451         XpdrTpPortConnectionAttributesBuilder xtpcaBldr = new XpdrTpPortConnectionAttributesBuilder(
 452             tpBldr.augmentation(TerminationPoint1.class).getXpdrTpPortConnectionAttributes());
 453         List<Uint16> tsPool = new ArrayList<>(xtpcaBldr.getTsPool());
 454         if (isDeletion) {
 455             for (int i = minTribSlotNb; i <= maxTribSlotNb; i++) {
 456                 tsPool.add(Uint16.valueOf(i));
 457             }
 458         } else {
 459             for (int i = minTribSlotNb; i <= maxTribSlotNb; i++) {
 460                 tsPool.remove(Uint16.valueOf(i));
 461             }
 462         }
 463         xtpcaBldr.setTsPool(tsPool);
 464         List<Uint16> tpnPool;
 465         List<OdtuTpnPool> odtuTpnPoolValues = new ArrayList<>(xtpcaBldr.getOdtuTpnPool().values());
 466         if (odtuTpnPoolValues.get(0).getTpnPool() != null) {
 467             tpnPool = new ArrayList<>(odtuTpnPoolValues.get(0).getTpnPool());
 468             if (isDeletion) {
 469                 tpnPool.add(Uint16.valueOf(tribPortNb));
 470             } else {
 471                 tpnPool.remove(Uint16.valueOf(tribPortNb));
 472             }
 473         } else {
 474             tpnPool = new ArrayList<>();
 475         }
 476         Class<? extends OdtuTypeIdentity> odtuType = null;
 477         switch (serviceRate.intValue()) {
 478             case 1:
 479             case 10:
 480                 odtuType = ODTU4TsAllocated.class;
 481                 break;
 482             case 100:
 483                 odtuType = ODTUCnTs.class;
 484                 break;
 485             default:
 486                 LOG.warn("Unable to set the odtu-type");
 487                 break;
 488         }
 489         OdtuTpnPool odtuTpnPool = new OdtuTpnPoolBuilder().setOdtuType(odtuType)
 490             .setTpnPool(tpnPool).build();
 491         xtpcaBldr.setOdtuTpnPool(ImmutableMap.of(odtuTpnPool.key(),odtuTpnPool));
 492
 493         tpBldr.addAugmentation(new TerminationPoint1Builder(tp.augmentation(TerminationPoint1.class))
 494                 .setXpdrTpPortConnectionAttributes(xtpcaBldr.build()).build());
 495         return tpBldr.build();
 496     }
 497
 498     private static Map<Integer, OtnTopoNode> convertPortMappingToOtnNodeList(Nodes mappingNode) {
 499         List<Mapping> networkMappings = mappingNode.nonnullMapping().values()
 500                 .stream().filter(k -> k.getLogicalConnectionPoint()
 501             .contains("NETWORK")).collect(Collectors.toList());
 502         Map<Integer, OtnTopoNode> xpdrMap = new HashMap<>();
 503         for (Mapping mapping : networkMappings) {
 504             Integer xpdrNb = Integer.parseInt(mapping.getLogicalConnectionPoint().split("XPDR")[1].split("-")[0]);
 505             if (!xpdrMap.containsKey(xpdrNb)) {
 506                 List<Mapping> xpdrNetMaps = mappingNode.nonnullMapping().values()
 507                         .stream().filter(k -> k.getLogicalConnectionPoint()
 508                     .contains("XPDR" + xpdrNb + NETWORK)).collect(Collectors.toList());
 509                 List<Mapping> xpdrClMaps = mappingNode.nonnullMapping().values()
 510                         .stream().filter(k -> k.getLogicalConnectionPoint()
 511                     .contains("XPDR" + xpdrNb + CLIENT)).collect(Collectors.toList());
 512                 OtnTopoNode otnNode = null;
 513                 if (mapping.getXponderType() != null) {
 514                     otnNode = new OtnTopoNode(mappingNode.getNodeId(), mappingNode.getNodeInfo().getNodeClli(), xpdrNb,
 515                         mapping.getXponderType(), fillConnectionMapLcp(xpdrNetMaps), fillConnectionMapLcp(xpdrClMaps),
 516                         xpdrNetMaps, xpdrClMaps);
 517                 } else {
 518                     otnNode = new OtnTopoNode(mappingNode.getNodeId(), mappingNode.getNodeInfo().getNodeClli(), xpdrNb,
 519                         XpdrNodeTypes.Tpdr, fillConnectionMapLcp(xpdrNetMaps), fillConnectionMapLcp(xpdrClMaps),
 520                         xpdrNetMaps, xpdrClMaps);
 521                 }
 522                 xpdrMap.put(xpdrNb, otnNode);
 523             }
 524         }
 525         LOG.debug("there are {} xpdr to build", xpdrMap.size());
 526         xpdrMap.forEach((k, v) -> LOG.debug("xpdr {} = {} - {} - {} - {}", k, v.getNodeId(), v.getNodeType(),
 527             v.getNbTpClient(), v.getNbTpNetwork()));
 528         return xpdrMap;
 529     }
 530
 531     private static Map<String, String> fillConnectionMapLcp(List<Mapping> mappingList) {
 532         Map<String, String> xpdrConnectionMap = new HashMap<>();
 533         for (Mapping map : mappingList) {
 534             if (map.getConnectionMapLcp() != null) {
 535                 xpdrConnectionMap.put(map.getLogicalConnectionPoint(), map.getConnectionMapLcp());
 536             } else {
 537                 xpdrConnectionMap.put(map.getLogicalConnectionPoint(), null);
 538             }
 539         }
 540         return xpdrConnectionMap;
 541     }
 542
 543     private static Node createTpdr(OtnTopoNode node) {
 544         // create otn-topology node augmentation
 545         XpdrAttributes xpdrAttr = new XpdrAttributesBuilder()
 546             .setXpdrNumber(Uint16.valueOf(node.getXpdrNb()))
 547             .build();
 548         Node1 otnNodeAug = new Node1Builder()
 549             .setXpdrAttributes(xpdrAttr)
 550             .build();
 551         org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1 ocnNodeAug =
 552             new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1Builder()
 553                     .setNodeType(OpenroadmNodeType.TPDR)
 554                     .setOperationalState(State.InService)
 555                     .setAdministrativeState(AdminStates.InService)
 556                     .build();
 557         // create ietf node augmentation to add TP list
 558         Map<TerminationPointKey,TerminationPoint> tpMap = new HashMap<>();
 559         // creation of tps
 560         createTP(tpMap, node, OpenroadmTpType.XPONDERCLIENT, false);
 561         createTP(tpMap, node, OpenroadmTpType.XPONDERNETWORK, true);
 562
 563         org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1 ietfNodeAug =
 564             new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder()
 565             .setTerminationPoint(tpMap)
 566             .build();
 567
 568         // return ietfNode
 569         return new NodeBuilder()
 570             .setNodeId(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
 571             .withKey(new NodeKey(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
 572             .setSupportingNode(createSupportingNodes(node))
 573             .addAugmentation(otnNodeAug)
 574             .addAugmentation(ocnNodeAug)
 575             .addAugmentation(ietfNodeAug)
 576             .build();
 577     }
 578
 579     private static Node createMuxpdr(OtnTopoNode node) {
 580         // create otn-topology node augmentation
 581         // TODO: will need to be completed
 582         TpBandwidthSharing tpBwSh = new TpBandwidthSharingBuilder().build();
 583         XpdrAttributes xpdrAttr = new XpdrAttributesBuilder()
 584             .setXpdrNumber(Uint16.valueOf(node.getXpdrNb()))
 585             .build();
 586
 587         Map<NonBlockingListKey, NonBlockingList> nbMap = new HashMap<>();
 588         for (int i = 1; i <= node.getNbTpClient(); i++) {
 589             List<TpId> tpList = new ArrayList<>();
 590             TpId tpId = new TpId("XPDR" + node.getXpdrNb() + CLIENT + i);
 591             tpList.add(tpId);
 592             tpId = new TpId("XPDR" + node.getXpdrNb() + "-NETWORK1");
 593             tpList.add(tpId);
 594             NonBlockingList nbl = new NonBlockingListBuilder()
 595                 .setNblNumber(Uint16.valueOf(i))
 596                 .setTpList(tpList)
 597                 .setAvailableInterconnectBandwidth(Uint32.valueOf(node.getNbTpNetwork() * 10L))
 598                 .setInterconnectBandwidthUnit(Uint32.valueOf(1000000000))
 599                 .build();
 600             nbMap.put(nbl.key(),nbl);
 601         }
 602         OduSwitchingPools oduSwitchPool = new OduSwitchingPoolsBuilder()
 603             .setSwitchingPoolNumber(Uint16.valueOf(1))
 604             .setSwitchingPoolType(SwitchingPoolTypes.NonBlocking)
 605             .setNonBlockingList(nbMap)
 606             .build();
 607         SwitchingPools switchingPools = new SwitchingPoolsBuilder()
 608             .setOduSwitchingPools(Map.of(oduSwitchPool.key(),oduSwitchPool))
 609             .build();
 610         Node1 otnNodeAug = new Node1Builder()
 611             .setTpBandwidthSharing(tpBwSh)
 612             .setXpdrAttributes(xpdrAttr)
 613             .setSwitchingPools(switchingPools)
 614             .build();
 615         org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1 ocnNodeAug =
 616             new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1Builder()
 617                     .setNodeType(OpenroadmNodeType.MUXPDR)
 618                     .setAdministrativeState(AdminStates.InService)
 619                     .setOperationalState(State.InService)
 620                     .build();
 621
 622         // create ietf node augmentation to add TP list
 623         Map<TerminationPointKey, TerminationPoint> tpMap = new HashMap<>();
 624         // creation of tps
 625         createTP(tpMap, node, OpenroadmTpType.XPONDERCLIENT, true);
 626         createTP(tpMap, node, OpenroadmTpType.XPONDERNETWORK, true);
 627
 628         org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1 ietfNodeAug =
 629             new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder()
 630             .setTerminationPoint(tpMap)
 631             .build();
 632
 633         // return ietfNode
 634         return new NodeBuilder()
 635             .setNodeId(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
 636             .withKey(new NodeKey(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
 637             .setSupportingNode(createSupportingNodes(node))
 638             .addAugmentation(otnNodeAug)
 639             .addAugmentation(ocnNodeAug)
 640             .addAugmentation(ietfNodeAug)
 641             .build();
 642     }
 643
 644     private static Node createSwitch(OtnTopoNode node) {
 645         List<TpId> tpl = new ArrayList<>();
 646         TpId tpId = null;
 647         for (int i = 1; i <= node.getNbTpClient(); i++) {
 648             tpId = new TpId("XPDR" + node.getXpdrNb() + CLIENT + i);
 649             tpl.add(tpId);
 650         }
 651         for (int i = 1; i <= node.getNbTpNetwork(); i++) {
 652             tpId = new TpId("XPDR" + node.getXpdrNb() + NETWORK + i);
 653             tpl.add(tpId);
 654         }
 655         Map<NonBlockingListKey, NonBlockingList> nbMap = new HashMap<>();
 656         NonBlockingList nbl = new NonBlockingListBuilder()
 657             .setNblNumber(Uint16.valueOf(1))
 658             .setTpList(tpl)
 659             .build();
 660         nbMap.put(nbl.key(),nbl);
 661
 662         OduSwitchingPools oduSwitchPool = new OduSwitchingPoolsBuilder()
 663             .setSwitchingPoolNumber(Uint16.valueOf(1))
 664             .setSwitchingPoolType(SwitchingPoolTypes.NonBlocking)
 665             .setNonBlockingList(nbMap)
 666             .build();
 667         Map<OduSwitchingPoolsKey, OduSwitchingPools> oduSwitchPoolList = new HashMap<>();
 668         oduSwitchPoolList.put(oduSwitchPool.key(),oduSwitchPool);
 669         SwitchingPools switchingPools = new SwitchingPoolsBuilder()
 670             .setOduSwitchingPools(oduSwitchPoolList)
 671             .build();
 672
 673         // create otn-topology node augmentation
 674         // TODO: will need to be completed
 675         TpBandwidthSharing tpBwSh = new TpBandwidthSharingBuilder().build();
 676         XpdrAttributes xpdrAttr = new XpdrAttributesBuilder()
 677             .setXpdrNumber(Uint16.valueOf(node.getXpdrNb()))
 678             .build();
 679
 680         Node1 otnNodeAug = new Node1Builder()
 681             .setTpBandwidthSharing(tpBwSh)
 682             .setXpdrAttributes(xpdrAttr)
 683             .setSwitchingPools(switchingPools)
 684             .build();
 685         org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1 ocnNodeAug =
 686             new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1Builder()
 687                     .setNodeType(OpenroadmNodeType.SWITCH)
 688                     .setOperationalState(State.InService)
 689                     .setAdministrativeState(AdminStates.InService)
 690                     .build();
 691
 692         // create ietf node augmentation to add TP list
 693         Map<TerminationPointKey, TerminationPoint> tpMap = new HashMap<>();
 694         // creation of tps
 695         createTP(tpMap, node, OpenroadmTpType.XPONDERCLIENT, true);
 696         createTP(tpMap, node, OpenroadmTpType.XPONDERNETWORK, true);
 697         org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1 ietfNodeAug =
 698             new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder()
 699             .setTerminationPoint(tpMap)
 700             .build();
 701
 702         // return ietfNode
 703         return new NodeBuilder()
 704             .setNodeId(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
 705             .withKey(new NodeKey(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
 706             .setSupportingNode(createSupportingNodes(node))
 707             .addAugmentation(otnNodeAug)
 708             .addAugmentation(ocnNodeAug)
 709             .addAugmentation(ietfNodeAug)
 710             .build();
 711     }
 712
 713     private static void createTP(Map<TerminationPointKey, TerminationPoint> tpMap,
 714             OtnTopoNode node, OpenroadmTpType tpType, boolean withRate) {
 715         List<Mapping> mappings = null;
 716         switch (tpType) {
 717             case XPONDERNETWORK:
 718                 mappings = node.getXpdrNetMappings();
 719                 break;
 720             case XPONDERCLIENT:
 721                 mappings = node.getXpdrClMappings();
 722                 break;
 723             default:
 724                 LOG.error("Error with Termination Point type {}", tpType);
 725                 return;
 726         }
 727         fillTpMap(tpMap, node, tpType, withRate, mappings);
 728     }
 729
 730     private static void fillTpMap(Map<TerminationPointKey, TerminationPoint> tpMap, OtnTopoNode node,
 731             OpenroadmTpType tpType, boolean withRate, List<Mapping> mappings) {
 732         for (Mapping mapping : mappings) {
 733             // openroadm-otn-topoology augmentation
 734             Map<SupportedInterfaceCapabilityKey, SupportedInterfaceCapability> supIfMap = new HashMap<>();
 735             TerminationPoint1Builder otnTp1Bldr = new TerminationPoint1Builder();
 736             if (mapping.getSupportedInterfaceCapability() != null) {
 737                 XpdrTpPortConnectionAttributesBuilder xtpcaBldr = new XpdrTpPortConnectionAttributesBuilder();
 738                 for (Class<? extends SupportedIfCapability> supInterCapa : mapping.getSupportedInterfaceCapability()) {
 739                     SupportedInterfaceCapability supIfCapa = new SupportedInterfaceCapabilityBuilder()
 740                         .withKey(new SupportedInterfaceCapabilityKey(supInterCapa))
 741                         .setIfCapType(supInterCapa)
 742                         .build();
 743                     supIfMap.put(supIfCapa.key(), supIfCapa);
 744                 }
 745                 TpSupportedInterfaces tpSupIf = new TpSupportedInterfacesBuilder()
 746                     .setSupportedInterfaceCapability(supIfMap)
 747                     .build();
 748                 otnTp1Bldr.setTpSupportedInterfaces(tpSupIf);
 749                 //TODO: It is not logical to assign a priori one of the possible rate to the TP.
 750                 //Would be worth assigning per default "unallocated" at the tp creation step,
 751                 //and updating it with correct rate when it supports a specific service.
 752                 if (withRate) {
 753                     xtpcaBldr.setRate(fixRate(mapping.getSupportedInterfaceCapability()));
 754                     otnTp1Bldr.setXpdrTpPortConnectionAttributes(xtpcaBldr.build());
 755                 }
 756             } else {
 757                 LOG.warn("mapping {} of node {} has no if-cap-type", mapping.getLogicalConnectionPoint(),
 758                     node.getNodeId());
 759             }
 760             org.opendaylight.yang.gen.v1.http.transportpce.topology.rev220123.TerminationPoint1Builder tpceTp1Bldr =
 761                 new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev220123.TerminationPoint1Builder();
 762             TpId tpId = new TpId(mapping.getLogicalConnectionPoint());
 763             setclientNwTpAttr(tpMap, node, tpId, tpType, otnTp1Bldr.build(), tpceTp1Bldr, mapping);
 764         }
 765     }
 766
 767     private static void setclientNwTpAttr(Map<TerminationPointKey, TerminationPoint> tpMap, OtnTopoNode node, TpId tpId,
 768             OpenroadmTpType tpType, TerminationPoint1 otnTp1,
 769             org.opendaylight.yang.gen.v1.http.transportpce.topology.rev220123.TerminationPoint1Builder tpceTp1Bldr,
 770             Mapping mapping) {
 771         switch (tpType) {
 772             case XPONDERNETWORK:
 773                 if (node.getXpdrNetConnectionMap().get(tpId.getValue()) != null) {
 774                     tpceTp1Bldr.setAssociatedConnectionMapPort(node.getXpdrNetConnectionMap().get(tpId.getValue()));
 775                 }
 776                 SupportingTerminationPoint stp = new SupportingTerminationPointBuilder()
 777                     .setNetworkRef(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))
 778                     .setNodeRef(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
 779                     .setTpRef(tpId)
 780                     .build();
 781                 TerminationPoint ietfTpNw = buildIetfTp(tpceTp1Bldr, otnTp1, tpType, tpId, Map.of(stp.key(), stp),
 782                     mapping);
 783                 tpMap.put(ietfTpNw.key(),ietfTpNw);
 784                 break;
 785             case XPONDERCLIENT:
 786                 if (node.getXpdrCliConnectionMap().get(tpId.getValue()) != null) {
 787                     tpceTp1Bldr.setAssociatedConnectionMapPort(node.getXpdrCliConnectionMap().get(tpId.getValue()));
 788                 }
 789                 TerminationPoint ietfTpCl = buildIetfTp(tpceTp1Bldr, otnTp1, tpType, tpId, null, mapping);
 790                 tpMap.put(ietfTpCl.key(),ietfTpCl);
 791                 break;
 792             default:
 793                 LOG.error("Undefined tpType for Termination point {} of {}", tpId.getValue(), node.getNodeId());
 794                 break;
 795         }
 796     }
 797
 798     private static Class<? extends OduRateIdentity> fixRate(List<Class<? extends SupportedIfCapability>> list) {
 799         Map<String, Class<? extends OduRateIdentity>> rateMap = Map.of(
 800             "If100GEODU4", ODU4.class,
 801             "IfOCHOTU4ODU4", ODU4.class,
 802             "If1GEODU0", ODU0.class,
 803             "If10GEODU2", ODU2.class,
 804             "If10GEODU2e", ODU2e.class);
 805         for (Class<? extends SupportedIfCapability> class1 : list) {
 806             if (rateMap.containsKey(class1.getSimpleName())) {
 807                 return rateMap.get(class1.getSimpleName());
 808             }
 809         }
 810         return null;
 811     }
 812
 813     private static Map<SupportingNodeKey,SupportingNode> createSupportingNodes(OtnTopoNode node) {
 814         SupportingNode suppNode1 = new SupportingNodeBuilder()
 815             .setNetworkRef(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID))
 816             .setNodeRef(new NodeId(node.getNodeId()))
 817             .withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID),
 818                 new NodeId(node.getNodeId())))
 819             .build();
 820         SupportingNode suppNode2 = new SupportingNodeBuilder()
 821             .setNetworkRef(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))
 822             .setNodeRef(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
 823             .withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID),
 824                 new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
 825             .build();
 826         SupportingNode suppNode3 = new SupportingNodeBuilder()
 827             .setNetworkRef(new NetworkId(NetworkUtils.CLLI_NETWORK_ID))
 828             .setNodeRef(new NodeId(node.getClli()))
 829             .withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.CLLI_NETWORK_ID),
 830                 new NodeId(node.getClli())))
 831             .build();
 832         Map<SupportingNodeKey,SupportingNode> suppNodeMap = new HashMap<>();
 833         suppNodeMap.put(suppNode1.key(),suppNode1);
 834         suppNodeMap.put(suppNode2.key(),suppNode2);
 835         suppNodeMap.put(suppNode3.key(),suppNode3);
 836         return suppNodeMap;
 837     }
 838
 839     private static TerminationPoint buildIetfTp(
 840         org.opendaylight.yang.gen.v1.http.transportpce.topology.rev220123.TerminationPoint1Builder tpceTp1Bldr,
 841         TerminationPoint1 otnTp1, OpenroadmTpType tpType, TpId tpId,
 842         Map<SupportingTerminationPointKey, SupportingTerminationPoint> supportTpMap, Mapping mapping) {
 843
 844         TerminationPointBuilder ietfTpBldr = new TerminationPointBuilder();
 845         if (tpceTp1Bldr.getAssociatedConnectionMapPort() != null) {
 846             ietfTpBldr.addAugmentation(tpceTp1Bldr.build());
 847         }
 848         if (supportTpMap != null) {
 849             ietfTpBldr.setSupportingTerminationPoint(supportTpMap);
 850         }
 851         org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.TerminationPoint1 ocnTp =
 852             new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.TerminationPoint1Builder()
 853                     .setTpType(tpType)
 854                     .setAdministrativeState(TopologyUtils.setNetworkAdminState(mapping.getPortAdminState()))
 855                     .setOperationalState(TopologyUtils.setNetworkOperState(mapping.getPortOperState()))
 856                     .build();
 857
 858         return ietfTpBldr.setTpId(tpId)
 859                 .withKey(new TerminationPointKey(tpId))
 860                 .addAugmentation(otnTp1)
 861                 .addAugmentation(ocnTp)
 862                 .build();
 863     }
 864
 865     private static String formatNodeName(String nodeName, String tpName) {
 866         return nodeName.contains(XPDR)
 867                 ? nodeName
 868                 : new StringBuilder(nodeName).append("-").append(tpName.split("-")[0]).toString();
 869     }
 870 }