/* * * (c) Copyright Ascensio System Limited 2010-2018 * * This program is freeware. You can redistribute it and/or modify it under the terms of the GNU * General Public License (GPL) version 3 as published by the Free Software Foundation (https://www.gnu.org/copyleft/gpl.html). * In accordance with Section 7(a) of the GNU GPL 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 more details, see GNU GPL at https://www.gnu.org/copyleft/gpl.html * * You can contact Ascensio System SIA by email at sales@onlyoffice.com * * The interactive user interfaces in modified source and object code versions of ONLYOFFICE must display * Appropriate Legal Notices, as required under Section 5 of the GNU GPL version 3. * * Pursuant to Section 7 § 3(b) of the GNU GPL you must retain the original ONLYOFFICE logo which contains * relevant author attributions when distributing the software. If the display of the logo in its graphic * form is not reasonably feasible for technical reasons, you must include the words "Powered by ONLYOFFICE" * in every copy of the program you distribute. * Pursuant to Section 7 § 3(e) we decline to grant you any rights under trademark law for use of our trademarks. * */ using System; using System.Collections; using System.Collections.Generic; using System.Linq; using ASC.Common; using ASC.Common.Caching; using ASC.Core.Tenants; using Autofac; using Microsoft.Extensions.Configuration; namespace ASC.Core.Common.Configuration { public class Consumer : IDictionary { public bool CanSet { get; private set; } public int Order { get; private set; } public string Name { get; private set; } protected readonly Dictionary Props; public IEnumerable ManagedKeys { get { return Props.Select(r => r.Key).ToList(); } } protected readonly Dictionary Additional; public virtual IEnumerable AdditionalKeys { get { return Additional.Select(r => r.Key).ToList(); } } public ICollection Keys { get { return AllProps.Keys; } } public ICollection Values { get { return AllProps.Values; } } private Dictionary AllProps { get { var result = Props.ToDictionary(item => item.Key, item => item.Value); foreach (var item in Additional.Where(item => !result.ContainsKey(item.Key))) { result.Add(item.Key, item.Value); } return result; } } private readonly bool OnlyDefault; internal protected TenantManager TenantManager { get; set; } internal protected CoreBaseSettings CoreBaseSettings { get; set; } internal protected CoreSettings CoreSettings { get; set; } internal protected ConsumerFactory ConsumerFactory { get; set; } internal protected IConfiguration Configuration { get; } internal protected ICacheNotify Cache { get; } public bool IsSet { get { return Props.Count > 0 && !Props.All(r => string.IsNullOrEmpty(this[r.Key])); } } static Consumer() { } public Consumer() { Props = new Dictionary(); Additional = new Dictionary(); } public Consumer( TenantManager tenantManager, CoreBaseSettings coreBaseSettings, CoreSettings coreSettings, IConfiguration configuration, ICacheNotify cache, ConsumerFactory consumerFactory) : this() { TenantManager = tenantManager; CoreBaseSettings = coreBaseSettings; CoreSettings = coreSettings; Configuration = configuration; Cache = cache; ConsumerFactory = consumerFactory; OnlyDefault = configuration["core:default-consumers"] == "true"; Name = ""; Order = int.MaxValue; } public Consumer( TenantManager tenantManager, CoreBaseSettings coreBaseSettings, CoreSettings coreSettings, IConfiguration configuration, ICacheNotify cache, ConsumerFactory consumerFactory, string name, int order, Dictionary additional) : this(tenantManager, coreBaseSettings, coreSettings, configuration, cache, consumerFactory) { Name = name; Order = order; Props = new Dictionary(); Additional = additional; } public Consumer( TenantManager tenantManager, CoreBaseSettings coreBaseSettings, CoreSettings coreSettings, IConfiguration configuration, ICacheNotify cache, ConsumerFactory consumerFactory, string name, int order, Dictionary props, Dictionary additional = null) : this(tenantManager, coreBaseSettings, coreSettings, configuration, cache, consumerFactory) { Name = name; Order = order; Props = props ?? new Dictionary(); Additional = additional ?? new Dictionary(); if (props != null && props.Count > 0) { CanSet = props.All(r => string.IsNullOrEmpty(r.Value)); } } public IEnumerator> GetEnumerator() { return AllProps.GetEnumerator(); } IEnumerator IEnumerable.GetEnumerator() { return GetEnumerator(); } public void Add(KeyValuePair item) { } public void Clear() { if (!CanSet) { throw new NotSupportedException("Key for read only. Consumer " + Name); } foreach (var providerProp in Props) { this[providerProp.Key] = null; } Cache.Publish(new ConsumerCacheItem() { Name = this.Name }, CacheNotifyAction.Remove); } public bool Contains(KeyValuePair item) { return AllProps.Contains(item); } public void CopyTo(KeyValuePair[] array, int arrayIndex) { } public bool Remove(KeyValuePair item) { return AllProps.Remove(item.Key); } public int Count { get { return AllProps.Count; } } public bool IsReadOnly { get { return true; } } public bool ContainsKey(string key) { return AllProps.ContainsKey(key); } public void Add(string key, string value) { } public bool Remove(string key) { return false; } public bool TryGetValue(string key, out string value) { return AllProps.TryGetValue(key, out value); } public string this[string key] { get { return Get(key); } set { Set(key, value); } } private string Get(string name) { string value = null; if (!OnlyDefault && CanSet) { var tenant = CoreBaseSettings.Standalone ? Tenant.DEFAULT_TENANT : TenantManager.GetCurrentTenant().TenantId; value = CoreSettings.GetSetting(GetSettingsKey(name), tenant); } if (string.IsNullOrEmpty(value)) { AllProps.TryGetValue(name, out value); } return value; } private void Set(string name, string value) { if (!CanSet) { throw new NotSupportedException("Key for read only. Key " + name); } if (!ManagedKeys.Contains(name)) { if (Additional.ContainsKey(name)) { Additional[name] = value; } else { Additional.Add(name, value); } return; } var tenant = CoreBaseSettings.Standalone ? Tenant.DEFAULT_TENANT : TenantManager.GetCurrentTenant().TenantId; CoreSettings.SaveSetting(GetSettingsKey(name), value, tenant); } protected virtual string GetSettingsKey(string name) { return "AuthKey_" + name; } } public class DataStoreConsumer : Consumer, ICloneable { public Type HandlerType { get; private set; } public DataStoreConsumer Cdn { get; private set; } public const string HandlerTypeKey = "handlerType"; public const string CdnKey = "cdn"; public DataStoreConsumer() : base() { } public DataStoreConsumer( TenantManager tenantManager, CoreBaseSettings coreBaseSettings, CoreSettings coreSettings, IConfiguration configuration, ICacheNotify cache, ConsumerFactory consumerFactory) : base(tenantManager, coreBaseSettings, coreSettings, configuration, cache, consumerFactory) { } public DataStoreConsumer( TenantManager tenantManager, CoreBaseSettings coreBaseSettings, CoreSettings coreSettings, IConfiguration configuration, ICacheNotify cache, ConsumerFactory consumerFactory, string name, int order, Dictionary additional) : base(tenantManager, coreBaseSettings, coreSettings, configuration, cache, consumerFactory, name, order, additional) { Init(additional); } public DataStoreConsumer( TenantManager tenantManager, CoreBaseSettings coreBaseSettings, CoreSettings coreSettings, IConfiguration configuration, ICacheNotify cache, ConsumerFactory consumerFactory, string name, int order, Dictionary props, Dictionary additional) : base(tenantManager, coreBaseSettings, coreSettings, configuration, cache, consumerFactory, name, order, props, additional) { Init(additional); } public override IEnumerable AdditionalKeys { get { return base.AdditionalKeys.Where(r => r != HandlerTypeKey && r != "cdn").ToList(); } } protected override string GetSettingsKey(string name) { return base.GetSettingsKey(Name + name); } private void Init(IReadOnlyDictionary additional) { if (additional == null || !additional.ContainsKey(HandlerTypeKey)) throw new ArgumentException(HandlerTypeKey); HandlerType = Type.GetType(additional[HandlerTypeKey]); if (additional.TryGetValue(CdnKey, out var value)) { Cdn = GetCdn(value); } } private DataStoreConsumer GetCdn(string cdn) { var fromConfig = ConsumerFactory.GetByKey(cdn); if (string.IsNullOrEmpty(fromConfig.Name)) return null; var props = ManagedKeys.ToDictionary(prop => prop, prop => this[prop]); var additional = fromConfig.AdditionalKeys.ToDictionary(prop => prop, prop => fromConfig[prop]); additional.Add(HandlerTypeKey, HandlerType.AssemblyQualifiedName); return new DataStoreConsumer(fromConfig.TenantManager, fromConfig.CoreBaseSettings, fromConfig.CoreSettings, fromConfig.Configuration, fromConfig.Cache, fromConfig.ConsumerFactory, fromConfig.Name, fromConfig.Order, props, additional); } public object Clone() { return new DataStoreConsumer(TenantManager, CoreBaseSettings, CoreSettings, Configuration, Cache, ConsumerFactory, Name, Order, Props.ToDictionary(r => r.Key, r => r.Value), Additional.ToDictionary(r => r.Key, r => r.Value)); } } [Scope] public class ConsumerFactory : IDisposable { public ILifetimeScope Builder { get; set; } public ConsumerFactory(IContainer builder) { Builder = builder.BeginLifetimeScope(); } public ConsumerFactory(ILifetimeScope builder) { Builder = builder; } public Consumer GetByKey(string key) { if (Builder.TryResolveKeyed(key, typeof(Consumer), out var result)) { return (Consumer)result; } return new Consumer(); } public T GetByKey(string key) where T : Consumer, new() { if (Builder.TryResolveKeyed(key, typeof(T), out var result)) { return (T)result; } return new T(); } public T Get() where T : Consumer, new() { if (Builder.TryResolve(out T result)) { return result; } return new T(); } public IEnumerable GetAll() where T : Consumer, new() { return Builder.Resolve>(); } public void Dispose() { Builder.Dispose(); } } }