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