Separations for using IRepository pattern more easily

Author: mzand111

MZBase.Domain/MZBase.Domain.csproj

@@ -13,7 +13,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="MZSimpleDynamicLinq.Core" Version="1.0.3" />
+    <PackageReference Include="MZSimpleDynamicLinq.Core" Version="1.0.4" />
     <PackageReference Include="System.ComponentModel.Annotations" Version="5.0.0" />
   </ItemGroup>
 

MZBase.EntityFrameworkCore/BaseLDRComatibleRepositoryAsync.cs

@@ -0,0 +1,38 @@
+using Microsoft.EntityFrameworkCore;
+using MZBase.Domain;
+using MZBase.Infrastructure;
+using MZSimpleDynamicLinq.Core;
+using MZSimpleDynamicLinq.EFCoreExtensions;
+
+namespace MZBase.EntityFrameworkCore
+{
+    /// <summary>
+    /// Provides an asynchronous repository implementation that is compatible with LinqDataRequest handling.
+    /// </summary>
+    /// <typeparam name="DBModelEntity">The type of the database model entity.</typeparam>
+    /// <typeparam name="DomainModelEntity">The type of the domain model entity.</typeparam>
+    /// <typeparam name="PrimaryKeyType">The type of the primary key.</typeparam>
+    public class BaseLDRCompatibleRepositoryAsync<DomainModelEntity, DBModelEntity, PrimaryKeyType> : BaseRepositoryAsync<DomainModelEntity, DBModelEntity, PrimaryKeyType>, IBaseLDRCompatibleRepositoryAsync<DomainModelEntity, DBModelEntity, PrimaryKeyType>
+        where DomainModelEntity : Model<PrimaryKeyType>
+        where DBModelEntity : DomainModelEntity, IConvertibleDBModelEntity<DomainModelEntity>, new()
+        where PrimaryKeyType : struct
+    {
+        /// <summary>
+        /// Initializes a new instance of the <see cref="BaseLDRCompatibleRepositoryAsync{DBModelEntity, DomainModelEntity, PrimaryKeyType}"/> class.
+        /// </summary>
+        /// <param name="context">The database context.</param>
+        public BaseLDRCompatibleRepositoryAsync(DbContext context) : base(context)
+        {
+        }
+
+        /// <summary>
+        /// Gets all items asynchronously based on the specified LinqDataRequest.
+        /// </summary>
+        /// <param name="request">The LinqDataRequest containing the query parameters.</param>
+        /// <returns>A task that represents the asynchronous operation. The task result contains the LinqDataResult of the domain model entities.</returns>
+        public virtual async Task<LinqDataResult<DomainModelEntity>> AllItemsAsync(LinqDataRequest request)
+        {
+            return await _context.Set<DBModelEntity>().ToLinqDataResultAsync<DomainModelEntity>(request.Take, request.Skip, request.Sort, request.Filter);
+        }
+    }
+}

MZBase.EntityFrameworkCore/EFCoreStorageBusinessService.cs

