summaryrefslogtreecommitdiffstats
path: root/BRMSGateway/src
diff options
context:
space:
mode:
Diffstat (limited to 'BRMSGateway/src')
-rw-r--r--BRMSGateway/src/main/java/org/onap/policy/brmsInterface/BRMSPush.java11
-rw-r--r--BRMSGateway/src/test/java/org/onap/brmsgw/test/BRMSPushTest.java234
-rw-r--r--BRMSGateway/src/test/resources/META-INF/drop.ddl2
-rw-r--r--BRMSGateway/src/test/resources/META-INF/persistenceBRMStest.xml44
-rw-r--r--BRMSGateway/src/test/resources/config.properties86
5 files changed, 376 insertions, 1 deletions
diff --git a/BRMSGateway/src/main/java/org/onap/policy/brmsInterface/BRMSPush.java b/BRMSGateway/src/main/java/org/onap/policy/brmsInterface/BRMSPush.java
index b09a3d8c8..c923c3c34 100644
--- a/BRMSGateway/src/main/java/org/onap/policy/brmsInterface/BRMSPush.java
+++ b/BRMSGateway/src/main/java/org/onap/policy/brmsInterface/BRMSPush.java
@@ -137,6 +137,9 @@ public class BRMSPush {
private boolean syncFlag = false;
public BRMSPush(String propertiesFile, BackUpHandler handler) throws PolicyException {
+ if(propertiesFile==null || handler==null){
+ throw new PolicyException("Error no propertiesFile or handler");
+ }
Properties config = new Properties();
Path file = Paths.get(propertiesFile);
if (Files.notExists(file)) {
@@ -185,7 +188,9 @@ public class BRMSPush {
} catch (Exception e) {
LOGGER.error("Error starting BackUpMonitor: " + e);
}
- config.setProperty(PersistenceUnitProperties.ECLIPSELINK_PERSISTENCE_XML, "META-INF/persistenceBRMS.xml");
+ if(!config.containsKey(PersistenceUnitProperties.ECLIPSELINK_PERSISTENCE_XML)){
+ config.setProperty(PersistenceUnitProperties.ECLIPSELINK_PERSISTENCE_XML, "META-INF/persistenceBRMS.xml");
+ }
EntityManagerFactory emf = Persistence.createEntityManagerFactory("BRMSGW", config);
em = emf.createEntityManager();
defaultName = config.getProperty("defaultName");
@@ -1014,6 +1019,10 @@ public class BRMSPush {
private void readGroups(Properties config) throws PolicyException {
String[] groupNames = null;
+ if (!config.containsKey("groupNames") || config.getProperty("groupNames")==null){
+ throw new PolicyException(XACMLErrorConstants.ERROR_DATA_ISSUE
+ + "groupNames property is missing or empty from the property file ");
+ }
if (config.getProperty("groupNames").contains(",")) {
groupNames = config.getProperty("groupNames").replaceAll(" ", "").split(",");
} else {
diff --git a/BRMSGateway/src/test/java/org/onap/brmsgw/test/BRMSPushTest.java b/BRMSGateway/src/test/java/org/onap/brmsgw/test/BRMSPushTest.java
new file mode 100644
index 000000000..aa2574401
--- /dev/null
+++ b/BRMSGateway/src/test/java/org/onap/brmsgw/test/BRMSPushTest.java
@@ -0,0 +1,234 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.
+ * 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.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.brmsgw.test;
+
+import static org.junit.Assert.assertNotNull;
+
+import java.io.FileInputStream;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Properties;
+
+import org.junit.Test;
+import org.onap.policy.api.PolicyException;
+import org.onap.policy.brmsInterface.BRMSHandler;
+
+public class BRMSPushTest {
+
+ private final String VALIDFILE = "src/test/resources/config.properties";
+ private final String INVALIDFILE = "src/test/resources/failure.properties";
+
+ @Test (expected = PolicyException.class)
+ public void bRMSHandlerFailTest() throws PolicyException {
+ new BRMSHandler(null);
+ }
+
+ @Test (expected = PolicyException.class)
+ public void bRMSHandlerFailTest1() throws PolicyException {
+ new BRMSHandler("src/test/resources/filenotexists.txt");
+ }
+
+ @Test (expected = PolicyException.class)
+ public void bRMSHandlerFailTest2() throws PolicyException {
+ PropertyChange prop = new PropertyChange();
+ prop.key = "defaultName";
+ prop.remove = true;
+ List<PropertyChange> props = new LinkedList<>();
+ props.add(prop);
+ setFailureProperties(props);
+ new BRMSHandler(INVALIDFILE);
+ }
+
+ @Test (expected = PolicyException.class)
+ public void bRMSHandlerFailTest3() throws PolicyException {
+ PropertyChange prop = new PropertyChange();
+ prop.key = "repositoryID";
+ prop.remove = true;
+ List<PropertyChange> props = new LinkedList<>();
+ props.add(prop);
+ prop = new PropertyChange();
+ prop.key = "RESOURCE_NAME";
+ prop.remove = true;
+ props.add(prop);
+ setFailureProperties(props);
+ new BRMSHandler(INVALIDFILE);
+ }
+
+ @Test (expected = PolicyException.class)
+ public void bRMSHandlerFailTest4() throws PolicyException {
+ PropertyChange prop = new PropertyChange();
+ prop.key = "repositoryURL";
+ prop.remove = true;
+ List<PropertyChange> props = new LinkedList<>();
+ props.add(prop);
+ setFailureProperties(props);
+ new BRMSHandler(INVALIDFILE);
+ }
+
+ @Test (expected = PolicyException.class)
+ public void bRMSHandlerFailTest5() throws PolicyException {
+ PropertyChange prop = new PropertyChange();
+ prop.key = "repositoryName";
+ prop.remove = true;
+ List<PropertyChange> props = new LinkedList<>();
+ props.add(prop);
+ setFailureProperties(props);
+ new BRMSHandler(INVALIDFILE);
+ }
+
+ @Test (expected = PolicyException.class)
+ public void bRMSHandlerFailTest6() throws PolicyException {
+ PropertyChange prop = new PropertyChange();
+ prop.key = "repositoryURL";
+ prop.value = "http://nexus:8081/nexus/content/repositories/releases, http://nexus:8081/nexus/content/repositories/releases";
+ prop.remove = false;
+ List<PropertyChange> props = new LinkedList<>();
+ props.add(prop);
+ prop = new PropertyChange();
+ prop.key = "repositoryUsername";
+ prop.remove = true;
+ props.add(prop);
+ setFailureProperties(props);
+ new BRMSHandler(INVALIDFILE);
+ }
+
+ @Test (expected = PolicyException.class)
+ public void bRMSHandlerFailTest7() throws PolicyException {
+ PropertyChange prop = new PropertyChange();
+ prop.key = "repositoryPassword";
+ prop.remove = true;
+ List<PropertyChange> props = new LinkedList<>();
+ props.add(prop);
+ setFailureProperties(props);
+ new BRMSHandler(INVALIDFILE);
+ }
+
+ @Test (expected = PolicyException.class)
+ public void bRMSHandlerFailTest8() throws PolicyException {
+ PropertyChange prop = new PropertyChange();
+ prop.key = "policyKeyID";
+ prop.remove = true;
+ List<PropertyChange> props = new LinkedList<>();
+ props.add(prop);
+ setFailureProperties(props);
+ new BRMSHandler(INVALIDFILE);
+ }
+
+ @Test (expected = PolicyException.class)
+ public void bRMSHandlerFailTest9() throws PolicyException {
+ PropertyChange prop = new PropertyChange();
+ prop.key = "sync";
+ prop.value = "true";
+ prop.remove = false;
+ List<PropertyChange> props = new LinkedList<>();
+ props.add(prop);
+ prop = new PropertyChange();
+ prop.key = "brms.dependency.version";
+ prop.remove = true;
+ props.add(prop);
+ prop = new PropertyChange();
+ prop.key = "groupNames";
+ prop.remove = true;
+ props.add(prop);
+ setFailureProperties(props);
+ new BRMSHandler(INVALIDFILE);
+ }
+
+ @Test (expected = PolicyException.class)
+ public void bRMSHandlerFailTest10() throws PolicyException {
+ PropertyChange prop = new PropertyChange();
+ prop.key = "groupNames";
+ prop.value = "";
+ prop.remove = false;
+ List<PropertyChange> props = new LinkedList<>();
+ props.add(prop);
+ setFailureProperties(props);
+ new BRMSHandler(INVALIDFILE);
+ }
+
+ @Test (expected = PolicyException.class)
+ public void bRMSHandlerFailTest11() throws PolicyException {
+ PropertyChange prop = new PropertyChange();
+ prop.key = "default.groupID";
+ prop.remove = true;
+ List<PropertyChange> props = new LinkedList<>();
+ props.add(prop);
+ setFailureProperties(props);
+ new BRMSHandler(INVALIDFILE);
+ }
+
+ @Test (expected = PolicyException.class)
+ public void bRMSHandlerFailTest12() throws PolicyException {
+ PropertyChange prop = new PropertyChange();
+ prop.key = "default.artifactID";
+ prop.remove = true;
+ List<PropertyChange> props = new LinkedList<>();
+ props.add(prop);
+ setFailureProperties(props);
+ new BRMSHandler(INVALIDFILE);
+ }
+
+ @Test (expected = PolicyException.class)
+ public void bRMSHandlerFailTest13() throws PolicyException {
+ PropertyChange prop = new PropertyChange();
+ prop.key = "NOTIFICATION_TYPE";
+ prop.value = "dmaap";
+ prop.remove = false;
+ List<PropertyChange> props = new LinkedList<>();
+ props.add(prop);
+ prop = new PropertyChange();
+ prop.key = "NOTIFICATION_SERVERS";
+ prop.remove = true;
+ props.add(prop);
+ setFailureProperties(props);
+ new BRMSHandler(INVALIDFILE);
+ }
+
+ @Test
+ public void BRMSHandlerTest() throws PolicyException {
+ assertNotNull(new BRMSHandler(VALIDFILE));
+ }
+
+ private void setFailureProperties(List<PropertyChange> properties) throws PolicyException {
+ Properties validProp = new Properties();
+ try {
+ validProp.load(new FileInputStream(VALIDFILE));
+ for (PropertyChange prop: properties) {
+ if(prop.remove) {
+ validProp.remove(prop.key);
+ }else {
+ validProp.setProperty(prop.key, prop.value);
+ }
+ }
+ validProp.store(new FileOutputStream(INVALIDFILE), null);
+ } catch (IOException e) {
+ throw new PolicyException(e);
+ }
+ }
+
+ class PropertyChange {
+ public String key = null;
+ public String value = null;
+ public Boolean remove = false;
+ }
+}
diff --git a/BRMSGateway/src/test/resources/META-INF/drop.ddl b/BRMSGateway/src/test/resources/META-INF/drop.ddl
new file mode 100644
index 000000000..a46848df2
--- /dev/null
+++ b/BRMSGateway/src/test/resources/META-INF/drop.ddl
@@ -0,0 +1,2 @@
+DROP TABLE IF EXISTS brmsgroup_info
+DROP TABLE IF EXISTS brmsgroup_policy \ No newline at end of file
diff --git a/BRMSGateway/src/test/resources/META-INF/persistenceBRMStest.xml b/BRMSGateway/src/test/resources/META-INF/persistenceBRMStest.xml
new file mode 100644
index 000000000..f757aca86
--- /dev/null
+++ b/BRMSGateway/src/test/resources/META-INF/persistenceBRMStest.xml
@@ -0,0 +1,44 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ ============LICENSE_START=======================================================
+ PolicyEngineUtils
+ ================================================================================
+ Copyright (C) 2017 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.
+ 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.
+ ============LICENSE_END=========================================================
+ -->
+
+<persistence version="2.1"
+ xmlns="http://xmlns.jcp.org/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/persistence http://xmlns.jcp.org/xml/ns/persistence/persistence_2_1.xsd">
+ <persistence-unit name="BRMSGW" transaction-type="RESOURCE_LOCAL">
+ <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>
+ <class>org.onap.policy.brmsInterface.jpa.BRMSGroupInfo</class>
+ <class>org.onap.policy.brmsInterface.jpa.BRMSPolicyInfo</class>
+ <property name="javax.persistence.schema-generation.scripts.action"
+ value="drop-and-create" />
+ <property name="javax.persistence.schema-generation.scripts.create-target"
+ value="./src/test/resources/META-INF/generatedCreate.ddl" />
+ <property name="javax.persistence.schema-generation.scripts.drop-target"
+ value="./src/test/resources/META-INF/generatedDrop.ddl" />
+ <property name="javax.persistence.schema-generation.database.action"
+ value="drop-and-create" />
+ <property name="javax.persistence.schema-generation.create-source"
+ value="metadata-then-script" />
+ <property name="javax.persistence.schema-generation.drop-source"
+ value="script" />
+ <property name="javax.persistence.schema-generation.drop-script-source"
+ value="META-INF/drop.ddl" />
+ </persistence-unit>
+</persistence> \ No newline at end of file
diff --git a/BRMSGateway/src/test/resources/config.properties b/BRMSGateway/src/test/resources/config.properties
new file mode 100644
index 000000000..4f9e01305
--- /dev/null
+++ b/BRMSGateway/src/test/resources/config.properties
@@ -0,0 +1,86 @@
+###
+# ============LICENSE_START=======================================================
+# ONAP Policy Engine
+# ================================================================================
+# Copyright (C) 2017 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.
+# 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.
+# ============LICENSE_END=========================================================
+###
+
+PDP_URL2 = https://localhost:8082/pdp/ , testpdp, alpha456
+PAP_URL = http://localhost:8070/pap/ , testpap, alpha123
+
+#Notification Properties... type can be either websocket, ueb, or dmaap
+NOTIFICATION_TYPE=websocket
+NOTIFICATION_SERVERS=
+NOTIFICATION_TOPIC=PDPD-CONFIGURATION
+NOTIFICATION_DELAY=
+UEB_API_KEY=
+UEB_API_SECRET=
+CLIENT_ID=
+CLIENT_KEY=
+
+# BRMS Properties.
+## defaultName is the default group name to which the rule gets pushed if no artifactID is specified.
+defaultName = default
+## repositoryID
+repositoryID = releases
+## reposiroryName
+repositoryName = Releases
+## repositoryURL
+repositoryURL = http://nexus:8081/nexus/content/repositories/releases
+## repositoryUsername & Password
+repositoryUsername=admin
+repositoryPassword=admin123
+## policyKeyID the value of Policy Key whose value will be the group Name.
+policyKeyID = controller
+
+## GroupNames can be comma separated values.
+groupNames = default, vFW , vDNS
+default.groupID = org.onap.policy-engine
+default.artifactID = drlPDPGroup
+vFW.groupID= org.onap.policy-engine.drools.vFW
+vFW.artifactID= policy-vFW-rules
+vDNS.groupID= org.onap.policy-engine.drools.vDNS
+vDNS.artifactID= policy-vDNS-rules
+
+#Integrity Monitor values
+#database driver for Integrity Monitor
+javax.persistence.jdbc.driver=org.h2.Driver
+#database URL for Integrity Monitor
+javax.persistence.jdbc.url=jdbc:h2:file:./sql/xacmlTest
+#database username for Integrity Monitor
+javax.persistence.jdbc.user=sa
+#database password for Integrity Monitor
+javax.persistence.jdbc.password=
+#persistence xml
+eclipselink.persistencexml=META-INF/persistenceBRMStest.xml
+#resource name
+RESOURCE_NAME=site_1.brmsgw_1
+#***Properties for IntegrityMonitor integration defined in IntegrityMonitorProperties.java***
+site_name=site_1
+node_type=brms_gateway
+fp_monitor_interval=30
+failed_counter_threshold=3
+test_trans_interval=20
+write_fpc_interval=5
+max_fpc_update_interval=60
+test_via_jmx=false
+ping_interval=30000
+#
+#
+#
+brms.dependency.version=1.1.0-SNAPSHOT
+
+ENVIRONMENT = DEVL