Add Unit Tests for openstack.net-virt-providers.openflow13 - FlowCapableNodeDataChang...

Change-Id: Icc614719be95e5b945a2bb686d509712a956c703
Signed-off-by: Ben Eze <beze@inocybe.ca>

diff --git a/openstack/net-virt-providers/src/test/java/org/opendaylight/ovsdb/openstack/netvirt/providers/openflow13/FlowCapableNodeDataChangeListenerTest.java b/openstack/net-virt-providers/src/test/java/org/opendaylight/ovsdb/openstack/netvirt/providers/openflow13/FlowCapableNodeDataChangeListenerTest.java
new file mode 100644 (file)
index 0000000..c341972
--- /dev/null
+++ b/openstack/net-virt-providers/src/test/java/org/opendaylight/ovsdb/openstack/netvirt/providers/openflow13/FlowCapableNodeDataChangeListenerTest.java
@@ -0,0 +1,147 @@
+/*
+ * Copyright (c) 2015 Inocybe Technologies.  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.ovsdb.openstack.netvirt.providers.openflow13;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertTrue;
+import static org.mockito.Matchers.any;
+import static org.mockito.Matchers.anyString;
+import static org.mockito.Matchers.eq;
+import static org.mockito.Matchers.same;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import java.lang.reflect.Field;
+import java.util.List;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.Mockito;
+import org.mockito.runners.MockitoJUnitRunner;
+import org.powermock.api.mockito.PowerMockito;
+import org.powermock.core.classloader.annotations.PrepareForTest;
+import org.powermock.modules.junit4.PowerMockRunner;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
+import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
+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.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNode;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
+import org.opendaylight.yangtools.concepts.ListenerRegistration;
+import org.opendaylight.yangtools.yang.binding.DataObject;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+import org.opendaylight.neutron.spi.INeutronPortCRUD;
+import org.opendaylight.neutron.spi.INeutronSubnetCRUD;
+import org.opendaylight.ovsdb.openstack.netvirt.NeutronCacheUtils;
+import org.opendaylight.ovsdb.openstack.netvirt.api.Action;
+import org.opendaylight.ovsdb.openstack.netvirt.api.NodeCacheManager;
+import org.opendaylight.ovsdb.openstack.netvirt.impl.EventDispatcherImpl;
+import org.opendaylight.ovsdb.utils.servicehelper.ServiceHelper;
+
+/**
+ * Unit test for {@link FlowCapableNodeDataChangeListener}
+ */
+@RunWith(PowerMockRunner.class)
+@PrepareForTest(ServiceHelper.class)
+public class FlowCapableNodeDataChangeListenerTest {
+
+    @InjectMocks
+    private FlowCapableNodeDataChangeListener nodeListener;
+
+    @Mock
+    private DataBroker dataBroker;
+
+    @Mock
+    private ListenerRegistration<DataChangeListener> registration;
+
+    @Mock
+    private NodeCacheManager nodeCacheManager;
+
+    @Mock
+    private PipelineOrchestrator orchestrator;
+
+    @Before
+    public void setUp() {
+
+        DataBroker dataBroker = mock(DataBroker.class);
+        registration = dataBroker.registerDataChangeListener(LogicalDatastoreType.OPERATIONAL,
+                FlowCapableNodeDataChangeListener.createFlowCapableNodePath()
+                , nodeListener
+                , AsyncDataBroker.DataChangeScope.BASE);
+
+        when(dataBroker.registerDataChangeListener(LogicalDatastoreType.OPERATIONAL,
+                FlowCapableNodeDataChangeListener.createFlowCapableNodePath()
+                , nodeListener
+                , AsyncDataBroker.DataChangeScope.BASE)).thenReturn(registration);
+
+        nodeListener = new FlowCapableNodeDataChangeListener(dataBroker);
+        orchestrator = Mockito.mock(PipelineOrchestrator.class);
+        nodeCacheManager = Mockito.mock(NodeCacheManager.class);
+
+
+        PowerMockito.mockStatic(ServiceHelper.class);
+
+        Mockito.when(ServiceHelper.getGlobalInstance(PipelineOrchestrator.class, nodeListener)).thenReturn(orchestrator);
+        Mockito.when(ServiceHelper.getGlobalInstance(NodeCacheManager.class, nodeListener)).thenReturn(nodeCacheManager);
+
+    }
+
+
+    /**
+     * Test method {@link FlowCapableNodeDataChangeListener#notifyFlowCapableNodeEventTest(String,Action)}
+     */
+    @Test
+    public void notifyFlowCapableNodeEventTest() throws Exception{
+
+        List<Node> nodeCache = (List<Node>) getClassField(nodeListener, "nodeCache");
+
+        nodeListener.notifyFlowCapableNodeEvent("flowid1", Action.ADD);
+        nodeListener.notifyFlowCapableNodeEvent("flowid2", Action.ADD);
+        assertEquals("Error, notifyFlowCapableNodeEvent() - Controller's node inventory size after an ADD operation is incorrect", 2, nodeCache.size());
+        verify(nodeCacheManager,times(1)).nodeAdded("flowid1");
+        verify(nodeCacheManager,times(1)).nodeAdded("flowid2");
+        verify(orchestrator, times(1)).enqueue("flowid1");
+
+        nodeListener.notifyFlowCapableNodeEvent("flowid1", Action.UPDATE);
+        assertEquals("Error, notifyFlowCapableNodeEvent() - Controller's node inventory size after an UPDATE operation is incorrect", 2, nodeCache.size());
+        verify(nodeCacheManager, times(1)).nodeAdded("flowid1");
+        verify(orchestrator, times(1)).enqueue("flowid1");
+
+        nodeListener.notifyFlowCapableNodeEvent("flowid1", Action.DELETE);
+        assertEquals("Error, notifyFlowCapableNodeEvent() - Controller's node inventory size after a DELETE operation is incorrect", 2, nodeCache.size());
+        verify(nodeCacheManager, times(1)).nodeAdded("flowid1");
+        verify(nodeCacheManager, times(1)).nodeRemoved("flowid1");
+        verify(orchestrator, times(1)).enqueue("flowid1");
+
+    }
+
+    /**
+     * Get the specified field from FlowCapableNodeDataChangeListener using reflection
+     * @param instancee - the class instance
+     * @param fieldName - the field to retrieve
+     *
+     * @return the desired field
+     */
+    private Object getClassField(FlowCapableNodeDataChangeListener instance, String fieldName) throws NoSuchFieldException, SecurityException, IllegalArgumentException, IllegalAccessException{
+        Field field = FlowCapableNodeDataChangeListener.class.getDeclaredField(fieldName);
+        field.setAccessible(true);
+        return field.get(instance);
+    }
+
+}

