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.Collection;
13 import java.util.Optional;
15 import java.util.UUID;
16 import java.util.concurrent.ExecutionException;
17 import org.eclipse.jdt.annotation.NonNull;
18 import org.opendaylight.mdsal.binding.api.DataTreeChangeListener;
19 import org.opendaylight.mdsal.binding.api.DataTreeModification;
20 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
21 import org.opendaylight.transportpce.common.NetworkUtils;
22 import org.opendaylight.transportpce.common.network.NetworkTransactionService;
23 import org.opendaylight.transportpce.tapi.TapiStringConstants;
24 import org.opendaylight.transportpce.tapi.utils.TapiLink;
25 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Link1;
26 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev211210.OpenroadmLinkType;
27 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NetworkId;
28 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.Networks;
29 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network;
30 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.NetworkKey;
31 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.LinkId;
32 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Network1;
33 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.Link;
34 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkKey;
35 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.Context;
36 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.LayerProtocolName;
37 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.Uuid;
38 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.Context1;
39 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.context.TopologyContext;
40 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.context.Topology;
41 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.context.TopologyBuilder;
42 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.context.TopologyKey;
43 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
44 import org.slf4j.Logger;
45 import org.slf4j.LoggerFactory;
47 public class TapiOrLinkListener implements DataTreeChangeListener<Link> {
49 private static final Logger LOG = LoggerFactory.getLogger(TapiOrLinkListener.class);
50 private final TapiLink tapiLink;
51 private final NetworkTransactionService networkTransactionService;
52 private final Uuid tapiTopoUuid = new Uuid(UUID.nameUUIDFromBytes(TapiStringConstants.T0_FULL_MULTILAYER
53 .getBytes(Charset.forName("UTF-8"))).toString());
55 public TapiOrLinkListener(final TapiLink tapiLink, final NetworkTransactionService networkTransactionService) {
56 this.tapiLink = tapiLink;
57 this.networkTransactionService = networkTransactionService;
61 public void onDataTreeChanged(@NonNull Collection<DataTreeModification<Link>> changes) {
62 LOG.info("onDataTreeChanged - {}", this.getClass().getSimpleName());
63 for (DataTreeModification<Link> change : changes) {
64 if (change.getRootNode().getDataBefore() == null && change.getRootNode().getDataAfter() != null) {
65 LOG.info("New link in openroadm topology");
66 Link link = change.getRootNode().getDataAfter();
67 // Todo: XPDR links are unidirectional, therefore we need to check for the current one and
68 // the opposite one. But first check the type
69 Link1 link1 = link.augmentation(Link1.class);
71 LOG.error("No type in link. We cannot trigger the TAPI link creation");
74 if (!(link1.getLinkType().equals(OpenroadmLinkType.XPONDERINPUT)
75 || link1.getLinkType().equals(OpenroadmLinkType.XPONDEROUTPUT))) {
76 LOG.warn("Not triggering creation of link for type = {}", link1.getLinkType().getName());
79 if (!oppositeLinkExists(link1.getOppositeLink())) {
80 LOG.warn("Opposite link doest exist. Not creating TAPI link");
83 LOG.info("Opposite link already in datastore. Creatin TAPI bidirectional link");
84 String srcNode = getRoadmOrXpdr(link.getSource().getSourceNode().getValue());
85 String srcTp = link.getSource().getSourceTp().getValue();
86 String destNode = getRoadmOrXpdr(link.getDestination().getDestNode().getValue());
87 String destTp = link.getDestination().getDestTp().getValue();
88 putTapiLinkInTopology(this.tapiLink.createTapiLink(srcNode, srcTp, destNode, destTp,
89 TapiStringConstants.OMS_XPDR_RDM_LINK, getQual(srcNode), getQual(destNode),
90 TapiStringConstants.PHTNC_MEDIA, TapiStringConstants.PHTNC_MEDIA,
91 link1.getAdministrativeState().getName(), link1.getOperationalState().getName(),
92 Set.of(LayerProtocolName.PHOTONICMEDIA), Set.of(LayerProtocolName.PHOTONICMEDIA.getName()),
98 private void putTapiLinkInTopology(
99 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Link tapiXpdrLink) {
100 LOG.info("Creating tapi link in TAPI topology context");
101 InstanceIdentifier<Topology> topoIID = InstanceIdentifier.builder(Context.class)
102 .augmentation(Context1.class).child(TopologyContext.class)
103 .child(Topology.class, new TopologyKey(this.tapiTopoUuid))
106 Topology topology = new TopologyBuilder().setUuid(this.tapiTopoUuid)
107 .setLink(Map.of(tapiXpdrLink.key(), tapiXpdrLink)).build();
109 // merge in datastore
110 this.networkTransactionService.merge(LogicalDatastoreType.OPERATIONAL, topoIID,
113 this.networkTransactionService.commit().get();
114 } catch (InterruptedException | ExecutionException e) {
115 LOG.error("Error populating TAPI topology: ", e);
117 LOG.info("TAPI Link added succesfully.");
120 private String getQual(String node) {
121 if (node.contains("ROADM")) {
122 return TapiStringConstants.PHTNC_MEDIA;
124 return TapiStringConstants.OTSI;
127 private boolean oppositeLinkExists(LinkId oppositeLink) {
129 InstanceIdentifier<Link> linkIID = InstanceIdentifier.builder(Networks.class)
130 .child(Network.class, new NetworkKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID)))
131 .augmentation(Network1.class).child(Link.class, new LinkKey(oppositeLink)).build();
133 Optional<Link> optLink =
134 this.networkTransactionService.read(LogicalDatastoreType.CONFIGURATION, linkIID).get();
135 if (!optLink.isPresent()) {
136 LOG.error("Opposite link not found in datastore {}", oppositeLink.getValue());
140 } catch (InterruptedException | ExecutionException e) {
141 LOG.error("Failed to read opposite link", e);
146 private String getRoadmOrXpdr(String node) {
147 if (node.contains("ROADM")) {
148 return String.join("-", node.split("-")[0], node.split("-")[1]);