2 * Copyright © 2016 AT&T and others. All rights reserved.
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
9 package org.opendaylight.transportpce.networkmodel.util;
11 import java.util.ArrayList;
12 import java.util.Comparator;
13 import java.util.HashMap;
14 import java.util.List;
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.rev220114.mapping.Mapping;
26 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220114.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;
71 public final class OpenRoadmTopology {
73 private static final Logger LOG = LoggerFactory.getLogger(OpenRoadmTopology.class);
75 private OpenRoadmTopology() {
78 public static TopologyShard createTopologyShard(Nodes mappingNode) {
81 List<Node> nodes = new ArrayList<>();
82 List<Link> links = new ArrayList<>();
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));
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);
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);
108 LOG.error("unknown element");
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());
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());
124 numOfDegrees = mapDeg.size();
125 numOfSrgs = mapSrg.size();
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());
162 if (nodes.isEmpty()) {
165 return new TopologyShard(nodes, links);
168 LOG.error("Device node Type not managed yet");
172 private static NodeBuilder createXpdr(String nodeId, String clli, Integer xpdrNb, List<Mapping> mappings,
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)
181 // Create ietf node setting supporting-node data
182 NodeBuilder ietfNodeBldr = createTopoLayerNode(nodeId, clli);
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);
190 Map<TerminationPointKey, TerminationPoint> tpMap = new HashMap<>();
191 TerminationPointBuilder ietfTpBldr;
192 for (Mapping m : mappings) {
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.rev210511.TerminationPoint1 tpceTp1 =
204 new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev210511.TerminationPoint1Builder()
205 .setAssociatedConnectionMapPort(m.getConnectionMapLcp()).build();
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.rev210511.TerminationPoint1 tpceTp1 =
214 new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev210511.TerminationPoint1Builder()
215 .setAssociatedConnectionMapPort(m.getConnectionMapLcp()).build();
217 .addAugmentation(ocnTp1Bldr.build())
218 .addAugmentation(tpceTp1);
219 TerminationPoint ietfTp = ietfTpBldr.build();
220 tpMap.put(ietfTp.key(),ietfTp);
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()));
232 .addAugmentation(ocnTp1Bldr.build());
233 TerminationPoint ietfTp = ietfTpBldr.build();
234 tpMap.put(ietfTp.key(),ietfTp);
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());
246 private static NodeBuilder createDegree(String degNb, List<Mapping> degListMap, String nodeId, String clli) {
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()));
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);
265 ocnTp1Bldr.setTpType(OpenroadmTpType.DEGREETXTTP);
268 ocnTp1Bldr.setTpType(OpenroadmTpType.DEGREERXTTP);
271 LOG.error("impossible to set tp-type to {}", m.getLogicalConnectionPoint());
273 ietfTpBldr.addAugmentation(ocnTp1Bldr.build());
274 TerminationPoint ietfTp = ietfTpBldr.build();
275 tpMap.put(ietfTp.key(),ietfTp);
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)
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())
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);
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)
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());
316 private static NodeBuilder createSrg(String srgNb, List<Mapping> srgListMap, String nodeId, String clli) {
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);
334 ocnTp1Bldr.setTpType(OpenroadmTpType.SRGTXPP);
337 ocnTp1Bldr.setTpType(OpenroadmTpType.SRGRXPP);
340 LOG.error("impossible to set tp-type to {}", m.getLogicalConnectionPoint());
342 ietfTpBldr.addAugmentation(ocnTp1Bldr.build());
343 TerminationPoint ietfTp = ietfTpBldr.build();
344 tpMap.put(ietfTp.key(),ietfTp);
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)
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)
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());
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
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);
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);
409 private static LinkBuilder createLink(String srcNode, String destNode, String srcTp, String destTp) {
411 SourceBuilder ietfSrcLinkBldr = new SourceBuilder().setSourceNode(new NodeId(srcNode))
412 .setSourceTp(new TpId(srcTp));
413 //create destination link
414 DestinationBuilder ietfDestLinkBldr = new DestinationBuilder().setDestNode(new NodeId(destNode))
415 .setDestTp(new TpId(destTp));
416 LinkId linkId = LinkIdUtil.buildLinkId(srcNode, srcTp, destNode, destTp);
417 return new LinkBuilder()
418 .setSource(ietfSrcLinkBldr.build())
419 .setDestination(ietfDestLinkBldr.build())
421 .withKey(new LinkKey(linkId));
424 private static List<Link> createNewLinks(List<Node> nodes) {
425 List<Link> links = new ArrayList<>();
430 for (int i = 0; i < nodes.size() - 1; i++) {
431 for (int j = i + 1; j < nodes.size(); j++) {
432 srcNode = nodes.get(i).getNodeId().getValue();
433 destNode = nodes.get(j).getNodeId().getValue();
436 .augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang
437 .ietf.network.topology.rev180226.Node1.class).nonnullTerminationPoint().values().stream()
438 .filter(tp -> tp.getTpId().getValue().contains("CP") || tp.getTpId().getValue().contains("CTP"))
439 .findFirst().get().getTpId().getValue();
440 destTp = nodes.get(j)
441 .augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang
442 .ietf.network.topology.rev180226.Node1.class)
443 .nonnullTerminationPoint().values().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
448 .org.openroadm.common.network.rev200529.Node1.class).getNodeType().getIntValue();
449 int destNodeType = nodes.get(j).augmentation(org.opendaylight.yang.gen.v1.http
450 .org.openroadm.common.network.rev200529.Node1.class).getNodeType().getIntValue();
451 if (srcNodeType == 11 && destNodeType == 11) {
452 ocnAzLinkBldr.setLinkType(OpenroadmLinkType.EXPRESSLINK);
453 } else if (srcNodeType == 11 && destNodeType == 12) {
454 ocnAzLinkBldr.setLinkType(OpenroadmLinkType.DROPLINK);
455 } else if (srcNodeType == 12 && destNodeType == 11) {
456 ocnAzLinkBldr.setLinkType(OpenroadmLinkType.ADDLINK);
461 Link1Builder ocnZaLinkBldr = new Link1Builder();
462 if (srcNodeType == 11 && destNodeType == 11) {
463 ocnZaLinkBldr.setLinkType(OpenroadmLinkType.EXPRESSLINK);
464 } else if (destNodeType == 11 && srcNodeType == 12) {
465 ocnZaLinkBldr.setLinkType(OpenroadmLinkType.DROPLINK);
466 } else if (destNodeType == 12 && srcNodeType == 11) {
467 ocnZaLinkBldr.setLinkType(OpenroadmLinkType.ADDLINK);
471 // Add state to link. Based on the operational state of the TPs at the edge of the link.
472 // Similar to getting srcTp and destTp
473 State srcTpState = nodes.get(i).augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang
474 .ietf.network.topology.rev180226.Node1.class).getTerminationPoint().values().stream()
475 .filter(tp -> tp.getTpId().getValue().contains("CP") || tp.getTpId().getValue().contains("CTP"))
476 .findFirst().get().augmentation(org.opendaylight.yang.gen.v1.http
477 .org.openroadm.common.network.rev200529.TerminationPoint1.class).getOperationalState();
478 State destTpState = nodes.get(j).augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang
479 .ietf.network.topology.rev180226.Node1.class).getTerminationPoint().values().stream()
480 .filter(tp -> tp.getTpId().getValue().contains("CP") || tp.getTpId().getValue().contains("CTP"))
481 .findFirst().get().augmentation(org.opendaylight.yang.gen.v1.http
482 .org.openroadm.common.network.rev200529.TerminationPoint1.class).getOperationalState();
483 if (State.InService.equals(srcTpState) && State.InService.equals(destTpState)) {
484 ocnAzLinkBldr.setAdministrativeState(AdminStates.InService)
485 .setOperationalState(State.InService);
486 ocnZaLinkBldr.setAdministrativeState(AdminStates.InService)
487 .setOperationalState(State.InService);
489 ocnAzLinkBldr.setAdministrativeState(AdminStates.OutOfService)
490 .setOperationalState(State.OutOfService);
491 ocnZaLinkBldr.setAdministrativeState(AdminStates.OutOfService)
492 .setOperationalState(State.OutOfService);
494 // set opposite link augmentations
495 LinkBuilder ietfAzLinkBldr = createLink(srcNode, destNode, srcTp, destTp);
496 LinkBuilder ietfZaLinkBldr = createLink(destNode, srcNode, destTp, srcTp);
497 ocnAzLinkBldr.setOppositeLink(ietfZaLinkBldr.getLinkId());
498 ietfAzLinkBldr.addAugmentation(ocnAzLinkBldr.build());
499 ocnZaLinkBldr.setOppositeLink(ietfAzLinkBldr.getLinkId());
500 ietfZaLinkBldr.addAugmentation(ocnZaLinkBldr.build());
501 links.add(ietfAzLinkBldr.build());
502 links.add(ietfZaLinkBldr.build());
508 // This method returns the linkBuilder object for given source and destination
509 public static boolean deleteLink(String srcNode, String dstNode, String srcTp, String destTp,
510 NetworkTransactionService networkTransactionService) {
511 LOG.info("deleting link for {}-{}", srcNode, dstNode);
512 LinkId linkId = LinkIdUtil.buildLinkId(srcNode, srcTp, dstNode, destTp);
513 if (deleteLinkLinkId(linkId, networkTransactionService)) {
514 LOG.debug("Link Id {} updated to have admin state down", linkId);
517 LOG.debug("Link Id not found for Source {} and Dest {}", srcNode, dstNode);
522 // This method returns the linkBuilder object for given source and destination
523 public static boolean deleteLinkLinkId(LinkId linkId , NetworkTransactionService networkTransactionService) {
524 LOG.info("deleting link for LinkId: {}", linkId.getValue());
526 InstanceIdentifierBuilder<Link> linkIID = InstanceIdentifier.builder(Networks.class).child(Network.class,
527 new NetworkKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))).augmentation(Network1.class)
528 .child(Link.class, new LinkKey(linkId));
529 java.util.Optional<Link> link =
530 networkTransactionService.read(LogicalDatastoreType.CONFIGURATION,linkIID.build()).get();
531 if (link.isPresent()) {
532 LinkBuilder linkBuilder = new LinkBuilder(link.get());
533 org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev200529.Link1Builder link1Builder =
534 new org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev200529.Link1Builder(
535 linkBuilder.augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev200529
537 linkBuilder.removeAugmentation(Link1.class)
538 .addAugmentation(link1Builder.build());
539 networkTransactionService.merge(LogicalDatastoreType.CONFIGURATION, linkIID.build(),
540 linkBuilder.build());
541 networkTransactionService.commit().get(1, TimeUnit.SECONDS);
544 LOG.error("No link found for given LinkId: {}",
549 } catch (InterruptedException | ExecutionException | TimeoutException e) {
550 LOG.error("Error deleting link {}", linkId.getValue(), e);
556 * Get a builder for instance identifier related to common network termination point.
557 * @param nodeId String
559 * @return InstanceIdentifierBuilder
561 public static InstanceIdentifierBuilder<org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529
562 .TerminationPoint1> createCommonNetworkTerminationPointIIDBuilder(String nodeId, String tpId) {
563 return InstanceIdentifier
564 .builder(Networks.class).child(Network.class, new NetworkKey(
565 new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID)))
566 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network
567 .Node.class, new NodeKey(new NodeId(nodeId)))
568 .augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
570 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks
571 .network.node.TerminationPoint.class, new TerminationPointKey(new TpId(tpId)))
572 .augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529
573 .TerminationPoint1.class);
577 * Get a builder for instance identifier related to network termination point.
578 * @param nodeId String
580 * @return InstanceIdentifierBuilder
582 public static InstanceIdentifierBuilder<TerminationPoint1> createNetworkTerminationPointIIDBuilder(String nodeId,
584 return InstanceIdentifier
585 .builder(Networks.class).child(Network.class, new NetworkKey(
586 new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID)))
587 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network
588 .Node.class, new NodeKey(new NodeId(nodeId)))
589 .augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
591 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks
592 .network.node.TerminationPoint.class, new TerminationPointKey(new TpId(tpId)))
593 .augmentation(TerminationPoint1.class);
597 * Get an instance identifier related to network node.
598 * @param nodeId String
599 * @return InstanceIdentifier
601 public static InstanceIdentifier<Node1> createNetworkNodeIID(String nodeId) {
602 return InstanceIdentifier
603 .builder(Networks.class).child(Network.class, new NetworkKey(
604 new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID)))
605 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network
606 .Node.class, new NodeKey(new NodeId(nodeId))).augmentation(Node1.class).build();
610 * Get an instance identifier related to common network node.
611 * @param nodeId String
612 * @return InstanceIdentifier
614 public static InstanceIdentifier<org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529
615 .Node1> createCommonNetworkNodeIID(String nodeId) {
616 return InstanceIdentifier
617 .builder(Networks.class).child(Network.class, new NetworkKey(
618 new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID)))
619 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network
620 .Node.class, new NodeKey(new NodeId(nodeId)))
621 .augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1.class)