CompoundQuery.cs

using System.Collections.Generic;
using System.Threading.Tasks;
using Waher.Runtime.Language;
 
namespace Waher.Things.Queries
{
    public class CompoundQuery : Query
    {
        private readonly IEnumerable<Query> queries;
 
        public CompoundQuery(string CommandId, string QueryId, object State, Language Language, IEnumerable<Query> Queries)
            : base(CommandId, QueryId, State, Language, null)
        {
            this.queries = Queries;
 
            foreach (Query Query in this.queries)
            {
                Query.OnAborted += Query_OnAborted;
                Query.OnBeginSection += Query_OnBeginSection;
                Query.OnDone += Query_OnDone;
                Query.OnEndSection += Query_OnEndSection;
                Query.OnMessage += Query_OnMessage;
                Query.OnNewObject += Query_OnNewObject;
                Query.OnNewRecords += Query_OnNewRecords;
                Query.OnNewTable += Query_OnNewTable;
                Query.OnStarted += Query_OnStarted;
                Query.OnStatus += Query_OnStatus;
                Query.OnTableDone += Query_OnTableDone;
                Query.OnTitle += Query_OnTitle;
            }
        }
 
        private Task Query_OnTitle(object Sender, QueryTitleEventArgs e)
        {
            return this.SetTitle(e);
        }
 
        private Task Query_OnTableDone(object Sender, QueryTableEventArgs e)
        {
            return this.TableDone(e);
        }
 
        private Task Query_OnStatus(object Sender, QueryStatusEventArgs e)
        {
            return this.SetStatus(e);
        }
 
        private Task Query_OnStarted(object Sender, QueryEventArgs e)
        {
            return this.Start(e);
        }
 
        private Task Query_OnNewTable(object Sender, QueryNewTableEventArgs e)
        {
            return this.NewTable(e);
        }
 
        private Task Query_OnNewRecords(object Sender, QueryNewRecordsEventArgs e)
        {
            return this.NewRecords(e);
        }
 
        private Task Query_OnNewObject(object Sender, QueryObjectEventArgs e)
        {
            return this.NewObject(e);
        }
 
        private Task Query_OnMessage(object Sender, QueryMessageEventArgs e)
        {
            return this.LogMessage(e);
        }
 
        private Task Query_OnEndSection(object Sender, QueryEventArgs e)
        {
            return this.EndSection(e);
        }
 
        private Task Query_OnDone(object Sender, QueryEventArgs e)
        {
            return this.Done(e);
        }
 
        private Task Query_OnBeginSection(object Sender, QueryTitleEventArgs e)
        {
            return this.BeginSection(e);
        }
 
        private Task Query_OnAborted(object Sender, QueryEventArgs e)
        {
            return this.Abort(e);
        }
 
        public IEnumerable<Query> Queries => this.queries;
 
        public override async Task Abort()
        {
            await base.Abort();
 
            foreach (Query Query in this.queries)
                await Query.Abort();
        }
    }
}