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