Read device state from data stream and report on state endpoint

ChemDoserProxy/Dto/DataFrame.cs

@@ -8,7 +8,7 @@ public class DataFrame
 
     public DateTime ReceiveDate { get; init; }
 
-    public bool Flow { get; init; }
+    public DeviceState State { get; init; }
 
     public int pHValue { get; init; }
 
@@ -27,7 +27,7 @@ public class DataFrame
     public override string ToString()
     {
         return string.Join(Environment.NewLine, $"Serial={Serial}", $"Timestamp={Timestamp}", $"Received={ReceiveDate}",
-            $"Flow={Flow}", $"pH={pHValue}",
+            $"State={State}", $"pH={pHValue}",
             $"clF={clFreeValue}", $"clF(mv)={clFreeMilliVolts}", $"WaterTemp={WaterTemperature}",
             $"ActivePump={ActivePump}", $"Delay={DelaySeconds}s");
     }
@@ -43,3 +43,16 @@ public class FlowRates
 
     public int FlocPlusC { get; init; }
 }
+
+public enum DeviceState
+{
+    NoError = 0,
+    HourDoseExceeded = 1,
+    TimeCorrectionError = 2,
+    NoFlow = 4,
+    EmptyBufferTank = 8,
+    BufferTankOverflow = 16,
+    LowFillingSpeed = 32,
+    NoChangeInpHValue = 64,
+    NoChangeInClValue = 128
+}

ChemDoserProxy/Dto/DoserState.cs

@@ -1,3 +1,3 @@
 namespace ChemDoserProxy.Dto;
 
-public record DoserState(decimal clFree, decimal clFreeMv, decimal pH, decimal WaterTemp);
+public record DoserState(DeviceState State, decimal clFree, decimal clFreeMv, decimal pH, decimal WaterTemp);

ChemDoserProxy/Logic/DataFrameProcessor.cs

@@ -1,7 +1,6 @@
 using System.Threading.Channels;
 using ChemDoserProxy.Dto;
 using ChemDoserProxy.State;
-using ChemDoserProxy.Tcp;
 
 namespace ChemDoserProxy.Logic;
 
@@ -57,7 +56,7 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
                 _pumpLastActive = null;
             }
 
-            _stateManager.Set(frame.clFreeValue / 100m, frame.clFreeMilliVolts, frame.pHValue / 100m,
+            _stateManager.Set(frame.State, frame.clFreeValue / 100m, frame.clFreeMilliVolts, frame.pHValue / 100m,
                 frame.WaterTemperature / 10m);
         }
     }

ChemDoserProxy/Logic/DataFrameQueue.cs

@@ -1,6 +1,5 @@
 using System.Threading.Channels;
 using ChemDoserProxy.Dto;
-using ChemDoserProxy.Tcp;
 
 namespace ChemDoserProxy.Logic;
 

ChemDoserProxy/State/StateManager.cs

@@ -11,11 +11,11 @@ public StateManager(ILogger<StateManager> logger)
         _logger = logger;
     }
 
-    public DoserState State { get; private set; } = new(0, 0, 0, 0);
+    public DoserState State { get; private set; } = new(DeviceState.NoError, 0, 0, 0, 0);
 
-    public void Set(decimal clFree, decimal clFreeMv, decimal pH, decimal waterTemp)
+    public void Set(DeviceState state, decimal clFree, decimal clFreeMv, decimal pH, decimal waterTemp)
     {
-        State = new DoserState(clFree, clFreeMv, pH, waterTemp);
+        State = new DoserState(state, clFree, clFreeMv, pH, waterTemp);
         _logger.LogDebug("State updated to {}", State);
     }
 }

ChemDoserProxy/Tcp/ClientConnection.cs

@@ -2,7 +2,6 @@
 using System.Threading.Channels;
 using ChemDoserProxy.Dto;
 using ChemDoserProxy.Logic;
-using Microsoft.Extensions.Logging;
 
 namespace ChemDoserProxy.Tcp;
 
@@ -43,7 +42,7 @@ public async Task Receive(CancellationToken ct)
                     ReceiveDate = DateTime.UtcNow,
                     Timestamp = new DateTime(2000 + buffer[6], buffer[7], buffer[8],
                         buffer[9], buffer[10], buffer[11]),
-                    Flow = buffer[13] == 0,
+                    State = (DeviceState)buffer[13],
                     pHValue = BitConverter.ToInt16(buffer.AsSpan().GetBytes(14, 2)),
                     clFreeValue = BitConverter.ToInt16(buffer.AsSpan().GetBytes(16, 2)),
                     clFreeMilliVolts = BitConverter.ToInt16(buffer.AsSpan().GetBytes(20, 2)),

ChemDoserProxy/Tcp/Forwarder.cs

@@ -1,7 +1,5 @@
-using System.Net;
-using System.Net.Sockets;
+using System.Net.Sockets;
 using ChemDoserProxy.Configuration;
-using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
 
 namespace ChemDoserProxy.Tcp;

ChemDoserProxy/Tcp/Listener.cs

@@ -2,8 +2,6 @@
 using System.Net.Sockets;
 using ChemDoserProxy.Configuration;
 using ChemDoserProxy.Logic;
-using Microsoft.Extensions.Hosting;
-using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
 
 namespace ChemDoserProxy.Tcp;