MqttChannelTopicNode.cs

using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks;
using Waher.Runtime.Inventory;
using Waher.Runtime.Language;
using Waher.Things.Attributes;
using Waher.Things.DisplayableParameters;
using Waher.Things.Mqtt;
 
namespace Waher.Things.Ieee1451.Ieee1451_1_6
{
    public class MqttChannelTopicNode : MqttTimTopicNode
    {
        private string preferredUnit;
        private int channelId;
 
        public MqttChannelTopicNode()
        {
        }
 
        [Page(1, "IEEE 1451")]
        [Header(8, "Channel:", 300)]
        [ToolTip(9, "Channel identifier on TIM.")]
        [Required]
        [Range(1, ushort.MaxValue)]
        public int ChannelId
        {
            get => this.channelId;
            set => this.channelId = value;
        }
 
        [Page(1, "IEEE 1451")]
        [Header(33, "Preferred Unit:", 300)]
        [ToolTip(36, "Preferred unit to use for transducer values.")]
        public string PreferredUnit
        {
            get => this.preferredUnit;
            set => this.preferredUnit = value;
        }
 
        public override string LocalId
        {
            get
            {
                if (!string.IsNullOrEmpty(this.EntityName))
                    return this.EntityName;
                else
                    return this.NodeId;
            }
        }
 
        public override Task<string> GetTypeNameAsync(Language Language)
        {
            return Language.GetStringAsync(typeof(Ieee1451Parser), 7, "IEEE 1451.0 Channel");
        }
 
        public override async Task<IEnumerable<Parameter>> GetDisplayableParametersAsync(Language Language, RequestOrigin Caller)
        {
            LinkedList<Parameter> Parameters = (LinkedList<Parameter>)await base.GetDisplayableParametersAsync(Language, Caller);
 
            Parameters.AddLast(new Int32Parameter("ChannelId",
                await Language.GetStringAsync(typeof(MqttNcapTopicNode), 10, "Channel"),
                this.ChannelId));
 
            Parameters.AddLast(new StringParameter("TimId",
                await Language.GetStringAsync(typeof(MqttNcapTopicNode), 7, "TIM ID"),
                this.TimId));
 
            Parameters.AddLast(new StringParameter("NcapId",
                await Language.GetStringAsync(typeof(MqttNcapTopicNode), 4, "NCAP ID"),
                this.NcapId));
 
            return Parameters;
        }
 
        public override Task<bool> AcceptsParentAsync(INode Parent)
        {
            return Task.FromResult(Parent is MqttTimTopicNode);
        }
 
        public override Task<bool> AcceptsChildAsync(INode Child)
        {
            return Task.FromResult(false);
        }
 
        public override Grade Supports(MqttTopicRepresentation Topic)
        {
            if (Topic.SegmentIndex > 0 &&
                Topic.CurrentParentTopic?.Node is MqttTimTopicNode &&
                !(Topic.CurrentParentTopic?.Node is MqttChannelTopicNode) &&
                int.TryParse(Topic.CurrentSegment, out _))
            {
                return Grade.Excellent;
            }
            else
                return Grade.NotAtAll;
        }
 
        public override async Task<IMqttTopicNode> CreateNew(MqttTopicRepresentation Topic)
        {
            StringBuilder sb = new StringBuilder();
 
            sb.Append("Channel-");
            sb.Append(Topic.Segments[Topic.SegmentIndex - 1]);
            sb.Append('#');
            sb.Append(Topic.CurrentSegment);
 
            return new MqttChannelTopicNode()
            {
                NodeId = await GetUniqueNodeId(sb.ToString()),
                LocalTopic = Topic.CurrentSegment,
                ChannelId = int.Parse(Topic.CurrentSegment),
                TimId = Topic.Segments[Topic.SegmentIndex - 1],
                NcapId = Topic.Segments[Topic.SegmentIndex - 2]
            };
        }
 
    }
}