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