tests/MassTransit.Tests/Serialization/GivenAComplexMessage.cs - develop - vshmidt/masstransit

tests/MassTransit.Tests/Serialization/GivenAComplexMessage.cs
260 строк7 KB
Marcus Christensen
Add support for MessagePack serialization.
15 окт 2024, 16:49
15 окт 2024, 16:49faeebdf
namespace MassTransit.Tests.Serialization
{
    using System;
    using System.Linq;
    using MassTransit.Initializers;
    using MassTransit.Serialization;
    using Messages;
    using NUnit.Framework;
    using TestFramework.Messages;


    [TestFixture(typeof(NewtonsoftJsonMessageSerializer))]
    [TestFixture(typeof(SystemTextJsonMessageSerializer))]
    [TestFixture(typeof(BsonMessageSerializer))]
    [TestFixture(typeof(NewtonsoftXmlMessageSerializer))]
    [TestFixture(typeof(EncryptedMessageSerializer))]
    [TestFixture(typeof(EncryptedMessageSerializerV2))]
    [TestFixture(typeof(MessagePackMessageSerializer))]
    public class Given_a_variety_of_challenging_messages :
        SerializationTest
    {
        [Test]
        public void Byte_array()
        {
            TestSerialization(new C {Contents = new byte[] {0x56, 0x34, 0xf3}});
        }

        [Test]
        public void Byte_interface_array()
        {
            var msg = MessageInitializerCache<ByteArrayMessage>.Initialize(new {Contents = new byte[] {0x56, 0x34, 0xf3}}).GetAwaiter().GetResult().Message;

            var result = SerializeAndReturn(msg);

            Assert.That(result.Contents, Is.EquivalentTo(msg.Contents));
        }

        [Test]
        public void Crazy_date_time()
        {
            TestSerialization(new B
            {
                Local = new DateTime(2001, 9, 11, 8, 46, 30, DateTimeKind.Local),
                Universal = new DateTime(2001, 9, 11, 9, 3, 2, DateTimeKind.Local).ToUniversalTime()
            });
        }

        [Test]
        public void No_default_constructor()
        {
            TestSerialization(new A("Dru", "Sellers"));
        }

        [Test]
        public void Serialize_complex()
        {
            Message = new SerializationTestMessage
            {
                DecimalValue = 123.45m,
                LongValue = 098123213,
                BoolValue = true,
                ByteValue = 127,
                IntValue = 123,
                DateTimeValue = new DateTime(2008, 9, 8, 7, 6, 5, 4),
                TimeSpanValue = TimeSpan.FromSeconds(30),
                GuidValue = Guid.NewGuid(),
                StringValue = "Chris's Sample Code",
                DoubleValue = 1823.172,
                MaybeMoney = 567.89m
            };

            TestSerialization(Message);
        }

        [Test]
        public void Serialize_simple()
        {
            TestSerialization(new PingMessage());
        }

        [Test]
        public void Serialize_small_number()
        {
            const decimal smallNumber = 0.000001M;

            TestSerialization(new SmallNumberMessage {SmallNumber = smallNumber});
        }

        public SerializationTestMessage Message { get; private set; }

        public Given_a_variety_of_challenging_messages(Type serializerType)
            : base(serializerType)
        {
        }


        public interface ByteArrayMessage
        {
            byte[] Contents { get; set; }
        }


        class C : IEquatable<C>
        {
            public byte[] Contents { get; set; }

            public bool Equals(C other)
            {
                if (ReferenceEquals(null, other))
                    return false;

                if (ReferenceEquals(this, other))
                    return true;

                return Contents.SequenceEqual(other.Contents);
            }

            public override bool Equals(object obj)
            {
                if (ReferenceEquals(null, obj))
                    return false;

                if (ReferenceEquals(this, obj))
                    return true;

                if (obj.GetType() != GetType())
                    return false;

                return Equals((C)obj);
            }

            public override int GetHashCode()
            {
                return Contents != null ? Contents.GetHashCode() : 0;
            }
        }


        class B : IEquatable<B>
        {
            public DateTime Local { get; set; }
            public DateTime Universal { get; set; }

            public bool Equals(B other)
            {
                if (ReferenceEquals(null, other))
                    return false;

                if (ReferenceEquals(this, other))
                    return true;

                return Local.Equals(other.Local) && Universal.Equals(other.Universal);
            }

            public override bool Equals(object obj)
            {
                if (ReferenceEquals(null, obj))
                    return false;

                if (ReferenceEquals(this, obj))
                    return true;

                if (obj.GetType() != GetType())
                    return false;

                return Equals((B)obj);
            }

            public override int GetHashCode()
            {
                unchecked
                {
                    return (Local.GetHashCode() * 397) ^ Universal.GetHashCode();
                }
            }
        }


        class A : IEquatable<A>
        {
            public A(string name, string value)
            {
                Name = name;
                Value = value;
            }

            public string Name { get; private set; }
            public string Value { get; private set; }

            public bool Equals(A other)
            {
                if (ReferenceEquals(null, other))
                    return false;

                if (ReferenceEquals(this, other))
                    return true;

                return string.Equals(Name, other.Name) && string.Equals(Value, other.Value);
            }

            public override bool Equals(object obj)
            {
                if (ReferenceEquals(null, obj))
                    return false;

                if (ReferenceEquals(this, obj))
                    return true;

                if (obj.GetType() != GetType())
                    return false;

                return Equals((A)obj);
            }

            public override int GetHashCode()
            {
                unchecked
                {
                    return ((Name != null ? Name.GetHashCode() : 0) * 397) ^ (Value != null ? Value.GetHashCode() : 0);
                }
            }
        }


        public class SmallNumberMessage : IEquatable<SmallNumberMessage>
        {
            public decimal SmallNumber { get; set; }

            public bool Equals(SmallNumberMessage other)
            {
                if (ReferenceEquals(null, other))
                    return false;

                if (ReferenceEquals(this, other))
                    return true;

                return SmallNumber == other.SmallNumber;
            }

            public override bool Equals(object obj)
            {
                if (ReferenceEquals(null, obj))
                    return false;

                if (ReferenceEquals(this, obj))
                    return true;

                if (obj.GetType() != GetType())
                    return false;

                return Equals((SmallNumberMessage)obj);
            }

            public override int GetHashCode()
            {
                return SmallNumber.GetHashCode();
            }
        }
    }
}