From 91a1bfcab2d11c8400f5662aed6cd4832b72d541 Mon Sep 17 00:00:00 2001 From: isaeed Date: Sun, 20 Jun 2021 17:52:41 +0500 Subject: [PATCH] adding SaveChangesAsync overloads to support Async save --- Oqtane.Server/Repository/Context/DBContextBase.cs | 9 +++++++++ Oqtane.Server/Repository/Context/MasterDBContext.cs | 9 +++++++++ 2 files changed, 18 insertions(+) diff --git a/Oqtane.Server/Repository/Context/DBContextBase.cs b/Oqtane.Server/Repository/Context/DBContextBase.cs index 4a5180e6..926bdcf2 100644 --- a/Oqtane.Server/Repository/Context/DBContextBase.cs +++ b/Oqtane.Server/Repository/Context/DBContextBase.cs @@ -1,4 +1,6 @@ using System; +using System.Threading; +using System.Threading.Tasks; using Microsoft.AspNetCore.Http; using Microsoft.AspNetCore.Identity; using Microsoft.AspNetCore.Identity.EntityFrameworkCore; @@ -84,6 +86,13 @@ namespace Oqtane.Repository return base.SaveChanges(); } + public override Task SaveChangesAsync(CancellationToken cancellationToken = default) + { + DbContextUtils.SaveChanges(this, _accessor); + + return base.SaveChangesAsync(cancellationToken); + } + [Obsolete("This constructor is obsolete. Use DBContextBase(ITenantManager tenantManager, IHttpContextAccessor httpContextAccessor) instead.", false)] public DBContextBase(ITenantResolver tenantResolver, IHttpContextAccessor httpContextAccessor) { diff --git a/Oqtane.Server/Repository/Context/MasterDBContext.cs b/Oqtane.Server/Repository/Context/MasterDBContext.cs index fe70ee0f..a7874100 100644 --- a/Oqtane.Server/Repository/Context/MasterDBContext.cs +++ b/Oqtane.Server/Repository/Context/MasterDBContext.cs @@ -12,6 +12,8 @@ using Oqtane.Interfaces; using Oqtane.Migrations.Framework; using Oqtane.Repository.Databases.Interfaces; using Oqtane.Shared; +using System.Threading.Tasks; +using System.Threading; // ReSharper disable BuiltInTypeReferenceStyleForMemberAccess // ReSharper disable UnusedAutoPropertyAccessor.Global @@ -75,5 +77,12 @@ namespace Oqtane.Repository return base.SaveChanges(); } + + public override Task SaveChangesAsync(CancellationToken cancellationToken = default) + { + DbContextUtils.SaveChanges(this, _accessor); + + return base.SaveChangesAsync(cancellationToken); + } } }