EntryEventNode.cs

using System.Text;
using System.Threading.Tasks;
using System.Xml;
using Waher.Content.Xml;
using Waher.Persistence;
using Waher.Persistence.Attributes;
using Waher.Service.IoTBroker.StateMachines.EventHandlers;
using Waher.Service.IoTBroker.StateMachines.Model.Attributes;
using Waher.Service.IoTBroker.StateMachines.Model.States;
 
namespace Waher.Service.IoTBroker.StateMachines.Model.Events
{
    public abstract class EntryEventNode : EventNode
    {
        private ScriptableStringAttribute entryVariable;
        private ScriptableStringAttribute collectionName;
        private ScriptableStringAttribute typeName;
 
        public EntryEventNode()
            : base()
        {
        }
 
        [DefaultValueNull]
        public string EntryVariableDefinition
        {
            get => this.entryVariable?.Definition;
            set => this.entryVariable = new ScriptableStringAttribute(value, this);
        }
 
        [DefaultValueNull]
        public string CollectionNameDefinition
        {
            get => this.collectionName?.Definition;
            set => this.collectionName = new ScriptableStringAttribute(value, this);
        }
 
        [DefaultValueNull]
        public string TypeNameDefinition
        {
            get => this.typeName?.Definition;
            set => this.typeName = new ScriptableStringAttribute(value, this);
        }
 
        public override Task Parse(XmlElement Xml)
        {
            this.entryVariable = new ScriptableStringAttribute(XML.Attribute(Xml, "sellerVariable"), this);
            this.collectionName = new ScriptableStringAttribute(XML.Attribute(Xml, "collectionName"), this);
            this.typeName = new ScriptableStringAttribute(XML.Attribute(Xml, "typeName"), this);
 
            return base.Parse(Xml);
        }
 
        public override async Task<bool> Register(int EventIndex, EvaluationArguments Arguments, OnEvent Event)
        {
            string Collection = await this.collectionName.Evaluate(Arguments.Variables);
            string Type = await this.typeName.Evaluate(Arguments.Variables);
 
            EntryEventHandler Handler = new EntryEventHandler(Arguments, EventIndex, this, Collection, Type);
 
            await Database.Insert(Handler);
            await Handler.AddToCache();
 
            return false;
        }
 
        public override string Label
        {
            get
            {
                StringBuilder sb = new StringBuilder();
 
                sb.Append(this.GetType().Name);
                sb.Append('(');
                sb.Append(this.typeName.Definition);
                sb.Append(')');
 
                return sb.ToString();
            }
        }
 
    }
}