[Java-475] GridFSInput constructors are now protected access

Additionally added GridFSInput.createChunk() method

Author: breinero-zz

src/main/com/mongodb/gridfs/GridFSInputFile.java

@@ -56,7 +56,7 @@ public class GridFSInputFile extends GridFSFile {
      * @param closeStreamOnPersist
                   indicate the passed in input stream should be closed once the data chunk persisted
      */
-    GridFSInputFile( GridFS fs , InputStream in , String filename, boolean closeStreamOnPersist ) {
+    protected GridFSInputFile( GridFS fs , InputStream in , String filename, boolean closeStreamOnPersist ) {
         _fs = fs;
         _in = in;
         _filename = filename;
@@ -81,7 +81,7 @@ public class GridFSInputFile extends GridFSFile {
      * @param filename
      *            Name of the file to be created.
      */
-    GridFSInputFile( GridFS fs , InputStream in , String filename ) {
+    protected GridFSInputFile( GridFS fs , InputStream in , String filename ) {
         this( fs, in, filename, false);
     }
 
@@ -96,7 +96,7 @@ public class GridFSInputFile extends GridFSFile {
      * @param filename
      *            Name of the file to be created.
      */
-    GridFSInputFile( GridFS fs , String filename ) {
+    protected GridFSInputFile( GridFS fs , String filename ) {
         this( fs , null , filename );
     }
 
@@ -108,7 +108,7 @@ public class GridFSInputFile extends GridFSFile {
      * @param fs
      *            The GridFS connection handle.
      */
-    GridFSInputFile( GridFS fs ) {
+    protected GridFSInputFile( GridFS fs ) {
         this( fs , null , null );
     }
 
@@ -271,10 +271,7 @@ private void _dumpBuffer( boolean writePartial ) {
             System.arraycopy( _buffer, 0, writeBuffer, 0, _currentBufferPosition );
         }
 
-        DBObject chunk = BasicDBObjectBuilder.start()
-                .add( "files_id", _id )
-                .add( "n", _currentChunkNumber )
-                .add( "data", writeBuffer ).get();
+        DBObject chunk = createChunk(_id, _currentChunkNumber, writeBuffer);
 
         _fs._chunkCollection.save( chunk );
 
@@ -283,6 +280,13 @@ private void _dumpBuffer( boolean writePartial ) {
         _messageDigester.update( writeBuffer );
         _currentBufferPosition = 0;
     }
+    
+    protected DBObject createChunk(Object id, int currentChunkNumber, byte[] writeBuffer) {
+         return BasicDBObjectBuilder.start()
+         .add("files_id", id)
+         .add("n", currentChunkNumber)
+         .add("data", writeBuffer).get();
+    }
 
     /**
      * Reads a buffer full from the {@link java.io.InputStream}.