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