Add generic pagiantion on generic repository #1304

CGI-FR · Oct 4, 2022 · a21db8e · a21db8e
1 parent ce82f4e
commit a21db8e
Show file tree

Hide file tree

Showing 2 changed files with 34 additions and 0 deletions.
diff --git a/src/AzureIoTHub.Portal.Infrastructure/Repositories/GenericRepository.cs b/src/AzureIoTHub.Portal.Infrastructure/Repositories/GenericRepository.cs
@@ -7,7 +7,10 @@ namespace AzureIoTHub.Portal.Infrastructure.Repositories
     using Domain.Base;
     using Microsoft.EntityFrameworkCore;
     using System.Collections.Generic;
+    using System.Linq.Expressions;
     using System.Threading.Tasks;
+    using Shared.Models.v1._0;
+    using System.Linq.Dynamic.Core;
 
     public class GenericRepository<T> : IRepository<T> where T : EntityBase
     {
@@ -50,5 +53,32 @@ public void Delete(object id)
 
             _ = this.context.Set<T>().Remove(existing);
         }
+
+        public async Task<PaginatedResult<T>> GetPaginatedListAsync(
+            int pageNumber,
+            int pageSize,
+            string[]? orderBy = null,
+            Expression<Func<T, bool>>? expression = null,
+            CancellationToken cancellationToken = default
+            )
+        {
+            IQueryable<T> query = this.context.Set<T>();
+            if (expression != null) query = query.Where(expression);
+
+            var ordering = orderBy?.Any() == true ? string.Join(",", orderBy) : null;
+
+            query = !string.IsNullOrWhiteSpace(ordering) ? query.OrderBy(ordering) : query.OrderBy(a => a.Id);
+
+            var count = await query
+                .AsNoTracking()
+                .CountAsync(cancellationToken: cancellationToken);
+
+            var items = await query
+                .Skip((pageNumber - 1) * pageSize)
+                .Take(pageSize)
+                .ToDynamicListAsync<T>(cancellationToken: cancellationToken);
+
+            return new PaginatedResult<T>(items, count, pageNumber, pageSize);
+        }
     }
 }
diff --git a/src/AzureIoTHubPortal.Domain/IRepository.cs b/src/AzureIoTHubPortal.Domain/IRepository.cs
@@ -4,8 +4,10 @@
 namespace AzureIoTHub.Portal.Domain
 {
     using System.Collections.Generic;
+    using System.Linq.Expressions;
     using System.Threading.Tasks;
     using Base;
+    using Portal.Shared.Models.v1._0;
 
     public interface IRepository<T> where T : EntityBase
     {
@@ -18,5 +20,7 @@ public interface IRepository<T> where T : EntityBase
         void Update(T obj);
 
         void Delete(object id);
+
+        Task<PaginatedResult<T>> GetPaginatedListAsync(int pageNumber, int pageSize, string[]? orderBy = null, Expression<Func<T, bool>>? expression = null, CancellationToken cancellationToken = default);
     }
 }