Fix ObjectFileWriter configuration for first file.

Previously, setters would only take effect for subsequently opened files.

Regarding `ObjectFileWriterCompressionTest`: It only passed due to file names automatically triggering the expected compression.

Author: blackwinter

metafacture-io/src/main/java/org/metafacture/io/ObjectFileWriter.java

@@ -46,7 +46,7 @@ public final class ObjectFileWriter<T> extends AbstractObjectWriter<T>  {
     private String path;
     private int count;
     private Writer writer;
-    private boolean firstObject;
+    private boolean firstObject = true;
     private boolean closed;
 
     private String encoding = "UTF-8";
@@ -59,12 +59,6 @@ public final class ObjectFileWriter<T> extends AbstractObjectWriter<T>  {
      */
     public ObjectFileWriter(final String path) {
         this.path = path;
-        startNewFile();
-
-        final Matcher matcher = VAR_PATTERN.matcher(this.path);
-        if (!matcher.find()) {
-            this.path = this.path + VAR;
-        }
     }
 
     @Override
@@ -97,13 +91,13 @@ public void process(final T obj) {
         assert !closed;
         try {
             if (firstObject) {
-                writer.write(getHeader());
+                getWriter().write(getHeader());
                 firstObject = false;
             }
             else {
-                writer.write(getSeparator());
+                getWriter().write(getSeparator());
             }
-            writer.write(obj.toString());
+            getWriter().write(obj.toString());
         }
         catch (final IOException e) {
             throw new MetafactureException(e);
@@ -112,20 +106,7 @@ public void process(final T obj) {
 
     @Override
     public void resetStream() {
-        if (!closed) {
-            try {
-                if (!firstObject) {
-                    writer.write(getFooter());
-                }
-                writer.close();
-            }
-            catch (final IOException e) {
-                throw new MetafactureException(e);
-            }
-            finally {
-                closed = true;
-            }
-        }
+        closeStream();
         startNewFile();
         ++count;
     }
@@ -135,9 +116,9 @@ public void closeStream() {
         if (!closed) {
             try {
                 if (!firstObject) {
-                    writer.write(getFooter());
+                    getWriter().write(getFooter());
                 }
-                writer.close();
+                getWriter().close();
             }
             catch (final IOException e) {
                 throw new MetafactureException(e);
@@ -175,4 +156,17 @@ private void startNewFile() {
         }
     }
 
+    private Writer getWriter() {
+        if (writer == null) {
+            startNewFile();
+
+            final Matcher matcher = VAR_PATTERN.matcher(this.path);
+            if (!matcher.find()) {
+                this.path = this.path + VAR;
+            }
+        }
+
+        return writer;
+    }
+
 }

metafacture-io/src/test/java/org/metafacture/io/ObjectFileWriterCompressionTest.java

@@ -47,6 +47,7 @@ public final class ObjectFileWriterCompressionTest {
     private static final String FILENAME_BZ2 = "compressed.txt.bz2";
     private static final String FILENAME_BZIP2 = "compressed.txt.bzip2";
     private static final String FILENAME_GZ = "compressed.txt.gz";
+    private static final String FILENAME_GZ_NOAUTO = "compressed.txt.gz.noauto";
     private static final String FILENAME_GZIP = "compressed.txt.gzip";
     private static final String FILENAME_XZ = "compressed.txt.xz";
 
@@ -76,11 +77,13 @@ public static Iterable<Object[]> data() {
                 { FILENAME_BZ2, FileCompression.AUTO, MAGIC_BYTES_BZIP2 },
                 { FILENAME_BZIP2, FileCompression.AUTO, MAGIC_BYTES_BZIP2 },
                 { FILENAME_GZ, FileCompression.AUTO, MAGIC_BYTES_GZIP },
+                { FILENAME_GZ_NOAUTO, FileCompression.AUTO, MAGIC_BYTES_NONE },
                 { FILENAME_GZIP, FileCompression.AUTO, MAGIC_BYTES_GZIP },
                 { FILENAME_XZ, FileCompression.AUTO, MAGIC_BYTES_XZ },
                 { FILENAME_NONE, FileCompression.NONE, MAGIC_BYTES_NONE },
                 { FILENAME_BZ2, FileCompression.BZIP2, MAGIC_BYTES_BZIP2 },
                 { FILENAME_GZ, FileCompression.GZIP, MAGIC_BYTES_GZIP },
+                { FILENAME_GZ_NOAUTO, FileCompression.GZIP, MAGIC_BYTES_GZIP },
                 { FILENAME_XZ, FileCompression.XZ, MAGIC_BYTES_XZ },
             });
     }