Rolled back MediatR due to validation issue.

RCommon-Team · Jul 24, 2024 · 1839095 · 1839095
1 parent d562a49
commit 1839095
Show file tree

Hide file tree

Showing 9 changed files with 65 additions and 16 deletions.
diff --git a/Src/RCommon.Core/Extensions/IQueryableExtensions.cs b/Src/RCommon.Core/Extensions/IQueryableExtensions.cs
@@ -90,11 +90,11 @@ private static MethodInfo GetLikeMethod(string value, char wildcard)
             return stringType.GetMethod(methodName, new Type[] { stringType });
         }
 
-        public static IPaginatedList<T> ToPaginatedList<T>(this IQueryable<T> source, int? pageIndex, int pageSize)
+        public static IPaginatedList<T> ToPaginatedList<T>(this IQueryable<T> source, int pageNumber = 1, int pageSize = 10)
         {
             Guard.IsNotNegativeOrZero(pageSize, "pageSize");
 
-            return new PaginatedList<T>(source, pageIndex, pageSize);
+            return new PaginatedList<T>(source, pageNumber, pageSize);
         }
 
     }

diff --git a/Src/RCommon.Core/IPagedSpecification.cs b/Src/RCommon.Core/IPagedSpecification.cs
@@ -9,7 +9,7 @@ namespace RCommon
 {
     public interface IPagedSpecification<T> : ISpecification<T>
     {
-        public int PageIndex { get; }
+        public int PageNumber { get; }
         public int PageSize { get; }
 
         public Expression<Func<T, object>> OrderByExpression { get; }

diff --git a/Src/RCommon.Core/PagedSpecification.cs b/Src/RCommon.Core/PagedSpecification.cs
@@ -10,16 +10,16 @@ namespace RCommon
     public class PagedSpecification<T> : Specification<T>, IPagedSpecification<T>
     {
         public PagedSpecification(Expression<Func<T, bool>> predicate, Expression<Func<T, object>> orderByExpression, 
-            bool orderByAscending, int pageIndex, int pageSize) : base(predicate)
+            bool orderByAscending, int pageNumber, int pageSize) : base(predicate)
         {
             OrderByExpression = orderByExpression;
             OrderByAscending = orderByAscending;
-            PageIndex = pageIndex;
+            PageNumber = pageNumber;
             PageSize = pageSize;
         }
 
         public Expression<Func<T, object>> OrderByExpression { get; }
-        public int PageIndex { get;  }
+        public int PageNumber { get;  }
         public int PageSize { get; }
 
         public bool OrderByAscending { get; set; }

diff --git a/Src/RCommon.EfCore/Crud/EFCoreRepository.cs b/Src/RCommon.EfCore/Crud/EFCoreRepository.cs
@@ -202,11 +202,11 @@ public async override Task<IPaginatedList<TEntity>> FindAsync(IPagedSpecificatio
             {
                 query = FindCore(specification.Predicate).OrderByDescending(specification.OrderByExpression);
             }
-            return await Task.FromResult(query.ToPaginatedList(specification.PageIndex, specification.PageSize));
+            return await Task.FromResult(query.ToPaginatedList(specification.PageNumber, specification.PageSize));
         }
 
         public async override Task<IPaginatedList<TEntity>> FindAsync(Expression<Func<TEntity, bool>> expression, Expression<Func<TEntity, object>> orderByExpression,
-            bool orderByAscending, int? pageIndex, int pageSize = 1,
+            bool orderByAscending, int pageNumber = 1, int pageSize = 1,
             CancellationToken token = default)
         {
             IQueryable<TEntity> query;
@@ -218,7 +218,27 @@ public async override Task<IPaginatedList<TEntity>> FindAsync(Expression<Func<TE
             {
                 query = FindCore(expression).OrderByDescending(orderByExpression);
             }
-            return await Task.FromResult(query.ToPaginatedList(pageIndex, pageSize));
+            return await Task.FromResult(query.ToPaginatedList(pageNumber, pageSize));
+        }
+        public override IQueryable<TEntity> FindQuery(Expression<Func<TEntity, bool>> expression, Expression<Func<TEntity, object>> orderByExpression,
+            bool orderByAscending, int pageNumber = 1, int pageSize = 0)
+        {
+            IQueryable<TEntity> query;
+            if (orderByAscending)
+            {
+                query = FindCore(expression).OrderBy(orderByExpression);
+            }
+            else
+            {
+                query = FindCore(expression).OrderByDescending(orderByExpression);
+            }
+            return query.Skip((pageNumber - 1) * pageSize).Take(pageSize);
+        }
+
+        public override IQueryable<TEntity> FindQuery(IPagedSpecification<TEntity> specification)
+        {
+            return this.FindQuery(specification.Predicate, specification.OrderByExpression, 
+                specification.OrderByAscending, specification.PageNumber, specification.PageSize);
         }
 
         public override async Task<TEntity> FindSingleOrDefaultAsync(Expression<Func<TEntity, bool>> expression, CancellationToken token = default)

diff --git a/Src/RCommon.Linq2Db/Crud/Linq2DbRepository.cs b/Src/RCommon.Linq2Db/Crud/Linq2DbRepository.cs
@@ -16,6 +16,7 @@
 using RCommon;
 using RCommon.Persistence.Crud;
 using RCommon.Persistence.Transactions;
+using LinqToDB.Linq;
 
 namespace RCommon.Persistence.Linq2Db.Crud
 {
@@ -184,11 +185,11 @@ public async override Task<IPaginatedList<TEntity>> FindAsync(IPagedSpecificatio
             {
                 query = FindCore(specification.Predicate).OrderByDescending(specification.OrderByExpression);
             }
-            return await Task.FromResult(query.ToPaginatedList(specification.PageIndex, specification.PageSize));
+            return await Task.FromResult(query.ToPaginatedList(specification.PageNumber, specification.PageSize));
         }
 
         public async override Task<IPaginatedList<TEntity>> FindAsync(Expression<Func<TEntity, bool>> expression, Expression<Func<TEntity, object>> orderByExpression,
-            bool orderByAscending, int? pageIndex, int pageSize = 1,
+            bool orderByAscending, int pageNumber = 1, int pageSize = 1,
             CancellationToken token = default)
         {
             IQueryable<TEntity> query;
@@ -200,7 +201,28 @@ public async override Task<IPaginatedList<TEntity>> FindAsync(Expression<Func<TE
             {
                 query = FindCore(expression).OrderByDescending(orderByExpression);
             }
-            return await Task.FromResult(query.ToPaginatedList(pageIndex, pageSize));
+            return await Task.FromResult(query.ToPaginatedList(pageNumber, pageSize));
+        }
+
+        public override IQueryable<TEntity> FindQuery(Expression<Func<TEntity, bool>> expression, Expression<Func<TEntity, object>> orderByExpression, 
+            bool orderByAscending, int pageNumber = 1, int pageSize = 0)
+        {
+            IQueryable<TEntity> query;
+            if (orderByAscending)
+            {
+                query = FindCore(expression).OrderBy(orderByExpression);
+            }
+            else
+            {
+                query = FindCore(expression).OrderByDescending(orderByExpression);
+            }
+            return query.Skip((pageNumber - 1) * pageSize).Take(pageSize);
+        }
+
+        public override IQueryable<TEntity> FindQuery(IPagedSpecification<TEntity> specification)
+        {
+            return this.FindQuery(specification.Predicate, specification.OrderByExpression,
+                 specification.OrderByAscending, specification.PageNumber, specification.PageSize);
         }
 
         public async override Task<TEntity> FindSingleOrDefaultAsync(Expression<Func<TEntity, bool>> expression, CancellationToken token = default)

diff --git a/Src/RCommon.Mediator/Subscribers/IAppRequest.cs b/Src/RCommon.Mediator/Subscribers/IAppRequest.cs
@@ -11,7 +11,7 @@ public interface IAppRequest
 
     }
 
-    public interface IAppRequest<TResponse>
+    public interface IAppRequest<out TResponse>
     {
 
     }

diff --git a/Src/RCommon.Mediatr/RCommon.MediatR.csproj b/Src/RCommon.Mediatr/RCommon.MediatR.csproj
@@ -7,7 +7,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="MediatR" Version="12.4.0" />
+    <PackageReference Include="MediatR" Version="12.3.0" />
   </ItemGroup>
 
   <ItemGroup>

diff --git a/Src/RCommon.Persistence/Crud/ILinqRepository.cs b/Src/RCommon.Persistence/Crud/ILinqRepository.cs
@@ -17,9 +17,12 @@ public interface ILinqRepository<TEntity>: IQueryable<TEntity>, IReadOnlyReposit
     {
         IQueryable<TEntity> FindQuery(ISpecification<TEntity> specification);
         IQueryable<TEntity> FindQuery(Expression<Func<TEntity, bool>> expression);
+        IQueryable<TEntity> FindQuery(Expression<Func<TEntity, bool>> expression, Expression<Func<TEntity, object>> orderByExpression,
+            bool orderByAscending, int pageNumber = 1, int pageSize = 0);
+        IQueryable<TEntity> FindQuery(IPagedSpecification<TEntity> specification);
 
         Task<IPaginatedList<TEntity>> FindAsync(Expression<Func<TEntity, bool>> expression, Expression<Func<TEntity, object>> orderByExpression,
-            bool orderByAscending, int? pageIndex, int pageSize = 0,
+            bool orderByAscending, int pageNumber = 1, int pageSize = 0,
             CancellationToken token = default);
         Task<IPaginatedList<TEntity>> FindAsync(IPagedSpecification<TEntity> specification, CancellationToken token = default);
 

diff --git a/Src/RCommon.Persistence/Crud/LinqRepositoryBase.cs b/Src/RCommon.Persistence/Crud/LinqRepositoryBase.cs
@@ -137,10 +137,14 @@ public IEnumerable<TEntity> Query(ISpecification<TEntity> specification)
         public abstract Task<bool> AnyAsync(ISpecification<TEntity> specification, CancellationToken token = default);
 
         public abstract Task<IPaginatedList<TEntity>> FindAsync(Expression<Func<TEntity, bool>> expression, Expression<Func<TEntity, object>> orderByExpression,
-            bool orderByAscending, int? pageIndex, int pageSize = 0,
+            bool orderByAscending, int pageNumber = 1, int pageSize = 0,
             CancellationToken token = default);
         public abstract Task<IPaginatedList<TEntity>> FindAsync(IPagedSpecification<TEntity> specification, CancellationToken token = default);
 
+        public abstract IQueryable<TEntity> FindQuery(Expression<Func<TEntity, bool>> expression, Expression<Func<TEntity, object>> orderByExpression,
+            bool orderByAscending, int pageNumber = 1, int pageSize = 0);
+        public abstract IQueryable<TEntity> FindQuery(IPagedSpecification<TEntity> specification);
+
         public abstract IEagerLoadableQueryable<TEntity> Include(Expression<Func<TEntity, object>> path);
 
         public abstract IEagerLoadableQueryable<TEntity> ThenInclude<TPreviousProperty, TProperty>(Expression<Func<object, TProperty>> path);
-Original file line number
+Diff line change
@@ Expand Up / @@ -11,7 +11,7 @@ public interface IAppRequest @@
         }
-        public interface IAppRequest<TResponse>
+        public interface IAppRequest<out TResponse>
         {
         }
@@ Expand Down @@