add cancellation token

src/CSharp/EasyMicroservices.Cores.AspCoreApi/EasyMicroservices.Cores.AspCoreApi.csproj

@@ -4,7 +4,7 @@
     <TargetFrameworks>netstandard2.1;net6.0;net7.0;net8.0</TargetFrameworks>
     <Platforms>AnyCPU;x64;x86</Platforms>
     <Authors>EasyMicroservices</Authors>
-    <Version>0.0.1.51</Version>
+    <Version>0.0.1.52</Version>
     <Description>asp core servces.</Description>
     <Copyright>[email protected]</Copyright>
     <PackageTags>core,cores,base,database,services,asp,aspnet</PackageTags>

src/CSharp/EasyMicroservices.Cores.AspEntityFrameworkCoreApi/EasyMicroservices.Cores.AspEntityFrameworkCoreApi.csproj

@@ -4,7 +4,7 @@
     <TargetFrameworks>net6.0;net7.0;net8.0</TargetFrameworks>
     <Platforms>AnyCPU;x64;x86</Platforms>
     <Authors>EasyMicroservices</Authors>
-    <Version>0.0.1.51</Version>
+    <Version>0.0.1.52</Version>
     <Description>asp core servces.</Description>
     <Copyright>[email protected]</Copyright>
     <PackageTags>core,cores,base,database,services,asp,aspnet,aspcore,efcore</PackageTags>

src/CSharp/EasyMicroservices.Cores.Clients/EasyMicroservices.Cores.Clients.csproj

@@ -4,7 +4,7 @@
     <TargetFrameworks>netstandard2.0;netstandard2.1;net6.0;net8.0</TargetFrameworks>
     <Platforms>AnyCPU;x64;x86</Platforms>
     <Authors>EasyMicroservices</Authors>
-    <Version>0.0.1.51</Version>
+    <Version>0.0.1.52</Version>
     <Description>core of database.</Description>
     <Copyright>[email protected]</Copyright>
     <PackageTags>core,cores,base,client,clients</PackageTags>

src/CSharp/EasyMicroservices.Cores.Contracts/EasyMicroservices.Cores.Contracts.csproj

@@ -4,7 +4,7 @@
     <TargetFrameworks>netstandard2.0;netstandard2.1;net45;net6.0;net8.0</TargetFrameworks>
     <Platforms>AnyCPU;x64;x86</Platforms>
     <Authors>EasyMicroservices</Authors>
-    <Version>0.0.1.51</Version>
+    <Version>0.0.1.52</Version>
     <Description>core contracts.</Description>
     <Copyright>[email protected]</Copyright>
     <PackageTags>core,cores,base,contract,contracts,dto,dtos</PackageTags>

src/CSharp/EasyMicroservices.Cores.Database/Database/Interfaces/IDatabaseWidget.cs

@@ -1,5 +1,6 @@
 using EasyMicroservices.Cores.Interfaces;
 using System.Collections.Generic;
+using System.Threading;
 using System.Threading.Tasks;
 
 namespace EasyMicroservices.Cores.Database.Interfaces;
@@ -20,14 +21,16 @@ public interface IDatabaseWidget<TEntity, T> : IWidget<T>
     /// <param name="baseUnitOfWork"></param>
     /// <param name="entity"></param>
     /// <param name="contract"></param>
+    /// <param name="cancellationToken"></param>
     /// <returns></returns>
-    Task AddProcess(IDatabaseWidgetManager databaseWidgetManager, IBaseUnitOfWork baseUnitOfWork, TEntity entity, T contract);
+    Task AddProcess(IDatabaseWidgetManager databaseWidgetManager, IBaseUnitOfWork baseUnitOfWork, TEntity entity, T contract, CancellationToken cancellationToken = default);
     /// <summary>
     /// 
     /// </summary>
     /// <param name="databaseWidgetManager"></param>
     /// <param name="baseUnitOfWork"></param>
     /// <param name="items"></param>
+    /// <param name="cancellationToken"></param>
     /// <returns></returns>
-    Task AddBulkProcess(IDatabaseWidgetManager databaseWidgetManager, IBaseUnitOfWork baseUnitOfWork, Dictionary<T, TEntity> items);
+    Task AddBulkProcess(IDatabaseWidgetManager databaseWidgetManager, IBaseUnitOfWork baseUnitOfWork, Dictionary<T, TEntity> items, CancellationToken cancellationToken = default);
 }

src/CSharp/EasyMicroservices.Cores.Database/Database/Interfaces/IDatabaseWidgetManager.cs

@@ -1,5 +1,6 @@
 using EasyMicroservices.Cores.Interfaces;
 using System.Collections.Generic;
+using System.Threading;
 using System.Threading.Tasks;
 
 namespace EasyMicroservices.Cores.Database.Interfaces;
