feat: use start/count instead of bookmark

lib/persistence/Repository.ts

@@ -1,6 +1,11 @@
 import { Aggregate, AnyIdentity } from '@lib/domain/models'
 import { Query } from '@lib/persistence'
 
+export interface ResultSetSlice {
+  start: number
+  count: number
+}
+
 /**
  * Result set.
  */
@@ -12,7 +17,7 @@ export class ResultSet<TEntity extends Aggregate<AnyIdentity>> {
    */
   constructor(
     public readonly entities: readonly TEntity[],
-    public readonly bookmark?: string,
+    public readonly slice: ResultSetSlice,
   ) { }
 }
 

lib/persistence/memory/InMemoryRepository.ts

@@ -14,7 +14,8 @@ export class InMemoryRepository<
   // options?: QueryOptions,
   ): Promise<ResultSet<TAggregate>> {
     return new ResultSet(
-      Array.from(this.entities.values())
+      Array.from(this.entities.values()),
+      { start: 0, count: this.entities.size }
     )
   }
 
@@ -38,11 +39,11 @@ export class InMemoryRepository<
     query: Query<TAggregate>,
     options?: QueryOptions,
   ): Promise<ResultSet<TAggregate>> {
-    const startIndex = parseInt(options?.bookmark ?? '0', 10)
+    const startIndex = options?.skip || 0
     const entities = Array.from(this.entities.values()).slice(startIndex)
     const result = this.processor.execute(query, entities)
     return new ResultSet<TAggregate>(
-      result, (startIndex + entities.length).toString()
+      result, { start: startIndex, count: result.length }
     )
   }
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@akdasa-studios/framework",
-  "version": "0.5.1",
+  "version": "0.5.2",
   "description": "Framework to build every app",
   "main": "dist/index.js",
   "typings": "dist/index.d.ts",

tests/persistence/memory/InMemoryRepository.spec.ts

@@ -127,7 +127,7 @@ describe('InMemoryRepository', () => {
       let result = await repository.find(query)
 
       // act:
-      result = await repository.find(query, { bookmark: result.bookmark })
+      result = await repository.find(query, { skip: result.slice.count })
 
       // assert:
       expect(result.entities).toEqual([])