diff options
Diffstat (limited to 'feature-simulators/src/test/java/org/onap/policy/drools/simulators/DMaaPSimulatorTest.java')
| -rw-r--r-- | feature-simulators/src/test/java/org/onap/policy/drools/simulators/DMaaPSimulatorTest.java | 291 |
1 files changed, 142 insertions, 149 deletions
diff --git a/feature-simulators/src/test/java/org/onap/policy/drools/simulators/DMaaPSimulatorTest.java b/feature-simulators/src/test/java/org/onap/policy/drools/simulators/DMaaPSimulatorTest.java index b16804e6..1ba2fc44 100644 --- a/feature-simulators/src/test/java/org/onap/policy/drools/simulators/DMaaPSimulatorTest.java +++ b/feature-simulators/src/test/java/org/onap/policy/drools/simulators/DMaaPSimulatorTest.java @@ -36,43 +36,46 @@ import java.nio.charset.StandardCharsets; import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.Test; -import org.onap.policy.drools.http.server.HttpServletServer; +import org.onap.policy.common.endpoints.http.server.HttpServletServer; +import org.onap.policy.common.endpoints.http.server.impl.IndexedHttpServletServerFactory; +import org.onap.policy.common.utils.network.NetworkUtil; import org.onap.policy.drools.utils.logging.LoggerUtil; -import org.onap.policy.drools.utils.NetworkUtil; public class DMaaPSimulatorTest { - private static final int DMAAPSIM_SERVER_PORT = 6670; + private static final int DMAAPSIM_SERVER_PORT = 6670; + @BeforeClass public static void setUpSimulator() { LoggerUtil.setLevel("ROOT", "INFO"); LoggerUtil.setLevel("org.eclipse.jetty", "WARN"); try { - final HttpServletServer testServer = HttpServletServer.factory.build("dmaapSim", - "localhost", DMAAPSIM_SERVER_PORT, "/", false, true); - testServer.addServletClass("/*", DMaaPSimulatorJaxRs.class.getName()); - testServer.waitedStart(5000); - if (!NetworkUtil.isTcpPortOpen("localhost", testServer.getPort(), 5, 10000L)) - throw new IllegalStateException("cannot connect to port " + testServer.getPort()); + final HttpServletServer testServer = IndexedHttpServletServerFactory.getInstance().build("dmaapSim", + "localhost", DMAAPSIM_SERVER_PORT, "/", false, true); + testServer.addServletClass("/*", DMaaPSimulatorJaxRs.class.getName()); + testServer.waitedStart(5000); + if (!NetworkUtil.isTcpPortOpen("localhost", testServer.getPort(), 5, 10000L)) { + throw new IllegalStateException("cannot connect to port " + testServer.getPort()); + } } catch (final Exception e) { - fail(e.getMessage()); + fail(e.getMessage()); } } @AfterClass public static void tearDownSimulator() { - HttpServletServer.factory.destroy(); + IndexedHttpServletServerFactory.getInstance().destroy(); } - + @Test public void testGetNoData() { int timeout = 1000; - Pair <Integer, String> response = dmaapGet("myTopicNoData", timeout); + Pair<Integer, String> response = dmaapGet("myTopicNoData", timeout); assertNotNull(response); assertNotNull(response.a); assertEquals("No topic", response.b); } - + @Test public void testSinglePost() { String myTopic = "myTopicSinglePost"; @@ -81,13 +84,13 @@ public class DMaaPSimulatorTest { assertNotNull(response); assertNotNull(response.a); assertNotNull(response.b); - + response = dmaapGet(myTopic, 1000); assertNotNull(response); assertNotNull(response.a); assertEquals(testData, response.b); } - + @Test public void testOneTopicMultiPost() { String[] data = {"data point 1", "data point 2", "something random"}; @@ -96,269 +99,259 @@ public class DMaaPSimulatorTest { assertNotNull(response); assertNotNull(response.a); assertNotNull(response.b); - + response = dmaapPost(myTopic, data[1]); assertNotNull(response); assertNotNull(response.a); assertNotNull(response.b); - + response = dmaapPost(myTopic, data[2]); assertNotNull(response); assertNotNull(response.a); assertNotNull(response.b); - + response = dmaapGet(myTopic, 1000); assertNotNull(response); assertNotNull(response.a); assertEquals(data[0], response.b); - + response = dmaapGet(myTopic, 1000); assertNotNull(response); assertNotNull(response.a); assertEquals(data[1], response.b); - + response = dmaapGet(myTopic, 1000); assertNotNull(response); assertNotNull(response.a); assertEquals(data[2], response.b); } - + @Test public void testMultiTopic() { - String[][] data = {{"Topic one message one", "Topic one message two"}, {"Topic two message one", "Topic two message two"}}; + String[][] data = {{"Topic one message one", "Topic one message two"}, + {"Topic two message one", "Topic two message two"}}; String[] topics = {"topic1", "topic2"}; - + Pair<Integer, String> response = dmaapPost(topics[0], data[0][0]); assertNotNull(response); assertNotNull(response.a); assertNotNull(response.b); - + response = dmaapGet(topics[0], 1000); assertNotNull(response); assertNotNull(response.a); assertEquals(data[0][0], response.b); - + response = dmaapGet(topics[1], 1000); assertNotNull(response); assertNotNull(response.a); assertEquals("No topic", response.b); - + response = dmaapPost(topics[1], data[1][0]); assertNotNull(response); assertNotNull(response.a); assertNotNull(response.b); - + response = dmaapPost(topics[1], data[1][1]); assertNotNull(response); assertNotNull(response.a); assertNotNull(response.b); - + response = dmaapPost(topics[0], data[0][1]); assertNotNull(response); assertNotNull(response.a); assertNotNull(response.b); - + response = dmaapGet(topics[1], 1000); assertNotNull(response); assertNotNull(response.a); assertEquals(data[1][0], response.b); - + response = dmaapGet(topics[0], 1000); assertNotNull(response); assertNotNull(response.a); assertEquals(data[0][1], response.b); - + response = dmaapGet(topics[1], 1000); assertNotNull(response); assertNotNull(response.a); assertEquals(data[1][1], response.b); - + response = dmaapGet(topics[0], 1000); assertNotNull(response); assertNotNull(response.a); assertEquals("No Data", response.b); } - + @Test public void testResponseCode() { Pair<Integer, String> response = dmaapPost("myTopic", "myTopicData"); assertNotNull(response); assertNotNull(response.a); assertNotNull(response.b); - + response = setStatus(503); assertNotNull(response); assertNotNull(response.a); assertNotNull(response.b); - + response = dmaapGet("myTopic", 500); assertNotNull(response); assertEquals(503, response.a.intValue()); assertEquals("You got response code: 503", response.b); - + response = setStatus(202); assertNotNull(response); assertNotNull(response.a); assertNotNull(response.b); - + response = dmaapGet("myTopic", 500); assertNotNull(response); assertEquals(202, response.a.intValue()); assertEquals("myTopicData", response.b); } - - private static Pair<Integer, String> dmaapGet (String topic, int timeout) { + + private static Pair<Integer, String> dmaapGet(String topic, int timeout) { return dmaapGet(topic, "1", "1", timeout); } - - private static Pair<Integer, String> dmaapGet (String topic, String consumerGroup, String consumerId, int timeout) { - String url = "http://localhost:" + DMAAPSIM_SERVER_PORT + "/events/" + topic + "/" + consumerGroup + "/" + consumerId + "?timeout=" + timeout; + + private static Pair<Integer, String> dmaapGet(String topic, String consumerGroup, String consumerId, int timeout) { + String url = "http://localhost:" + DMAAPSIM_SERVER_PORT + "/events/" + topic + "/" + consumerGroup + "/" + + consumerId + "?timeout=" + timeout; try { - URLConnection conn = new URL(url).openConnection(); + URLConnection conn = new URL(url).openConnection(); HttpURLConnection httpConn = null; if (conn instanceof HttpURLConnection) { - httpConn = (HttpURLConnection) conn; - } - else { - fail("connection not set up right"); + httpConn = (HttpURLConnection) conn; + } else { + fail("connection not set up right"); } httpConn.setRequestMethod("GET"); httpConn.connect(); String response = ""; try (BufferedReader connReader = new BufferedReader(new InputStreamReader(httpConn.getInputStream()))) { - String line; - while((line = connReader.readLine()) != null) { - response += line; - } - httpConn.disconnect(); - return new Pair<Integer, String>(httpConn.getResponseCode(), response); - } - catch (IOException e) { - if (e.getMessage().startsWith("Server returned HTTP response code")) { - System.out.println("hi"); - BufferedReader connReader = new BufferedReader(new InputStreamReader(httpConn.getErrorStream())); - String line; - while((line = connReader.readLine()) != null) { - response += line; - } - httpConn.disconnect(); - return new Pair<Integer, String>(httpConn.getResponseCode(), response); - } - else { - fail("we got an exception: " + e); - } + String line; + while ((line = connReader.readLine()) != null) { + response += line; + } + httpConn.disconnect(); + return new Pair<Integer, String>(httpConn.getResponseCode(), response); + } catch (IOException e) { + if (e.getMessage().startsWith("Server returned HTTP response code")) { + System.out.println("hi"); + BufferedReader connReader = new BufferedReader(new InputStreamReader(httpConn.getErrorStream())); + String line; + while ((line = connReader.readLine()) != null) { + response += line; + } + httpConn.disconnect(); + return new Pair<Integer, String>(httpConn.getResponseCode(), response); + } else { + fail("we got an exception: " + e); + } } + } catch (Exception e) { + fail("we got an exception" + e); } - catch (Exception e) { - fail("we got an exception" + e); - } - + return null; } - - private static Pair<Integer, String> dmaapPost (String topic, String data) { + + private static Pair<Integer, String> dmaapPost(String topic, String data) { String url = "http://localhost:" + DMAAPSIM_SERVER_PORT + "/events/" + topic; byte[] postData = data.getBytes(StandardCharsets.UTF_8); try { - URLConnection conn = new URL(url).openConnection(); - HttpURLConnection httpConn = null; + URLConnection conn = new URL(url).openConnection(); + HttpURLConnection httpConn = null; if (conn instanceof HttpURLConnection) { - httpConn = (HttpURLConnection) conn; - } - else { - fail("connection not set up right"); + httpConn = (HttpURLConnection) conn; + } else { + fail("connection not set up right"); } httpConn.setRequestMethod("POST"); httpConn.setDoOutput(true); - httpConn.setRequestProperty( "Content-Type", "text/plain"); - httpConn.setRequestProperty("Content-Length", ""+postData.length); + httpConn.setRequestProperty("Content-Type", "text/plain"); + httpConn.setRequestProperty("Content-Length", "" + postData.length); httpConn.connect(); String response = ""; try (DataOutputStream connWriter = new DataOutputStream(httpConn.getOutputStream())) { - connWriter.write(postData); - connWriter.flush(); + connWriter.write(postData); + connWriter.flush(); } try (BufferedReader connReader = new BufferedReader(new InputStreamReader(httpConn.getInputStream()))) { - String line; - while((line = connReader.readLine()) != null) { - response += line; - } - httpConn.disconnect(); - return new Pair<Integer, String>(httpConn.getResponseCode(), response); - } - catch (IOException e) { - if (e.getMessage().startsWith("Server returned HTTP response code")) { - System.out.println("hi"); - BufferedReader connReader = new BufferedReader(new InputStreamReader(httpConn.getErrorStream())); - String line; - while((line = connReader.readLine()) != null) { - response += line; - } - httpConn.disconnect(); - return new Pair<Integer, String>(httpConn.getResponseCode(), response); - } - else { - fail("we got an exception: " + e); - } + String line; + while ((line = connReader.readLine()) != null) { + response += line; + } + httpConn.disconnect(); + return new Pair<Integer, String>(httpConn.getResponseCode(), response); + } catch (IOException e) { + if (e.getMessage().startsWith("Server returned HTTP response code")) { + System.out.println("hi"); + BufferedReader connReader = new BufferedReader(new InputStreamReader(httpConn.getErrorStream())); + String line; + while ((line = connReader.readLine()) != null) { + response += line; + } + httpConn.disconnect(); + return new Pair<Integer, String>(httpConn.getResponseCode(), response); + } else { + fail("we got an exception: " + e); + } } - } - catch (Exception e) { - fail("we got an exception: " + e); + } catch (Exception e) { + fail("we got an exception: " + e); } return null; } - - private static Pair<Integer, String> setStatus (int status) { + + private static Pair<Integer, String> setStatus(int status) { String url = "http://localhost:" + DMAAPSIM_SERVER_PORT + "/events/setStatus?statusCode=" + status; try { - URLConnection conn = new URL(url).openConnection(); + URLConnection conn = new URL(url).openConnection(); HttpURLConnection httpConn = null; if (conn instanceof HttpURLConnection) { - httpConn = (HttpURLConnection) conn; - } - else { - fail("connection not set up right"); + httpConn = (HttpURLConnection) conn; + } else { + fail("connection not set up right"); } httpConn.setRequestMethod("POST"); httpConn.connect(); String response = ""; try (BufferedReader connReader = new BufferedReader(new InputStreamReader(httpConn.getInputStream()))) { - String line; - while((line = connReader.readLine()) != null) { - response += line; - } - httpConn.disconnect(); - return new Pair<Integer, String>(httpConn.getResponseCode(), response); - } - catch (IOException e) { - if (e.getMessage().startsWith("Server returned HTTP response code")) { - System.out.println("hi"); - BufferedReader connReader = new BufferedReader(new InputStreamReader(httpConn.getErrorStream())); - String line; - while((line = connReader.readLine()) != null) { - response += line; - } - httpConn.disconnect(); - return new Pair<Integer, String>(httpConn.getResponseCode(), response); - } - else { - fail("we got an exception: " + e); - } + String line; + while ((line = connReader.readLine()) != null) { + response += line; + } + httpConn.disconnect(); + return new Pair<Integer, String>(httpConn.getResponseCode(), response); + } catch (IOException e) { + if (e.getMessage().startsWith("Server returned HTTP response code")) { + System.out.println("hi"); + BufferedReader connReader = new BufferedReader(new InputStreamReader(httpConn.getErrorStream())); + String line; + while ((line = connReader.readLine()) != null) { + response += line; + } + httpConn.disconnect(); + return new Pair<Integer, String>(httpConn.getResponseCode(), response); + } else { + fail("we got an exception: " + e); + } } - } - catch (Exception e) { - fail("we got an exception" + e); + } catch (Exception e) { + fail("we got an exception" + e); } return null; } - + private static class Pair<A, B> { - public final A a; - public final B b; - - public Pair(A a, B b) { - this.a = a; - this.b = b; - } - } + public final A a; + public final B b; + + public Pair(A a, B b) { + this.a = a; + this.b = b; + } + } } |