DiscoverNcapsRoot.cs

using System.Text;
using System.Threading.Tasks;
using Waher.Networking.MQTT;
using Waher.Runtime.Language;
using Waher.Things.Attributes;
using Waher.Things.Ieee1451.Ieee1451_0.Messages;
using Waher.Things.Mqtt;
using Waher.Things.Mqtt.Model;
using Waher.Things.Queries;
 
namespace Waher.Things.Ieee1451.Ieee1451_1_6
{
    public class DiscoverNcapsRoot : ICommand
    {
        private readonly MqttBrokerNode brokerNode;
 
        public DiscoverNcapsRoot(MqttBrokerNode BrokerNode)
        {
            this.brokerNode = BrokerNode;
        }
 
        [Page(1, "IEEE 1451")]
        [Header(21, "Topic:", 100)]
        [ToolTip(22, "Search for NCAPs on this topic.")]
        [Required]
        public string Topic { get; set; }
 
        public string CommandID => "DiscoverNcaps";
 
        public CommandType Type => CommandType.Parametrized;
 
        public string SortCategory => "IEEE1451.1.6";
 
        public string SortKey => "1";
 
        public Task<string> GetNameAsync(Language Language)
        {
            return Language.GetStringAsync(typeof(RootTopic), 20, "Discover NCAPs...");
        }
 
        public Task<string> GetConfirmationStringAsync(Language Language) => Task.FromResult<string>(null);
 
        public Task<string> GetFailureStringAsync(Language Language) => Task.FromResult<string>(null);
 
        public Task<string> GetSuccessStringAsync(Language Language) => Task.FromResult<string>(null);
 
        public Task<bool> CanExecuteAsync(RequestOrigin Caller) => Task.FromResult(true);
 
        public Task StartQueryExecutionAsync(Query Query, Language Language) => this.ExecuteCommandAsync();
 
        public ICommand Copy()
        {
            return new DiscoverNcapsRoot(this.brokerNode)
            {
                Topic = this.Topic
            };
        }
 
        public async Task ExecuteCommandAsync()
        {
            StringBuilder ToSniffer = this.brokerNode.HasSniffers ? new StringBuilder() : null;
            byte[] Request = DiscoveryMessage.SerializeRequest(ToSniffer);
            MqttBroker Broker = await this.brokerNode.GetBroker();
 
            if (!(ToSniffer is null))
                await this.brokerNode.Information(ToSniffer.ToString());
 
            await Broker.Publish(this.Topic, MqttQualityOfService.AtLeastOnce, false, Request);
        }
    }
}