fix: pagination aggregation should always use the RAW-DAO

Author: Simon Siedler

src/main/scala/dev/mongocamp/driver/mongodb/pagination/MongoPaginatedAggregation.scala

@@ -12,7 +12,8 @@ import scala.jdk.CollectionConverters._
 case class MongoPaginatedAggregation[A <: Any](
     dao: MongoDAO[A],
     aggregationPipeline: List[Bson] = List(),
-    allowDiskUse: Boolean = false
+    allowDiskUse: Boolean = false,
+    maxWait: Int = DefaultMaxWait
 ) extends MongoPagination[Document] {
 
   private val AggregationKeyMetaData      = "metadata"
@@ -37,7 +38,7 @@ case class MongoPaginatedAggregation[A <: Any](
         Aggregates.facet(new Facet(AggregationKeyMetaData, listOfMetaData.asJava), new Facet(AggregationKeyData, listOfPaging.asJava))
       )
 
-    val dbResponse = dao.findAggregated(pipeline, allowDiskUse).result().asInstanceOf[Document]
+    val dbResponse = dao.Raw.findAggregated(pipeline, allowDiskUse).result(maxWait)
 
     val count: Long = dbResponse.get(AggregationKeyMetaData).get.asArray().get(0).asDocument().get(AggregationKeyMetaDataTotal).asNumber().longValue()
     val allPages    = Math.ceil(count.toDouble / rows).toInt
@@ -52,7 +53,7 @@ case class MongoPaginatedAggregation[A <: Any](
     val pipeline = aggregationPipeline ++ List(
       Aggregates.facet(new Facet(AggregationKeyMetaData, listOfMetaData.asJava), new Facet(AggregationKeyData, listOfPaging.asJava))
     )
-    val dbResponse  = dao.findAggregated(pipeline, allowDiskUse).result().asInstanceOf[Document]
+    val dbResponse  = dao.Raw.findAggregated(pipeline, allowDiskUse).result(maxWait)
     val count: Long = dbResponse.get(AggregationKeyMetaData).get.asArray().get(0).asDocument().get(AggregationKeyMetaDataTotal).asNumber().longValue()
     count
   }

src/test/scala/dev/mongocamp/driver/mongodb/pagination/PaginationFilterSpec.scala

@@ -34,7 +34,7 @@ class PaginationFilterSpec extends PersonSpecification with MongoImplicits {
       val pageFemale = paginationFemale.paginate(1, 10)
       // #endregion filter-pagination
 
-      paginationFemale.countResult mustEqual 11
+      paginationFemale.countResult mustEqual 98
       pageFemale.paginationInfo.pagesCount mustEqual 10
       pageFemale.paginationInfo.allCount mustEqual 98
       pageFemale.paginationInfo.page mustEqual 1
@@ -46,7 +46,7 @@ class PaginationFilterSpec extends PersonSpecification with MongoImplicits {
       val paginationMales = MongoPaginatedFilter(PersonDAO, Map("gender" -> "male"))
       val pageMale        = paginationMales.paginate(1, 10)
 
-      paginationMales.countResult mustEqual 11
+      paginationMales.countResult mustEqual 102
       pageMale.paginationInfo.pagesCount mustEqual 11
       pageMale.paginationInfo.allCount mustEqual 102
       pageMale.paginationInfo.page mustEqual 1