DiscoverableTopicNode.cs

using System.Collections.Generic;
using System.Threading.Tasks;
using Waher.Runtime.Inventory;
using Waher.Runtime.Language;
using Waher.Things.Mqtt;
using Waher.Things.Mqtt.Model;
 
namespace Waher.Things.Ieee1451.Ieee1451_1_6
{
    public class DiscoverableTopicNode : MqttTopicNode
    {
        public DiscoverableTopicNode()
        {
        }
 
        public override Task<string> GetTypeNameAsync(Language Language)
        {
            return Language.GetStringAsync(typeof(RootTopic), 23, "IEEE 1451.1.6 Topic Node");
        }
 
        public override Task<bool> AcceptsParentAsync(INode Parent)
        {
            return Task.FromResult(Parent is DiscoverableTopicNode || Parent is RootTopic);
        }
 
        public override Task<bool> AcceptsChildAsync(INode Child)
        {
            return Task.FromResult(Child is DiscoverableTopicNode || Child is MqttNcapTopicNode);
        }
 
        public override Grade Supports(MqttTopicRepresentation Topic)
        {
            if ((Topic.CurrentParentTopic?.Node is RootTopic ||
                Topic.CurrentParentTopic?.Node is DiscoverableTopicNode) &&
                !(Topic.CurrentParentTopic?.Node is MqttNcapTopicNode))
            {
                return Grade.Ok;
            }
            else
                return Grade.NotAtAll;
        }
 
        public override async Task<IMqttTopicNode> CreateNew(MqttTopicRepresentation Topic)
        {
            return new DiscoverableTopicNode()
            {
                NodeId = await GetUniqueNodeId(Topic.CurrentSegment),
                LocalTopic = Topic.CurrentSegment
            };
        }
 
        public override async Task<IMqttData> GetDefaultDataObject()
        {
            MqttTopic Topic = await this.GetTopic();
            if (Topic is null)
                return null;
 
            return new MessageData(Topic, null, null, 0);
        }
 
        public bool ResponseReceived(MqttTopic Topic, Ieee1451_0.Messages.Message Message)
        {
            if (Topic.Data is MessageData Data)
                return Data.DataReported(Message);
            else
            {
                Topic.SetData(new MessageData(Topic, Message, null, null, 0));
                return false;
            }
        }
 
        public override Task<IEnumerable<ICommand>> Commands => this.GetCommands();
 
        private async Task<IEnumerable<ICommand>> GetCommands()
        {
            List<ICommand> Commands = new List<ICommand>();
            Commands.AddRange(await base.Commands);
 
            Commands.Add(new DiscoverNcapsTopic(await this.GetBroker(), this));
 
            return Commands.ToArray();
        }
 
    }
}