@@ -17,7 +17,7 @@ public abstract class EFCoreStorageBusinessService<DomainModel, DBModelEntity, P
         where DataContext : DbContext
     {
         protected readonly UnitOfWork _unitOfWork;
-        protected readonly ILDRCompatibleRepositoryAsync<DomainModel, DBModelEntity, PrimaryKeyType> _baseRepo;
+        protected readonly IBaseLDRCompatibleRepositoryAsync<DomainModel, DBModelEntity, PrimaryKeyType> _baseRepo;
 
         public EFCoreStorageBusinessService(UnitOfWork unitOfWork,
               IDateTimeProviderService dateTimeProvider,

MZBase.EntityFrameworkCore/LDRComatibleRepositoryAsync.cs

@@ -12,13 +12,13 @@ namespace MZBase.EntityFrameworkCore
     /// <typeparam name="DBModelEntity">The type of the database model entity.</typeparam>
     /// <typeparam name="DomainModelEntity">The type of the domain model entity.</typeparam>
     /// <typeparam name="PrimaryKeyType">The type of the primary key.</typeparam>
-    public class LDRCompatibleRepositoryAsync<DomainModelEntity, DBModelEntity, PrimaryKeyType> : BaseRepositoryAsync<DomainModelEntity, DBModelEntity, PrimaryKeyType>, ILDRCompatibleRepositoryAsync<DomainModelEntity, DBModelEntity, PrimaryKeyType>
+    public class LDRCompatibleRepositoryAsync<DomainModelEntity, DBModelEntity, PrimaryKeyType> : RepositoryAsync<DomainModelEntity, DBModelEntity, PrimaryKeyType>, ILDRCompatibleRepositoryAsync<DomainModelEntity, DBModelEntity, PrimaryKeyType>
         where DomainModelEntity : Model<PrimaryKeyType>
         where DBModelEntity : DomainModelEntity, IConvertibleDBModelEntity<DomainModelEntity>, new()
         where PrimaryKeyType : struct
     {
         /// <summary>
-        /// Initializes a new instance of the <see cref="LDRCompatibleRepositoryAsync{DBModelEntity, DomainModelEntity, PrimaryKeyType}"/> class.
+        /// Initializes a new instance of the <see cref="BaseLDRCompatibleRepositoryAsync{DBModelEntity, DomainModelEntity, PrimaryKeyType}"/> class.
         /// </summary>
         /// <param name="context">The database context.</param>
         public LDRCompatibleRepositoryAsync(DbContext context) : base(context)
@@ -34,5 +34,10 @@ public virtual async Task<LinqDataResult<DomainModelEntity>> AllItemsAsync(LinqD
         {
             return await _context.Set<DBModelEntity>().ToLinqDataResultAsync<DomainModelEntity>(request.Take, request.Skip, request.Sort, request.Filter);
         }
+
+        public virtual LinqDataResult<DomainModelEntity> AllItems(LinqDataRequest request)
+        {
+            return _context.Set<DBModelEntity>().ToLinqDataResult<DomainModelEntity>(request.Take, request.Skip, request.Sort, request.Filter);
+        }
     }
 }

MZBase.EntityFrameworkCore/MZBase.EntityFrameworkCore.csproj

@@ -16,7 +16,7 @@ Different repository implementations are included.</Description>
 
   <ItemGroup>
     <PackageReference Include="Microsoft.EntityFrameworkCore" Version="9.0.2" />
-    <PackageReference Include="MZSimpleDynamicLinq.EFCoreExtensions" Version="1.0.2" />
+    <PackageReference Include="MZSimpleDynamicLinq.EFCoreExtensions" Version="1.0.3" />
   </ItemGroup>
 
   <ItemGroup>

MZBase.Infrastructure/IBaseLDRComatibleRepositoryAsync.cs

@@ -0,0 +1,19 @@
+using MZBase.Domain;
+using MZSimpleDynamicLinq.Core;
+using System.Threading.Tasks;
+
+namespace MZBase.Infrastructure
+{
+    /// <summary>
+    /// Repository interface compatible with handling LinqDataRequest
+    /// </summary>
+    /// <typeparam name="ModelItem"></typeparam>
+    /// <typeparam name="T"></typeparam>
+    public interface IBaseLDRCompatibleRepositoryAsync<ModelItem, DBModelEntity, T> : IBaseRepositoryAsync<ModelItem, DBModelEntity, T>
+          where ModelItem : Model<T>
+         where DBModelEntity : ModelItem, IConvertibleDBModelEntity<ModelItem>, new()
+          where T : struct
+    {
+        Task<LinqDataResult<ModelItem>> AllItemsAsync(LinqDataRequest request);
+    }
+}

MZBase.Infrastructure/IBasePSFRepositoryAsync.cs

@@ -0,0 +1,21 @@
+using MZBase.Domain;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+
+namespace MZBase.Infrastructure
+{
+    /// <summary>
+    /// Page-able, sortable and filterable repo interface
+    /// </summary>
+    /// <typeparam name="ModelItem"></typeparam>
+    /// <typeparam name="T"></typeparam>
+    public interface IBasePSFRepositoryAsync<ModelItem, DBModelEntity, T> : IBaseRepositoryAsync<ModelItem, DBModelEntity, T>
+          where ModelItem : Model<T>
+         where DBModelEntity : ModelItem, IConvertibleDBModelEntity<ModelItem>, new()
+          where T : struct
+    {
+        Task<IReadOnlyList<ModelItem>> AllItemsAsync(int pageSize, int skip);
+        Task<IReadOnlyList<ModelItem>> AllItemsAsync(int pageSize, int skip, string sortColumn, string sortDirection);
+        Task<int> GetTotalCountAsync();
+    }
+}

MZBase.Infrastructure/IDynamicTestableUnitOfWorkAsync.cs

@@ -4,7 +4,7 @@ namespace MZBase.Infrastructure
 {
     public interface IDynamicTestableUnitOfWorkAsync : IUnitOfWorkAsync
     {
-        ILDRCompatibleRepositoryAsync<DomainModel, DBModelEntity, PrimKey> GetRepo<DomainModel, DBModelEntity, PrimKey>()
+        IBaseLDRCompatibleRepositoryAsync<DomainModel, DBModelEntity, PrimKey> GetRepo<DomainModel, DBModelEntity, PrimKey>()
             where DomainModel : Model<PrimKey>
              where DBModelEntity : DomainModel, IConvertibleDBModelEntity<DomainModel>, new()
            where PrimKey : struct;

MZBase.Infrastructure/ILDRComatibleRepositoryAsync.cs

@@ -9,11 +9,12 @@ namespace MZBase.Infrastructure
     /// </summary>
     /// <typeparam name="ModelItem"></typeparam>
     /// <typeparam name="T"></typeparam>
-    public interface ILDRCompatibleRepositoryAsync<ModelItem, DBModelEntity, T> : IBaseRepositoryAsync<ModelItem, DBModelEntity, T>
+    public interface ILDRCompatibleRepositoryAsync<ModelItem, DBModelEntity, T> : IRepositoryAsync<ModelItem, DBModelEntity, T>
           where ModelItem : Model<T>
          where DBModelEntity : ModelItem, IConvertibleDBModelEntity<ModelItem>, new()
           where T : struct
     {
         Task<LinqDataResult<ModelItem>> AllItemsAsync(LinqDataRequest request);
+        LinqDataResult<ModelItem> AllItems(LinqDataRequest request);
     }
 }

MZBase.Infrastructure/IPSFRepositoryAsync.cs

@@ -9,13 +9,18 @@ namespace MZBase.Infrastructure
     /// </summary>
     /// <typeparam name="ModelItem"></typeparam>
     /// <typeparam name="T"></typeparam>
-    public interface IPSFRepositoryAsync<ModelItem, DBModelEntity, T> : IBaseRepositoryAsync<ModelItem, DBModelEntity, T>
+    public interface IPSFRepositoryAsync<ModelItem, DBModelEntity, T> : IRepositoryAsync<ModelItem, DBModelEntity, T>
           where ModelItem : Model<T>
          where DBModelEntity : ModelItem, IConvertibleDBModelEntity<ModelItem>, new()
           where T : struct
     {
         Task<IReadOnlyList<ModelItem>> AllItemsAsync(int pageSize, int skip);
         Task<IReadOnlyList<ModelItem>> AllItemsAsync(int pageSize, int skip, string sortColumn, string sortDirection);
         Task<int> GetTotalCountAsync();
+
+        IReadOnlyList<ModelItem> AllItems(int pageSize, int skip);
+        IReadOnlyList<ModelItem> AllItems(int pageSize, int skip, string sortColumn, string sortDirection);
+        int GetTotalCount();
+
     }
 }