ScheduleAction.cs

using System;
using System.Threading.Tasks;
 
namespace Waher.Service.IoTBroker.StateMachines.Model.Actions.Runtime
{
    public class ScheduleAction : ActionReference, IActionNode
    {
        private When when;
 
        public ScheduleAction()
            : base()
        {
        }
 
        public When When => this.when;
 
        public override string LocalName => nameof(ScheduleAction);
 
        public override IStateMachineNode Create()
        {
            return new ScheduleAction();
        }
 
        protected override void OnChildNodesUpdated()
        {
            base.OnChildNodesUpdated();
 
            this.when = this.GetChildElement<When>(true);
        }
 
        public async Task Execute(EvaluationArguments Arguments)
        {
            DateTime Timepoint = await this.when.CalcWhenUtc(Arguments);
 
            if (Timepoint <= DateTime.UtcNow)
                await this.ExecuteNoLog(Arguments, false);
            else
            {
                string ActionId = await this.GetReference(Arguments);
                await ScheduledAction.Schedule(Arguments.Machine.StateMachineId, Timepoint, 
                    ActionId, this.BeforeActionScript);
            }
        }
    }
}