diff options
Diffstat (limited to 'dcae_dmaapbc_client/src/test/java/org/openecomp/dcae/dmaapbc/TestDmaapBcRestClient.java')
| -rw-r--r-- | dcae_dmaapbc_client/src/test/java/org/openecomp/dcae/dmaapbc/TestDmaapBcRestClient.java | 159 |
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"); + + } + +} |