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