src/MassTransit/Metadata/RegistrationMetadata.cs - develop - vshmidt/masstransit

src/MassTransit/Metadata/RegistrationMetadata.cs
115 строк4 KB
Chris Patterson
Massive file cleanup
27 мар 2024, 02:43
27 мар 2024, 02:432ac69e8
namespace MassTransit.Metadata
{
    using System;
    using System.Linq;
    using Internals;


    public static class RegistrationMetadata
    {
        /// <summary>
        /// Returns true if the type is a consumer, or a consumer definition
        /// </summary>
        /// <param name="type"></param>
        /// <returns></returns>
        public static bool IsConsumerOrDefinition(Type type)
        {
            Type[] interfaces = type.GetInterfaces();

            return !IsSaga(type) && interfaces.Any(t => t.HasInterface(typeof(IConsumer<>))
                || t.HasInterface(typeof(IJobConsumer<>))
                || t.HasInterface(typeof(IConsumerDefinition<>)));
        }

        /// <summary>
        /// Returns true if the type is a consumer, or a consumer definition
        /// </summary>
        /// <param name="type"></param>
        /// <returns></returns>
        public static bool IsConsumer(Type type)
        {
            Type[] interfaces = type.GetInterfaces();

            return interfaces.Any(t => t.HasInterface(typeof(IConsumer<>))
                || t.HasInterface(typeof(IJobConsumer<>)));
        }

        /// <summary>
        /// Returns true if the type is a saga, or a saga definition
        /// </summary>
        /// <param name="type"></param>
        /// <returns></returns>
        public static bool IsSagaOrDefinition(Type type)
        {
            Type[] interfaces = type.GetInterfaces();

            if (interfaces.Contains(typeof(ISaga)))
                return true;

            return interfaces.Any(t => t.HasInterface(typeof(InitiatedBy<>))
                || t.HasInterface(typeof(Orchestrates<>))
                || t.HasInterface(typeof(InitiatedByOrOrchestrates<>))
                || t.HasInterface(typeof(Observes<,>))
                || t.HasInterface(typeof(ISagaDefinition<>)));
        }

        /// <summary>
        /// Returns true if the type is a saga
        /// </summary>
        /// <param name="type"></param>
        /// <returns></returns>
        public static bool IsSaga(Type type)
        {
            Type[] interfaces = type.GetInterfaces();

            if (interfaces.Contains(typeof(ISaga)))
                return true;

            return interfaces.Any(t => t.HasInterface(typeof(InitiatedBy<>))
                || t.HasInterface(typeof(Orchestrates<>))
                || t.HasInterface(typeof(InitiatedByOrOrchestrates<>))
                || t.HasInterface(typeof(Observes<,>)));
        }

        /// <summary>
        /// Returns true if the type is a state machine or saga definition
        /// </summary>
        /// <param name="type"></param>
        /// <returns></returns>
        public static bool IsSagaStateMachineOrDefinition(Type type)
        {
            Type[] interfaces = type.GetInterfaces();

            return interfaces.Any(t => t.HasInterface(typeof(SagaStateMachine<>))
                || t.HasInterface(typeof(ISagaDefinition<>)));
        }

        /// <summary>
        /// Returns true if the type is an activity
        /// </summary>
        /// <param name="type"></param>
        /// <returns></returns>
        public static bool IsActivityOrDefinition(Type type)
        {
            Type[] interfaces = type.GetInterfaces();

            return interfaces.Any(t => t.HasInterface(typeof(IExecuteActivity<>))
                || t.HasInterface(typeof(ICompensateActivity<>))
                || t.HasInterface(typeof(IActivityDefinition<,,>))
                || t.HasInterface(typeof(IExecuteActivityDefinition<,>)));
        }

        /// <summary>
        /// Returns true if the type is a future or future definition
        /// </summary>
        /// <param name="type"></param>
        /// <returns></returns>
        public static bool IsFutureOrDefinition(Type type)
        {
            Type[] interfaces = type.GetInterfaces();

            return interfaces.Any(t => t.HasInterface(typeof(SagaStateMachine<FutureState>))
                || t.HasInterface(typeof(IFutureDefinition<>)));
        }
    }
}