InMemoryPlcClient.cs

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

using Dreamine.PLC.Abstractions.Devices;
using Dreamine.PLC.Abstractions.Results;
using Dreamine.PLC.Core.Memory;
 
namespace Dreamine.PLC.Core.Clients;

public sealed class InMemoryPlcClient : PlcClientBase
{
    private readonly InMemoryPlcMemory _memory;
    private bool _isConnected;

    public InMemoryPlcClient()
        : this(new InMemoryPlcMemory())
    {
    }

    public InMemoryPlcClient(InMemoryPlcMemory memory)
    {
        _memory = memory ?? throw new ArgumentNullException(nameof(memory));
    }

    public InMemoryPlcMemory Memory => _memory;

    protected override Task<PlcResult> ConnectCoreAsync(CancellationToken cancellationToken)
    {
        cancellationToken.ThrowIfCancellationRequested();
 
        _isConnected = true;
 
        return Task.FromResult(PlcResult.Success());
    }

    protected override Task<PlcResult> DisconnectCoreAsync(CancellationToken cancellationToken)
    {
        cancellationToken.ThrowIfCancellationRequested();
 
        _isConnected = false;
 
        return Task.FromResult(PlcResult.Success());
    }

    protected override Task<PlcResult<bool[]>> ReadBitsCoreAsync(
        PlcAddress address,
        int count,
        CancellationToken cancellationToken)
    {
        cancellationToken.ThrowIfCancellationRequested();
 
        if (!_isConnected)
        {
            return Task.FromResult(PlcResult<bool[]>.Failure("The in-memory PLC client is not connected."));
        }
 
        return Task.FromResult(_memory.ReadBits(address, count));
    }

    protected override Task<PlcResult<short[]>> ReadWordsCoreAsync(
        PlcAddress address,
        int count,
        CancellationToken cancellationToken)
    {
        cancellationToken.ThrowIfCancellationRequested();
 
        if (!_isConnected)
        {
            return Task.FromResult(PlcResult<short[]>.Failure("The in-memory PLC client is not connected."));
        }
 
        return Task.FromResult(_memory.ReadWords(address, count));
    }

    protected override Task<PlcResult> WriteBitsCoreAsync(
        PlcAddress address,
        IReadOnlyList<bool> values,
        CancellationToken cancellationToken)
    {
        cancellationToken.ThrowIfCancellationRequested();
 
        if (!_isConnected)
        {
            return Task.FromResult(PlcResult.Failure("The in-memory PLC client is not connected."));
        }
 
        return Task.FromResult(_memory.WriteBits(address, values));
    }

    protected override Task<PlcResult> WriteWordsCoreAsync(
        PlcAddress address,
        IReadOnlyList<short> values,
        CancellationToken cancellationToken)
    {
        cancellationToken.ThrowIfCancellationRequested();
 
        if (!_isConnected)
        {
            return Task.FromResult(PlcResult.Failure("The in-memory PLC client is not connected."));
        }
 
        return Task.FromResult(_memory.WriteWords(address, values));
    }
}