WebHookEventSinkNode.cs

using System.Collections.Generic;
using System.Threading.Tasks;
using System.Xml;
using Waher.Content;
using Waher.Events.WebHook;
using Waher.Runtime.Language;
using Waher.Things;
using Waher.Things.Attributes;
using Waher.Things.DisplayableParameters;
 
namespace Waher.Service.IoTBroker.Sources.GatewayConfig.EventSinkNodes
{
    public class WebHookEventSinkNode : EventSinkNode
    {
        public WebHookEventSinkNode()
            : base()
        {
        }
 
        public WebHookEventSinkNode(GatewayConfigSource Source, ConfigurationNode Parent,
            string SinkId, string Url, int MaxSecondsUsed, int MaxSecondsUnused, 
            bool CollectOnType, bool CollectOnLevel, bool CollectOnEventId, 
            bool CollectOnObject, bool CollectOnActor, bool CollectOnFacility, 
            bool CollectOnModule)
            : base(Source, Parent, SinkId)
        {
            this.Url = Url;
            this.MaxSecondsUsed = MaxSecondsUsed;
            this.MaxSecondsUnused = MaxSecondsUnused;
            this.CollectOnType = CollectOnType;
            this.CollectOnLevel = CollectOnLevel;
            this.CollectOnEventId = CollectOnEventId;
            this.CollectOnObject = CollectOnObject;
            this.CollectOnActor = CollectOnActor;
            this.CollectOnFacility = CollectOnFacility;
            this.CollectOnModule = CollectOnModule;
        }
 
        [Page(7, "Configuration")]
        [Header(185, "Callback URL:")]
        [ToolTip(186, "URL to call for each event.")]
        [Required]
        public string Url { get; set; }
 
        [Page(7, "Configuration")]
        [Header(221, "Max collection time (s):")]
        [ToolTip(222, "Maximum number of seconds events can be cached before being sent.")]
        public int MaxSecondsUsed { get; set; }
 
        [Page(7, "Configuration")]
        [Header(223, "Min collection time (s):")]
        [ToolTip(224, "Minimum number of seconds events can be cached before being sent.")]
        public int MaxSecondsUnused { get; set; }
 
        [Page(7, "Configuration")]
        [Header(225, "Collect on Type.")]
        [ToolTip(226, "Collect events having the same event type.")]
        public bool CollectOnType { get; set; }
 
        [Page(7, "Configuration")]
        [Header(227, "Collect on Level.")]
        [ToolTip(228, "Collect events having the same event level.")]
        public bool CollectOnLevel { get; set; }
 
        [Page(7, "Configuration")]
        [Header(229, "Collect on Level.")]
        [ToolTip(230, "Collect events having the same event level.")]
        public bool CollectOnEventId { get; set; }
 
        [Page(7, "Configuration")]
        [Header(231, "Collect on Object.")]
        [ToolTip(232, "Collect events having the same event object.")]
        public bool CollectOnObject { get; set; }
 
        [Page(7, "Configuration")]
        [Header(233, "Collect on Actor.")]
        [ToolTip(234, "Collect events having the same event actor.")]
        public bool CollectOnActor { get; set; }
 
        [Page(7, "Configuration")]
        [Header(235, "Collect on Facility.")]
        [ToolTip(236, "Collect events having the same event facility.")]
        public bool CollectOnFacility { get; set; }
 
        [Page(7, "Configuration")]
        [Header(237, "Collect on Module.")]
        [ToolTip(238, "Collect events having the same event module.")]
        public bool CollectOnModule { get; set; }
 
        public override Task<string> GetTypeNameAsync(Language Language)
        {
            return Language.GetStringAsync(typeof(GatewayConfigSource), 187, "WebHook 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("Url", await Namespace.GetStringAsync(188, "URL"), this.Url));
 
            return Parameters;
        }
 
        public override void Export(XmlWriter Output)
        {
            Output.WriteStartElement("WebHookEventSink");
            Output.WriteAttributeString("id", this.SinkId);
            Output.WriteAttributeString("url", this.Url);
            Output.WriteAttributeString("maxSecondsUsed", this.MaxSecondsUsed.ToString());
            Output.WriteAttributeString("maxSecondsUnused", this.MaxSecondsUnused.ToString());
            Output.WriteAttributeString("collectOnType", CommonTypes.Encode(this.CollectOnType));
            Output.WriteAttributeString("collectOnLevel", CommonTypes.Encode(this.CollectOnLevel));
            Output.WriteAttributeString("collectOnEventId", CommonTypes.Encode(this.CollectOnEventId));
            Output.WriteAttributeString("collectOnObject", CommonTypes.Encode(this.CollectOnObject));
            Output.WriteAttributeString("collectOnActor", CommonTypes.Encode(this.CollectOnActor));
            Output.WriteAttributeString("collectOnFacility", CommonTypes.Encode(this.CollectOnFacility));
            Output.WriteAttributeString("collectOnModule", CommonTypes.Encode(this.CollectOnModule));
            Output.WriteEndElement();
        }
    }
}