EvaluationArguments.cs

using System.Collections.Generic;
using Waher.Persistence;
using Waher.Runtime.Profiling;
using Waher.Script;
using Waher.Service.IoTBroker.EDaler;
using Waher.Service.IoTBroker.Legal;
using Waher.Service.IoTBroker.NeuroFeatures;
 
namespace Waher.Service.IoTBroker.StateMachines.Model
{
    public class EvaluationArguments
    {
        private readonly SortedDictionary<string, object> updatedVariables = new SortedDictionary<string, object>();
 
        public EvaluationArguments(Variables Variables, StateMachine Machine, Token Token,
            CurrentState CurrentState, LegalComponent Legal, EDalerComponent EDaler,
            Profiler Profiler)
        {
            this.Variables = Variables;
            this.Machine = Machine;
            this.Token = Token;
            this.CurrentState = CurrentState;
            this.StateUpdated = false;
            this.VariablesUpdated = false;
            this.AuthorizationsUpdated = false;
            this.Legal = Legal;
            this.EDaler = EDaler;
            this.Profiler = Profiler;
        }
 
        public Variables Variables { get; }
 
        public StateMachine Machine { get; }
 
        public Token Token { get; }
 
        public CurrentState CurrentState { get; }
 
        public bool StateUpdated 
        { 
            get; 
            internal set; 
        }
 
        public bool VariablesUpdated 
        { 
            get; 
            private set; 
        }
 
        public bool AuthorizationsUpdated
        {
            get;
            internal set;
        }
 
        public LegalComponent Legal { get; }
 
        public EDalerComponent EDaler { get; }
 
        public Profiler Profiler { get; }
 
        public void SetState(string StateId)
        {
            this.CurrentState.State = StateId;
            this.StateUpdated = true;
 
            if (string.IsNullOrEmpty(StateId))
                this.Profiler?.Idle();
            else
                this.Profiler?.NewState(StateId);
        }
 
        public void UpdateVariable(string Name, object Value)
        {
            lock (this.updatedVariables)
            {
                this.updatedVariables[Name] = Value;
                this.VariablesUpdated = true;
            }
 
            this.Variables[Name] = Value;
            this.CurrentState.SetVariable(Name, Value);
        }
 
        public void AddSource(CaseInsensitiveString Source)
        {
            if (this.CurrentState.AddSource(Source))
                this.AuthorizationsUpdated = true;
        }
 
        public void RemoveSource(CaseInsensitiveString Source)
        {
            if (this.CurrentState.RemoveSource(Source))
                this.AuthorizationsUpdated = true;
        }
 
        public KeyValuePair<string, object>[] PopUpdatedVariables()
        {
            KeyValuePair<string, object>[] Result;
 
            lock (this.updatedVariables)
            {
                Result = new KeyValuePair<string, object>[this.updatedVariables.Count];
                this.updatedVariables.CopyTo(Result, 0);
 
                this.updatedVariables.Clear();
                this.VariablesUpdated = false;
            }
 
            return Result;
        }
 
        public void ClearUpdatedVariables()
        {
            lock (this.updatedVariables)
            {
                this.updatedVariables.Clear();
                this.VariablesUpdated = false;
            }
        }
    }
}