summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--integrity-audit/src/main/java/org/onap/policy/common/ia/AuditThread.java12
-rw-r--r--integrity-audit/src/main/java/org/onap/policy/common/ia/DbAudit.java8
-rw-r--r--integrity-audit/src/main/java/org/onap/policy/common/ia/DbDAO.java21
-rw-r--r--integrity-audit/src/main/java/org/onap/policy/common/ia/IntegrityAudit.java15
-rw-r--r--integrity-audit/src/main/java/org/onap/policy/common/ia/IntegrityAuditException.java17
-rw-r--r--integrity-audit/src/main/java/org/onap/policy/common/ia/IntegrityAuditProperties.java6
-rw-r--r--integrity-audit/src/main/java/org/onap/policy/common/ia/jpa/IntegrityAuditEntity.java12
-rw-r--r--integrity-audit/src/test/java/org/onap/policy/common/ia/test/AuditPeriodTest.java2
-rw-r--r--integrity-audit/src/test/java/org/onap/policy/common/ia/test/DbAuditCompareEntriesTest.java4
-rw-r--r--integrity-audit/src/test/java/org/onap/policy/common/ia/test/DbAuditTest.java4
-rw-r--r--integrity-audit/src/test/java/org/onap/policy/common/ia/test/IntegrityAuditDesignationTest.java2
11 files changed, 67 insertions, 36 deletions
diff --git a/integrity-audit/src/main/java/org/onap/policy/common/ia/AuditThread.java b/integrity-audit/src/main/java/org/onap/policy/common/ia/AuditThread.java
index e7e16a64..2e15da5f 100644
--- a/integrity-audit/src/main/java/org/onap/policy/common/ia/AuditThread.java
+++ b/integrity-audit/src/main/java/org/onap/policy/common/ia/AuditThread.java
@@ -26,7 +26,6 @@ import java.util.Comparator;
import java.util.Date;
import java.util.List;
import java.util.Properties;
-//import org.apache.log4j.Logger;
import org.onap.policy.common.ia.jpa.IntegrityAuditEntity;
@@ -146,8 +145,8 @@ public class AuditThread extends Thread {
DbAudit dbAudit = new DbAudit(dbDAO);
- IntegrityAuditEntity entityCurrentlyDesignated = null;
- IntegrityAuditEntity thisEntity = null;
+ IntegrityAuditEntity entityCurrentlyDesignated;
+ IntegrityAuditEntity thisEntity;
integrityAudit.setThreadInitialized(true); // An exception will set
// it to false
@@ -702,7 +701,7 @@ public class AuditThread extends Thread {
+ thisEntity.getLastUpdated());
}
- long timeDifference = -1;
+ long timeDifference;
Date currentTime = new Date();
Date lastUpdated = thisEntity.getLastUpdated();
@@ -752,9 +751,8 @@ public class AuditThread extends Thread {
+ this.persistenceUnit + " on resourceName="
+ this.resourceName);
}
- if (IntegrityAudit.isUnitTesting) {
- dbAudit.dbAuditSimulate(this.resourceName, this.persistenceUnit,
- this.nodeType);
+ if (IntegrityAudit.isUnitTesting()) {
+ dbAudit.dbAuditSimulate(this.resourceName, this.persistenceUnit);
} else {
dbAudit.dbAudit(this.resourceName, this.persistenceUnit,
this.nodeType);
diff --git a/integrity-audit/src/main/java/org/onap/policy/common/ia/DbAudit.java b/integrity-audit/src/main/java/org/onap/policy/common/ia/DbAudit.java
index 8312daa3..8a1a521b 100644
--- a/integrity-audit/src/main/java/org/onap/policy/common/ia/DbAudit.java
+++ b/integrity-audit/src/main/java/org/onap/policy/common/ia/DbAudit.java
@@ -33,7 +33,6 @@ import org.apache.commons.lang3.SerializationUtils;
import org.apache.commons.lang3.builder.RecursiveToStringStyle;
import org.apache.commons.lang3.builder.ReflectionToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle;
-//import org.apache.log4j.Logger;
@@ -140,7 +139,7 @@ public class DbAudit {
* This is the map of mismatched entries indexed by className. For
* each class name there is a list of mismatched entries
*/
- HashMap<String,HashSet<Object>> misMatchedMap = new HashMap<String,HashSet<Object>>();
+ HashMap<String,HashSet<Object>> misMatchedMap = new HashMap<>();
// We need to keep track of how long the audit is taking
long startTime = System.currentTimeMillis();
@@ -350,8 +349,7 @@ public class DbAudit {
* @throws InterruptedException
* @throws DbDaoTransactionException
*/
- public void dbAuditSimulate(String resourceName, String persistenceUnit,
- String nodeType) throws InterruptedException,
+ public void dbAuditSimulate(String resourceName, String persistenceUnit) throws InterruptedException,
DbDaoTransactionException {
logger.info("dbAuditSimulate: Starting audit simulation for resourceName="
@@ -386,7 +384,7 @@ public class DbAudit {
* it is currently working on.
*
*/
- HashSet<Object> misMatchedKeySet = new HashSet<Object>();
+ HashSet<Object> misMatchedKeySet = new HashSet<>();
for(Object key: myEntries.keySet()){
byte[] mySerializedEntry = SerializationUtils.serialize((Serializable) myEntries.get(key));
byte[] theirSerializedEntry = SerializationUtils.serialize((Serializable) theirEntries.get(key));
diff --git a/integrity-audit/src/main/java/org/onap/policy/common/ia/DbDAO.java b/integrity-audit/src/main/java/org/onap/policy/common/ia/DbDAO.java
index 0db43bbc..20132ae1 100644
--- a/integrity-audit/src/main/java/org/onap/policy/common/ia/DbDAO.java
+++ b/integrity-audit/src/main/java/org/onap/policy/common/ia/DbDAO.java
@@ -40,7 +40,6 @@ import javax.persistence.criteria.Root;
import javax.persistence.metamodel.ManagedType;
import javax.persistence.metamodel.Metamodel;
-//import org.apache.log4j.Logger;
import org.onap.policy.common.ia.jpa.IntegrityAuditEntity;
import org.onap.policy.common.logging.flexlogger.FlexLogger;
@@ -125,7 +124,7 @@ public class DbDAO {
public HashMap<Object, Object> getAllMyEntries(String className) {
logger.debug("getAllMyEntries: Entering, className="
+ className);
- HashMap<Object, Object> resultMap = new HashMap<Object,Object>();
+ HashMap<Object, Object> resultMap = new HashMap<>();
EntityManager em = emf.createEntityManager();
try{
CriteriaBuilder cb = em.getCriteriaBuilder();
@@ -162,7 +161,7 @@ public class DbDAO {
logger.debug("getAllMyEntries: Entering, className="
+ className + ",\n keySet=" + keySet);
- HashMap<Object, Object> resultMap = new HashMap<Object,Object>();
+ HashMap<Object, Object> resultMap = new HashMap<>();
EntityManager em = emf.createEntityManager();
try{
Class<?> clazz = Class.forName(className);
@@ -193,7 +192,7 @@ public class DbDAO {
logger.debug("getAllEntries: Entering, persistenceUnit="
+ persistenceUnit + ",\n className=" + className);
- HashMap<Object, Object> resultMap = new HashMap<Object,Object>();
+ HashMap<Object, Object> resultMap = new HashMap<>();
EntityManagerFactory theEmf = Persistence.createEntityManagerFactory(persistenceUnit, properties);
EntityManager em = theEmf.createEntityManager();
@@ -238,7 +237,7 @@ public class DbDAO {
+ persistenceUnit + ",\n properties= " + properties + ",\n className=" + className + ",\n keySet= " + keySet);
EntityManagerFactory theEmf = Persistence.createEntityManagerFactory(persistenceUnit, properties);
EntityManager em = theEmf.createEntityManager();
- HashMap<Object, Object> resultMap = new HashMap<Object,Object>();
+ HashMap<Object, Object> resultMap = new HashMap<>();
try{
Class<?> clazz = Class.forName(className);
for(Object key : keySet){
@@ -386,7 +385,7 @@ public class DbDAO {
*/
public HashSet<String> getPersistenceClassNames(){
logger.debug("DbDAO: getPersistenceClassNames() entry");
- HashSet<String> returnList = new HashSet<String>();
+ HashSet<String> returnList = new HashSet<>();
final Metamodel mm = emf.getMetamodel();
logger.debug("\n" + persistenceUnit +" persistence unit classes:");
for (final ManagedType<?> managedType : mm.getManagedTypes()) {
@@ -417,7 +416,7 @@ public class DbDAO {
@SuppressWarnings("rawtypes")
List iaeList = iaequery.getResultList();
- IntegrityAuditEntity iae = null;
+ IntegrityAuditEntity iae;
//If it already exists, we just want to update the properties and lastUpdated date
if(!iaeList.isEmpty()){
@@ -453,7 +452,7 @@ public class DbDAO {
et.commit();
em.close();
}catch (Exception e){
- String msg = "DbDAO: " + "register() " + "ecountered a problem in execution: ";
+ String msg = "DbDAO: " + "register() " + "encountered a problem in execution: ";
logger.error(msg + e);
System.out.println(new Date());
e.printStackTrace();
@@ -486,7 +485,7 @@ public class DbDAO {
@SuppressWarnings("rawtypes")
List iaeList = iaequery.getResultList();
- IntegrityAuditEntity iae = null;
+ IntegrityAuditEntity iae;
if(!iaeList.isEmpty()){
//ignores multiple results
@@ -539,7 +538,7 @@ public class DbDAO {
@SuppressWarnings("rawtypes")
List iaeList = iaequery.getResultList();
- IntegrityAuditEntity iae = null;
+ IntegrityAuditEntity iae;
if(!iaeList.isEmpty()){
//ignores multiple results
@@ -582,7 +581,7 @@ public class DbDAO {
try{
- if (!IntegrityAudit.isUnitTesting) {
+ if (!IntegrityAudit.isUnitTesting()) {
String msg = "DbDAO: " + "deleteAllIntegrityAuditEntities() " + "should only be invoked during JUnit testing";
logger.error(msg);
throw new DbDaoTransactionException(msg);
diff --git a/integrity-audit/src/main/java/org/onap/policy/common/ia/IntegrityAudit.java b/integrity-audit/src/main/java/org/onap/policy/common/ia/IntegrityAudit.java
index 5ec6229c..50fc6932 100644
--- a/integrity-audit/src/main/java/org/onap/policy/common/ia/IntegrityAudit.java
+++ b/integrity-audit/src/main/java/org/onap/policy/common/ia/IntegrityAudit.java
@@ -22,7 +22,6 @@ package org.onap.policy.common.ia;
import java.util.Properties;
-//import org.apache.log4j.Logger;
import org.onap.policy.common.ia.IntegrityAuditProperties.NodeTypeEnum;
import org.onap.policy.common.logging.flexlogger.FlexLogger;
@@ -36,7 +35,7 @@ public class IntegrityAudit {
private static final Logger logger = FlexLogger.getLogger(IntegrityAudit.class);
- public static boolean isUnitTesting;
+ private static boolean isUnitTesting;
private boolean isThreadInitialized = false;
AuditThread auditThread = null;
@@ -65,7 +64,7 @@ public class IntegrityAudit {
* @param properties
* @throws Exception
*/
- public IntegrityAudit(String resourceName, String persistenceUnit, Properties properties) throws Exception {
+ public IntegrityAudit(String resourceName, String persistenceUnit, Properties properties) throws IntegrityAuditException {
logger.info("Constructor: Entering and checking for nulls");
String parmList = "";
@@ -73,7 +72,7 @@ public class IntegrityAudit {
logger.error("Constructor: Parms contain nulls; cannot run audit for resourceName="
+ resourceName + ", persistenceUnit=" + persistenceUnit
+ ", bad parameters: " + parmList);
- throw new Exception(
+ throw new IntegrityAuditException(
"Constructor: Parms contain nulls; cannot run audit for resourceName="
+ resourceName + ", persistenceUnit="
+ persistenceUnit
@@ -238,4 +237,12 @@ public class IntegrityAudit {
logger.info("setThreadInitialized: Setting isThreadInitialized=" + isThreadInitialized);
this.isThreadInitialized = isThreadInitialized;
}
+
+ public static boolean isUnitTesting() {
+ return isUnitTesting;
+ }
+
+ public static void setUnitTesting(boolean isUnitTesting) {
+ IntegrityAudit.isUnitTesting = isUnitTesting;
+ }
}
diff --git a/integrity-audit/src/main/java/org/onap/policy/common/ia/IntegrityAuditException.java b/integrity-audit/src/main/java/org/onap/policy/common/ia/IntegrityAuditException.java
new file mode 100644
index 00000000..4068ffe2
--- /dev/null
+++ b/integrity-audit/src/main/java/org/onap/policy/common/ia/IntegrityAuditException.java
@@ -0,0 +1,17 @@
+package org.onap.policy.common.ia;
+
+public class IntegrityAuditException extends Exception{
+ private static final long serialVersionUID = 1L;
+ public IntegrityAuditException() {
+ }
+ public IntegrityAuditException(String message) {
+ super(message);
+ }
+
+ public IntegrityAuditException(Throwable cause) {
+ super(cause);
+ }
+ public IntegrityAuditException(String message, Throwable cause) {
+ super(message, cause);
+ }
+}
diff --git a/integrity-audit/src/main/java/org/onap/policy/common/ia/IntegrityAuditProperties.java b/integrity-audit/src/main/java/org/onap/policy/common/ia/IntegrityAuditProperties.java
index 3f87cf26..d0781e9c 100644
--- a/integrity-audit/src/main/java/org/onap/policy/common/ia/IntegrityAuditProperties.java
+++ b/integrity-audit/src/main/java/org/onap/policy/common/ia/IntegrityAuditProperties.java
@@ -38,7 +38,7 @@ public class IntegrityAuditProperties {
public static final String SITE_NAME = "site_name";
public static final String NODE_TYPE = "node_type";
- public static enum NodeTypeEnum {
+ public enum NodeTypeEnum {
pdp_xacml,
pdp_drools,
pap,
@@ -51,4 +51,8 @@ public class IntegrityAuditProperties {
}
+ private IntegrityAuditProperties() {
+
+ }
+
}
diff --git a/integrity-audit/src/main/java/org/onap/policy/common/ia/jpa/IntegrityAuditEntity.java b/integrity-audit/src/main/java/org/onap/policy/common/ia/jpa/IntegrityAuditEntity.java
index 2b68a51d..50e25159 100644
--- a/integrity-audit/src/main/java/org/onap/policy/common/ia/jpa/IntegrityAuditEntity.java
+++ b/integrity-audit/src/main/java/org/onap/policy/common/ia/jpa/IntegrityAuditEntity.java
@@ -49,7 +49,7 @@ import javax.persistence.TemporalType;
public class IntegrityAuditEntity implements Serializable {
private static final long serialVersionUID = 1L;
- public static boolean isUnitTesting;
+ private static boolean isUnitTesting;
@Id
@GeneratedValue(strategy = GenerationType.AUTO)
@@ -104,7 +104,7 @@ public class IntegrityAuditEntity implements Serializable {
@PreUpdate
public void preUpdate() {
- if (!isUnitTesting) {
+ if (!isUnitTesting()) {
this.lastUpdated = new Date();
}
}
@@ -200,4 +200,12 @@ public class IntegrityAuditEntity implements Serializable {
public void setCreatedDate(Date created) {
this.createdDate = created;
}
+
+ public static boolean isUnitTesting() {
+ return isUnitTesting;
+ }
+
+ public static void setUnitTesting(boolean isUnitTesting) {
+ IntegrityAuditEntity.isUnitTesting = isUnitTesting;
+ }
}
diff --git a/integrity-audit/src/test/java/org/onap/policy/common/ia/test/AuditPeriodTest.java b/integrity-audit/src/test/java/org/onap/policy/common/ia/test/AuditPeriodTest.java
index 52f847cf..848f6706 100644
--- a/integrity-audit/src/test/java/org/onap/policy/common/ia/test/AuditPeriodTest.java
+++ b/integrity-audit/src/test/java/org/onap/policy/common/ia/test/AuditPeriodTest.java
@@ -74,7 +74,7 @@ public class AuditPeriodTest {
logger.info("setUp: Entering");
- IntegrityAudit.isUnitTesting = true;
+ IntegrityAudit.setUnitTesting(true);
properties = new Properties();
properties.put(IntegrityAuditProperties.DB_DRIVER, IntegrityAuditProperties.DEFAULT_DB_DRIVER);
diff --git a/integrity-audit/src/test/java/org/onap/policy/common/ia/test/DbAuditCompareEntriesTest.java b/integrity-audit/src/test/java/org/onap/policy/common/ia/test/DbAuditCompareEntriesTest.java
index 8a811366..c41803a8 100644
--- a/integrity-audit/src/test/java/org/onap/policy/common/ia/test/DbAuditCompareEntriesTest.java
+++ b/integrity-audit/src/test/java/org/onap/policy/common/ia/test/DbAuditCompareEntriesTest.java
@@ -80,7 +80,7 @@ public class DbAuditCompareEntriesTest {
logger.info("setUp: Entering");
- IntegrityAudit.isUnitTesting = true;
+ IntegrityAudit.setUnitTesting(true);
properties = new Properties();
properties.put(IntegrityAuditProperties.DB_DRIVER, IntegrityAuditProperties.DEFAULT_DB_DRIVER);
@@ -446,7 +446,7 @@ public class DbAuditCompareEntriesTest {
logger.info("Setting up DB");
- IntegrityAudit.isUnitTesting = true;
+ IntegrityAudit.setUnitTesting(true);
properties = new Properties();
properties.put(IntegrityAuditProperties.DB_DRIVER, IntegrityAuditProperties.DEFAULT_DB_DRIVER);
diff --git a/integrity-audit/src/test/java/org/onap/policy/common/ia/test/DbAuditTest.java b/integrity-audit/src/test/java/org/onap/policy/common/ia/test/DbAuditTest.java
index fd1172a8..e2aa9988 100644
--- a/integrity-audit/src/test/java/org/onap/policy/common/ia/test/DbAuditTest.java
+++ b/integrity-audit/src/test/java/org/onap/policy/common/ia/test/DbAuditTest.java
@@ -113,8 +113,8 @@ public class DbAuditTest {
logger.info("setUp: Entering");
- IntegrityAudit.isUnitTesting = true;
- IntegrityAuditEntity.isUnitTesting = true;
+ IntegrityAudit.setUnitTesting(true);
+ IntegrityAuditEntity.setUnitTesting(true);
properties = new Properties();
properties.put(IntegrityAuditProperties.DB_DRIVER, IntegrityAuditProperties.DEFAULT_DB_DRIVER);
diff --git a/integrity-audit/src/test/java/org/onap/policy/common/ia/test/IntegrityAuditDesignationTest.java b/integrity-audit/src/test/java/org/onap/policy/common/ia/test/IntegrityAuditDesignationTest.java
index f74b354b..91371b96 100644
--- a/integrity-audit/src/test/java/org/onap/policy/common/ia/test/IntegrityAuditDesignationTest.java
+++ b/integrity-audit/src/test/java/org/onap/policy/common/ia/test/IntegrityAuditDesignationTest.java
@@ -79,7 +79,7 @@ public class IntegrityAuditDesignationTest {
logger.info("setUp: Entering");
- IntegrityAudit.isUnitTesting = true;
+ IntegrityAudit.setUnitTesting(true);
properties = new Properties();
properties.put(IntegrityAuditProperties.DB_DRIVER, IntegrityAuditProperties.DEFAULT_DB_DRIVER);