CreateEntry.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using System.Xml;
using Waher.Persistence.Serialization;
 
namespace Waher.Service.IoTBroker.StateMachines.Model.Actions.Ledger
{
    public class CreateEntry : ActionNode
    {
        private Collection collection;
        private Type type;
        private Property[] properties;
 
        public CreateEntry()
            : base()
        {
        }
 
        public Collection Collection => this.collection;
 
        public Type Type => this.type;
 
        public Property[] Properties => this.properties;
 
        public override string LocalName => nameof(CreateEntry);
 
        public override IStateMachineNode Create()
        {
            return new CreateEntry();
        }
 
        public override async Task Parse(XmlElement Xml)
        {
            await base.Parse(Xml);
 
            this.ConvertValueAttributesToElements(Xml,
                new System.Type[]
                {
                    typeof(Collection),
                    typeof(Type)
                },
                new bool[]
                {
                    true,
                    true
                });
        }
 
        protected override void OnChildNodesUpdated()
        {
            base.OnChildNodesUpdated();
 
            this.collection = this.GetValueElement<Collection>();
            this.type = this.GetValueElement<Type>();
            this.properties = this.GetChildElements<Property>();
        }
 
        public override async Task Execute(EvaluationArguments Arguments)
        {
            string Collection = (await this.collection.Evaluate(Arguments))?.ToString();
            string Type = (await this.type.Evaluate(Arguments))?.ToString();
            List<KeyValuePair<string, object>> Properties = new List<KeyValuePair<string, object>>();
 
            foreach (Property Property in this.properties)
            {
                Properties.Add(new KeyValuePair<string, object>(
                    (await Property.Key.Evaluate(Arguments))?.ToString(),
                    await Property.Value.Evaluate(Arguments)));
            }
 
            await Persistence.Ledger.NewEntry(new GenericObject(Collection, Type, Guid.NewGuid(), Properties.ToArray()));
        }
    }
}