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