DiscoverNcapsTopic.cs

using System.Text;
using System.Threading.Tasks;
using Waher.Networking.MQTT;
using Waher.Runtime.Language;
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 DiscoverNcapsTopic : ICommand
    {
        private readonly MqttBrokerNode brokerNode;
        private readonly MqttTopicNode topicNode;
 
        public DiscoverNcapsTopic(MqttBrokerNode BrokerNode, MqttTopicNode TopicNode)
        {
            this.brokerNode = BrokerNode;
            this.topicNode = TopicNode;
        }
 
        public string CommandID => "DiscoverNcaps";
 
        public CommandType Type => CommandType.Simple;
 
        public string SortCategory => "IEEE1451.1.6";
 
        public string SortKey => "1";
 
        public Task<string> GetNameAsync(Language Language)
        {
            return Language.GetStringAsync(typeof(RootTopic), 24, "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 DiscoverNcapsTopic(this.brokerNode, this.topicNode);
        }
 
        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(await this.topicNode.GetFullTopic(), MqttQualityOfService.AtLeastOnce, false, Request);
        }
    }
}