JsonMessageSerializerTests.cs

이 파일의 문서화 페이지로 가기

using System.Text;
using Dreamine.Communication.Abstractions.Models;
using Dreamine.Communication.Core.Serialization;
 
namespace Dreamine.FullKit.Tests.Communication;

public sealed class JsonMessageSerializerTests
{
    [Fact]
    public void SerializeThenDeserialize_PreservesEnvelopeValues()
    {
        var serializer = new JsonMessageSerializer();
        var envelope = new MessageEnvelope
        {
            MessageId = "message-1",
            Name = "Telemetry",
            Route = "/machine/1",
            Payload = Encoding.UTF8.GetBytes("payload"),
            Headers = new Dictionary<string, string>
            {
                ["Content-Type"] = "text/plain"
            },
            CreatedAt = new DateTimeOffset(2026, 6, 7, 1, 2, 3, TimeSpan.Zero)
        };
 
        var data = serializer.Serialize(envelope);
        var result = serializer.Deserialize(data);
 
        Assert.Equal(envelope.MessageId, result.MessageId);
        Assert.Equal(envelope.Name, result.Name);
        Assert.Equal(envelope.Route, result.Route);
        Assert.Equal(envelope.Payload, result.Payload);
        Assert.Equal(envelope.Headers, result.Headers);
        Assert.Equal(envelope.CreatedAt, result.CreatedAt);
    }

    [Fact]
    public void Deserialize_AcceptsCaseInsensitivePropertyNames()
    {
        var json = """
            {
              "messageid": "lower-case",
              "name": "Ping",
              "route": "/ping",
              "payload": "AQID",
              "headers": { "A": "B" },
              "createdat": "2026-06-07T00:00:00+00:00"
            }
            """;
 
        var result = new JsonMessageSerializer().Deserialize(Encoding.UTF8.GetBytes(json));
 
        Assert.Equal("lower-case", result.MessageId);
        Assert.Equal(new byte[] { 1, 2, 3 }, result.Payload);
        Assert.Equal("B", result.Headers["A"]);
    }
}