using System; using System.Collections.Generic; using System.Linq; using System.Reflection; using ASC.Common.Threading.Progress; using ASC.Common.Threading.Workers; using Microsoft.AspNetCore.Authentication; using Microsoft.AspNetCore.Mvc; using Microsoft.AspNetCore.Mvc.Filters; using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.DependencyInjection.Extensions; using Microsoft.Extensions.Options; namespace ASC.Common { public class TransientAttribute : DIAttribute { public TransientAttribute() { } public TransientAttribute(Type service) : base(service) { } public TransientAttribute(Type service, Type implementation) : base(service, implementation) { } } public class ScopeAttribute : DIAttribute { public ScopeAttribute() { } public ScopeAttribute(Type service) : base(service) { } public ScopeAttribute(Type service, Type implementation) : base(service, implementation) { } } public class SingletoneAttribute : DIAttribute { public SingletoneAttribute() { } public SingletoneAttribute(Type service) : base(service) { } public SingletoneAttribute(Type service, Type implementation) : base(service, implementation) { } } public class DIAttribute : Attribute { public Type Implementation { get; } public Type Service { get; } public Type Additional { get; set; } public DIAttribute() { } public DIAttribute(Type service) { Service = service; } public DIAttribute(Type service, Type implementation) { Implementation = implementation; Service = service; } } public class DIHelper { public List Added { get; set; } public List Singleton { get; set; } public List Scoped { get; set; } public List Transient { get; set; } public List Configured { get; set; } public IServiceCollection ServiceCollection { get; private set; } public DIHelper() { Added = new List(); Singleton = new List(); Scoped = new List(); Transient = new List(); Configured = new List(); } public DIHelper(IServiceCollection serviceCollection) : this() { ServiceCollection = serviceCollection; } public void Configure(IServiceCollection serviceCollection) { ServiceCollection = serviceCollection; } public bool TryAddScoped() where TService : class { var serviceName = $"{typeof(TService)}"; if (!Scoped.Contains(serviceName)) { Scoped.Add(serviceName); ServiceCollection.TryAddScoped(); return true; } return false; } public bool TryAdd() where TService : class { return TryAdd(typeof(TService)); } public bool TryAdd() where TService : class { return TryAdd(typeof(TService), typeof(TImplementation)); } public bool TryAdd(Type service, Type implementation = null) { if (service.IsInterface && service.IsGenericType && (service.GetGenericTypeDefinition() == typeof(IOptionsSnapshot<>) || service.GetGenericTypeDefinition() == typeof(IOptions<>))) { service = service.GetGenericArguments().FirstOrDefault(); if (service == null) { return false; } } var serviceName = $"{service}{implementation}"; if (Added.Contains(serviceName)) return false; Added.Add(serviceName); if (serviceName == "ASC.Notify.DbWorker") { var qqaz = 0; } var di = service.IsGenericType && (service.GetGenericTypeDefinition() == typeof(IConfigureOptions<>) || service.GetGenericTypeDefinition() == typeof(IPostConfigureOptions<>)) && implementation != null ? implementation.GetCustomAttribute() : service.GetCustomAttribute(); var isnew = false; if (di != null) { if (di.Additional != null) { var m = di.Additional.GetMethod("Register", BindingFlags.Public | BindingFlags.Static); m.Invoke(null, new[] { this }); } if (!service.IsInterface || implementation != null) { isnew = implementation != null ? Register(service, implementation) : Register(service); if (!isnew) return false; } if (service.IsInterface && implementation == null || !service.IsInterface) { if (di.Service != null) { var a = di.Service.GetInterfaces().FirstOrDefault(x => x.IsGenericType && (x.GetGenericTypeDefinition() == typeof(IConfigureOptions<>) || x.GetGenericTypeDefinition() == typeof(IPostConfigureOptions<>))); if (a != null) { if (!a.ContainsGenericParameters) { var b = a.GetGenericArguments(); foreach (var g in b) { if (g != service) { TryAdd(g); if (service.IsInterface && di.Implementation == null) { TryAdd(service, g); } } } TryAdd(a, di.Service); } else { Type c = null; var a1 = a.GetGenericTypeDefinition(); var b = a.GetGenericArguments().FirstOrDefault(); if (b != null && b.IsGenericType) { var b1 = b.GetGenericTypeDefinition().MakeGenericType(service.GetGenericArguments()); TryAdd(b1); c = a1.MakeGenericType(b1); } else { c = a1.MakeGenericType(service.GetGenericArguments()); } TryAdd(c, di.Service.MakeGenericType(service.GetGenericArguments())); //a, di.Service } } else { isnew = di.Implementation == null ? Register(service, di.Service) : Register(di.Service); } } if (di.Implementation != null) { var a = di.Implementation.GetInterfaces().FirstOrDefault(x => x.IsGenericType && (x.GetGenericTypeDefinition() == typeof(IConfigureOptions<>) || x.GetGenericTypeDefinition() == typeof(IPostConfigureOptions<>))); if (a != null) { if (!a.ContainsGenericParameters) { var b = a.GetGenericArguments(); foreach (var g in b) { if (g != service) { //TryAdd(g); if (service.IsInterface && implementation == null) { TryAdd(service, g); } } } TryAdd(a, di.Implementation); } else { Type c = null; var a1 = a.GetGenericTypeDefinition(); var b = a.GetGenericArguments().FirstOrDefault(); if (b != null && b.IsGenericType) { var b1 = b.GetGenericTypeDefinition().MakeGenericType(service.GetGenericArguments()); TryAdd(b1); c = a1.MakeGenericType(b1); } else { c = a1.MakeGenericType(service.GetGenericArguments()); } TryAdd(c, di.Implementation.MakeGenericType(service.GetGenericArguments())); //a, di.Service } } else { isnew = TryAdd(service, di.Implementation); } } } } if (isnew) { ConstructorInfo[] props = null; if (!service.IsInterface) { props = service.GetConstructors(); } else if (implementation != null) { props = implementation.GetConstructors(); } else if (di.Service != null) { props = di.Service.GetConstructors(); } if (props != null) { var par = props.SelectMany(r => r.GetParameters()).Distinct(); foreach (var p1 in par) { TryAdd(p1.ParameterType); } } } return isnew; } private bool Register(Type service) { if (service.IsSubclassOf(typeof(ControllerBase)) || service.GetInterfaces().Contains(typeof(IResourceFilter)) || service.GetInterfaces().Contains(typeof(IAuthenticationHandler))) return true; var c = service.GetCustomAttribute(); var serviceName = $"{service}"; if (c is ScopeAttribute) { if (!Scoped.Contains(serviceName)) { Scoped.Add(serviceName); ServiceCollection.TryAddScoped(service); return true; } } else if (c is SingletoneAttribute) { if (!Singleton.Contains(serviceName)) { Singleton.Add(serviceName); ServiceCollection.TryAddSingleton(service); return true; } } else if (c is TransientAttribute) { if (!Transient.Contains(serviceName)) { Transient.Add(serviceName); ServiceCollection.TryAddTransient(service); return true; } } return false; } private bool Register(Type service, Type implementation) { if (service.IsSubclassOf(typeof(ControllerBase)) || service.GetInterfaces().Contains(typeof(IResourceFilter))) return true; var c = service.IsGenericType && (service.GetGenericTypeDefinition() == typeof(IConfigureOptions<>) || service.GetGenericTypeDefinition() == typeof(IPostConfigureOptions<>)) && implementation != null ? implementation.GetCustomAttribute() : service.GetCustomAttribute(); var serviceName = $"{service}{implementation}"; if (c is ScopeAttribute) { if (!Scoped.Contains(serviceName)) { Scoped.Add(serviceName); ServiceCollection.TryAddScoped(service, implementation); return true; } } else if (c is SingletoneAttribute) { if (!Singleton.Contains(serviceName)) { Singleton.Add(serviceName); ServiceCollection.AddSingleton(service, implementation); return true; } } else if (c is TransientAttribute) { if (!Transient.Contains(serviceName)) { Transient.Add(serviceName); ServiceCollection.TryAddTransient(service, implementation); return true; } } return false; } public bool TryAddScoped() where TService : class where TImplementation : class, TService { var serviceName = $"{typeof(TService)}{typeof(TImplementation)}"; if (!Scoped.Contains(serviceName)) { Scoped.Add(serviceName); ServiceCollection.TryAddScoped(); return true; } return false; } public DIHelper TryAddSingleton() where TService : class { var serviceName = $"{typeof(TService)}"; if (!Singleton.Contains(serviceName)) { Singleton.Add(serviceName); ServiceCollection.TryAddSingleton(); } return this; } public DIHelper TryAddSingleton(Func implementationFactory) where TService : class { var serviceName = $"{typeof(TService)}"; if (!Singleton.Contains(serviceName)) { Singleton.Add(serviceName); ServiceCollection.TryAddSingleton(implementationFactory); } return this; } public DIHelper TryAddSingleton() where TService : class where TImplementation : class, TService { var serviceName = $"{typeof(TService)}{typeof(TImplementation)}"; if (!Singleton.Contains(serviceName)) { Singleton.Add(serviceName); ServiceCollection.TryAddSingleton(); } return this; } public DIHelper AddSingleton() where TService : class where TImplementation : class, TService { var serviceName = $"{typeof(TService)}{typeof(TImplementation)}"; if (!Singleton.Contains(serviceName)) { Singleton.Add(serviceName); ServiceCollection.AddSingleton(); } return this; } public DIHelper TryAddSingleton(TService tservice, TImplementation tImplementation) where TService : Type where TImplementation : Type { var serviceName = $"{tservice}{tImplementation}"; if (!Singleton.Contains(serviceName)) { Singleton.Add(serviceName); ServiceCollection.TryAddSingleton(tservice, tImplementation); } return this; } public DIHelper Configure(Action configureOptions) where TOptions : class { var serviceName = $"{typeof(TOptions)}"; if (!Configured.Contains(serviceName)) { Configured.Add(serviceName); ServiceCollection.Configure(configureOptions); } return this; } private void AddToConfigured(string type, Action action) where TOptions : class { if (!Configured.Contains(type)) { Configured.Add(type); ServiceCollection.Configure(action); } } public DIHelper AddWorkerQueue(int workerCount, int waitInterval, bool stopAfterFinsih, int errorCount) { void action(WorkerQueue a) { a.workerCount = workerCount; a.waitInterval = waitInterval; a.stopAfterFinsih = stopAfterFinsih; a.errorCount = errorCount; } AddToConfigured($"{typeof(WorkerQueue)}", (Action>)action); return this; } public DIHelper AddProgressQueue(int workerCount, int waitInterval, bool removeAfterCompleted, bool stopAfterFinsih, int errorCount) where T1 : class, IProgressItem { void action(ProgressQueue a) { a.workerCount = workerCount; a.waitInterval = waitInterval; a.stopAfterFinsih = stopAfterFinsih; a.errorCount = errorCount; a.removeAfterCompleted = removeAfterCompleted; } AddToConfigured($"{typeof(ProgressQueue)}", (Action>)action); return this; } public DIHelper Configure(string name, Action configureOptions) where TOptions : class { var serviceName = $"{typeof(TOptions)}{name}"; if (!Configured.Contains(serviceName)) { Configured.Add(serviceName); ServiceCollection.Configure(name, configureOptions); } return this; } } }