refactor: limit for pagination is an int in official mongodb driver

Author: QuadStingray

package.json

@@ -1,7 +1,7 @@
 {
   "name" : "mongodb-driver",
   "organization" : "dev.mongocamp",
-  "version" : "3.0.10.snapshot",
+  "version" : "3.0.10",
   "author" : "[email protected]",
   "license" : "Apache-2.0",
   "type" : "module",

src/main/scala/dev/mongocamp/driver/mongodb/operation/Search.scala

@@ -20,8 +20,9 @@ abstract class Search[A]()(implicit ct: ClassTag[A], decoder: Decoder[A]) extend
 
   def find(filter: Bson = Document(), sort: Bson = Document(), projection: Bson = Document(), limit: Int = 0, skip: Int = 0): Observable[A] = {
     val findObservable = {
+      val internalLimit = if (limit == Int.MaxValue) limit - 1 else limit
       if (limit > 0) {
-        coll.find(filter).sort(sort).projection(projection).limit(limit).skip(skip)
+        coll.find(filter).sort(sort).projection(projection).limit(internalLimit).skip(skip)
       }
       else {
         coll.find(filter).sort(sort).projection(projection).skip(skip)

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

@@ -19,7 +19,7 @@ case class MongoPaginatedAggregation[A <: Any](
   private val AggregationKeyData          = "data"
   private val AggregationKeyMetaDataTotal = "total"
 
-  def paginate(page: Long, rows: Long): PaginationResult[Document] = {
+  def paginate(page: Int, rows: Int): PaginationResult[Document] = {
     if (rows <= 0) {
       throw MongoCampPaginationException("rows per page must be greater then 0.")
     }

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

@@ -7,7 +7,7 @@ import org.mongodb.scala.bson.conversions.Bson
 case class MongoPaginatedFilter[A <: Any](dao: MongoDAO[A], filter: Bson = Map(), sort: Bson = Map(), projection: Bson = Map(), maxWait: Int = DefaultMaxWait)
     extends MongoPagination[A] {
 
-  def paginate(page: Long, rows: Long): PaginationResult[A] = {
+  def paginate(page: Int, rows: Int): PaginationResult[A] = {
     val count = countResult
     if (rows <= 0) {
       throw MongoCampPaginationException("rows per page must be greater then 0.")
@@ -17,7 +17,7 @@ case class MongoPaginatedFilter[A <: Any](dao: MongoDAO[A], filter: Bson = Map()
     }
     val allPages     = Math.ceil(count.toDouble / rows).toInt
     val skip         = (page - 1) * rows
-    val responseList = dao.find(filter, sort, projection, rows.toInt, skip.toInt).resultList(maxWait)
+    val responseList = dao.find(filter, sort, projection, rows, skip).resultList(maxWait)
     PaginationResult(responseList, PaginationInfo(count, rows, page, allPages))
   }
 

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

@@ -3,7 +3,7 @@ package dev.mongocamp.driver.mongodb.pagination
 import dev.mongocamp.driver.mongodb.database.ConfigHelper
 
 trait MongoPagination[A <: Any] extends ConfigHelper {
-  def paginate(page: Long, rows: Long): PaginationResult[A]
+  def paginate(page: Int, rows: Int): PaginationResult[A]
   def countResult: Long
 
   def foreach(a: A => Unit): Unit = {

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

@@ -10,7 +10,7 @@ class PaginationFilterSuite extends BasePersonSuite with MongoImplicits {
   test("search with rows Long MaxValue") {
     val personCollectionCount = PersonDAO.count().result().toInt
     val pagination            = MongoPaginatedFilter(PersonDAO)
-    val page                  = pagination.paginate(1, Long.MaxValue)
+    val page                  = pagination.paginate(1, Int.MaxValue)
     assertEquals(page.paginationInfo.allCount, personCollectionCount.toLong)
     assertEquals(page.databaseObjects.size, personCollectionCount)
   }