NETCONF event handling

- DeviceListener processes NETCONF events from CircuitPack change

JIRA: TRNSPRTPCE-350
Change-Id: I20a8cf392dbf2f80560a7aaa341a1eef6d9c91bb
Signed-off-by: Javier <errea@eurecom.fr>

diff --git a/networkmodel/src/main/java/org/opendaylight/transportpce/networkmodel/NetConfTopologyListener.java b/networkmodel/src/main/java/org/opendaylight/transportpce/networkmodel/NetConfTopologyListener.java
index 63a02069076184c67ed5e674348dce862eb78e9f..e2bf2da7865756ee23c6626ff03e0712ad07002c 100644 (file)
--- a/networkmodel/src/main/java/org/opendaylight/transportpce/networkmodel/NetConfTopologyListener.java
+++ b/networkmodel/src/main/java/org/opendaylight/transportpce/networkmodel/NetConfTopologyListener.java
@@ -105,7 +105,8 @@ public class NetConfTopologyListener implements DataTreeChangeListener<Node> {
                 accessDeOperationasNotificationListenerRegistration =
                 notificationService.get().registerNotificationListener(deOperationsListener);
 
-            final OrgOpenroadmDeviceListener deviceListener = new DeviceListener();
+            final OrgOpenroadmDeviceListener deviceListener = new DeviceListener(this.deviceTransactionManager,
+                    nodeId);
             LOG.info("Registering notification listener on OrgOpenroadmDeviceListener for node: {}", nodeId);
             final ListenerRegistration<OrgOpenroadmDeviceListener> accessDeviceNotificationListenerRegistration =
                 notificationService.get().registerNotificationListener(deviceListener);

diff --git a/networkmodel/src/main/java/org/opendaylight/transportpce/networkmodel/listeners/DeviceListener.java b/networkmodel/src/main/java/org/opendaylight/transportpce/networkmodel/listeners/DeviceListener.java
index ab9d4e0367247d819b68bcce114f61a0b470b12d..1859b2991a27ca94439d6ef6312577c65f9dbb1b 100644 (file)
--- a/networkmodel/src/main/java/org/opendaylight/transportpce/networkmodel/listeners/DeviceListener.java
+++ b/networkmodel/src/main/java/org/opendaylight/transportpce/networkmodel/listeners/DeviceListener.java
@@ -8,15 +8,39 @@
 
 package org.opendaylight.transportpce.networkmodel.listeners;
 
+import java.util.Objects;
+import java.util.Optional;
+import java.util.concurrent.TimeUnit;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
+import org.opendaylight.transportpce.common.device.DeviceTransactionManager;
 import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.ChangeNotification;
 import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.OrgOpenroadmDeviceListener;
 import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.OtdrScanResult;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.change.notification.Edit;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.circuit.packs.CircuitPacks;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.circuit.packs.CircuitPacksKey;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.org.openroadm.device.container.OrgOpenroadmDevice;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 public class DeviceListener implements OrgOpenroadmDeviceListener {
 
     private static final Logger LOG = LoggerFactory.getLogger(DeviceListener.class);
+    /* TODO: value obtained from DeviceTransactionManagerImpl and increased due to the timeout error described in
+        JIRA TRNSPRTPCE-249. The increase had no effect.
+     */
+    private static final long GET_DATA_SUBMIT_TIMEOUT = 5000;
+    private static final TimeUnit MAX_DURATION_TO_SUBMIT_TIMEUNIT = TimeUnit.MILLISECONDS;
+    private final DeviceTransactionManager deviceTransactionManager;
+    private final String nodeId;
+
+    public DeviceListener(DeviceTransactionManager deviceTransactionManager, String nodeId) {
+        this.deviceTransactionManager = deviceTransactionManager;
+        this.nodeId = nodeId;
+    }
 
     /**
      * Callback for change-notification.
@@ -27,6 +51,88 @@ public class DeviceListener implements OrgOpenroadmDeviceListener {
     public void onChangeNotification(ChangeNotification notification) {
 
         LOG.info("Notification {} received {}", ChangeNotification.QNAME, notification);
+        // NETCONF event notification handling
+        String deviceComponentChanged = null;
+        // Seems like there is only one edit in the NETCONF notification (from honeynode experience)
+        Edit edit = Objects.requireNonNull(notification.getEdit()).get(0);
+        deviceComponentChanged = Objects.requireNonNull(edit.getTarget()).getTargetType().getSimpleName();
+        // Only circuitPack type handled
+        switch (deviceComponentChanged) {
+            case "Interface":
+                // do changes
+                LOG.info("Interface modified on device {}", this.nodeId);
+                break;
+            case "CircuitPacks":
+                LOG.info("Circuit Pack modified on device {}", this.nodeId);
+                // 1. Get the name of the component modified
+                Iterable<InstanceIdentifier.PathArgument> pathArguments = edit.getTarget().getPathArguments();
+                String cpackId = null;
+                for (InstanceIdentifier.PathArgument pathArgument : pathArguments) {
+                    if (!pathArgument.toString().contains("CircuitPacks")) {
+                        LOG.warn("Path argument element doesnt reference a Circuit Pack");
+                        continue;
+                    }
+                    Pattern pattern = Pattern.compile("\\{(.*?)}", Pattern.DOTALL);
+                    Matcher matcher = pattern.matcher(pathArgument.toString());
+                    while (matcher.find()) {
+                        String cpackKey = matcher.group(1);
+                        Pattern pattern1 = Pattern.compile("=(.*)", Pattern.DOTALL);
+                        Matcher matcher1 = pattern1.matcher(cpackKey);
+                        while (matcher1.find()) {
+                            cpackId = matcher1.group(1);
+                        }
+                    }
+                }
+                // 2. Get new configuration of component from device
+                if (cpackId == null) {
+                    LOG.warn("No Circuit pack id retrieved from NETCONF notification... aborting");
+                    break;
+                }
+                LOG.info("Circuit Pack {} modified on device {}", cpackId, this.nodeId);
+                if (!this.deviceTransactionManager.isDeviceMounted(nodeId)) {
+                    LOG.error("Device {} not mounted yet", nodeId);
+                    break;
+                }
+                InstanceIdentifier<CircuitPacks> cpIID = InstanceIdentifier.create(OrgOpenroadmDevice.class)
+                        .child(CircuitPacks.class, new CircuitPacksKey(cpackId));
+                        /* Creating runnable to perform configuration retrieval and topology update in a new thread
+                        to avoid JIRA TRNSPRTCE-251 */
+                Runnable handlenetconfEvent = new Runnable() {
+                    private CircuitPacks circuitPacks;
+
+                    public CircuitPacks getCircuitPacks() {
+                        return circuitPacks;
+                    }
+
+                    public void setCircuitPacks(CircuitPacks circuitPacks) {
+                        this.circuitPacks = circuitPacks;
+                    }
+
+                    @Override
+                    public void run() {
+                        Optional<CircuitPacks> cpacksOptional = deviceTransactionManager
+                                .getDataFromDevice(nodeId, LogicalDatastoreType.OPERATIONAL, cpIID,
+                                        GET_DATA_SUBMIT_TIMEOUT, MAX_DURATION_TO_SUBMIT_TIMEUNIT);
+                        if (!cpacksOptional.isPresent()) {
+                            LOG.error("Couldnt read from device datastore");
+                            return;
+                        }
+                        setCircuitPacks(cpacksOptional.get());
+                        LOG.info("Component {} configuration: {}", getCircuitPacks().getCircuitPackName(),
+                                getCircuitPacks());
+                        // 3. Update openroadm-topology
+                        // TODO
+                        // networkModelService.updateOpenRoadmNode(nodeId, getCircuitPacks());
+                    }
+                };
+                Thread thread = new Thread(handlenetconfEvent);
+                thread.start();
+                break;
+            default:
+                // TODO: handle more component types --> it implies development on honeynode simulator
+                LOG.warn("Component {} change not supported", deviceComponentChanged);
+        }
+
     }
 
     /**