Implement test case for Fabric Discovery Plugin

Fabric Discovery plugin implements framework to connect to fabric
update notifications from local domain controllers. This task is to implement
unit test case for this module.

Issue-Id: CCSDK-96

Change-Id: I3387f248e693a7da6b4817bc27f87dbc86aea806
Signed-off-by: Arun S. Yerra <arun.yerra@huawei.com>

1 files changed, 35 insertions, 0 deletions

diff --git a/fabric-discovery-plugin/provider/src/test/java/jtest/org/onap/ccsdk/sli/plugins/fabricdiscovery/TestFabricDiscoveryPlugin.java b/fabric-discovery-plugin/provider/src/test/java/jtest/org/onap/ccsdk/sli/plugins/fabricdiscovery/TestFabricDiscoveryPlugin.java
new file mode 100644
index 00000000..f5dc7cbc
--- /dev/null
+++ b/fabric-discovery-plugin/provider/src/test/java/jtest/org/onap/ccsdk/sli/plugins/fabricdiscovery/TestFabricDiscoveryPlugin.java
@@ -0,0 +1,35 @@
+package jtest.org.onap.ccsdk.sli.plugins.fabricdiscovery;
+
+import java.util.HashMap;
+import java.util.Map;
+import org.junit.Assert;
+import org.junit.Test;
+import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
+import org.onap.ccsdk.sli.plugins.fabricdiscovery.FabricDiscoveryPlugin;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Created by arun on 9/18/17.
+ */
+
+public class TestFabricDiscoveryPlugin {
+    private static final Logger LOG = LoggerFactory.getLogger(TestFabricDiscoveryPlugin.class);
+    private static final String C_STREAM =
+        "ws://localhost:8185/data-change-event-subscription/network-topology:network-topology/datastore=CONFIGURATION/scope=BASE";
+    private final String FB_DISCOVERY_STATUS = "fb-response";
+
+    @Test
+    public void connectToNotificationServerSuccess() throws Exception {
+        SvcLogicContext ctx = new SvcLogicContext();
+        String stream = C_STREAM;
+
+        Map<String, String> p = new HashMap<String, String>();
+        p.put("stream", stream);
+        p.put("enable", "true");
+
+        FabricDiscoveryPlugin fdp = new FabricDiscoveryPlugin();
+        fdp.processDcNotificationStream(p, ctx);
+        Assert.assertEquals("Success", ctx.getAttribute(FB_DISCOVERY_STATUS));
+    }
+}