transmission-control-protocol-helper

File-Watcher.csproj

@@ -20,7 +20,7 @@
     <PackageReference Include="Microsoft.Extensions.Logging.Console" Version="8.0.1" />
     <PackageReference Include="Microsoft.Extensions.Logging.EventLog" Version="8.0.1" />
     <PackageReference Include="Oracle.ManagedDataAccess.Core" Version="23.7.0" />
-    <PackageReference Include="runtime.win-x64.Microsoft.DotNet.ILCompiler" Version="8.0.16" />
+    <PackageReference Include="runtime.win-x64.Microsoft.DotNet.ILCompiler" Version="8.0.19" />
     <PackageReference Include="System.Data.SqlClient" Version="4.8.6" />
     <PackageReference Include="System.Drawing.Common" Version="8.0.16" />
     <PackageReference Include="System.IO.Ports" Version="8.0.0" />

Helpers/TransmissionControlProtocolHelper.cs

@@ -0,0 +1,129 @@
+using File_Watcher.Models;
+using System.Net.Sockets;
+using System.Text;
+
+namespace File_Watcher.Helpers;
+
+internal static partial class TransmissionControlProtocolHelper
+{
+
+    private record Record(BinaryReader BinaryReader,
+                          BinaryWriter BinaryWriter,
+                          NetworkStream NetworkStream,
+                          List<long> ReadTimes);
+
+    private static long _LastWrite;
+    private static Record? _Record;
+    private static readonly object _Lock = new();
+
+    private static void ReadFiles(TransmissionControlProtocolConfiguration tcpConfiguration, ILogger<Worker> logger)
+    {
+        List<byte> bytes = [];
+        // byte nullByte = Convert.ToByte('\0');
+        string directory = GetDirectory(tcpConfiguration);
+        string[] files = Directory.GetFiles(directory, $"{tcpConfiguration.IPAddress}-*.raw", SearchOption.TopDirectoryOnly);
+        logger.LogInformation("Read {count} files", files.Length);
+        foreach (string file in files)
+        {
+            foreach (byte @byte in File.ReadAllBytes(file))
+            {
+                // if (@byte.Equals(nullByte))
+                //     continue;
+                bytes.Add(@byte);
+            }
+        }
+        if (bytes.Count > 0)
+        {
+            string bytesFile = Path.Combine(directory, $"{tcpConfiguration.IPAddress}-{DateTime.Now.Ticks}.pcl");
+            File.WriteAllBytes(bytesFile, bytes.ToArray());
+            foreach (string file in files)
+                File.Delete(file);
+        }
+    }
+
+    private static void CreateClient(AppSettings appSettings, ILogger<Worker> logger)
+    {
+        logger.LogDebug(appSettings.TransmissionControlProtocolConfiguration.IPAddress);
+        TcpClient tcpClient = new(appSettings.TransmissionControlProtocolConfiguration.IPAddress, appSettings.TransmissionControlProtocolConfiguration.Port);
+        NetworkStream networkStream = tcpClient.GetStream();
+        _Record = new(BinaryReader: new(networkStream), BinaryWriter: new(networkStream), NetworkStream: networkStream, ReadTimes: []);
+    }
+
+    private static string GetDirectory(TransmissionControlProtocolConfiguration tcpConfiguration)
+    {
+        string result = Path.GetFullPath(Path.Combine(tcpConfiguration.Destination, tcpConfiguration.IPAddress));
+        if (!Directory.Exists(result))
+            _ = Directory.CreateDirectory(result);
+        return result;
+    }
+
+    private static void NetworkStreamCanRead(TransmissionControlProtocolConfiguration tcpConfiguration, ILogger<Worker> logger, NetworkStream networkStream)
+    {
+        List<byte> results = [];
+        byte[] bytes = new byte[1024];
+        string directory = GetDirectory(tcpConfiguration);
+        do
+        {
+            int count = networkStream.Read(bytes, 0, bytes.Length);
+            if (count > 0)
+                results.AddRange(bytes.Take(count));
+        }
+        while (networkStream.DataAvailable);
+        logger.LogInformation("Read {count} bytes", results.Count);
+        if (results.Count > 0)
+        {
+            bytes = results.ToArray();
+            File.WriteAllBytes(Path.Combine(directory, $"{tcpConfiguration.IPAddress}-{DateTime.Now.Ticks}.raw"), bytes);
+            if (!string.IsNullOrEmpty(tcpConfiguration.DelimiterPattern))
+            {
+                string content = Encoding.ASCII.GetString(bytes);
+                logger.LogDebug("Content {content}", content);
+                if (content.Contains(tcpConfiguration.DelimiterPattern))
+                    ReadFiles(tcpConfiguration, logger);
+            }
+        }
+    }
+
+    internal static bool ReadWrite(AppSettings appSettings, ILogger<Worker> logger)
+    {
+        lock (_Lock)
+        {
+            if (!appSettings.TransmissionControlProtocolConfiguration.Server && _Record is not null && appSettings.TransmissionControlProtocolConfiguration.DelimiterSeconds > 0)
+            {
+                TimeSpan? timeSpan = _Record.ReadTimes.Count == 0 ? null : new(DateTime.Now.Ticks - _Record.ReadTimes[^1]);
+                if (timeSpan is not null && timeSpan.Value.TotalSeconds > appSettings.TransmissionControlProtocolConfiguration.DelimiterSeconds)
+                {
+                    ReadFiles(appSettings.TransmissionControlProtocolConfiguration, logger);
+                    _Record.ReadTimes.Clear();
+                }
+            }
+            if (!appSettings.TransmissionControlProtocolConfiguration.Server && _Record is not null)
+            {
+                TimeSpan timeSpan = new(DateTime.Now.Ticks - _LastWrite);
+                if (_LastWrite == 0 || timeSpan.TotalMinutes > 1)
+                {
+                    try
+                    {
+                        _Record.NetworkStream.WriteByte(Convert.ToByte('\0'));
+                        _LastWrite = DateTime.Now.Ticks;
+                    }
+                    catch (Exception)
+                    { }
+                }
+            }
+            if (!appSettings.TransmissionControlProtocolConfiguration.Server && (_Record?.NetworkStream is null || !_Record.NetworkStream.Socket.Connected))
+                CreateClient(appSettings, logger);
+            else if (appSettings.TransmissionControlProtocolConfiguration.Server)
+                throw new NotImplementedException($"Use {nameof(HelperTCP)}");
+            if (_Record?.NetworkStream is not null && _Record.NetworkStream.CanRead && _Record.NetworkStream.DataAvailable)
+            {
+                _Record.ReadTimes.Add(DateTime.Now.Ticks);
+                NetworkStreamCanRead(appSettings.TransmissionControlProtocolConfiguration, logger, _Record.NetworkStream);
+            }
+            if (appSettings.TransmissionControlProtocolConfiguration.Server && _Record?.NetworkStream is not null && _Record.NetworkStream.CanWrite)
+                throw new NotImplementedException($"Use {nameof(HelperTCP)}");
+        }
+        return true;
+    }
+
+}

