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.controller.md.sal.common.api.data.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.rev190702.network.Nodes;
  28 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev190702.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.submit().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         NetworkBuilder nwBuilder = new NetworkBuilder();
 116         NetworkId nwId = new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID);
 117         nwBuilder.setNetworkId(nwId);
 118         nwBuilder.withKey(new NetworkKey(nwId));
 119         NetworkTypes1Builder topoNetworkTypesBldr = new NetworkTypes1Builder();
 120         topoNetworkTypesBldr.setOpenroadmCommonNetwork(new OpenroadmCommonNetworkBuilder().build());
 121         NetworkTypesBuilder nwTypeBuilder = new NetworkTypesBuilder();
 122         nwTypeBuilder.addAugmentation(NetworkTypes1.class, topoNetworkTypesBldr.build());
 123         nwBuilder.setNetworkTypes(nwTypeBuilder.build());
 124         // Array to store nodes in the topolayer of a roadm/Xponder
 125         Network1Builder nwBldr1 = new Network1Builder();
 126         // adding expressLinks
 127         nwBldr1.setLink(Collections.emptyList());
 128         nwBuilder.addAugmentation(Network1.class, nwBldr1.build());
 129         nwBuilder.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         // Create ietf node setting supporting-node data
 198         NodeBuilder ietfNodeBldr = createTopoLayerNode(mappingNode.getNodeId());
 199         // set node-id
 200         String nodeIdtopo = new StringBuilder().append(mappingNode.getNodeId()).append("-XPDR1").toString();
 201         ietfNodeBldr.setNodeId(new NodeId(nodeIdtopo));
 202         ietfNodeBldr.withKey((new NodeKey(new NodeId(nodeIdtopo))));
 203         // Create openroadm-network-topo augmentation to set node type to Xponder
 204         Node1Builder ontNode1Bldr = new Node1Builder();
 205         ontNode1Bldr.setNodeType(OpenroadmNodeType.XPONDER);
 206         ietfNodeBldr.addAugmentation(Node1.class, ontNode1Bldr.build());
 207
 208         // Create tp-list
 209         List<TerminationPoint> tpList = new ArrayList<>();
 210         TerminationPointBuilder ietfTpBldr;
 211         for (Mapping m : mappingNode.getMapping()) {
 212             ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
 213             // Add openroadm-network-topology tp augmentations
 214             TerminationPoint1Builder ontTp1Bldr = new TerminationPoint1Builder();
 215             if (m.getPortQual().equals("xpdr-network")) {
 216                 ontTp1Bldr.setTpType(OpenroadmTpType.XPONDERNETWORK);
 217                 XpdrNetworkAttributesBuilder xpdrNwAttrBldr = new XpdrNetworkAttributesBuilder();
 218                 xpdrNwAttrBldr.setTailEquipmentId(m.getAssociatedLcp());
 219                 ontTp1Bldr.setXpdrNetworkAttributes(xpdrNwAttrBldr.build());
 220                 ietfTpBldr.addAugmentation(TerminationPoint1.class, ontTp1Bldr.build());
 221                 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev190625
 222                     .TerminationPoint1Builder tpceTp1Bldr = new org.opendaylight.yang.gen.v1.http.transportpce
 223                     .topology.rev190625.TerminationPoint1Builder();
 224                 tpceTp1Bldr.setAssociatedConnectionMapPort(m.getAssociatedLcp());
 225                 ietfTpBldr.addAugmentation(org.opendaylight.yang.gen.v1.http.transportpce.topology.rev190625
 226                     .TerminationPoint1.class, tpceTp1Bldr.build());
 227                 tpList.add(ietfTpBldr.build());
 228             } else if (m.getPortQual().equals("xpdr-client")) {
 229                 ontTp1Bldr.setTpType(OpenroadmTpType.XPONDERCLIENT);
 230                 XpdrClientAttributesBuilder xpdrNwAttrBldr = new XpdrClientAttributesBuilder();
 231                 xpdrNwAttrBldr.setTailEquipmentId(m.getAssociatedLcp());
 232                 ontTp1Bldr.setXpdrClientAttributes(xpdrNwAttrBldr.build());
 233                 ietfTpBldr.addAugmentation(TerminationPoint1.class, ontTp1Bldr.build());
 234                 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev190625
 235                     .TerminationPoint1Builder tpceTp1Bldr = new org.opendaylight.yang.gen.v1.http.transportpce
 236                     .topology.rev190625.TerminationPoint1Builder();
 237                 tpceTp1Bldr.setAssociatedConnectionMapPort(m.getAssociatedLcp());
 238                 ietfTpBldr.addAugmentation(org.opendaylight.yang.gen.v1.http.transportpce.topology.rev190625
 239                     .TerminationPoint1.class, tpceTp1Bldr.build());
 240                 tpList.add(ietfTpBldr.build());
 241             }
 242         }
 243
 244         // Create ietf node augmentation to support ietf tp-list
 245         org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
 246             .Node1Builder ietfNode1 = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology
 247             .rev180226.Node1Builder();
 248         ietfNode1.setTerminationPoint(tpList);
 249         ietfNodeBldr.addAugmentation(
 250             org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class,
 251             ietfNode1.build());
 252         return ietfNodeBldr;
 253     }
 254
 255     private NodeBuilder createDegree(String degNb, List<Mapping> degListMap, String nodeId) {
 256         // Create ietf node setting supporting-node data
 257         NodeBuilder ietfNodeBldr = createTopoLayerNode(nodeId);
 258         // set node-id
 259         String nodeIdtopo = new StringBuilder().append(nodeId).append("-").append(degNb).toString();
 260         ietfNodeBldr.setNodeId(new NodeId(nodeIdtopo));
 261         ietfNodeBldr.withKey((new NodeKey(new NodeId(nodeIdtopo))));
 262         // Create openroadm-network-topo augmentation to set node type to DEGREE
 263         Node1Builder ontNode1Bldr = new Node1Builder();
 264         ontNode1Bldr.setNodeType(OpenroadmNodeType.DEGREE);
 265         // set degree-attributes
 266         DegreeAttributesBuilder degAttBldr = new DegreeAttributesBuilder();
 267         degAttBldr.setDegreeNumber(new Integer(degNb.split("DEG")[1]));
 268         degAttBldr.setAvailableWavelengths(create96AvalWaveDegree());
 269         ontNode1Bldr.setDegreeAttributes(degAttBldr.build());
 270         ietfNodeBldr.addAugmentation(Node1.class, ontNode1Bldr.build());
 271
 272         // Create tp-list
 273         List<TerminationPoint> tpList = new ArrayList<>();
 274         TerminationPointBuilder ietfTpBldr;
 275         for (Mapping m : degListMap) {
 276             ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
 277             // Add openroadm-network-topology tp augmentations
 278             TerminationPoint1Builder ontTp1Bldr = new TerminationPoint1Builder();
 279             switch (m.getPortDirection()) {
 280                 case "bidirectional":
 281                     ontTp1Bldr.setTpType(OpenroadmTpType.DEGREETXRXTTP);
 282                     break;
 283                 case "tx":
 284                     ontTp1Bldr.setTpType(OpenroadmTpType.DEGREETXTTP);
 285                     break;
 286                 case "rx":
 287                     ontTp1Bldr.setTpType(OpenroadmTpType.DEGREERXTTP);
 288                     break;
 289                 default:
 290                     LOG.error("impossible to set tp-type to {}", m.getLogicalConnectionPoint());
 291             }
 292             ietfTpBldr.addAugmentation(TerminationPoint1.class, ontTp1Bldr.build());
 293             tpList.add(ietfTpBldr.build());
 294         }
 295         // Add CTP to tp-list
 296         ietfTpBldr = createTpBldr(degNb + "-CTP-TXRX");
 297         TerminationPoint1Builder ontTp1Bldr = new TerminationPoint1Builder();
 298         ontTp1Bldr.setTpType(OpenroadmTpType.DEGREETXRXCTP);
 299         ietfTpBldr.addAugmentation(TerminationPoint1.class, ontTp1Bldr.build());
 300         tpList.add(ietfTpBldr.build());
 301
 302         // Create ietf node augmentation to support ietf tp-list
 303         org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
 304             .Node1Builder ietfNode1 = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology
 305             .rev180226.Node1Builder();
 306         ietfNode1.setTerminationPoint(tpList);
 307         ietfNodeBldr.addAugmentation(
 308             org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class,
 309             ietfNode1.build());
 310         return ietfNodeBldr;
 311     }
 312
 313     private NodeBuilder createSrg(String srgNb, List<Mapping> srgListMap, String nodeId) {
 314         // Create ietf node setting supporting-node data
 315         NodeBuilder ietfNodeBldr = createTopoLayerNode(nodeId);
 316         // set node-id
 317         String nodeIdtopo = new StringBuilder().append(nodeId).append("-").append(srgNb).toString();
 318         ietfNodeBldr.setNodeId(new NodeId(nodeIdtopo));
 319         ietfNodeBldr.withKey((new NodeKey(new NodeId(nodeIdtopo))));
 320         // Create openroadm-network-topo augmentation to set node type to DEGREE
 321         Node1Builder ontNode1Bldr = new Node1Builder();
 322         ontNode1Bldr.setNodeType(OpenroadmNodeType.SRG);
 323         // set srg-attributes
 324         SrgAttributesBuilder srgAttrBldr = new SrgAttributesBuilder();
 325         srgAttrBldr.setAvailableWavelengths(create96AvalWaveSrg());
 326         ontNode1Bldr.setSrgAttributes(srgAttrBldr.build());
 327         ietfNodeBldr.addAugmentation(Node1.class, ontNode1Bldr.build());
 328
 329         // Create tp-list
 330         List<TerminationPoint> tpList = new ArrayList<>();
 331         TerminationPointBuilder ietfTpBldr;
 332         for (Mapping m : srgListMap) {
 333             ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
 334             // Add openroadm-network-topology tp augmentations
 335             TerminationPoint1Builder ontTp1Bldr = new TerminationPoint1Builder();
 336             switch (m.getPortDirection()) {
 337                 case "bidirectional":
 338                     ontTp1Bldr.setTpType(OpenroadmTpType.SRGTXRXPP);
 339                     break;
 340                 case "tx":
 341                     ontTp1Bldr.setTpType(OpenroadmTpType.SRGTXPP);
 342                     break;
 343                 case "rx":
 344                     ontTp1Bldr.setTpType(OpenroadmTpType.SRGRXPP);
 345                     break;
 346                 default:
 347                     LOG.error("impossible to set tp-type to {}", m.getLogicalConnectionPoint());
 348             }
 349             ietfTpBldr.addAugmentation(TerminationPoint1.class, ontTp1Bldr.build());
 350             tpList.add(ietfTpBldr.build());
 351         }
 352         // Add CP to tp-list
 353         ietfTpBldr = createTpBldr(srgNb + "-CP-TXRX");
 354         TerminationPoint1Builder ontTp1Bldr = new TerminationPoint1Builder();
 355         ontTp1Bldr.setTpType(OpenroadmTpType.SRGTXRXCP);
 356         ietfTpBldr.addAugmentation(TerminationPoint1.class, ontTp1Bldr.build());
 357         tpList.add(ietfTpBldr.build());
 358
 359         // Create ietf node augmentation to support ietf tp-list
 360         org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
 361             .Node1Builder ietfNode1 = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology
 362             .rev180226.Node1Builder();
 363         ietfNode1.setTerminationPoint(tpList);
 364         ietfNodeBldr.addAugmentation(
 365             org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class,
 366             ietfNode1.build());
 367         return ietfNodeBldr;
 368     }
 369
 370     private NodeBuilder createTopoLayerNode(String nodeId) {
 371         // Sets the value of Network-ref and Node-ref as a part of the supporting node
 372         // attribute
 373         SupportingNodeBuilder supportbldr = new SupportingNodeBuilder();
 374         supportbldr.withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID), new NodeId(nodeId)));
 375         supportbldr.setNetworkRef(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID));
 376         supportbldr.setNodeRef(new NodeId(nodeId));
 377         ArrayList<SupportingNode> supportlist = new ArrayList<>();
 378         supportlist.add(supportbldr.build());
 379         NodeBuilder nodebldr = new NodeBuilder();
 380         nodebldr.setSupportingNode(supportlist);
 381         return nodebldr;
 382     }
 383
 384
 385     // This method returns a generic termination point builder for a given tpid
 386     private TerminationPointBuilder createTpBldr(String tpId) {
 387         TerminationPointBuilder tpBldr = new TerminationPointBuilder();
 388         TpId tp = new TpId(tpId);
 389         TerminationPointKey tpKey = new TerminationPointKey(tp);
 390         tpBldr.withKey(tpKey);
 391         tpBldr.setTpId(tp);
 392         return tpBldr;
 393     }
 394
 395     private LinkBuilder createLink(String srcNode, String destNode, String srcTp, String destTp) {
 396         LinkBuilder ietfLinkBldr = new LinkBuilder();
 397         //create source link
 398         SourceBuilder ietfSrcLinkBldr = new SourceBuilder().setSourceNode(new NodeId(srcNode)).setSourceTp(srcTp);
 399         //create destination link
 400         DestinationBuilder ietfDestLinkBldr = new DestinationBuilder().setDestNode(new NodeId(destNode))
 401             .setDestTp(destTp);
 402         ietfLinkBldr.setSource(ietfSrcLinkBldr.build())
 403             .setDestination(ietfDestLinkBldr.build())
 404             .setLinkId(LinkIdUtil.buildLinkId(srcNode, srcTp, destNode, destTp))
 405             .withKey(new LinkKey(ietfLinkBldr.getLinkId()));
 406         return ietfLinkBldr;
 407     }
 408
 409     private List<Link> createNewLinks(List<Node> nodes) {
 410         List<Link> links = new ArrayList<>();
 411         String srcNode;
 412         String destNode;
 413         String srcTp;
 414         String destTp;
 415         for (int i = 0; i < nodes.size() - 1; i++) {
 416             for (int j = i + 1; j < nodes.size(); j++) {
 417                 srcNode = nodes.get(i).getNodeId().getValue();
 418                 destNode = nodes.get(j).getNodeId().getValue();
 419                 // A to Z direction
 420                 srcTp = nodes.get(i).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                 destTp = nodes.get(j).augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf
 425                     .network.topology.rev180226.Node1.class).getTerminationPoint().stream()
 426                     .filter(tp -> tp.getTpId().getValue().contains("CP") || tp.getTpId().getValue().contains("CTP"))
 427                     .findFirst().get().getTpId().getValue();
 428                 LinkBuilder ietfAzLinkBldr = createLink(srcNode, destNode, srcTp, destTp);
 429                 Link1Builder ontAzLinkBldr = new Link1Builder();
 430                 int srcNodeType = nodes.get(i).augmentation(Node1.class).getNodeType().getIntValue();
 431                 int destNodeType = nodes.get(j).augmentation(Node1.class).getNodeType().getIntValue();
 432                 if (srcNodeType == 11 && destNodeType == 11) {
 433                     ontAzLinkBldr.setLinkType(OpenroadmLinkType.EXPRESSLINK);
 434                 } else if (srcNodeType == 11 && destNodeType == 12) {
 435                     ontAzLinkBldr.setLinkType(OpenroadmLinkType.DROPLINK);
 436                 } else if (srcNodeType == 12 && destNodeType == 11) {
 437                     ontAzLinkBldr.setLinkType(OpenroadmLinkType.ADDLINK);
 438                 } else {
 439                     continue;
 440                 }
 441                 // Z to A direction
 442                 LinkBuilder ietfZaLinkBldr = createLink(destNode, srcNode, destTp, srcTp);
 443                 Link1Builder ontZaLinkBldr = new Link1Builder();
 444                 if (srcNodeType == 11 && destNodeType == 11) {
 445                     ontZaLinkBldr.setLinkType(OpenroadmLinkType.EXPRESSLINK);
 446                 } else if (destNodeType == 11 && srcNodeType == 12) {
 447                     ontZaLinkBldr.setLinkType(OpenroadmLinkType.DROPLINK);
 448                 } else if (destNodeType == 12 && srcNodeType == 11) {
 449                     ontZaLinkBldr.setLinkType(OpenroadmLinkType.ADDLINK);
 450                 } else {
 451                     continue;
 452                 }
 453                 // set opposite link augmentations
 454                 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1Builder ocnAzLinkBldr =
 455                     new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1Builder()
 456                     .setOppositeLink(ietfZaLinkBldr.getLinkId());
 457                 ietfAzLinkBldr.addAugmentation(Link1.class, ontAzLinkBldr.build());
 458                 ietfAzLinkBldr.addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
 459                     .Link1.class, ocnAzLinkBldr.build());
 460                 ietfZaLinkBldr.addAugmentation(Link1.class, ontZaLinkBldr.build());
 461                 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1Builder ocnZaLinkBldr =
 462                     new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1Builder()
 463                     .setOppositeLink(ietfAzLinkBldr.getLinkId());
 464                 ietfZaLinkBldr.addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
 465                     .Link1.class, ocnZaLinkBldr.build());
 466                 links.add(ietfAzLinkBldr.build());
 467                 links.add(ietfZaLinkBldr.build());
 468             }
 469         }
 470         return links;
 471     }
 472
 473     // This method returns the linkBuilder object for given source and destination
 474     public static boolean deleteLink(String srcNode, String dstNode, String srcTp, String destTp,
 475                                      NetworkTransactionService networkTransactionService) {
 476         LOG.info("deleting link for {}-{}", srcNode, dstNode);
 477         LinkId linkId = LinkIdUtil.buildLinkId(srcNode, srcTp, dstNode, destTp);
 478         if (deleteLinkLinkId(linkId, networkTransactionService)) {
 479             LOG.debug("Link Id {} updated to have admin state down");
 480             return true;
 481         } else {
 482             LOG.debug("Link Id not found for Source {} and Dest {}", srcNode, dstNode);
 483             return false;
 484         }
 485     }
 486
 487     // This method returns the linkBuilder object for given source and destination
 488     public static boolean deleteLinkLinkId(LinkId linkId , NetworkTransactionService networkTransactionService) {
 489         LOG.info("deleting link for LinkId: {}", linkId);
 490         try {
 491             InstanceIdentifierBuilder<Link> linkIID = InstanceIdentifier.builder(Networks.class).child(Network.class,
 492                 new NetworkKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))).augmentation(Network1.class)
 493                 .child(Link.class, new LinkKey(linkId));
 494             com.google.common.base.Optional<Link> link =
 495                     networkTransactionService.read(LogicalDatastoreType.CONFIGURATION,linkIID.build()).get();
 496             if (link.isPresent()) {
 497                 LinkBuilder linkBuilder = new LinkBuilder(link.get());
 498                 Link1Builder link1Builder = new Link1Builder(linkBuilder.augmentation(org.opendaylight
 499                         .yang.gen.v1.http.org.openroadm.network.topology.rev181130.Link1.class));
 500                 link1Builder.setAdministrativeState(State.OutOfService);
 501                 linkBuilder.removeAugmentation(Link1.class);
 502                 linkBuilder.addAugmentation(Link1.class,link1Builder.build());
 503                 networkTransactionService.merge(LogicalDatastoreType.CONFIGURATION, linkIID.build(),
 504                         linkBuilder.build());
 505                 networkTransactionService.submit().get(1, TimeUnit.SECONDS);
 506                 return true;
 507             } else {
 508                 LOG.error("No link found for given LinkId: {}",
 509                         linkId);
 510                 return false;
 511             }
 512
 513         } catch (InterruptedException | ExecutionException | TimeoutException e) {
 514             LOG.error(e.getMessage(), e);
 515             return false;
 516         }
 517     }
 518
 519     private List<AvailableWavelengths> create96AvalWaveDegree() {
 520         List<AvailableWavelengths> waveList = new ArrayList<>();
 521
 522         for (int i = 1; i < 97; i++) {
 523             AvailableWavelengthsBuilder avalBldr = new AvailableWavelengthsBuilder();
 524             avalBldr.setIndex((long) i);
 525             avalBldr.withKey(new AvailableWavelengthsKey((long) i));
 526             waveList.add(avalBldr.build());
 527         }
 528
 529         return waveList;
 530     }
 531
 532     private List<org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node
 533             .attributes.AvailableWavelengths> create96AvalWaveSrg() {
 534
 535         List<org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node.attributes
 536                 .AvailableWavelengths> waveList =
 537                 new ArrayList<>();
 538
 539         for (int i = 1; i < 97; i++) {
 540             org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node.attributes
 541                     .AvailableWavelengthsBuilder avalBldr =
 542                     new org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node
 543                             .attributes.AvailableWavelengthsBuilder();
 544             avalBldr.setIndex((long) i);
 545             avalBldr.withKey(
 546                     new org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node
 547                             .attributes.AvailableWavelengthsKey(
 548                             (long) i));
 549             waveList.add(avalBldr.build());
 550         }
 551
 552         return waveList;
 553     }
 554 }