DataReaderImageImporterProcess
using kCura.Relativity.DataReaderClient;
using Monitoring.Sinks;
using Relativity.DataExchange;
using Relativity.DataExchange.Io;
using System;
using System.Data;
namespace kCura.WinEDDS.ImportExtension
{
public class DataReaderImageImporterProcess : ImportImageFileProcess
{
private IDataReader _reader;
private ImageSettings _imageSettings;
public DataReaderImageImporterProcess(ImageSourceIDataReader sourceData, ImageSettings imageSettings, IMetricService metricService, IRunningContext runningContext, Func<string> correlationIdFunc)
: base(metricService, runningContext, correlationIdFunc)
{
_reader = sourceData.Reader;
_imageSettings = imageSettings;
}
protected override BulkImageFileImporter GetImageFileImporter()
{
_ioReporterContext = new IoReporterContext(base.FileSystem, base.AppSettings, new WaitAndRetryPolicy(base.AppSettings));
IIoReporter ioReporterInstance = CreateIoReporter(_ioReporterContext);
return new DataReaderImageImporter(ImageLoadFile.DestinationFolderID, ImageLoadFile, base.Context, ioReporterInstance, base.Logger, Guid.NewGuid(), base.CancellationTokenSource, _reader, _imageSettings, _correlationIdFunc, base.RunningContext.ExecutionSource);
}
protected override void OnExecute()
{
base.OnExecute();
}
}
}