@@ -16,8 +17,9 @@ public interface IDatabaseWidgetManager : IWidgetManager
     /// <param name="baseUnitOfWork"></param>
     /// <param name="entity"></param>
     /// <param name="contract"></param>
+    /// <param name="cancellationToken"></param>
     /// <returns></returns>
-    Task Add<TEntity, T>(IBaseUnitOfWork baseUnitOfWork, TEntity entity, T contract)
+    Task Add<TEntity, T>(IBaseUnitOfWork baseUnitOfWork, TEntity entity, T contract, CancellationToken cancellationToken = default)
         where TEntity : class;
     /// <summary>
     /// 
@@ -26,7 +28,8 @@ Task Add<TEntity, T>(IBaseUnitOfWork baseUnitOfWork, TEntity entity, T contract)
     /// <typeparam name="TEntity"></typeparam>
     /// <param name="baseUnitOfWork"></param>
     /// <param name="items"></param>
+    /// <param name="cancellationToken"></param>
     /// <returns></returns>
-    Task AddBulk<TEntity, T>(IBaseUnitOfWork baseUnitOfWork, Dictionary<T, TEntity> items)
+    Task AddBulk<TEntity, T>(IBaseUnitOfWork baseUnitOfWork, Dictionary<T, TEntity> items, CancellationToken cancellationToken = default)
         where TEntity : class;
 }

src/CSharp/EasyMicroservices.Cores.Database/Database/Logics/DatabaseLogicInfrastructure.cs

@@ -1023,12 +1023,12 @@
             {
                 await InternalUpdateBulk(easyWritableQueryable, result.Select(x => x.Entity).ToList(), false, true, true, true, cancellationToken)
                     .AsCheckedResult();
-                await easyWritableQueryable.SaveChangesAsync();
+                await easyWritableQueryable.SaveChangesAsync(cancellationToken);
             }
             var response = result.Select(x => x.Entity).ToList();
             var widgetManager = _baseUnitOfWork.GetDatabaseWidgetManager();
             await widgetManager.AddBulk(_baseUnitOfWork, items);
             await ActivityChangeLogLogic.AddBuldAsync(response, _baseUnitOfWork);
             return response;
         }
 

src/CSharp/EasyMicroservices.Cores.Database/Database/Managers/DatabaseWidgetManager.cs

@@ -3,6 +3,7 @@
 using EasyMicroservices.Cores.Widgets;
 using System.Collections.Generic;
 using System.Diagnostics.Contracts;
+using System.Threading;
 using System.Threading.Tasks;
 
 namespace EasyMicroservices.Cores.Database.Managers;
@@ -20,8 +21,9 @@ public class DatabaseWidgetManager : WidgetManager, IDatabaseWidgetManager
     /// <param name="baseUnitOfWork"></param>
     /// <param name="entity"></param>
     /// <param name="contract"></param>
+    /// <param name="cancellationToken"></param>
     /// <returns></returns>
