refactor: encapsulate pagination logic

Murzbul · Nov 22, 2023 · 3d0ddcf · 3d0ddcf
1 parent 4e1eebd
commit 3d0ddcf
Show file tree

Hide file tree

Showing 2 changed files with 22 additions and 17 deletions.
diff --git a/src/Item/Infrastructure/Repositories/ItemMongooseRepository.ts b/src/Item/Infrastructure/Repositories/ItemMongooseRepository.ts
@@ -3,14 +3,11 @@ import { ICriteria } from '@digichanges/shared-experience';
 
 import IItemRepository from './IItemRepository';
 import ItemFilter from '../../Presentation/Criterias/ItemFilter';
-import MongoosePaginator from '../../../Main/Infrastructure/Orm/MongoosePaginator';
 
 import BaseMongooseRepository from '../../../Main/Infrastructure/Repositories/BaseMongooseRepository';
 import IItemDomain from '../../Domain/Entities/IItemDomain';
 import Item from '../../Domain/Entities/Item';
 import { ItemMongooseDocument } from '../Schemas/ItemMongoose';
-import ResponsePayload from '../../../Shared/Utils/ResponsePayload';
-import PaginatorTransformer from '../../../Shared/Utils/PaginatorTransformer';
 
 class ItemMongooseRepository extends BaseMongooseRepository<IItemDomain, ItemMongooseDocument> implements IItemRepository
 {
@@ -38,20 +35,7 @@ class ItemMongooseRepository extends BaseMongooseRepository<IItemDomain, ItemMon
             void queryBuilder.where(ItemFilter.NAME).regex(rSearch);
         }
 
-        const paginator = new MongoosePaginator(queryBuilder, criteria);
-        const data = await paginator.paginate();
-        const metadata = paginator.getMetadata();
-        const result = { data, metadata } as ResponsePayload;
-
-        if (paginator.getExist())
-        {
-            const paginatorTransformer = new PaginatorTransformer();
-            const pagination = await paginatorTransformer.handle(paginator);
-
-            Object.assign(result, { pagination });
-        }
-
-        return result;
+        return this.pagination(queryBuilder, criteria);
     }
 }
 

diff --git a/src/Main/Infrastructure/Repositories/BaseMongooseRepository.ts b/src/Main/Infrastructure/Repositories/BaseMongooseRepository.ts
@@ -2,6 +2,9 @@ import * as mongoose from 'mongoose';
 import { IBaseDomain, ICriteria, IPaginator, NotFoundException } from '@digichanges/shared-experience';
 import IByOptions from './IByOptions';
 import IBaseRepository from './IBaseRepository';
+import MongoosePaginator from '../Orm/MongoosePaginator';
+import ResponsePayload from '../../../Shared/Utils/ResponsePayload';
+import PaginatorTransformer from '../../../Shared/Utils/PaginatorTransformer';
 
 abstract class BaseMongooseRepository<T extends IBaseDomain, D extends Document & T> implements IBaseRepository<T>
 {
@@ -93,6 +96,24 @@ abstract class BaseMongooseRepository<T extends IBaseDomain, D extends Document
         return exist;
     }
 
+    async pagination(queryBuilder: mongoose.Query<D[], D>, criteria: ICriteria)
+    {
+        const paginator = new MongoosePaginator(queryBuilder, criteria);
+        const data = await paginator.paginate();
+        const metadata = paginator.getMetadata();
+        const result = { data, metadata } as ResponsePayload;
+
+        if (paginator.getExist())
+        {
+            const paginatorTransformer = new PaginatorTransformer();
+            const pagination = await paginatorTransformer.handle(paginator);
+
+            Object.assign(result, { pagination });
+        }
+
+        return result;
+    }
+
     abstract list(criteria: ICriteria): Promise<IPaginator>;
 }