ModbusUnitDiscreteInputNode.cs

using System;
using System.Collections;
using System.Collections.Generic;
using System.Threading.Tasks;
using Waher.Networking.Modbus;
using Waher.Persistence.Attributes;
using Waher.Runtime.Language;
using Waher.Things.Attributes;
using Waher.Things.DisplayableParameters;
using Waher.Things.SensorData;
 
namespace Waher.Things.Modbus
{
    public class ModbusUnitDiscreteInputNode : ModbusUnitChildNode, ISensor
    {
        public ModbusUnitDiscreteInputNode()
            : base()
        {
        }
 
        [Page(4, "Modbus", 100)]
        [Header(13, "Register Number:")]
        [ToolTip(14, "Register number on the Modbus unit.")]
        [Range(0, 65535)]
        [Required]
        public int RegisterNr { get; set; }
 
        [Page(4, "Modbus", 100)]
        [Header(11, "Field Name:")]
        [ToolTip(12, "Custom field name for value.")]
        [DefaultValueStringEmpty]
        public string FieldName { get; set; }
 
        public override Task<string> GetTypeNameAsync(Language Language)
        {
            return Language.GetStringAsync(typeof(ModbusGatewayNode), 29, "Discrete Input (1x)");
        }
 
        public override async Task<IEnumerable<Parameter>> GetDisplayableParametersAsync(Language Language, RequestOrigin Caller)
        {
            LinkedList<Parameter> Result = await base.GetDisplayableParametersAsync(Language, Caller) as LinkedList<Parameter>;
 
            Result.AddLast(new Int32Parameter("Nr", await Language.GetStringAsync(typeof(ModbusGatewayNode), 10, "Nr"), this.RegisterNr));
 
            return Result;
        }
 
        public async Task StartReadout(ISensorReadout Request)
        {
            ModbusTcpClient Client = await (await this.GetGateway()).GetTcpIpConnection();
            await Client.Enter();
            try
            {
                BitArray Values = await Client.ReadInputDiscretes((byte)(await this.GetUnitNode()).UnitId, (ushort)this.RegisterNr, 1);
                DateTime TP = DateTime.UtcNow;
 
                ThingReference This = await this.GetReportAs();
 
                await Request.ReportFields(true,
                    new BooleanField(This, TP, this.GetFieldName(), Values[0], FieldType.Momentary, FieldQoS.AutomaticReadout));
            }
            catch (Exception ex)
            {
                await Request.ReportErrors(true, new ThingError(this, ex.Message));
            }
            finally
            {
                await Client.Leave();
            }
        }
 
        public string GetFieldName()
        {
            if (string.IsNullOrEmpty(this.FieldName))
                return "Value";
            else
                return this.FieldName;
        }
    }
}