OwnerEventNode.cs

using System.Threading.Tasks;
using Waher.Persistence;
using Waher.Service.IoTBroker.StateMachines.EventHandlers;
using Waher.Service.IoTBroker.StateMachines.Exceptions;
using Waher.Service.IoTBroker.StateMachines.Model.States;
 
namespace Waher.Service.IoTBroker.StateMachines.Model.Events
{
    public abstract class OwnerEventNode : EventNode
    {
        public OwnerEventNode()
            : base()
        {
        }
 
        public override async Task<EventHandlerReference> Register(int EventIndex, EvaluationArguments Arguments, OnEvent Event)
        {
            if (Arguments.Token is null)
                throw new StateMachineException(Arguments.Machine, "State Machine does not have single token owner.");
 
            OwnerEventHandler Handler = new OwnerEventHandler(Arguments, EventIndex, this, Arguments.Token.OwnerJid);
            
            await Database.Insert(Handler);
            await Handler.AddToCache();
 
            return null;
        }
 
    }
}