2 * Copyright © 2021 Nokia. 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
8 package org.opendaylight.transportpce.tapi.topology;
10 import java.nio.charset.Charset;
11 import java.util.List;
14 import java.util.UUID;
15 import java.util.concurrent.ExecutionException;
16 import org.eclipse.jdt.annotation.NonNull;
17 import org.opendaylight.mdsal.binding.api.DataTreeChangeListener;
18 import org.opendaylight.mdsal.binding.api.DataTreeModification;
19 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
20 import org.opendaylight.transportpce.common.NetworkUtils;
21 import org.opendaylight.transportpce.common.network.NetworkTransactionService;
22 import org.opendaylight.transportpce.tapi.TapiStringConstants;
23 import org.opendaylight.transportpce.tapi.utils.TapiLink;
24 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev230526.Link1;
25 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev230526.OpenroadmLinkType;
26 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NetworkId;
27 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.Networks;
28 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network;
29 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.NetworkKey;
30 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.LinkId;
31 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Network1;
32 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.Link;
33 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkKey;
34 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev221121.Context;
35 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev221121.LayerProtocolName;
36 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev221121.Uuid;
37 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev221121.Context1;
38 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev221121.context.TopologyContext;
39 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev221121.topology.context.Topology;
40 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev221121.topology.context.TopologyBuilder;
41 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev221121.topology.context.TopologyKey;
42 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
43 import org.slf4j.Logger;
44 import org.slf4j.LoggerFactory;
46 public class TapiOrLinkListener implements DataTreeChangeListener<Link> {
48 private static final Logger LOG = LoggerFactory.getLogger(TapiOrLinkListener.class);
49 private final TapiLink tapiLink;
50 private final NetworkTransactionService networkTransactionService;
51 private final Uuid tapiTopoUuid = new Uuid(UUID.nameUUIDFromBytes(
52 TapiStringConstants.T0_FULL_MULTILAYER.getBytes(Charset.forName("UTF-8")))
55 public TapiOrLinkListener(final TapiLink tapiLink, final NetworkTransactionService networkTransactionService) {
56 this.tapiLink = tapiLink;
57 this.networkTransactionService = networkTransactionService;
61 public void onDataTreeChanged(@NonNull List<DataTreeModification<Link>> changes) {
62 LOG.info("onDataTreeChanged - {}", this.getClass().getSimpleName());
63 for (DataTreeModification<Link> change : changes) {
64 if (change.getRootNode().dataBefore() != null) {
67 Link link = change.getRootNode().dataAfter();
71 LOG.info("New link in openroadm topology");
72 // Todo: XPDR links are unidirectional, therefore we need to check for the current one and
73 // the opposite one. But first check the type
74 Link1 link1 = link.augmentation(Link1.class);
76 LOG.error("No type in link. We cannot trigger the TAPI link creation");
79 if (!(link1.getLinkType().equals(OpenroadmLinkType.XPONDERINPUT)
80 || link1.getLinkType().equals(OpenroadmLinkType.XPONDEROUTPUT))) {
81 LOG.warn("Not triggering creation of link for type = {}", link1.getLinkType().getName());
84 if (!oppositeLinkExists(link1.getOppositeLink())) {
85 LOG.warn("Opposite link doest exist. Not creating TAPI link");
88 LOG.info("Opposite link already in datastore. Creatin TAPI bidirectional link");
89 String srcNode = getRoadmOrXpdr(link.getSource().getSourceNode().getValue());
90 String srcTp = link.getSource().getSourceTp().getValue();
91 String destNode = getRoadmOrXpdr(link.getDestination().getDestNode().getValue());
92 String destTp = link.getDestination().getDestTp().getValue();
93 putTapiLinkInTopology(this.tapiLink.createTapiLink(srcNode, srcTp, destNode, destTp,
94 TapiStringConstants.OMS_XPDR_RDM_LINK, getQual(srcNode), getQual(destNode),
95 TapiStringConstants.PHTNC_MEDIA_OTS, TapiStringConstants.PHTNC_MEDIA_OTS,
96 link1.getAdministrativeState().getName(), link1.getOperationalState().getName(),
97 Set.of(LayerProtocolName.PHOTONICMEDIA), Set.of(LayerProtocolName.PHOTONICMEDIA.getName()),
102 private void putTapiLinkInTopology(
103 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev221121.topology.Link tapiXpdrLink) {
104 LOG.info("Creating tapi link in TAPI topology context");
105 // merge in datastore
106 this.networkTransactionService.merge(
107 LogicalDatastoreType.OPERATIONAL,
108 InstanceIdentifier.builder(Context.class)
109 .augmentation(Context1.class).child(TopologyContext.class)
110 .child(Topology.class, new TopologyKey(this.tapiTopoUuid))
112 new TopologyBuilder()
113 .setUuid(this.tapiTopoUuid)
114 .setLink(Map.of(tapiXpdrLink.key(), tapiXpdrLink))
117 this.networkTransactionService.commit().get();
118 } catch (InterruptedException | ExecutionException e) {
119 LOG.error("Error populating TAPI topology: ", e);
121 LOG.info("TAPI Link added succesfully.");
124 private String getQual(String node) {
125 return node.contains("ROADM") ? TapiStringConstants.PHTNC_MEDIA : TapiStringConstants.XPDR;
128 private boolean oppositeLinkExists(LinkId oppositeLink) {
130 if (this.networkTransactionService
132 LogicalDatastoreType.CONFIGURATION,
133 InstanceIdentifier.builder(Networks.class)
134 .child(Network.class, new NetworkKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID)))
135 .augmentation(Network1.class)
136 .child(Link.class, new LinkKey(oppositeLink))
140 LOG.error("Opposite link not found in datastore {}", oppositeLink.getValue());
144 } catch (InterruptedException | ExecutionException e) {
145 LOG.error("Failed to read opposite link", e);
150 private String getRoadmOrXpdr(String node) {
151 return node.contains("ROADM")
152 ? String.join("-", node.split("-")[0], node.split("-")[1])