Fix EfCore Session Store Transaction & Save Changes (#42)

mckaragoz · web-flow · commit 49eaac54c0ff · 2026-04-20T13:14:57.000+03:00
diff --git a/docs/website/CodeBeam.UltimateAuth.Docs.Wasm/CodeBeam.UltimateAuth.Docs.Wasm.Client/Pages/DocsSidebar.razor b/docs/website/CodeBeam.UltimateAuth.Docs.Wasm/CodeBeam.UltimateAuth.Docs.Wasm.Client/Pages/DocsSidebar.razor
@@ -35,7 +35,6 @@
 
 @code {
     private Dictionary<string, List<DocIndexItem>>? _groups;
-    private DocIndexItem? _selectedValue;
     private bool _expanded = true;
 
     [Parameter]
diff --git a/samples/UAuthHub/CodeBeam.UltimateAuth.Sample.UAuthHub.EFCore/uauthhub.db-shm b/samples/UAuthHub/CodeBeam.UltimateAuth.Sample.UAuthHub.EFCore/uauthhub.db-shm
diff --git a/samples/UAuthHub/CodeBeam.UltimateAuth.Sample.UAuthHub.EFCore/uauthhub.db-wal b/samples/UAuthHub/CodeBeam.UltimateAuth.Sample.UAuthHub.EFCore/uauthhub.db-wal
diff --git a/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer.EFCore/Components/Dialogs/CreateUserDialog.razor.cs b/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer.EFCore/Components/Dialogs/CreateUserDialog.razor.cs
@@ -18,7 +18,7 @@ public partial class CreateUserDialog
 
     private async Task CreateUserAsync()
     {
-        await _form.Validate();
+        await _form.ValidateAsync();
 
         if (!_form.IsValid)
             return;
diff --git a/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer.EFCore/Components/Dialogs/CredentialDialog.razor.cs b/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer.EFCore/Components/Dialogs/CredentialDialog.razor.cs
@@ -31,7 +31,7 @@ private async Task ChangePasswordAsync()
         if (_form is null)
             return;
 
-        await _form.Validate();
+        await _form.ValidateAsync();
         if (!_form.IsValid)
         {
             Snackbar.Add("Form is not valid.", Severity.Error);
diff --git a/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer.EFCore/Components/Dialogs/ProfileDialog.razor.cs b/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer.EFCore/Components/Dialogs/ProfileDialog.razor.cs
@@ -70,7 +70,7 @@ private async Task SaveAsync()
 
         if (_form is not null)
         {
-            await _form.Validate();
+            await _form.ValidateAsync();
             if (!_form.IsValid)
                 return;
         }
diff --git a/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer.EFCore/Components/Pages/Register.razor.cs b/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer.EFCore/Components/Pages/Register.razor.cs
@@ -20,7 +20,7 @@ protected override async Task OnInitializedAsync()
 
     private async Task HandleRegisterAsync()
     {
-        await _form.Validate();
+        await _form.ValidateAsync();
         
         if (!_form.IsValid)
             return;
diff --git a/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer.EFCore/Components/Pages/ResetCredential.razor.cs b/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer.EFCore/Components/Pages/ResetCredential.razor.cs
@@ -12,7 +12,7 @@ public partial class ResetCredential
 
     private async Task ResetPasswordAsync()
     {
-        await _form.Validate();
+        await _form.ValidateAsync();
         if (!_form.IsValid)
         {
             Snackbar.Add("Please fix the validation errors.", Severity.Error);
diff --git a/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer.EFCore/uauth.db b/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer.EFCore/uauth.db
diff --git a/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer.EFCore/uauth.db-shm b/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer.EFCore/uauth.db-shm
diff --git a/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer.EFCore/uauth.db-wal b/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer.EFCore/uauth.db-wal
diff --git a/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer/Components/Dialogs/CreateUserDialog.razor.cs b/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer/Components/Dialogs/CreateUserDialog.razor.cs
@@ -18,7 +18,7 @@ public partial class CreateUserDialog
 
     private async Task CreateUserAsync()
     {
-        await _form.Validate();
+        await _form.ValidateAsync();
 
         if (!_form.IsValid)
             return;
diff --git a/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer/Components/Dialogs/CredentialDialog.razor.cs b/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer/Components/Dialogs/CredentialDialog.razor.cs
@@ -31,7 +31,7 @@ private async Task ChangePasswordAsync()
         if (_form is null)
             return;
 
-        await _form.Validate();
+        await _form.ValidateAsync();
         if (!_form.IsValid)
         {
             Snackbar.Add("Form is not valid.", Severity.Error);
diff --git a/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer/Components/Dialogs/ProfileDialog.razor.cs b/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer/Components/Dialogs/ProfileDialog.razor.cs
@@ -70,7 +70,7 @@ private async Task SaveAsync()
 
         if (_form is not null)
         {
-            await _form.Validate();
+            await _form.ValidateAsync();
             if (!_form.IsValid)
                 return;
         }
diff --git a/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer/Components/Pages/Register.razor.cs b/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer/Components/Pages/Register.razor.cs
@@ -20,7 +20,7 @@ protected override async Task OnInitializedAsync()
 
     private async Task HandleRegisterAsync()
     {
-        await _form.Validate();
+        await _form.ValidateAsync();
         
         if (!_form.IsValid)
             return;
diff --git a/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer/Components/Pages/ResetCredential.razor.cs b/samples/blazor-server/CodeBeam.UltimateAuth.Sample.BlazorServer/Components/Pages/ResetCredential.razor.cs
@@ -12,7 +12,7 @@ public partial class ResetCredential
 
     private async Task ResetPasswordAsync()
     {
-        await _form.Validate();
+        await _form.ValidateAsync();
         if (!_form.IsValid)
         {
             Snackbar.Add("Please fix the validation errors.", Severity.Error);
diff --git a/samples/blazor-standalone-wasm/CodeBeam.UltimateAuth.Sample.BlazorStandaloneWasm/Components/Dialogs/CreateUserDialog.razor.cs b/samples/blazor-standalone-wasm/CodeBeam.UltimateAuth.Sample.BlazorStandaloneWasm/Components/Dialogs/CreateUserDialog.razor.cs
@@ -18,7 +18,7 @@ public partial class CreateUserDialog
 
     private async Task CreateUserAsync()
     {
-        await _form.Validate();
+        await _form.ValidateAsync();
 
         if (!_form.IsValid)
             return;
diff --git a/samples/blazor-standalone-wasm/CodeBeam.UltimateAuth.Sample.BlazorStandaloneWasm/Components/Dialogs/CredentialDialog.razor.cs b/samples/blazor-standalone-wasm/CodeBeam.UltimateAuth.Sample.BlazorStandaloneWasm/Components/Dialogs/CredentialDialog.razor.cs
@@ -31,7 +31,7 @@ private async Task ChangePasswordAsync()
         if (_form is null)
             return;
 
-        await _form.Validate();
+        await _form.ValidateAsync();
         if (!_form.IsValid)
         {
             Snackbar.Add("Form is not valid.", Severity.Error);
diff --git a/samples/blazor-standalone-wasm/CodeBeam.UltimateAuth.Sample.BlazorStandaloneWasm/Components/Dialogs/ProfileDialog.razor.cs b/samples/blazor-standalone-wasm/CodeBeam.UltimateAuth.Sample.BlazorStandaloneWasm/Components/Dialogs/ProfileDialog.razor.cs
@@ -72,7 +72,7 @@ private async Task SaveAsync()
 
         if (_form is not null)
         {
-            await _form.Validate();
+            await _form.ValidateAsync();
             if (!_form.IsValid)
                 return;
         }
diff --git a/samples/blazor-standalone-wasm/CodeBeam.UltimateAuth.Sample.BlazorStandaloneWasm/Pages/Register.razor.cs b/samples/blazor-standalone-wasm/CodeBeam.UltimateAuth.Sample.BlazorStandaloneWasm/Pages/Register.razor.cs
@@ -20,7 +20,7 @@ protected override async Task OnInitializedAsync()
 
     private async Task HandleRegisterAsync()
     {
-        await _form.Validate();
+        await _form.ValidateAsync();
         
         if (!_form.IsValid)
             return;
diff --git a/samples/blazor-standalone-wasm/CodeBeam.UltimateAuth.Sample.BlazorStandaloneWasm/Pages/ResetCredential.razor.cs b/samples/blazor-standalone-wasm/CodeBeam.UltimateAuth.Sample.BlazorStandaloneWasm/Pages/ResetCredential.razor.cs
@@ -12,7 +12,7 @@ public partial class ResetCredential
 
     private async Task ResetPasswordAsync()
     {
-        await _form.Validate();
+        await _form.ValidateAsync();
         if (!_form.IsValid)
         {
             Snackbar.Add("Please fix the validation errors.", Severity.Error);
diff --git a/src/CodeBeam.UltimateAuth.Server/Services/SessionApplicationService.cs b/src/CodeBeam.UltimateAuth.Server/Services/SessionApplicationService.cs
@@ -164,7 +164,9 @@ public async Task RevokeUserSessionAsync(AccessContext context, UserKey userKey,
             var expected = session.Version;
             var revoked = session.Revoke(now);
 
-            await store.SaveSessionAsync(revoked, expected);
+            await store.ExecuteAsync(async innerCt2 => {
+                await store.SaveSessionAsync(revoked, expected);
+            });
         });
 
         await _accessOrchestrator.ExecuteAsync(context, command, ct);
@@ -176,7 +178,10 @@ public async Task<RevokeResult> RevokeUserChainAsync(AccessContext context, User
         {
             var isCurrent = context.ActorChainId == chainId;
             var store = _storeFactory.Create(context.ResourceTenant);
-            await store.RevokeChainCascadeAsync(chainId, _clock.UtcNow);
+
+            await store.ExecuteAsync(async innerCt2 => {
+                await store.RevokeChainCascadeAsync(chainId, _clock.UtcNow);
+            });
 
             return new RevokeResult
             {
@@ -198,15 +203,18 @@ public async Task RevokeAllChainsAsync(AccessContext context, UserKey userKey, S
         var command = new AccessCommand(async innerCt =>
         {
             var store = _storeFactory.Create(context.ResourceTenant);
-            var chains = await store.GetChainsByUserAsync(userKey);
 
-            foreach (var chain in chains)
-            {
-                if (exceptChainId.HasValue && chain.ChainId == exceptChainId.Value)
-                    continue;
+            await store.ExecuteAsync(async innerCt2 => {
+                var chains = await store.GetChainsByUserAsync(userKey);
 
-                await store.RevokeChainCascadeAsync(chain.ChainId, _clock.UtcNow);
-            }
+                foreach (var chain in chains)
+                {
+                    if (exceptChainId.HasValue && chain.ChainId == exceptChainId.Value)
+                        continue;
+
+                    await store.RevokeChainCascadeAsync(chain.ChainId, _clock.UtcNow);
+                }
+            });
         });
 
         await _accessOrchestrator.ExecuteAsync(context, command, ct);
@@ -220,7 +228,9 @@ public async Task<RevokeResult> LogoutDeviceAsync(AccessContext context, Session
             var store = _storeFactory.Create(context.ResourceTenant);
             var now = _clock.UtcNow;
 
-            await store.LogoutChainAsync(currentChainId, now, innerCt);
+            await store.ExecuteAsync(async innerCt2 => {
+                await store.LogoutChainAsync(currentChainId, now, innerCt2);
+            });
 
             return new RevokeResult
             {
@@ -239,7 +249,10 @@ public async Task LogoutOtherDevicesAsync(AccessContext context, UserKey userKey
             var store = _storeFactory.Create(context.ResourceTenant);
             var now = _clock.UtcNow;
 
-            await store.RevokeOtherSessionsAsync(userKey, currentChainId, now, innerCt);
+            await store.ExecuteAsync(async innerCt2 => {
+                await store.RevokeOtherSessionsAsync(userKey, currentChainId, now, innerCt2);
+            });
+            
         });
 
         await _accessOrchestrator.ExecuteAsync(context, command, ct);
@@ -252,7 +265,9 @@ public async Task LogoutAllDevicesAsync(AccessContext context, UserKey userKey,
             var store = _storeFactory.Create(context.ResourceTenant);
             var now = _clock.UtcNow;
 
-            await store.RevokeAllSessionsAsync(userKey, now, innerCt);
+            await store.ExecuteAsync(async innerCt2 => {
+                await store.RevokeAllSessionsAsync(userKey, now, innerCt2);
+            });
         });
 
         await _accessOrchestrator.ExecuteAsync(context, command, ct);
@@ -263,7 +278,10 @@ public async Task RevokeRootAsync(AccessContext context, UserKey userKey, Cancel
         var command = new AccessCommand(async innerCt =>
         {
             var store = _storeFactory.Create(context.ResourceTenant);
-            await store.RevokeRootCascadeAsync(userKey, _clock.UtcNow);
+
+            await store.ExecuteAsync(async innerCt2 => {
+                await store.RevokeRootCascadeAsync(userKey, _clock.UtcNow);
+            });
         });
 
         await _accessOrchestrator.ExecuteAsync(context, command, ct);
diff --git a/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/Stores/EfCoreSessionStore.cs b/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/Stores/EfCoreSessionStore.cs
diff --git a/tests/CodeBeam.UltimateAuth.Tests.Unit/EntityFrameworkCore/EfCoreSessionStoreTests.cs b/tests/CodeBeam.UltimateAuth.Tests.Unit/EntityFrameworkCore/EfCoreSessionStoreTests.cs

Original file line number	Diff line number	Diff line change
`@@ -18,7 +18,7 @@ public partial class CreateUserDialog`
`18`	`18`
`19`	`19`	`private async Task CreateUserAsync()`
`20`	`20`	`{`
`21`		`- await _form.Validate();`
	`21`	`+ await _form.ValidateAsync();`
`22`	`22`
`23`	`23`	`if (!_form.IsValid)`
`24`	`24`	`return;`
Original file line number	Diff line number	Diff line change
`@@ -31,7 +31,7 @@ private async Task ChangePasswordAsync()`
`31`	`31`	`if (_form is null)`
`32`	`32`	`return;`
`33`	`33`
`34`		`- await _form.Validate();`
	`34`	`+ await _form.ValidateAsync();`
`35`	`35`	`if (!_form.IsValid)`
`36`	`36`	`{`
`37`	`37`	`Snackbar.Add("Form is not valid.", Severity.Error);`
Original file line number	Diff line number	Diff line change
`@@ -70,7 +70,7 @@ private async Task SaveAsync()`
`70`	`70`
`71`	`71`	`if (_form is not null)`
`72`	`72`	`{`
`73`		`- await _form.Validate();`
	`73`	`+ await _form.ValidateAsync();`
`74`	`74`	`if (!_form.IsValid)`
`75`	`75`	`return;`
`76`	`76`	`}`
Original file line number	Diff line number	Diff line change
`@@ -20,7 +20,7 @@ protected override async Task OnInitializedAsync()`
`20`	`20`
`21`	`21`	`private async Task HandleRegisterAsync()`
`22`	`22`	`{`
`23`		`- await _form.Validate();`
	`23`	`+ await _form.ValidateAsync();`
`24`	`24`
`25`	`25`	`if (!_form.IsValid)`
`26`	`26`	`return;`
Original file line number	Diff line number	Diff line change
`@@ -12,7 +12,7 @@ public partial class ResetCredential`
`12`	`12`
`13`	`13`	`private async Task ResetPasswordAsync()`
`14`	`14`	`{`
`15`		`- await _form.Validate();`
	`15`	`+ await _form.ValidateAsync();`
`16`	`16`	`if (!_form.IsValid)`
`17`	`17`	`{`
`18`	`18`	`Snackbar.Add("Please fix the validation errors.", Severity.Error);`