SynchronizationStatistics.cs

using System;
using System.Collections.Generic;
using System.Runtime.InteropServices.ComTypes;
using System.Threading.Tasks;
using Waher.Events;
using Waher.Things.Queries;
 
namespace Waher.Things.Files.Commands
{
    public class SynchronizationStatistics
    {
        private readonly Dictionary<string, string> folderIds = new Dictionary<string, string>();
        private readonly Query query;
        private readonly FolderNode node;
        private int nrFoldersAdded = 0;
        private int nrFoldersFound = 0;
        private int nrFoldersDeleted = 0;
        private int nrFilesAdded = 0;
        private int nrFilesFound = 0;
        private int nrFilesDeleted = 0;
 
        public SynchronizationStatistics(FolderNode Node, Query Query)
        {
            this.node = Node;
            this.query = Query;
        }
 
        private async Task<string> GetFolderTableId(string Folder)
        {
            if (this.folderIds.TryGetValue(Folder, out string TableId))
                return TableId;
 
            TableId = "F" + (this.folderIds.Count + 1).ToString();
            this.folderIds[Folder] = TableId;
 
            await this.query.BeginSection(Folder);
            await this.query.NewTable(TableId, "Files in " + Folder,
                new Column("FileName", "Filename", null, null, null, null, ColumnAlignment.Left, null),
                new Column("Action", "Action", null, null, null, null, ColumnAlignment.Left, null));
 
            return TableId;
        }
 
        public async Task FileFound(string Folder, string FileName)
        {
            string TableId = await this.GetFolderTableId(Folder);
            
            await this.query.NewRecords(TableId, new Record(FileName, "-"));
            
            this.nrFilesFound++;
        }
 
        public async Task FolderFound(string Folder, string SubFolder)
        {
            string TableId = await this.GetFolderTableId(Folder);
 
            await this.query.NewRecords(TableId, new Record(SubFolder, "-"));
 
            this.nrFoldersFound++;
        }
 
        public async Task FileAdded(string Folder, string FileName)
        {
            string TableId = await this.GetFolderTableId(Folder);
 
            await this.query.NewRecords(TableId, new Record(FileName, "Added"));
 
            this.nrFilesAdded++;
        }
 
        public async Task FolderAdded(string Folder, string SubFolder)
        {
            string TableId = await this.GetFolderTableId(Folder);
 
            await this.query.NewRecords(TableId, new Record(SubFolder, "Added"));
 
            this.nrFoldersAdded++;
        }
 
        public async Task FileDeleted(string Folder, string FileName)
        {
            string TableId = await this.GetFolderTableId(Folder);
 
            await this.query.NewRecords(TableId, new Record(FileName, "Deleted"));
 
            this.nrFilesDeleted++;
        }
 
        public async Task FolderDeleted(string Folder, string SubFolder)
        {
            string TableId = await this.GetFolderTableId(Folder);
 
            await this.query.NewRecords(TableId, new Record(SubFolder, "Deleted"));
 
            this.nrFoldersDeleted++;
        }
 
        public async Task Start()
        {
            await this.query.Start();
            await this.query.SetTitle(this.node.FolderPath);
 
            await this.query.BeginSection("Title");
            await this.query.NewTable("Totals", "Totals",
                new Column("Key", "Metric", string.Empty, string.Empty, null, null, ColumnAlignment.Left, null),
                new Column("Value", "Value", string.Empty, string.Empty, null, null, ColumnAlignment.Right, null));
            await this.query.EndSection();
        }
 
        public async Task Error(Exception ex)
        {
            await this.query.LogMessage(ex);
        }
 
        public async Task Done()
        {
            await this.query.NewRecords("Totals",
                new Record("#Files Existed", this.nrFilesFound),
                new Record("#Files Added", this.nrFilesAdded),
                new Record("#Files Deleted", this.nrFilesDeleted),
                new Record("#Folders Existed", this.nrFoldersFound),
                new Record("#Folders Added", this.nrFoldersAdded),
                new Record("#Folders Deleted", this.nrFoldersDeleted));
            await this.query.TableDone("Totals");
 
            foreach (KeyValuePair<string, string> P in this.folderIds)
                await this.query.TableDone(P.Value);
 
            await this.query.Done();
        }
    }
}