GridFS Upload Problem with 4.2 driver found

Author: sfxcode

CHANGES.md

@@ -3,6 +3,9 @@
 
 ## Versions
 
+### 2.2.3
+* rollback to mongo-scala-driver [4.1.2](https://mongodb.github.io/mongo-java-driver/4.2/driver-scala/) because of critical bug in GridFS Upload
+
 ### 2.2.2
 * mongo-scala-driver [4.2.3](https://mongodb.github.io/mongo-java-driver/4.2/driver-scala/)
 

build.sbt

@@ -55,7 +55,7 @@ libraryDependencies += "joda-time" % "joda-time" % "2.10.10" % Test
 
 libraryDependencies += "org.json4s" %% "json4s-native" % "3.6.11" % Test
 
-libraryDependencies += "org.mongodb.scala" %% "mongo-scala-driver" % "4.2.3"
+libraryDependencies += "org.mongodb.scala" %% "mongo-scala-driver" % "4.1.2"
 
 libraryDependencies += "org.xerial.snappy" % "snappy-java" % "1.1.8.4" % Provided
 

src/test/scala/com/sfxcode/nosql/mongo/gridfs/GridFSDatabaseSpec.scala

@@ -8,6 +8,8 @@ import org.bson.types.ObjectId
 import org.specs2.mutable.Specification
 import org.specs2.specification.BeforeAll
 
+import scala.io.Source
+
 class GridFSDatabaseSpec extends Specification with GridfsDatabaseFunctions with BeforeAll {
 
   "GridFSDatabase" should {
@@ -20,12 +22,12 @@ class GridFSDatabaseSpec extends Specification with GridfsDatabaseFunctions with
 
     }
 
-
-
     "insert file and in" in {
       val fileName = "scala-logo.png"
 
-      val oid: ObjectId = insertImage(ImageDAOSourcePath + fileName, ImageMetadata("template1", group = "templates"))
+      val filePath      = ImageDAOSourcePath + fileName
+      val oid: ObjectId = insertImage(filePath, ImageMetadata("template1", group = "templates"))
+      val uploadBytes   = File(filePath).bytes.toList
 
       val file = findImage(oid)
       file.getFilename must be equalTo fileName
@@ -39,7 +41,14 @@ class GridFSDatabaseSpec extends Specification with GridfsDatabaseFunctions with
 
       result must not be equalTo(-1)
 
-      File(downloadPath).exists must beTrue
+      val downloadedFile = File(downloadPath)
+      downloadedFile.exists must beTrue
+
+      val downloadBytes = File(downloadPath).bytes.toList
+
+      downloadBytes.size must be equalTo uploadBytes.size
+
+      downloadBytes must be equalTo uploadBytes
 
     }