Initial OpenECOMP UI/DMaapBC commit

Change-Id: Ia492e1b88311b9bed4c31f593b28deaaad73b7e4
Signed-off-by: talasila <talasila@research.att.com>

1 files changed, 159 insertions, 0 deletions

diff --git a/dcae_dmaapbc_client/src/test/java/org/openecomp/dcae/dmaapbc/TestDmaapBcRestClient.java b/dcae_dmaapbc_client/src/test/java/org/openecomp/dcae/dmaapbc/TestDmaapBcRestClient.java
new file mode 100644
index 0000000..e90c7b8
--- /dev/null
+++ b/dcae_dmaapbc_client/src/test/java/org/openecomp/dcae/dmaapbc/TestDmaapBcRestClient.java
@@ -0,0 +1,159 @@
+package org.openecomp.dcae.dmaapbc;
+
+import java.util.List;
+
+import org.junit.Test;
+import org.openecomp.dcae.dmaap.bcapi.client.DmaapBcRestClient;
+import org.openecomp.dcae.dmaap.bcapi.client.HttpStatusAndResponse;
+import org.openecomp.dcae.dmaapbc.model.DmaapObject;
+import org.openecomp.dcae.dmaapbc.model.Feed;
+import org.openecomp.dcae.dmaapbc.model.Topic;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class TestDmaapBcRestClient {
+
+	private static Logger logger = LoggerFactory.getLogger(TestDmaapBcRestClient.class);
+
+	/**
+	 * Exercises some of the DMaaP Bus Controller client's functionality.
+	 */
+	@Test
+	public void test() throws Exception {
+		DmaapBcRestClient client = new DmaapBcRestClient("https://host:8443/webapi/",
+				"host", "MechIdPassword");
+
+		// This may help when in a hurry, but it's dangerous.
+		// client.setFailOnUnknownProperties(false);
+
+		DmaapObject dmaap = client.getDmaap();
+		if (dmaap == null)
+			logger.warn("Failed to get DMAAP");
+		else
+			logger.info("DMAAP is " + dmaap.toString());
+
+		List<DmaapObject> locs = client.getDcaeLocations();
+		if (locs == null) {
+			logger.warn("Failed to get DCAE locations");
+		} else {
+			logger.info("Loc count is " + locs.size());
+			for (DmaapObject loc : locs)
+				logger.info("Location is: " + loc.toString());
+		}
+
+		List<DmaapObject> nodes = client.getDRNodes();
+		if (nodes == null) {
+			logger.warn("Failed to get nodes");
+		} else {
+			logger.info("node count is " + nodes.size());
+			for (DmaapObject node : nodes)
+				logger.info("Nodeis: " + node.toString());
+		}
+
+		List<DmaapObject> drPubs = client.getDRPubs();
+		if (drPubs == null) {
+			logger.warn("Failed to get DR pubs");
+		} else {
+			logger.info("DR_Pub count is " + drPubs.size());
+			for (DmaapObject pub : drPubs)
+				logger.info("DR_Pub is: " + pub.toString());
+		}
+		List<DmaapObject> drSubs = client.getDRSubs();
+		if (drSubs == null) {
+			logger.warn("Failed to get DR subs");
+		} else {
+			logger.info("DR_Sub count is " + drSubs.size());
+			for (DmaapObject sub : drSubs)
+				logger.info("DR_Sub is: " + sub.toString());
+		}
+
+		List<DmaapObject> feeds = client.getFeeds();
+		if (feeds == null) {
+			logger.warn("Failed to get feeds");
+		} else {
+			logger.info("Feed count is " + feeds.size());
+			for (DmaapObject feed : feeds)
+				logger.info("Feed is: " + feed.toString());
+		}
+		List<DmaapObject> topics = client.getTopics();
+		if (topics == null) {
+			logger.warn("Failed to get topics");
+		} else {
+			logger.info("Topic count is " + topics.size());
+			for (DmaapObject topic : topics)
+				logger.info("Topic is: " + topic.toString());
+		}
+		List<DmaapObject> clients = client.getMRClients();
+		if (clients == null) {
+			logger.warn("Failed to get MR clients");
+		} else {
+			logger.info("MR client count is " + clients.size());
+			for (DmaapObject mrc : clients)
+				logger.info("MR client is: " + mrc.toString());
+		}
+		List<DmaapObject> clusters = client.getMRClusters();
+		if (clusters == null) {
+			logger.warn("Failed to get MR clusters");
+		} else {
+			logger.info("MR cluster count is " + clusters.size());
+			for (DmaapObject mrc : clusters)
+				logger.info("MR cluster is: " + mrc.toString());
+		}
+
+		// Create and delete feed
+
+		Feed feed = (Feed) feeds.get(0);
+		final String feedId = "987654321";
+		final String feedName = "TestFeed1234567890";
+		final String feedUrl = "http://host.com/foo/bar";
+		feed.setFeedId(feedId);
+		feed.setFeedName(feedName);
+		feed.setPublishURL(feedUrl);
+		HttpStatusAndResponse<Object> addFeedResp = client.postFeed(feed);
+		if (addFeedResp.getStatusCode() == 200)
+			logger.info("add feed succeeded, response is " + addFeedResp);
+		else
+			logger.error("add feed failed, response is " + addFeedResp);
+
+		DmaapObject getFeedResp = client.getFeed(feedId);
+		logger.info("get feed response is " + getFeedResp);
+		HttpStatusAndResponse<Object> delFeedResp = client.deleteFeed(feedId);
+		if (delFeedResp.getStatusCode() == 200)
+			logger.info("delete feed succeeded, response is " + delFeedResp);
+		else
+			logger.error("delete feed failed, response is " + delFeedResp);
+
+		// Attempt to create empty feed should fail -- but does not
+		// Feed emptyFeed = new Feed();
+		// HttpStatusAndResponse<Object> addEmptyFeedResp =
+		// client.postFeed(emptyFeed);
+		// if (addEmptyFeedResp.getStatusCode() == 200)
+		// logger.info("add feed succeeded, response is " + addFeedResp);
+		// else
+		// logger.error("add feed failed, response is " + addFeedResp);
+
+		// Create and delete topic
+
+		Topic topic = new Topic();
+		final String fqtn = "host";
+		topic.setFqtn(fqtn);
+		HttpStatusAndResponse<Object> createTopicResp = client.postTopic(topic);
+		logger.info("create topic response is " + createTopicResp);
+		DmaapObject getTopicResp = client.getTopic(fqtn);
+		logger.info("get topic response is " + getTopicResp);
+		HttpStatusAndResponse<Object> delTopic = client.deleteTopic(fqtn);
+		if (delTopic.getStatusCode() == 200)
+			logger.info("del topic succeeded, response is " + delTopic);
+		else
+			logger.error("del topic failed, response is " + delTopic);
+		HttpStatusAndResponse<Object> delTopicMissing = client.deleteTopic(fqtn);
+		if (delTopicMissing.getStatusCode() == 204)
+			logger.info("del of missing topic succeeded, response is " + delTopicMissing);
+		else
+			logger.error("del of missing topic failed, response is " + delTopic);
+
+		logger.info("ends");
+
+	}
+
+}