up

Author: baoduy

src/DKNet.FW.sln.DotSettings.user

@@ -573,6 +573,9 @@
 &lt;/AssemblyExplorer&gt;</s:String>
 	<s:Boolean x:Key="/Default/Environment/Filtering/ExcludeCoverageFilters/=_002ATests_002A_003B_002A_003B_002A_003B_002A/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/Environment/SettingsMigration/IsMigratorApplied/=JetBrains_002EReSharper_002EPsi_002ECSharp_002ECodeStyle_002EMemberReordering_002EMigrations_002ECSharpFileLayoutPatternRemoveIsAttributeUpgrade/@EntryIndexedValue">True</s:Boolean>
+	<s:String x:Key="/Default/Environment/UnitTesting/UnitTestSessionStore/Sessions/=1dff25f3_002Dfbaa_002D485f_002Daa89_002D134e33eadc1a/@EntryIndexedValue">&lt;SessionState ContinuousTestingMode="0" IsActive="True" Name="All tests from &amp;lt;SlimBus&amp;gt;\&amp;lt;SlimBus.Extensions.Tests&amp;gt;" xmlns="urn:schemas-jetbrains-com:jetbrains-ut-session"&gt;
+  &lt;Project Location="/Users/steven/_CODE/DRUNK/DKNet/src/SlimBus/SlimBus.Extensions.Tests" Presentation="&amp;lt;SlimBus&amp;gt;\&amp;lt;SlimBus.Extensions.Tests&amp;gt;" /&gt;
+&lt;/SessionState&gt;</s:String>
 	<s:String x:Key="/Default/Environment/UnitTesting/UnitTestSessionStore/Sessions/=8275c8a4_002D4ae3_002D406a_002D9cd0_002D6dc520603cf1/@EntryIndexedValue">&lt;SessionState ContinuousTestingMode="0" Name="All tests from &amp;lt;EfCore&amp;gt;\&amp;lt;EfCore.Specifications.Tests&amp;gt;" xmlns="urn:schemas-jetbrains-com:jetbrains-ut-session"&gt;
   &lt;Project Location="/Users/steven/_CODE/DRUNK/DKNet/src/EfCore/EfCore.Specifications.Tests" Presentation="&amp;lt;EfCore&amp;gt;\&amp;lt;EfCore.Specifications.Tests&amp;gt;" /&gt;
 &lt;/SessionState&gt;</s:String>

src/SlimBus/DKNet.SlimBus.Extensions/Behaviors/EfAutoSavePostProcessor.cs

@@ -24,27 +24,22 @@ public async Task<TResponse> OnHandle(TRequest request, Func<Task<TResponse>> ne
         var response = await next();
 
         //If response is null or failed, do not save changes
-        if (response is null || response is IResultBase { IsSuccess: false })
-        {
-            return response;
-        }
+        if (response is null || response is IResultBase { IsSuccess: false }) return response;
 
         //If request is a query type, do not save changes
         if (request is Fluents.Queries.IWitResponse<TResponse> ||
             request is Fluents.Queries.IWitPageResponse<TResponse>
             || request is Fluents.EventsConsumers.IHandler<IRequest>)
-        {
             return response;
-        }
 
-        // Save changes for all DbContexts with changes
-        var dbContexts = serviceProvider.GetServices<DbContext>().Distinct();
+        var dbContexts = serviceProvider.GetServices<DbContext>();
         foreach (var db in dbContexts.Where(db => db.ChangeTracker.HasChanges()))
         {
             await db.AddNewEntitiesFromNavigations(context.CancellationToken);
             await db.SaveChangesAsync(context.CancellationToken);
         }
 
+
         return response;
     }