Test clean csv string

Author: blootsvoets

src/main/java/org/radarcns/hdfs/data/CsvAvroConverter.java

@@ -274,7 +274,7 @@ private void checkHeader(String prefix, int size) {
 
     static String cleanCsvString(String orig) {
         if (ESCAPE_PATTERN.matcher(orig).find()) {
-            String cleaned = LINE_ENDING_PATTERN.matcher(orig).replaceAll("\\n");
+            String cleaned = LINE_ENDING_PATTERN.matcher(orig).replaceAll("\\\\n");
             cleaned = TAB_PATTERN.matcher(cleaned).replaceAll("    ");
             cleaned = NON_PRINTING_PATTERN.matcher(cleaned).replaceAll("?");
             if (QUOTE_OR_COMMA_PATTERN.matcher(cleaned).find()) {

src/test/java/org/radarcns/hdfs/data/CsvAvroConverterTest.java

@@ -60,6 +60,7 @@
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertNull;
 import static org.junit.Assert.assertTrue;
+import static org.radarcns.hdfs.data.CsvAvroConverter.cleanCsvString;
 
 public class CsvAvroConverterTest {
     @Rule
@@ -231,4 +232,15 @@ public void parseCsvLine() throws IOException {
             assertEquals(Arrays.asList("a", "b", "ba\"ca", "\"da\""), headers);
         }
     }
+
+    @Test
+    public void cleanString() {
+        assertEquals("test", cleanCsvString("test"));
+        assertEquals("", cleanCsvString(""));
+        assertEquals("\"\"\"\"", cleanCsvString("\""));
+        assertEquals("    test", cleanCsvString("\ttest"));
+        assertEquals("test\\n", cleanCsvString("test\r\n"));
+        assertEquals("test?", cleanCsvString("test\b"));
+        assertEquals("\"test,\"", cleanCsvString("test,"));
+    }
 }