From 25e3f7a0d6cd5e364e4fd69eef310fcdb8a58b55 Mon Sep 17 00:00:00 2001 From: liamfallon Date: Fri, 4 Sep 2020 11:03:24 +0100 Subject: Remove client code from apex-pdp Removal of the deployment and monitoring client from the apex-pdp as the functionality is replaced by the Policy Framework deployment using PAP and the Policy Framework monitoring GUI. Code in the engine proper that was used to administer apex-pdp over the Web Socket port is also removed, as this code was only used by the apex-pdp legacy GUIs. Issue-ID: POLICY-2621 Change-Id: Ib9fc4a667a4bc79377bb7b82fae6a2bd520a3e3d Signed-off-by: liamfallon --- .../monitoring/rest/MonitoringExceptionTest.java | 40 ---- .../monitoring/rest/MonitoringRestExtraTest.java | 39 --- .../monitoring/rest/MonitoringRestMainTest.java | 196 --------------- .../client/monitoring/rest/ParameterCheckTest.java | 191 --------------- .../client/monitoring/rest/RestResourceTest.java | 263 --------------------- 5 files changed, 729 deletions(-) delete mode 100644 client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/MonitoringExceptionTest.java delete mode 100644 client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/MonitoringRestExtraTest.java delete mode 100644 client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/MonitoringRestMainTest.java delete mode 100644 client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/ParameterCheckTest.java delete mode 100644 client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/RestResourceTest.java (limited to 'client/client-monitoring/src/test/java/org') diff --git a/client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/MonitoringExceptionTest.java b/client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/MonitoringExceptionTest.java deleted file mode 100644 index 3b5ecd100..000000000 --- a/client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/MonitoringExceptionTest.java +++ /dev/null @@ -1,40 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2018 Ericsson. 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. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.apex.client.monitoring.rest; - -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertNotNull; - -import org.junit.Test; - -/** - * Test the REST monitoring exception. - * - */ -public class MonitoringExceptionTest { - - @Test - public void test() { - ApexMonitoringRestParameterException ame = new ApexMonitoringRestParameterException("a message"); - assertNotNull(ame); - assertEquals("a message", ame.getMessage()); - } -} diff --git a/client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/MonitoringRestExtraTest.java b/client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/MonitoringRestExtraTest.java deleted file mode 100644 index 277b2ed17..000000000 --- a/client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/MonitoringRestExtraTest.java +++ /dev/null @@ -1,39 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2018 Ericsson. 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. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.apex.client.monitoring.rest; - -import static org.junit.Assert.assertEquals; - -import org.junit.Test; - -/** - * Extra monitoring rest tests. - * - */ -public class MonitoringRestExtraTest { - - @Test - public void test() { - ApexMonitoringRestParameters parameters = new ApexMonitoringRestParameters(); - parameters.setRestPort(12345); - assertEquals(12345, parameters.getRestPort()); - } -} diff --git a/client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/MonitoringRestMainTest.java b/client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/MonitoringRestMainTest.java deleted file mode 100644 index b376c9bfa..000000000 --- a/client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/MonitoringRestMainTest.java +++ /dev/null @@ -1,196 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2018 Ericsson. All rights reserved. - * Modifications Copyright (C) 2020 Nordix Foundation. - * ================================================================================ - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.apex.client.monitoring.rest; - -import static org.assertj.core.api.Assertions.assertThatCode; -import static org.assertj.core.api.Assertions.assertThatThrownBy; -import static org.awaitility.Awaitility.await; -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertNotNull; - -import java.io.ByteArrayInputStream; -import java.io.ByteArrayOutputStream; -import java.io.InputStream; -import java.io.PrintStream; -import java.util.concurrent.TimeUnit; -import org.junit.Test; - -/** - * Test the periodic event manager utility. - */ -public class MonitoringRestMainTest { - @Test - public void testMonitoringClientBad() { - final String[] eventArgs = {"-z"}; - assertThatCode(() -> ApexMonitoringRestMain.main(eventArgs)).doesNotThrowAnyException(); - } - - @Test - public void testMonitoringClientOk() { - final String[] eventArgs = {"-t", "1"}; - assertThatCode(() -> ApexMonitoringRestMain.main(eventArgs)).doesNotThrowAnyException(); - } - - @Test - public void testMonitoringClientNoOptions() { - final String[] eventArgs = new String[] {}; - - final String outputString = testApexMonitoringRestMainConstructor(eventArgs); - - System.err.println(outputString); - assertEquals("*** StdOut ***\n\n*** StdErr ***\n", outputString); - } - - @Test - public void testMonitoringClientBadOptions() { - final String[] eventArgs = {"-zabbu"}; - - assertThatThrownBy(() -> new ApexMonitoringRestMain(eventArgs, System.out)) - .hasMessageContaining("Apex Services REST endpoint (ApexMonitoringRestMain: Config=[null], State=STOPPED) " - + "parameter error, invalid command line arguments specified " + ": Unrecognized option: -zabbu"); - } - - @Test - public void testMonitoringClientHelp() { - final String[] eventArgs = {"-h"}; - - assertThatThrownBy(() -> new ApexMonitoringRestMain(eventArgs, System.out)) - .hasMessageContaining("usage: org.onap.policy.apex.client.monitoring.rest." - + "ApexMonitoringRestMain [options...]"); - } - - @Test - public void testMonitoringClientPortBad() { - final String[] eventArgs = {"-p", "hello"}; - - assertThatThrownBy(() -> new ApexMonitoringRestMain(eventArgs, System.out)) - .hasMessageContaining("Apex Services REST endpoint (ApexMonitoringRestMain: Config=[null], State=STOPPED) " - + "parameter error, error parsing argument \"port\" :For input string: \"hello\""); - } - - @Test - public void testMonitoringClientPortNegative() { - final String[] eventArgs = {"-p", "-1"}; - - assertThatThrownBy(() -> new ApexMonitoringRestMain(eventArgs, System.out)) - .hasMessageContaining("Apex Services REST endpoint (ApexMonitoringRestMain: Config=[ApexMonitoringRest" - + "Parameters: URI=http://localhost:-1/apexservices/, TTL=-1sec], State=STOPPED) parameters invalid, " - + "port must be greater than 1023 and less than 65536"); - } - - @Test - public void testMonitoringClientTtlTooSmall() { - final String[] eventArgs = {"-t", "-2"}; - - assertThatThrownBy(() -> new ApexMonitoringRestMain(eventArgs, System.out)) - .hasMessageContaining("Apex Services REST endpoint (ApexMonitoringRestMain: Config=[ApexMonitoringRest" - + "Parameters: URI=http://localhost:18989/apexservices/, TTL=-2sec], State=STOPPED) parameters invalid, " - + "time to live must be greater than -1 (set to -1 to wait forever)"); - } - - @Test - public void testMonitoringClientTooManyPars() { - final String[] eventArgs = {"-t", "10", "-p", "12344", "aaa", "bbb"}; - - assertThatThrownBy(() -> new ApexMonitoringRestMain(eventArgs, System.out)) - .hasMessageContaining("Apex Services REST endpoint (ApexMonitoringRestMain: Config=[null], State=STOPPED) " - + "parameter error, too many command line arguments specified : [aaa, bbb]"); - } - - @Test - public void testMonitoringClientTtlNotNumber() { - final String[] eventArgs = {"-t", "timetolive"}; - - assertThatThrownBy(() -> new ApexMonitoringRestMain(eventArgs, System.out)) - .hasMessageContaining("Apex Services REST endpoint (ApexMonitoringRestMain: Config=[null], State=STOPPED) " - + "parameter error, error parsing argument \"time-to-live\" :" + "For input string: \"" - + "timetolive\""); - } - - @Test - public void testMonitoringClientPortTooBig() { - final String[] eventArgs = {"-p", "65536"}; - - assertThatThrownBy(() -> new ApexMonitoringRestMain(eventArgs, System.out)) - .hasMessageContaining("Apex Services REST endpoint (ApexMonitoringRestMain: Config=[ApexMonitoring" - + "RestParameters: URI=http://localhost:65536/apexservices/, TTL=-1sec], State=STOPPED) parameters invalid, " - + "port must be greater than 1023 and less than 65536"); - } - - @Test - public void testMonitoringClientDefaultPars() { - ApexMonitoringRest monRest = new ApexMonitoringRest(); - assertNotNull(monRest); - assertThatCode(() -> monRest.shutdown()).isNull(); - } - - @Test - public void testMonitoringOneSecStart() { - final String[] eventArgs = {"-t", "1"}; - - ApexMonitoringRestMain monRestMain = new ApexMonitoringRestMain(eventArgs, System.out); - assertNotNull(monRestMain); - monRestMain.init(); - assertThatCode(() -> monRestMain.shutdown()).isNull(); - } - - @Test - public void testMonitoringForeverStart() { - final String[] eventArgs = {"-t", "-1"}; - - ApexMonitoringRestMain monRestMain = new ApexMonitoringRestMain(eventArgs, System.out); - - Thread monThread = new Thread() { - @Override - public void run() { - monRestMain.init(); - } - }; - assertThatCode(() -> { - monThread.start(); - await().atMost(6, TimeUnit.SECONDS) - .until(() -> monRestMain.getState().equals(ApexMonitoringRestMain.ServicesState.RUNNING)); - monRestMain.shutdown(); - }).doesNotThrowAnyException(); - } - - /** - * Run the application. - * - * @param eventArgs the command arguments - * @return a string containing the command output - */ - private String testApexMonitoringRestMainConstructor(final String[] eventArgs) { - final ByteArrayOutputStream baosOut = new ByteArrayOutputStream(); - final ByteArrayOutputStream baosErr = new ByteArrayOutputStream(); - - new ApexMonitoringRestMain(eventArgs, new PrintStream(baosOut, true)); - - InputStream testInput = new ByteArrayInputStream("Test Data for Input to WS".getBytes()); - System.setIn(testInput); - - String outString = baosOut.toString(); - String errString = baosErr.toString(); - - return "*** StdOut ***\n" + outString + "\n*** StdErr ***\n" + errString; - } -} diff --git a/client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/ParameterCheckTest.java b/client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/ParameterCheckTest.java deleted file mode 100644 index bea15eb87..000000000 --- a/client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/ParameterCheckTest.java +++ /dev/null @@ -1,191 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2018 Ericsson. 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. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.apex.client.monitoring.rest; - -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertNull; - -import java.util.LinkedHashMap; -import java.util.Map; -import org.junit.Test; -import org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey; - -/** - * Test the parameter check class. - * - */ -public class ParameterCheckTest { - - @Test - public void testStartStop() { - assertEquals("START", ParameterCheck.StartStop.START.name()); - assertEquals("STOP", ParameterCheck.StartStop.STOP.name()); - } - - @Test - public void testHostName() { - assertNull(ParameterCheck.getHostName(null)); - - Map parameterMap = new LinkedHashMap<>(); - assertNull(ParameterCheck.getHostName(parameterMap)); - parameterMap.put("hostname", null); - assertNull(ParameterCheck.getHostName(parameterMap)); - - String[] hostnameBlankValue0 = {"", ""}; - parameterMap.put("hostname", hostnameBlankValue0); - assertNull(ParameterCheck.getHostName(parameterMap)); - - String[] hostnameBlankValue1 = {" ", " "}; - parameterMap.put("hostname", hostnameBlankValue1); - assertNull(ParameterCheck.getHostName(parameterMap)); - - String[] hostnameValue = {"hostname0", "hostname1"}; - parameterMap.put("hostname", hostnameValue); - assertEquals("hostname0", ParameterCheck.getHostName(parameterMap)); - } - - @Test - public void testPort() { - assertEquals(-1, ParameterCheck.getPort(null)); - - Map parameterMap = new LinkedHashMap<>(); - assertEquals(-1, ParameterCheck.getPort(parameterMap)); - parameterMap.put("port", null); - assertEquals(-1, ParameterCheck.getPort(parameterMap)); - - String[] portBlankValue0 = {"", ""}; - parameterMap.put("port", portBlankValue0); - assertEquals(-1, ParameterCheck.getPort(parameterMap)); - - String[] portBlankValue1 = {" ", " "}; - parameterMap.put("port", portBlankValue1); - assertEquals(-1, ParameterCheck.getPort(parameterMap)); - - String[] portValueBad = {"port", "value"}; - parameterMap.put("port", portValueBad); - assertEquals(-1, ParameterCheck.getPort(parameterMap)); - - String[] portValueRange0 = {"-1", "-1"}; - parameterMap.put("port", portValueRange0); - assertEquals(-1, ParameterCheck.getPort(parameterMap)); - - String[] portValueRange1 = {"65536", "65536"}; - parameterMap.put("port", portValueRange1); - assertEquals(-1, ParameterCheck.getPort(parameterMap)); - - String[] portValue = {"12344", "23221"}; - parameterMap.put("port", portValue); - assertEquals(12344, ParameterCheck.getPort(parameterMap)); - } - - @Test - public void testEngineKey() { - assertEquals(null, ParameterCheck.getEngineKey(null)); - - Map parameterMap = new LinkedHashMap<>(); - parameterMap.put("Zooby", null); - assertEquals(null, ParameterCheck.getEngineKey(parameterMap)); - - parameterMap.put("AxArtifactKey", null); - assertEquals(null, ParameterCheck.getEngineKey(parameterMap)); - parameterMap.remove("AxArtifactKey"); - - parameterMap.put("AxArtifactKey#zooby", null); - assertEquals(null, ParameterCheck.getEngineKey(parameterMap)); - parameterMap.remove("AxArtifactKey#zooby"); - - parameterMap.put("AxArtifactKey#zooby#looby", null); - assertEquals(null, ParameterCheck.getEngineKey(parameterMap)); - parameterMap.remove("AxArtifactKey#zooby#looby"); - - parameterMap.put("AxArtifactKey#Name:0.0.1", null); - assertEquals(new AxArtifactKey("Name", "0.0.1"), ParameterCheck.getEngineKey(parameterMap)); - } - - @Test - public void testStartStopValue() { - assertEquals(null, ParameterCheck.getStartStop(null, null)); - - Map parameterMap = new LinkedHashMap<>(); - assertEquals(null, ParameterCheck.getStartStop(parameterMap, null)); - - parameterMap.put("Zooby", null); - assertEquals(null, ParameterCheck.getStartStop(parameterMap, null)); - - AxArtifactKey engineKey = new AxArtifactKey("Engine", "0.0.1"); - - parameterMap.put("Zooby", null); - assertEquals(null, ParameterCheck.getStartStop(parameterMap, engineKey)); - - String key = "AxArtifactKey#" + engineKey.getId(); - - parameterMap.put(key, null); - assertEquals(null, ParameterCheck.getStartStop(parameterMap, engineKey)); - - String[] startStopBlankValue0 = {"", ""}; - parameterMap.put(key, startStopBlankValue0); - assertEquals(null, ParameterCheck.getStartStop(parameterMap, engineKey)); - - String[] startStopBlankValue1 = {" ", " "}; - parameterMap.put(key, startStopBlankValue1); - assertEquals(null, ParameterCheck.getStartStop(parameterMap, engineKey)); - - String[] startStopValueBad = {key, "value"}; - parameterMap.put(key, startStopValueBad); - assertEquals(null, ParameterCheck.getStartStop(parameterMap, engineKey)); - - String[] startValue = {"START", "STOP"}; - parameterMap.put(key, startValue); - assertEquals(ParameterCheck.StartStop.START, ParameterCheck.getStartStop(parameterMap, engineKey)); - - String[] stopValue = {"STOP", "START"}; - parameterMap.put(key, stopValue); - assertEquals(ParameterCheck.StartStop.STOP, ParameterCheck.getStartStop(parameterMap, engineKey)); - } - - @Test - public void testLong() { - assertEquals(-1, ParameterCheck.getLong(null, null)); - - Map parameterMap = new LinkedHashMap<>(); - assertEquals(-1, ParameterCheck.getLong(parameterMap, null)); - - parameterMap.put("long0", null); - assertEquals(-1, ParameterCheck.getLong(parameterMap, "longx")); - assertEquals(-1, ParameterCheck.getLong(parameterMap, "long0")); - - String[] longBlankValue0 = {"", ""}; - parameterMap.put("long1", longBlankValue0); - assertEquals(-1, ParameterCheck.getLong(parameterMap, "long1")); - - String[] longBlankValue1 = {" ", " "}; - parameterMap.put("long2", longBlankValue1); - assertEquals(-1, ParameterCheck.getLong(parameterMap, "long2")); - - String[] longValueBad = {"long", "value"}; - parameterMap.put("long3", longValueBad); - assertEquals(-1, ParameterCheck.getLong(parameterMap, "long3")); - - String[] longValue = {"12345", "6789"}; - parameterMap.put("long4", longValue); - assertEquals(12345, ParameterCheck.getLong(parameterMap, "long4")); - } -} diff --git a/client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/RestResourceTest.java b/client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/RestResourceTest.java deleted file mode 100644 index e8e7e9251..000000000 --- a/client/client-monitoring/src/test/java/org/onap/policy/apex/client/monitoring/rest/RestResourceTest.java +++ /dev/null @@ -1,263 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2018 Ericsson. All rights reserved. - * Modifications Copyright (C) 2020 Nordix Foundation. - * ================================================================================ - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.apex.client.monitoring.rest; - -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertNotEquals; -import static org.junit.Assert.assertNotNull; -import static org.junit.Assert.assertTrue; - -import javax.ws.rs.core.Response; -import org.junit.Before; -import org.junit.Test; -import org.mockito.Mock; -import org.mockito.Mockito; -import org.mockito.MockitoAnnotations; -import org.onap.policy.apex.core.deployment.ApexDeploymentException; -import org.onap.policy.apex.core.deployment.EngineServiceFacade; -import org.onap.policy.apex.model.basicmodel.concepts.ApexException; -import org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey; -import org.onap.policy.apex.model.enginemodel.concepts.AxEngineModel; - -/** - * Test the monitoring rest resource. - */ -public class RestResourceTest { - @Mock - private EngineServiceFacade engineServiceFacadeMock; - private ApexMonitoringRestResource restResource; - - /** - * Set up mocking of the engine service facade. - * - * @throws ApexException on engine service facade setup errors - */ - @Before - public void initializeMocking() throws ApexException { - MockitoAnnotations.initMocks(this); - - final AxArtifactKey engineServiceKey = new AxArtifactKey("EngineServiceKey", "0.0.1"); - final AxArtifactKey engineKey = new AxArtifactKey("Engine0", "0.0.1"); - final AxArtifactKey[] engineServiceKeyArray = - { engineKey }; - final AxEngineModel engineModel = new AxEngineModel(engineServiceKeyArray[0]); - - restResource = Mockito.spy(new ApexMonitoringRestResource()); - Mockito.doReturn(engineServiceFacadeMock).when(restResource).getEngineServiceFacade("apexServer", 12345); - - Mockito.doReturn(engineServiceKey).when(engineServiceFacadeMock).getKey(); - Mockito.doReturn(engineServiceKeyArray).when(engineServiceFacadeMock).getEngineKeyArray(); - Mockito.doReturn(engineModel).when(engineServiceFacadeMock).getEngineStatus(engineKey); - } - - @Test - public void testRestResourceCreateSession() throws ApexException { - Response response = restResource.createSession("apexServer", 12345); - assertEquals(200, response.getStatus()); - assertTrue(((String) response.getEntity()).contains("Engine0:0.0.1")); - } - - @Test - public void testRestResourceCreateSessionWithApexModelKey() throws ApexException { - Mockito.doReturn(new AxArtifactKey("ModelKey:0.0.1")).when(engineServiceFacadeMock).getApexModelKey(); - - Response response = restResource.createSession("apexServer", 12345); - assertEquals(200, response.getStatus()); - assertTrue(((String) response.getEntity()).contains("Engine0:0.0.1")); - } - - @Test - public void testRestResourceCreateSessionConnectException() throws ApexException { - Mockito.doThrow(new ApexDeploymentException("Connection Failed")).when(engineServiceFacadeMock).init(); - - Response response = restResource.createSession("apexServer", 12345); - assertEquals(500, response.getStatus()); - assertTrue(((String) response.getEntity()).contains("Error connecting to Apex Engine Service")); - } - - @Test - public void testRestResourceCreateSessionGetException() throws ApexException { - final AxArtifactKey engineKey = new AxArtifactKey("Engine0", "0.0.1"); - Mockito.doThrow(new ApexException("Exception on get")).when(engineServiceFacadeMock).getEngineStatus(engineKey); - - Response response = restResource.createSession("apexServer", 12345); - assertEquals(200, response.getStatus()); - } - - @Test - public void testRestResourceCreateSessionInfo() throws ApexException { - final AxArtifactKey engineKey = new AxArtifactKey("Engine0", "0.0.1"); - Mockito.doReturn("{}").when(engineServiceFacadeMock).getEngineInfo(engineKey); - - Response response = restResource.createSession("apexServer", 12345); - assertEquals(200, response.getStatus()); - } - - @Test - public void testRestResourceCreateSessionNullInfo() throws ApexException { - final AxArtifactKey engineKey = new AxArtifactKey("Engine0", "0.0.1"); - Mockito.doReturn(null).when(engineServiceFacadeMock).getEngineInfo(engineKey); - - Response response = restResource.createSession("apexServer", 12345); - assertEquals(200, response.getStatus()); - } - - @Test - public void testRestResourceCreateSessionEmptyInfo() throws ApexException { - final AxArtifactKey engineKey = new AxArtifactKey("Engine0", "0.0.1"); - Mockito.doReturn(" ").when(engineServiceFacadeMock).getEngineInfo(engineKey); - - Response response = restResource.createSession("apexServer", 12345); - assertEquals(200, response.getStatus()); - } - - @Test - public void testRestResourceCreateSessionExceptionInfo() throws ApexException { - final AxArtifactKey engineKey = new AxArtifactKey("Engine0", "0.0.1"); - Mockito.doThrow(new ApexException("Exception on info")).when(engineServiceFacadeMock).getEngineInfo(engineKey); - - Response response = restResource.createSession("apexServer", 12345); - assertEquals(200, response.getStatus()); - } - - @Test - public void testRestResourceStartEngine() throws ApexException { - final AxArtifactKey engineKey = new AxArtifactKey("Engine0", "0.0.1"); - - Response response = restResource.startStop("apexServer", 12345, engineKey.getId(), "Start"); - assertEquals(200, response.getStatus()); - } - - @Test - public void testRestResourceStopEngine() throws ApexException { - final AxArtifactKey engineKey = new AxArtifactKey("Engine0", "0.0.1"); - - Response response = restResource.startStop("apexServer", 12345, engineKey.getId(), "Stop"); - assertEquals(200, response.getStatus()); - } - - @Test - public void testRestResourceNotStartStopEngine() throws ApexException { - final AxArtifactKey engineKey = new AxArtifactKey("Engine0", "0.0.1"); - - Response response = restResource.startStop("apexServer", 12345, engineKey.getId(), "Hello"); - assertEquals(200, response.getStatus()); - } - - @Test - public void testRestResourceInitExceptionStartStopEngine() throws ApexException { - Mockito.doThrow(new ApexDeploymentException("Exception on init")).when(engineServiceFacadeMock).init(); - - final AxArtifactKey engineKey = new AxArtifactKey("Engine0", "0.0.1"); - - Response response = restResource.startStop("apexServer", 12345, engineKey.getId(), "Hello"); - assertEquals(500, response.getStatus()); - } - - @Test - public void testRestResourceExceptionStartStopEngine() throws ApexException { - final AxArtifactKey engineKey = new AxArtifactKey("Engine0", "0.0.1"); - Mockito.doThrow(new ApexDeploymentException("Exception on Start/Stop")).when(engineServiceFacadeMock) - .startEngine(engineKey); - - Response response = restResource.startStop("apexServer", 12345, engineKey.getId(), "Start"); - assertEquals(500, response.getStatus()); - } - - @Test - public void testRestResourceStartPeriodicEvents() throws ApexException { - final AxArtifactKey engineKey = new AxArtifactKey("Engine0", "0.0.1"); - - Response response = restResource.periodiceventStartStop("apexServer", 12345, engineKey.getId(), "Start", 1000); - assertEquals(200, response.getStatus()); - } - - @Test - public void testRestResourceStopPeriodicEvents() throws ApexException { - final AxArtifactKey engineKey = new AxArtifactKey("Engine0", "0.0.1"); - - Response response = restResource.periodiceventStartStop("apexServer", 12345, engineKey.getId(), "Stop", 1000); - assertEquals(200, response.getStatus()); - } - - @Test - public void testRestResourceNotStartStopPeriodicEvents() throws ApexException { - final AxArtifactKey engineKey = new AxArtifactKey("Engine0", "0.0.1"); - - Response response = restResource.periodiceventStartStop("apexServer", 12345, engineKey.getId(), "Hello", 1000); - assertEquals(200, response.getStatus()); - } - - @Test - public void testRestResourceExceptionPeriodicEvents() throws ApexException { - final AxArtifactKey engineKey = new AxArtifactKey("Engine0", "0.0.1"); - Mockito.doThrow(new ApexDeploymentException("Exception on Periodic Events")).when(engineServiceFacadeMock) - .stopPerioidicEvents(engineKey); - - Response response = restResource.periodiceventStartStop("apexServer", 12345, engineKey.getId(), "Stop", 1000); - assertEquals(500, response.getStatus()); - } - - @Test - public void testCounter() { - ApexMonitoringRestResource.Counter counter = restResource.new Counter(1538338576, 1538338592); - - assertEquals(1538338576, counter.getTimestamp()); - assertEquals(1538338592, counter.getValue()); - } - - @Test - public void testSlidingWindow() { - ApexMonitoringRestResource.SlidingWindowList slidingWindowList0 = restResource.new SlidingWindowList<>( - 2); - - assertNotEquals(0, slidingWindowList0.hashCode()); - - assertTrue(slidingWindowList0.add("Hello")); - assertTrue(slidingWindowList0.add("Hi")); - assertTrue(slidingWindowList0.add("Howdy")); - - assertNotNull(slidingWindowList0); - // disabling sonar because this code tests the equals() method - assertEquals(slidingWindowList0, slidingWindowList0); // NOSONAR - ApexMonitoringRestResource.SlidingWindowList slidingWindowList1 = restResource.new SlidingWindowList<>( - 2); - ApexMonitoringRestResource.SlidingWindowList slidingWindowList2 = restResource.new SlidingWindowList<>( - 2); - assertNotEquals(slidingWindowList0, slidingWindowList1); - assertNotEquals(slidingWindowList0, slidingWindowList2); - assertEquals(slidingWindowList1, slidingWindowList2); - ApexMonitoringRestResource.SlidingWindowList slidingWindowList3 = restResource.new SlidingWindowList<>( - 3); - assertNotEquals(slidingWindowList1, slidingWindowList3); - ApexMonitoringRestResource.SlidingWindowList slidingWindowList4 = restResource.new SlidingWindowList<>( - 3); - assertTrue(slidingWindowList3.add("Hello")); - assertTrue(slidingWindowList4.add(10)); - assertNotEquals(slidingWindowList3, slidingWindowList4); - } - - @Test - public void mopUp() { - assertEquals(engineServiceFacadeMock, restResource.getEngineServiceFacade("apexServer", 12345)); - } -} -- cgit 1.2.3-korg