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