update build

Rdmp.Dicom/Extraction/DicomTagToCSV.cs

@@ -5,6 +5,7 @@
 using Org.BouncyCastle.Tls;
 using Rdmp.Core.Curation.Data;
 using Rdmp.Core.DataFlowPipeline;
+using Rdmp.Core.Repositories.Construction;
 using Rdmp.Core.ReusableLibraryCode.Checks;
 using Rdmp.Core.ReusableLibraryCode.Progress;
 using Rdmp.Dicom.Extraction.FoDicomBased;
@@ -36,7 +37,11 @@ public class DicomTagToCSV : IPluginDataFlowComponent<DataTable>
         [DemandsInitialization("The number of errors (e.g. failed to find/anonymise file) to allow before abandoning the extraction", DefaultValue = 100)]
         public int ErrorThreshold { get; set; }
 
+        [DemandsInitialization("Determines how dicom files are written to the project output directory", TypeOf = typeof(IPutDicomFilesInExtractionDirectories), Mandatory = true)]
+        public Type PutterType { get; set; }
+
         private int _errors = 0;
+        private DirectoryInfo _destinationDirectory;
         private IPutDicomFilesInExtractionDirectories _putter;
 
 
@@ -67,14 +72,16 @@ public DataTable ProcessPipelineData(DataTable toProcess, IDataLoadEventListener
                 fileRows.Add(file, processRow);
                 dicomFiles.Add((file, file));
             }
-
+            _putter ??= (IPutDicomFilesInExtractionDirectories)ObjectConstructor.Construct(PutterType);
+
             var dicomFilePaths = new AmbiguousFilePath(ArchiveRootIfAny, dicomFiles).GetDataset(FileFetchRetryLimit, FileFetchRetryTimeout, listener);
             foreach (var dcm in dicomFilePaths)
             {
                 var filepath = Path.Combine("C:\\temp\\csvtest", dcm.Item1);
+
                 var sw = new StreamWriter(filepath);
                 using var w = new CsvWriter(sw, System.Globalization.CultureInfo.InvariantCulture);
-                w.WriteRecord(
+                w.WriteRecords(
                 dcm.Item2.Dataset.SelectMany(t => Entry.ProcessTag(dcm.Item1, t))
                 );
             }
@@ -83,6 +90,18 @@ public DataTable ProcessPipelineData(DataTable toProcess, IDataLoadEventListener
         }
     }
 
+     public void Initialize(int projectNumber, DirectoryInfo destinationDirectory, IMappingRepository uidSubstitutionLookup = null)
+        {
+            //_projectNumber = projectNumber;
+
+            //_uidSubstitutionLookup = uidSubstitutionLookup ?? (UIDMappingServer == null ? null : new MappingRepository(UIDMappingServer));
+            _destinationDirectory = destinationDirectory;
+
+            //_deleteTags = GetDeleteTags().ToArray();
+
+            //initialized = true;
+        }
+
     internal class Entry
     {
         public string Id { get; }