Models/TransmissionControlProtocolConfiguration.cs

@@ -3,7 +3,9 @@ using System.Text.Json.Serialization;
 
 namespace File_Watcher.Models;
 
-public record TransmissionControlProtocolConfiguration(string Destination,
+public record TransmissionControlProtocolConfiguration(string DelimiterPattern,
+                                                       int DelimiterSeconds,
+                                                       string Destination,
                                                        string GhostPCLFileName,
                                                        string IPAddress,
                                                        int Port,

Worker.cs

@@ -91,6 +91,7 @@ public partial class Worker : BackgroundService
                 nameof(Helpers.HelperMetrologyFiles) => Helpers.HelperMetrologyFiles.SortAndDelete(_AppSettings, _Logger),
                 nameof(Helpers.NationalInstrumentsHelper) => Helpers.NationalInstrumentsHelper.WriteData(_AppSettings, _Logger),
                 nameof(Helpers.DeterministicHashCodeHelper) => Helpers.DeterministicHashCodeHelper.WindowsWork(_AppSettings, _Logger),
+                nameof(Helpers.TransmissionControlProtocolHelper) => Helpers.TransmissionControlProtocolHelper.ReadWrite(_AppSettings, _Logger),
 #if Selenium
                 nameof(Helpers.SeleniumHelper) => Helpers.SeleniumHelper.HyperTextMarkupLanguageToPortableNetworkGraphics(_AppSettings, _Logger),
 #endif