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