src/MassTransit.Newtonsoft/Serialization/NewtonsoftEnvelopeSerializerContext.cs - develop - vshmidt/masstransit

src/MassTransit.Newtonsoft/Serialization/NewtonsoftEnvelopeSerializerContext.cs

91 строка3 KB

Chris Patterson

Fixed #3344 - added internal code analysis types for NETSTANDARD2.0 and NET462 builds to allow proper nullable output types for analyzer

06 мар 2023, 21:47

06 мар 2023, 21:47715a0a2

#nullable enable
namespace MassTransit.Serialization
{
    using System;
    using System.Collections.Generic;
    using System.Diagnostics.CodeAnalysis;
    using JsonConverters;
    using Newtonsoft.Json;
    using Newtonsoft.Json.Linq;


    public abstract class NewtonsoftSerializerContext :
        BaseSerializerContext
    {
        readonly JsonSerializer _deserializer;
        readonly object? _message;

        protected NewtonsoftSerializerContext(JsonSerializer deserializer, IObjectDeserializer objectDeserializer, MessageContext messageContext,
            object? message, string[] supportedMessageTypes)
            : base(objectDeserializer, messageContext, supportedMessageTypes)
        {
            _deserializer = deserializer;
            _message = message;
        }

        public override bool TryGetMessage<T>(out T? message)
            where T : class
        {
            var messageToken = GetMessageToken(_message);

            if (typeof(T) == typeof(JToken))
            {
                message = messageToken as T;
                return message != null;
            }

            if (IsSupportedMessageType<T>())
            {
                if (_message is T messageOfT)
                {
                    message = messageOfT;
                    return true;
                }

                using var json = messageToken.CreateReader();
                message = _deserializer.Deserialize<T>(json);

                return message != null;
            }

            message = null;
            return false;
        }

        public override bool TryGetMessage(Type messageType, [NotNullWhen(true)] out object? message)
        {
            if (_message != null && messageType.IsInstanceOfType(_message))
            {
                message = _message;
                return true;
            }

            var messageToken = GetMessageToken(_message);

            using var reader = messageToken.CreateReader();
            message = _deserializer.Deserialize(reader, messageType);

            return message != null;
        }

        public override Dictionary<string, object> ToDictionary<T>(T? message)
            where T : class
        {
            if (message == null)
                return new Dictionary<string, object>(StringComparer.OrdinalIgnoreCase);

            var dictionary = JObject.FromObject(message, NewtonsoftJsonMessageSerializer.Serializer);

            return dictionary.ToObject<Dictionary<string, object>>(_deserializer) ?? new CaseInsensitiveDictionary<object>();
        }

        static JToken GetMessageToken(object? message)
        {
            return message is JToken element
                ? element.Type == JTokenType.Null
                    ? new JObject()
                    : element
                : new JObject();
        }
    }
}