IndexRebuilderFilterDecorator.cs

using System.Collections.Generic;
using System.Threading.Tasks;

using Sitecore.Xdb.Collection;
using Sitecore.Xdb.Collection.Indexing;
using Sitecore.Xdb.Collection.Model;

namespace Test.SCExtensions.Xdb.Collection.Search.Solr
{
  public sealed class IndexRebuilderFilterDecorator : IIndexRebuilder
  {
    private readonly IIndexRebuilder _inner;

    public IndexRebuilderFilterDecorator(IIndexRebuilder inner)
    {
      this._inner = inner;
    }

    public Task BeginRebuild()
    {
      return this._inner.BeginRebuild();
    }

    public Task CompleteRebuild(ISyncToken syncToken)
    {
      return this._inner.CompleteRebuild(syncToken);
    }

    public async Task WriteDataBatch(ChangedDataRecords changedDataRecordsBatch)
    {
      ChangedDataRecords filteredChanges = new ChangedDataRecords(changedDataRecordsBatch.get_ContactRecords(), (IReadOnlyCollection<InteractionDataRecord>) new List<InteractionDataRecord>().AsReadOnly(), changedDataRecordsBatch.get_DeletedContactIds(), changedDataRecordsBatch.get_DeletedInteractionIds());
      await this._inner.WriteDataBatch(filteredChanges).ConfigureAwait(false);
    }
  }
}