MqttTimTopicNode.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Waher.Runtime.Inventory;
using Waher.Runtime.Language;
using Waher.Security;
using Waher.Things.Attributes;
using Waher.Things.DisplayableParameters;
using Waher.Things.Mqtt;
 
namespace Waher.Things.Ieee1451.Ieee1451_1_6
{
    public class MqttTimTopicNode : MqttNcapTopicNode
    {
        private string timId;
        private byte[] timIdBin;
 
        public MqttTimTopicNode()
        {
        }
 
        [Page(1, "IEEE 1451")]
        [Header(5, "TIM ID:", 200)]
        [ToolTip(6, "TIM unique identifier.")]
        [Required]
        [RegularExpression("[A-Fa-f0-9]{32}")]
        public string TimId
        {
            get => this.timId;
            set
            {
                this.timIdBin = Hashes.StringToBinary(value);
                this.timId = value;
            }
        }
 
        public byte[] TimIdBinary => this.timIdBin;
 
        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), 6, "IEEE 1451.0 TIM");
        }
 
        public override async Task<IEnumerable<Parameter>> GetDisplayableParametersAsync(Language Language, RequestOrigin Caller)
        {
            LinkedList<Parameter> Parameters = (LinkedList<Parameter>)await base.GetDisplayableParametersAsync(Language, Caller);
 
            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 MqttNcapTopicNode);
        }
 
        public override Task<bool> AcceptsChildAsync(INode Child)
        {
            return Task.FromResult(Child is MqttChannelTopicNode);
        }
 
        public override Grade Supports(MqttTopicRepresentation Topic)
        {
            if (Topic.CurrentParentTopic?.Node is MqttNcapTopicNode &&
                !(Topic.CurrentParentTopic?.Node is MqttTimTopicNode) &&
                Guid.TryParse(Topic.CurrentSegment, out _))
            {
                return Grade.Excellent;
            }
            else
                return Grade.NotAtAll;
        }
 
        public override async Task<IMqttTopicNode> CreateNew(MqttTopicRepresentation Topic)
        {
            return new MqttTimTopicNode()
            {
                NodeId = await GetUniqueNodeId("TIM-" + Topic.CurrentSegment),
                LocalTopic = Topic.CurrentSegment,
                TimId = Topic.CurrentSegment,
                NcapId = Topic.Segments[Topic.SegmentIndex - 1]
            };
        }
    }
}