DeltaProcessorBase.cs


using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
using BIT.Data.Sync.EventArgs;

namespace BIT.Data.Sync
{
    /// <summary>
    /// Base class for delta processors. This class implements the IDeltaProcessor interface and provides a basic implementation.
    /// </summary>
    public abstract class DeltaProcessorBase : IDeltaProcessor, IDeltaProcessorWithEvents
    {
        /// <summary>
        /// The sequence service used by the delta processor.
        /// </summary>
        private readonly ISequenceService sequenceService;
       

        public event EventHandler<ProcessingDeltaEventArgs> ProcessingDelta;
        public event EventHandler<ProcessedDeltaEventArgs> ProcessedDelta;

        /// <summary>
        /// Raises the ProcessingDelta event.
        /// </summary>
        /// <param name="e"></param>
        protected virtual void OnProcessingDelta(ProcessingDeltaEventArgs e)
        {

             ProcessingDelta?.Invoke(this, e);
        }
        /// <summary>
        /// Raises the ProcessedDelta event.
        /// </summary>
        /// <param name="e"></param>
        protected virtual void OnProcessedDelta(ProcessedDeltaEventArgs e)
        {
            ProcessedDelta?.Invoke(this, e);
        }

        /// <summary>
        /// Gets the sequence service used by the delta processor.
        /// </summary>
        public ISequenceService SequenceService => sequenceService;

        /// <summary>
        /// Processes a collection of deltas asynchronously.
        /// </summary>
        /// <param name="Deltas">The deltas to process.</param>
        /// <param name="cancellationToken">A cancellation token that can be used to cancel the operation.</param>
        /// <returns>A task that represents the asynchronous operation.</returns>
        public abstract Task ProcessDeltasAsync(IEnumerable<IDelta> Deltas, CancellationToken cancellationToken);

        /// <summary>
        /// Initializes a new instance of the DeltaProcessorBase class with the specified sequence service.
        /// </summary>
        /// <param name="sequenceService">The sequence service to use for processing deltas.</param>
        public DeltaProcessorBase(ISequenceService sequenceService)
        {
            this.sequenceService = sequenceService;
        }
    }
}