feat: added skip to find method

Author: QuadStingray

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

@@ -15,8 +15,12 @@ import org.mongodb.scala.{ Document, ListIndexesObservable, MongoCollection, Obs
 import scala.collection.mutable
 import scala.concurrent.duration.{ durationToPair, Duration }
 import scala.reflect.ClassTag
+import dev.mongocamp.driver.mongodb.schema.JsonConverter._
+import io.circe.syntax._
+import io.circe.generic.auto._
 
 abstract class Base[A](implicit classTag: ClassTag[A]) extends LazyLogging with CirceSchema {
+
   def documentToObject[A](document: Document, decoder: Decoder[A]): A = {
     if (classTag.runtimeClass == classOf[Document]) {
       document.asInstanceOf[A]

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

@@ -4,11 +4,12 @@ import dev.mongocamp.driver.mongodb._
 import dev.mongocamp.driver.mongodb.bson.BsonConverter._
 import dev.mongocamp.driver.mongodb.database.DatabaseProvider
 import io.circe.Decoder
+import net.sf.jsqlparser.statement.select.Skip
 import org.bson.BsonValue
 import org.mongodb.scala.bson.ObjectId
 import org.mongodb.scala.bson.conversions.Bson
 import org.mongodb.scala.model.Filters._
-import org.mongodb.scala.{ DistinctObservable, Document, MongoCollection, Observable }
+import org.mongodb.scala.{DistinctObservable, Document, MongoCollection, Observable}
 
 import scala.reflect.ClassTag
 
@@ -20,14 +21,15 @@ abstract class Search[A]()(implicit ct: ClassTag[A], decoder: Decoder[A]) extend
       filter: Bson = Document(),
       sort: Bson = Document(),
       projection: Bson = Document(),
-      limit: Int = 0
+      limit: Int = 0,
+      skip: Int = 0
   ): Observable[A] = {
     val findObservable = {
       if (limit > 0) {
-        coll.find(filter).sort(sort).projection(projection).limit(limit)
+        coll.find(filter).sort(sort).projection(projection).limit(limit).skip(skip)
       }
       else {
-        coll.find(filter).sort(sort).projection(projection)
+        coll.find(filter).sort(sort).projection(projection).skip(skip)
       }
     }
     findObservable.map(doc => documentToObject[A](doc, decoder))

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

@@ -19,9 +19,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
-    // todo: add projection
-    val responseList = dao.find(filter, sort, projection, rows.toInt).resultList(maxWait)
-//    val responseList = dao.find(filter, sort, projection, rows.toInt).skip(skip.toInt).resultList(maxWait)
+    val responseList = dao.find(filter, sort, projection, rows.toInt, skip.toInt).resultList(maxWait)
     PaginationResult(responseList, PaginationInfo(count, rows, page, allPages))
   }
 

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

@@ -10,6 +10,7 @@ trait MongoPagination[A <: Any] extends ConfigHelper {
     val rows = intConfig(configPath = "dev.mongocamp.mongodb.pagination", key = "rows")
     foreach(rows)(a)
   }
+
   def foreach(rows: Int)(a: A => Unit): Unit = {
     var currentPageNumber = 1
     val rowsPerPage       = if (rows < 1) Int.MaxValue else rows

src/main/scala/dev/mongocamp/driver/mongodb/schema/JsonConverter.scala

@@ -8,6 +8,7 @@ import io.circe.generic.auto._
 import org.bson.Document
 
 import scala.collection.mutable
+
 class JsonConverter extends CirceSchema {
 
   def toJson(s: Any): String = {