aboutsummaryrefslogtreecommitdiffstats
path: root/examples/aadm/src/test
diff options
context:
space:
mode:
authorramverma <ram.krishna.verma@ericsson.com>2018-07-25 17:26:52 +0100
committerramverma <ram.krishna.verma@ericsson.com>2018-07-25 17:32:29 +0100
commitf8959f5c51e6338b62e23ea503eb86d9c65d7c74 (patch)
tree7a8afbbf61f7091c30aadfc1cace70fb6e65bff9 /examples/aadm/src/test
parentdccf9a9e0758be0a926c94bf1599ee625066100d (diff)
Renaming examples in apex-pdp
Renaming the examples as per what the documentation expects them. Otherwise the documents won't work. Change-Id: Ib9e30bf5a4cec0fec981372e1d9f3a0ee5d60f2f Issue-ID: POLICY-861 Signed-off-by: ramverma <ram.krishna.verma@ericsson.com>
Diffstat (limited to 'examples/aadm/src/test')
-rw-r--r--examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestAADMDBWrite.java60
-rw-r--r--examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestAADMModel.java81
-rw-r--r--examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestAADMModelCreator.java56
-rw-r--r--examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestAADMUseCase.java412
-rw-r--r--examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestApexActionListener.java91
-rw-r--r--examples/aadm/src/test/resources/META-INF/persistence.xml69
-rw-r--r--examples/aadm/src/test/resources/logback-test.xml74
7 files changed, 0 insertions, 843 deletions
diff --git a/examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestAADMDBWrite.java b/examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestAADMDBWrite.java
deleted file mode 100644
index 02e6f9179..000000000
--- a/examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestAADMDBWrite.java
+++ /dev/null
@@ -1,60 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * Copyright (C) 2016-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.examples.aadm;
-
-import java.io.File;
-import java.sql.Connection;
-import java.sql.DriverManager;
-
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-import org.onap.policy.apex.model.basicmodel.dao.DAOParameters;
-import org.onap.policy.apex.model.basicmodel.test.TestApexModel;
-import org.onap.policy.apex.model.policymodel.concepts.AxPolicyModel;
-
-public class TestAADMDBWrite {
- private Connection connection;
- TestApexModel<AxPolicyModel> testApexModel;
-
- @Before
- public void setup() throws Exception {
- Class.forName("org.apache.derby.jdbc.EmbeddedDriver").newInstance();
- connection = DriverManager.getConnection("jdbc:derby:memory:apex_test;create=true");
-
- testApexModel = new TestApexModel<AxPolicyModel>(AxPolicyModel.class, new TestAADMModelCreator());
- }
-
- @After
- public void teardown() throws Exception {
- connection.close();
- new File("derby.log").delete();
- }
-
- @Test
- public void testModelWriteReadJPA() throws Exception {
- final DAOParameters daoParameters = new DAOParameters();
- daoParameters.setPluginClass("org.onap.policy.apex.model.basicmodel.dao.impl.DefaultApexDao");
- daoParameters.setPersistenceUnit("AADMModelTest");
-
- testApexModel.testApexModelWriteReadJPA(daoParameters);
- }
-}
diff --git a/examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestAADMModel.java b/examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestAADMModel.java
deleted file mode 100644
index 2c62c4994..000000000
--- a/examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestAADMModel.java
+++ /dev/null
@@ -1,81 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * Copyright (C) 2016-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.examples.aadm;
-
-import static org.junit.Assert.assertTrue;
-
-import java.io.File;
-import java.sql.Connection;
-import java.sql.DriverManager;
-
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-import org.onap.policy.apex.model.basicmodel.concepts.AxValidationResult;
-import org.onap.policy.apex.model.basicmodel.dao.DAOParameters;
-import org.onap.policy.apex.model.basicmodel.test.TestApexModel;
-import org.onap.policy.apex.model.policymodel.concepts.AxPolicyModel;
-
-public class TestAADMModel {
- private Connection connection;
- TestApexModel<AxPolicyModel> testApexModel;
-
- @Before
- public void setup() throws Exception {
- Class.forName("org.apache.derby.jdbc.EmbeddedDriver").newInstance();
- connection = DriverManager.getConnection("jdbc:derby:memory:apex_test;create=true");
-
- testApexModel = new TestApexModel<AxPolicyModel>(AxPolicyModel.class, new TestAADMModelCreator());
- }
-
- @After
- public void teardown() throws Exception {
- connection.close();
- new File("derby.log").delete();
- }
-
- @Test
- public void testModelValid() throws Exception {
- final AxValidationResult result = testApexModel.testApexModelValid();
- assertTrue(result.toString().equals(VALID_MODEL_STRING));
- }
-
- @Test
- public void testModelWriteReadXML() throws Exception {
- testApexModel.testApexModelWriteReadXML();
- }
-
- @Test
- public void testModelWriteReadJSON() throws Exception {
- testApexModel.testApexModelWriteReadJSON();
- }
-
- @Test
- public void testModelWriteReadJPA() throws Exception {
- final DAOParameters daoParameters = new DAOParameters();
- daoParameters.setPluginClass("org.onap.policy.apex.model.basicmodel.dao.impl.DefaultApexDao");
- daoParameters.setPersistenceUnit("AADMModelTest");
-
- testApexModel.testApexModelWriteReadJPA(daoParameters);
- }
-
- private static final String VALID_MODEL_STRING = "***validation of model successful***";
-}
diff --git a/examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestAADMModelCreator.java b/examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestAADMModelCreator.java
deleted file mode 100644
index 9aa2095c7..000000000
--- a/examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestAADMModelCreator.java
+++ /dev/null
@@ -1,56 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * Copyright (C) 2016-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.examples.aadm;
-
-import org.onap.policy.apex.examples.aadm.model.AADMDomainModelFactory;
-import org.onap.policy.apex.model.basicmodel.test.TestApexModelCreator;
-import org.onap.policy.apex.model.policymodel.concepts.AxPolicyModel;
-
-/**
- * @author Liam Fallon (liam.fallon@ericsson.com)
- */
-public class TestAADMModelCreator implements TestApexModelCreator<AxPolicyModel> {
-
- @Override
- public AxPolicyModel getModel() {
- return new AADMDomainModelFactory().getAADMPolicyModel();
- }
-
- @Override
- public AxPolicyModel getMalstructuredModel() {
- return null;
- }
-
- @Override
- public AxPolicyModel getObservationModel() {
- return null;
- }
-
- @Override
- public AxPolicyModel getWarningModel() {
- return getModel();
- }
-
- @Override
- public AxPolicyModel getInvalidModel() {
- return null;
- }
-}
diff --git a/examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestAADMUseCase.java b/examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestAADMUseCase.java
deleted file mode 100644
index 58b1800ba..000000000
--- a/examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestAADMUseCase.java
+++ /dev/null
@@ -1,412 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * Copyright (C) 2016-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.examples.aadm;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertTrue;
-
-import java.io.IOException;
-
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-import org.onap.policy.apex.context.ContextAlbum;
-import org.onap.policy.apex.core.engine.EngineParameters;
-import org.onap.policy.apex.core.engine.engine.impl.ApexEngineFactory;
-import org.onap.policy.apex.core.engine.engine.impl.ApexEngineImpl;
-import org.onap.policy.apex.core.engine.event.EnEvent;
-import org.onap.policy.apex.examples.aadm.concepts.ENodeBStatus;
-import org.onap.policy.apex.examples.aadm.model.AADMDomainModelFactory;
-import org.onap.policy.apex.model.basicmodel.concepts.ApexException;
-import org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey;
-import org.onap.policy.apex.model.eventmodel.concepts.AxEvent;
-import org.onap.policy.apex.model.policymodel.concepts.AxPolicyModel;
-import org.onap.policy.apex.plugins.executor.mvel.MVELExecutorParameters;
-import org.slf4j.ext.XLogger;
-import org.slf4j.ext.XLoggerFactory;
-
-/**
- * User: Sergey Sachkov Date: 13/10/15
- */
-public class TestAADMUseCase {
- private static final XLogger logger = XLoggerFactory.getXLogger(TestAADMUseCase.class);
-
- /**
- * Test aadm use case setup.
- */
- @Before
- public void testAADMUseCaseSetup() {}
-
- /**
- * Test aadm case.
- *
- * @throws ApexException the apex exception
- * @throws InterruptedException the interrupted exception
- * @throws IOException Signals that an I/O exception has occurred.
- */
- @Test
- public void testAADMCase() throws ApexException, InterruptedException, IOException {
- final AxPolicyModel apexPolicyModel = new AADMDomainModelFactory().getAADMPolicyModel();
- assertNotNull(apexPolicyModel);
- final AxArtifactKey key = new AxArtifactKey("AADMApexEngine", "0.0.1");
-
- final EngineParameters parameters = new EngineParameters();
- parameters.getExecutorParameterMap().put("MVEL", new MVELExecutorParameters());
-
- final ApexEngineImpl apexEngine = (ApexEngineImpl) new ApexEngineFactory().createApexEngine(key);
- final TestApexActionListener listener = new TestApexActionListener("Test");
- apexEngine.addEventListener("listener", listener);
- apexEngine.updateModel(apexPolicyModel);
- apexEngine.start();
-
- final AxEvent axEvent = getTriggerEvent(apexPolicyModel);
- assertNotNull(axEvent);
-
- // getting number of connections send it to policy, expecting probe action
- logger.info("Sending too many connections trigger ");
- EnEvent event = apexEngine.createEvent(axEvent.getKey());
- event.put("IMSI", new Long(123456));
- event.put("IMSI_IP", "101.111.121.131");
- event.put("ENODEB_ID", new Long(123));
- event.put("SERVICE_REQUEST_COUNT", 99);
- event.put("AVG_SUBSCRIBER_SERVICE_REQUEST", 101.0);
- event.put("UE_IP_ADDRESS", "101.111.121.131");
- event.put("NUM_SUBSCRIBERS", 101);
- event.put("ACTTASK", "");
- event.put("APPLICATION", "");
- event.put("ATTACH_COUNT", 0);
- event.put("AVG_SUBSCRIBER_ATTACH", 0D);
- event.put("DoS", false);
- event.put("NW_IP", "");
- event.put("PROBE_ON", false);
- event.put("SGW_IP_ADDRESS", "");
- event.put("TCP_ON", false);
- event.put("TCP_UE_SIDE_AVG_THROUGHPUT", 0D);
- event.put("TCP_UE_SIDE_MEDIAN_RTT_TX_TO_RX", 0L);
- event.put("http_host_class", "");
- event.put("protocol_group", "");
- apexEngine.handleEvent(event);
- EnEvent result = listener.getResult();
- assertTrue(result.getName().startsWith("XSTREAM_AADM_ACT_EVENT"));
- assertEquals("ExecutionIDs are different", event.getExecutionID(), result.getExecutionID());
- // no DOS_IN_eNodeB set so return probe action
- assertTrue(result.get("ACTTASK").equals("probe"));
- assertTrue((boolean) result.get("TCP_ON"));
- assertTrue((boolean) result.get("PROBE_ON"));
- logger.info("Receiving action event with {} action", result.get("ACTTASK"));
-
- final ContextAlbum eNodeBStatusAlbum = apexEngine.getInternalContext().get("ENodeBStatusAlbum");
- final ENodeBStatus eNodeBStatus = (ENodeBStatus) eNodeBStatusAlbum.get("123");
- eNodeBStatus.setDOSCount(101);
- eNodeBStatusAlbum.put(eNodeBStatus.getENodeB(), eNodeBStatus);
-
- logger.info("Sending too many connections trigger ");
- event = apexEngine.createEvent(axEvent.getKey());
- event.put("IMSI", new Long(123456));
- event.put("IMSI_IP", "101.111.121.131");
- event.put("ENODEB_ID", new Long(123));
- event.put("SERVICE_REQUEST_COUNT", 101);
- event.put("AVG_SUBSCRIBER_SERVICE_REQUEST", 99.0);
- event.put("UE_IP_ADDRESS", "101.111.121.131");
- event.put("NUM_SUBSCRIBERS", 101);
- event.put("TCP_UE_SIDE_AVG_THROUGHPUT", 101.0);
- event.put("ACTTASK", "");
- event.put("APPLICATION", "");
- event.put("ATTACH_COUNT", 0);
- event.put("AVG_SUBSCRIBER_ATTACH", 0D);
- event.put("DoS", false);
- event.put("NW_IP", "");
- event.put("PROBE_ON", false);
- event.put("SGW_IP_ADDRESS", "");
- event.put("TCP_ON", false);
- event.put("TCP_UE_SIDE_MEDIAN_RTT_TX_TO_RX", 0L);
- event.put("http_host_class", "");
- event.put("protocol_group", "");
-
- apexEngine.handleEvent(event);
- result = listener.getResult();
- assertTrue(result.getName().startsWith("XSTREAM_AADM_ACT_EVENT"));
- assertEquals("ExecutionIDs are different", event.getExecutionID(), result.getExecutionID());
- // DOS_IN_eNodeB set to be more than throughput so return act action
- assertTrue(result.get("ACTTASK").equals("act"));
- // only one imsi was sent to process, so stop probe and tcp
- assertTrue(!(boolean) result.get("TCP_ON"));
- assertTrue(!(boolean) result.get("PROBE_ON"));
- assertEquals(100, ((ENodeBStatus) eNodeBStatusAlbum.get("123")).getDOSCount());
- logger.info("Receiving action event with {} action", result.get("ACTTASK"));
-
- ((ENodeBStatus) eNodeBStatusAlbum.get("123")).setDOSCount(99);
-
- // getting number of connections send it to policy, expecting probe action
- logger.info("Sending too many connections trigger ");
- event = apexEngine.createEvent(axEvent.getKey());
- event.put("IMSI", new Long(123456));
- event.put("IMSI_IP", "101.111.121.131");
- event.put("ENODEB_ID", new Long(123));
- event.put("SERVICE_REQUEST_COUNT", 99);
- event.put("AVG_SUBSCRIBER_SERVICE_REQUEST", 101.0);
- event.put("UE_IP_ADDRESS", "101.111.121.131");
- event.put("NUM_SUBSCRIBERS", 99);
- event.put("ACTTASK", "");
- event.put("APPLICATION", "");
- event.put("ATTACH_COUNT", 0);
- event.put("AVG_SUBSCRIBER_ATTACH", 0D);
- event.put("DoS", false);
- event.put("NW_IP", "");
- event.put("PROBE_ON", false);
- event.put("SGW_IP_ADDRESS", "");
- event.put("TCP_ON", false);
- event.put("TCP_UE_SIDE_AVG_THROUGHPUT", 0D);
- event.put("TCP_UE_SIDE_MEDIAN_RTT_TX_TO_RX", 0L);
- event.put("http_host_class", "");
- event.put("protocol_group", "");
-
- apexEngine.handleEvent(event);
- result = listener.getResult();
- assertTrue(result.getName().startsWith("XSTREAM_AADM_ACT_EVENT"));
- assertEquals("ExecutionIDs are different", event.getExecutionID(), result.getExecutionID());
- assertTrue(result.get("ACTTASK").equals("probe"));
- assertTrue((boolean) result.get("TCP_ON"));
- assertTrue((boolean) result.get("PROBE_ON"));
- assertEquals(99, ((ENodeBStatus) eNodeBStatusAlbum.get("123")).getDOSCount());
-
- ((ENodeBStatus) eNodeBStatusAlbum.get("123")).setDOSCount(99);
-
- // tcp correlation return positive dos
- logger.info("Receiving action event with {} action", result.get("ACTTASK"));
- event = apexEngine.createEvent(axEvent.getKey());
- event.put("IMSI", new Long(123456));
- event.put("IMSI_IP", "101.111.121.131");
- event.put("ENODEB_ID", new Long(123));
- event.put("TCP_UE_SIDE_AVG_THROUGHPUT", 101.0);
- event.put("ACTTASK", "");
- event.put("APPLICATION", "");
- event.put("ATTACH_COUNT", 0);
- event.put("AVG_SUBSCRIBER_ATTACH", 0D);
- event.put("AVG_SUBSCRIBER_SERVICE_REQUEST", 0.0);
- event.put("DoS", false);
- event.put("NUM_SUBSCRIBERS", 0);
- event.put("NW_IP", "");
- event.put("PROBE_ON", false);
- event.put("SERVICE_REQUEST_COUNT", 0);
- event.put("SGW_IP_ADDRESS", "");
- event.put("TCP_ON", false);
- event.put("TCP_UE_SIDE_MEDIAN_RTT_TX_TO_RX", 0L);
- event.put("UE_IP_ADDRESS", "");
- event.put("http_host_class", "");
- event.put("protocol_group", "");
-
- apexEngine.handleEvent(event);
- result = listener.getResult();
- assertTrue(result.getName().startsWith("XSTREAM_AADM_ACT_EVENT"));
- assertEquals("ExecutionIDs are different", event.getExecutionID(), result.getExecutionID());
- assertTrue(result.get("ACTTASK").equals("act"));
- assertTrue(!(boolean) result.get("TCP_ON"));
- assertTrue(!(boolean) result.get("PROBE_ON"));
- assertEquals(98, ((ENodeBStatus) eNodeBStatusAlbum.get("123")).getDOSCount());
- logger.info("Receiving action event with {} action", result.get("ACTTASK"));
-
- ((ENodeBStatus) eNodeBStatusAlbum.get("123")).setDOSCount(101);
-
- // user moving enodeB
- logger.info("Sending too many connections trigger ");
- event = apexEngine.createEvent(axEvent.getKey());
- event.put("IMSI", new Long(123456));
- event.put("IMSI_IP", "101.111.121.131");
- event.put("ENODEB_ID", new Long(123));
- event.put("SERVICE_REQUEST_COUNT", 99);
- event.put("AVG_SUBSCRIBER_SERVICE_REQUEST", 101.0);
- event.put("UE_IP_ADDRESS", "101.111.121.131");
- event.put("NUM_SUBSCRIBERS", 101);
- event.put("ACTTASK", "");
- event.put("APPLICATION", "");
- event.put("ATTACH_COUNT", 0);
- event.put("AVG_SUBSCRIBER_ATTACH", 0D);
- event.put("AVG_SUBSCRIBER_SERVICE_REQUEST", 0.0);
- event.put("DoS", false);
- event.put("NW_IP", "");
- event.put("PROBE_ON", false);
- event.put("SGW_IP_ADDRESS", "");
- event.put("TCP_ON", false);
- event.put("TCP_UE_SIDE_AVG_THROUGHPUT", 0D);
- event.put("TCP_UE_SIDE_MEDIAN_RTT_TX_TO_RX", 0L);
- event.put("http_host_class", "");
- event.put("protocol_group", "");
-
- apexEngine.handleEvent(event);
- result = listener.getResult();
- assertTrue(result.getName().startsWith("XSTREAM_AADM_ACT_EVENT"));
- assertEquals("ExecutionIDs are different", event.getExecutionID(), result.getExecutionID());
- assertTrue(result.get("ACTTASK").equals("act"));
- assertTrue(!(boolean) result.get("TCP_ON"));
- assertTrue(!(boolean) result.get("PROBE_ON"));
- assertEquals(100, ((ENodeBStatus) eNodeBStatusAlbum.get("123")).getDOSCount());
- logger.info("Receiving action event with {} action", result.get("ACTTASK"));
-
- logger.info("Sending too many connections trigger ");
- event = apexEngine.createEvent(axEvent.getKey());
- event.put("IMSI", new Long(123456));
- event.put("ENODEB_ID", new Long(124));
- event.put("SERVICE_REQUEST_COUNT", 99);
- event.put("AVG_SUBSCRIBER_SERVICE_REQUEST", 101.0);
- event.put("UE_IP_ADDRESS", "101.111.121.131");
- event.put("NUM_SUBSCRIBERS", 101);
- event.put("ACTTASK", "");
- event.put("APPLICATION", "");
- event.put("ATTACH_COUNT", 0);
- event.put("AVG_SUBSCRIBER_ATTACH", 0D);
- event.put("DoS", false);
- event.put("IMSI_IP", "");
- event.put("NW_IP", "");
- event.put("PROBE_ON", false);
- event.put("SGW_IP_ADDRESS", "");
- event.put("TCP_ON", false);
- event.put("TCP_UE_SIDE_AVG_THROUGHPUT", 0D);
- event.put("TCP_UE_SIDE_MEDIAN_RTT_TX_TO_RX", 0L);
- event.put("http_host_class", "");
- event.put("protocol_group", "");
-
- apexEngine.handleEvent(event);
- result = listener.getResult();
- assertTrue(result.getName().startsWith("XSTREAM_AADM_ACT_EVENT"));
- assertEquals("ExecutionIDs are different", event.getExecutionID(), result.getExecutionID());
- assertTrue(result.get("ACTTASK").equals("probe"));
- assertTrue((boolean) result.get("TCP_ON"));
- assertTrue((boolean) result.get("PROBE_ON"));
- assertEquals(99, ((ENodeBStatus) eNodeBStatusAlbum.get("123")).getDOSCount());
- assertEquals(1, ((ENodeBStatus) eNodeBStatusAlbum.get("124")).getDOSCount());
- logger.info("Receiving action event with {} action", result.get("ACTTASK"));
- // End of user moving enodeB
-
- ((ENodeBStatus) eNodeBStatusAlbum.get("123")).setDOSCount(101);
-
- // user becomes non anomalous
- logger.info("Sending too many connections trigger ");
- event = apexEngine.createEvent(axEvent.getKey());
- event.put("IMSI", new Long(123456));
- event.put("IMSI_IP", "101.111.121.131");
- event.put("ENODEB_ID", new Long(123));
- event.put("SERVICE_REQUEST_COUNT", 99);
- event.put("AVG_SUBSCRIBER_SERVICE_REQUEST", 101.0);
- event.put("UE_IP_ADDRESS", "101.111.121.131");
- event.put("NUM_SUBSCRIBERS", 101);
- event.put("ACTTASK", "");
- event.put("APPLICATION", "");
- event.put("ATTACH_COUNT", 0);
- event.put("AVG_SUBSCRIBER_ATTACH", 0D);
- event.put("DoS", false);
- event.put("NW_IP", "");
- event.put("PROBE_ON", false);
- event.put("SGW_IP_ADDRESS", "");
- event.put("TCP_ON", false);
- event.put("TCP_UE_SIDE_AVG_THROUGHPUT", 0D);
- event.put("TCP_UE_SIDE_MEDIAN_RTT_TX_TO_RX", 0L);
- event.put("http_host_class", "");
- event.put("protocol_group", "");
-
- apexEngine.handleEvent(event);
- result = listener.getResult();
- assertTrue(result.getName().startsWith("XSTREAM_AADM_ACT_EVENT"));
- assertEquals("ExecutionIDs are different", event.getExecutionID(), result.getExecutionID());
- assertTrue(result.get("ACTTASK").equals("probe"));
- assertTrue((boolean) result.get("TCP_ON"));
- assertTrue((boolean) result.get("PROBE_ON"));
- assertEquals(102, ((ENodeBStatus) eNodeBStatusAlbum.get("123")).getDOSCount());
- logger.info("Receiving action event with {} action", result.get("ACTTASK"));
-
- logger.info("Sending too many connections trigger ");
- event = apexEngine.createEvent(axEvent.getKey());
- event.put("IMSI", new Long(123456));
- event.put("ENODEB_ID", new Long(123));
- event.put("SERVICE_REQUEST_COUNT", 99);
- event.put("UE_IP_ADDRESS", "101.111.121.131");
- event.put("ACTTASK", "");
- event.put("APPLICATION", "");
- event.put("ATTACH_COUNT", 0);
- event.put("AVG_SUBSCRIBER_ATTACH", 0D);
- event.put("AVG_SUBSCRIBER_SERVICE_REQUEST", 0.0);
- event.put("DoS", false);
- event.put("IMSI_IP", "");
- event.put("NUM_SUBSCRIBERS", 0);
- event.put("NW_IP", "");
- event.put("PROBE_ON", false);
- event.put("SGW_IP_ADDRESS", "");
- event.put("TCP_ON", false);
- event.put("TCP_UE_SIDE_AVG_THROUGHPUT", 0D);
- event.put("TCP_UE_SIDE_MEDIAN_RTT_TX_TO_RX", 0L);
- event.put("http_host_class", "");
- event.put("protocol_group", "");
-
- apexEngine.handleEvent(event);
- result = listener.getResult();
- assertTrue(result.getName().startsWith("XSTREAM_AADM_ACT_EVENT"));
- assertEquals("ExecutionIDs are different", event.getExecutionID(), result.getExecutionID());
- assertTrue(result.get("ACTTASK").equals("probe"));
- assertTrue((boolean) result.get("TCP_ON"));
- assertTrue((boolean) result.get("PROBE_ON"));
- assertEquals(102, ((ENodeBStatus) eNodeBStatusAlbum.get("123")).getDOSCount());
- logger.info("Receiving action event with {} action", result.get("ACTTASK"));
- // End of user becomes non anomalous
- apexEngine.handleEvent(result);
- result = listener.getResult();
- assertTrue(result.getName().startsWith("SAPCBlacklistSubscriberEvent"));
- assertTrue(result.get("PROFILE").equals("ServiceA"));
- assertTrue(result.get("BLACKLIST_ON").equals(true));
-
- event = apexEngine.createEvent(new AxArtifactKey("PeriodicEvent", "0.0.1"));
- event.put("PERIODIC_EVENT_COUNT", (long) 100);
- event.put("PERIODIC_DELAY", (long) 1000);
- event.put("PERIODIC_FIRST_TIME", System.currentTimeMillis());
- event.put("PERIODIC_CURRENT_TIME", System.currentTimeMillis());
- event.put("PERIODIC_LAST_TIME", System.currentTimeMillis());
- apexEngine.handleEvent(event);
- result = listener.getResult();
- assertTrue(result.getName().startsWith("SAPCBlacklistSubscriberEvent"));
- assertEquals("ExecutionIDs are different", event.getExecutionID(), result.getExecutionID());
- assertEquals(0L, result.get("IMSI"));
- assertTrue(result.get("PROFILE").equals("ServiceA"));
- assertTrue(result.get("BLACKLIST_ON").equals(false));
-
- apexEngine.stop();
- }
-
- /**
- * Test vpn cleardown.
- */
- @After
- public void testAADMCleardown() {}
-
- /**
- * Gets the trigger event.
- *
- * @param apexModel the apex model
- * @return the trigger event
- */
- private AxEvent getTriggerEvent(final AxPolicyModel apexPolicyModel) {
- for (final AxEvent axEvent : apexPolicyModel.getEvents().getEventMap().values()) {
- if (axEvent.getKey().getID().equals("AADMEvent:0.0.1")) {
- return axEvent;
- }
- }
- return null;
- }
-}
diff --git a/examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestApexActionListener.java b/examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestApexActionListener.java
deleted file mode 100644
index ccf4539aa..000000000
--- a/examples/aadm/src/test/java/org/onap/policy/apex/examples/aadm/TestApexActionListener.java
+++ /dev/null
@@ -1,91 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * Copyright (C) 2016-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.examples.aadm;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import org.onap.policy.apex.core.engine.engine.EnEventListener;
-import org.onap.policy.apex.core.engine.event.EnEvent;
-import org.onap.policy.apex.core.infrastructure.threading.ThreadUtilities;
-
-/**
- * The listener interface for receiving testApexAction events. The class that is interested in processing a
- * testApexAction event implements this interface, and the object created with that class is registered with a component
- * using the component's <code>addTestApexActionListener</code> method. When the testApexAction event occurs, that
- * object's appropriate method is invoked.
- *
- * @author Liam Fallon (liam.fallon@ericsson.com)
- */
-public class TestApexActionListener implements EnEventListener {
- List<EnEvent> resultEvents = new ArrayList<EnEvent>();
-
- private final String id;
-
- /**
- * Instantiates a new test apex action listener.
- *
- * @param id the id
- */
- public TestApexActionListener(final String id) {
- this.id = id;
- }
-
- /**
- * Gets the result.
- *
- * @return the result
- */
- public EnEvent getResult() {
- while (resultEvents.isEmpty()) {
- ThreadUtilities.sleep(100);
- }
- return resultEvents.remove(0);
- }
-
- /*
- * (non-Javadoc)
- *
- * @see
- * org.onap.policy.apex.core.engine.engine.EnEventListener#onEnEvent(org.onap.policy.apex.core.engine.event.EnEvent)
- */
- @Override
- public void onEnEvent(final EnEvent actionEvent) {
- try {
- Thread.sleep(100);
- } catch (final InterruptedException e) {
- e.printStackTrace();
- }
- if (actionEvent != null) {
- System.out.println("Action event from engine:" + actionEvent.getName());
- resultEvents.add(actionEvent);
- }
- }
-
- /**
- * Gets the id.
- *
- * @return the id
- */
- public String getId() {
- return id;
- }
-}
diff --git a/examples/aadm/src/test/resources/META-INF/persistence.xml b/examples/aadm/src/test/resources/META-INF/persistence.xml
deleted file mode 100644
index eaef96a85..000000000
--- a/examples/aadm/src/test/resources/META-INF/persistence.xml
+++ /dev/null
@@ -1,69 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
- ============LICENSE_START=======================================================
- Copyright (C) 2016-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=========================================================
--->
-
-<persistence xmlns="http://java.sun.com/xml/ns/persistence" version="2.0">
- <persistence-unit name="AADMModelTest" transaction-type="RESOURCE_LOCAL">
- <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>
-
- <class>org.onap.policy.apex.model.basicmodel.dao.converters.CDATAConditioner</class>
- <class>org.onap.policy.apex.model.basicmodel.dao.converters.UUID2String</class>
- <class>org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey</class>
- <class>org.onap.policy.apex.model.basicmodel.concepts.AxConcept</class>
- <class>org.onap.policy.apex.model.basicmodel.concepts.AxKeyInfo</class>
- <class>org.onap.policy.apex.model.basicmodel.concepts.AxKeyInformation</class>
- <class>org.onap.policy.apex.model.basicmodel.concepts.AxModel</class>
- <class>org.onap.policy.apex.model.basicmodel.concepts.TestEntity</class>
- <class>org.onap.policy.apex.model.contextmodel.concepts.AxContextSchema</class>
- <class>org.onap.policy.apex.model.contextmodel.concepts.AxContextSchemas</class>
- <class>org.onap.policy.apex.model.contextmodel.concepts.AxContextAlbum</class>
- <class>org.onap.policy.apex.model.contextmodel.concepts.AxContextAlbums</class>
- <class>org.onap.policy.apex.model.contextmodel.concepts.AxContextModel</class>
- <class>org.onap.policy.apex.model.eventmodel.concepts.AxField</class>
- <class>org.onap.policy.apex.model.eventmodel.concepts.AxInputField</class>
- <class>org.onap.policy.apex.model.eventmodel.concepts.AxOutputField</class>
- <class>org.onap.policy.apex.model.eventmodel.concepts.AxEvent</class>
- <class>org.onap.policy.apex.model.eventmodel.concepts.AxEvents</class>
- <class>org.onap.policy.apex.model.eventmodel.concepts.AxEventModel</class>
- <class>org.onap.policy.apex.model.policymodel.concepts.AxLogic</class>
- <class>org.onap.policy.apex.model.policymodel.concepts.AxTaskParameter</class>
- <class>org.onap.policy.apex.model.policymodel.concepts.AxTaskLogic</class>
- <class>org.onap.policy.apex.model.policymodel.concepts.AxTask</class>
- <class>org.onap.policy.apex.model.policymodel.concepts.AxTasks</class>
- <class>org.onap.policy.apex.model.policymodel.concepts.AxTaskSelectionLogic</class>
- <class>org.onap.policy.apex.model.policymodel.concepts.AxStateFinalizerLogic</class>
- <class>org.onap.policy.apex.model.policymodel.concepts.AxStateOutput</class>
- <class>org.onap.policy.apex.model.policymodel.concepts.AxStateTaskReference</class>
- <class>org.onap.policy.apex.model.policymodel.concepts.AxState</class>
- <class>org.onap.policy.apex.model.policymodel.concepts.AxPolicy</class>
- <class>org.onap.policy.apex.model.policymodel.concepts.AxPolicies</class>
- <class>org.onap.policy.apex.model.policymodel.concepts.AxPolicyModel</class>
-
- <properties>
- <property name="javax.persistence.jdbc.url" value="jdbc:derby:memory:apex_test" />
- <property name="javax.persistence.target-database" value="Derby" />
- <property name="javax.persistence.jdbc.driver" value="org.apache.derby.jdbc.EmbeddedDriver" />
-
- <property name="eclipselink.ddl-generation" value="drop-and-create-tables" />
- <property name="eclipselink.ddl-generation.output-mode" value="database" />
- <property name="eclipselink.logging.level" value="INFO" />
- </properties>
- </persistence-unit>
-</persistence>
diff --git a/examples/aadm/src/test/resources/logback-test.xml b/examples/aadm/src/test/resources/logback-test.xml
deleted file mode 100644
index 4b9258c40..000000000
--- a/examples/aadm/src/test/resources/logback-test.xml
+++ /dev/null
@@ -1,74 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
- ============LICENSE_START=======================================================
- Copyright (C) 2016-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=========================================================
--->
-
-<configuration>
-
- <contextName>Apex</contextName>
- <statusListener class="ch.qos.logback.core.status.OnConsoleStatusListener" />
- <property name="LOG_DIR" value="${java.io.tmpdir}/apex_logging/" />
-
- <!-- USE FOR STD OUT ONLY -->
- <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
- <encoder>
- <Pattern>%d %contextName [%t] %level %logger{36} - %msg%n</Pattern>
- </encoder>
- </appender>
-
- <root level="INFO">
- <appender-ref ref="STDOUT" />
- </root>
-
- <logger name="org.infinispan" level="INFO" additivity="false">
- <appender-ref ref="STDOUT" />
- </logger>
-
- <logger name="org.apache.zookeeper.ClientCnxn" level="OFF" additivity="false">
- <appender-ref ref="STDOUT" />
- </logger>
-
- <appender name="FILE" class="ch.qos.logback.core.FileAppender">
- <file>${LOG_DIR}/apex.log</file>
- <encoder>
- <pattern>%d %-5relative [procId=${processId}] [%thread] %-5level
- %logger{26} - %msg %n %ex{full}</pattern>
- </encoder>
- </appender>
-
- <appender name="CTXT_FILE" class="ch.qos.logback.core.FileAppender">
- <file>${LOG_DIR}/apex_ctxt.log</file>
- <encoder>
- <pattern>%d %-5relative [procId=${processId}] [%thread] %-5level
- %logger{26} - %msg %n %ex{full}</pattern>
- </encoder>
- </appender>
-
- <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="TRACE" additivity="false">
- <appender-ref ref="CTXT_FILE" />
- </logger>
-
- <logger name="org.onap.policy.apex" level="TRACE" additivity="false">
- <appender-ref ref="STDOUT" />
- </logger>
-
- <logger name="org.onap.policy.apex.core.infrastructure" level="INFO" additivity="false">
- <appender-ref ref="STDOUT" />
- </logger>
-</configuration>