Add mongoose pagination

packages/pagination/CHANGELOG.md

@@ -0,0 +1,7 @@
+# @lowerdeck/pagination
+
+## 1.0.1
+
+### Patch Changes
+
+- Add mongoose opts

packages/pagination/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@lowerdeck/pagination",
-  "version": "1.0.0",
+  "version": "1.0.1",
   "publishConfig": {
     "access": "public"
   },
@@ -24,8 +24,9 @@
     "build": "microbundle"
   },
   "devDependencies": {
-    "microbundle": "^0.15.1",
     "@lowerdeck/tsconfig": "^1.0.0",
+    "microbundle": "^0.15.1",
+    "mongoose": "^9.0.2",
     "typescript": "^5.9.3",
     "vitest": "^3.2.4"
   },

packages/pagination/src/paginatedProvider.ts

@@ -1,4 +1,5 @@
 import { ServiceError, badRequestError } from '@lowerdeck/error';
+import type { QueryFilter, SortOrder } from 'mongoose';
 import { PaginatedList } from './types';
 
 export interface PaginatedProviderInput {
@@ -15,6 +16,12 @@ export interface PrismaPaginationOpts {
   skip: number;
 }
 
+export interface MongoosePaginationOpts<T> {
+  filter: QueryFilter<T>;
+  sort: { _id: SortOrder };
+  limit: number;
+}
+
 export type PaginatedProvider<T> = (
   input: PaginatedProviderInput
 ) => Promise<PaginatedList<T>>;
@@ -98,3 +105,65 @@ export let paginatedProviderPrisma =
       }
     };
   };
+
+export let paginatedProviderMongoose =
+  <T extends { _id: string }>(
+    provider: (opts: MongoosePaginationOpts<T>) => Promise<T[] | null | undefined>
+  ): PaginatedProvider<T> =>
+  async (input: PaginatedProviderInput) => {
+    let { limit, after, before, order } = input;
+
+    if (after && before) {
+      throw new ServiceError(
+        badRequestError({
+          message: 'Cannot use both after and before cursors'
+        })
+      );
+    }
+
+    let filter: QueryFilter<T> = {};
+    let sort: { _id: SortOrder } = { _id: order === 'asc' ? 1 : -1 };
+    let cursorId = after ?? before;
+    let cursorType: 'after' | 'before' | 'none' = 'none';
+
+    if (after) {
+      filter._id = order === 'asc' ? { $gt: after } : { $lt: after };
+      cursorType = 'after';
+    } else if (before) {
+      filter._id = order === 'asc' ? { $lt: before } : { $gt: before };
+      sort._id = order === 'asc' ? -1 : 1;
+      cursorType = 'before';
+    }
+
+    let opts: MongoosePaginationOpts<T> = {
+      filter,
+      sort,
+      limit: limit + 1
+    };
+
+    let items = (await provider(opts)) ?? [];
+
+    if (cursorType === 'before') items = items.reverse();
+
+    let hasMore = items.length > limit;
+    let selectedItems = hasMore ? items.slice(0, limit) : items;
+
+    let hasItemsBefore = false;
+    let hasItemsAfter = false;
+
+    if (cursorType === 'after' || cursorType === 'none') {
+      hasItemsAfter = hasMore;
+      hasItemsBefore = !!after;
+    } else if (cursorType === 'before') {
+      hasItemsBefore = hasMore;
+      hasItemsAfter = !!before;
+    }
+
+    return {
+      items: selectedItems,
+      pagination: {
+        hasNextPage: hasItemsAfter,
+        hasPreviousPage: hasItemsBefore
+      }
+    };
+  };

packages/pagination/src/paginator.ts

@@ -3,6 +3,7 @@ import { Cursor } from './cursor';
 import {
   PaginatedProvider,
   PaginatedProviderInput,
+  paginatedProviderMongoose,
   paginatedProviderPrisma
 } from './paginatedProvider';
 import { PaginatedList } from './types';
@@ -22,6 +23,7 @@ export interface PaginatorOpts {
 
 export type Provider<T> = (providers: {
   prisma: typeof paginatedProviderPrisma;
+  mongoose: typeof paginatedProviderMongoose;
 }) => PaginatedProvider<T>;
 
 export class Paginator<T> {
@@ -113,7 +115,8 @@ export class Paginator<T> {
     }
 
     let provider = this.provider({
-      prisma: paginatedProviderPrisma
+      prisma: paginatedProviderPrisma,
+      mongoose: paginatedProviderMongoose
     });
 
     return await provider(providerInput);