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