src/MassTransit/MessageData/Configuration/PutMessageDataObjectArrayTransformConfiguration.cs - develop - vshmidt/masstransit

src/MassTransit/MessageData/Configuration/PutMessageDataObjectArrayTransformConfiguration.cs

42 строки2 KB

Chris Patterson

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

22 янв 2022, 18:24

22 янв 2022, 18:24b5b4f50

namespace MassTransit.MessageData.Configuration
{
    using System;
    using System.Collections.Generic;
    using System.Reflection;
    using Initializers;
    using Initializers.PropertyConverters;
    using Initializers.PropertyProviders;


    public class PutMessageDataObjectArrayTransformConfiguration<TInput, TProperty, TElement> :
        IMessageDataTransformConfiguration<TInput>
        where TInput : class
        where TElement : class
    {
        readonly PropertyInfo _property;
        readonly PutMessageDataTransformSpecification<TElement> _transformConfigurator;

        public PutMessageDataObjectArrayTransformConfiguration(IMessageDataRepository repository, IEnumerable<Type> knownTypes, PropertyInfo property)
        {
            _property = property;

            _transformConfigurator = new PutMessageDataTransformSpecification<TElement>(repository, knownTypes);
        }

        public void Apply(ITransformConfigurator<TInput> configurator)
        {
            if (_transformConfigurator.TryGetConverter(out IPropertyConverter<TElement, TElement> converter))
            {
                var inputPropertyProvider = new InputPropertyProvider<TInput, TProperty>(_property);

                IPropertyConverter<TProperty, TProperty> arrayConverter = typeof(TProperty).IsArray
                    ? new ArrayPropertyConverter<TElement, TElement>(converter) as IPropertyConverter<TProperty, TProperty>
                    : new ListPropertyConverter<TElement, TElement>(converter) as IPropertyConverter<TProperty, TProperty>;

                var provider = new PropertyConverterPropertyProvider<TInput, TProperty, TProperty>(arrayConverter, inputPropertyProvider);

                configurator.Transform(_property, provider);
            }
        }
    }
}