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

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