DreamineEnvelopeProtocolAdapter.cs

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

using Dreamine.Communication.Abstractions.Interfaces;
using Dreamine.Communication.Abstractions.Models;
using Dreamine.Communication.Core.Serialization;
 
namespace Dreamine.Communication.Core.Protocols;

public sealed class DreamineEnvelopeProtocolAdapter : IMessageProtocolAdapter
{
    private readonly IMessageSerializer _serializer;

    public DreamineEnvelopeProtocolAdapter()
        : this(new JsonMessageSerializer())
    {
    }

    public DreamineEnvelopeProtocolAdapter(IMessageSerializer serializer)
    {
        _serializer = serializer ?? throw new ArgumentNullException(nameof(serializer));
    }

    public MessageEnvelope Decode(byte[] payload)
    {
        ArgumentNullException.ThrowIfNull(payload);
        return _serializer.Deserialize(payload);
    }

    public byte[] Encode(MessageEnvelope message)
    {
        ArgumentNullException.ThrowIfNull(message);
        return _serializer.Serialize(message);
    }
}