Add Endpoint Manager and Listener

Change-Id: Ia24206237751b2035cbf2206a6d67ff6e5543b78
Signed-off-by: adetalhouet <adetalhouet@inocybe.com>

diff --git a/renderers/iovisor/src/main/java/org/opendaylight/groupbasedpolicy/renderer/iovisor/endpoint/EndpointListener.java b/renderers/iovisor/src/main/java/org/opendaylight/groupbasedpolicy/renderer/iovisor/endpoint/EndpointListener.java
new file mode 100644 (file)
index 0000000..a48c741
--- /dev/null
+++ b/renderers/iovisor/src/main/java/org/opendaylight/groupbasedpolicy/renderer/iovisor/endpoint/EndpointListener.java
@@ -0,0 +1,128 @@
+/*
+ * Copyright (c) 2015 Inocybe Technologies and others. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
+package org.opendaylight.groupbasedpolicy.renderer.iovisor.endpoint;
+
+import java.util.Map;
+import java.util.Map.Entry;
+
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
+import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker;
+import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent;
+import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
+import org.opendaylight.groupbasedpolicy.util.IidFactory;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.endpoint.rev140421.endpoints.Endpoint;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.endpoint.rev140421.endpoints.EndpointBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.endpoint.rev140421.endpoints.EndpointKey;
+import org.opendaylight.yangtools.concepts.ListenerRegistration;
+import org.opendaylight.yangtools.yang.binding.DataObject;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class EndpointListener implements DataChangeListener, AutoCloseable {
+
+    private static final Logger LOG = LoggerFactory.getLogger(EndpointListener.class);
+
+    private final ListenerRegistration<DataChangeListener> registerListener;
+
+    public EndpointListener(DataBroker dataBroker) {
+        this.registerListener = dataBroker.registerDataChangeListener(
+                                                LogicalDatastoreType.OPERATIONAL,
+                                                IidFactory.endpointsIidWildcard().child(Endpoint.class),
+                                                this,
+                                                AsyncDataBroker.DataChangeScope.SUBTREE);
+    }
+
+    @Override
+    public void onDataChanged(AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> changes) {
+        created(changes.getCreatedData());
+        updated(changes.getUpdatedData());
+        removed(changes);
+    }
+
+    /**
+     * Process created events.
+     *
+     * @param created
+     *            Created data
+     */
+    private void created(Map<InstanceIdentifier<?>, DataObject> created) {
+        for (Entry<InstanceIdentifier<?>, DataObject> newEndpoint : created.entrySet()) {
+            Endpoint endpoint = fromMd(newEndpoint.getKey(), (Endpoint) newEndpoint.getValue());
+            LOG.info("Endpoint CREATED {}", endpoint);
+            // TODO process created event
+        }
+    }
+
+    /**
+     * Process updated events.
+     *
+     * @param updated
+     *            updated data
+     */
+    private void updated(Map<InstanceIdentifier<?>, DataObject> updated) {
+        for (Entry<InstanceIdentifier<?>, DataObject> updatedEndpoint : updated.entrySet()) {
+            Endpoint endpoint = fromMd(updatedEndpoint.getKey(), (Endpoint) updatedEndpoint.getValue());
+            LOG.info("Endpoint UPDATED {}", endpoint);
+            //TODO process updated event
+        }
+    }
+
+    /**
+     * Process REMOVED data.
+     *
+     * @param changes
+     *            Changes data
+     */
+    private void removed(AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> changes) {
+        for (InstanceIdentifier<?> deletedEndpointPath : changes.getRemovedPaths()) {
+            Endpoint endpoint = fromMd(deletedEndpointPath, (Endpoint) changes.getOriginalData().get(deletedEndpointPath));
+            LOG.info("Endpoint REMOVED {}", endpoint);
+            // TODO process removed event
+        }
+    }
+
+    /**
+     * Get the object from MD-SAL based on the instance identifier.
+     *
+     * @param iid
+     *            {@link InstanceIdentifier} of the related event
+     * @param endpoint
+     *            Endpoint from the related event
+     * @return Endpoint constructed from the one gathered in the related event
+     */
+    @SuppressWarnings("deprecation")
+    private Endpoint fromMd(InstanceIdentifier<?> iid, Endpoint endpoint) {
+        EndpointBuilder result = new EndpointBuilder();
+
+        final EndpointKey endpointKey = iid.firstKeyOf(Endpoint.class, EndpointKey.class);
+        if (endpointKey != null) {
+            result.setKey(endpointKey);
+        }
+
+        result.setCondition(endpoint.getCondition());
+        result.setEndpointGroup(endpoint.getEndpointGroup());
+        result.setEndpointGroups(endpoint.getEndpointGroups());
+        result.setL2Context(endpoint.getL2Context());
+        result.setL3Address(endpoint.getL3Address());
+        result.setMacAddress(endpoint.getMacAddress());
+        result.setNetworkContainment(endpoint.getNetworkContainment());
+        result.setTenant(endpoint.getTenant());
+        result.setTimestamp(endpoint.getTimestamp());
+
+        return result.build();
+    }
+
+    @Override
+    public void close() throws Exception {
+        if (registerListener != null)
+            registerListener.close();
+    }
+}

diff --git a/renderers/iovisor/src/main/java/org/opendaylight/groupbasedpolicy/renderer/iovisor/endpoint/EndpointManager.java b/renderers/iovisor/src/main/java/org/opendaylight/groupbasedpolicy/renderer/iovisor/endpoint/EndpointManager.java
new file mode 100644 (file)
index 0000000..1c8ffa0
--- /dev/null
+++ b/renderers/iovisor/src/main/java/org/opendaylight/groupbasedpolicy/renderer/iovisor/endpoint/EndpointManager.java
@@ -0,0 +1,35 @@
+/*
+ * Copyright (c) 2015 Inocybe Technologies and others. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
+package org.opendaylight.groupbasedpolicy.renderer.iovisor.endpoint;
+
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.google.common.base.Preconditions;
+
+public class EndpointManager implements AutoCloseable {
+
+    private static final Logger LOG = LoggerFactory.getLogger(EndpointManager.class);
+    private EndpointListener endpointListener;
+
+    public EndpointManager(DataBroker dataBroker) {
+        LOG.debug("Initialized IOVisor EndpointManager");
+        Preconditions.checkNotNull("DataBroker instance must not be null", dataBroker);
+
+        this.endpointListener = new EndpointListener(dataBroker);
+    }
+
+    @Override
+    public void close() throws Exception {
+        if (endpointListener != null) {
+            endpointListener.close();
+        }
+    }
+}
\ No newline at end of file