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