ReadModBusDiscreteInput.cs

using System;
using System.Collections;
using System.Collections.Generic;
using System.Threading.Tasks;
using TAG.Simulator.ModBus.Activities;
using TAG.Simulator.ModBus.Actors;
using TAG.Simulator.ObjectModel.Activities;
using Waher.Networking.Modbus;
using Waher.Script;
 
namespace TAG.Simulator.ModBus.Registers.Activities
{
    public class ReadModBusDiscreteInput : ModBusReadOperation
    {
        public ReadModBusDiscreteInput(ISimulationNode Parent, Model Model)
            : base(Parent, Model)
        {
        }
 
        public override string LocalName => nameof(ReadModBusDiscreteInput);
 
        public override ISimulationNode Create(ISimulationNode Parent, Model Model)
        {
            return new ReadModBusDiscreteInput(Parent, Model);
        }
 
        public override async Task<LinkedListNode<IActivityNode>> Execute(Variables Variables)
        {
            ModBusClient Client = await this.GetClient(Variables);
            byte Address = await this.address.GetUInt8ValueAsync(Variables);
            ushort Register = await this.register.GetUInt16ValueAsync(Variables);
            string VariableName = await this.responseVariable.GetValueAsync(Variables);
 
            await Client.Lock();
            try
            {
                if (!(Client.Client is null))
                {
                    BitArray Bits = await Client.Client.ReadInputDiscretes(Address, Register, 1);
                    Variables[VariableName] = Bits[0];
                }
            }
            finally
            {
                Client.Unlock();
            }
 
            return null;
        }
    }
}