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

   1 /*
   2  * Copyright © 2016 AT&T and others.  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 java.util.ArrayList;
  12 import java.util.Comparator;
  13 import java.util.HashMap;
  14 import java.util.List;
  15 import java.util.Map;
  16 import java.util.concurrent.ExecutionException;
  17 import java.util.concurrent.TimeUnit;
  18 import java.util.concurrent.TimeoutException;
  19 import java.util.stream.Collectors;
  20
  21 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
  22 import org.opendaylight.transportpce.common.NetworkUtils;
  23 import org.opendaylight.transportpce.common.network.NetworkTransactionService;
  24 import org.opendaylight.transportpce.networkmodel.dto.TopologyShard;
  25 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200128.network.Nodes;
  26 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200128.network.nodes.Mapping;
  27 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1;
  28 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1Builder;
  29 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev181130.State;
  30 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev181019.NodeTypes;
  31 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev181019.XpdrNodeTypes;
  32 import org.opendaylight.yang.gen.v1.http.org.openroadm.degree.rev181130.degree.node.attributes.AvailableWavelengths;
  33 import org.opendaylight.yang.gen.v1.http.org.openroadm.degree.rev181130.degree.node.attributes.AvailableWavelengthsBuilder;
  34 import org.opendaylight.yang.gen.v1.http.org.openroadm.degree.rev181130.degree.node.attributes.AvailableWavelengthsKey;
  35 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.Node1;
  36 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.Node1Builder;
  37 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.DegreeAttributes;
  38 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.DegreeAttributesBuilder;
  39 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.SrgAttributes;
  40 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.SrgAttributesBuilder;
  41 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmLinkType;
  42 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmNodeType;
  43 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmTpType;
  44 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NetworkId;
  45 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.Networks;
  46 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NodeId;
  47 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network;
  48 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.NetworkKey;
  49 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.Node;
  50 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeBuilder;
  51 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeKey;
  52 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNode;
  53 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeBuilder;
  54 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeKey;
  55 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.LinkId;
  56 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Network1;
  57 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.TpId;
  58 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.Link;
  59 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkBuilder;
  60 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkKey;
  61 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.link.DestinationBuilder;
  62 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.link.SourceBuilder;
  63 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPoint;
  64 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointBuilder;
  65 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointKey;
  66 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  67 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier.InstanceIdentifierBuilder;
  68 import org.opendaylight.yangtools.yang.common.Uint16;
  69 import org.opendaylight.yangtools.yang.common.Uint32;
  70 import org.slf4j.Logger;
  71 import org.slf4j.LoggerFactory;
  72
  73 public final class OpenRoadmTopology {
  74
  75     private static final Logger LOG = LoggerFactory.getLogger(OpenRoadmTopology.class);
  76
  77     private OpenRoadmTopology() {
  78     }
  79
  80     public static TopologyShard createTopologyShard(Nodes mappingNode) {
  81         int numOfDegrees;
  82         int numOfSrgs;
  83         List<Node> nodes = new ArrayList<>();
  84         List<Link> links = new ArrayList<>();
  85
  86         // Check if node is ROADM
  87         if (NodeTypes.Rdm.getIntValue() == mappingNode.getNodeInfo().getNodeType().getIntValue()) {
  88             LOG.info("creating rdm node in openroadmtopology for node {}", mappingNode.getNodeId());
  89             // transform flat mapping list to per degree and per srg mapping lists
  90             Map<String, List<Mapping>> mapDeg = new HashMap<>();
  91             Map<String, List<Mapping>> mapSrg = new HashMap<>();
  92             List<Mapping> mappingList = new ArrayList<>(mappingNode.getMapping());
  93             mappingList.sort(Comparator.comparing(Mapping::getLogicalConnectionPoint));
  94
  95             List<String> nodeShardList = new ArrayList<>();
  96             for (Mapping mapping : mappingList) {
  97                 String str = mapping.getLogicalConnectionPoint().split("-")[0];
  98                 if (!nodeShardList.contains(str)) {
  99                     nodeShardList.add(str);
 100                 }
 101             }
 102             for (String str : nodeShardList) {
 103                 List<Mapping> interList = mappingList.stream().filter(x -> x.getLogicalConnectionPoint().contains(str))
 104                     .collect(Collectors.toList());
 105                 if (str.contains("DEG")) {
 106                     mapDeg.put(str, interList);
 107                 } else if (str.contains("SRG")) {
 108                     mapSrg.put(str,  interList);
 109                 } else {
 110                     LOG.error("unknown element");
 111                 }
 112             }
 113             // create degree nodes
 114             for (Map.Entry<String, List<Mapping>> entry : mapDeg.entrySet()) {
 115                 NodeBuilder ietfNode = createDegree(entry.getKey(), entry.getValue(), mappingNode.getNodeId(),
 116                     mappingNode.getNodeInfo().getNodeClli());
 117                 nodes.add(ietfNode.build());
 118             }
 119             // create srg nodes
 120             for (Map.Entry<String, List<Mapping>> entry : mapSrg.entrySet()) {
 121                 NodeBuilder ietfNode = createSrg(entry.getKey(), entry.getValue(), mappingNode.getNodeId(),
 122                     mappingNode.getNodeInfo().getNodeClli());
 123                 nodes.add(ietfNode.build());
 124             }
 125
 126             numOfDegrees = mapDeg.size();
 127             numOfSrgs = mapSrg.size();
 128
 129             LOG.info("adding links numOfDegrees={} numOfSrgs={}", numOfDegrees, numOfSrgs);
 130             links.addAll(createNewLinks(nodes));
 131             LOG.info("created nodes/links: {}/{}", nodes.size(), links.size());
 132             return new TopologyShard(nodes, links);
 133         } else if (NodeTypes.Xpdr.getIntValue() ==  mappingNode.getNodeInfo().getNodeType().getIntValue()) {
 134             // Check if node is Xpdr is a Transponder
 135             List<Mapping> networkMappings = mappingNode.getMapping().stream().filter(k -> k.getLogicalConnectionPoint()
 136                 .contains("NETWORK")).collect(Collectors.toList());
 137             List<Integer> tpdrList = new ArrayList<>();
 138             for (Mapping mapping : networkMappings) {
 139                 List<Mapping> extractedMappings = null;
 140                 Integer xpdrNb = Integer.parseInt(mapping.getLogicalConnectionPoint().split("XPDR")[1].split("-")[0]);
 141                 if (!tpdrList.contains(xpdrNb)) {
 142                     tpdrList.add(xpdrNb);
 143                     extractedMappings = mappingNode.getMapping().stream().filter(lcp -> lcp
 144                         .getLogicalConnectionPoint().contains("XPDR" + xpdrNb)).collect(Collectors.toList());
 145                     NodeBuilder ietfNode;
 146                     if (mapping.getXponderType() == null
 147                         || XpdrNodeTypes.Tpdr.getIntValue() == mapping.getXponderType().getIntValue()) {
 148                         LOG.info("creating xpdr node {} of type Tpdr in openroadm-topology",
 149                             mappingNode.getNodeId() + "-XPDR" + xpdrNb);
 150                         ietfNode = createXpdr(mappingNode.getNodeId(), mappingNode.getNodeInfo().getNodeClli(), xpdrNb,
 151                             extractedMappings, false);
 152                         nodes.add(ietfNode.build());
 153                     } else if (XpdrNodeTypes.Mpdr.getIntValue() == mapping.getXponderType().getIntValue()
 154                         || XpdrNodeTypes.Switch.getIntValue() == mapping.getXponderType().getIntValue()) {
 155                         LOG.info("creating xpdr node {} of type {} in openroadm-topology",
 156                             mappingNode.getNodeId() + "-XPDR" + xpdrNb, mapping.getXponderType().getName());
 157                         ietfNode = createXpdr(mappingNode.getNodeId(), mappingNode.getNodeInfo().getNodeClli(), xpdrNb,
 158                             extractedMappings, true);
 159                         nodes.add(ietfNode.build());
 160                     }
 161                 }
 162             }
 163             if (nodes.isEmpty()) {
 164                 return null;
 165             } else {
 166                 return new TopologyShard(nodes, links);
 167             }
 168         }
 169         LOG.error("Device node Type not managed yet");
 170         return null;
 171     }
 172
 173     private static NodeBuilder createXpdr(String nodeId, String clli, Integer xpdrNb, List<Mapping> mappings,
 174         boolean isOtn) {
 175         // Create openroadm-network-topo augmentation to set node type to Xponder
 176         org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1 ocnNode1 =
 177             new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1Builder()
 178             .setNodeType(OpenroadmNodeType.XPONDER).build();
 179         // Create ietf node setting supporting-node data
 180         NodeBuilder ietfNodeBldr = createTopoLayerNode(nodeId, clli);
 181         // set node-id
 182         String nodeIdtopo = new StringBuilder().append(nodeId).append("-XPDR").append(xpdrNb).toString();
 183         ietfNodeBldr.setNodeId(new NodeId(nodeIdtopo))
 184             .withKey((new NodeKey(new NodeId(nodeIdtopo))))
 185             .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
 186                 .Node1.class, ocnNode1);
 187
 188         // Create tp-list
 189         List<TerminationPoint> tpList = new ArrayList<>();
 190         TerminationPointBuilder ietfTpBldr;
 191         for (Mapping m : mappings) {
 192             if (!isOtn) {
 193                 ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
 194                 // Add openroadm-network-topology tp augmentations
 195                 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
 196                     .TerminationPoint1Builder ocnTp1Bldr = new org.opendaylight.yang.gen.v1.http.org.openroadm
 197                     .common.network.rev181130.TerminationPoint1Builder();
 198                 if (m.getPortQual().equals("xpdr-network")) {
 199                     ocnTp1Bldr.setTpType(OpenroadmTpType.XPONDERNETWORK);
 200                     org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129.TerminationPoint1 tpceTp1 =
 201                         new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129
 202                         .TerminationPoint1Builder().setAssociatedConnectionMapPort(m.getConnectionMapLcp()).build();
 203                     ietfTpBldr
 204                         .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network
 205                             .rev181130.TerminationPoint1.class, ocnTp1Bldr.build())
 206                         .addAugmentation(org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129
 207                             .TerminationPoint1.class, tpceTp1);
 208                     tpList.add(ietfTpBldr.build());
 209                 } else if (m.getPortQual().equals("xpdr-client")) {
 210                     ocnTp1Bldr.setTpType(OpenroadmTpType.XPONDERCLIENT);
 211                     org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129.TerminationPoint1 tpceTp1 =
 212                         new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129
 213                         .TerminationPoint1Builder().setAssociatedConnectionMapPort(m.getConnectionMapLcp()).build();
 214                     ietfTpBldr
 215                         .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
 216                             .TerminationPoint1.class, ocnTp1Bldr.build())
 217                         .addAugmentation(org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129
 218                             .TerminationPoint1.class, tpceTp1);
 219                     tpList.add(ietfTpBldr.build());
 220                 }
 221             } else {
 222                 if (m.getPortQual().equals("xpdr-network") || m.getPortQual().equals("switch-network")) {
 223                     ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
 224                     org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
 225                         .TerminationPoint1Builder ocnTp1Bldr = new org.opendaylight.yang.gen.v1.http.org.openroadm
 226                         .common.network.rev181130.TerminationPoint1Builder().setTpType(OpenroadmTpType.XPONDERNETWORK);
 227                     ietfTpBldr
 228                         .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network
 229                             .rev181130.TerminationPoint1.class, ocnTp1Bldr.build());
 230                     tpList.add(ietfTpBldr.build());
 231                 }
 232             }
 233         }
 234         // Create ietf node augmentation to support ietf tp-list
 235         org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
 236             .Node1Builder ietfNode1 = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology
 237             .rev180226.Node1Builder()
 238             .setTerminationPoint(tpList);
 239         ietfNodeBldr.addAugmentation(
 240             org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class,
 241             ietfNode1.build());
 242         return ietfNodeBldr;
 243     }
 244
 245     private static NodeBuilder createDegree(String degNb, List<Mapping> degListMap, String nodeId, String clli) {
 246         // Create tp-list
 247         List<TerminationPoint> tpList = new ArrayList<>();
 248         TerminationPointBuilder ietfTpBldr;
 249         for (Mapping m : degListMap) {
 250             ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
 251             // Add openroadm-common-network tp type augmentations
 252             org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
 253                 .TerminationPoint1Builder ocnTp1Bldr = new org.opendaylight.yang.gen.v1.http.org.openroadm.common
 254                 .network.rev181130.TerminationPoint1Builder();
 255             switch (m.getPortDirection()) {
 256                 case "bidirectional":
 257                     ocnTp1Bldr.setTpType(OpenroadmTpType.DEGREETXRXTTP);
 258                     break;
 259                 case "tx":
 260                     ocnTp1Bldr.setTpType(OpenroadmTpType.DEGREETXTTP);
 261                     break;
 262                 case "rx":
 263                     ocnTp1Bldr.setTpType(OpenroadmTpType.DEGREERXTTP);
 264                     break;
 265                 default:
 266                     LOG.error("impossible to set tp-type to {}", m.getLogicalConnectionPoint());
 267             }
 268             ietfTpBldr.addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
 269                 .TerminationPoint1.class, ocnTp1Bldr.build());
 270             tpList.add(ietfTpBldr.build());
 271         }
 272         // Add CTP to tp-list
 273         ietfTpBldr = createTpBldr(degNb + "-CTP-TXRX");
 274         org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1 ocnTp1 =
 275             new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1Builder()
 276             .setTpType(OpenroadmTpType.DEGREETXRXCTP).build();
 277         ietfTpBldr.addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
 278             .TerminationPoint1.class, ocnTp1);
 279         tpList.add(ietfTpBldr.build());
 280         // set degree-attributes
 281         DegreeAttributes degAtt = new DegreeAttributesBuilder()
 282             .setDegreeNumber(Uint16.valueOf(degNb.split("DEG")[1]))
 283             .setAvailableWavelengths(create96AvalWaveDegree()).build();
 284         // Create ietf node augmentation to support ietf tp-list
 285         org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
 286             .Node1Builder ietfNode1 = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology
 287             .rev180226.Node1Builder()
 288             .setTerminationPoint(tpList);
 289         // set node-id
 290         String nodeIdtopo = new StringBuilder().append(nodeId).append("-").append(degNb).toString();
 291         Node1 ontNode1 = new Node1Builder().setDegreeAttributes(degAtt).build();
 292         // Create openroadm-common-network augmentation to set node type to DEGREE
 293         org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1 ocnNode1 =
 294             new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1Builder()
 295             .setNodeType(OpenroadmNodeType.DEGREE).build();
 296         // Create ietf node setting supporting-node data
 297         return createTopoLayerNode(nodeId, clli)
 298             .setNodeId(new NodeId(nodeIdtopo))
 299             .withKey((new NodeKey(new NodeId(nodeIdtopo))))
 300             .addAugmentation(Node1.class, ontNode1)
 301             .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
 302                 .Node1.class, ocnNode1)
 303             .addAugmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology
 304                 .rev180226.Node1.class,
 305             ietfNode1.build());
 306     }
 307
 308     private static NodeBuilder createSrg(String srgNb, List<Mapping> srgListMap, String nodeId, String clli) {
 309         // Create tp-list
 310         List<TerminationPoint> tpList = new ArrayList<>();
 311         TerminationPointBuilder ietfTpBldr;
 312         for (Mapping m : srgListMap) {
 313             ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
 314             // Add openroadm-common-network tp type augmentations
 315             org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
 316                 .TerminationPoint1Builder ocnTp1Bldr = new org.opendaylight.yang.gen.v1.http.org.openroadm.common
 317                 .network.rev181130.TerminationPoint1Builder();
 318             switch (m.getPortDirection()) {
 319                 case "bidirectional":
 320                     ocnTp1Bldr.setTpType(OpenroadmTpType.SRGTXRXPP);
 321                     break;
 322                 case "tx":
 323                     ocnTp1Bldr.setTpType(OpenroadmTpType.SRGTXPP);
 324                     break;
 325                 case "rx":
 326                     ocnTp1Bldr.setTpType(OpenroadmTpType.SRGRXPP);
 327                     break;
 328                 default:
 329                     LOG.error("impossible to set tp-type to {}", m.getLogicalConnectionPoint());
 330             }
 331             ietfTpBldr.addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
 332                 .TerminationPoint1.class, ocnTp1Bldr.build());
 333             tpList.add(ietfTpBldr.build());
 334         }
 335         // Add CP to tp-list
 336         ietfTpBldr = createTpBldr(srgNb + "-CP-TXRX");
 337         org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
 338             .TerminationPoint1 ocnTp1 = new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network
 339             .rev181130.TerminationPoint1Builder().setTpType(OpenroadmTpType.SRGTXRXCP).build();
 340         ietfTpBldr.addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
 341             .TerminationPoint1.class, ocnTp1);
 342         tpList.add(ietfTpBldr.build());
 343         // Create openroadm-common-network augmentation to set node type to SRG
 344         org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1 ocnNode1 =
 345             new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1Builder()
 346             .setNodeType(OpenroadmNodeType.SRG).build();
 347         // set srg-attributes
 348         SrgAttributes srgAttr = new SrgAttributesBuilder().setAvailableWavelengths(create96AvalWaveSrg()).build();
 349         Node1 ontNode1 = new Node1Builder().setSrgAttributes(srgAttr).build();
 350         // Create ietf node augmentation to support ietf tp-list
 351         org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
 352             .Node1Builder ietfNode1 = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology
 353             .rev180226.Node1Builder()
 354             .setTerminationPoint(tpList);
 355         // Create ietf node setting supporting-node data
 356         String nodeIdtopo = new StringBuilder().append(nodeId).append("-").append(srgNb).toString();
 357         return createTopoLayerNode(nodeId, clli)
 358             .setNodeId(new NodeId(nodeIdtopo))
 359             .withKey((new NodeKey(new NodeId(nodeIdtopo))))
 360             .addAugmentation(Node1.class, ontNode1)
 361             .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
 362                 .Node1.class, ocnNode1)
 363             .addAugmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
 364                 .Node1.class, ietfNode1.build());
 365     }
 366
 367     private static NodeBuilder createTopoLayerNode(String nodeId, String clli) {
 368         // Sets the value of Network-ref and Node-ref as a part of the supporting node
 369         // attribute
 370         SupportingNodeBuilder support1bldr = new SupportingNodeBuilder()
 371             .withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID), new NodeId(nodeId)))
 372             .setNetworkRef(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID))
 373             .setNodeRef(new NodeId(nodeId));
 374         SupportingNodeBuilder support2bldr = new SupportingNodeBuilder()
 375             .withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.CLLI_NETWORK_ID), new NodeId(clli)))
 376             .setNetworkRef(new NetworkId(NetworkUtils.CLLI_NETWORK_ID))
 377             .setNodeRef(new NodeId(clli));
 378         ArrayList<SupportingNode> supportlist = new ArrayList<>();
 379         supportlist.add(support1bldr.build());
 380         supportlist.add(support2bldr.build());
 381         return new NodeBuilder().setSupportingNode(supportlist);
 382     }
 383
 384
 385     // This method returns a generic termination point builder for a given tpid
 386     private static TerminationPointBuilder createTpBldr(String tpId) {
 387         TpId tp = new TpId(tpId);
 388         return new TerminationPointBuilder().withKey(new TerminationPointKey(tp)).setTpId(tp);
 389     }
 390
 391     private static LinkBuilder createLink(String srcNode, String destNode, String srcTp, String destTp) {
 392         //create source link
 393         SourceBuilder ietfSrcLinkBldr = new SourceBuilder().setSourceNode(new NodeId(srcNode)).setSourceTp(srcTp);
 394         //create destination link
 395         DestinationBuilder ietfDestLinkBldr = new DestinationBuilder().setDestNode(new NodeId(destNode))
 396             .setDestTp(destTp);
 397         LinkId linkId = LinkIdUtil.buildLinkId(srcNode, srcTp, destNode, destTp);
 398         return new LinkBuilder()
 399             .setSource(ietfSrcLinkBldr.build())
 400             .setDestination(ietfDestLinkBldr.build())
 401             .setLinkId(linkId)
 402             .withKey(new LinkKey(linkId));
 403     }
 404
 405     private static List<Link> createNewLinks(List<Node> nodes) {
 406         List<Link> links = new ArrayList<>();
 407         String srcNode;
 408         String destNode;
 409         String srcTp;
 410         String destTp;
 411         for (int i = 0; i < nodes.size() - 1; i++) {
 412             for (int j = i + 1; j < nodes.size(); j++) {
 413                 srcNode = nodes.get(i).getNodeId().getValue();
 414                 destNode = nodes.get(j).getNodeId().getValue();
 415                 // A to Z direction
 416                 srcTp = nodes.get(i).augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf
 417                     .network.topology.rev180226.Node1.class).getTerminationPoint().stream()
 418                     .filter(tp -> tp.getTpId().getValue().contains("CP") || tp.getTpId().getValue().contains("CTP"))
 419                     .findFirst().get().getTpId().getValue();
 420                 destTp = nodes.get(j).augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf
 421                     .network.topology.rev180226.Node1.class).getTerminationPoint().stream()
 422                     .filter(tp -> tp.getTpId().getValue().contains("CP") || tp.getTpId().getValue().contains("CTP"))
 423                     .findFirst().get().getTpId().getValue();
 424                 Link1Builder ocnAzLinkBldr = new Link1Builder();
 425                 int srcNodeType = nodes.get(i).augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common
 426                     .network.rev181130.Node1.class).getNodeType().getIntValue();
 427                 int destNodeType = nodes.get(j).augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common
 428                     .network.rev181130.Node1.class).getNodeType().getIntValue();
 429                 if (srcNodeType == 11 && destNodeType == 11) {
 430                     ocnAzLinkBldr.setLinkType(OpenroadmLinkType.EXPRESSLINK);
 431                 } else if (srcNodeType == 11 && destNodeType == 12) {
 432                     ocnAzLinkBldr.setLinkType(OpenroadmLinkType.DROPLINK);
 433                 } else if (srcNodeType == 12 && destNodeType == 11) {
 434                     ocnAzLinkBldr.setLinkType(OpenroadmLinkType.ADDLINK);
 435                 } else {
 436                     continue;
 437                 }
 438                 // Z to A direction
 439                 Link1Builder ocnZaLinkBldr = new Link1Builder();
 440                 if (srcNodeType == 11 && destNodeType == 11) {
 441                     ocnZaLinkBldr.setLinkType(OpenroadmLinkType.EXPRESSLINK);
 442                 } else if (destNodeType == 11 && srcNodeType == 12) {
 443                     ocnZaLinkBldr.setLinkType(OpenroadmLinkType.DROPLINK);
 444                 } else if (destNodeType == 12 && srcNodeType == 11) {
 445                     ocnZaLinkBldr.setLinkType(OpenroadmLinkType.ADDLINK);
 446                 } else {
 447                     continue;
 448                 }
 449                 // set opposite link augmentations
 450                 LinkBuilder ietfAzLinkBldr = createLink(srcNode, destNode, srcTp, destTp);
 451                 LinkBuilder ietfZaLinkBldr = createLink(destNode, srcNode, destTp, srcTp);
 452                 ocnAzLinkBldr.setOppositeLink(ietfZaLinkBldr.getLinkId());
 453                 ietfAzLinkBldr.addAugmentation(Link1.class, ocnAzLinkBldr.build());
 454                 ocnZaLinkBldr.setOppositeLink(ietfAzLinkBldr.getLinkId());
 455                 ietfZaLinkBldr.addAugmentation(Link1.class, ocnZaLinkBldr.build());
 456                 links.add(ietfAzLinkBldr.build());
 457                 links.add(ietfZaLinkBldr.build());
 458             }
 459         }
 460         return links;
 461     }
 462
 463     // This method returns the linkBuilder object for given source and destination
 464     public static boolean deleteLink(String srcNode, String dstNode, String srcTp, String destTp,
 465                                      NetworkTransactionService networkTransactionService) {
 466         LOG.info("deleting link for {}-{}", srcNode, dstNode);
 467         LinkId linkId = LinkIdUtil.buildLinkId(srcNode, srcTp, dstNode, destTp);
 468         if (deleteLinkLinkId(linkId, networkTransactionService)) {
 469             LOG.debug("Link Id {} updated to have admin state down", linkId);
 470             return true;
 471         } else {
 472             LOG.debug("Link Id not found for Source {} and Dest {}", srcNode, dstNode);
 473             return false;
 474         }
 475     }
 476
 477     // This method returns the linkBuilder object for given source and destination
 478     public static boolean deleteLinkLinkId(LinkId linkId , NetworkTransactionService networkTransactionService) {
 479         LOG.info("deleting link for LinkId: {}", linkId.getValue());
 480         try {
 481             InstanceIdentifierBuilder<Link> linkIID = InstanceIdentifier.builder(Networks.class).child(Network.class,
 482                 new NetworkKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))).augmentation(Network1.class)
 483                 .child(Link.class, new LinkKey(linkId));
 484             java.util.Optional<Link> link =
 485                     networkTransactionService.read(LogicalDatastoreType.CONFIGURATION,linkIID.build()).get();
 486             if (link.isPresent()) {
 487                 LinkBuilder linkBuilder = new LinkBuilder(link.get());
 488                 org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.Link1Builder link1Builder =
 489                     new org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.Link1Builder(
 490                     linkBuilder.augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130
 491                     .Link1.class))
 492                     .setAdministrativeState(State.OutOfService);
 493                 linkBuilder.removeAugmentation(Link1.class)
 494                     .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130
 495                         .Link1.class,link1Builder.build());
 496                 networkTransactionService.merge(LogicalDatastoreType.CONFIGURATION, linkIID.build(),
 497                         linkBuilder.build());
 498                 networkTransactionService.commit().get(1, TimeUnit.SECONDS);
 499                 return true;
 500             } else {
 501                 LOG.error("No link found for given LinkId: {}",
 502                         linkId);
 503                 return false;
 504             }
 505
 506         } catch (InterruptedException | ExecutionException | TimeoutException e) {
 507             LOG.error("Error deleting link {}", linkId.getValue(), e);
 508             return false;
 509         }
 510     }
 511
 512     private static List<AvailableWavelengths> create96AvalWaveDegree() {
 513         List<AvailableWavelengths> waveList = new ArrayList<>();
 514
 515         for (int i = 1; i < 97; i++) {
 516             AvailableWavelengthsBuilder avalBldr = new AvailableWavelengthsBuilder()
 517                 .setIndex(Uint32.valueOf(i))
 518                 .withKey(new AvailableWavelengthsKey(Uint32.valueOf(i)));
 519             waveList.add(avalBldr.build());
 520         }
 521
 522         return waveList;
 523     }
 524
 525     private static List<org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node
 526             .attributes.AvailableWavelengths> create96AvalWaveSrg() {
 527
 528         List<org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node.attributes
 529             .AvailableWavelengths> waveList = new ArrayList<>();
 530
 531         for (int i = 1; i < 97; i++) {
 532             org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node.attributes
 533                 .AvailableWavelengthsBuilder avalBldr = new org.opendaylight.yang.gen.v1.http.org.openroadm.srg
 534                 .rev181130.srg.node.attributes.AvailableWavelengthsBuilder()
 535                 .setIndex(Uint32.valueOf(i))
 536                 .withKey(new org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node.attributes
 537                     .AvailableWavelengthsKey(Uint32.valueOf(i)));
 538             waveList.add(avalBldr.build());
 539         }
 540         return waveList;
 541     }
 542 }