XmlNote.cs

using System;
using System.Threading.Tasks;
using System.Xml;
using Waher.Events;
using Waher.Persistence;
using Waher.Service.IoTBroker.NeuroFeatures.Events;
using Waher.Service.IoTBroker.StateMachines.Exceptions;
 
namespace Waher.Service.IoTBroker.StateMachines.Model.Actions.Notes
{
    public class XmlNote : Note
    {
        public XmlNote()
            : base()
        {
        }
 
        public override string LocalName => nameof(XmlNote);
 
        public override IStateMachineNode Create()
        {
            return new XmlNote();
        }
 
        public override async Task Execute(EvaluationArguments Arguments)
        {
            object Content = await this.Content.Evaluate(Arguments);
            string XmlContent;
 
            if (Content is XmlNode N)
                XmlContent = N.OuterXml;
            else
                throw new StateMachineException(Arguments.Machine, "Expected XML content.");
 
            bool Personal = false;
            if (!(this.Personal is null))
            {
                if (await this.Personal.Evaluate(Arguments) is bool b)
                    Personal = b;
                else
                    throw new StateMachineException(Arguments.Machine, "Personal must be a boolean value.");
            }
 
            NoteXml Event = new NoteXml()
            {
                ArchiveOptional = Arguments.Token?.ArchiveOptional ?? Arguments.Machine?.ArchiveOptional,
                ArchiveRequired = Arguments.Token?.ArchiveRequired ?? Arguments.Machine?.ArchiveRequired,
                Expires = Arguments.Token?.Expires ?? Arguments.Machine?.Expires ?? DateTime.MaxValue,
                Note = XmlContent,
                LocalName = N.LocalName,
                Namespace = N.NamespaceURI,
                Personal = Personal,
                Timestamp = DateTime.UtcNow,
                TokenId = Arguments.Token?.TokenId ?? Arguments.Machine?.StateMachineId
            };
 
            await Database.Insert(Event);
 
            _ = Task.Run(async () =>
            {
                try
                {
                    if (Arguments.Token is null)
                        await StateMachineProcessor.EventGenerated(Arguments.Machine?.StateMachineId, Event);
                    else
                        await StateMachineProcessor.EventGenerated(Arguments.Token, Event);
                }
                catch (Exception ex)
                {
                    Log.Exception(ex);
                }
            });
        }
    }
}