MqttEventSinkNode.cs

using System.Collections.Generic;
using System.Threading.Tasks;
using System.Xml;
using Waher.Content;
using Waher.Events.MQTT;
using Waher.Runtime.Language;
using Waher.Things;
using Waher.Things.Attributes;
using Waher.Things.DisplayableParameters;
 
namespace Waher.Service.IoTBroker.Sources.GatewayConfig.EventSinkNodes
{
    public class MqttEventSinkNode : EventSinkNode
    {
        public MqttEventSinkNode()
            : base()
        {
        }
 
        public MqttEventSinkNode(GatewayConfigSource Source, ConfigurationNode Parent,
            string SinkId, string Broker, int Port, bool Tls, string UserName,
            string Password, string Topic)
            : base(Source, Parent, SinkId)
        {
            this.Broker = Broker;
            this.Port = Port;
            this.Tls = Tls;
            this.UserName = UserName;
            this.Password = Password;
            this.Topic = Topic;
        }
 
        [Page(7, "Configuration")]
        [Header(159, "Broker:")]
        [ToolTip(160, "Host name of broker.")]
        [Required]
        public string Broker { get; set; }
 
        [Page(7, "Configuration")]
        [Header(161, "Port:")]
        [ToolTip(162, "Port number of the broker.")]
        [Required]
        [Range(1, 65535)]
        public int Port { get; set; }
 
        [Page(7, "Configuration")]
        [Header(163, "Use Encryption (TLS)")]
        [ToolTip(164, "If TLS is used to connect to the broker.")]
        [Required]
        public bool Tls { get; set; }
 
        [Page(7, "Configuration")]
        [Header(165, "User Name:")]
        [ToolTip(166, "User name to use when connecting to the broker.")]
        public string UserName { get; set; }
 
        [Page(7, "Configuration")]
        [Header(167, "Password:")]
        [ToolTip(168, "Password to use when connecting to the broker.")]
        [Text(TextPosition.AfterField, 169, "Note: Leave User Name and Password empty to either connect anonymously, or authenticate using mTLS where such is supported.")]
        public string Password { get; set; }
 
        [Page(7, "Configuration")]
        [Header(170, "Topic:")]
        [ToolTip(171, "Topic to publish events to.")]
        [Required]
        public string Topic { get; set; }
 
        public override Task<string> GetTypeNameAsync(Language Language)
        {
            return Language.GetStringAsync(typeof(GatewayConfigSource), 172, "MQTT Event Sink");
        }
 
        public override async Task<IEnumerable<Parameter>> GetDisplayableParametersAsync(Language Language, RequestOrigin Caller)
        {
            LinkedList<Parameter> Parameters = (LinkedList<Parameter>)await base.GetDisplayableParametersAsync(Language, Caller);
            Namespace Namespace = await Language.GetNamespaceAsync(typeof(GatewayConfigSource).Namespace);
 
            Parameters.AddLast(new StringParameter("Broker", await Namespace.GetStringAsync(173, "Broker"), this.Broker));
            Parameters.AddLast(new Int32Parameter("Port", await Namespace.GetStringAsync(45, "Port Number"), this.Port));
            Parameters.AddLast(new BooleanParameter("Tls", await Namespace.GetStringAsync(36, "Encrypted"), this.Tls));
            Parameters.AddLast(new StringParameter("Topic", await Namespace.GetStringAsync(174, "Topic"), this.Topic));
 
            return Parameters;
        }
 
        public override void Export(XmlWriter Output)
        {
            Output.WriteStartElement("MqttEventSink");
            Output.WriteAttributeString("id", this.SinkId);
            Output.WriteAttributeString("broker", this.Broker);
            Output.WriteAttributeString("port", this.Port.ToString());
            Output.WriteAttributeString("tls", CommonTypes.Encode(this.Tls));
            
            if (!string.IsNullOrEmpty(this.UserName))
                Output.WriteAttributeString("username", this.UserName);
            
            if (!string.IsNullOrEmpty(this.Password))
                Output.WriteAttributeString("password", this.Password);
            
            Output.WriteAttributeString("topic", this.Topic);
            Output.WriteEndElement();
        }
    }
}