JsonMessageSerializer.cs

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

using System;
using System.Text.Json;
using Dreamine.Communication.Abstractions.Interfaces;
using Dreamine.Communication.Abstractions.Models;
 
namespace Dreamine.Communication.Core.Serialization;

public sealed class JsonMessageSerializer : IMessageSerializer
{
    private readonly JsonSerializerOptions _options;

    public JsonMessageSerializer()
    {
        _options = new JsonSerializerOptions
        {
            PropertyNameCaseInsensitive = true,
            WriteIndented = false
        };
    }

    public JsonMessageSerializer(JsonSerializerOptions options)
    {
        _options = options ?? throw new ArgumentNullException(nameof(options));
    }

    public byte[] Serialize(MessageEnvelope message)
    {
        ArgumentNullException.ThrowIfNull(message);
        return JsonSerializer.SerializeToUtf8Bytes(message, _options);
    }

    public MessageEnvelope Deserialize(byte[] data)
    {
        ArgumentNullException.ThrowIfNull(data);
 
        var message = JsonSerializer.Deserialize<MessageEnvelope>(data, _options);
 
        if (message is null)
        {
            throw new InvalidOperationException("Failed to deserialize MessageEnvelope.");
        }
 
        return message;
    }
}