From 2bfd20329d25cfa7b06639e759ab4cd9fbceb4b9 Mon Sep 17 00:00:00 2001 From: Dinh Danh Le Date: Sat, 28 Jul 2018 23:01:04 +0100 Subject: Add test case for plugin event carrier RESTServer Change-Id: Ia81a35e359c1f7072f4a39db871076d478dd7dab Signed-off-by: Dinh Danh Le Issue-ID: POLICY-954 --- .../test/adapt/restserver/TestRESTServer.java | 47 +++++++++++++++------- 1 file changed, 33 insertions(+), 14 deletions(-) (limited to 'testsuites/integration/integration-uservice-test/src/test') diff --git a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/restserver/TestRESTServer.java b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/restserver/TestRESTServer.java index 5ac714673..b0bcac439 100644 --- a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/restserver/TestRESTServer.java +++ b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/restserver/TestRESTServer.java @@ -59,10 +59,7 @@ public class TestRESTServer { final Client client = ClientBuilder.newClient(); - // Wait for the required amount of events to be received or for 10 seconds for (int i = 0; i < 20; i++) { - ThreadUtilities.sleep(100); - final Response response = client.target("http://localhost:23324/apex/FirstConsumer/EventIn") .request("application/json").put(Entity.json(getEvent())); @@ -85,10 +82,7 @@ public class TestRESTServer { final Client client = ClientBuilder.newClient(); - // Wait for the required amount of events to be received or for 10 seconds for (int i = 0; i < 20; i++) { - ThreadUtilities.sleep(100); - final Response response = client.target("http://localhost:23324/apex/FirstConsumer/EventIn") .request("application/json").post(Entity.json(getEvent())); @@ -104,6 +98,39 @@ public class TestRESTServer { apexMain.shutdown(); } + @Test + public void testRESTServerGetStatus() throws MessagingException, ApexException, IOException { + final String[] args = {"src/test/resources/prodcons/RESTServerJsonEvent.json"}; + final ApexMain apexMain = new ApexMain(args); + + final Client client = ClientBuilder.newClient(); + + // trigger 10 POST & PUT events + for (int i = 0; i < 10; i++) { + final Response postResponse = client.target("http://localhost:23324/apex/FirstConsumer/EventIn") + .request("application/json").post(Entity.json(getEvent())); + final Response putResponse = client.target("http://localhost:23324/apex/FirstConsumer/EventIn") + .request("application/json").put(Entity.json(getEvent())); + assertEquals(Response.Status.OK.getStatusCode(), postResponse.getStatus()); + assertEquals(Response.Status.OK.getStatusCode(), putResponse.getStatus()); + } + + final Response statResponse = + client.target("http://localhost:23324/apex/FirstConsumer/Status").request("application/json").get(); + + assertEquals(Response.Status.OK.getStatusCode(), statResponse.getStatus()); + final String responseString = statResponse.readEntity(String.class); + + @SuppressWarnings("unchecked") + final Map jsonMap = new Gson().fromJson(responseString, Map.class); + assertEquals("[FirstConsumer]", jsonMap.get("INPUTS")); + assertEquals(1.0, jsonMap.get("STAT")); + assertEquals(10.0, jsonMap.get("POST")); + assertEquals(10.0, jsonMap.get("PUT")); + + apexMain.shutdown(); + } + @Test public void testRESTServerMultiInputs() throws MessagingException, ApexException, IOException { final String[] args = {"src/test/resources/prodcons/RESTServerJsonEventMultiIn.json"}; @@ -111,10 +138,7 @@ public class TestRESTServer { final Client client = ClientBuilder.newClient(); - // Wait for the required amount of events to be received or for 10 seconds for (int i = 0; i < 20; i++) { - ThreadUtilities.sleep(100); - final Response firstResponse = client.target("http://localhost:23324/apex/FirstConsumer/EventIn") .request("application/json").post(Entity.json(getEvent())); @@ -286,10 +310,7 @@ public class TestRESTServer { final Client client = ClientBuilder.newClient(); - // Wait for the required amount of events to be received or for 10 seconds for (int i = 0; i < 20; i++) { - ThreadUtilities.sleep(100); - final Response response = client.target("http://localhost:23324/apex/FirstConsumer/EventIn") .request("application/json").put(Entity.json(getEvent())); @@ -301,10 +322,8 @@ public class TestRESTServer { assertEquals("org.onap.policy.apex.sample.events", jsonMap.get("nameSpace")); assertEquals("Test slogan for External Event0", jsonMap.get("TestSlogan")); assertTrue(((String) jsonMap.get("exceptionMessage")).contains("caused by: / by zero")); - } - apexMain.shutdown(); } -- cgit 1.2.3-korg