Removed IFileRead.Callback

Adaptation/FileHandlers/Archive/FileRead.cs

@@ -100,8 +100,6 @@ public class FileRead : Shared.FileRead, IFileRead
             throw new Exception();
     }
 
-    void IFileRead.Callback(object state) => throw new Exception(string.Concat("Not ", nameof(_IsDuplicator)));
-
     private void MoveArchive(DateTime dateTime)
     {
         if (dateTime == DateTime.MinValue)

Adaptation/FileHandlers/Dummy/FileRead.cs

@@ -101,8 +101,6 @@ public class FileRead : Shared.FileRead, IFileRead
             throw new Exception();
     }
 
-    void IFileRead.Callback(object state) => Callback(state);
-
     private void CallbackInProcessCleared(string sourceArchiveFile, string traceDummyFile, string targetFileLocation, string monARessource, string inProcessDirectory, long sequence, bool warning)
     {
         const string site = "sjc";

Adaptation/FileHandlers/MET08THFTIRSTRATUS/FileRead.cs

@@ -23,9 +23,6 @@ public class FileRead : Shared.FileRead, IFileRead
 
 #pragma warning disable CA1847
 
-    private readonly Timer _Timer;
-    private int _LastDummyRunIndex;
-    private readonly bool _IsDummy;
     private readonly bool _IsNaEDA;
     private readonly bool _IsXToAPC;
     private readonly string _IqsFile;
@@ -53,8 +50,6 @@ public class FileRead : Shared.FileRead, IFileRead
         if (!_IsDuplicator)
             throw new Exception(cellInstanceConnectionName);
         _OriginalDataBioRad = "OriginalDataBioRad_";
-        _LastDummyRunIndex = -1;
-        _IsDummy = _Hyphens == (int)Hyphen.IsDummy;
         _IsNaEDA = _Hyphens == (int)Hyphen.IsNaEDA;
         _IsXToAPC = _Hyphens == (int)Hyphen.IsXToAPC;
         _CellNames = new Dictionary<string, string>();
@@ -70,21 +65,6 @@ public class FileRead : Shared.FileRead, IFileRead
         ModelObjectParameterDefinition[] cellInstanceCollection = GetProperties(cellInstanceConnectionName, modelObjectParameters, "CellInstance.", ".Path");
         foreach (ModelObjectParameterDefinition modelObjectParameterDefinition in cellInstanceCollection)
             _CellNames.Add(modelObjectParameterDefinition.Name.Split('.')[1], modelObjectParameterDefinition.Value);
-        if (_IsDummy)
-        {
-            if (Debugger.IsAttached || fileConnectorConfiguration.PreProcessingMode == FileConnectorConfiguration.PreProcessingModeEnum.Process)
-            {
-                _Timer = new Timer(Callback, null, Timeout.Infinite, Timeout.Infinite);
-                Callback(null);
-            }
-            else
-            {
-                int milliSeconds;
-                milliSeconds = (int)(fileConnectorConfiguration.FileScanningIntervalInSeconds * 1000 / 2);
-                _Timer = new Timer(Callback, null, milliSeconds, Timeout.Infinite);
-                milliSeconds += 2000;
-            }
-        }
     }
 
     void IFileRead.Move(Tuple<string, Test[], JsonElement[], List<FileInfo>> extractResults, Exception exception) => Move(extractResults, exception);
@@ -158,8 +138,6 @@ public class FileRead : Shared.FileRead, IFileRead
             throw new Exception();
     }
 
-    void IFileRead.Callback(object state) => Callback(state);
-
     protected static List<Stratus.Description> GetDescriptions(JsonElement[] jsonElements)
     {
         List<Stratus.Description> results = new();
@@ -312,80 +290,7 @@ public class FileRead : Shared.FileRead, IFileRead
     }
 
     private void CallbackIsDummy(string traceDummyFile, List<Tuple<string, string, string, string, int>> tuples, bool fileConnectorConfigurationIncludeSubDirectories, bool includeSubDirectoriesExtra)
