JobTaskNode.cs

using System.Collections.Generic;
using System.Threading.Tasks;
using Waher.Groups;
using Waher.Runtime.Collections;
using Waher.Things;
 
namespace Waher.Jobs.NodeTypes
{
    public abstract class JobTaskNode : JobNode, IGroup
    {
        public JobTaskNode()
        {
        }
 
        public override Task<bool> AcceptsParentAsync(INode Parent)
        {
            return Task.FromResult(Parent is Job);
        }
 
        public async Task<T[]> FindNodes<T>()
            where T : INode
        {
            ChunkedList<T> Nodes = new ChunkedList<T>();
            await this.FindNodes(Nodes);
            return Nodes.ToArray();
        }
 
        public async Task FindNodes<T>(ChunkedList<T> Nodes)
            where T : INode
        {
            IEnumerable<INode> Children = await this.ChildNodes;
            if (Children is null)
                return;
 
            foreach (INode Child in Children)
            {
                if (Child is T Typed)
                    Nodes.Add(Typed);
                else if (Child is IGroup Group)
                    await Group.FindNodes(Nodes);
            }
        }
 
        public abstract Task ExecuteTask(JobExecutionStatus Status);
    }
}