FakeOmronFinsTransport.cs

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

using Dreamine.PLC.Abstractions.Results;
 
namespace Dreamine.PLC.Omron.Fins.Transport;

public sealed class FakeOmronFinsTransport : IOmronFinsTransport
{
    private readonly Queue<byte[]> _responses = new();

    public bool IsConnected { get; private set; }

    public List<byte[]> SentRequests { get; } = [];

    public void EnqueueResponse(byte[] response)
    {
        _responses.Enqueue(response);
    }

    public Task<PlcResult> ConnectAsync(CancellationToken cancellationToken = default)
    {
        IsConnected = true;
        return Task.FromResult(PlcResult.Success());
    }

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

    public Task<PlcResult<byte[]>> SendAndReceiveAsync(
        IReadOnlyList<byte> requestFrame,
        int receiveTimeoutMs,
        int retryCount,
        CancellationToken cancellationToken = default)
    {
        SentRequests.Add(requestFrame.ToArray());
        if (_responses.Count == 0)
        {
            return Task.FromResult(PlcResult<byte[]>.Failure("No fake FINS response has been queued."));
        }
 
        return Task.FromResult(PlcResult<byte[]>.Success(_responses.Dequeue()));
    }

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