Implement test case for Fabric Discovery Plugin 39/13339/1
authorArun S. Yerra <arun.yerra@huawei.com>
Tue, 19 Sep 2017 07:38:58 +0000 (00:38 -0700)
committerArun S. Yerra <arun.yerra@huawei.com>
Tue, 19 Sep 2017 07:38:58 +0000 (00:38 -0700)
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>
fabric-discovery-plugin/provider/src/test/java/jtest/org/onap/ccsdk/sli/plugins/fabricdiscovery/TestFabricDiscoveryPlugin.java [new file with mode: 0644]

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 (file)
index 0000000..f5dc7cb
--- /dev/null
@@ -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));
+    }
+}