- * @author Rajiv Singla . Creation Date: 10/19/2016. - */ -abstract class BaseDCAEAnalyticsCommonTest { - - protected static final Logger LOG = LoggerFactory.getLogger(BaseDCAEAnalyticsCommonTest.class); - - /** - * Asserts if expected Json String and actual Json String contain the same properties ignoring - * property order. Simple String assertion might fail as property order during serialization and deserialization - * is generally non-deterministic. Also proper error message are generated more missing or unexpected - * properties - * - * @param expectedJsonString expected Json String - * @param actualJsonString actual Json String - * @throws JSONException Json Exception - */ - public static void assertJson(String expectedJsonString, String actualJsonString) throws JSONException { - JSONAssert.assertEquals(expectedJsonString, actualJsonString, true); - } - - /** - * Converts given file location to String - * - * @param fileLocation location of the file which needs to be converted to String - * @return Contents of file as string - * @throws IOException IOException - */ - public static String fromStream(String fileLocation) throws IOException { - final InputStream jsonFileInputStream = - BaseDCAEAnalyticsCommonTest.class.getClassLoader().getResourceAsStream(fileLocation); - Assert.assertNotNull("Json File Location must be valid", jsonFileInputStream); - try (BufferedReader reader = - new BufferedReader(new InputStreamReader(jsonFileInputStream, Charset.forName("UTF-8")))) { - final StringBuilder result = new StringBuilder(); - final String newLine = System.getProperty("line.separator"); - String line = reader.readLine(); - while (line != null) { - result.append(line) - .append(newLine); - line = reader.readLine(); - } - jsonFileInputStream.close(); - return result.toString(); - } - } - - - /** - * Checks if object can be serialized properly - * - * @param object input object - * @param callingClass calling class - * @throws IOException IOException - */ - public static void testSerialization(Object object, Class callingClass) throws IOException { - final URL location = callingClass.getProtectionDomain().getCodeSource().getLocation(); - final File serializedOutputFile = - new File(location.getPath() + String.format("serialization/%s.ser", object.getClass().getSimpleName())); - - // Maybe file already try deleting it first - final boolean deleteIfExists = deleteIfExists(Paths.get(serializedOutputFile.getPath())); - - if (deleteIfExists) { - LOG.warn("Previous serialization file was overwritten at location: {}", serializedOutputFile.getPath()); - } - - boolean mkdirs = true; - if (!exists(Paths.get(serializedOutputFile.getParentFile().getPath()))) { - mkdirs = serializedOutputFile.getParentFile().mkdirs(); - } - if (mkdirs) { - try (FileOutputStream fileOutputStream = new FileOutputStream(serializedOutputFile); - ObjectOutputStream objectOutputStream = new ObjectOutputStream(fileOutputStream)) { - objectOutputStream.writeObject(object); - LOG.debug("Successfully created serialization file at location: {}", serializedOutputFile.getPath()); - } - } else { - throw new IllegalStateException( - String.format("Failed to create location to store serialization file: %s", - serializedOutputFile)); - } - } - - /** - * Writes Text to Output file - * - * @param textFileLocation - location of text file e.g. textfiles/fileName.json - * @param content - file content - * @param callingClass - calling class - * @throws IOException - ioException - */ - public static void writeToOutputTextFile(String textFileLocation, String content, Class callingClass) throws - IOException { - final URL location = callingClass.getProtectionDomain().getCodeSource().getLocation(); - final File fileLocation = new File(location.getPath() + textFileLocation); - - // Maybe file already try deleting it first - final boolean deleteIfExists = deleteIfExists(Paths.get(fileLocation.getPath())); - - if (deleteIfExists) { - LOG.warn("Previous file will be overwritten at location: {}", fileLocation.getPath()); - } - - boolean mkdirs = true; - if (!exists(Paths.get(fileLocation.getParentFile().getPath()))) { - mkdirs = fileLocation.getParentFile().mkdirs(); - } - if (mkdirs) { - try ( - FileOutputStream fileOutputStream = new FileOutputStream(fileLocation); - OutputStreamWriter outputStream = - new OutputStreamWriter(fileOutputStream, Charset.forName("UTF-8"))) { - outputStream.write(content); - LOG.debug("Successfully created text file at location: {}", fileLocation.getPath()); - } - } else { - throw new IllegalStateException( - String.format("Failed to create location to store text file: %s", fileLocation)); - } - - } - - - /** - * For testing purposes only we may sometime we may want to access private fields of underlying - * object to confirm the values are setup correctly. - *
- * This method uses java reflection to get the value to private object in the class
- *
- * @param object Actual object which has the private field you want to check
- * @param fieldName Field name in the Actual Object you want to get the value of
- * @param privateFieldClass Type of the private field
- * @param
+ * @author Rajiv Singla . Creation Date: 10/19/2016.
+ */
+abstract class BaseDCAEAnalyticsCommonTest {
+
+ protected static final Logger LOG = LoggerFactory.getLogger(BaseDCAEAnalyticsCommonTest.class);
+
+ /**
+ * Asserts if expected Json String and actual Json String contain the same properties ignoring
+ * property order. Simple String assertion might fail as property order during serialization and deserialization
+ * is generally non-deterministic. Also proper error message are generated more missing or unexpected
+ * properties
+ *
+ * @param expectedJsonString expected Json String
+ * @param actualJsonString actual Json String
+ * @throws JSONException Json Exception
+ */
+ public static void assertJson(String expectedJsonString, String actualJsonString) throws JSONException {
+ JSONAssert.assertEquals(expectedJsonString, actualJsonString, true);
+ }
+
+ /**
+ * Converts given file location to String
+ *
+ * @param fileLocation location of the file which needs to be converted to String
+ * @return Contents of file as string
+ * @throws IOException IOException
+ */
+ public static String fromStream(String fileLocation) throws IOException {
+ final InputStream jsonFileInputStream =
+ BaseDCAEAnalyticsCommonTest.class.getClassLoader().getResourceAsStream(fileLocation);
+ Assert.assertNotNull("Json File Location must be valid", jsonFileInputStream);
+ try (BufferedReader reader =
+ new BufferedReader(new InputStreamReader(jsonFileInputStream, Charset.forName("UTF-8")))) {
+ final StringBuilder result = new StringBuilder();
+ final String newLine = System.getProperty("line.separator");
+ String line = reader.readLine();
+ while (line != null) {
+ result.append(line)
+ .append(newLine);
+ line = reader.readLine();
+ }
+ jsonFileInputStream.close();
+ return result.toString();
+ }
+ }
+
+
+ /**
+ * Checks if object can be serialized properly
+ *
+ * @param object input object
+ * @param callingClass calling class
+ * @throws IOException IOException
+ */
+ public static void testSerialization(Object object, Class callingClass) throws IOException {
+ final URL location = callingClass.getProtectionDomain().getCodeSource().getLocation();
+ final File serializedOutputFile =
+ new File(location.getPath() + String.format("serialization/%s.ser", object.getClass().getSimpleName()));
+
+ // Maybe file already try deleting it first
+ final boolean deleteIfExists = deleteIfExists(Paths.get(serializedOutputFile.getPath()));
+
+ if (deleteIfExists) {
+ LOG.warn("Previous serialization file was overwritten at location: {}", serializedOutputFile.getPath());
+ }
+
+ boolean mkdirs = true;
+ if (!exists(Paths.get(serializedOutputFile.getParentFile().getPath()))) {
+ mkdirs = serializedOutputFile.getParentFile().mkdirs();
+ }
+ if (mkdirs) {
+ try (FileOutputStream fileOutputStream = new FileOutputStream(serializedOutputFile);
+ ObjectOutputStream objectOutputStream = new ObjectOutputStream(fileOutputStream)) {
+ objectOutputStream.writeObject(object);
+ LOG.debug("Successfully created serialization file at location: {}", serializedOutputFile.getPath());
+ }
+ } else {
+ throw new IllegalStateException(
+ String.format("Failed to create location to store serialization file: %s",
+ serializedOutputFile));
+ }
+ }
+
+ /**
+ * Writes Text to Output file
+ *
+ * @param textFileLocation - location of text file e.g. textfiles/fileName.json
+ * @param content - file content
+ * @param callingClass - calling class
+ * @throws IOException - ioException
+ */
+ public static void writeToOutputTextFile(String textFileLocation, String content, Class callingClass) throws
+ IOException {
+ final URL location = callingClass.getProtectionDomain().getCodeSource().getLocation();
+ final File fileLocation = new File(location.getPath() + textFileLocation);
+
+ // Maybe file already try deleting it first
+ final boolean deleteIfExists = deleteIfExists(Paths.get(fileLocation.getPath()));
+
+ if (deleteIfExists) {
+ LOG.warn("Previous file will be overwritten at location: {}", fileLocation.getPath());
+ }
+
+ boolean mkdirs = true;
+ if (!exists(Paths.get(fileLocation.getParentFile().getPath()))) {
+ mkdirs = fileLocation.getParentFile().mkdirs();
+ }
+ if (mkdirs) {
+ try (
+ FileOutputStream fileOutputStream = new FileOutputStream(fileLocation);
+ OutputStreamWriter outputStream =
+ new OutputStreamWriter(fileOutputStream, Charset.forName("UTF-8"))) {
+ outputStream.write(content);
+ LOG.debug("Successfully created text file at location: {}", fileLocation.getPath());
+ }
+ } else {
+ throw new IllegalStateException(
+ String.format("Failed to create location to store text file: %s", fileLocation));
+ }
+
+ }
+
+
+ /**
+ * For testing purposes only we may sometime we may want to access private fields of underlying
+ * object to confirm the values are setup correctly.
+ *
+ * This method uses java reflection to get the value to private object in the class
+ *
+ * @param object Actual object which has the private field you want to check
+ * @param fieldName Field name in the Actual Object you want to get the value of
+ * @param privateFieldClass Type of the private field
+ * @param