networkmodel/src/main/java/org/opendaylight/transportpce/networkmodel/util/OpenRoadmOtnTopology.java

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