TextNote.cs

using System;
using System.Threading.Tasks;
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 TextNote : Note
    {
        public TextNote()
            : base()
        {
        }
 
        public override string LocalName => nameof(TextNote);
 
        public override IStateMachineNode Create()
        {
            return new TextNote();
        }
 
        public override async Task Execute(EvaluationArguments Arguments)
        {
            object Content = await this.Content.Evaluate(Arguments);
            if (!(Content is string TextContent))
                throw new StateMachineException(Arguments.Machine, "Expected text 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.");
            }
 
            NoteText Event = new NoteText()
            {
                ArchiveOptional = Arguments.Token?.ArchiveOptional ?? Arguments.Machine?.ArchiveOptional,
                ArchiveRequired = Arguments.Token?.ArchiveRequired ?? Arguments.Machine?.ArchiveRequired,
                Expires = Arguments.Token?.Expires ?? Arguments.Machine?.Expires ?? DateTime.MaxValue,
                Note = TextContent,
                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);
                }
            });
        }
    }
}