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