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