--- /dev/null
+/*
+ * Copyright (c) 2018 Orange and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at:
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.fd.honeycomb.transportpce.device.notifications;
+
+import com.google.common.base.Preconditions;
+import com.google.common.collect.Lists;
+import com.google.inject.Inject;
+import com.google.inject.name.Named;
+
+
+import io.fd.honeycomb.notification.ManagedNotificationProducer;
+import io.fd.honeycomb.notification.NotificationCollector;
+
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.Date;
+import java.util.Iterator;
+import java.util.List;
+
+
+
+import org.opendaylight.mdsal.binding.api.DataBroker;
+import org.opendaylight.mdsal.binding.api.DataObjectModification;
+import org.opendaylight.mdsal.binding.api.DataTreeChangeListener;
+import org.opendaylight.mdsal.binding.api.DataTreeIdentifier;
+import org.opendaylight.mdsal.binding.api.DataTreeModification;
+import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.ChangeNotification;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.ChangeNotification.Datastore;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.ChangeNotificationBuilder;
+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.change.notification.EditBuilder;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.changed.by.parms.ChangedBy;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.changed.by.parms.ChangedByBuilder;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.changed.by.parms.changed.by.server.or.user.ServerBuilder;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.circuit.pack.Ports;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.circuit.pack.PortsKey;
+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.interfaces.grp.Interface;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.org.openroadm.device.container.OrgOpenroadmDevice;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.netconf.base._1._0.rev110601.EditOperationType;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.DateAndTime;
+import org.opendaylight.yangtools.yang.binding.DataObject;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+import org.opendaylight.yangtools.yang.binding.Notification;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * @author Martial COULIBALY ( mcoulibaly.ext@orange.com ) on behalf of Orange
+ */
+public class DeviceNotificationProducer implements ManagedNotificationProducer {
+ private static final Logger LOG = LoggerFactory.getLogger(DeviceNotificationProducer.class);
+ private static final InstanceIdentifier<OrgOpenroadmDevice> DEVICE_CONTAINER_ID = InstanceIdentifier
+ .create(OrgOpenroadmDevice.class);
+ private static final String INTERFACE_CLASS = Interface.class.getName();
+
+ @Inject
+ @Named("device-databroker")
+ private DataBroker dataBroker;
+
+ @Override
+ public Collection<Class<? extends Notification>> getNotificationTypes() {
+ final ArrayList<Class<? extends Notification>> classes = Lists.newArrayList();
+ classes.add(ChangeNotification.class);
+ return classes;
+ }
+
+ @Override
+ public void close() throws Exception {
+ stop();
+ }
+
+ @Override
+ public void start(NotificationCollector collector) {
+ LOG.info("Starting notification stream for OrgOpenroadmDevice");
+ Preconditions.checkArgument(this.dataBroker != null, "Device datastore is null");
+ this.dataBroker.registerDataTreeChangeListener(DataTreeIdentifier.create(LogicalDatastoreType.OPERATIONAL, DEVICE_CONTAINER_ID),
+ new DataTreeChangeListener<OrgOpenroadmDevice>() {
+ @Override
+ public void onDataTreeChanged(Collection<DataTreeModification<OrgOpenroadmDevice>> changes) {
+ LOG.info("onDataTreeChanged");
+ ChangeNotification changeNotification = null;
+ try {
+ changeNotification = transformToNotification(changes);
+ LOG.info("Emitting notification : {}", changeNotification);
+ collector.onNotification(changeNotification);
+ } catch (NullPointerException e) {
+ LOG.warn("Failed to emit notification");
+ }
+ }
+ });
+ }
+
+ @Override
+ public void stop() {
+ LOG.info("Stopping OrgOpenroadmDevice change notification");
+ }
+
+ /**
+ * Transform {@link Collection} of {@link DataTreeModification } to {@link ChangeNotification}
+ *
+ * @return changeNotification {@link ChangeNotification}
+ */
+ private ChangeNotification transformToNotification(Collection<DataTreeModification<OrgOpenroadmDevice>> changes) {
+ LOG.info("transforming changes to notification...");
+ ChangeNotification result = null;
+ List<Edit> editList = new ArrayList<Edit>();
+ for (DataTreeModification<OrgOpenroadmDevice> change : changes) {
+ LOG.info("Received Device change :\n{}", change.getRootNode().getModificationType());
+ final DataObjectModification<OrgOpenroadmDevice> rootNode = change.getRootNode();
+ final DataTreeIdentifier<OrgOpenroadmDevice> rootPath = change.getRootPath();
+ if (rootNode != null) {
+ Collection<? extends DataObjectModification<? extends DataObject>> modifiedChildren = rootNode.getModifiedChildren();
+ switch (rootNode.getModificationType()) {
+ case SUBTREE_MODIFIED: // OrgOpenroadmDevice
+ if (!modifiedChildren.isEmpty()) {
+ Iterator<? extends DataObjectModification<? extends DataObject>> iterator = modifiedChildren.iterator();
+ while (iterator.hasNext()) {
+ DataObjectModification<? extends DataObject> modified = iterator.next();
+ LOG.info(
+ "modified = \ndataType : {}\nid : {}\nmodifiedType : {}\noldData : {}\nnewData : {} \n",
+ modified.getDataType(), modified.getIdentifier(), modified.getModificationType(),
+ modified.getDataBefore(), modified.getDataAfter());
+ String dataType = modified.getDataType().getName();
+ if (dataType.equals(INTERFACE_CLASS)) {
+ Interface data = null;
+ LOG.info("Interface type update !");
+ switch (modified.getModificationType()) {
+ case SUBTREE_MODIFIED:
+ data = (Interface) modified.getDataAfter();
+ break;
+ case WRITE:
+ data = (Interface) modified.getDataAfter();
+ break;
+ case DELETE:
+ data = (Interface) modified.getDataBefore();
+ break;
+ default:
+ break;
+ }
+ if (data!= null) {
+ String circuitPackName = data.getSupportingCircuitPackName();
+ String port = data.getSupportingPort().toString();
+ String interfaceName = data.getName();
+ if (circuitPackName != null && port != null && interfaceName != null) {
+ InstanceIdentifier<Ports> portIId = InstanceIdentifier.create(OrgOpenroadmDevice.class).child(
+ CircuitPacks.class, new CircuitPacksKey(circuitPackName)).child(Ports.class,
+ new PortsKey(port));
+ Edit edit = new EditBuilder()
+ .setOperation(EditOperationType.Merge)
+ .setTarget(portIId)
+ .build();
+ editList.add(edit);
+ }
+ } else {
+ LOG.warn("Interface data is null !");
+ }
+ } else {
+ LOG.warn("modifiedChild is not an interface !");
+ }
+ }
+ }
+ break;
+ case WRITE:
+ LOG.info("device operational datastore is created !");
+ break;
+ case DELETE:
+ LOG.info("device operational datastore is deleted !");
+ break;
+ default:
+ break;
+ }
+ } else {
+ LOG.error("rootNode is null !");
+ }
+ }
+ if (!editList.isEmpty()) {
+ ChangedBy changedBy = new ChangedByBuilder().setServerOrUser(new ServerBuilder().setServer(true).build())
+ .build();
+ String time = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSSSSSXXX").format(new Date());
+ result = new ChangeNotificationBuilder().setChangedBy(changedBy).setChangeTime(new DateAndTime(time))
+ .setDatastore(Datastore.Running).setEdit(editList).build();
+ } else {
+ LOG.warn("edit List is empty !");
+ }
+ return result;
+ }
+}
Code Review / transportpce.git / blobdiff