ConditionalProcessor.cs

using System;
using System.Threading.Tasks;
using Waher.Persistence;
using Waher.Script.Abstraction.Elements;
using Waher.Script.Model;
 
namespace Waher.Script.Persistence.SQL.Processors
{
    public class ConditionalProcessor : IProcessor<object>
    {
        private readonly IProcessor<object> processor;
        private readonly bool isAsynchronous;
        private readonly ScriptNode conditions;
        private readonly Variables variables;
        private ObjectProperties properties = null;
 
        public ConditionalProcessor(IProcessor<object> Processor, Variables Variables, ScriptNode Conditions)
        {
            this.processor = Processor;
            this.variables = Variables;
            this.conditions = Conditions;
            this.isAsynchronous = Processor.IsAsynchronous || Conditions.IsAsynchronous;
        }
 
        public bool IsAsynchronous => this.isAsynchronous;
 
        public bool Process(object Object)
        {
            try
            {
                if (this.properties is null)
                    this.properties = new ObjectProperties(Object, this.variables);
                else
                    this.properties.Object = Object;
 
                IElement E = this.conditions.Evaluate(this.properties);
                if (!(E.AssociatedObjectValue is bool B) || !B)
                    return true;
 
                return this.processor.Process(Object);
            }
            catch (Exception)
            {
                return true;
            }
        }
 
        public async Task<bool> ProcessAsync(object Object)
        {
            try
            {
                if (this.properties is null)
                    this.properties = new ObjectProperties(Object, this.variables);
                else
                    this.properties.Object = Object;
 
                IElement E = await this.conditions.EvaluateAsync(this.properties);
                if (!(E.AssociatedObjectValue is bool B) || !B)
                    return true;
 
                return await this.processor.ProcessAsync(Object);
            }
            catch (Exception)
            {
                return true;
            }
        }
 
        public bool Flush() => this.processor.Flush();
 
        public Task<bool> FlushAsync() => this.processor.FlushAsync();
    }
}