diff --git a/openstack/net-virt-providers/src/test/java/org/opendaylight/ovsdb/openstack/netvirt/providers/openflow13/MdsalConsumerImplTest.java b/openstack/net-virt-providers/src/test/java/org/opendaylight/ovsdb/openstack/netvirt/providers/openflow13/MdsalConsumerImplTest.java
new file mode 100644 (file)
index 0000000..f7a6209
--- /dev/null
+++ b/openstack/net-virt-providers/src/test/java/org/opendaylight/ovsdb/openstack/netvirt/providers/openflow13/MdsalConsumerImplTest.java
@@ -0,0 +1,155 @@
+/*
+ * Copyright (c) 2015 Inocybe Technologies.  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.ovsdb.openstack.netvirt.providers.openflow13;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertSame;
+import static org.junit.Assert.assertTrue;
+import static org.mockito.Matchers.any;
+import static org.mockito.Matchers.anyString;
+import static org.mockito.Matchers.eq;
+import static org.mockito.Matchers.same;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import java.lang.reflect.Field;
+import java.util.ArrayList;
+import java.util.List;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.Mockito;
+import org.mockito.runners.MockitoJUnitRunner;
+import org.powermock.api.mockito.PowerMockito;
+import org.powermock.core.classloader.annotations.PrepareForTest;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
+import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
+import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker;
+import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
+import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.sal.binding.api.NotificationProviderService;
+import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ConsumerContext;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNode;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.FlowBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeBuilder;
+import org.opendaylight.yangtools.concepts.ListenerRegistration;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+import org.opendaylight.neutron.spi.INeutronPortCRUD;
+import org.opendaylight.neutron.spi.INeutronSubnetCRUD;
+import org.opendaylight.ovsdb.openstack.netvirt.NeutronCacheUtils;
+import org.opendaylight.ovsdb.openstack.netvirt.api.Action;
+import org.opendaylight.ovsdb.openstack.netvirt.api.NodeCacheManager;
+import org.opendaylight.ovsdb.openstack.netvirt.impl.EventDispatcherImpl;
+import org.opendaylight.ovsdb.utils.servicehelper.ServiceHelper;
+
+/**
+ * Unit test for {@link MdsalConsumerImpl}
+ */
+@RunWith(MockitoJUnitRunner.class)
+public class MdsalConsumerImplTest {
+
+    private MdsalConsumerImpl mdsalConsumer;
+
+    @Mock
+    private DataBroker dataBroker;
+
+    @Mock
+    private ConsumerContext session;
+
+    @Mock
+    private ProviderContext providerSession;
+
+    @Mock
+    private NotificationProviderService notificationService;
+
+    @Before
+    public void setUp(){
+
+        mdsalConsumer = new MdsalConsumerImpl();
+        dataBroker = Mockito.mock(DataBroker.class);
+        session = Mockito.mock(ConsumerContext.class);
+        providerSession = Mockito.mock(ProviderContext.class);
+        notificationService = Mockito.mock(NotificationProviderService.class);
+
+        when(session.getSALService(DataBroker.class)).thenReturn(dataBroker);
+        when(providerSession.getSALService(NotificationProviderService.class)).thenReturn(notificationService);
+
+        //Initialize the Mdsal consumer
+        mdsalConsumer.onSessionInitialized(session);
+        mdsalConsumer.onSessionInitiated(providerSession);
+    }
+
+    /**
+     * Test method for
+     *          {@link MdsalConsumerImpl#getConsumerContext()}
+     *          {@link MdsalConsumerImpl#getDataBroker()}
+     *          {@link MdsalConsumerImpl#getNotificationService()}
+     *
+     */
+    @Test
+    public void InitializationsTests(){
+
+        assertSame("Error, getConsumerContext - returned context is invalid", session, mdsalConsumer.getConsumerContext());
+        assertSame("Error, getDataBroker - returned broker is invalid", dataBroker, mdsalConsumer.getDataBroker());
+        assertSame("Error, getNotificationService - returned notification service provider is invalid", notificationService, mdsalConsumer.getNotificationService());
+
+    }
+
+    /**
+     * Test method {@link MdsalConsumerImpl#notifyFlowCapableNodeCreateEvent(String, Action)}
+     */
+    @Test
+    public void notifyFlowCapableNodeCreateEventTest() throws Exception{
+
+        FlowCapableNodeDataChangeListener nodeChangeListener = (FlowCapableNodeDataChangeListener) getClassField(mdsalConsumer, "flowCapableNodeChangeListener");
+
+        //Send a notification
+        mdsalConsumer.notifyFlowCapableNodeCreateEvent("flowId1", Action.ADD);
+
+        List<Node> nodeCache = (List<Node>) getClassField(nodeChangeListener, "nodeCache");
+        assertEquals("Error, notifyFlowCapableNodeEvent() - MdsalConsumerImpl NodeDataChangeLister inventory size after an ADD operation is incorrect", 1, nodeCache.size());
+    }
+
+    /**
+     * Get the specified field from MdsalConsumerImpl using reflection
+     * @param instancee - the class instance
+     * @param fieldName - the field to retrieve
+     *
+     * @return the desired field
+     */
+    private Object getClassField(MdsalConsumerImpl instance, String fieldName) throws NoSuchFieldException, SecurityException, IllegalArgumentException, IllegalAccessException{
+        Field field = MdsalConsumerImpl.class.getDeclaredField(fieldName);
+        field.setAccessible(true);
+        return field.get(instance);
+    }
+
+    /**
+     * Get the specified field from FlowCapableNodeDataChangeListener using reflection
+     * @param instancee - the class instance
+     * @param fieldName - the field to retrieve
+     *
+     * @return the desired field
+     */
+    private Object getClassField(FlowCapableNodeDataChangeListener instance, String fieldName) throws NoSuchFieldException, SecurityException, IllegalArgumentException, IllegalAccessException{
+        Field field = FlowCapableNodeDataChangeListener.class.getDeclaredField(fieldName);
+        field.setAccessible(true);
+        return field.get(instance);
+    }
+
+}