XmppStatisticsCommand.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Waher.Persistence;
using Waher.Persistence.Filters;
using Waher.Runtime.Language;
using Waher.Things;
using Waher.Things.Attributes;
using Waher.Things.Queries;
 
namespace Waher.Service.IoTBroker.Sources.Reports.Protocols.Commands
{
    public class XmppStatisticsCommand : ExecuteServerAdminReport
    {
        public XmppStatisticsCommand(XmppProtocol Report)
            : base(Report)
        {
        }
 
        [Page(1, "Time", 150)]
        [Header(2, "From:")]
        [ToolTip(3, "Search for records from this point in time.")]
        public DateTime From = DateTime.Today.AddDays(-1);
 
        [Page(1, "Time", 150)]
        [Header(4, "To:")]
        [ToolTip(5, "Search for records to this point in time.")]
        public DateTime To = DateTime.Today.AddDays(1);
 
        public override Task<string> GetNameAsync(Language Language)
        {
            return Language.GetStringAsync(typeof(XmppStatisticsCommand), 6, "Statistics...");
        }
 
        public override ICommand Copy()
        {
            return new XmppStatisticsCommand((XmppProtocol)this.Report)
            {
                From = this.From,
                To = this.To
            };
        }
 
        public override Task StartQueryExecutionAsync(Query Query, Language Language)
        {
            this.Execute(Query, Language);
            return Task.CompletedTask;
        }
 
        private async void Execute(Query Query, Language Language)
        {
            try
            {
                await Query.Start();
                await Query.SetTitle(await Language.GetStringAsync(typeof(XmppStatisticsCommand), 15, "Requests"));
 
                if (this.To < this.From)
                {
                    DateTime Temp = this.To;
                    this.To = this.From;
                    this.From = Temp;
                }
 
                List<Filter> Filters = new List<Filter>();
                if (this.From > DateTime.MinValue)
                    Filters.Add(new FilterFieldGreaterOrEqualTo("Timestamp", this.From));
 
                if (this.To < DateTime.MaxValue)
                    Filters.Add(new FilterFieldLesserOrEqualTo("Timestamp", this.To));
 
                await Query.SetStatus(await Language.GetStringAsync(typeof(XmppStatisticsCommand), 8, "Searching database..."));
                
                IEnumerable<XmppStatistic> Records = Filters.Count switch
                {
                    0 => await Database.Find<XmppStatistic>("Timestamp"),
                    1 => await Database.Find<XmppStatistic>(Filters[0], "Timestamp"),
                    _ => await Database.Find<XmppStatistic>(new FilterAnd(Filters.ToArray()), "Timestamp"),
                };
                
                string Header = await Language.GetStringAsync(typeof(XmppStatisticsCommand), 17, "XMPP Statistics");
                await Query.BeginSection(Header);
                await Query.NewTable("Statistics", Header, new Column[]
                {
                    new Column("Start", await Language.GetStringAsync(typeof(XmppStatisticsCommand), 10, "Start"),
                        null, null, null, null, ColumnAlignment.Left, null),
                    new Column("Timestamp", await Language.GetStringAsync(typeof(XmppStatisticsCommand), 11, "Timestamp"),
                        null, null, null, null, ColumnAlignment.Left, null),
                    new Column("Requests", await Language.GetStringAsync(typeof(XmppStatisticsCommand), 16, "#Stanzas"),
                        null, null, null, null, ColumnAlignment.Right, null),
                    new Column("Rx", await Language.GetStringAsync(typeof(XmppStatisticsCommand), 13, "#Rx"),
                        null, null, null, null, ColumnAlignment.Right, null),
                    new Column("Tx", await Language.GetStringAsync(typeof(XmppStatisticsCommand), 14, "#Tx"),
                        null, null, null, null, ColumnAlignment.Right, null)
                });
 
                foreach (XmppStatistic Rec in Records)
                {
                    await Query.NewRecords("Statistics", new Record(new object[]
                    {
                        Rec.Start,
                        Rec.Timestamp,
                        Rec.NrStanzas,
                        Rec.NrBytesRx,
                        Rec.NrBytesTx
                    }));
                }
 
                await Query.TableDone("Statistics");
                await Query.EndSection();
            }
            catch (Exception ex)
            {
                await Query.LogMessage(ex);
            }
            finally
            {
                await Query.Done();
            }
        }
 
    }
}