EventQueueEventSinkNode.cs

using System.Collections.Generic;
using System.Threading.Tasks;
using System.Xml;
using Waher.Events.Queue;
using Waher.Runtime.Language;
using Waher.Service.IoTBroker.Sources.GatewayConfig.EventSinkNodes.Commands;
using Waher.Things;
using Waher.Things.Attributes;
using Waher.Things.DisplayableParameters;
 
namespace Waher.Service.IoTBroker.Sources.GatewayConfig.EventSinkNodes
{
    public class EventQueueEventSinkNode : EventSinkNode
    {
        public EventQueueEventSinkNode()
            : base()
        {
        }
 
        public EventQueueEventSinkNode(GatewayConfigSource Source, ConfigurationNode Parent,
            string SinkId, string Queue, int DeleteAfterDays)
            : base(Source, Parent, SinkId)
        {
            this.Queue = Queue;
            this.DeleteAfterDays = DeleteAfterDays;
        }
 
        [Page(7, "Configuration")]
        [Header(250, "Queue Name:")]
        [ToolTip(251, "Name of local queue to which events will be logged.")]
        [Required]
        public string Queue { get; set; }
 
        [Page(7, "Configuration")]
        [Header(150, "Delete After Days:")]
        [ToolTip(258, "Number of days after which log events are purged from queue.")]
        [Required]
        [Range(1, int.MaxValue)]
        public int DeleteAfterDays { get; set; }
 
        public override Task<string> GetTypeNameAsync(Language Language)
        {
            return Language.GetStringAsync(typeof(GatewayConfigSource), 252, "Event Queue 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("Queue", await Namespace.GetStringAsync(253, "Queue"), this.Queue));
 
            return Parameters;
        }
 
        public override void Export(XmlWriter Output)
        {
            Output.WriteStartElement("EventQueue");
            Output.WriteAttributeString("id", this.SinkId);
            Output.WriteAttributeString("name", this.Queue);
            Output.WriteAttributeString("deleteAfterDays", this.DeleteAfterDays.ToString());
            Output.WriteEndElement();
        }
 
        public override bool HasCommands => true;
 
        public override Task<IEnumerable<ICommand>> Commands => this.GetCommands();
 
        private Task<IEnumerable<ICommand>> GetCommands()
        {
            return Task.FromResult<IEnumerable<ICommand>>(new ICommand[]
            {
                new ClearQueueCommand(this.Queue)
            });
        }
    }
}