// (c) Copyright Ascensio System SIA 2010-2022 // // This program is a free software product. // You can redistribute it and/or modify it under the terms // of the GNU Affero General Public License (AGPL) version 3 as published by the Free Software // Foundation. In accordance with Section 7(a) of the GNU AGPL its Section 15 shall be amended // to the effect that Ascensio System SIA expressly excludes the warranty of non-infringement of // any third-party rights. // // This program is distributed WITHOUT ANY WARRANTY, without even the implied warranty // of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. For details, see // the GNU AGPL at: http://www.gnu.org/licenses/agpl-3.0.html // // You can contact Ascensio System SIA at Lubanas st. 125a-25, Riga, Latvia, EU, LV-1021. // // The interactive user interfaces in modified source and object code versions of the Program must // display Appropriate Legal Notices, as required under Section 5 of the GNU AGPL version 3. // // Pursuant to Section 7(b) of the License you must retain the original Product logo when // distributing the program. Pursuant to Section 7(e) we decline to grant you any rights under // trademark law for use of our trademarks. // // All the Product's GUI elements, including illustrations and icon sets, as well as technical writing // content are licensed under the terms of the Creative Commons Attribution-ShareAlike 4.0 // International. See the License terms at http://creativecommons.org/licenses/by-sa/4.0/legalcode using JsonSerializer = System.Text.Json.JsonSerializer; namespace ASC.Core.Data; [Singletone] public class DbSettingsManagerCache { public ICache Cache { get; } private readonly ICacheNotify _notify; public DbSettingsManagerCache(ICacheNotify notify, ICache cache) { Cache = cache; _notify = notify; _notify.Subscribe((i) => Cache.Remove(i.Key), CacheNotifyAction.Remove); } public void Remove(string key) { _notify.Publish(new SettingsCacheItem { Key = key }, CacheNotifyAction.Remove); } } [Scope] class ConfigureDbSettingsManager : IConfigureNamedOptions { private readonly IServiceProvider _serviceProvider; private readonly DbSettingsManagerCache _dbSettingsManagerCache; private readonly ILogger _logger; private readonly AuthContext _authContext; private readonly IOptionsSnapshot _tenantManager; private readonly DbContextManager _dbContextManager; public ConfigureDbSettingsManager( IServiceProvider serviceProvider, DbSettingsManagerCache dbSettingsManagerCache, ILogger iLog, AuthContext authContext, IOptionsSnapshot tenantManager, DbContextManager dbContextManager ) { _serviceProvider = serviceProvider; _dbSettingsManagerCache = dbSettingsManagerCache; _logger = iLog; _authContext = authContext; _tenantManager = tenantManager; _dbContextManager = dbContextManager; } public void Configure(string name, DbSettingsManager options) { Configure(options); options.TenantManager = _tenantManager.Get(name); options.LazyWebstudioDbContext = new Lazy(() => _dbContextManager.Get(name)); } public void Configure(DbSettingsManager options) { options.ServiceProvider = _serviceProvider; options.DbSettingsManagerCache = _dbSettingsManagerCache; options.AuthContext = _authContext; options.Logger = _logger; options.TenantManager = _tenantManager.Value; options.LazyWebstudioDbContext = new Lazy(() => _dbContextManager.Value); } } [Scope(typeof(ConfigureDbSettingsManager))] public class DbSettingsManager { private readonly TimeSpan _expirationTimeout = TimeSpan.FromMinutes(5); internal ILogger Logger { get; set; } internal ICache Cache { get; set; } internal IServiceProvider ServiceProvider { get; set; } internal DbSettingsManagerCache DbSettingsManagerCache { get; set; } internal AuthContext AuthContext { get; set; } internal TenantManager TenantManager { get; set; } internal Lazy LazyWebstudioDbContext; internal WebstudioDbContext WebstudioDbContext => LazyWebstudioDbContext.Value; public DbSettingsManager() { } public DbSettingsManager( IServiceProvider serviceProvider, DbSettingsManagerCache dbSettingsManagerCache, ILogger logger, AuthContext authContext, TenantManager tenantManager, DbContextManager dbContextManager) { ServiceProvider = serviceProvider; DbSettingsManagerCache = dbSettingsManagerCache; AuthContext = authContext; TenantManager = tenantManager; Cache = dbSettingsManagerCache.Cache; Logger = logger; LazyWebstudioDbContext = new Lazy(() => dbContextManager.Value); } private int _tenantID; private int TenantID { get { if (_tenantID == 0) { _tenantID = TenantManager.GetCurrentTenant().Id; } return _tenantID; } } // private Guid? _currentUserID; private Guid CurrentUserID { get { _currentUserID ??= AuthContext.CurrentAccount.ID; return _currentUserID.Value; } } public bool SaveSettings(T settings, int tenantId) where T : class, ISettings { return SaveSettingsFor(settings, tenantId, Guid.Empty); } public T LoadSettings(int tenantId) where T : class, ISettings { return LoadSettingsFor(tenantId, Guid.Empty); } public void ClearCache(int tenantId) where T : class, ISettings { var settings = LoadSettings(tenantId); var key = settings.ID.ToString() + tenantId + Guid.Empty; DbSettingsManagerCache.Remove(key); } public bool SaveSettingsFor(T settings, int tenantId, Guid userId) where T : class, ISettings { ArgumentNullException.ThrowIfNull(settings); try { var key = settings.ID.ToString() + tenantId + userId; var data = Serialize(settings); var def = GetDefault(); var defaultData = Serialize(def); if (data.SequenceEqual(defaultData)) { var strategy = WebstudioDbContext.Database.CreateExecutionStrategy(); strategy.Execute(() => { using var tr = WebstudioDbContext.Database.BeginTransaction(); // remove default settings var s = WebstudioDbContext.WebstudioSettings .Where(r => r.Id == settings.ID) .Where(r => r.TenantId == tenantId) .Where(r => r.UserId == userId) .FirstOrDefault(); if (s != null) { WebstudioDbContext.WebstudioSettings.Remove(s); } WebstudioDbContext.SaveChanges(); tr.Commit(); }); } else { var s = new DbWebstudioSettings { Id = settings.ID, UserId = userId, TenantId = tenantId, Data = data }; WebstudioDbContext.AddOrUpdate(r => r.WebstudioSettings, s); WebstudioDbContext.SaveChanges(); } DbSettingsManagerCache.Remove(key); Cache.Insert(key, settings, _expirationTimeout); return true; } catch (Exception ex) { Logger.ErrorSaveSettingsFor(ex); return false; } } internal T LoadSettingsFor(int tenantId, Guid userId) where T : class, ISettings { var def = GetDefault(); var key = def.ID.ToString() + tenantId + userId; try { var settings = Cache.Get(key); if (settings != null) { return settings; } var result = WebstudioDbContext.WebstudioSettings .Where(r => r.Id == def.ID) .Where(r => r.TenantId == tenantId) .Where(r => r.UserId == userId) .Select(r => r.Data) .FirstOrDefault(); if (result != null) { settings = Deserialize(result); } else { settings = def; } Cache.Insert(key, settings, _expirationTimeout); return settings; } catch (Exception ex) { Logger.ErrorLoadSettingsFor(ex); } return def; } public T GetDefault() where T : class, ISettings { var settingsInstance = ActivatorUtilities.CreateInstance(ServiceProvider); return settingsInstance.GetDefault(); } public T Load() where T : class, ISettings { return LoadSettings(TenantID); } public T LoadForCurrentUser() where T : class, ISettings { return LoadForUser(CurrentUserID); } public T LoadForUser(Guid userId) where T : class, ISettings { return LoadSettingsFor(TenantID, userId); } public T LoadForDefaultTenant() where T : class, ISettings { return LoadForTenant(Tenant.DefaultTenant); } public T LoadForTenant(int tenantId) where T : class, ISettings { return LoadSettings(tenantId); } public virtual bool Save(T data) where T : class, ISettings { return SaveSettings(data, TenantID); } public bool SaveForCurrentUser(T data) where T : class, ISettings { return SaveForUser(data, CurrentUserID); } public bool SaveForUser(T data, Guid userId) where T : class, ISettings { return SaveSettingsFor(data, TenantID, userId); } public bool SaveForDefaultTenant(T data) where T : class, ISettings { return SaveForTenant(data, Tenant.DefaultTenant); } public bool SaveForTenant(T data, int tenantId) where T : class, ISettings { return SaveSettings(data, tenantId); } public void ClearCache() where T : class, ISettings { ClearCache(TenantID); } private T Deserialize(string data) { var options = new JsonSerializerOptions { PropertyNameCaseInsensitive = true, }; return JsonSerializer.Deserialize(data, options); } private string Serialize(T settings) { return JsonSerializer.Serialize(settings); } }