FakeMitsubishiMcTransport.cs

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

using Dreamine.PLC.Abstractions.Results;
 
namespace Dreamine.PLC.Mitsubishi.MC.Transport;

public sealed class FakeMitsubishiMcTransport : IMitsubishiMcTransport
{
    private readonly Queue<byte[]> _responses = new();
    private readonly List<byte[]> _sentFrames = new();

    public bool IsConnected { get; private set; }

    public IReadOnlyList<byte[]> SentFrames => _sentFrames;

    public void EnqueueResponse(byte[] responseFrame)
    {
        ArgumentNullException.ThrowIfNull(responseFrame);
 
        _responses.Enqueue(responseFrame);
    }

    public Task<PlcResult> ConnectAsync(
        string host,
        int port,
        int timeoutMs,
        CancellationToken cancellationToken = default)
    {
        cancellationToken.ThrowIfCancellationRequested();
 
        IsConnected = true;
 
        return Task.FromResult(PlcResult.Success());
    }

    public Task<PlcResult> DisconnectAsync(CancellationToken cancellationToken = default)
    {
        cancellationToken.ThrowIfCancellationRequested();
 
        IsConnected = false;
 
        return Task.FromResult(PlcResult.Success());
    }

    public Task<PlcResult<byte[]>> SendAndReceiveAsync(
        IReadOnlyList<byte> requestFrame,
        int receiveTimeoutMs,
        int retryCount,
        CancellationToken cancellationToken = default)
    {
        ArgumentNullException.ThrowIfNull(requestFrame);
 
        cancellationToken.ThrowIfCancellationRequested();
 
        if (!IsConnected)
        {
            return Task.FromResult(
                PlcResult<byte[]>.Failure("The fake Mitsubishi MC transport is not connected."));
        }
 
        if (requestFrame.Count == 0)
        {
            return Task.FromResult(
                PlcResult<byte[]>.Failure("The request frame must not be empty."));
        }
 
        _sentFrames.Add(requestFrame as byte[] ?? requestFrame.ToArray());
 
        if (_responses.Count == 0)
        {
            return Task.FromResult(
                PlcResult<byte[]>.Failure("No fake Mitsubishi MC response frame was queued."));
        }
 
        return Task.FromResult(
            PlcResult<byte[]>.Success(_responses.Dequeue()));
    }

    public ValueTask DisposeAsync()
    {
        IsConnected = false;
        _responses.Clear();
        _sentFrames.Clear();
 
        return ValueTask.CompletedTask;
    }
}