ExportCounter.cs

using System;
using System.Threading.Tasks;
using Waher.Persistence;
using Waher.Persistence.Serialization;
 
namespace Waher.Script.Persistence.SQL.LedgerExports
{
    public class ExportCounter : ILedgerExport
    {
        private readonly ILedgerExport output;
        private long nrCollections = 0;
        private long nrBlocks = 0;
        private long nrEntries = 0;
        private long nrProperties = 0;
 
        public ExportCounter(ILedgerExport Output)
        {
            this.output = Output;
        }
 
        public long NrCollections => this.nrCollections;
        
        public long NrBlocks => this.nrBlocks;
        
        public long NrEntries => this.nrEntries;
        
        public long NrProperties => this.nrProperties;
 
        public Task<bool> StartLedger(ILedgerProvider Provider)
        {
            return this.output?.StartLedger(Provider) ?? Task.FromResult(true);
        }
 
        public Task<bool> EndLedger()
        {
            return this.output?.EndLedger() ?? Task.FromResult(true);
        }
 
        public Task<bool> StartCollection(string CollectionName)
        {
            this.nrCollections++;
            return this.output?.StartCollection(CollectionName) ?? Task.FromResult(true);
        }
 
        public Task<bool> EndCollection()
        {
            return this.output?.EndCollection() ?? Task.FromResult(true);
        }
 
        public Task<bool> StartBlock(string BlockID)
        {
            this.nrBlocks++;
            return this.output?.StartBlock(BlockID) ?? Task.FromResult(true);
        }
 
        public Task<bool> BlockMetaData(string Key, object Value)
        {
            return this.output?.BlockMetaData(Key, Value) ?? Task.FromResult(true);
        }
 
        public Task<bool> EndBlock()
        {
            return this.output?.EndBlock() ?? Task.FromResult(true);
        }
 
        public Task<bool> StartEntry(string ObjectId, string TypeName, EntryType EntryType, DateTimeOffset EntryTimestamp)
        {
            this.nrEntries++;
            return this.output?.StartEntry(ObjectId, TypeName, EntryType, EntryTimestamp) ?? Task.FromResult(true);
        }
 
        public Task<bool> ReportProperty(string PropertyName, object PropertyValue)
        {
            this.nrProperties++;
            return this.output?.ReportProperty(PropertyName, PropertyValue) ?? Task.FromResult(true);
        }
 
        public Task<bool> EndEntry()
        {
            return this.output?.EndEntry() ?? Task.FromResult(true);
        }
 
        public Task<bool> CollectionCleared(DateTimeOffset EntryTimestamp)
        {
            return this.output?.CollectionCleared(EntryTimestamp) ?? Task.FromResult(true);
        }
 
        public Task<bool> ReportError(string Message)
        {
            return this.output?.ReportError(Message) ?? Task.FromResult(true);
        }
 
        public Task<bool> ReportException(Exception Exception)
        {
            return this.output?.ReportException(Exception) ?? Task.FromResult(true);
        }
    }
}