summaryrefslogtreecommitdiffstats
path: root/policy-management/src/test/java/org
diff options
context:
space:
mode:
authorjhh <jorge.hernandez-herrero@att.com>2021-09-20 13:22:08 -0500
committerjhh <jorge.hernandez-herrero@att.com>2021-09-20 13:22:08 -0500
commit91774239eba5db5dfbb57c8491e0e4bfe06eb383 (patch)
treeded9713cffc058c59ddebcad88ddd180eaedfcfe /policy-management/src/test/java/org
parentc4d3f1e4a1cd5ddb5c145f0e7989feb5abc212ca (diff)
Additional tests for Telemetry
Increasing coverage for drools to >= 80%. Issue-ID: POLICY-3453 Signed-off-by: jhh <jorge.hernandez-herrero@att.com> Change-Id: I9d8550a80b87b8c6f68da06246d392260eba1e65
Diffstat (limited to 'policy-management/src/test/java/org')
-rw-r--r--policy-management/src/test/java/org/onap/policy/drools/server/restful/test/RestManagerTest.java271
1 files changed, 104 insertions, 167 deletions
diff --git a/policy-management/src/test/java/org/onap/policy/drools/server/restful/test/RestManagerTest.java b/policy-management/src/test/java/org/onap/policy/drools/server/restful/test/RestManagerTest.java
index 40af2845..feeb25ed 100644
--- a/policy-management/src/test/java/org/onap/policy/drools/server/restful/test/RestManagerTest.java
+++ b/policy-management/src/test/java/org/onap/policy/drools/server/restful/test/RestManagerTest.java
@@ -2,7 +2,7 @@
* ============LICENSE_START=======================================================
* policy-management
* ================================================================================
- * Copyright (C) 2017-2020 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017-2021 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -34,7 +34,10 @@ import org.apache.http.client.CredentialsProvider;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpDelete;
import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpPut;
+import org.apache.http.client.methods.HttpRequestBase;
+import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.BasicCredentialsProvider;
import org.apache.http.impl.client.CloseableHttpClient;
@@ -95,6 +98,8 @@ public class RestManagerTest {
private static final String FOO_CONTROLLER_FILE = FOO_CONTROLLER + "-controller.properties";
private static final String FOO_CONTROLLER_FILE_BAK = FOO_CONTROLLER_FILE + ".bak";
+ private static final String PDP_CONFIGURATION_JSON =
+ "src/test/resources/org/onap/policy/drools/server/restful/PdpConfiguration.json";
private static CloseableHttpClient client;
@@ -174,7 +179,6 @@ public class RestManagerTest {
* Tear down.
*
* @throws IOException IO exception
- * @throws InterruptedException Interrupted exception
*/
@AfterClass
public static void tearDown() throws IOException {
@@ -194,161 +198,24 @@ public class RestManagerTest {
@Test
public void testPutDelete() throws IOException {
- HttpDelete httpDelete;
- CloseableHttpResponse response;
+ putTest(HOST_URL + "/engine/switches/lock", 406);
+ deleteTest(HOST_URL + "/engine/switches/lock", 406);
- /*
- * DELETE: /engine/controllers/controllerName/drools/facts/session/factType
- *
- */
- httpDelete =
- new HttpDelete(HOST_URL + "/engine/controllers/" + FOO_CONTROLLER + "/drools/facts/session/factType");
- response = client.execute(httpDelete);
- logger.info(httpDelete.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(200, response.getStatusLine().getStatusCode());
- httpDelete.releaseConnection();
+ putDeleteEngineControllers();
- httpDelete = new HttpDelete(HOST_URL + "/engine/controllers/controllerName/drools/facts/session/factType");
- response = client.execute(httpDelete);
- logger.info(httpDelete.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(404, response.getStatusLine().getStatusCode());
- httpDelete.releaseConnection();
+ putTest(HOST_URL + "/engine/switches/lock", 200);
+ deleteTest(HOST_URL + "/engine/switches/lock", 200);
- /*
- * PUT: /engine/switches/lock /engine/controllers/controllername/switches/lock DELETE:
- * /engine/switches/lock /engine/controllers/controllername
- */
- HttpPut httpPut = new HttpPut(HOST_URL + "/engine/switches/lock");
- response = client.execute(httpPut);
- logger.info(httpPut.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(406, response.getStatusLine().getStatusCode());
- httpPut.releaseConnection();
-
- httpDelete = new HttpDelete(HOST_URL + "/engine/switches/lock");
- response = client.execute(httpDelete);
- logger.info(httpDelete.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(406, response.getStatusLine().getStatusCode());
- httpDelete.releaseConnection();
-
- httpDelete = new HttpDelete(HOST_URL + "/engine/controllers/");
- response = client.execute(httpDelete);
- logger.info(httpDelete.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(405, response.getStatusLine().getStatusCode());
- httpDelete.releaseConnection();
-
- httpDelete = new HttpDelete(HOST_URL + "/engine/controllers/" + null);
- response = client.execute(httpDelete);
- logger.info(httpDelete.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(400, response.getStatusLine().getStatusCode());
- httpDelete.releaseConnection();
-
- httpPut = new HttpPut(HOST_URL + "/engine/controllers/" + FOO_CONTROLLER + "/switches/lock");
- response = client.execute(httpPut);
- logger.info(httpPut.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(406, response.getStatusLine().getStatusCode());
- httpPut.releaseConnection();
-
- httpDelete = new HttpDelete(HOST_URL + "/engine/controllers/" + FOO_CONTROLLER);
- response = client.execute(httpDelete);
- logger.info(httpDelete.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(200, response.getStatusLine().getStatusCode());
- httpDelete.releaseConnection();
-
- httpPut = new HttpPut(HOST_URL + "/engine/switches/lock");
- response = client.execute(httpPut);
- logger.info(httpPut.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(200, response.getStatusLine().getStatusCode());
- httpPut.releaseConnection();
-
- httpDelete = new HttpDelete(HOST_URL + "/engine/switches/lock");
- response = client.execute(httpDelete);
- logger.info(httpDelete.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(200, response.getStatusLine().getStatusCode());
- httpDelete.releaseConnection();
+ putDeleteTopicsSources();
+ putDeleteTopicSwitches();
- /*
- * PUT: /engine/topics/sources/ueb/topic/events
- * /engine/topics/sources/dmaap/topic/events
- * /engine/topics/switches/lock
- *
- * DELETE: /engine/topics/switches/lock
- */
- httpPut = new HttpPut(HOST_URL + "/engine/topics/sources/ueb/" + UEB_TOPIC + "/events");
- httpPut.addHeader("Content-Type", "text/plain");
- httpPut.addHeader("Accept", "application/json");
- httpPut.setEntity(new StringEntity("{x:y}"));
- response = client.execute(httpPut);
- logger.info(httpPut.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(200, response.getStatusLine().getStatusCode());
- httpPut.releaseConnection();
-
- httpPut = new HttpPut(HOST_URL + "/engine/topics/sources/noop/" + NOOP_TOPIC + "/events");
- httpPut.addHeader("Content-Type", "text/plain");
- httpPut.addHeader("Accept", "application/json");
- httpPut.setEntity(new StringEntity("{x:y}"));
- response = client.execute(httpPut);
- logger.info(httpPut.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(200, response.getStatusLine().getStatusCode());
- httpPut.releaseConnection();
-
- httpPut = new HttpPut(HOST_URL + "/engine/topics/sources/dmaap/" + DMAAP_TOPIC + "/events");
- httpPut.addHeader("Content-Type", "text/plain");
- httpPut.addHeader("Accept", "application/json");
- httpPut.setEntity(new StringEntity("FOOOO"));
- response = client.execute(httpPut);
- logger.info(httpPut.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(200, response.getStatusLine().getStatusCode());
- httpPut.releaseConnection();
-
- httpPut = new HttpPut(HOST_URL + "/engine/topics/sources/ueb/fiznits/events");
- httpPut.addHeader("Content-Type", "text/plain");
- httpPut.addHeader("Accept", "application/json");
- httpPut.setEntity(new StringEntity("FOOOO"));
- response = client.execute(httpPut);
- logger.info(httpPut.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(406, response.getStatusLine().getStatusCode());
- httpPut.releaseConnection();
-
- httpPut = new HttpPut(HOST_URL + "/engine/topics/sources/dmaap/fiznits/events");
- httpPut.addHeader("Content-Type", "text/plain");
- httpPut.addHeader("Accept", "application/json");
- httpPut.setEntity(new StringEntity("FOOOO"));
- response = client.execute(httpPut);
- logger.info(httpPut.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
-
- assertEquals(406, response.getStatusLine().getStatusCode());
- httpPut.releaseConnection();
-
- httpPut = new HttpPut(HOST_URL + "/engine/topics/switches/lock");
- response = client.execute(httpPut);
- logger.info(httpPut.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(200, response.getStatusLine().getStatusCode());
- httpPut.releaseConnection();
-
- httpPut = new HttpPut(HOST_URL + "/engine/topics/sources/ueb/" + UEB_TOPIC + "/events");
- httpPut.addHeader("Content-Type", "text/plain");
- httpPut.addHeader("Accept", "application/json");
- httpPut.setEntity(new StringEntity("FOOOO"));
- response = client.execute(httpPut);
- logger.info(httpPut.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(406, response.getStatusLine().getStatusCode());
- httpPut.releaseConnection();
-
- httpPut = new HttpPut(HOST_URL + "/engine/topics/sources/dmaap/" + DMAAP_TOPIC + "/events");
- httpPut.addHeader("Content-Type", "text/plain");
- httpPut.addHeader("Accept", "application/json");
- httpPut.setEntity(new StringEntity("FOOOO"));
- response = client.execute(httpPut);
- logger.info(httpPut.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(406, response.getStatusLine().getStatusCode());
- httpPut.releaseConnection();
-
- httpDelete = new HttpDelete(HOST_URL + "/engine/topics/switches/lock");
- response = client.execute(httpDelete);
- logger.info(httpDelete.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(200, response.getStatusLine().getStatusCode());
- httpDelete.releaseConnection();
+ putTest(HOST_URL + "/engine/tools/loggers/ROOT/debug", 200);
+ putTest(HOST_URL + "/engine/environment/XX", 200, "WARN", ContentType.DEFAULT_TEXT);
+ deleteTest(HOST_URL + "/engine/switches/activation", 200);
+ putTest(HOST_URL + "/engine/switches/activation", 200);
+ }
+ private void putDeleteTopicSwitches() throws IOException {
putDeleteSwitch("/engine/topics/sources/ueb/", UEB_TOPIC, "lock");
putDeleteSwitch("/engine/topics/sources/dmaap/", DMAAP_TOPIC, "lock");
putDeleteSwitch("/engine/topics/sources/noop/", NOOP_TOPIC, "lock");
@@ -369,13 +236,64 @@ public class RestManagerTest {
putSwitch("/engine/topics/sinks/ueb/", UEB_TOPIC, "activation");
putSwitch("/engine/topics/sinks/dmaap/", DMAAP_TOPIC, "activation");
putSwitch("/engine/topics/sinks/noop/", NOOP_TOPIC, "activation");
+ }
- httpPut = new HttpPut(HOST_URL + "/engine/tools/loggers/ROOT/debug");
- response = client.execute(httpPut);
- logger.info(httpPut.getRequestLine() + "response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(200, response.getStatusLine().getStatusCode());
- httpPut.releaseConnection();
+ private void putDeleteTopicsSources() throws IOException {
+ putTest(HOST_URL + "/engine/topics/sources/ueb/" + UEB_TOPIC + "/events", 200,
+ "{x:y}", ContentType.TEXT_PLAIN);
+ putTest(HOST_URL + "/engine/topics/sources/noop/" + NOOP_TOPIC + "/events", 200,
+ "{x:y}", ContentType.TEXT_PLAIN);
+ putTest(HOST_URL + "/engine/topics/sources/dmaap/" + DMAAP_TOPIC + "/events", 200,
+ "FOOOO", ContentType.TEXT_PLAIN);
+ putTest(HOST_URL + "/engine/topics/sources/ueb/fiznits/events", 406, "FOOOO", ContentType.TEXT_PLAIN);
+ putTest(HOST_URL + "/engine/topics/sources/dmaap/fiznits/events", 406,
+ "FOOOO", ContentType.TEXT_PLAIN);
+ putTest(HOST_URL + "/engine/topics/switches/lock", 200);
+ putTest(HOST_URL + "/engine/topics/sources/ueb/" + UEB_TOPIC + "/events",
+ 406, "FOOOO", ContentType.TEXT_PLAIN);
+ putTest(HOST_URL + "/engine/topics/sources/dmaap/" + DMAAP_TOPIC + "/events",
+ 406, "FOOOO", ContentType.TEXT_PLAIN);
+ deleteTest(HOST_URL + "/engine/topics/switches/lock", 200);
+ }
+
+ private void putDeleteEngineControllers() throws IOException {
+ deleteTest(HOST_URL + "/engine/controllers/" + FOO_CONTROLLER + "/drools/facts/session/factType", 200);
+ deleteTest(HOST_URL + "/engine/controllers/controllerName/drools/facts/session/factType", 404);
+ deleteTest(HOST_URL + "/engine/controllers/", 405);
+ deleteTest(HOST_URL + "/engine/controllers/" + null, 400);
+ putTest(HOST_URL + "/engine/controllers/" + FOO_CONTROLLER + "/switches/lock", 406);
+ deleteTest(HOST_URL + "/engine/controllers/" + FOO_CONTROLLER, 200);
+ }
+
+ private void postTest(String uri, int statusCode, String payload, ContentType contentType) throws IOException {
+ HttpPost post = new HttpPost(uri);
+ if (contentType != null) {
+ post.setEntity(new StringEntity(payload, contentType));
+ }
+ requestTest(post, statusCode);
+ }
+
+ private void putTest(String uri, int statusCode) throws IOException {
+ requestTest(new HttpPut(uri), statusCode);
+ }
+
+ private void putTest(String uri, int statusCode, String payload, ContentType contentType) throws IOException {
+ HttpPut put = new HttpPut(uri);
+ if (contentType != null) {
+ put.setEntity(new StringEntity(payload, contentType));
+ }
+ requestTest(put, statusCode);
+ }
+
+ private void deleteTest(String uri, int statusCode) throws IOException {
+ requestTest(new HttpDelete(uri), statusCode);
+ }
+ private void requestTest(HttpRequestBase request, int statusCode) throws IOException {
+ CloseableHttpResponse resp = client.execute(request);
+ logger.info(request.getRequestLine() + "response code: {}", resp.getStatusLine().getStatusCode());
+ assertEquals(statusCode, resp.getStatusLine().getStatusCode());
+ request.releaseConnection();
}
private void putDeleteSwitch(String urlPrefix, String topic, String control) throws IOException {
@@ -384,19 +302,38 @@ public class RestManagerTest {
}
private void deleteSwitch(String urlPrefix, String topic, String control) throws IOException {
- HttpDelete httpDelete = new HttpDelete(HOST_URL + urlPrefix + topic + "/switches/" + control);
- CloseableHttpResponse response = client.execute(httpDelete);
- logger.info(httpDelete.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(200, response.getStatusLine().getStatusCode());
- httpDelete.releaseConnection();
+ deleteTest(HOST_URL + urlPrefix + topic + "/switches/" + control, 200);
}
private void putSwitch(String urlPrefix, String topic, String control) throws IOException {
- HttpPut httpPut = new HttpPut(HOST_URL + urlPrefix + topic + "/switches/" + control);
- CloseableHttpResponse response = client.execute(httpPut);
- logger.info(httpPut.getRequestLine() + " response code: {}", response.getStatusLine().getStatusCode());
- assertEquals(200, response.getStatusLine().getStatusCode());
- httpPut.releaseConnection();
+ putTest(HOST_URL + urlPrefix + topic + "/switches/" + control, 200);
+ }
+
+ @Test
+ public void testPost() throws IOException {
+ postTest(HOST_URL + "/engine/inputs/configuration", 406,
+ Files.readString(Paths.get(PDP_CONFIGURATION_JSON)),
+ ContentType.APPLICATION_JSON);
+
+ postTest(HOST_URL + "/engine/controllers", 400,
+ "{}",
+ ContentType.APPLICATION_JSON);
+
+ postTest(HOST_URL + "/engine/controllers", 304,
+ "{controller.name : foo}",
+ ContentType.APPLICATION_JSON);
+
+ postTest(HOST_URL + "/engine/controllers", 206,
+ "{controller.name : new}",
+ ContentType.APPLICATION_JSON);
+
+ deleteTest(HOST_URL + "/engine/controllers/new", 200);
+
+ postTest(HOST_URL + "/engine/controllers/foo/drools/facts/session1/query1/entity1", 200,
+ "[{f:v}]", ContentType.APPLICATION_JSON);
+
+ postTest(HOST_URL + "/engine/controllers/new/drools/facts/session1/query1/entity1", 404,
+ "[{f:v}]", ContentType.APPLICATION_JSON);
}
@Test