-    {
+    {}
-        int fileCount;
-        string[] files;
-        string monARessource;
-        string checkDirectory;
-        string sourceArchiveFile;
-        string inProcessDirectory;
-        const string site = "sjc";
-        string stateName = string.Concat("Dummy_", _EventName);
-        const string monInURL = "http://moninhttp.sjc.infineon.com/input/text";
-        MonIn monIn = MonIn.GetInstance(monInURL);
-        foreach (Tuple<string, string, string, string, int> item in tuples)
-        {
-            monARessource = item.Item1;
-            sourceArchiveFile = item.Item2;
-            inProcessDirectory = item.Item3;
-            checkDirectory = item.Item4;
-            fileCount = item.Item5;
-            try
-            {
-                if (fileCount > 0 || string.IsNullOrEmpty(checkDirectory))
-                {
-                    File.AppendAllLines(traceDummyFile, new string[] { site, monARessource, stateName, State.Warning.ToString() });
-                    _ = monIn.SendStatus(site, monARessource, stateName, State.Warning);
-                    for (int i = 1; i < 12; i++)
-                        Thread.Sleep(500);
-                }
-                else if (inProcessDirectory == checkDirectory)
-                    continue;
-                if (!_IsEAFHosted)
-                    continue;
-                if (!File.Exists(sourceArchiveFile))
-                    continue;
-                if (!long.TryParse(Path.GetFileNameWithoutExtension(sourceArchiveFile).Replace("x", string.Empty), out long sequence))
-                    continue;
-                ZipFile.ExtractToDirectory(sourceArchiveFile, inProcessDirectory);
-                if (fileConnectorConfigurationIncludeSubDirectories && includeSubDirectoriesExtra)
-                    checkDirectory = string.Concat(checkDirectory, @"\", sequence);
-                if (fileConnectorConfigurationIncludeSubDirectories)
-                    files = Directory.GetFiles(inProcessDirectory, "*", SearchOption.AllDirectories);
-                else
-                    files = Directory.GetFiles(inProcessDirectory, "*", SearchOption.TopDirectoryOnly);
-                if (files.Length > 250)
-                    throw new Exception("Safety net!");
-                foreach (string file in files)
-                    File.SetLastWriteTime(file, new DateTime(sequence));
-                if (!fileConnectorConfigurationIncludeSubDirectories)
-                {
-                    foreach (string file in files)
-                        File.Move(file, string.Concat(checkDirectory, @"\", Path.GetFileName(file)));
-                }
-                else
-                {
-                    string[] directories = Directory.GetDirectories(inProcessDirectory, "*", SearchOption.AllDirectories);
-                    foreach (string directory in directories)
-                        _ = Directory.CreateDirectory(string.Concat(checkDirectory, directory.Substring(inProcessDirectory.Length)));
-                    foreach (string file in files)
-                        File.Move(file, string.Concat(checkDirectory, file.Substring(inProcessDirectory.Length)));
-                }
-                File.AppendAllLines(traceDummyFile, new string[] { site, monARessource, stateName, State.Ok.ToString() });
-                _ = monIn.SendStatus(site, monARessource, stateName, State.Ok);
-            }
-            catch (Exception exception)
-            {
-                string subject = string.Concat("Exception:", _CellInstanceConnectionName);
-                string body = string.Concat(exception.Message, Environment.NewLine, Environment.NewLine, exception.StackTrace);
-                try
-                { _SMTP.SendHighPriorityEmailMessage(subject, body); }
-                catch (Exception) { }
-                File.AppendAllLines(traceDummyFile, new string[] { site, monARessource, stateName, State.Critical.ToString(), exception.Message, exception.StackTrace });
-                _ = monIn.SendStatus(site, monARessource, stateName, State.Critical);
-            }
-        }
-    }
 
     private void Callback(object state)
     {

Adaptation/FileHandlers/Stratus/FileRead.cs

@@ -98,8 +98,6 @@ public class FileRead : Shared.FileRead, IFileRead
 
     void IFileRead.CheckTests(Test[] tests, bool extra) => throw new Exception(string.Concat("Not ", nameof(_IsDuplicator)));
 
-    void IFileRead.Callback(object state) => throw new Exception(string.Concat("Not ", nameof(_IsDuplicator)));
-
     private Tuple<string, Test[], JsonElement[], List<FileInfo>> GetExtractResult(string reportFullPath, DateTime dateTime)
     {
         Tuple<string, Test[], JsonElement[], List<FileInfo>> results = new(string.Empty, null, null, new List<FileInfo>());

Adaptation/FileHandlers/ToArchive/FileRead.cs

@@ -109,31 +109,14 @@ public class FileRead : Shared.FileRead, IFileRead
             throw new Exception();
     }
 
-    void IFileRead.Callback(object state) => throw new Exception(string.Concat("Not ", nameof(_IsDuplicator)));
-
     private Tuple<string, Test[], JsonElement[], List<FileInfo>> GetExtractResult(string reportFullPath, DateTime dateTime)
     {
         if (dateTime == DateTime.MinValue)
         { }
         Tuple<string, Test[], JsonElement[], List<FileInfo>> results = new(string.Empty, null, null, new List<FileInfo>());        
-        _Logistics = new Logistics(this, reportFullPath, useSplitForMID: true);
+        Tuple<string, string[], string[]> pdsf = ProcessDataStandardFormat.GetLogisticsColumnsAndBody(reportFullPath);
+        _Logistics = new Logistics(reportFullPath, pdsf.Item1);        
         SetFileParameterLotIDToLogisticsMID();
-
-        string[] segments = Path.GetFileNameWithoutExtension(reportFullPath).Split('_');
-        string duplicateDirectory = string.Concat(_FileConnectorConfiguration.TargetFileLocation, @"\", segments[0]);
-        if (segments.Length > 2)
-            duplicateDirectory = string.Concat(duplicateDirectory, @"-", segments[2]);
-        if (!Directory.Exists(duplicateDirectory))
-            _ = Directory.CreateDirectory(duplicateDirectory);
-
-        string logisticsSequence = _Logistics.Sequence.ToString();
-        bool isDummyRun = _DummyRuns.Any() && _DummyRuns.ContainsKey(_Logistics.JobID) && _DummyRuns[_Logistics.JobID].Any() && (from l in _DummyRuns[_Logistics.JobID] where l == _Logistics.Sequence select 1).Any();
-
-        List<Tuple<Shared.Properties.IScopeInfo, string>> tuples = new();
-
-        string destinationDirectory = WriteScopeInfo(_ProgressPath, _Logistics, dateTime, duplicateDirectory, tuples);
-        if (isDummyRun)
-            Shared0607(reportFullPath, duplicateDirectory, logisticsSequence, destinationDirectory);
         return results;
     }
 

Adaptation/FileHandlers/txt/FileRead.cs

@@ -98,8 +98,6 @@ public class FileRead : Shared.FileRead, IFileRead
 
     void IFileRead.CheckTests(Test[] tests, bool extra) => throw new Exception(string.Concat("Not ", nameof(_IsDuplicator)));
 
-    void IFileRead.Callback(object state) => throw new Exception(string.Concat("Not ", nameof(_IsDuplicator)));
-
     private Tuple<string, Test[], JsonElement[], List<FileInfo>> GetExtractResult(string reportFullPath, DateTime dateTime)
     {
         Tuple<string, Test[], JsonElement[], List<FileInfo>> results = new(string.Empty, null, null, new List<FileInfo>());

Adaptation/Shared/Methods/IFileRead.cs

@@ -10,7 +10,6 @@ public interface IFileRead : Properties.IFileRead
 
     void WaitForThread();
     JsonProperty[] GetDefault();
-    void Callback(object state);
     string GetEventDescription();
     List<string> GetHeaderNames();
     void CheckTests(Test[] tests, bool extra);