-    public async Task Add<TEntity, T>(IBaseUnitOfWork baseUnitOfWork, TEntity entity, T contract)
+    public async Task Add<TEntity, T>(IBaseUnitOfWork baseUnitOfWork, TEntity entity, T contract, CancellationToken cancellationToken = default)
         where TEntity : class
     {
         var widgets = GetWidgetsByType(typeof(T));
@@ -41,8 +43,9 @@ public async Task Add<TEntity, T>(IBaseUnitOfWork baseUnitOfWork, TEntity entity
     /// <typeparam name="T"></typeparam>
     /// <param name="baseUnitOfWork"></param>
     /// <param name="items"></param>
+    /// <param name="cancellationToken"></param>
     /// <returns></returns>
-    public async Task AddBulk<TEntity, T>(IBaseUnitOfWork baseUnitOfWork, Dictionary<T, TEntity> items) where TEntity : class
+    public async Task AddBulk<TEntity, T>(IBaseUnitOfWork baseUnitOfWork, Dictionary<T, TEntity> items, CancellationToken cancellationToken = default) where TEntity : class
     {
         var widgets = GetWidgetsByType(typeof(T));
         foreach (var widget in widgets)

src/CSharp/EasyMicroservices.Cores.Database/Database/Widgets/SimpleReportingEntityWidget.cs

@@ -5,6 +5,7 @@
 using System;
 using System.Collections.Generic;
 using System.Linq;
+using System.Threading;
 using System.Threading.Tasks;
 
 namespace EasyMicroservices.Cores.Widgets;
@@ -64,9 +65,10 @@ public Task Initialize(params TObjectContract[] parameters)
     /// <param name="baseUnitOfWork"></param>
     /// <param name="entity"></param>
     /// <param name="contract"></param>
+    /// <param name="cancellationToken"></param>
     /// <returns></returns>
     /// <exception cref="NotImplementedException"></exception>
-    public async Task AddProcess(IDatabaseWidgetManager databaseWidgetManager, IBaseUnitOfWork baseUnitOfWork, TEntity entity, TObjectContract contract)
+    public async Task AddProcess(IDatabaseWidgetManager databaseWidgetManager, IBaseUnitOfWork baseUnitOfWork, TEntity entity, TObjectContract contract, CancellationToken cancellationToken = default)
     {
         var reportEntity = await baseUnitOfWork
             .GetMapper()
@@ -77,7 +79,7 @@ public async Task AddProcess(IDatabaseWidgetManager databaseWidgetManager, IBase
         });
         DatabaseExtensions.SetIdToRecordId(logic.GetReadableContext(), entity, reportEntity);
         await logic
-            .Add(reportEntity)
+            .Add(reportEntity, cancellationToken)
             .AsCheckedResult();
     }
 
@@ -87,8 +89,9 @@ await logic
     /// <param name="databaseWidgetManager"></param>
     /// <param name="baseUnitOfWork"></param>
     /// <param name="items"></param>
+    /// <param name="cancellationToken"></param>
     /// <returns></returns>
-    public async Task AddBulkProcess(IDatabaseWidgetManager databaseWidgetManager, IBaseUnitOfWork baseUnitOfWork, Dictionary<TObjectContract, TEntity> items)
+    public async Task AddBulkProcess(IDatabaseWidgetManager databaseWidgetManager, IBaseUnitOfWork baseUnitOfWork, Dictionary<TObjectContract, TEntity> items, CancellationToken cancellationToken = default)
     {
         var reportEntities = await baseUnitOfWork
             .GetMapper()
@@ -99,7 +102,7 @@ public async Task AddBulkProcess(IDatabaseWidgetManager databaseWidgetManager, I
         });
         DatabaseExtensions.SetIdToRecordId(logic.GetReadableContext(), reportEntities);
         await logic
-            .AddBulk(reportEntities.Values.ToList())
+            .AddBulk(reportEntities.Values.ToList(), cancellationToken)
             .AsCheckedResult();
     }
-}
+}

src/CSharp/EasyMicroservices.Cores.Database/EasyMicroservices.Cores.Database.csproj

@@ -4,7 +4,7 @@
     <TargetFrameworks>netstandard2.0;netstandard2.1;net45;net6.0;net8.0</TargetFrameworks>
     <Platforms>AnyCPU;x64;x86</Platforms>
     <Authors>EasyMicroservices</Authors>
-    <Version>0.0.1.51</Version>
+    <Version>0.0.1.52</Version>
     <Description>core of database.</Description>
     <Copyright>[email protected]</Copyright>
     <PackageTags>core,cores,base,database</PackageTags>

src/CSharp/EasyMicroservices.Cores.EntityFrameworkCore/EasyMicroservices.Cores.EntityFrameworkCore.csproj

@@ -4,7 +4,7 @@
     <TargetFrameworks>netstandard2.1;net6.0;net8.0</TargetFrameworks>
     <Platforms>AnyCPU;x64;x86</Platforms>
     <Authors>EasyMicroservices</Authors>
-    <Version>0.0.1.51</Version>
+    <Version>0.0.1.52</Version>
     <Description>ef core of database.</Description>
     <Copyright>[email protected]</Copyright>
     <PackageTags>core,cores,base,database,ef,efcore</PackageTags>

src/CSharp/EasyMicroservices.Cores.Infrastructure/EasyMicroservices.Cores.Infrastructure.csproj

@@ -4,7 +4,7 @@
     <TargetFrameworks>netstandard2.0;netstandard2.1;net45;net6.0;net8.0</TargetFrameworks>
     <Platforms>AnyCPU;x64;x86</Platforms>
     <Authors>EasyMicroservices</Authors>
-    <Version>0.0.1.51</Version>
+    <Version>0.0.1.52</Version>
     <Description>core of infrastructure.</Description>
     <Copyright>[email protected]</Copyright>
     <PackageTags>core,cores,base,infrastructure</PackageTags>

src/CSharp/EasyMicroservices.Cores.Relational.EntityFrameworkCore/EasyMicroservices.Cores.Relational.EntityFrameworkCore.csproj

@@ -4,7 +4,7 @@
     <TargetFrameworks>netstandard2.1;net6.0;net7.0;net8.0</TargetFrameworks>
     <Platforms>AnyCPU;x64;x86</Platforms>
     <Authors>EasyMicroservices</Authors>
-    <Version>0.0.1.51</Version>
+    <Version>0.0.1.52</Version>
     <Description>ef core of Relational database.</Description>
     <Copyright>[email protected]</Copyright>
     <PackageTags>core,cores,base,database,ef,efcore,Relational</PackageTags>