ExecuteReportFileCommand.cs

using System;
using System.Threading.Tasks;
using Waher.Events;
using Waher.Networking.XMPP.Concentrator;
using Waher.Networking.XMPP.DataForms;
using Waher.Reports.Files.Model;
using Waher.Runtime.Language;
using Waher.Script;
using Waher.Things;
using Waher.Things.Queries;
 
namespace Waher.Reports.Files.Commands
{
    public class ExecuteReportFileCommand : ExecuteReport, IEditableObject
    {
        private readonly ReportFile parsedReport;
        private readonly Variables variables;
 
        public ExecuteReportFileCommand(ReportFile Report, ReportNode ReportNode, Variables Variables)
            : base(ReportNode)
        {
            this.parsedReport = Report;
            this.variables = Variables;
        }
 
        public override ICommand Copy()
        {
            return new ExecuteReportFileCommand(this.parsedReport, this.Report, this.variables);
        }
 
        public Task PopulateForm(DataForm Parameters, Language Language, IRequestOrigin Origin)
        {
            return this.parsedReport.PopulateForm(Parameters, Language, this.variables, Origin);
        }
 
        public Task<SetEditableFormResult> SetParameters(DataForm Parameters, Language Language, 
            bool OnlySetChanged, IRequestOrigin Origin)
        {
            return this.parsedReport.SetParameters(Parameters, Language, OnlySetChanged, this.variables, Origin);
        }
 
        public override async Task StartQueryExecutionAsync(Query Query, Language Language)
        {
            ReportState State = new ReportState(Query, Language, this.variables,
                await Language.GetNamespaceAsync(typeof(ReportFileNode).Namespace),
                Query.Origin);
 
            try
            {
                if (!State.Query.IsStarted)
                    await State.Query.Start();
 
                await Query.SetStatus(await State.ReportFilesNamespace.GetStringAsync(9, "Executing Query..."));
 
                await this.parsedReport.Execute(State);
 
                await State.Query.SetStatus(string.Empty);
            }
            catch (Exception ex)
            {
                await Query.LogMessage(ex);
                Log.Exception(ex);
            }
            finally
            {
                if (!Query.IsDone && !Query.IsAborted)
                    await Query.Done();
            }
        }
    }
}