src/MassTransit.Abstractions/Metadata/Activation.cs - develop - vshmidt/masstransit

src/MassTransit.Abstractions/Metadata/Activation.cs
71 строка3 KB
Chris Patterson
Massive file cleanup
27 мар 2024, 02:43
27 мар 2024, 02:432ac69e8
namespace MassTransit.Metadata
{
    using System;
    using System.Collections.Concurrent;


    public static class Activation
    {
        public static TResult Activate<TResult>(Type type, IActivationType<TResult> activationType)
        {
            return Cached.Instance.Value
                .GetOrAdd(type,
                    _ => (CachedType)(Activator.CreateInstance(typeof(TypeAdapter<>).MakeGenericType(type)) ?? throw new InvalidOperationException()))
                .ActivateType(activationType);
        }

        public static TResult Activate<TResult, T1>(Type type, IActivationType<TResult, T1> activationType, T1 arg1)
        {
            return Cached.Instance.Value
                .GetOrAdd(type,
                    _ => (CachedType)(Activator.CreateInstance(typeof(TypeAdapter<>).MakeGenericType(type)) ?? throw new InvalidOperationException()))
                .ActivateType(activationType, arg1);
        }

        public static TResult Activate<TResult, T1, T2>(Type type, IActivationType<TResult, T1, T2> activationType, T1 arg1, T2 arg2)
        {
            return Cached.Instance.Value
                .GetOrAdd(type,
                    _ => (CachedType)(Activator.CreateInstance(typeof(TypeAdapter<>).MakeGenericType(type)) ?? throw new InvalidOperationException()))
                .ActivateType(activationType, arg1, arg2);
        }


        interface CachedType
        {
            Type Type { get; }
            TResult ActivateType<TResult>(IActivationType<TResult> activationType);
            TResult ActivateType<TResult, T1>(IActivationType<TResult, T1> activationType, T1 arg1);
            TResult ActivateType<TResult, T1, T2>(IActivationType<TResult, T1, T2> activationType, T1 arg1, T2 arg2);
        }


        static class Cached
        {
            internal static readonly Lazy<ConcurrentDictionary<Type, CachedType>> Instance = new(() => new ConcurrentDictionary<Type, CachedType>());
        }


        class TypeAdapter<TAdapter> :
            CachedType
            where TAdapter : class
        {
            public Type Type => typeof(TAdapter);

            public TResult ActivateType<TResult>(IActivationType<TResult> activationType)
            {
                return activationType.ActivateType<TAdapter>();
            }

            public TResult ActivateType<TResult, T1>(IActivationType<TResult, T1> activationType, T1 arg1)
            {
                return activationType.ActivateType<TAdapter>(arg1);
            }

            public TResult ActivateType<TResult, T1, T2>(IActivationType<TResult, T1, T2> activationType, T1 arg1, T2 arg2)
            {
                return activationType.ActivateType<TAdapter>(arg1, arg2);
            }
        }
    }
}