Switch to MD-SAL APIs

[openflowplugin.git] / applications / forwardingrules-manager / src / test / java / test / mock / NodeListenerTest.java

diff --git a/applications/forwardingrules-manager/src/test/java/test/mock/NodeListenerTest.java b/applications/forwardingrules-manager/src/test/java/test/mock/NodeListenerTest.java
index 5ee4b07290fff5fb3eaf11c7f3dc4c7d02ca21e8..bec4dee8faf194e3c5d0aa895b0003ae693c84ee 100644 (file)
--- a/applications/forwardingrules-manager/src/test/java/test/mock/NodeListenerTest.java
+++ b/applications/forwardingrules-manager/src/test/java/test/mock/NodeListenerTest.java
@@ -1,4 +1,4 @@
-/**
+/*
  * Copyright (c) 2014 Cisco Systems, Inc. and others.  All rights reserved.
  *
  * This program and the accompanying materials are made available under the
@@ -9,9 +9,19 @@ package test.mock;
 
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertTrue;
+
+import org.junit.After;
+import org.junit.Before;
 import org.junit.Test;
-import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry;
+import org.junit.runner.RunWith;
+import org.mockito.Mock;
+import org.mockito.junit.MockitoJUnitRunner;
+import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider;
+import org.opendaylight.openflowplugin.api.openflow.mastership.MastershipChangeServiceManager;
 import org.opendaylight.openflowplugin.applications.frm.impl.ForwardingRulesManagerImpl;
+import org.opendaylight.openflowplugin.applications.frm.recovery.OpenflowServiceRecoveryHandler;
+import org.opendaylight.openflowplugin.applications.reconciliation.ReconciliationManager;
+import org.opendaylight.serviceutils.srm.ServiceRecoveryRegistry;
 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;
@@ -21,33 +31,55 @@ import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
 import test.mock.util.FRMTest;
 import test.mock.util.RpcProviderRegistryMock;
 
+@RunWith(MockitoJUnitRunner.class)
 public class NodeListenerTest extends FRMTest {
+    private ForwardingRulesManagerImpl forwardingRulesManager;
+    private static final NodeKey NODE_KEY = new NodeKey(new NodeId("testnode:1"));
+    RpcProviderRegistryMock rpcProviderRegistryMock = new RpcProviderRegistryMock();
+    @Mock
+    ClusterSingletonServiceProvider clusterSingletonService;
+    @Mock
+    private ReconciliationManager reconciliationManager;
+    @Mock
+    private OpenflowServiceRecoveryHandler openflowServiceRecoveryHandler;
+    @Mock
+    private ServiceRecoveryRegistry serviceRecoveryRegistry;
+    @Mock
+    private MastershipChangeServiceManager mastershipChangeServiceManager;
 
-    RpcProviderRegistry rpcProviderRegistryMock = new RpcProviderRegistryMock();
-    NodeKey s1Key = new NodeKey(new NodeId("S1"));
-
-    @Test
-    public void addRemoveNodeTest() throws Exception {
-        try (ForwardingRulesManagerImpl forwardingRulesManager = new ForwardingRulesManagerImpl(
+    @Before
+    public void setUp() {
+        forwardingRulesManager = new ForwardingRulesManagerImpl(
                 getDataBroker(),
                 rpcProviderRegistryMock,
-                getConfig())) {
-            forwardingRulesManager.start();
-
-            addFlowCapableNode(s1Key);
+                rpcProviderRegistryMock,
+                getConfig(),
+                mastershipChangeServiceManager,
+                clusterSingletonService,
+                getConfigurationService(),
+                reconciliationManager,
+                openflowServiceRecoveryHandler,
+                serviceRecoveryRegistry);
 
-            InstanceIdentifier<FlowCapableNode> nodeII = InstanceIdentifier.create(Nodes.class).child(Node.class, s1Key)
-                    .augmentation(FlowCapableNode.class);
 
-            boolean nodeActive = forwardingRulesManager.isNodeActive(nodeII);
-            assertTrue(nodeActive);
+        forwardingRulesManager.start();
+    }
 
-            removeNode(s1Key);
+    @Test
+    public void addRemoveNodeTest() throws Exception {
+        addFlowCapableNode(NODE_KEY);
 
-            nodeActive = forwardingRulesManager.isNodeActive(nodeII);
-            assertFalse(nodeActive);
-        }
+        InstanceIdentifier<FlowCapableNode> nodeII = InstanceIdentifier.create(Nodes.class).child(Node.class, NODE_KEY)
+                .augmentation(FlowCapableNode.class);
+        boolean nodeActive = forwardingRulesManager.isNodeActive(nodeII);
+        assertTrue(nodeActive);
+        removeNode(NODE_KEY);
+        nodeActive = forwardingRulesManager.isNodeActive(nodeII);
+        assertFalse(nodeActive);
     }
 
-
+    @After
+    public void tearDown() throws Exception {
+        forwardingRulesManager.close();
+    }
 }