Added initial version.

Author: Pedromdrp

.babelrc

@@ -0,0 +1,6 @@
+{
+  "presets": [
+    "es2015",
+    "stage-0"
+  ]
+}

.gitignore

@@ -2,58 +2,18 @@
 logs
 *.log
 npm-debug.log*
-yarn-debug.log*
-yarn-error.log*
 
 # Runtime data
 pids
 *.pid
 *.seed
 *.pid.lock
 
-# Directory for instrumented libs generated by jscoverage/JSCover
-lib-cov
-
-# Coverage directory used by tools like istanbul
-coverage
-
-# nyc test coverage
-.nyc_output
-
-# Grunt intermediate storage (http://gruntjs.com/creating-plugins#storing-task-files)
-.grunt
-
-# Bower dependency directory (https://bower.io/)
-bower_components
-
-# node-waf configuration
-.lock-wscript
-
-# Compiled binary addons (http://nodejs.org/api/addons.html)
-build/Release
-
 # Dependency directories
 node_modules/
-jspm_packages/
-
-# Typescript v1 declaration files
-typings/
-
-# Optional npm cache directory
-.npm
-
-# Optional eslint cache
-.eslintcache
-
-# Optional REPL history
-.node_repl_history
-
-# Output of 'npm pack'
-*.tgz
-
-# Yarn Integrity file
-.yarn-integrity
 
 # dotenv environment variables file
 .env
 
+# Output directories
+lib/

.travis.yml

@@ -0,0 +1,9 @@
+language: node_js
+
+node_js:
+  - "4"
+  - "5"
+  - "6"
+
+services:
+  - mongodb

package.json

@@ -0,0 +1,38 @@
+{
+  "name": "mongoose-cursor-pagination",
+  "version": "0.1.0",
+  "description": "Mongoose cursor-based pagination.",
+  "main": "lib/index.js",
+  "files": [
+    "lib"
+  ],
+  "scripts": {
+    "build": "babel src --out-dir lib",
+    "test": "standard"
+  },
+  "repository": {
+    "type": "git",
+    "url": "https://github.com/enkidevs/mongoose-cursor-pagination.git"
+  },
+  "keywords": [
+    "mongoose",
+    "paginate",
+    "pagination",
+    "cursor",
+    "mongodb",
+    "javascript"
+  ],
+  "author": "Pedro da Rocha Pinto <[email protected]>",
+  "license": "MIT",
+  "bugs": {
+    "url": "https://github.com/enkidevs/mongoose-cursor-pagination/issues"
+  },
+  "homepage": "https://github.com/enkidevs/mongoose-cursor-pagination",
+  "devDependencies": {
+    "babel-cli": "^6.26.0",
+    "babel-preset-es2015": "^6.24.1",
+    "babel-preset-stage-0": "^6.24.1",
+    "mongoose": "^4.12.3",
+    "standard": "*"
+  }
+}

src/index.js

@@ -0,0 +1,88 @@
+export default function paginationPlugin (schema, pluginOptions) {
+  pluginOptions = pluginOptions || {}
+
+  const minLimit = +pluginOptions.minLimit || 1
+  const maxLimit = +pluginOptions.maxLimit || 100
+
+  const defaultOptions = {
+    key: pluginOptions.key || '_id',
+    lean: pluginOptions.lean || false,
+    limit: +pluginOptions.limit || 20,
+    sort: {}
+  }
+
+  schema.statics.paginate = function (query, options, callback) {
+    query = query || {}
+    options = options || {}
+    options.limit = +options.limit || defaultOptions.limit
+    options = { ...defaultOptions, ...options }
+
+    if (options.limit > maxLimit || options.limit < minLimit) {
+      options.limit = defaultOptions.limit
+    }
+
+    const { key, select, populate, lean, limit, sort } = options
+    let reverse = false
+
+    if (options.startingAfter || options.endingBefore) {
+      query[key] = {}
+
+      if (options.endingBefore) {
+        query[key] = { $lt: options.endingBefore }
+
+        if (sort[key] > 0) {
+          sort[key] = -1
+          reverse = true
+        }
+      } else {
+        query[key] = { $gt: options.startingAfter }
+
+        if (sort[key] <= 0) {
+          sort[key] = 1
+          reverse = true
+        }
+      }
+    }
+
+    const promise = this.find()
+      .where(query)
+      .select(select)
+      .sort(sort)
+      .limit(limit + 1)
+      .lean(lean)
+
+    if (populate) {
+      [].concat(populate).forEach(item => promise.populate(item))
+    }
+
+    return new Promise((resolve, reject) => promise.exec((error, items) => {
+      if (error) {
+        if (typeof callback === 'function') {
+          setImmediate(() => callback(error))
+        }
+
+        return reject(error)
+      }
+
+      items = items || []
+      const hasMore = items.length === limit + 1
+
+      if (hasMore) {
+        items.pop()
+      }
+
+      items = reverse ? items.reverse() : items
+
+      const results = {
+        items,
+        hasMore
+      }
+
+      if (typeof callback === 'function') {
+        setImmediate(() => callback(null, results))
+      }
+
+      return resolve(results)
+    }))
+  }
+}