WriteModBusCoil.cs

using System;
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 WriteModBusCoil : ModBusWriteOperation
    {
        public WriteModBusCoil(ISimulationNode Parent, Model Model)
            : base(Parent, Model)
        {
        }
 
        public override string LocalName => nameof(WriteModBusCoil);
 
        public override ISimulationNode Create(ISimulationNode Parent, Model Model)
        {
            return new WriteModBusCoil(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);
 
            if (this.value is null)
                throw new Exception("Value not defined.");
 
            double Value = Expression.ToDouble(await this.value.EvaluateAsync(Variables));
            bool Result;
 
            await Client.Lock();
            try
            {
                if (!(Client.Client is null))
                    Result = await Client.Client.WriteCoil(Address, Register, Value != 0);
                else
                    return null;
            }
            finally
            {
                Client.Unlock();
            }
 
            if (!(this.responseVariable is null))
            {
                string VariableName = await this.responseVariable.GetValueAsync(Variables);
                Variables[VariableName] = Result;
            }
 
            return null;
        }
    }
}