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