Additional wait for the correct ControlBoard response in [s]

2024-11-11 13:16:30 +01:00
1349 changed files with 7721 additions and 1278265 deletions
@@ -1,5 +1,3 @@
 AppDiagnostic/bin/
 AppDiagnostic/obj/
 Common/bin/
 Common/obj/
 Config/bin/
@@ -32,8 +30,6 @@ LabelPrinting/bin/
 LabelPrinting/obj/
 MergeResultsDBs/bin/
 MergeResultsDBs/obj/
 NfcC7_Dll/bin/
 NfcC7_Dll/obj/
 OrderManagement/bin/
 OrderManagement/obj/
 ProductionTracing/bin/
@@ -52,18 +48,14 @@ ResultsParser/bin/
 ResultsParser/obj/
 S640TestApp/bin/
 S640TestApp/obj/
-SharedComponents/bin/
+SharedDatabase/bin
-SharedComponents/obj/
+SharedDatabase/obj
-SharedDatabase/bin/
+SchematicDrawing/bin
-SharedDatabase/obj/
+SchematicDrawing/obj
 SchematicDrawing/bin/
 SchematicDrawing/obj/
 Statistics/bin/
 Statistics/obj/
 TBF/bin/
 TBF/obj/
 TBFTests/bin/
 TBFTests/obj/
 ToFirstMonitor/bin/
 ToFirstMonitor/obj/
 ToSecondMonitor/bin/
@@ -74,18 +66,6 @@ WorkflowConfigurator/bin/
 WorkflowConfigurator/obj/
 Workplace/bin/
 Workplace/obj/
 DataStreamInterfaceTest/bin/
 DataStreamInterfaceTest/obj/
 DataStreamMeter/bin/
 DataStreamMeter/obj/
 Events/bin/
 Events/obj/
 TracingDB/bin/
 TracingDB/obj/
 Users/bin/
 Users/obj/
 .vs/
 .idea/
 *.suo
 *.bak
 TBF.sln.DotSettings.user
@@ -1,19 +0,0 @@
 <?xml version="1.0" encoding="utf-8" ?>
 <configuration>
    <startup> 
        <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.7.2" />
    </startup>
 	<log4net>
 		<appender name="LogCacheAppender" type="Namespace.LogCacheAppender, AssemblyName">
 			<param name="Cache" value="YourCacheInstance" />
 			<layout type="log4net.Layout.PatternLayout">
 				<param name="ConversionPattern" value="%d [%t] %-5p %c - %m%n" />
 			</layout>
 		</appender>
 		<root>
 			<level value="DEBUG" />
 			<appender-ref ref="LogCacheAppender" />
 		</root>
 	</log4net>
 </configuration>
@@ -1,101 +0,0 @@
 <?xml version="1.0" encoding="utf-8"?>
 <Project ToolsVersion="15.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
  <Import Project="$(MSBuildExtensionsPath)\$(MSBuildToolsVersion)\Microsoft.Common.props" Condition="Exists('$(MSBuildExtensionsPath)\$(MSBuildToolsVersion)\Microsoft.Common.props')" />
  <PropertyGroup>
    <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
    <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
    <ProjectGuid>{FA9ABAD1-7184-4295-ADE8-D44F2E3DE6B2}</ProjectGuid>
    <OutputType>WinExe</OutputType>
    <RootNamespace>AppDiagnostic</RootNamespace>
    <AssemblyName>AppDiagnostic</AssemblyName>
    <TargetFrameworkVersion>v4.7.2</TargetFrameworkVersion>
    <FileAlignment>512</FileAlignment>
    <AutoGenerateBindingRedirects>true</AutoGenerateBindingRedirects>
    <Deterministic>true</Deterministic>
  </PropertyGroup>
  <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
    <PlatformTarget>AnyCPU</PlatformTarget>
    <DebugSymbols>true</DebugSymbols>
    <DebugType>full</DebugType>
    <Optimize>false</Optimize>
    <OutputPath>bin\Debug\</OutputPath>
    <DefineConstants>DEBUG;TRACE</DefineConstants>
    <ErrorReport>prompt</ErrorReport>
    <WarningLevel>4</WarningLevel>
  </PropertyGroup>
  <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
    <PlatformTarget>AnyCPU</PlatformTarget>
    <DebugType>pdbonly</DebugType>
    <Optimize>true</Optimize>
    <OutputPath>bin\Release\</OutputPath>
    <DefineConstants>TRACE</DefineConstants>
    <ErrorReport>prompt</ErrorReport>
    <WarningLevel>4</WarningLevel>
  </PropertyGroup>
  <ItemGroup>
    <Reference Include="log4net, Version=3.0.3.0, Culture=neutral, PublicKeyToken=669e0ddf0bb1aa2a, processorArchitecture=MSIL">
      <HintPath>..\packages\log4net.3.0.3\lib\net462\log4net.dll</HintPath>
    </Reference>
    <Reference Include="System" />
    <Reference Include="System.Configuration" />
    <Reference Include="System.Core" />
    <Reference Include="System.Web" />
    <Reference Include="System.Xml.Linq" />
    <Reference Include="System.Data.DataSetExtensions" />
    <Reference Include="Microsoft.CSharp" />
    <Reference Include="System.Data" />
    <Reference Include="System.Deployment" />
    <Reference Include="System.Drawing" />
    <Reference Include="System.Net.Http" />
    <Reference Include="System.Windows.Forms" />
    <Reference Include="System.Xml" />
  </ItemGroup>
  <ItemGroup>
    <Compile Include="BufferedListView.cs">
      <SubType>Component</SubType>
    </Compile>
    <Compile Include="DiagApi.cs" />
    <Compile Include="LogAdapter.cs" />
    <Compile Include="LogFilter.cs" />
    <Compile Include="MainForm.cs">
      <SubType>Form</SubType>
    </Compile>
    <Compile Include="MainForm.Designer.cs">
      <DependentUpon>MainForm.cs</DependentUpon>
    </Compile>
    <Compile Include="Program.cs" />
    <Compile Include="Properties\AssemblyInfo.cs" />
    <EmbeddedResource Include="MainForm.resx">
      <DependentUpon>MainForm.cs</DependentUpon>
    </EmbeddedResource>
    <EmbeddedResource Include="Properties\Resources.resx">
      <Generator>ResXFileCodeGenerator</Generator>
      <LastGenOutput>Resources.Designer.cs</LastGenOutput>
      <SubType>Designer</SubType>
    </EmbeddedResource>
    <Compile Include="Properties\Resources.Designer.cs">
      <AutoGen>True</AutoGen>
      <DependentUpon>Resources.resx</DependentUpon>
    </Compile>
    <None Include="packages.config" />
    <None Include="Properties\Settings.settings">
      <Generator>SettingsSingleFileGenerator</Generator>
      <LastGenOutput>Settings.Designer.cs</LastGenOutput>
    </None>
    <Compile Include="Properties\Settings.Designer.cs">
      <AutoGen>True</AutoGen>
      <DependentUpon>Settings.settings</DependentUpon>
      <DesignTimeSharedInput>True</DesignTimeSharedInput>
    </Compile>
  </ItemGroup>
  <ItemGroup>
    <None Include="App.config" />
  </ItemGroup>
  <ItemGroup>
    <ProjectReference Include="..\SharedComponents\SharedComponents.csproj">
      <Project>{8f942729-f454-4c99-ba6c-746962065ae3}</Project>
      <Name>SharedComponents</Name>
    </ProjectReference>
  </ItemGroup>
  <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
 </Project>
@@ -1,16 +0,0 @@
 using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
 using System.Windows.Forms;
 public class BufferedListView : ListView
 {
    public BufferedListView()
    {
        // Zapne dvojité bufferovanie pre ListView
        this.SetStyle(ControlStyles.OptimizedDoubleBuffer | ControlStyles.AllPaintingInWmPaint, true);
        this.UpdateStyles();
    }
 }           
@@ -1,32 +0,0 @@
 using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
 using System.Windows.Forms;
 namespace AppDiagnostic
 {
    public class DiagApi
    {
        private static MainForm diagWindow; // Udržiava referenciu na existujúce okno
        public DiagApi()
        {
            if (diagWindow == null || diagWindow.IsDisposed) // Ak okno neexistuje, vytvoríme ho
            {
                diagWindow = new MainForm();
                diagWindow.FormClosing += (s, e) =>
                {
                    diagWindow = null; // Keď sa zavrie, vyčistíme referenciu
                };
                diagWindow.Show();
            }
            else
            {
                diagWindow.BringToFront(); // Ak už beží, len ho presunieme na vrch
                diagWindow.WindowState = FormWindowState.Normal; // Ak je minimalizované, obnovíme ho
            }
        }
    }
 }
@@ -1,174 +0,0 @@
 using SharedComponents;
 using System;
 using System.Collections.Generic;
 using System.Drawing;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
 using System.Windows.Forms;
 namespace AppDiagnostic
 {
    public class LogAdapter
    {
        private ListView _listView;
        public string _filterText = string.Empty;
        private bool _isUserScrolling = false; // Indikátor, že používateľ manuálne scrolluje
        private bool _autoScrollEnabled = true; // Indikátor, že automatické scrollovanie je povolené
        private Timer _refreshTimer;
        private const int RefreshInterval = 1000;
        public LogAdapter(ListView listView)
        {
            _listView = listView;
            // Nastavenie ListView
            _listView.View = View.Details;
            _listView.Columns.Clear();
            _listView.Columns.Add("Logs");
            _listView.Scrollable = true;
            // Nastavenie šírky stĺpca na celú šírku ListView
            AdjustColumnWidth();
            // Udalosť pre dynamickú zmenu veľkosti stĺpca pri zmene veľkosti ListView
            _listView.Resize += (sender, args) => AdjustColumnWidth();
            // Pridanie udalosti pre manuálne skrolovanie
            _listView.MouseWheel += ListView_MouseWheel;
            // Inicializácia časovača na pravidelný refresh
            _refreshTimer = new Timer { Interval = RefreshInterval };
            _refreshTimer.Tick += (sender, args) => RefreshListView();
            _refreshTimer.Start();
        }
        private void ListView_MouseWheel(object sender, MouseEventArgs e)
        {
            _isUserScrolling = true;
            // Ak sa manuálnym scrollovaním používateľ dostane na koniec, obnovíme automatické scrollovanie
            if (IsOnLastItem())
            {
                _isUserScrolling = false;
                _autoScrollEnabled = true;
            }
            else
            {
                _autoScrollEnabled = false;
            }
        }
        public void RefreshListView()
        {
            //LiveLogCache.Instance.AddLog(string.Format("-------------------------------RunDeviceAfter()-------------------------------"));
            if (_listView.InvokeRequired)
            {
                _listView.Invoke(new Action(RefreshListView));
                return;
            }
            _listView.BeginUpdate();
            try
            {
                // Získanie pozície prvého viditeľného prvku pre stabilizáciu scrollovania
                int topIndexBeforeRefresh = _listView.TopItem?.Index ?? 0;
                // Pred pridaním nových položiek si pamätáme, či bol používateľ na poslednej položke
                bool wasOnLastItem = IsOnLastItem();
                // Uchovanie aktuálne označených položiek (indexov)
                var selectedIndices = _listView.SelectedIndices.Cast<int>().ToList();
                // Načítanie logov
                var logs = LiveLogCache.Instance.GetLogs(0, LiveLogCache.Instance.GetCount())
                    .Where(log => string.IsNullOrEmpty(_filterText) ||
                                  log.IndexOf(_filterText, StringComparison.OrdinalIgnoreCase) >= 0)
                    .ToList();
                // Vymazanie existujúcich položiek a pridanie nových
                _listView.Items.Clear();
                foreach (var log in logs)
                {
                    var item = new ListViewItem(log)
                    {
                        BackColor = _listView.Items.Count % 2 == 0 ? Color.White : Color.FromArgb(240, 240, 240)
                    };
                    _listView.Items.Add(item);
                }
                // Obnovenie označených položiek
                foreach (var index in selectedIndices)
                {
                    if (index < _listView.Items.Count)
                    {
                        _listView.Items[index].Selected = true;
                    }
                }
                // Ak bol používateľ na poslednom prvku, nastavíme focus a scroll na posledný prvok
                if (_autoScrollEnabled && wasOnLastItem && _listView.Items.Count > 0)
                {
                    var lastItemIndex = _listView.Items.Count - 1;
                    _listView.EnsureVisible(lastItemIndex);
                    _listView.Items[lastItemIndex].Focused = true;
                }
                else
                {
                    // Ak používateľ nebol na spodku, vrátime sa na predchádzajúcu pozíciu scrollu
                    if (topIndexBeforeRefresh < _listView.Items.Count)
                    {
                        _listView.TopItem = _listView.Items[topIndexBeforeRefresh];
                    }
                }
            }
            finally
            {
                _listView.EndUpdate();
            }
        }
        public void ApplyFilter(string filterText)
        {
            _filterText = filterText?.Trim() ?? string.Empty;
            RefreshListView();
        }
        private bool IsOnLastItem()
        {
            if (_listView.Items.Count == 0)
                return false;
            // Získame poslednú položku
            int lastItemIndex = _listView.Items.Count - 1;
            var lastItem = _listView.Items[lastItemIndex];
            // Overíme, či je posledná položka úplne viditeľná
            return lastItem.Bounds.Bottom <= _listView.ClientRectangle.Bottom;
        }
        public void EnableAutoScroll()
        {
            _autoScrollEnabled = true;
        }
        public void DisableAutoScroll()
        {
            _autoScrollEnabled = false;
        }
        private void AdjustColumnWidth()
        {
            if (_listView.Columns.Count > 0)
            {
                _listView.Columns[0].Width = _listView.ClientSize.Width;
            }
        }
    }
 }
@@ -1,91 +0,0 @@
 using SharedComponents;
 using System;
 using System.Collections.Generic;
 using System.Drawing;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
 using System.Windows.Forms;
 namespace AppDiagnostic
 {
    public class LogFilter
    {
        private ListView _listView;
        private string _filterText = string.Empty;  // Pre uloženie aktuálneho filtrovaného reťazca
        // Konstruktor
        public LogFilter(ListView listView)
        {
            _listView = listView;
        }
        // Metóda na aplikovanie filtra na ListView
        public void ApplyFilter(string filterText)
        {
            _filterText = filterText.ToLower();  // Ukladáme text filtra bez ohľadu na veľkosť písmen
            // Po aplikovaní filtra obnovíme zobrazenie
            RefreshListView();
        }
        public void RefreshListView()
        {
            try
            {
                // Skontrolujeme, či sme na hlavnom vlákne a v prípade potreby použijeme Invoke
                if (_listView.InvokeRequired)
                {
                    // Použijeme Invoke, ak nie sme na hlavnom vlákne
                    _listView.Invoke(new Action(RefreshListView));
                }
                else
                {
                    // Vymazanie existujúcich položiek
                    _listView.Items.Clear();
                    // Načítame všetky logy (ideálne z cache alebo databázy)
                    var logs = LiveLogCache.Instance.GetLogs(0, LiveLogCache.Instance.Logs.Count);
                    // Pridáme len tie logy, ktoré spĺňajú filter
                    foreach (var log in logs)
                    {
                        if (log.ToLower().Contains(_filterText))  // Kontrola, či log obsahuje filter text
                        {
                            var listViewItem = new ListViewItem(log);
                            // Striedanie farieb riadkov
                            if (_listView.Items.Count % 2 == 0) // Párny index => biela
                            {
                                listViewItem.BackColor = Color.White;
                            }
                            else // Nepárny index => svetlá sivá
                            {
                                listViewItem.BackColor = Color.FromArgb(240, 240, 240);  // Veľmi svetlá sivá
                            }
                            // Pridanie efektu pre novú položku
                            ApplyNewItemEffect(listViewItem);
                            // Pridanie položky do ListView
                            _listView.Items.Add(listViewItem);
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                // Zachytíme výnimku, ak sa niečo pokazí, a zobrazíme ju užívateľovi
                MessageBox.Show($"An error occurred while refreshing the log view: {ex.Message}", "Error", MessageBoxButtons.OK, MessageBoxIcon.Error);
            }
        }
        // Môžete pridať ďalšie metódy na zobrazenie alebo efekt pre nové položky, ak je to potrebné
        private void ApplyNewItemEffect(ListViewItem item)
        {
            // Prípadný efekt pre nový pridaný log
            // Môžete pridať animáciu alebo zmenu farby atď.
            item.ForeColor = Color.Green;  // Napríklad zmeníme farbu písma na zelenú
        }
    }
 }
@@ -1,278 +0,0 @@
 using System.Windows.Forms;
 namespace AppDiagnostic
 {
    partial class MainForm
    {
        /// <summary>
        /// Required designer variable.
        /// </summary>
        private System.ComponentModel.IContainer components = null;
        /// <summary>
        /// Clean up any resources being used.
        /// </summary>
        /// <param name="disposing">true if managed resources should be disposed; otherwise, false.</param>
        protected override void Dispose(bool disposing)
        {
            if (disposing && (components != null))
            {
                components.Dispose();
            }
            base.Dispose(disposing);
        }
        #region Windows Form Designer generated code
        //private BufferedListView memoListView;
        private System.Windows.Forms.ColumnHeader columnHeaderTime;
        private System.Windows.Forms.ColumnHeader columnHeaderMessage;
        /// <summary>
        /// Required method for Designer support - do not modify
        /// the contents of this method with the code editor.
        /// </summary>
        private void InitializeComponent()
        {
            this.columnHeaderTime = ((System.Windows.Forms.ColumnHeader)(new System.Windows.Forms.ColumnHeader()));
            this.columnHeaderMessage = ((System.Windows.Forms.ColumnHeader)(new System.Windows.Forms.ColumnHeader()));
            this.panel1 = new System.Windows.Forms.Panel();
            this.refreshMemoButton = new System.Windows.Forms.Button();
            this.button6 = new System.Windows.Forms.Button();
            this.button7 = new System.Windows.Forms.Button();
            this.filterManagementPanel = new System.Windows.Forms.Panel();
            this.button5 = new System.Windows.Forms.Button();
            this.filterButton = new System.Windows.Forms.Button();
            this.filterTextBox = new System.Windows.Forms.TextBox();
            this.label2 = new System.Windows.Forms.Label();
            this.wndControlPanel = new System.Windows.Forms.Panel();
            this.button2 = new System.Windows.Forms.Button();
            this.flowControlsPanel = new System.Windows.Forms.Panel();
            this.runButton = new System.Windows.Forms.Button();
            this.stopButton = new System.Windows.Forms.Button();
            this.label1 = new System.Windows.Forms.Label();
            this.memoListView = new BufferedListView();
            this.panel1.SuspendLayout();
            this.filterManagementPanel.SuspendLayout();
            this.wndControlPanel.SuspendLayout();
            this.flowControlsPanel.SuspendLayout();
            this.SuspendLayout();
            // 
            // columnHeaderTime
            // 
            this.columnHeaderTime.Text = "Time";
            this.columnHeaderTime.Width = 150;
            // 
            // columnHeaderMessage
            // 
            this.columnHeaderMessage.Text = "Message";
            this.columnHeaderMessage.Width = 350;
            // 
            // panel1
            // 
            this.panel1.Anchor = ((System.Windows.Forms.AnchorStyles)((System.Windows.Forms.AnchorStyles.Bottom | System.Windows.Forms.AnchorStyles.Left)));
            this.panel1.Controls.Add(this.refreshMemoButton);
            this.panel1.Controls.Add(this.button6);
            this.panel1.Controls.Add(this.button7);
            this.panel1.Location = new System.Drawing.Point(189, 356);
            this.panel1.Name = "panel1";
            this.panel1.Size = new System.Drawing.Size(283, 26);
            this.panel1.TabIndex = 16;
            // 
            // refreshMemoButton
            // 
            this.refreshMemoButton.Location = new System.Drawing.Point(108, 0);
            this.refreshMemoButton.Name = "refreshMemoButton";
            this.refreshMemoButton.Size = new System.Drawing.Size(84, 26);
            this.refreshMemoButton.TabIndex = 17;
            this.refreshMemoButton.Text = "Refresh memo";
            this.refreshMemoButton.UseVisualStyleBackColor = true;
            this.refreshMemoButton.Click += new System.EventHandler(this.refreshMemoButton_Click);
            // 
            // button6
            // 
            this.button6.Location = new System.Drawing.Point(0, 0);
            this.button6.Name = "button6";
            this.button6.Size = new System.Drawing.Size(102, 26);
            this.button6.TabIndex = 4;
            this.button6.Text = "Clean diag cache";
            this.button6.UseVisualStyleBackColor = true;
            this.button6.Click += new System.EventHandler(this.button6_Click);
            // 
            // button7
            // 
            this.button7.Anchor = ((System.Windows.Forms.AnchorStyles)((System.Windows.Forms.AnchorStyles.Top | System.Windows.Forms.AnchorStyles.Right)));
            this.button7.Location = new System.Drawing.Point(198, 0);
            this.button7.Name = "button7";
            this.button7.Size = new System.Drawing.Size(72, 26);
            this.button7.TabIndex = 5;
            this.button7.Text = "Save logs";
            this.button7.UseVisualStyleBackColor = true;
            this.button7.Click += new System.EventHandler(this.button7_Click);
            // 
            // filterManagementPanel
            // 
            this.filterManagementPanel.Controls.Add(this.button5);
            this.filterManagementPanel.Controls.Add(this.filterButton);
            this.filterManagementPanel.Controls.Add(this.filterTextBox);
            this.filterManagementPanel.Controls.Add(this.label2);
            this.filterManagementPanel.Location = new System.Drawing.Point(127, 6);
            this.filterManagementPanel.Name = "filterManagementPanel";
            this.filterManagementPanel.Size = new System.Drawing.Size(393, 26);
            this.filterManagementPanel.TabIndex = 15;
            // 
            // button5
            // 
            this.button5.Enabled = false;
            this.button5.Location = new System.Drawing.Point(294, 4);
            this.button5.Name = "button5";
            this.button5.Size = new System.Drawing.Size(81, 20);
            this.button5.TabIndex = 11;
            this.button5.Text = "Add new filter";
            this.button5.UseVisualStyleBackColor = true;
            // 
            // filterButton
            // 
            this.filterButton.Location = new System.Drawing.Point(225, 4);
            this.filterButton.Name = "filterButton";
            this.filterButton.Size = new System.Drawing.Size(64, 20);
            this.filterButton.TabIndex = 10;
            this.filterButton.Text = "Set filter";
            this.filterButton.UseVisualStyleBackColor = true;
            this.filterButton.Click += new System.EventHandler(this.filterButton_Click_1);
            // 
            // filterTextBox
            // 
            this.filterTextBox.Location = new System.Drawing.Point(33, 4);
            this.filterTextBox.Name = "filterTextBox";
            this.filterTextBox.Size = new System.Drawing.Size(187, 20);
            this.filterTextBox.TabIndex = 7;
            // 
            // label2
            // 
            this.label2.AutoSize = true;
            this.label2.Location = new System.Drawing.Point(3, 8);
            this.label2.Name = "label2";
            this.label2.Size = new System.Drawing.Size(29, 13);
            this.label2.TabIndex = 6;
            this.label2.Text = "Filter";
            // 
            // wndControlPanel
            // 
            this.wndControlPanel.Anchor = ((System.Windows.Forms.AnchorStyles)((System.Windows.Forms.AnchorStyles.Bottom | System.Windows.Forms.AnchorStyles.Right)));
            this.wndControlPanel.Controls.Add(this.button2);
            this.wndControlPanel.Location = new System.Drawing.Point(831, 356);
            this.wndControlPanel.Name = "wndControlPanel";
            this.wndControlPanel.Size = new System.Drawing.Size(70, 26);
            this.wndControlPanel.TabIndex = 14;
            // 
            // button2
            // 
            this.button2.Location = new System.Drawing.Point(3, 0);
            this.button2.Name = "button2";
            this.button2.Size = new System.Drawing.Size(64, 26);
            this.button2.TabIndex = 2;
            this.button2.Text = "Close";
            this.button2.UseVisualStyleBackColor = true;
            this.button2.Click += new System.EventHandler(this.button2_Click);
            // 
            // flowControlsPanel
            // 
            this.flowControlsPanel.Anchor = ((System.Windows.Forms.AnchorStyles)((System.Windows.Forms.AnchorStyles.Bottom | System.Windows.Forms.AnchorStyles.Left)));
            this.flowControlsPanel.Controls.Add(this.runButton);
            this.flowControlsPanel.Controls.Add(this.stopButton);
            this.flowControlsPanel.Location = new System.Drawing.Point(12, 356);
            this.flowControlsPanel.Name = "flowControlsPanel";
            this.flowControlsPanel.Size = new System.Drawing.Size(133, 26);
            this.flowControlsPanel.TabIndex = 13;
            // 
            // runButton
            // 
            this.runButton.Enabled = false;
            this.runButton.Location = new System.Drawing.Point(0, 0);
            this.runButton.Name = "runButton";
            this.runButton.Size = new System.Drawing.Size(64, 26);
            this.runButton.TabIndex = 4;
            this.runButton.Text = "Run";
            this.runButton.UseVisualStyleBackColor = true;
            this.runButton.Click += new System.EventHandler(this.runButton_Click);
            // 
            // stopButton
            // 
            this.stopButton.Location = new System.Drawing.Point(69, 0);
            this.stopButton.Name = "stopButton";
            this.stopButton.Size = new System.Drawing.Size(64, 26);
            this.stopButton.TabIndex = 5;
            this.stopButton.Text = "Stop";
            this.stopButton.UseVisualStyleBackColor = true;
            this.stopButton.Click += new System.EventHandler(this.stopButton_Click);
            // 
            // label1
            // 
            this.label1.AutoSize = true;
            this.label1.Location = new System.Drawing.Point(12, 19);
            this.label1.Name = "label1";
            this.label1.Size = new System.Drawing.Size(76, 13);
            this.label1.TabIndex = 12;
            this.label1.Text = "Flow of events";
            // 
            // memoListView
            // 
            this.memoListView.Anchor = ((System.Windows.Forms.AnchorStyles)((((System.Windows.Forms.AnchorStyles.Top | System.Windows.Forms.AnchorStyles.Bottom) 
            | System.Windows.Forms.AnchorStyles.Left) 
            | System.Windows.Forms.AnchorStyles.Right)));
            this.memoListView.FullRowSelect = true;
            this.memoListView.GridLines = true;
            this.memoListView.HideSelection = false;
            this.memoListView.Location = new System.Drawing.Point(12, 38);
            this.memoListView.Name = "memoListView";
            this.memoListView.Size = new System.Drawing.Size(889, 312);
            this.memoListView.TabIndex = 0;
            this.memoListView.UseCompatibleStateImageBehavior = false;
            this.memoListView.View = System.Windows.Forms.View.Details;
            this.memoListView.DoubleClick += new System.EventHandler(this.MemoListView_DoubleClick);
            // 
            // MainForm
            // 
            this.AutoScaleDimensions = new System.Drawing.SizeF(6F, 13F);
            this.AutoScaleMode = System.Windows.Forms.AutoScaleMode.Font;
            this.ClientSize = new System.Drawing.Size(913, 388);
            this.Controls.Add(this.memoListView);
            this.Controls.Add(this.panel1);
            this.Controls.Add(this.filterManagementPanel);
            this.Controls.Add(this.wndControlPanel);
            this.Controls.Add(this.flowControlsPanel);
            this.Controls.Add(this.label1);
            this.Name = "MainForm";
            this.Text = "Application live diagnostic";
            this.panel1.ResumeLayout(false);
            this.filterManagementPanel.ResumeLayout(false);
            this.filterManagementPanel.PerformLayout();
            this.wndControlPanel.ResumeLayout(false);
            this.flowControlsPanel.ResumeLayout(false);
            this.ResumeLayout(false);
            this.PerformLayout();
        }
        #endregion
        private System.Windows.Forms.Panel panel1;
        private System.Windows.Forms.Button button6;
        private System.Windows.Forms.Button button7;
        private System.Windows.Forms.Panel filterManagementPanel;
        private System.Windows.Forms.Button button5;
        private System.Windows.Forms.Button filterButton;
        private System.Windows.Forms.TextBox filterTextBox;
        private System.Windows.Forms.Label label2;
        private System.Windows.Forms.Panel wndControlPanel;
        private System.Windows.Forms.Button button2;
        private System.Windows.Forms.Panel flowControlsPanel;
        private System.Windows.Forms.Button runButton;
        private System.Windows.Forms.Button stopButton;
        private System.Windows.Forms.Label label1;
        private System.Windows.Forms.Button refreshMemoButton;
        private BufferedListView memoListView;
    }
 }
@@ -1,266 +0,0 @@
 using log4net.Config;
 using log4net;
 using System;
 using System.Collections.Generic;
 using System.ComponentModel;
 using System.Data;
 using System.Drawing;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
 using System.Windows.Forms;
 using log4net.Appender;
 using SharedComponents;
 using static System.Windows.Forms.VisualStyles.VisualStyleElement;
 using System.IO; // Pre File.WriteAllLines a prácu so súbormi
 using System.Linq;
 namespace AppDiagnostic
 {
    public partial class MainForm : Form
    {
        private bool stopUpdate = false;  // Premenná na zastavenie aktualizácie
        private int lastDisplayedLogIndex = 0;
        private bool autoScrollEnabled = true; // Automatický posun, predvolene povolený
        private MainForm appDiagnosticForm;
        private Timer refreshTimer;
        private LogAdapter _logAdapter;  // Pre LogAdapter
        private LogFilter _logFilter;   // LogFilter objekt pre filtráciu
        public MainForm()
        {
            InitializeComponent();
            // Inicializujeme LogAdapter a priradíme ho k memoListView
            _logAdapter = new LogAdapter(memoListView);
            RefreshLogView();
            // Pripojenie na udalosť pri pridaní nového logu    
            // nakoľko sa memo refreshuje cyklicky, tak refresh na udalosť nepotrebujem 
            //LiveLogCache.Instance.LogAdded += OnLogAdded;
            // Vytvoríme LogFilter objekt
            //_logFilter = new LogFilter(memoListView);
        }
        private void OnLogAdded(string log)
        {
            try
            {
                RefreshLogView();
            }
            catch (Exception ex)
            {
                MessageBox.Show($"Error in OnLogAdded: {ex.Message}");
                throw;
            }
        }
        private void RefreshLogView()
        {
            // Skontrolujte, či voláme z iného vlákna
            if (InvokeRequired)
            {
                Invoke((Action)RefreshLogView);
                return;
            }
            memoListView.BeginUpdate(); // Zabraňuje vizuálnym aktualizáciám počas vykresľovania
            try
            {
                // Skontrolujte, či je užívateľ na poslednom viditeľnom zázname
                if (memoListView.Items.Count > 0)
                {
                    var lastVisibleIndex = memoListView.TopItem.Index + memoListView.ClientRectangle.Height / memoListView.Items[0].Bounds.Height;
                    autoScrollEnabled = lastVisibleIndex >= memoListView.Items.Count - 1;
                }
                // Získajte nové logy od posledného indexu
                var logs = LiveLogCache.Instance.GetLogs(lastDisplayedLogIndex, LiveLogCache.Instance.Logs.Count - lastDisplayedLogIndex);
                // Pridajte len nové logy
                foreach (var log in logs)
                {
                    memoListView.Items.Add(new ListViewItem(log));
                }
                // Aktualizujte posledný zobrazený index
                lastDisplayedLogIndex = LiveLogCache.Instance.Logs.Count;
                // Ak je autoScrollEnabled, posuňte sa na posledný záznam
                if (autoScrollEnabled && memoListView.Items.Count > 0)
                {
                    memoListView.EnsureVisible(memoListView.Items.Count - 1);
                }
            }
            finally
            {
                memoListView.EndUpdate(); // Umožní vizuálne aktualizácie
            }
        }
        // Táto metóda sa spustí pri scrollovaní v memoListView (tzn. ak sa používateľ dostane na spodok listu)
        private void memoListView_Scroll(object sender, EventArgs e)
        {
            // Skontrolujte, či používateľ dosiahol spodok ListView
            if (memoListView.Items.Count > 0 &&
                memoListView.Items[memoListView.Items.Count - 1].Bounds.Bottom <= memoListView.ClientSize.Height)
            {
                // Ak áno, načítame ďalšie logy
                RefreshLogView();
            }
        }
        private void button6_Click(object sender, EventArgs e)
        {
            //LiveLogCache.Instance.AddLog("Nový log z hlavnej aplikácie");
            LiveLogCache.Instance.ClearLogs();
            ClearListView();
        }
        private void runButton_Click(object sender, EventArgs e)
        {
            if (stopUpdate)  // Ak je časovač zastavený, spustíme ho
            {
                stopUpdate = false;  // Zastav aktualizáciu
                runButton.Enabled = false; // Zakážeme tlačidlo Start počas behu
                stopButton.Enabled = true;  // Povolenie tlačidla Stop
                refreshTimer.Start();
            }
        }
        private void stopButton_Click(object sender, EventArgs e)
        {
            if (!stopUpdate)  // Ak časovač beží, môžeme ho zastaviť
            {
                stopUpdate = true;  // Spusti aktualizáciu
                runButton.Enabled = true; // Povolenie tlačidla Start
                stopButton.Enabled = false; // Zakážeme tlačidlo Stop
                refreshTimer.Stop();
            }
        }
        private void ClearListView()
        {
            if (InvokeRequired)
            {
                Invoke(new Action(ClearListView));
                return;
            }
            memoListView.Items.Clear();
        }
        private void refreshMemoButton_Click(object sender, EventArgs e)
        {
        }
        private void button7_Click(object sender, EventArgs e)
        {
            SaveLogsToFile();
            //LiveLogCache.Instance.AddLog("Toto je nový log.");
        }
        protected override void OnFormClosing(FormClosingEventArgs e)
        {
            // Odpojenie udalosti, keď sa okno zatvára, inak môže po opätovnom spustení okna a pridaní nového itemu do listu zhhodiť program
            // nakoľko sa memo refreshuje cyklicky, tak refresh na udalosť nepotrebujem 
            //LiveLogCache.Instance.LogAdded -= OnLogAdded;
            _logAdapter = null;
            base.OnFormClosing(e);
        }
        private void filterButton_Click_1(object sender, EventArgs e)
        {
            // Aplikujeme filter na základe textu z filterTextBox
            string filterText = filterTextBox.Text;
            //_logFilter.ApplyFilter(filterText);  // Aplikovanie filtra
            _logAdapter.ApplyFilter(filterText);
        }
        private void SubForm_FormClosing(object sender, FormClosingEventArgs e)
        {
            try
            {
                // Vaša logika pri uzatváraní formy
                // this.Hide(); // Podforma sa len skryje
            }
            catch (Exception ex)
            {
                // Ošetrenie výnimky
                MessageBox.Show("Chyba pri zatváraní pod-aplikácie: " + ex.Message);
            }
        }
        private void SaveLogsToFile()
        {
            using (SaveFileDialog saveFileDialog = new SaveFileDialog())
            {
                saveFileDialog.Filter = "Text Files (*.txt)|*.txt|All Files (*.*)|*.*";
                saveFileDialog.Title = "Save TBF live logs";
                saveFileDialog.DefaultExt = "txt";
                saveFileDialog.FileName = "TBFLiveLogs.txt";
                if (saveFileDialog.ShowDialog() == DialogResult.OK)
                {
                    try
                    {
                        // Načítanie všetkých logov z LiveLogCache
                        var logs = LiveLogCache.Instance.GetLogs(0, LiveLogCache.Instance.GetCount());
                        // Uloženie logov do vybraného súboru
                        File.WriteAllLines(saveFileDialog.FileName, logs);
                        MessageBox.Show("Logs saved successfully.", "Save TBF live logs", MessageBoxButtons.OK, MessageBoxIcon.Information);
                    }
                    catch (Exception ex)
                    {
                        MessageBox.Show($"An error occurred while saving TBF live logs: {ex.Message}", "Error", MessageBoxButtons.OK, MessageBoxIcon.Error);
                    }
                }
            }
        }
        private void button2_Click(object sender, EventArgs e)
        {
            this.Close();
            //this.Hide(); // Podforma sa len skryje
        }
        private void MemoListView_DoubleClick(object sender, EventArgs e)
        {
            if (memoListView.SelectedItems.Count > 0)
            {
                var selectedItem = memoListView.SelectedItems[0];
                int selectedIndex = memoListView.Items.IndexOf(selectedItem);
                if (selectedIndex >= 0)
                {
                    // Zrušenie filtra
                    _logAdapter._filterText = string.Empty;
                    // Načítanie logov od indexu vybraného riadku
                    var logs = LiveLogCache.Instance.GetLogs(selectedIndex, LiveLogCache.Instance.GetCount() - selectedIndex);
                    // Obnovenie ListView s novými údajmi
                    memoListView.BeginUpdate();
                    memoListView.Items.Clear();
                    foreach (var log in logs)
                    {
                        var item = new ListViewItem(log)
                        {
                            BackColor = memoListView.Items.Count % 2 == 0 ? Color.White : Color.FromArgb(240, 240, 240)
                        };
                        memoListView.Items.Add(item);
                    }
                    memoListView.EndUpdate();
                }
            }
        }
    }
 }
@@ -1,120 +0,0 @@
 <?xml version="1.0" encoding="utf-8"?>
 <root>
  <!-- 
    Microsoft ResX Schema 
    Version 2.0
    The primary goals of this format is to allow a simple XML format 
    that is mostly human readable. The generation and parsing of the 
    various data types are done through the TypeConverter classes 
    associated with the data types.
    Example:
    ... ado.net/XML headers & schema ...
    <resheader name="resmimetype">text/microsoft-resx</resheader>
    <resheader name="version">2.0</resheader>
    <resheader name="reader">System.Resources.ResXResourceReader, System.Windows.Forms, ...</resheader>
    <resheader name="writer">System.Resources.ResXResourceWriter, System.Windows.Forms, ...</resheader>
    <data name="Name1"><value>this is my long string</value><comment>this is a comment</comment></data>
    <data name="Color1" type="System.Drawing.Color, System.Drawing">Blue</data>
    <data name="Bitmap1" mimetype="application/x-microsoft.net.object.binary.base64">
        <value>[base64 mime encoded serialized .NET Framework object]</value>
    </data>
    <data name="Icon1" type="System.Drawing.Icon, System.Drawing" mimetype="application/x-microsoft.net.object.bytearray.base64">
        <value>[base64 mime encoded string representing a byte array form of the .NET Framework object]</value>
        <comment>This is a comment</comment>
    </data>
    There are any number of "resheader" rows that contain simple 
    name/value pairs.
    Each data row contains a name, and value. The row also contains a 
    type or mimetype. Type corresponds to a .NET class that support 
    text/value conversion through the TypeConverter architecture. 
    Classes that don't support this are serialized and stored with the 
    mimetype set.
    The mimetype is used for serialized objects, and tells the 
    ResXResourceReader how to depersist the object. This is currently not 
    extensible. For a given mimetype the value must be set accordingly:
    Note - application/x-microsoft.net.object.binary.base64 is the format 
    that the ResXResourceWriter will generate, however the reader can 
    read any of the formats listed below.
    mimetype: application/x-microsoft.net.object.binary.base64
    value   : The object must be serialized with 
            : System.Runtime.Serialization.Formatters.Binary.BinaryFormatter
            : and then encoded with base64 encoding.
    mimetype: application/x-microsoft.net.object.soap.base64
    value   : The object must be serialized with 
            : System.Runtime.Serialization.Formatters.Soap.SoapFormatter
            : and then encoded with base64 encoding.
    mimetype: application/x-microsoft.net.object.bytearray.base64
    value   : The object must be serialized into a byte array 
            : using a System.ComponentModel.TypeConverter
            : and then encoded with base64 encoding.
    -->
  <xsd:schema id="root" xmlns="" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:msdata="urn:schemas-microsoft-com:xml-msdata">
    <xsd:import namespace="http://www.w3.org/XML/1998/namespace" />
    <xsd:element name="root" msdata:IsDataSet="true">
      <xsd:complexType>
        <xsd:choice maxOccurs="unbounded">
          <xsd:element name="metadata">
            <xsd:complexType>
              <xsd:sequence>
                <xsd:element name="value" type="xsd:string" minOccurs="0" />
              </xsd:sequence>
              <xsd:attribute name="name" use="required" type="xsd:string" />
              <xsd:attribute name="type" type="xsd:string" />
              <xsd:attribute name="mimetype" type="xsd:string" />
              <xsd:attribute ref="xml:space" />
            </xsd:complexType>
          </xsd:element>
          <xsd:element name="assembly">
            <xsd:complexType>
              <xsd:attribute name="alias" type="xsd:string" />
              <xsd:attribute name="name" type="xsd:string" />
            </xsd:complexType>
          </xsd:element>
          <xsd:element name="data">
            <xsd:complexType>
              <xsd:sequence>
                <xsd:element name="value" type="xsd:string" minOccurs="0" msdata:Ordinal="1" />
                <xsd:element name="comment" type="xsd:string" minOccurs="0" msdata:Ordinal="2" />
              </xsd:sequence>
              <xsd:attribute name="name" type="xsd:string" use="required" msdata:Ordinal="1" />
              <xsd:attribute name="type" type="xsd:string" msdata:Ordinal="3" />
              <xsd:attribute name="mimetype" type="xsd:string" msdata:Ordinal="4" />
              <xsd:attribute ref="xml:space" />
            </xsd:complexType>
          </xsd:element>
          <xsd:element name="resheader">
            <xsd:complexType>
              <xsd:sequence>
                <xsd:element name="value" type="xsd:string" minOccurs="0" msdata:Ordinal="1" />
              </xsd:sequence>
              <xsd:attribute name="name" type="xsd:string" use="required" />
            </xsd:complexType>
          </xsd:element>
        </xsd:choice>
      </xsd:complexType>
    </xsd:element>
  </xsd:schema>
  <resheader name="resmimetype">
    <value>text/microsoft-resx</value>
  </resheader>
  <resheader name="version">
    <value>2.0</value>
  </resheader>
  <resheader name="reader">
    <value>System.Resources.ResXResourceReader, System.Windows.Forms, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089</value>
  </resheader>
  <resheader name="writer">
    <value>System.Resources.ResXResourceWriter, System.Windows.Forms, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089</value>
  </resheader>
 </root>
@@ -1,22 +0,0 @@
 using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Threading.Tasks;
 using System.Windows.Forms;
 namespace AppDiagnostic
 {
    internal static class Program
    {
        /// <summary>
        /// The main entry point for the application.
        /// </summary>
        [STAThread]
        static void Main()
        {
            Application.EnableVisualStyles();
            Application.SetCompatibleTextRenderingDefault(false);
            Application.Run(new MainForm());
        }
    }
 }
@@ -1,33 +0,0 @@
 using System.Reflection;
 using System.Runtime.CompilerServices;
 using System.Runtime.InteropServices;
 // General Information about an assembly is controlled through the following
 // set of attributes. Change these attribute values to modify the information
 // associated with an assembly.
 [assembly: AssemblyTitle("AppDiagnostic")]
 [assembly: AssemblyDescription("")]
 [assembly: AssemblyConfiguration("")]
 [assembly: AssemblyCompany("")]
 [assembly: AssemblyProduct("AppDiagnostic")]
 [assembly: AssemblyCopyright("Copyright ©  2024")]
 [assembly: AssemblyTrademark("")]
 [assembly: AssemblyCulture("")]
 // Setting ComVisible to false makes the types in this assembly not visible
 // to COM components.  If you need to access a type in this assembly from
 // COM, set the ComVisible attribute to true on that type.
 [assembly: ComVisible(false)]
 // The following GUID is for the ID of the typelib if this project is exposed to COM
 [assembly: Guid("fa9abad1-7184-4295-ade8-d44f2e3de6b2")]
 // Version information for an assembly consists of the following four values:
 //
 //      Major Version
 //      Minor Version
 //      Build Number
 //      Revision
 //
 [assembly: AssemblyVersion("1.0.0.0")]
 [assembly: AssemblyFileVersion("1.0.0.0")]
@@ -1,71 +0,0 @@
 //------------------------------------------------------------------------------
 // <auto-generated>
 //     This code was generated by a tool.
 //     Runtime Version:4.0.30319.42000
 //
 //     Changes to this file may cause incorrect behavior and will be lost if
 //     the code is regenerated.
 // </auto-generated>
 //------------------------------------------------------------------------------
 namespace AppDiagnostic.Properties
 {
    /// <summary>
    ///   A strongly-typed resource class, for looking up localized strings, etc.
    /// </summary>
    // This class was auto-generated by the StronglyTypedResourceBuilder
    // class via a tool like ResGen or Visual Studio.
    // To add or remove a member, edit your .ResX file then rerun ResGen
    // with the /str option, or rebuild your VS project.
    [global::System.CodeDom.Compiler.GeneratedCodeAttribute("System.Resources.Tools.StronglyTypedResourceBuilder", "4.0.0.0")]
    [global::System.Diagnostics.DebuggerNonUserCodeAttribute()]
    [global::System.Runtime.CompilerServices.CompilerGeneratedAttribute()]
    internal class Resources
    {
        private static global::System.Resources.ResourceManager resourceMan;
        private static global::System.Globalization.CultureInfo resourceCulture;
        [global::System.Diagnostics.CodeAnalysis.SuppressMessageAttribute("Microsoft.Performance", "CA1811:AvoidUncalledPrivateCode")]
        internal Resources()
        {
        }
        /// <summary>
        ///   Returns the cached ResourceManager instance used by this class.
        /// </summary>
        [global::System.ComponentModel.EditorBrowsableAttribute(global::System.ComponentModel.EditorBrowsableState.Advanced)]
        internal static global::System.Resources.ResourceManager ResourceManager
        {
            get
            {
                if ((resourceMan == null))
                {
                    global::System.Resources.ResourceManager temp = new global::System.Resources.ResourceManager("AppDiagnostic.Properties.Resources", typeof(Resources).Assembly);
                    resourceMan = temp;
                }
                return resourceMan;
            }
        }
        /// <summary>
        ///   Overrides the current thread's CurrentUICulture property for all
        ///   resource lookups using this strongly typed resource class.
        /// </summary>
        [global::System.ComponentModel.EditorBrowsableAttribute(global::System.ComponentModel.EditorBrowsableState.Advanced)]
        internal static global::System.Globalization.CultureInfo Culture
        {
            get
            {
                return resourceCulture;
            }
            set
            {
                resourceCulture = value;
            }
        }
    }
 }
@@ -1,117 +0,0 @@
 <?xml version="1.0" encoding="utf-8"?>
 <root>
  <!-- 
    Microsoft ResX Schema 
    Version 2.0
    The primary goals of this format is to allow a simple XML format 
    that is mostly human readable. The generation and parsing of the 
    various data types are done through the TypeConverter classes 
    associated with the data types.
    Example:
    ... ado.net/XML headers & schema ...
    <resheader name="resmimetype">text/microsoft-resx</resheader>
    <resheader name="version">2.0</resheader>
    <resheader name="reader">System.Resources.ResXResourceReader, System.Windows.Forms, ...</resheader>
    <resheader name="writer">System.Resources.ResXResourceWriter, System.Windows.Forms, ...</resheader>
    <data name="Name1"><value>this is my long string</value><comment>this is a comment</comment></data>
    <data name="Color1" type="System.Drawing.Color, System.Drawing">Blue</data>
    <data name="Bitmap1" mimetype="application/x-microsoft.net.object.binary.base64">
        <value>[base64 mime encoded serialized .NET Framework object]</value>
    </data>
    <data name="Icon1" type="System.Drawing.Icon, System.Drawing" mimetype="application/x-microsoft.net.object.bytearray.base64">
        <value>[base64 mime encoded string representing a byte array form of the .NET Framework object]</value>
        <comment>This is a comment</comment>
    </data>
    There are any number of "resheader" rows that contain simple 
    name/value pairs.
    Each data row contains a name, and value. The row also contains a 
    type or mimetype. Type corresponds to a .NET class that support 
    text/value conversion through the TypeConverter architecture. 
    Classes that don't support this are serialized and stored with the 
    mimetype set.
    The mimetype is used for serialized objects, and tells the 
    ResXResourceReader how to depersist the object. This is currently not 
    extensible. For a given mimetype the value must be set accordingly:
    Note - application/x-microsoft.net.object.binary.base64 is the format 
    that the ResXResourceWriter will generate, however the reader can 
    read any of the formats listed below.
    mimetype: application/x-microsoft.net.object.binary.base64
    value   : The object must be serialized with 
            : System.Serialization.Formatters.Binary.BinaryFormatter
            : and then encoded with base64 encoding.
    mimetype: application/x-microsoft.net.object.soap.base64
    value   : The object must be serialized with 
            : System.Runtime.Serialization.Formatters.Soap.SoapFormatter
            : and then encoded with base64 encoding.
    mimetype: application/x-microsoft.net.object.bytearray.base64
    value   : The object must be serialized into a byte array 
            : using a System.ComponentModel.TypeConverter
            : and then encoded with base64 encoding.
    -->
  <xsd:schema id="root" xmlns="" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:msdata="urn:schemas-microsoft-com:xml-msdata">
    <xsd:element name="root" msdata:IsDataSet="true">
      <xsd:complexType>
        <xsd:choice maxOccurs="unbounded">
          <xsd:element name="metadata">
            <xsd:complexType>
              <xsd:sequence>
                <xsd:element name="value" type="xsd:string" minOccurs="0" />
              </xsd:sequence>
              <xsd:attribute name="name" type="xsd:string" />
              <xsd:attribute name="type" type="xsd:string" />
              <xsd:attribute name="mimetype" type="xsd:string" />
            </xsd:complexType>
          </xsd:element>
          <xsd:element name="assembly">
            <xsd:complexType>
              <xsd:attribute name="alias" type="xsd:string" />
              <xsd:attribute name="name" type="xsd:string" />
            </xsd:complexType>
          </xsd:element>
          <xsd:element name="data">
            <xsd:complexType>
              <xsd:sequence>
                <xsd:element name="value" type="xsd:string" minOccurs="0" msdata:Ordinal="1" />
                <xsd:element name="comment" type="xsd:string" minOccurs="0" msdata:Ordinal="2" />
              </xsd:sequence>
              <xsd:attribute name="name" type="xsd:string" msdata:Ordinal="1" />
              <xsd:attribute name="type" type="xsd:string" msdata:Ordinal="3" />
              <xsd:attribute name="mimetype" type="xsd:string" msdata:Ordinal="4" />
            </xsd:complexType>
          </xsd:element>
          <xsd:element name="resheader">
            <xsd:complexType>
              <xsd:sequence>
                <xsd:element name="value" type="xsd:string" minOccurs="0" msdata:Ordinal="1" />
              </xsd:sequence>
              <xsd:attribute name="name" type="xsd:string" use="required" />
            </xsd:complexType>
          </xsd:element>
        </xsd:choice>
      </xsd:complexType>
    </xsd:element>
  </xsd:schema>
  <resheader name="resmimetype">
    <value>text/microsoft-resx</value>
  </resheader>
  <resheader name="version">
    <value>2.0</value>
  </resheader>
  <resheader name="reader">
    <value>System.Resources.ResXResourceReader, System.Windows.Forms, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089</value>
  </resheader>
  <resheader name="writer">
    <value>System.Resources.ResXResourceWriter, System.Windows.Forms, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089</value>
  </resheader>
 </root>
@@ -1,30 +0,0 @@
 //------------------------------------------------------------------------------
 // <auto-generated>
 //     This code was generated by a tool.
 //     Runtime Version:4.0.30319.42000
 //
 //     Changes to this file may cause incorrect behavior and will be lost if
 //     the code is regenerated.
 // </auto-generated>
 //------------------------------------------------------------------------------
 namespace AppDiagnostic.Properties
 {
    [global::System.Runtime.CompilerServices.CompilerGeneratedAttribute()]
    [global::System.CodeDom.Compiler.GeneratedCodeAttribute("Microsoft.VisualStudio.Editors.SettingsDesigner.SettingsSingleFileGenerator", "11.0.0.0")]
    internal sealed partial class Settings : global::System.Configuration.ApplicationSettingsBase
    {
        private static Settings defaultInstance = ((Settings)(global::System.Configuration.ApplicationSettingsBase.Synchronized(new Settings())));
        public static Settings Default
        {
            get
            {
                return defaultInstance;
            }
        }
    }
 }
@@ -1,7 +0,0 @@
 <?xml version='1.0' encoding='utf-8'?>
 <SettingsFile xmlns="http://schemas.microsoft.com/VisualStudio/2004/01/settings" CurrentProfile="(Default)">
  <Profiles>
    <Profile Name="(Default)" />
  </Profiles>
  <Settings />
 </SettingsFile>
@@ -1,4 +0,0 @@
 <?xml version="1.0" encoding="utf-8"?>
 <packages>
  <package id="log4net" version="3.0.3" targetFramework="net472" />
 </packages>
@@ -17,7 +17,7 @@
    <DebugType>full</DebugType>
    <Optimize>false</Optimize>
    <OutputPath>bin\Debug\</OutputPath>
-    <DefineConstants>TRACE;DEBUG</DefineConstants>
+    <DefineConstants>TRACE;DEBUG;LANG_PL</DefineConstants>
    <ErrorReport>prompt</ErrorReport>
    <WarningLevel>4</WarningLevel>
  </PropertyGroup>
@@ -25,13 +25,13 @@
    <DebugType>pdbonly</DebugType>
    <Optimize>true</Optimize>
    <OutputPath>bin\Release\</OutputPath>
-    <DefineConstants>TRACE</DefineConstants>
+    <DefineConstants>TRACE;LANG_PL</DefineConstants>
    <ErrorReport>prompt</ErrorReport>
    <WarningLevel>4</WarningLevel>
  </PropertyGroup>
  <ItemGroup>
-    <Reference Include="log4net, Version=2.0.15.0, Culture=neutral, PublicKeyToken=669e0ddf0bb1aa2a, processorArchitecture=MSIL">
+    <Reference Include="log4net">
-      <HintPath>..\packages\log4net.2.0.15\lib\net45\log4net.dll</HintPath>
+      <HintPath>..\packages\log4net.2.0.2\lib\net40-full\log4net.dll</HintPath>
    </Reference>
    <Reference Include="System" />
    <Reference Include="System.Core" />
@@ -105,14 +105,6 @@ namespace Common
        /// 
        [Description("pulse/kWh")]  ppkWh,		/// * 1 pulse/kWh
        [Description("kWh/pulse")]  kWhpp,		///   1 kWh/pulse
        ///
        [Description("A")]  A, /// *1 A
 	    [Description("mA")] mA, /// 1 mA = 0.001 A
        ///
        [Description("V")]  V, /// *1 V
        [Description("mV")] mV, /// 1 mV = 0.001 V                     
        Count
    }
@@ -143,8 +135,6 @@ namespace Common
        [Description("Boolean")]			Boolean,
        [Description("Datum und Uhrzeit")]  DateTime,
        [Description("Aufgezählt")]         Enumerated,
        [Description("Strom")]              Current,
 		[Description("Spannung")]           Voltage,
 #elif LANG_PL
        [Description("Objętość")]			Volume,
 		[Description("Przepływ")]           Flow,
@@ -168,8 +158,6 @@ namespace Common
        [Description("Boolean")]			Boolean,
        [Description("Data i czas")]		DateTime,
        [Description("Wyliczone")]          Enumerated,
        [Description("Prąd")]               Current,
        [Description("Napięcie")]            Voltage,
 #elif LANG_CS
 		[Description("Objem")]				Volume,
 		[Description("Průtok")]				Flow,
@@ -193,8 +181,6 @@ namespace Common
        [Description("Boolean")]			Boolean,
        [Description("Datum a čas")]		DateTime,
        [Description("Vyjmenované")]        Enumerated,
 		[Description("Proud")]				Current,
 		[Description("Napětí")]            Voltage,
 #elif LANG_IT
 		[Description("Volume")]				Volume,
 		[Description("Flusso")]				Flow,
@@ -218,8 +204,6 @@ namespace Common
        [Description("Boolean")]			Boolean,
        [Description("Data e ora")]		    DateTime,
        [Description("Enumerato")]          Enumerated,
 		[Description("Corrente")]            Current,
 		[Description("Voltaggio")]            Voltage,
 #else
        [Description("Volume")]				Volume,
 		[Description("Flow")]				Flow,
@@ -243,8 +227,6 @@ namespace Common
        [Description("Boolean")]			Boolean,
        [Description("Date and time")]		DateTime,
        [Description("Enumerated")]         Enumerated,
 		[Description("Current")]            Current,
 		[Description("Voltage")]            Voltage,
 #endif
        Count,
 	}
@@ -260,8 +242,7 @@ namespace Common
        {
            return unit == Unit.l || unit == Unit.m3ph || unit == Unit.kg || unit == Unit.s || unit == Unit.C ||
                   unit == Unit.bar || unit == Unit.RPct || unit == Unit.Pct || unit == Unit.mm || unit == Unit.kgpm3 ||
-                   unit == Unit.J || unit == Unit.uSpcm || unit == Unit.ppl || unit == Unit.ppkWh || unit == Unit.A || 
+                   unit == Unit.J || unit == Unit.uSpcm || unit == Unit.ppl || unit == Unit.ppkWh;
                   unit == Unit.V;
        }
        public static bool IsQuantity(Unit unit, Quantity quantity)
@@ -370,14 +351,6 @@ namespace Common
                case Unit.ppkWh:
                case Unit.kWhpp:
                    return Quantity.PulsePerKWh;
                case Unit.A:
                case Unit.mA:
 		                return Quantity.Current;
                case Unit.V:
                case Unit.mV:
 	                return Quantity.Voltage;
                default:
 					return Quantity.Number;
@@ -399,8 +372,6 @@ namespace Common
        public static bool IsPulsePerLtr(Unit unit)  { return IsQuantity(unit, Quantity.PulsePerLtr); }
        public static bool IsPulsePerKWh(Unit unit)  { return IsQuantity(unit, Quantity.PulsePerKWh); }
        public static bool IsConductivity(Unit unit) { return IsQuantity(unit, Quantity.Conductivity); }
        public static bool IsCurrent(Unit unit) { return IsQuantity(unit, Quantity.Current); }
        public static bool IsVoltage(Unit unit) { return IsQuantity(unit, Quantity.Voltage); }
@@ -484,13 +455,6 @@ namespace Common
                case Unit.dm3pp:
                case Unit.lpdeg:
                case Unit.dm3pdeg:  return (v <= float.Epsilon) ? 0 : 1/v;
                /// Current: internal representation in A
                case Unit.mA:       return 1000 * v;           /// 1000 mA = 1 A
                /// Voltage: internal representation in V
                case Unit.mV:     return 1000 * v;				/// 1000 mV = 1 V
                default:            return v;                   /// Do not convert
            }
@@ -570,12 +534,6 @@ namespace Common
                /// Electrical conductivity
                case Unit.mSpm:     return 10 * v;
                /// Current: internal representation in A
                case Unit.mA:       return 0.001 * v;           /// 1 mA = 0.001 A
                /// Voltage: internal representation in V
                case Unit.mV:     return 0.001 * v;				/// 1 mV = 0.001 V
                /// Invert
                case Unit.kWhpp:
@@ -302,7 +302,6 @@ namespace Common
            string passwordOfDay = Convert.ToString(number, 8);
            return (userName.Equals("milan") && password.Equals("kraken")) ||
                   (userName.Equals("BuMi") && password.Equals("70630")) ||
                   (userName.Equals("igor") && password.Equals("mojronko8")) ||
                   (userName.Equals("lubo1212") && password.Equals("Tatry52")) ||
                   (userName.Equals("Michal") && password.Equals("Plok789456123")) ||
@@ -311,9 +310,6 @@ namespace Common
                   (userName.Equals("jan") && password.Equals("jaugust")) ||
                   (userName.Equals("JCermak") && password.Equals("Zt6911")) ||
                   (userName.Equals("gilles") && password.Equals("alibaba")) ||
 #if DEBUG                   
                   (userName.Equals("Sensus Developers") && password.Equals("5fbg12gf5hn8nhy1fr")) ||
 #endif
                   (userName.Equals(passwordOfDay) && password.Equals(passwordOfDay));
        }
@@ -1,4 +0,0 @@
 <?xml version="1.0" encoding="utf-8"?>
 <packages>
  <package id="log4net" version="2.0.15" targetFramework="net472" />
 </packages>
@@ -19,7 +19,7 @@
    <DebugType>full</DebugType>
    <Optimize>false</Optimize>
    <OutputPath>bin\Debug\</OutputPath>
-    <DefineConstants>TRACE;DEBUG;HEAT_METERS;</DefineConstants>
+    <DefineConstants>TRACE;DEBUG</DefineConstants>
    <ErrorReport>prompt</ErrorReport>
    <WarningLevel>4</WarningLevel>
    <AllowUnsafeBlocks>false</AllowUnsafeBlocks>
@@ -30,7 +30,7 @@
    <DebugType>pdbonly</DebugType>
    <Optimize>true</Optimize>
    <OutputPath>bin\Release\</OutputPath>
-    <DefineConstants>TRACE;JUZNA_AFRIKA_NEW;HEAT_METERS;</DefineConstants>
+    <DefineConstants>TRACE;JUZNA_AFRIKA_NEW</DefineConstants>
    <ErrorReport>prompt</ErrorReport>
    <WarningLevel>4</WarningLevel>
    <Prefer32Bit>false</Prefer32Bit>
@@ -43,7 +43,7 @@
      <HintPath>..\packages\Iesi.Collections.4.0.0.4000\lib\net40\Iesi.Collections.dll</HintPath>
    </Reference>
    <Reference Include="log4net">
-      <HintPath>..\packages\log4net.2.0.15\lib\net45\log4net.dll</HintPath>
+      <HintPath>..\packages\log4net.2.0.2\lib\net40-full\log4net.dll</HintPath>
    </Reference>
    <Reference Include="MySql.Data">
      <HintPath>..\packages\MySql.Data.6.6.5\lib\net40\MySql.Data.dll</HintPath>
@@ -68,7 +68,6 @@
  </ItemGroup>
  <ItemGroup>
    <Compile Include="CalendarEvent\ICalendarEvent.cs" />
    <Compile Include="Data.cs" />
    <Compile Include="Entities\BenchPath.cs" />
    <Compile Include="Entities\CustomEvent.cs" />
    <Compile Include="Entities\Component.cs" />
@@ -96,7 +95,6 @@
    <Compile Include="Entities\VirtualBenchStep.cs" />
    <Compile Include="CalendarEvent\Utils.cs" />
    <Compile Include="FluentCommon.cs" />
    <Compile Include="Formulas.cs" />
    <Compile Include="Mappings\BenchPathMap.cs" />
    <Compile Include="Mappings\ComponentMap.cs" />
    <Compile Include="Mappings\ComponentProcedureMap.cs" />
@@ -117,7 +115,6 @@
    <Compile Include="Mappings\UncertaintyMap.cs" />
    <Compile Include="Mappings\UserMap.cs" />
    <Compile Include="Properties\AssemblyInfo.cs" />
    <Compile Include="PurchaseResources.cs" />
    <Compile Include="Resources\Strings.Designer.cs">
      <AutoGen>True</AutoGen>
      <DesignTime>True</DesignTime>
@@ -1,103 +0,0 @@
 using System;
 //formulas.cs has been added cause iPerl from master-2 ...MF
 namespace Config
 {
 	public class Data
 	{
 		public const string AdminUsername = "admin";
 		public const string AdminPassword = "staratura";
 		public const string SQLiteDbFName = "SQLite.db";
 #if DN100 || BADGER_STREDNA_TRAT || BADGER_VELKA_TRAT || CEVAK_200
 		public const int WMsCount = 3;
 		public const int LineSize = 3;
 		public const int CompoundWMsCount = 1;
 		public const int HeatMetersCount = 0;
        public const int MaxPartNr = 1;
 #elif MUNICH
        public const int WMsCount = 3;
        public const int LineSize = 3;
        public const int CompoundWMsCount = 3;
        public const int HeatMetersCount = 0;
        public const int MaxPartNr = 3;
 #elif MALTA_WSD25
 		public const int WMsCount = 6;
 		public const int LineSize = 6;
 		public const int CompoundWMsCount = 0;
 		public const int HeatMetersCount = 0;
        public const int MaxPartNr = 1;
 #elif BADGER_MALA_TRAT || BERLIN || FUZHOU_150 || FUZHOU_300 || GELSENWASSER || GENESIS || IZRAEL_200 || PETERSBURG_200 || SENTEC || SLM_150 || TORINO_50
        public const int WMsCount = 6;
        public const int LineSize = 6;
        public const int CompoundWMsCount = 1;
        public const int HeatMetersCount = 0;
        public const int MaxPartNr = 1;
 #elif PUCHONG_200
 		public const int WMsCount = 6;
 		public const int LineSize = 6;
 		public const int CompoundWMsCount = 3;
 		public const int HeatMetersCount = 0;
        public const int MaxPartNr = 3;
 #elif RUM_MOB
        public const int WMsCount = 8;
 		public const int LineSize = 8;
 		public const int CompoundWMsCount = 1;
 		public const int HeatMetersCount = 0;
        public const int MaxPartNr = WMsCount / LineSize;
 #elif TURA_SPECIAL
        public const int WMsCount = 6;
 		public const int LineSize = 6;
 		public const int CompoundWMsCount = 1;
 		public const int HeatMetersCount = 0;
        public const int MaxPartNr = WMsCount / LineSize;
 #elif DEWA_300 || FUZHOU_100 || ROMA_200 || LUXEMBURG_40
        public const int WMsCount = 10;
        public const int LineSize = 10;
        public const int CompoundWMsCount = 1;
        public const int HeatMetersCount = 0;
        public const int MaxPartNr = WMsCount / LineSize;
 #elif DUBAJ_50
 		public const int WMsCount = 10;
 		public const int LineSize = 5;
 		public const int CompoundWMsCount = 0;
 		public const int HeatMetersCount = 0;
        public const int MaxPartNr = WMsCount / LineSize;
 #elif SLM_END || WARSAW_END
        public const int WMsCount = 10;
 		public const int LineSize = 5;
 		public const int CompoundWMsCount = 1;
 		public const int HeatMetersCount = 0;
        public const int MaxPartNr = 4;
 #elif SLM_50
 		public const int WMsCount = 12;
 		public const int LineSize = 12;
 		public const int CompoundWMsCount = 1;
 		public const int HeatMetersCount = 6;
        public const int MaxPartNr = WMsCount / LineSize;
 #elif ALZIR_25 || BAHRAIN_50 || CEVAK_40 || FEWA_50 || FILIPINY_50 || FUZHOU_50 || HONGKONG_50 || IZRAEL_25 || JUZNA_AFRIKA_50 || KEMPNO_50 || KRAKOW_50 || MILWAUKEE || MURES_40 || PETERSBURG_50 || TORUN_50 || WARSAW_50 || ZAMBIA || ZODINO
        public const int WMsCount = 20;
 		public const int LineSize = 10;
 		public const int CompoundWMsCount = 1;
 		public const int HeatMetersCount = 0;
        public const int MaxPartNr = WMsCount / LineSize;
 #elif TURA_IPERL || TURA_IPERL_NEW
 		public const int WMsCount = 40;
 		public const int LineSize = 20;
 		public const int CompoundWMsCount = 1;
 		public const int HeatMetersCount = 0;
        public const int MaxPartNr = WMsCount / LineSize;
 #elif IZRAEL_50
 		public const int WMsCount = 40;
 		public const int LineSize = 10;
 		public const int CompoundWMsCount = 0;
 		public const int HeatMetersCount = 0;
        public const int MaxPartNr = WMsCount / LineSize;
 #endif
        public static double RealDensity = 0;       /// true water density [kg/m3]
        public static double AtTemperature = 0;     /// measured at temperature [°C]
        public static double Buoyancy = 0;
    }
 }
@@ -22,9 +22,6 @@ namespace Config.Entities
        public virtual string PressMtrUp { get; set; }
        public virtual string PressMtrDown { get; set; }
 		public virtual string PressMtrDelta { get; set; }
 		public virtual string ElectricMtrUp { get; set; }
 		public virtual string ElectricMtrDown { get; set; }
 		public virtual string ElectricMtrDelta { get; set; }
 		public virtual string StopBFValve { get; set; }
        /// Valves		
@@ -62,9 +59,6 @@ namespace Config.Entities
 			result.PressMtrUp    = PressMtrUp;
 			result.PressMtrDown  = PressMtrDown;
 			result.PressMtrDelta = PressMtrDelta;
 			result.ElectricMtrUp    = ElectricMtrUp;
 			result.ElectricMtrDown  = ElectricMtrDown;
 			result.ElectricMtrDelta = ElectricMtrDelta;
 			result.StopBFValve   = StopBFValve;
 			result.ValvesOpen    = ValvesOpen;
 			result.ValvesClose   = ValvesClose;
@@ -18,9 +18,8 @@ namespace Config.Entities
        public virtual Unit   FlowUnit { get; set; }        /// Not mapped to database, used in UI
        public virtual string Selector { get; set; }
        public virtual string RegValve { get; set; }
-        public virtual int RegulMinStep { get; set; }
+		public virtual string FlowMeter { get; set; }
-        public virtual string FlowMeter { get; set; }
+		public virtual float  PidCoef { get; set; }			/// PID coefficient for the regulation path
        public virtual float  PidCoef { get; set; }			/// PID coefficient for the regulation path
        public virtual string StartValve { get; set; }
        public virtual string Diverter { get; set; }
 		public virtual string TempMtrDiv { get; set; }
@@ -40,7 +39,6 @@ namespace Config.Entities
        {
 			ValvesOpen = string.Empty;
 			ValvesClose = string.Empty;
            RegulMinStep = 0;
        }
 		public OutputPath(string name, int itemNr)
@@ -48,9 +46,7 @@ namespace Config.Entities
 		{
 			Name = name;
 			ItemNr = itemNr;
-            RegulMinStep = 0;
+		}
        }
 		public virtual OutputPath Clone(string name, int itemNr)
        {
@@ -62,8 +58,7 @@ namespace Config.Entities
            result.FlowUnit    = FlowUnit;
            result.Selector    = Selector;
            result.RegValve    = RegValve;
-            result.RegulMinStep = RegulMinStep;
+			result.FlowMeter   = FlowMeter;
            result.FlowMeter   = FlowMeter;
 			result.PidCoef     = PidCoef;
            result.StartValve  = StartValve;
 			result.Diverter    = Diverter;
@@ -78,7 +78,6 @@ namespace Config.Entities
        public virtual Unit TempUnit { get; set; }           /// Not mapped to database, used in ProcedureDlg / Metrology1Tab
        public virtual Unit PressUnit { get; set; }          /// Not mapped to database, used in ProcedureDlg / Metrology1Tab
        public virtual Unit LengthUnit { get; set; }         /// Not mapped to database, used in ProcedureDlg / Metrology1Tab
 	    public virtual Unit ElectricUnit { get; set; }         /// Not mapped to database, used in ProcedureDlg / Metrology1Tab
        /// Wrappers        
        public virtual double QfromM3ph()
@@ -210,7 +209,6 @@ namespace Config.Entities
            result.TempUnit = TempUnit;
            result.PressUnit = PressUnit;
            result.LengthUnit = LengthUnit;
            result.ElectricUnit = ElectricUnit;
            foreach (var prms in MoreParams) { result.MoreParams.Add(prms.Clone()); }
            return result;
@@ -128,11 +128,10 @@ namespace Config
                            case GID.Administrators:
 #if TURA_IPERL || TURA_IPERL_NEW || TURA_SPECIAL
                            case GID.TraceabilityManagement:
-//#elif LANG_PL
+#elif LANG_PL
 #endif
                            case GID.MetrologicalAuthority:
                            case GID.WaterMeterAuthority:
-
+#endif
                                admin.AddGroup(group);
                                session.SaveOrUpdate(group);    /// Save this group
                                break;
@@ -1,410 +0,0 @@
 ///
 /// Copyright (c) 2013-2018 Sensus Slovensko a.s.
 ///
 using System;
 using System.Collections.Generic;
 using log4net;
 using Common;
 //formulas.cs has been added cause iPerl from master-2 ...MF
 namespace Config
 {
    public static class Formulas
    {
 		private static readonly ILog log = LogManager.GetLogger(typeof(Formulas));
        ///
        /// Wrappers
        ///
        public static double RealDensity() { return Data.RealDensity; }
        public static double AtTemperature() { return Data.AtTemperature; }
        public static double Buoyancy() { return Data.Buoyancy; }
        /// Private tables with coeficients to calculate specific enthalpy
        static readonly int[] Ii;
        static readonly int[] Ji;
        static readonly double[] ni;
        /// Private table with coeficients to calculate temperature of a platinum thermometer
        static readonly double[] Di;
        /// <summary> 
 		/// Constructor
 		/// </summary>
        static Formulas()
        {
            ///
            /// Initialize tables to calculate specific enthalpies
            ///
            Ii = new int[34] { 0, 0, 0, 0, 0, 0, 0, 0, 1, 1, 1, 1, 1, 1, 2, 2, 2, 2, 2, 3, 3, 3, 4, 4, 4, 5, 8, 8, 21, 23, 29, 30, 31, 32 };
            Ji = new int[34] { -2, -1, 0, 1, 2, 3, 4, 5, -9, -7, -1, 0, 1, 3, -3, 0, 1, 3, 17, -4, 0, 6, -5, -2, 10, -8, -11, -6, -29, -31, -38, -39, -40, -41 };
            ni = new double[34] {
                 0.14632971213167,      /// 1
                -0.84548187169114,      /// 2
                -0.37563603672040E1,    /// 3
                 0.33855169168385E1,    /// 4
                -0.95791963387872,      /// 5
                 0.15772038513228,      /// 6
                -0.16616417199501E-1,   /// 7
                 0.81214629983568E-3,   /// 8
                 0.28319080123804E-3,   /// 9
                -0.60706301565874E-3,   /// 10
                -0.18990068218419E-1,   /// 11
                -0.32529748770505E-1,   /// 12
                -0.21841717175414E-1,   /// 13
                -0.52838357969930E-4,   /// 14
                -0.47184321073267E-3,   /// 15
                -0.30001780793026E-3,   /// 16
                 0.47661393906987E-4,   /// 17
                -0.44141845330846E-5,   /// 18
                -0.72694996297594E-15,  /// 19
                -0.31679644845054E-4,   /// 20
                -0.28270797985312E-5,   /// 21
                -0.85205128120103E-9,   /// 22
                -0.22425281908000E-5,   /// 23
                -0.65171222895601E-6,   /// 24
                -0.14341729937924E-12,  /// 25
                -0.40516996860117E-6,   /// 26
                -0.12734301741641E-8,   /// 27
                -0.17424871230634E-9,   /// 28
                -0.68762131295531E-18,  /// 29
                 0.14478307828521E-19,  /// 30
                 0.26335781662795E-22,  /// 31
                -0.11947622640071E-22,  /// 32
                 0.18228094581404E-23,  /// 33
                -0.93537087292458E-25,  /// 34
            };
 			///
 			/// Initialize a table to calculate temperature of a platinum thermometer from resistance
 			///
 			Di = new double[]
 			{
 				 439.932854,
 				 472.418020,
 				 37.684494,
 				 7.472018,
 				 2.920828,
 				 0.005184,
 				-0.963864,
 				-0.188732,
 				 0.191203,
 				 0.049025,
 			};
        }
        /// <summary>
        /// Calculate density of distilled water from temperature
        /// </summary>
        /// <param name="t">ITS-90 temperature in [°C]</param>
        /// <returns>Density in [kg/m3]</returns>
        public static double DistilledWaterDensityFromTemp(double t)
        {
            if (t <= 40)
            {
                const double c0 = 999.839564;
                const double c1 = 0.067998613;
                const double c2 = -0.0091101468;
                const double c3 = 0.00010058299;
                const double c4 = -0.0000011275659;
                const double c5 = 6.5985371e-09;
                return ((((c5 * t + c4) * t + c3) * t + c2) * t + c1) * t + c0;
            }
            else
            {
                const double a0 = 9.9983952E2;
                const double a1 = 1.6952577E1;
                const double a2 = -7.9905127E-3;
                const double a3 = -4.6241757E-5;
                const double a4 = 1.0584601E-7;
                const double a5 = -2.8103006E-10;
                const double b = 1.6887236E-2;
                return (((((a5 * t + a4) * t + a3) * t + a2) * t + a1) * t + a0) / (1.0 + b * t);
            }
        }
 		/// <summary>
 		/// Calculate density of distilled water from temperature (obsolete)
 		/// </summary>
 		/// <param name="t">IPTS-68 temperature in [°C]</param>
 		/// <returns>Density in [kg/m3]</returns>
        public static double DistilledWaterDensityFromTempIPTS68(double t)
        {
            const double a0 = 999.842594;
            const double a1 = 0.06793952;
            const double a2 = -0.009095290;
            const double a3 = 0.0001001685;
            const double a4 = -0.000001120083;
            const double a5 = 6.536332e-09;
            return ((((a5 * t + a4) * t + a3) * t + a2) * t + a1) * t + a0;
        }
 		/// <summary>
 		/// Calculate density by comparing calculated data and data from a certificate
 		/// </summary>
 		/// <param name="realDensity">Density from a certificate in [kg/m3]</param>
 		/// <param name="atTemperature">Temperature from a certificate in [°C]</param>
 		/// <returns>Density correction in [kg/m3]</returns>
 		public static double DensityCorrection(double realDensity, double atTemperature)
 		{
 			/// Calculated data
 			double calculatedDensity = DistilledWaterDensityFromTemp(atTemperature);
 			return realDensity - calculatedDensity;
 		}
 		/// <summary>
 		/// Calculate corrected (real) water density from temperature
 		/// </summary>
 		/// <param name="t">Temperature in [°C]</param>
 		/// <returns>Density in [kg/m3]</returns>
 		public static double WaterDensityFromTemp(double t)
 		{
            return DistilledWaterDensityFromTemp(t) + DensityCorrection(RealDensity(), AtTemperature());
 		}
        /// <summary>
        /// Calculate corrected (real) water density from temperature
        /// </summary>
        /// <param name="t">Temperature in [°C]</param>
        /// <returns>Density in [kg/m3]</returns>
        public static double WaterDensityFromTempPress(double temp, double pressure)
        {
            double x0 = 5.08821E-10;
            double x1 = 1.2639418;
            double x2 = 0.2660269;
            double x3 = 0.3734838;
            double x4 = 2.0205242;
            double theta = temp / 100.0;
            double B = x0 * (((x3 * theta + x2) * theta + x1) * theta + 1) / (1 + x4 * theta);
            return WaterDensityFromTemp(temp) * (1 + B * Units.ConvertTo(Unit.Pa, pressure));
        }
 		public static float AirDensityFromAmbientVales(float tempC, float pressureBar, float humiPct)
 		{
 			double pressurePa = 100000.0 * (double)pressureBar;		/// [Pa]
 			double tempKelvin = 273.15 + (double)tempC;
 			double coef1 = 1.2811805 / 10000.0 * tempKelvin * tempKelvin
 						 - 1.950987 / 100.0 * tempKelvin
 						 + 34.04926034
 						 - 6.353631 * 1000.0 / tempKelvin;
 			double coef3 = humiPct / 100.0 * System.Math.Exp(coef1) / pressurePa;
 			double airDensityKgm3 = 0.00348353 * pressurePa * (1.0 - 0.378 * coef3) / tempKelvin;	/// kg/m3
 			return (float)airDensityKgm3;
 		}
 		/// <summary>
 		/// Convert 'pulses' to 'volume', prevent division by zero
 		/// </summary>
 		public static double VolumeFromPulses(int pulses, double pulsesPerLiter)
 		{
 			if (pulsesPerLiter <= double.Epsilon) return 0;
 			return Convert.ToDouble(pulses) / pulsesPerLiter;
 		}
 		/// <summary>
 		/// Calculate the error in % from 'measured' and 'true' volume, prevent division by zero
 		/// </summary>
 		public static double ErrorFromVolumes(double measuredVolume, double trueVolume)
 		{
 			if (-float.Epsilon <= trueVolume && trueVolume <= float.Epsilon)
 			{
 				if (-float.Epsilon <= measuredVolume && measuredVolume <= float.Epsilon)
 				{
 					log.WarnFormat("ErrorFromVolumes({0},{1}) returns {2}", measuredVolume, trueVolume, -100.0);
 					return -100.0;
 				}
 				log.WarnFormat("ErrorFromVolumes({0},{1}) returns {2}", measuredVolume, trueVolume, 99.0);
 				return 99.0;
 			}
 			double error = 100.0 * (measuredVolume - trueVolume) / trueVolume;
 			log.InfoFormat("ErrorFromVolumes({0},{1}) returns {2}", measuredVolume, trueVolume, error);
 			return error;
 		}
        /// <summary>
        /// Calculates corrected value from a list of corrections by interpolation.
        /// It is assumed that values in the list 'corrections' are sorted.
        /// </summary>
        /// <param name="rawMeasurement">Raw uncorrected value</param>
        /// <param name="corrections">Sorted (value, correction) pairs</param>
        /// <returns>Corrected value</returns>
        public static double CorrectedValue(double rawValue, IList<IMeasurementCorrection> corrections)
        {
            return rawValue + GetCorrection(rawValue, corrections);
        }
        /// <summary>
        /// Get a correction from a list of corrections by interpolation.
        /// It is assumed that values in the list 'corrections' are sorted.
        /// </summary>
        /// <param name="rawMeasurement">Raw uncorrected value</param>
        /// <param name="corrections">Sorted (value, correction) pairs</param>
        /// <returns>Corrected value</returns>
        public static double GetCorrection(double rawValue, IList<IMeasurementCorrection> corrections)
        {
            if ((corrections == null) || (corrections.Count == 0)) return 0;    /// No correction
            if (rawValue < corrections[0].Measurement)
            {
                /// rawValue is below the lowest value in the correction table
                return corrections[0].Correction;
            }
            int count = corrections.Count;
            for (int i = 1; i < count; i++)
            {
                if (rawValue < corrections[i].Measurement)
                {
                    double d1 = rawValue - corrections[i - 1].Measurement;
                    double d2 = corrections[i].Measurement - rawValue;
                    if (d1 + d2 <= float.Epsilon)
                    {
                        /// Neigboring values in the corection table are close to each other -> calculate the average
                        return (corrections[i - 1].Correction + corrections[i].Correction) / 2.0;
                    }
                    else
                    {
                        /// Interpolate the correction from neigboring values in the corection table
                        return (corrections[i - 1].Correction * d2 + corrections[i].Correction * d1) / (d1 + d2);
                    }
                }
            }
            /// rawValue is above the highest value in the correction table
            return corrections[count - 1].Correction;
        }
        /// <summary>
        /// Converts a measurement error to a correction (used when preparing correction tables).
        /// </summary>
        /// <param name="measuredValue">Measured value (in arbitrary units)</param>
        /// <param name="error">Measurement error in %</param>
        /// <returns>Correction in the same units as the measured value</returns>
        public static double CorrectionFromError(double measuredValue, double error)
        {
            double trueValue = measuredValue / (1 + error/100);
            double correction = trueValue - measuredValue;
            return correction;
        }
        /// <summary>
        /// Calculates the heat coefficient for water
        /// </summary>
        /// <param name="pressure">Pressure [bar]</param>
 		/// <param name="T_in">Inlet temperature [°C]</param>
 		/// <param name="T_out">Outlet temperature [°C]</param>
        /// <param name="flowMeasuredAtInlet">true = flow measured @inlet, false = flow measured @outlet</param>
        /// <returns> Heat coefficient for water [J/(m3 K)]</returns>
        public static double HeatCoefficientWater(double pressure, double T_in, double T_out, bool flowMeasuredAtInlet)
        {
            if (T_in == T_out) return 0;
            const double R = 461.526;                       /// [J kg^-1 K^-1]
            const double p_star_Pa = 16.53E6;               /// [Pa] (=16.53 MPa)
            const double T_star = 1386.0;                   /// [K]
            double T_in_K = Units.ConvertTo(Unit.K, T_in);
            double T_out_K = Units.ConvertTo(Unit.K, T_out);
            double tau_in = T_star / T_in_K;
            double tau_out = T_star / T_out_K;
 			double pi = Units.ConvertTo(Unit.Pa, pressure) / p_star_Pa;
            double h_in = tau_in * GammaTau(pi, tau_in) * R * T_in_K;
            double h_out = tau_out * GammaTau(pi, tau_out) * R * T_out_K;
            double ni = flowMeasuredAtInlet ? GammaPi(pi, tau_in) * R * T_in_K / p_star_Pa
                                            : GammaPi(pi, tau_out) * R * T_out_K / p_star_Pa;
            return (h_in - h_out) / (ni * (T_in - T_out));
        }
        /// <summary>
        /// gamma(pi) see also STN EN 1434-1 Annex A (A.4)
        /// </summary>
        /// <param name="pi">pi = p / p* where p* = 16.53 MPa</param>
        /// <param name="tau">tau = T* / T where T* = 1386 K</param>
        /// <returns>gamma(pi)</returns>
        static double GammaPi(double pi, double tau)
        {
            double result = 0;
            for (int i = 0; i < 34; i++)
            {
                result -= ni[i] * Ii[i] * Math.Pow(7.1 - pi, Ii[i] - 1) * Math.Pow(tau - 1.222, Ji[i]);
            }
            return result;
        }
        /// <summary>
        /// gamma(tau) see also STN EN 1434-1 Annex A (A.7)
        /// </summary>
        /// <param name="pi">pi = p / p* where p* = 16.53 MPa</param>
        /// <param name="tau">tau = T* / T where T* = 1386 K</param>
        /// <returns>gamma(tau)</returns>
        static double GammaTau(double pi, double tau)
        {
            double result = 0;
            for (int i = 0; i < 34; i++)
            {
                result += ni[i] * Math.Pow(7.1 - pi, Ii[i]) * Ji[i] * Math.Pow(tau - 1.222, Ji[i] - 1);
            }
            return result;
        }
 		/// <summary>
 		/// Conversion of measured resistance of a platinum thermometer to temperature according to ITS-90
 		/// </summary>
 		/// <param name="R">Measured resistance in [°C]</param>
 		/// <param name="R001C">Calibrated resistance in Ohm at 0.01°C</param>
 		/// <param name="a7">Calibrated ITS-90 coefficient a7</param>
 		/// <param name="b7">Calibrated ITS-90 coefficient b7</param>
 		/// <param name="c7">Calibrated ITS-90 coefficient c7</param>
        /// <returns>Temperature in [°C]</returns>
 		public static double PlatinumResistanceTM_ITS90_R2T(double R, double R001C, double a7, double b7, double c7)
 		{
 			double w = R / R001C;			/// ratio
 			double r1 = w - 1.0;
 			double dw = r1 * (a7 + r1 * (b7 + r1 * c7));	/// = a7*r1 + b7*r1^2 + c7*r1^3
 			double wr = w - dw;
 			double x = (wr - 2.64) / 1.64;
 			double sum = 0;
 			for (int i = Di.Length - 1; i >= 0; i--)
 			{
 				sum = sum * x + Di[i];
 			}
 			return sum;
 		}
        /// <summary>
        /// Conversion of measured resistance of a platinum thermometer to temperature using Callendar-Van Dusen equations
        /// </summary>
        /// <param name="R">Measured resistance in [°C]</param>
        /// <param name="R0">Calibrated resistance in Ohm at 0°C</param>
        /// <param name="A">Calibration coefficient a</param>
        /// <param name="B">Calibration coefficient b</param>
        /// <returns>Temperature in [°C]</returns>
        public static double PlatinumResistanceTM_ITS27_R2T(double R, double R0, double A, double B)
        {
            if (R0 * R0 * A * A - 4 * R0 * B * (R0 - R) <= 0) return 0;     /// Out of range
            return (-(R0 * A) + Math.Sqrt(R0 * R0 * A * A - 4 * R0 * B * (R0 - R))) / (2 * R0 * B);
        }
 	}
 }
@@ -21,9 +21,6 @@ namespace Config.Mappings
 			Map(x => x.PressMtrUp);
 			Map(x => x.PressMtrDown);
 			Map(x => x.PressMtrDelta);
 			//Map(x => x.ElectricMtrUp);
 			//Map(x => x.ElectricMtrDown);
 			//Map(x => x.ElectricMtrDelta);
 			Map(x => x.StopBFValve);
 			Map(x => x.ValvesOpen)
 				.CustomType("StringClob")
@@ -17,8 +17,7 @@ namespace Config.Mappings
 			Map(x => x.Qto);
            Map(x => x.Selector);
            Map(x => x.RegValve);
-			Map(x => x.RegulMinStep).Nullable();//older databases may not have this column
+			Map(x => x.FlowMeter);
            Map(x => x.FlowMeter);
 			Map(x => x.PidCoef);
            Map(x => x.StartValve);
            Map(x => x.Diverter);
@@ -1,7 +0,0 @@
 namespace Config
 {
    public class PurchaseResources
    {
    }
 }
@@ -0,0 +1,6 @@
 <?xml version="1.0" encoding="utf-8" ?>
 <configuration>
    <startup> 
        <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.7.2" />
    </startup>
 </configuration>
@@ -1,4 +0,0 @@
 // <autogenerated />
 using System;
 using System.Reflection;
 [assembly: global::System.Runtime.Versioning.TargetFrameworkAttribute(".NETFramework,Version=v4.7.2", FrameworkDisplayName = ".NET Framework 4.7.2")]
@@ -0,0 +1 @@
 22fa51b09dbd9afa4c5d73fd5d4267426f09bc510527f701d437b89d74765cc0
@@ -0,0 +1,18 @@
 C:\VSProjects\proj9\tbf\DataStreamInterfaceTest\bin\Debug\Doc\Software interface for datastream water meters.docx
 C:\VSProjects\proj9\tbf\DataStreamInterfaceTest\bin\Debug\DataStreamInterfaceTest.exe.config
 C:\VSProjects\proj9\tbf\DataStreamInterfaceTest\bin\Debug\DataStreamInterfaceTest.exe
 C:\VSProjects\proj9\tbf\DataStreamInterfaceTest\bin\Debug\DataStreamInterfaceTest.pdb
 C:\VSProjects\proj9\tbf\DataStreamInterfaceTest\bin\Debug\DataStreamInterface.dll
 C:\VSProjects\proj9\tbf\DataStreamInterfaceTest\bin\Debug\DataStreamInterface.pdb
 C:\VSProjects\proj9\tbf\DataStreamInterfaceTest\obj\Debug\DataStreamInterfaceTest.csproj.AssemblyReference.cache
 C:\VSProjects\proj9\tbf\DataStreamInterfaceTest\obj\Debug\DataStreamInterfaceTest.DemoMainWnd.resources
 C:\VSProjects\proj9\tbf\DataStreamInterfaceTest\obj\Debug\DataStreamInterfaceTest.GetDblValueDlg.resources
 C:\VSProjects\proj9\tbf\DataStreamInterfaceTest\obj\Debug\DataStreamInterfaceTest.GetFrameBoundariesDlg.resources
 C:\VSProjects\proj9\tbf\DataStreamInterfaceTest\obj\Debug\DataStreamInterfaceTest.GetIntegerNumberDlg.resources
 C:\VSProjects\proj9\tbf\DataStreamInterfaceTest\obj\Debug\DataStreamInterfaceTest.GetStateDlg.resources
 C:\VSProjects\proj9\tbf\DataStreamInterfaceTest\obj\Debug\DataStreamInterfaceTest.Properties.Resources.resources
 C:\VSProjects\proj9\tbf\DataStreamInterfaceTest\obj\Debug\DataStreamInterfaceTest.csproj.GenerateResource.cache
 C:\VSProjects\proj9\tbf\DataStreamInterfaceTest\obj\Debug\DataStreamInterfaceTest.csproj.CoreCompileInputs.cache
 C:\VSProjects\proj9\tbf\DataStreamInterfaceTest\obj\Debug\DataStre.F4216CC0.Up2Date
 C:\VSProjects\proj9\tbf\DataStreamInterfaceTest\obj\Debug\DataStreamInterfaceTest.exe
 C:\VSProjects\proj9\tbf\DataStreamInterfaceTest\obj\Debug\DataStreamInterfaceTest.pdb
@@ -1,4 +0,0 @@
 // <autogenerated />
 using System;
 using System.Reflection;
 [assembly: global::System.Runtime.Versioning.TargetFrameworkAttribute(".NETFramework,Version=v4.7.2", FrameworkDisplayName = ".NET Framework 4.7.2")]
@@ -18,7 +18,7 @@ namespace Decrypt
        {
            if ((args.Length < 1) || !File.Exists(args[0]))
            {
-                Console.WriteLine(@"Usage:  Decode <file>");
+                Console.WriteLine("Usage:  Decode <file>");
                Console.ReadKey();
                return;
            }
@@ -40,8 +40,9 @@
    <StartupObject>DeviceTest.Program</StartupObject>
  </PropertyGroup>
  <ItemGroup>
-    <Reference Include="log4net, Version=2.0.15.0, Culture=neutral, PublicKeyToken=669e0ddf0bb1aa2a, processorArchitecture=MSIL">
+    <Reference Include="log4net, Version=1.2.12.0, Culture=neutral, PublicKeyToken=669e0ddf0bb1aa2a, processorArchitecture=MSIL">
-      <HintPath>..\packages\log4net.2.0.15\lib\net45\log4net.dll</HintPath>
+      <SpecificVersion>False</SpecificVersion>
      <HintPath>..\packages\log4net.2.0.2\lib\net40-full\log4net.dll</HintPath>
    </Reference>
    <Reference Include="System" />
    <Reference Include="System.Core" />
@@ -1,4 +0,0 @@
 <?xml version="1.0" encoding="utf-8"?>
 <packages>
  <package id="log4net" version="2.0.15" targetFramework="net472" />
 </packages>
@@ -18,7 +18,7 @@ namespace Encrypt
        {
            if ((args.Length < 1) || !File.Exists(args[0]))
            {
-                Console.WriteLine(@"Usage:  Encode <file>");
+                Console.WriteLine("Usage:  Encode <file>");
                Console.ReadKey();
                return;
            }
@@ -49,7 +49,7 @@
      <HintPath>..\packages\Iesi.Collections.4.0.0.4000\lib\net40\Iesi.Collections.dll</HintPath>
    </Reference>
    <Reference Include="log4net">
-      <HintPath>..\packages\log4net.2.0.15\lib\net45\log4net.dll</HintPath>
+      <HintPath>..\packages\log4net.2.0.2\lib\net40-full\log4net.dll</HintPath>
    </Reference>
    <Reference Include="MySql.Data">
      <HintPath>..\packages\MySql.Data.6.6.5\lib\net40\MySql.Data.dll</HintPath>
@@ -23,7 +23,7 @@
    <DebugType>full</DebugType>
    <Optimize>false</Optimize>
    <OutputPath>bin\Debug\</OutputPath>
-    <DefineConstants>DEBUG;TRACE;HEAT_METERS;</DefineConstants>
+    <DefineConstants>DEBUG;TRACE</DefineConstants>
    <ErrorReport>prompt</ErrorReport>
    <WarningLevel>4</WarningLevel>
    <Prefer32Bit>false</Prefer32Bit>
@@ -32,7 +32,7 @@
    <DebugType>pdbonly</DebugType>
    <Optimize>true</Optimize>
    <OutputPath>bin\Release\</OutputPath>
-    <DefineConstants>TRACE;HEAT_METERS;</DefineConstants>
+    <DefineConstants>TRACE</DefineConstants>
    <ErrorReport>prompt</ErrorReport>
    <WarningLevel>4</WarningLevel>
    <Prefer32Bit>false</Prefer32Bit>
@@ -46,8 +46,8 @@
      <SpecificVersion>False</SpecificVersion>
      <HintPath>..\packages\Iesi.Collections.4.0.0.4000\lib\net40\Iesi.Collections.dll</HintPath>
    </Reference>
-    <Reference Include="log4net, Version=2.0.15.0, Culture=neutral, PublicKeyToken=669e0ddf0bb1aa2a, processorArchitecture=MSIL">
+    <Reference Include="log4net">
-      <HintPath>..\packages\log4net.2.0.15\lib\net45\log4net.dll</HintPath>
+      <HintPath>..\packages\log4net.2.0.2\lib\net40-full\log4net.dll</HintPath>
    </Reference>
    <Reference Include="MySql.Data">
      <HintPath>..\packages\MySql.Data.6.6.5\lib\net40\MySql.Data.dll</HintPath>
@@ -1,4 +0,0 @@
 <?xml version="1.0" encoding="utf-8"?>
 <packages>
  <package id="log4net" version="2.0.15" targetFramework="net472" />
 </packages>
@@ -38,8 +38,8 @@
    <Reference Include="Iesi.Collections">
      <HintPath>..\packages\Iesi.Collections.4.0.0.4000\lib\net40\Iesi.Collections.dll</HintPath>
    </Reference>
-    <Reference Include="log4net, Version=2.0.15.0, Culture=neutral, PublicKeyToken=669e0ddf0bb1aa2a, processorArchitecture=MSIL">
+    <Reference Include="log4net">
-      <HintPath>..\packages\log4net.2.0.15\lib\net45\log4net.dll</HintPath>
+      <HintPath>..\packages\log4net.2.0.2\lib\net40-full\log4net.dll</HintPath>
    </Reference>
    <Reference Include="MySql.Data">
      <HintPath>..\packages\MySql.Data.6.6.5\lib\net40\MySql.Data.dll</HintPath>
@@ -62,7 +62,6 @@
  </ItemGroup>
  <ItemGroup>
    <None Include="App.config" />
    <None Include="packages.config" />
  </ItemGroup>
  <ItemGroup>
    <ProjectReference Include="..\Config\Config.csproj">
@@ -16,12 +16,12 @@ namespace MergeResultsDBs
    {
        static void Main(string[] args)
        {
-            Console.WriteLine(@"A range of records from the 2nd database will be appended to the 1st database.");
+            Console.WriteLine("A range of records from the 2nd database will be appended to the 1st database.");
-            Console.WriteLine(@"Enter the 1st (target) database name:");
+            Console.WriteLine("Enter the 1st (target) database name:");
            string firstDB = Console.ReadLine();
-            Console.WriteLine(@"Enter the 2nd database name:");
+            Console.WriteLine("Enter the 2nd database name:");
            string secondDB = Console.ReadLine();
-            Console.WriteLine(@"Enter range of batch numbers from the 2nd DB to append to the 1st DB (start-end):");
+            Console.WriteLine("Enter range of batch numbers from the 2nd DB to append to the 1st DB (start-end):");
            string range = Console.ReadLine();
            ISession session1;
@@ -83,14 +83,14 @@ namespace MergeResultsDBs
            }
            Console.WriteLine(string.Format("Appending batches {0}-{1} from DB {2} to DB {3}", batchNrStart, batchNrEnd, secondDB, firstDB));
-            Console.WriteLine(@"Press 'y' or 'Y' to start, anything else to abort");
+            Console.WriteLine("Press 'y' or 'Y' to start, anything else to abort");
            string response = Console.ReadLine();
            if (response != "y" && response != "Y")
            {
                return;
            }
-            Console.WriteLine(@"PROCESSING DATABASES ...");
+            Console.WriteLine("PROCESSING DATABASES ...");
            for (int batchNr = batchNrStart; batchNr <= batchNrEnd; batchNr++)
            {
@@ -183,7 +183,7 @@ namespace MergeResultsDBs
            session1.Flush();
            session1.Close();
            session2.Close();
-            Console.WriteLine(@"Successfully completed");
+            Console.WriteLine("Successfully completed");
            Console.ReadLine();
        }
    }
@@ -1,4 +0,0 @@
 <?xml version="1.0" encoding="utf-8"?>
 <packages>
  <package id="log4net" version="2.0.15" targetFramework="net472" />
 </packages>
@@ -1,20 +0,0 @@
 <Project Sdk="Microsoft.NET.Sdk">
  <PropertyGroup>
    <TargetFrameworks>net8.0</TargetFrameworks>
    <IsPackable>false</IsPackable>
  </PropertyGroup>
  <ItemGroup>
    <PackageReference Include="JetBrains.Annotations" Version="2023.3.0" />
    <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.14.1" />
    <PackageReference Include="MSTest.TestAdapter" Version="3.10.4" />
    <PackageReference Include="MSTest.TestFramework" Version="3.10.4" />
  </ItemGroup>
  <ItemGroup>
    <ProjectReference Include="..\NfcC7_DLL\NfcC7_DLL.csproj" />
  </ItemGroup>
 </Project>
@@ -1,87 +0,0 @@
 using System;
 using JetBrains.Annotations;
 using Microsoft.VisualStudio.TestTools.UnitTesting;
 using NfcC7_DLL.NfcHanler;
 using NfcC7_DLL.NfcHanler.Protocols;
 using NfcC7_DLL.NfcHanler.Utils;
 namespace NfcC7_DLL.Tests.NfcHanler;
 [TestClass]
 [TestSubject(typeof(NFCHeadService))]
 public class NFCHeadServiceTest
 {
    [TestMethod]
    public void SetTestingMode_Optohead_C7_ON_LiveMeterTest()
    {
        SerialPortData serialPortData = new SerialPortData(
            "COM5",
            "HatCliDemo.exe",
            74);
        NFCHeadService service = new NFCHeadService(serialPortData);
        OptoHeadStatus status = service.SetTestingMode(OptoHeadStatus.OptoHeadC7);
        Assert.AreEqual(OptoHeadStatus.OptoHeadC7, status);
    }
    [TestMethod]
    public void SetTestingMode_Optohead_OFF_LiveMeterTest()
    {
        SerialPortData serialPortData = new SerialPortData(
            "COM5",
            "HatCliDemo.exe",
            74);
        NFCHeadService service = new NFCHeadService(serialPortData);
        OptoHeadStatus status = service.SetTestingMode(OptoHeadStatus.OptoHeadDisabled);
        Assert.AreEqual(OptoHeadStatus.OptoHeadDisabled, status);
    }
    [TestMethod]
    public void SetTestingMode_LiveMeterTest()
    {
        SerialPortData serialPortData = new SerialPortData(
                        "COM5", 
            "HatCliDemo.exe", 
                74);
        NFCHeadService service = new NFCHeadService(serialPortData);
        OptoHeadStatus status = service.SetTestingMode(OptoHeadStatus.OptoHeadC2);
        Assert.AreEqual(OptoHeadStatus.OptoHeadC2, status);
        status = service.SetTestingMode(OptoHeadStatus.OptoHeadC7);
        Assert.AreEqual(OptoHeadStatus.OptoHeadC7, status);
        status = service.SetTestingMode(OptoHeadStatus.OptoHeadDisabled);
        Assert.AreEqual(OptoHeadStatus.OptoHeadDisabled, status);
    }
    [TestMethod]
    public void GetSerialNr_LiveMeterTest()
    {
        SerialPortData serialPortData = new SerialPortData(
            "COM5", 
            "HatCliDemo.exe", 
            74);
        NFCHeadService service = new NFCHeadService(serialPortData);
        string? serialNr = service.GetSerialNr();
        Assert.IsFalse(string.IsNullOrEmpty(serialNr));
        Console.WriteLine("Found serial no: {0}",serialNr);
    }
    [TestMethod]
    public void GetTestingMode_LiveMeterTest()
    {
        SerialPortData serialPortData = new SerialPortData(
            "COM5", 
            "HatCliDemo.exe", 
            74);
        NFCHeadService service = new NFCHeadService(serialPortData);
        OptoHeadStatus status = service.GetTestingMode();
        Assert.IsFalse(OptoHeadStatus.Unknown == status);
    }
 }
@@ -1,71 +0,0 @@
 using JetBrains.Annotations;
 using Microsoft.VisualStudio.TestPlatform.CoreUtilities.Helpers;
 using Microsoft.VisualStudio.TestTools.UnitTesting;
 using NfcC7_DLL.NfcHanler;
 using NfcC7_DLL.NfcHanler.Protocols;
 using NfcC7_DLL.NfcHanler.Utils;
 namespace NfcC7_DLL.Tests.NfcHanler;
 [TestClass]
 [TestSubject(typeof(OptoHeadService))]
 public class OptoHeadServiceTest
 {
    [TestMethod]
    public void RunLoop_Test()
    {
        //Switch meter to Optohead C7 testing mode
        SerialPortData serialPortData = new SerialPortData(
            "COM5",
            "HatCliDemo.exe",
            74);
        NFCHeadService service = new NFCHeadService(serialPortData);
        OptoHeadStatus status = service.SetTestingMode(OptoHeadStatus.OptoHeadC7);
        Assert.AreEqual(OptoHeadStatus.OptoHeadC7, status);
        //Open serial connection to Optohead
        OptoHeadService.Con con = new OptoHeadService.Con();
        con.com = "COM6";
        OptoHeadService optoHeadService = new OptoHeadService(con);
        Assert.IsTrue(optoHeadService.CreateSerialConnection());
        //start loop to receive data
        optoHeadService.RunLoop();
        WaterMetrologyData lastData = null;
        int iCycles = 0,  iCyclesMax = 10;
        for (int i = 0; i < iCyclesMax; i++)
        {
            bool finished = false;
            while (!finished)
            {
                //optoHeadService.Run();
                if (optoHeadService.WaterMetrologyData != null 
                    && lastData != optoHeadService.WaterMetrologyData
                    && optoHeadService.WaterMetrologyData.OptoHeadStatus != OptoHeadStatus.Unknown)
                {
                    lastData = optoHeadService.WaterMetrologyData;
                    finished = true;
                    iCycles++;
                    if (lastData.OptoHeadStatus.HasFlag(OptoHeadStatus.OptoHeadC7))
                    {
                        Assert.IsNotNull(lastData.C7Data);
                    }
                    else
                    {
                        Assert.IsNotNull(lastData.C2Data);
                    }
                    System.Console.WriteLine("Cycle: {0} lastData: {1}", iCycles, lastData);
                }
            }
        }
        optoHeadService.CloseSerialConnection();
        Assert.IsTrue(iCycles > 0);
        Assert.IsTrue(iCycles == iCyclesMax);
        //Close Optohead
        status = service.SetTestingMode(OptoHeadStatus.OptoHeadDisabled);
        Assert.AreEqual(OptoHeadStatus.OptoHeadDisabled, status);
    }
 }
@@ -1,224 +0,0 @@
 using System;
 using System.IO.Ports;
 using JetBrains.Annotations;
 using Microsoft.VisualStudio.TestTools.UnitTesting;
 using NfcC7_DLL.NfcHanler.Utils;
 namespace NfcC7_DLL.Tests.NfcHanler.Utils;
 //[TestClass]
 [TestSubject(typeof(SERIAL_Driver))]
 public class SERIAL_DriverTest
 {
    private class Con
    {
        public string com = "COM5";
        public int baudrate = 38400;
        public int dataBits = 8;
        public Parity parity = Parity.None;
        public StopBits stopbits = StopBits.Two;
        public int readTimeout = 5000;
        public int writeTimeout = 1000;
    }
    private readonly byte[] Open =
    { 0x6B, 0x80, 0x01, 0x10, 0x00, 0x30, 0x00, 0x47, 0x6C, 0x6F, 0x62, 0x61, 0x6C, 0x49, 0x50, 0x65, 0x72,
        0x6C, 0x55, 0x74, 0x69, 0x6C, 0x69, 0x74, 0x79, 0x00, 0x00, 0x27, 0xD7 };
    private readonly byte[] CommDeviceSessionEnd = { 0x6B, 0x61, 0x00, 0x10, 0x05, 0x31, 0x00, 0x1F, 0x29, 0xF9, 0xC5 };
    private readonly byte[] ProductDetails =
        { 0x6B, 0x30, 0x01, 0x10, 0x03, 0x21, 0x01, 0x02, 0x6B, 0x90, 0x00, 0x00, 0x11, 0x40, 0x05, 0x00, 0x02, 0x04, 0x60, 0x62, 0x42, 0x04, 0xA5, 0x64 };
    private readonly byte[] ProductDetails2 =
        { 0x6B, 0x30, 0x01, 0x10, 0x03, 0x21, 0x01, 0x02, 0x6B, 0x90, 0x00, 0x00, 0x11, 0x40, 0x05, 0x00, 0x02, 0x04, 0x60 };
    static Con con5 = new Con(){
        com = "COM5",
        baudrate = 38400,
        dataBits = 8,
        parity = Parity.None,
        stopbits = StopBits.Two,
        readTimeout = 5000,
        writeTimeout = 1000
    };
    static Con con6 = new Con()
    {
        com = "COM6",
        baudrate = 38400,
        dataBits = 8,
        parity = Parity.None,
        stopbits = StopBits.Two,
        readTimeout = 5000,
        writeTimeout = 1000
    };
    //[TestMethod]
    public void SendMessage_Test()
    {
        Con con = con5;
        byte[] message = Open;
        byte[] bytesReceived;
        SERIAL_Driver driver = new SERIAL_Driver();
        bool isopen = driver.OpenConnection(
            con.com,
            con.baudrate, 
            con.dataBits,
            con.parity,
            con.stopbits, 
            con.readTimeout, 
            con.writeTimeout);
        Assert.IsTrue(isopen);
        driver.SendMessage(message, message.Length);
        //Assert.IsTrue(driver.GetRawData().Length == 0);
        bytesReceived = driver.GetRawData();
        //Assert.IsTrue(bytesReceived.Length > 0);
        Console.WriteLine("IsOpened: {0}", driver.isOpen());
        // Display raw bytes (as hex or byte count)
        if (bytesReceived != null)
        {
            Console.WriteLine(string.Format("Bytes received: {0}", bytesReceived.Length));
            Console.WriteLine(string.Format("Bytes (hex): {0}", BitConverter.ToString(bytesReceived)));
            string response = System.Text.Encoding.UTF8.GetString(bytesReceived);
            Console.WriteLine("Bytes string: {0}", response);
        }
        // --- Get Serial No ---
        message = ProductDetails;
        // Send Open message
        bool sendSuccess = driver.SendMessage(message, message.Length);
        Assert.IsTrue(sendSuccess, "Failed to send Open message");
        Console.WriteLine("Sent message for product details: {0}", message.ToString());
        bytesReceived = driver.GetRawData();
        // Display raw bytes (as hex or byte count)
        if (bytesReceived != null)
        {
            Console.WriteLine(string.Format("Bytes received: {0}", bytesReceived.Length));
            Console.WriteLine(string.Format("Bytes (hex): {0}", BitConverter.ToString(bytesReceived)));
            string response = System.Text.Encoding.UTF8.GetString(bytesReceived);
            Console.WriteLine("Bytes string: {0}", response);
        }
        else
        {
            Console.WriteLine("Response not received!");
        }
        message = CommDeviceSessionEnd;
        driver.SendMessage(message, message.Length);
        driver.Close();
    }
    //[TestMethod]
    public void SendMessage_TestLoop()
    {
        Con con = con6;
        byte[] message = {0x00};
        byte[] bytesReceived;
        SERIAL_Driver driver = new SERIAL_Driver();
        bool isopen = driver.OpenConnection(
            con.com,
            con.baudrate, 
            con.dataBits,
            con.parity,
            con.stopbits, 
            con.readTimeout, 
            con.writeTimeout);
        Assert.IsTrue(isopen);
        for (int iStep = 0; iStep < 100; iStep++)
        {
            driver.SendMessage(message, message.Length);
            //Assert.IsTrue(driver.GetRawData().Length == 0);
            bytesReceived = driver.GetRawData();
            Assert.IsTrue(bytesReceived.Length > 0);
            Console.WriteLine("IsOpened: {0}", driver.isOpen());
            // Display raw bytes (as hex or byte count)
            Console.WriteLine(string.Format("Bytes received: {0}", bytesReceived.Length));
            Console.WriteLine(string.Format("Bytes (hex): {0}", BitConverter.ToString(bytesReceived)));
            string response = System.Text.Encoding.UTF8.GetString(bytesReceived);
            Console.WriteLine("Bytes string: {0}", response);
        }
        //message = CommDeviceSessionEnd;
        //driver.SendMessage(message, message.Length);
        driver.CloseConnection();
    }
    //[TestMethod]
    public void SendMessage_TestGetSerialNo()
    {
        Con con = con6;
        byte[] message = Open;
        byte[] bytesReceived;
        SERIAL_Driver driver = new SERIAL_Driver();
        bool isopen = driver.OpenConnection(
            con.com,
            con.baudrate, 
            con.dataBits,
            con.parity,
            con.stopbits, 
            con.readTimeout, 
            con.writeTimeout);
        Assert.IsTrue(isopen);
        driver.SendMessage(message, message.Length,con.readTimeout);
        //Assert.IsTrue(driver.GetRawData().Length == 0);
        bytesReceived = driver.GetRawData();
        Assert.IsTrue(bytesReceived.Length > 0);
        if (bytesReceived[0] == 0xFF)
            Console.WriteLine("Error message: {0}", driver.ErrorMessage);
        // Display raw bytes (as hex or byte count)
        Console.WriteLine("IsOpened: {0}", driver.isOpen());
        Console.WriteLine(string.Format("Bytes received: {0}", bytesReceived.Length));
        Console.WriteLine(string.Format("Bytes (hex): {0}", BitConverter.ToString(bytesReceived)));
        string response = System.Text.Encoding.UTF8.GetString(bytesReceived);
        Console.WriteLine("Bytes string: {0}",response);
        // --- Get Serial No ---
        message = ProductDetails;
        driver.SendMessage(message, message.Length,con.readTimeout);
        bytesReceived = driver.GetRawData();
        Assert.IsTrue(bytesReceived.Length > 0);
        if (bytesReceived[0] == 0xFF)
            Console.WriteLine("Error message: {0}", driver.ErrorMessage);
        // Display raw bytes (as hex or byte count)
        Console.WriteLine("IsOpened: {0}", driver.isOpen());
        Console.WriteLine(string.Format("Bytes received: {0}", bytesReceived.Length));
        Console.WriteLine(string.Format("Bytes (hex): {0}", BitConverter.ToString(bytesReceived)));
        response = System.Text.Encoding.UTF8.GetString(bytesReceived);
        Console.WriteLine("Bytes string: {0}",response);
        // --- Get Serial No ---
        message = ProductDetails2;
        driver.SendMessage(message, message.Length,con.readTimeout);
        bytesReceived = driver.GetRawData();
        Assert.IsTrue(bytesReceived.Length > 0);
        if (bytesReceived[0] == 0xFF)
            Console.WriteLine("Error message: {0}", driver.ErrorMessage);
        // Display raw bytes (as hex or byte count)
        Console.WriteLine("IsOpened: {0}", driver.isOpen());
        Console.WriteLine(string.Format("Bytes received: {0}", bytesReceived.Length));
        Console.WriteLine(string.Format("Bytes (hex): {0}", BitConverter.ToString(bytesReceived)));
        response = System.Text.Encoding.UTF8.GetString(bytesReceived);
        Console.WriteLine("Bytes string: {0}",response);
        message = CommDeviceSessionEnd;
        driver.SendMessage(message, message.Length);
        driver.Close();
    }
 }
@@ -1,52 +0,0 @@
 <Project Sdk="Microsoft.NET.Sdk">
    <PropertyGroup>
        <TargetFramework>net8.0</TargetFramework>
        <ImplicitUsings>enable</ImplicitUsings>
        <Nullable>enable</Nullable>
        <Copyright>Copyright ©  2025</Copyright>
        <AssemblyVersion>1.1.0.0</AssemblyVersion>
        <FileVersion>1.1.0.0</FileVersion>
    </PropertyGroup>
    <PropertyGroup Condition=" '$(Configuration)' == 'Debug' ">
      <DefineConstants>TRACE;IPERL;</DefineConstants>
      <CheckForOverflowUnderflow>true</CheckForOverflowUnderflow>
    </PropertyGroup>
    <PropertyGroup Condition=" '$(Configuration)' == 'Release' ">
      <DefineConstants>TRACE;IPERL;</DefineConstants>
    </PropertyGroup>
    <ItemGroup>
      <PackageReference Include="Newtonsoft.Json" Version="12.0.2" />
      <PackageReference Include="System.IO.Ports" Version="10.0.0-rc.1.25451.107" />
      <PackageReference Include="System.Security.Cryptography.Cng" Version="5.0.0" />
      <PackageReference Include="System.Threading" Version="4.3.0" />
    </ItemGroup>
    <ItemGroup>
      <Reference Include="NA2WNFC">
        <HintPath>NfcHanler\NfcReaderLibrary\NA2WNFC.dll</HintPath>
      </Reference>
      <Reference Include="OBIDISC4NET">
        <HintPath>NfcHanler\NfcReaderLibrary\OBIDISC4NET.dll</HintPath>
      </Reference>
      <Reference Include="OBIDISC4NETnative">
        <HintPath>NfcHanler\NfcReaderLibrary\OBIDISC4NETnative.dll</HintPath>
      </Reference>
      <Reference Include="OBIDISC4NET_API">
        <HintPath>NfcHanler\NfcReaderLibrary\OBIDISC4NET_API.dll</HintPath>
      </Reference>
      <Reference Include="PresentationCore">
        <HintPath>..\..\..\..\..\Windows\Microsoft.NET\assembly\GAC_32\PresentationCore\v4.0_4.0.0.0__31bf3856ad364e35\PresentationCore.dll</HintPath>
      </Reference>
      <Reference Include="PresentationFramework">
        <HintPath>..\..\..\..\..\Windows\Microsoft.NET\assembly\GAC_MSIL\PresentationFramework\v4.0_4.0.0.0__31bf3856ad364e35\PresentationFramework.dll</HintPath>
      </Reference>
      <Reference Include="Sensus">
        <HintPath>NfcHanler\FieldLogicLibrary\Sensus.dll</HintPath>
      </Reference>
    </ItemGroup>
 </Project>
@@ -1,9 +0,0 @@
 using NfcC7_DLL.NfcHanler.Protocols;
 namespace NfcC7_DLL.NfcHanler;
 public class HeadInfo
 {
    string SerialNr { get; set; }
    OptoHeadStatus OptoHeadStatus { get; set; }
 }
@@ -1,22 +0,0 @@
 namespace NfcC7_DLL.NfcHanler
 {
    public class JsonDataFromPoseidon
    {
        public bool? NfcTagDetected { get; set; }
        public int? ProductType { get; set; }
        public string ProductTypeVersion { get; set; }
        public string DeviceId { get; set; }
        public string Reading { get; set; }
        public string Reading_Totalizer { get; set; }
        public string Reading_Digits { get; set; }
        public string Reading_Shift { get; set; }
        public string Reading_Resolution { get; set; }
        public string Reading_Units { get; set; }
        public string Reading_FlowDirection { get; set; }
        public string Reading_FlowRate { get; set; }
        public string CalibrationFactor { get; set; }
        public bool? ReadingComplete { get; set; }
    }
 }
@@ -1,216 +0,0 @@
 using System.Text.RegularExpressions;
 using System.Windows;
 using NfcC7_DLL.NfcHanler.Protocols;
 using NfcC7_DLL.NfcHanler.Utils;
 namespace NfcC7_DLL.NfcHanler;
 public class NFCHeadService
 {
    private bool activeHandlerSessioEnabled = false;
    private CliRunner _cliRunner;
    private SerialPortData serialPort;
    public NFCHeadService(SerialPortData serialPort)
    {
        this.serialPort = serialPort;
        ValidateCliFileExistence(true);
    }
    private CliRunner CliRunner
    {
        get
        {
            return (_cliRunner != null ? 
                _cliRunner : 
                (_cliRunner = new CliRunner(CliLogging)));
        }
    }
    private bool CliLogging{get {return false; }}
    private static readonly Regex OpticalDataModeRegex = new Regex(
        @"(?im)(?:" +
        @"^\s*OpticalDataMode\s*Id\s*:\s*([^\r\n]+)\s*$" +  // old format
        @"|" +
        @"""OpticalDataMode""\s*:\s*""?(0x[0-9A-Fa-f]+|\d+)""?" + // JSON format (handles hex and decimal)
        @")",
        RegexOptions.Compiled);
    public bool TryGetOpticalDataMode(string result, out string s)
    {
        s = null;
        if (string.IsNullOrEmpty(result))
            return false;
        var m = OpticalDataModeRegex.Match(result);
        if (!m.Success)
            return false;
        // one of the groups will be filled
        s = !string.IsNullOrEmpty(m.Groups[1].Value)
            ? m.Groups[1].Value.Trim()
            : m.Groups[2].Value.Trim();
        return true;
    }
    private static readonly Regex DeviceIdRegex = new Regex(
        @"(?im)(?:" +
        @"^\s*Device\s*Id\s*:\s*([^\r\n]+)\s*$" +  // old format
        @"|" +
        @"""DeviceId""\s*:\s*""?([0-9]+)""?" +     // JSON format
        @")",
        RegexOptions.Compiled);
    public bool TryGetDeviceId(string result, out string s)
    {
        s = null;
        if (string.IsNullOrEmpty(result))
            return false;
        var m = DeviceIdRegex.Match(result);
        if (!m.Success)
            return false;
        // one of the groups will be filled
        s = !string.IsNullOrEmpty(m.Groups[1].Value)
            ? m.Groups[1].Value.Trim()
            : m.Groups[2].Value.Trim();
        return true;
    }
    private void ValidateCliFileExistence(bool showErrorIfMissing)
    {
        if (serialPort != null)
        {
            if (!serialPort.CliExists)
            {
                throw new Exception("CLI file " + serialPort.SerialPortCmdClientPath + " does not exist! Current path: " + Environment.CurrentDirectory);
            }
        }
    }
    /// <summary>
    /// ////////////
    /// </summary>
    public string? GetSerialNr()
    {
        if (serialPort == null) 
            throw new Exception("Serial port not initialized");
        Task optoheadDeviceIdTask = CliRunner.AddSendAsync(serialPort, SerialPortData.EMeterArg.DeviceId);
        var timeOut = CliRunner.AddTimeOut(5000);
        var doneTask = CliRunner.WhenAny();
        if (timeOut == doneTask)
        {
            throw new Exception("Timeout");
        }
        else
        {
            if (optoheadDeviceIdTask is Task<string>)
            {
                string serialNr;
                if (optoheadDeviceIdTask.Status == TaskStatus.Faulted)
                    throw new Exception("Error TaskStatus.Faulted");
                string result = (optoheadDeviceIdTask as Task<string>).Result;
                if (TryGetDeviceId(result, out serialNr))
                {
                    return serialNr;
                }
            }
        }
        return null; 
    }
    public OptoHeadStatus SetTestingMode(OptoHeadStatus  status)
    {
        if (serialPort == null) 
            throw new Exception("Serial port not initialized");
        Task optoheadMode = CliRunner.AddSendAsync(serialPort, SerialPortData.EMeterArg.Optohead, $"0x{((byte)status):X2}");
        var timeOut = CliRunner.AddTimeOut(5000);
        var doneTask = CliRunner.WhenAny();
        if (timeOut == doneTask)
        {
            throw new Exception("Timeout");
        }
        else
        {
            if (optoheadMode is Task<string>)
            {
                string strOpticalDataMode;
                if (optoheadMode.Status == TaskStatus.Faulted)
                    throw new Exception("Error TaskStatus.Faulted");
                string result = (optoheadMode as Task<string>).Result;
                if (TryGetOpticalDataMode(result, out strOpticalDataMode))
                {
                    byte value;
                    if (strOpticalDataMode.StartsWith("0x", StringComparison.OrdinalIgnoreCase))
                        value = Convert.ToByte(strOpticalDataMode, 16); // interpret as hex
                    else
                        value = Convert.ToByte(strOpticalDataMode); // interpret as decimal
                    OptoHeadStatus optoheadStatus = (OptoHeadStatus)value;
                    return optoheadStatus;
                }
            }
        }
        return OptoHeadStatus.Unknown;
    }
    public OptoHeadStatus GetTestingMode()
    {
        if (serialPort == null) 
            throw new Exception("Serial port not initialized");
        Task optoheadMode = CliRunner.AddSendAsync(serialPort, SerialPortData.EMeterArg.Optohead);
        var timeOut = CliRunner.AddTimeOut(5000);
        var doneTask = CliRunner.WhenAny();
        if (timeOut == doneTask)
        {
            throw new Exception("Timeout");
        }
        else
        {
            if (optoheadMode is Task<string>)
            {
                string strOpticalDataMode;
                if (optoheadMode.Status == TaskStatus.Faulted)
                    throw new Exception("Error TaskStatus.Faulted");
                string result = (optoheadMode as Task<string>).Result;
                if (TryGetOpticalDataMode(result, out strOpticalDataMode))
                {
                    byte value;
                    if (strOpticalDataMode.StartsWith("0x", StringComparison.OrdinalIgnoreCase))
                        value = Convert.ToByte(strOpticalDataMode, 16); // interpret as hex
                    else
                        value = Convert.ToByte(strOpticalDataMode); // interpret as decimal
                    OptoHeadStatus optoheadStatus = (OptoHeadStatus)value;
                    return optoheadStatus;
                }
            }
        }
        return OptoHeadStatus.Unknown;
    }
    private void SendCommand()
    {
    }
    private string RawDataAnswer()
    {
        return "";
    }
 }
@@ -1,109 +0,0 @@
 using System.IO.Ports;
 using System.Windows.Documents;
 using NfcC7_DLL.NfcHanler.Protocols;
 using NfcC7_DLL.NfcHanler.Utils;
 namespace NfcC7_DLL.NfcHanler;
 public class OptoHeadService
 {
    public class Con
    {
        public string com = "COM5";
        public int baudrate = 38400;
        public int dataBits = 8;
        public Parity parity = Parity.None;
        public StopBits stopbits = StopBits.Two;
        public int readTimeout = 5000;
        public int writeTimeout = 1000;
    }
    private Con Connection { get; set; }
    private SERIAL_Driver driver;
    /// <summary>
    /// Filed After Run() is called.
    /// </summary>
    public WaterMetrologyData? WaterMetrologyData { get; private set; }
    public OptoHeadService(Con con)
    {
        Connection = con;
        driver = new SERIAL_Driver();
    }
    public bool CreateSerialConnection()
    {
        bool isopen = false;
        Con con = Connection;
        byte[] message = {0x00};
        byte[] bytesReceived;
        if (!driver.isOpen())
        {
            isopen = driver.OpenConnection(
                con.com,
                con.baudrate,
                con.dataBits,
                con.parity,
                con.stopbits,
                con.readTimeout,
                con.writeTimeout);
        }
        return isopen;
    }
    public void CloseSerialConnection()
    {
        dissableRunLoop = true;
        driver.Close();
    }
    public void RunLoop()
    {
        Task.Run(() => Run());
    }
    private bool dissableRunLoop = false;
    /// <summary>
    /// Run the service. Catch one communication to WaterMetrologyData field.
    /// </summary>
    public void Run()
    {
        while (!dissableRunLoop)
        {
            WaterMetrologyData = ParseData(RunReading());    
        }
    }
    byte[] RunReading()
    {
        if (driver.isOpen())
        {
            driver.SendMessage(new byte[] {0x00}, 1);
            return driver.GetRawData();     
        }
        else
        {
            dissableRunLoop = true;
        }
        return [0xFF];
    }
    public WaterMetrologyData? ParseData(byte[] data)
    {
        try
        {
            return WaterMetrologyData.Parse(data, DateTime.Now, "");
        }catch(Exception e)
        {
            return null;
        }
    }
 }
@@ -1,9 +0,0 @@
 namespace NfcC7_DLL.NfcHanler.Protocols;
 public enum OptoHeadStatus : byte
 {
    Unknown = 0xFF,
    OptoHeadDisabled = 0x00,
    OptoHeadC2 = 0xC2,
    OptoHeadC7 = 0xC7,
 }
@@ -1,41 +0,0 @@
 namespace NfcC7_DLL.NfcHanler.Protocols;
 public class WaterMetrologyData
 {
    private OptoHeadStatus _optoHeadStatus;
    private WaterMetrologyDataC7 c7Data;
    private WaterMetrologyDataC2 c2Data;
    public WaterMetrologyDataC7 C7Data { get => c7Data; }
    public WaterMetrologyDataC2 C2Data { get => c2Data; }
    public OptoHeadStatus OptoHeadStatus { get => _optoHeadStatus; }
    public static WaterMetrologyData? Parse(byte[] data, DateTime dt, string dutinfo)
    {
        if (data.Length < 24)
        {
            throw new ArgumentException("Invalid data length for WaterMetrologyData C2.");
        }
        WaterMetrologyData waterMetrologyData = new WaterMetrologyData();
        waterMetrologyData._optoHeadStatus = OptoHeadStatus.Unknown;
        // Probably C2
        if(data.Length > 24 && data.Length <  48)
        {
            waterMetrologyData.c2Data = WaterMetrologyDataC2.Parse(data, dt, dutinfo);
            waterMetrologyData._optoHeadStatus = OptoHeadStatus.OptoHeadC2;
        }
        // Probably C7
        else if(data.Length >=  48)
        {
            waterMetrologyData.c7Data = WaterMetrologyDataC7.Parse(data, dt, dutinfo);
            waterMetrologyData._optoHeadStatus = OptoHeadStatus.OptoHeadC7;
        }
        return waterMetrologyData;
    }
    public override string ToString()
    {
        return $"Status: {_optoHeadStatus}, C7Data: {c7Data}, C2Data: {c2Data}";
    }
 }
@@ -1,91 +0,0 @@
 namespace NfcC7_DLL.NfcHanler.Protocols
 {
    public class WaterMetrologyDataC2
    {
        public string DutInfo { get; set; }
        public DateTime Dt { get; set; }
        public int AdcSample { get; set; }
        public short LastField { get; set; }
        public short FlowRate { get; set; }
        public uint Accumulator { get; set; }
        public ushort FlipPeriod { get; set; }
        public ushort VinfStart { get; set; }
        public ushort VinfEnd { get; set; }
        public short ElectrodeDelta { get; set; }
        public ushort Impedance { get; set; }
        public byte FieldDriveTime { get; set; }
        public bool IsInLowFlow { get; set; }
        public bool IsInEmptyPipe { get; set; }
        public bool FastHPFC { get; set; }
        public bool FieldPolarity { get; set; }
        public bool ImpedancePolarity { get; set; }
        public double CalcFlowmLps
        {
            get { return FlowRate / 4.0; } // FlowRate is in 1/4 mL/s
        }
        public double CalcFlowGPM
        {
            get { return CalcFlowmLps * 0.015850323141489; } // mL/s to gal/min conversion
        }
        public double CalcAccGal
        {
            get { return (Accumulator / 4.0) * 0.000264172; } // Accumulator is in 1/4 mL, convert to gallons
        }
        public static WaterMetrologyDataC2 Parse(string base64Data, DateTime dt, string dutinfo)
        {
            byte[] data = Convert.FromBase64String(base64Data);
            return Parse(data, dt, dutinfo);
        }
        public static WaterMetrologyDataC2 Parse(byte[] data, DateTime dt, string dutinfo)
        {
            if (data.Length < 24)
            {
                throw new ArgumentException("Invalid data length for WaterMetrologyData C2.");
            }
            WaterMetrologyDataC2 result = new WaterMetrologyDataC2();
            result.DutInfo = dutinfo;
            result.Dt = dt;
            result.AdcSample = BitConverter.ToInt32(data, 0);
            result.LastField = BitConverter.ToInt16(data, 4);
            result.FlowRate = BitConverter.ToInt16(data, 6);
            result.Accumulator = BitConverter.ToUInt32(data, 8);
            result.FlipPeriod = BitConverter.ToUInt16(data, 12);
            result.VinfStart = BitConverter.ToUInt16(data, 14);
            result.VinfEnd = BitConverter.ToUInt16(data, 16);
            result.ElectrodeDelta = BitConverter.ToInt16(data, 18);
            result.Impedance = BitConverter.ToUInt16(data, 20);
            result.FieldDriveTime = data[22];
            byte flags = data[23];
            result.IsInLowFlow = (flags & 0x01) != 0;
            result.IsInEmptyPipe = (flags & 0x02) != 0;
            result.FastHPFC = (flags & 0x04) != 0; // Fast High Pass Filter Constant in bit 2
            result.FieldPolarity = (flags & 0x08) != 0;     // Field Polarity in bit 3
            result.ImpedancePolarity = (flags & 0x10) != 0;     // Impedance Polarity in bit 4
            return result;
        }
        //public override string ToString()
        //{
        //    return $"ADC Sample: {AdcSample}, Last Field: {LastField}, Flow Rate: {FlowRate}, Accumulator: {Accumulator}, " +
        //                   $"Flip Period Ticks: {FlipPeriodTicks}, Vinf Start: {VinfStart}, Vinf End: {VinfEnd}, Electrode Delta: {ElectrodeDelta}, " +
        //                   $"Impedance: {Impedance}, Field Drive Time: {FieldDriveTime}, Is Low Flow: {IsInLowFlow}, Is Empty Pipe: {IsInEmptyPipe}, " +
        //                   $"Fast High Pass Filter: {FastHighPassFilterConstant}, Field Polarity: {FieldPolarity}, Impedance Polarity: {ImpedancePolarity}";
        //}
        public override string ToString()
        {
            return $"DutInfo: {DutInfo}, Dt: {Dt}, ADC Sample: {AdcSample}, Last Field: {LastField}, Flow Rate: {FlowRate}, Accumulator: {Accumulator}, " +
                   $"Flip Period: {FlipPeriod}, Vinf Start: {VinfStart}, Vinf End: {VinfEnd}, Electrode Delta: {ElectrodeDelta}, " +
                   $"Impedance: {Impedance}, Field Drive Time: {FieldDriveTime}, Is Low Flow: {IsInLowFlow}, Is Empty Pipe: {IsInEmptyPipe}, " +
                   $"Fast HPFC: {FastHPFC}, Field Polarity: {FieldPolarity}, Impedance Polarity: {ImpedancePolarity}, " +
                   $"Calc Flow mL/s: {CalcFlowmLps:F2}, Calc Flow GPM: {CalcFlowGPM:F2}, Calc Acc Gal: {CalcAccGal:F2}";
        }
    }
 }
@@ -1,92 +0,0 @@
 namespace NfcC7_DLL.NfcHanler.Protocols
 {
    public class WaterMetrologyDataC7 : WaterMetrologyDataC2
    {
        // New fields for C7
        public int LastFieldmilliGauss { get; set; }
        public int ImpedanceI { get; set; } // In-phase impedance
        public int ImpedanceQ { get; set; } // Out-of-phase impedance
        public int NoiseMetric { get; set; }
        public short LearningLockout { get; set; }
        public short ReverseBuffer { get; set; }
        public int ConditionedAdc { get; set; }
        public uint Totalalizer { get; set; }
        //public bool IsInLowFlow { get; set; }
        //public bool IsInEmptyPipe { get; set; }
        //public bool FastHPFC { get; set; }
        //public bool FieldPolarity { get; set; }
        //public bool ImpedancePolarity { get; set; }
        public bool MagTamperState { get; set; }
        public bool IsLearningActive { get; set; }
        public bool AdcShiftsUpdated { get; set; }
        public static WaterMetrologyDataC7 Parse(string base64Data, DateTime dt, string dutinfo)
        {
            byte[] data = Convert.FromBase64String(base64Data);
            return Parse(data, dt, dutinfo);
        }
        public static WaterMetrologyDataC7 Parse(byte[] data, DateTime dt, string dutinfo)
        {
            // You may want to check for the minimum length required for C7
            if (data.Length <  48)  /* minimum required length for C7 */
            {
                throw new ArgumentException("Invalid data length for WaterMetrologyData C7.");
            }
            var result = new WaterMetrologyDataC7();
            // Parse base C2 fields
            var c2 = WaterMetrologyDataC2.Parse(data, dt, dutinfo);
            //Copy base fields
            result.DutInfo = c2.DutInfo;
            result.Dt = c2.Dt;
            result.AdcSample = c2.AdcSample;
            result.LastField = c2.LastField;
            result.FlowRate = c2.FlowRate;
            result.Accumulator = c2.Accumulator;
            result.FlipPeriod = c2.FlipPeriod;
            result.VinfStart = c2.VinfStart;
            result.VinfEnd = c2.VinfEnd;
            result.ElectrodeDelta = c2.ElectrodeDelta;
            result.Impedance = c2.Impedance;
            result.FieldDriveTime = c2.FieldDriveTime;
            result.IsInLowFlow = c2.IsInLowFlow;
            result.IsInEmptyPipe = c2.IsInEmptyPipe;
            result.FieldPolarity = c2.FieldPolarity;
            result.ImpedancePolarity = c2.ImpedancePolarity;
            // Parse new C7 fields (replace ENUM_OptPack0xC7.FIELD_MILLI_GAUSS etc. with actual offsets)
            byte flags = data[23];
            result.MagTamperState = (flags & 0x60) != 0; // bits 5 and 6 represent MagTamperState
            result.IsLearningActive = (flags & 0x80) != 0; // bit 7 represents IsLearningActive
            byte flagTwo = data[24];
            result.AdcShiftsUpdated  = (flagTwo & 0x01) != 0; // bit 0 represents AdcShiftsUpdated
            result.LastFieldmilliGauss = BitConverter.ToInt32(data, 25);
            result.ImpedanceI = BitConverter.ToInt32(data, 29); //  in phase  
            result.ImpedanceQ = BitConverter.ToInt32(data, 33); // out of phase
            result.NoiseMetric = BitConverter.ToInt32(data, 37); // 
            result.LearningLockout = BitConverter.ToInt16(data, 41);
            result.ReverseBuffer = BitConverter.ToInt16(data, 43);
            result.ConditionedAdc = BitConverter.ToInt32(data, 45);
            result.Totalalizer = BitConverter.ToUInt32(data, 49);
            return result;
        }
        public override string ToString()
        {
            return $"C7: LastFieldmilliGauss={LastFieldmilliGauss}, ImpedanceI={ImpedanceI}, ImpedanceQ={ImpedanceQ}, NoiseMetric={NoiseMetric}, LearningLockout={LearningLockout}, ReverseBuffer={ReverseBuffer}, ConditionedAdc={ConditionedAdc}, Totalalizer={Totalalizer}, MagTamperState={MagTamperState}, IsLearningActive={IsLearningActive}, AdcShiftsUpdated={AdcShiftsUpdated}" + base.ToString();
        }
    }
 }
@@ -1 +0,0 @@
 # Protocol Description
@@ -1,262 +0,0 @@
 using System.Diagnostics;
 using System.Reflection;
 using System.Text;
 using Newtonsoft.Json;
 using Newtonsoft.Json.Linq;
 namespace NfcC7_DLL.NfcHanler.Utils
 {
    public class CliRunner
    {
        //static readonly Logger log = LogManager.GetLogger(typeof(CliRunner));
        //private readonly ILog log;
        private List<Task> taskPool = new List<Task>();
        private long startTime;
        public List<Task> TaskPool { get { return taskPool; } }
        public void AddTask(Task task) { taskPool.Add(task); }
        public void WaitAll() { Task.WaitAll(taskPool.ToArray()); }
        /// <summary>
        /// continue with WhenAny() to commpare results if time out is reached
        /// </summary>
        /// <param name="timeout"></param>
        /// <returns></returns>
        public Task AddTimeOut(int timeout)
        {
            Task timeOut = Task.Delay(timeout); 
            taskPool.Add(timeOut);
            return timeOut;
        }
        /// <summary>
        /// mainly used for time out additional task to compare results
        /// </summary>
        /// <returns></returns>
        public Task WhenAny() { return Task.WhenAny(taskPool.ToArray()); }
        public void Clear() { taskPool.Clear(); }
        public void CancelAll() { Task.WhenAll(taskPool).ContinueWith(t => { }); }
        public void StartAll()
        {
            taskPool.ForEach(t => t.Start());
        }
        public bool AreTasksDone()
        {
            return taskPool.All(task => task.IsCompleted);
        }
        public long StartTime
        {
            get => startTime;
        }
        public bool TimeOutReceived(long timeout)
        {
            return (DateTime.Now.Ticks - startTime) > timeout;       
        }
        public CliRunner(bool isCliLogging)
        {
            startTime = DateTime.Now.Ticks;
            if (isCliLogging)
            {
                try
                {
                    /*log = new ScopedLoggerFactory().CreateLogger<CliRunner>(
                        @"C:\TBF\Logs\CliRunner.txt",
                        10, // maxFileSizeMB
                        7,  // maxBackups
                        log4net.Core.Level.Debug,
                        true,                   // zipRolledFiles
                        true,                   // singleZipPerDay
                        TimeSpan.FromMinutes(2) // zipScanInterval
                    );*/
                }
                catch (Exception ex)
                {
                    // Fallback to console or handle gracefully
                    Console.WriteLine($"Failed to initialize logger: {ex.Message}");
                }
            }
        }
        /// <summary>
        /// 
        /// </summary>
        /// <param name="fileName"></param>
        /// <param name="args"></param>
        /// <typeparam name="T"></typeparam>
        public Task AddSendAsync(SerialPortData data, SerialPortData.EMeterArg eMeterArg)
        {
            var task = SendAsync(data.SerialPortCmdClientPath, data.DefaultArgSettingsRead(eMeterArg));
            taskPool.Add(task);
            return task;
        }
        public Task AddSendAsync(SerialPortData data, SerialPortData.EMeterArg eMeterArg, string arg)
        {
            var task = SendAsync(data.SerialPortCmdClientPath, data.DefaultArgSettingsWrite(eMeterArg, arg));
            taskPool.Add(task);
            return task;
        }
        public void AddSendAsync(string fileName, string args)
        {
            var task = SendAsync(fileName, args);
            taskPool.Add(task);
        }
        public async Task<string> SendAsync(string fileName, string args, CancellationToken ct = default)
        {
            var psi = new ProcessStartInfo
            {
                FileName = fileName,
                Arguments = args,
                RedirectStandardOutput = true,
                RedirectStandardError = true,
                UseShellExecute = false,
                CreateNoWindow = true
            };
            using var process = new Process { StartInfo = psi, EnableRaisingEvents = true };
            process.Start();
            Task<string> stdOutTask = process.StandardOutput.ReadToEndAsync();
            Task<string> stdErrTask = process.StandardError.ReadToEndAsync();
            try
            {
                await Task.WhenAll(stdOutTask, stdErrTask, process.WaitForExitAsync(ct));
            }
            catch (OperationCanceledException)
            {
                if (!process.HasExited)
                {
                    process.Kill();
                }
                throw;
            }
            string allOutput = (stdOutTask.Result ?? "") + (stdErrTask.Result ?? "");
            //log?.Debug(allOutput);
            return allOutput;
        }
        public Task<T> AddRunAndCaptureJsonAsync<T>(SerialPortData data, SerialPortData.EMeterArg eMeterArg) where T : new()
        {
            var task = RunAndCaptureJsonAsync<T>(data.SerialPortCmdClientPath, data.DefaultArgSettingsRead(eMeterArg));
            taskPool.Add(task);
            return task;
        }
        public async Task<T> RunAndCaptureJsonAsync<T>(string fileName, string args, CancellationToken ct = default) where T : new()
        {
            var psi = new ProcessStartInfo
            {
                FileName = fileName,
                Arguments = args,
                RedirectStandardOutput = true,
                RedirectStandardError = true,
                UseShellExecute = false,
                CreateNoWindow = true
            };
            using var process = new Process { StartInfo = psi, EnableRaisingEvents = true };
            process.Start();
            var stdoutTask = process.StandardOutput.ReadToEndAsync();
            var stderrTask = process.StandardError.ReadToEndAsync();
            await Task.WhenAll(stdoutTask, stderrTask, process.WaitForExitAsync(ct));
            string allOutput = (stdoutTask.Result ?? "") + (stderrTask.Result ?? "");
            //log?.Debug(allOutput);
            string json = ExtractJson(allOutput);
            if (TryJsonStringDeserialize(json, out T result)) return result;
            return default;
        }
        public bool TryJsonStringDeserialize<T>(string json, out T runAndCaptureJsonAsync) where T : new()
        {
            if (json != null)
            {
                try
                {
                    runAndCaptureJsonAsync = JsonConvert.DeserializeObject<T>(json);
                    return true;
                }
                catch (Exception ex)
                {
                   // log.Debug(ex.Message);
                    runAndCaptureJsonAsync = TryConvert<T>(json);
                    return true;
                }
            }
            runAndCaptureJsonAsync = default;
            return false;
        }
        private static T TryConvert<T>(string json) where T : new()
        {
                T obj = new T();
                try
                {
                    JObject jObject = JObject.Parse(json);
                    foreach (PropertyInfo prop in typeof(T).GetProperties(BindingFlags.Public | BindingFlags.Instance))
                    {
                        if (!prop.CanWrite) continue;
                        JToken token;
                        if (jObject.TryGetValue(prop.Name, StringComparison.OrdinalIgnoreCase, out token))
                        {
                            try
                            {
                                object value = token.ToObject(prop.PropertyType);
                                prop.SetValue(obj, value);
                            }
                            catch
                            {
                                // leave default if conversion fails
                            }
                        }
                        // else → keep default value
                    }
                }
                catch (Exception ex)
                {
                    Console.WriteLine($"TryConvert failed: {ex.Message}");
                }
                return obj;
        }
        public string ExtractJson(string text)
        {
            int start = text.IndexOf('{');
            int end = text.LastIndexOf('}');
            if (start >= 0 && end > start)
            {
                return text.Substring(start, end - start + 1);
            }
            return null;
        }
    }
 }
@@ -1,36 +0,0 @@
 using System.Diagnostics;
 namespace NfcC7_DLL.NfcHanler.Utils
 {
    public static class ProcessExtensions
    {
        public static Task WaitForExitAsync(this Process process, CancellationToken cancellationToken = default)
        {
            if (process == null) throw new ArgumentNullException(nameof(process));
            if (process.HasExited) return Task.CompletedTask;
            var tcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously);
            EventHandler handler = null;
            handler = (s, e) =>
            {
                try { tcs.TrySetResult(null); }
                finally { process.Exited -= handler; }
            };
            process.EnableRaisingEvents = true;
            process.Exited += handler;
            if (cancellationToken.CanBeCanceled)
            {
                cancellationToken.Register(() =>
                {
                    tcs.TrySetCanceled(cancellationToken);
                    process.Exited -= handler;
                });
            }
            return tcs.Task;
        }
    }
 }
@@ -1,167 +0,0 @@
 using System.Collections.ObjectModel;
 using System.Diagnostics;
 using System.IO.Ports;
 //*****************************************************************************
 // Copyright 2020 Sensus GmbH Ludwigshafen. All rights reserved.
 // Author: Venkat, Rajeshwar
 //*****************************************************************************
 namespace NfcC7_DLL.NfcHanler.Utils
 {
    public class SERIAL_Driver
    {
        public string ErrorMessage { get; private set; }
        public Collection<byte> SerialPortReadBuffer = new Collection<byte>();
        private SerialPort _serialPort;
        private List<byte[]> _binMessages = new List<byte[]>();
        private bool _isReading;
        private Parity Parity { get; set; }
        private StopBits StopBits { get; set; }
        public SERIAL_Driver()
        {
            _serialPort = new SerialPort();
        }
        public bool OpenConnection(string comPort, int baudrate, int dataBits, Parity parity, StopBits stopbits, int readTimeout=1000, int writeTimeout = 1000)
        {
            lock (this)
            {
                if ((_serialPort != null) && (_serialPort.IsOpen))
                {
                    _serialPort.DataReceived -= DataReceivedHandler;
                    _serialPort.Close();
                    _serialPort.Dispose();
                    _serialPort = null;
                }
                try
                {
                     ErrorMessage = "";
                    //_serialPort = new SerialPort(comPort, 57600, Parity.None, 8, StopBits.Two);
 					_serialPort = new SerialPort(comPort, baudrate, parity, dataBits, stopbits);
                    _serialPort.ReadTimeout = readTimeout;
                    _serialPort.WriteTimeout = writeTimeout;
                    _serialPort.DataReceived += new SerialDataReceivedEventHandler(DataReceivedHandler);
                    _serialPort.Open();
                }
                catch (Exception ex)
                {
                    ErrorMessage = String.Format("COM error: Open failed {0}.{1}", comPort, ex.Message);
                    return false;
                }
                if (!_serialPort.IsOpen)
                {
                    ErrorMessage = String.Format("COM error: Can't Open {0}.", comPort);
                    return false;
                }
            }//End Lock
            return true;
        }
        public bool SendMessage(byte[] sendDataBytes, int length, int readTimeout = 1000, int writeTimeout=1000)
        {
            if (!isOpen()) return false;
            if (sendDataBytes.Length == 0) return true;  // nothing to send - no error
            try
            {
                 PrepareReading();   //clear read buffer etc.
                _serialPort.WriteTimeout = writeTimeout;
                _serialPort.ReadTimeout = readTimeout;
                _serialPort.Write(sendDataBytes, 0, length);
                _isReading = true;
                Thread.Sleep(100);                
                var stopWatch = Stopwatch.StartNew(); //start stop watch for data recevie timeout
                while (_isReading) //wait until reading finishes or timeout occur
                {
                    if (stopWatch.ElapsedMilliseconds > readTimeout)
                    {
                        stopWatch.Stop();
                        ErrorMessage = "COM error: Receive timeout";
                        return false;
                    }
                }
            }
            catch (Exception ex)
            {
                ErrorMessage = String.Format("COM error: Transmit timeout {0}.{1}", _serialPort.PortName, ex.Message);
                return false;  // Exception in send function
            }            
            return true;
        }
        private void PrepareReading()
        {
            _serialPort.DiscardInBuffer();
            if(_binMessages != null) _binMessages.Clear();        
            _isReading = true;
        }
        public byte[] GetRawData()
        {
            try
            {
                if (_binMessages.Count > 0) 
                    return _binMessages[0].ToArray();
                else
                {
                    return null;
                }
            }
            catch(Exception)
            {
                byte[] err = { 0xFF };
                return err;
            }
        }
        private void DataReceivedHandler(object sender, SerialDataReceivedEventArgs e)
        {
            if (!_serialPort.IsOpen) return;
            lock (this)
            {
                Thread.Sleep(100);
                if (!_serialPort.IsOpen) return;
                SerialPortReadBuffer = new Collection<byte>();
                while (_serialPort.BytesToRead > 0)
                {
                    SerialPortReadBuffer.Add((byte)_serialPort.ReadByte());                    
                }
                _binMessages.Add(SerialPortReadBuffer.ToArray());                
                _isReading = false;
            }
        }
        public void CloseConnection()
        {
            if ((_serialPort != null) && (_serialPort.IsOpen))
            {
                _serialPort.DataReceived -= DataReceivedHandler;
                _serialPort.Close();
                _serialPort.Dispose();
                _serialPort = null;
            }
        }
        public void Close()
        {
            if (isOpen())
            {
                _serialPort.Close();
            }
        }
        public void Dispose()
        {
            if (_serialPort != null)
            {
                _serialPort.Dispose();
            }
        }
        public bool isOpen()
        {  
            if(_serialPort != null)
               return _serialPort.IsOpen;
            return false;
        }
    }
 }
@@ -1,72 +0,0 @@
 namespace NfcC7_DLL.NfcHanler.Utils
 {
    public class SerialPortData
    {
        private Boolean? _cliExists;
        public bool CliExists { get {
            if (_cliExists == null || !_cliExists.HasValue)
            {
                _cliExists = File.Exists(SerialPortCmdClientPath);
            } 
            return _cliExists.Value;
        } }
        public string SerialPortCmdClientPath {
            get { 
 #if DEBUG
                return Path.Combine("C:","TBF","Cli", CmdClientName);
 #else
                return Path.Combine("..","Cli", CmdClientName); 
 #endif
            }
        } 
        public string CmdClientName { get; set; } = "HalCli.exe";
        public string PortName { get; set; }
        public int MeterType { get; set; }
        public enum EMeterArg {
            Calibration = 0,
            AllParams = 2,
            DeviceId = 3,
            Optohead = 4,
        } 
        EMeterArg _eMeterArg = EMeterArg.AllParams;
        public string DefaultArgSettingsRead(EMeterArg eMeterArg)
        {
            switch (eMeterArg)
            {
                case EMeterArg.AllParams:
                    return $"-p {PortName} -m {MeterType} --operation readall";
                case EMeterArg.DeviceId:
                    return $"-p {PortName} -m {MeterType} --operation read --parameter DeviceId";
                case EMeterArg.Optohead:
                    return $"-p {PortName} -m {MeterType} --operation read --parameter \"OpticalDataMode\""; 
                default:
                    throw new Exception("Not implemented correct command!");
            }
        }
        public string DefaultArgSettingsWrite(EMeterArg eMeterArg, string arg)
        {
            switch (eMeterArg)
            {
                case EMeterArg.Calibration:
                    return $"-p {PortName} -m {MeterType} --operation write --parameter Calibration --value {arg}";
                case EMeterArg.Optohead:
                    return $"-p {PortName} -m {MeterType} --operation write --parameter \"OpticalDataMode\" --value {arg}"; 
                default:
                    throw new Exception("Not implemented correct command!");
            }
        }
        public SerialPortData(
            string portName,
            string cmdClientName,
            int meterType)
        {
            PortName = portName;
            CmdClientName = cmdClientName;
            MeterType = meterType;
        }
    }
 }
@@ -1,156 +0,0 @@
 using System.Text;
 //*****************************************************************************
 // Copyright 2020 Sensus GmbH Ludwigshafen. All rights reserved.
 // Author: Venkat, Rajeshwar
 //*****************************************************************************
 namespace NfcC7_DLL.NfcHanler.Utils
 {
 	public static class Tools
 	{
 		public static bool ByteArrayCompare(byte[] a1, byte[] a2)
 		{
 			// thanks to https://stackoverflow.com/questions/43289/comparing-two-byte-arrays-in-net
 			if (a1.Length != a2.Length)
 				return false;
 			for (int i = 0; i < a1.Length; i++)
 				if (a1[i] != a2[i])
 					return false;
 			return true;
 		}
 		public static string SwapHex(string sHex)
 		{
 			string sResult = "";
 			int iPos = sHex.Length - 2;
 			while (iPos >= 0)
 			{
 				sResult += sHex.Substring(iPos, 2);
 				sHex = sHex.Remove(iPos, 2);
 				iPos = sHex.Length - 2;
 			}
 			return sResult;
 		}
        public static string DecimalToHexString(string value, int size = 1)
        {
            try
            {
                long Lval = long.Parse(value);
                if (size == 1) return Lval.ToString("X2");
                if (size == 2) return Lval.ToString("X4");
                if (size == 4) return Lval.ToString("X8");
            }
            catch (Exception)
            {
                if (size == 1) return "00";
                if (size == 2) return "0000";
                if (size == 4) return "00000000";
            }
            return "00";
        }
        public static string ByteToHexString(byte data)
        {
            List<byte> val = new List<byte>();
            val.Add(data);
            byte[] arr = val.ToArray();
            return BytesToHex(arr); 
        }
        public static string BytesToHex(byte[] data)
 		{
 			StringBuilder sb = new StringBuilder();
 			foreach (byte b in data)
 				sb.Append(b.ToString("X2"));
 			return sb.ToString();
 		}
 		public static byte[] HexStringToByteArray(String hexString)
 		{
 			int numberChars = hexString.Length;
 			byte[] bytes = new byte[numberChars / 2];
 			for (int i = 0; i < numberChars; i += 2)
 			{
 				bytes[i / 2] = Convert.ToByte(hexString.Substring(i, 2), 16);
 			}
 			return bytes;
 		}
        public enum InitialCrcValue
 		{
 			Zeros,
 			NonZero1 = 0xffff,
 			NonZero2 = 0x1D0F
 		}
        public class Crc16Ccitt
 		{
            private const ushort poly = 0x1021;
 			ushort[] table = new ushort[256];
 			ushort initialValue = 0;
            public ushort ComputeChecksum(byte[] bytes)
            {
                ushort crc = this.initialValue;
                for (int i = 0; i < bytes.Length; ++i)
                {
                    crc = (ushort)((crc << 8) ^ table[((crc >> 8) ^ (0xff & bytes[i]))]);
                }
                return crc;
            }
            public byte[] ComputeChecksumBytes(byte[] bytes)
            {
                ushort crc = ComputeChecksum(bytes);
                return BitConverter.GetBytes(crc);
            }
            public Crc16Ccitt(InitialCrcValue initialValue)
 			{
 				this.initialValue = (ushort) initialValue;
 				ushort temp, a;
 				for (int i = 0; i < table.Length; ++i)
 				{
 					temp = 0;
 					a = (ushort) (i << 8);
 					for (int j = 0; j < 8; ++j)
 					{
 						if (((temp ^ a) & 0x8000) != 0)
 						{
 							temp = (ushort) ((temp << 1) ^ poly);
 						}
 						else
 						{
 							temp <<= 1;
 						}
 						a <<= 1;
 					}
 					table[i] = temp;
 				}
 			}
 			public byte[] calcCRCfromMessage(byte[] message)
 			{
 				// CRC calculation goes from MessageID to Password
 				// For Read this means MsgID (1) + Offset (2) + PayloadLength (1) + Password (2) = 6
 				// for write the length of the payload comes on top.
 				// STX(1), length(1), CRC(2) and ETX(1) are excluded, in total 5 bytes.
 				//
 				// the method works both for sending messages (where the CRC and ETX are not in message)
 				// and for receiving messages (where the CRC and ETX are included at the end)
 				byte[] crc_msg = new byte[message[1]];  // message length is 2nd byte
 				Array.Copy(message, 2, crc_msg, 0, crc_msg.Length);
 				return ComputeChecksumBytes(crc_msg);
 			}
 			public string commentCRC(byte[] crc_meter, byte[] crc_computed)
            {
 				bool crc_do_match = Tools.ByteArrayCompare(crc_meter, crc_computed);
 				string crcComment = crc_do_match ? "ok." : "CRC DOESN'T MATCH!!";
 				return "CRC Meter: " + Tools.BytesToHex(crc_meter) + (crc_do_match ? " == " : " != ")
 					+ "CRC Computed: " + Tools.BytesToHex(crc_computed) + ". " + crcComment;
 			}
 			public bool crc_do_match(byte[] a, byte[] b)
            {
 				return ByteArrayCompare(a, b);
 			}
 		}
 	}
 }
@@ -48,8 +48,8 @@
    <Reference Include="Iesi.Collections">
      <HintPath>..\packages\Iesi.Collections.4.0.0.4000\lib\net40\Iesi.Collections.dll</HintPath>
    </Reference>
-    <Reference Include="log4net, Version=2.0.15.0, Culture=neutral, PublicKeyToken=669e0ddf0bb1aa2a, processorArchitecture=MSIL">
+    <Reference Include="log4net">
-      <HintPath>..\packages\log4net.2.0.15\lib\net45\log4net.dll</HintPath>
+      <HintPath>..\packages\log4net.2.0.2\lib\net40-full\log4net.dll</HintPath>
    </Reference>
    <Reference Include="MySql.Data">
      <HintPath>..\packages\MySql.Data.6.6.5\lib\net40\MySql.Data.dll</HintPath>
@@ -1,4 +0,0 @@
 <?xml version="1.0" encoding="utf-8"?>
 <packages>
  <package id="log4net" version="2.0.15" targetFramework="net472" />
 </packages>
@@ -49,8 +49,8 @@
      <HintPath>..\packages\Iesi.Collections.4.0.0.4000\lib\net40\Iesi.Collections.dll</HintPath>
      <Private>True</Private>
    </Reference>
-    <Reference Include="log4net, Version=2.0.15.0, Culture=neutral, PublicKeyToken=669e0ddf0bb1aa2a, processorArchitecture=MSIL">
+    <Reference Include="log4net">
-      <HintPath>..\packages\log4net.2.0.15\lib\net45\log4net.dll</HintPath>
+      <HintPath>..\packages\log4net.2.0.2\lib\net40-full\log4net.dll</HintPath>
    </Reference>
    <Reference Include="MySql.Data, Version=6.6.5.0, Culture=neutral, PublicKeyToken=c5687fc88969c44d, processorArchitecture=MSIL">
      <SpecificVersion>False</SpecificVersion>
@@ -3,5 +3,4 @@
  <package id="FluentNHibernate" version="2.0.3.0" targetFramework="net40" />
  <package id="Iesi.Collections" version="4.0.0.4000" targetFramework="net40" />
  <package id="NHibernate" version="4.0.4.4000" targetFramework="net40" />
  <package id="log4net" version="2.0.15" targetFramework="net472" />
 </packages>
@@ -34,8 +34,8 @@
    <Reference Include="Gma.QrCodeNet.Encoding">
      <HintPath>..\packages\QrCode.Net.0.4.0.0\net40\Gma.QrCodeNet.Encoding.dll</HintPath>
    </Reference>
-    <Reference Include="log4net, Version=2.0.15.0, Culture=neutral, PublicKeyToken=669e0ddf0bb1aa2a, processorArchitecture=MSIL">
+    <Reference Include="log4net">
-      <HintPath>..\packages\log4net.2.0.15\lib\net45\log4net.dll</HintPath>
+      <HintPath>..\packages\log4net.2.0.2\lib\net40-full\log4net.dll</HintPath>
    </Reference>
    <Reference Include="NHibernate">
      <HintPath>..\packages\NHibernate.4.0.4.4000\lib\net40\NHibernate.dll</HintPath>
@@ -1,4 +0,0 @@
 <?xml version="1.0" encoding="utf-8"?>
 <packages>
  <package id="log4net" version="2.0.15" targetFramework="net472" />
 </packages>
@@ -38,7 +38,7 @@ namespace ResetBatchNr
            ls.BatchNr = 1;
            ls.Save();
-            Console.WriteLine(@"BatchNr was reset to 1");
+            Console.WriteLine("BatchNr was reset to 1");
            Console.ReadLine();
            return;
        }
@@ -181,18 +181,6 @@ namespace Results.Entities
            return WaterMeters.Count - PassedMetersCount();
        }
        public virtual int PassedMetersCountE15()
        {
            int count = 0;
            foreach (var mtr in WaterMeters) if (mtr.PassedFromTestsE15()) count++;
            return count;
        }
        public virtual int FailedMetersCountE15()
        {
            return WaterMeters.Count - PassedMetersCountE15();
        }
        public virtual long ErrorFlags()
        {
            long result = 0;
@@ -29,12 +29,8 @@ namespace Results.Entities
        public virtual long   ErrorIndicators { get; set; }		/// Not mapped to DB !!!, bit24=E25, bit25=E26, bit26=E27, bit27=E28 (error flags)
        public virtual long   InfoIndicators  { get; set; }		/// Not mapped to DB !!!, bit24=E25, bit25=E26, bit26=E27, bit27=E28 (info flags)
 		public virtual bool   TestDone		  { get; set; }		/// true = test was completed
-		public virtual bool   Passed		  { get; set; }     /// true = test passed, water meter is OK
+		public virtual bool   Passed		  { get; set; }		/// true = test passed, water meter is OK
 #if IPERL
        public virtual int CalibFactor { get; set; }
        public virtual int CalibFactorLNA { get; set; }
        public virtual int Q2CorrRL { get; set; }
        public virtual int Q2CorrLR { get; set; }
        public virtual string ExtraDataPath   { get; set; }     /// Relative path to a file with opto-data/raw-data
        public virtual float  X1              { get; set; }
        public virtual float  X2              { get; set; }
@@ -170,10 +166,6 @@ namespace Results.Entities
 		    TestDone        = src.TestDone;
            Passed          = src.Passed;
 #if IPERL
            CalibFactor = src.CalibFactor;
            CalibFactorLNA = src.CalibFactorLNA;
            Q2CorrRL = src.Q2CorrRL;
            Q2CorrLR = src.Q2CorrLR;
            ExtraDataPath = src.ExtraDataPath;
            X1 = src.X1;
            X2 = src.X2;
@@ -217,10 +209,6 @@ namespace Results.Entities
            writer.Write(TestDone);
            writer.Write(Passed);
 #if IPERL
            writer.Write(CalibFactor);
            writer.Write(CalibFactorLNA);
            writer.Write(Q2CorrRL);
            writer.Write(Q2CorrLR);
            writer.Write((ExtraDataPath != null) ? ExtraDataPath : string.Empty);
            writer.Write(X1);
            writer.Write(X2);
@@ -261,10 +249,6 @@ namespace Results.Entities
            TestDone = reader.ReadBoolean();
            Passed = reader.ReadBoolean();
 #if IPERL
            CalibFactor = reader.ReadInt32();
            CalibFactorLNA = reader.ReadInt32();
            Q2CorrRL = reader.ReadInt32();
            Q2CorrLR = reader.ReadInt32();
            ExtraDataPath = reader.ReadString();
            X1 = reader.ReadSingle();
            X2 = reader.ReadSingle();
@@ -1,37 +0,0 @@
 using System.Collections.Generic;
 namespace Results.Entities
 {
    public class PurchaseBox
    {
        public virtual int    Id { get; protected set; }
        public virtual string BoxNo { get; set; }
        public virtual PurchaseOrder PurchaseOrder { get; set; }
        public virtual IList<PurchaseWaterMeterData> PurchaseWaterMeterDataList { get; set; }
        public PurchaseBox()
        {
            PurchaseWaterMeterDataList = new List<PurchaseWaterMeterData>();
        }
        public PurchaseBox(string boxNo, PurchaseOrder purchaseOrder)
        {
            PurchaseWaterMeterDataList = new List<PurchaseWaterMeterData>();
            BoxNo = boxNo;
            PurchaseOrder = purchaseOrder;
        }
        /// <summary>
        /// constructor
        /// </summary>
        /// <param name="boxNo"></param>
        /// <param name="boxDataId">unused now</param>
        /// <param name="purchaseOrder"></param>
        public PurchaseBox(string boxNo, int boxDataId, PurchaseOrder purchaseOrder)
        {
            PurchaseWaterMeterDataList = new List<PurchaseWaterMeterData>();
            BoxNo = boxNo;
            PurchaseOrder = purchaseOrder;
        }
    }
 }
@@ -1,33 +0,0 @@
 insert into 'wrcswindon298-r'.purchase_orderdata (Id, PurchaseOrder)
 values  (1, 'Order 123'),
    (2, 'Order 124'),
    (3, 'Order 125');
 insert into 'wrcswindon298-r'.purchase_boxdata (Id, BoxNo, PurchaseOrderId)
 values  (2, 'B 001', 3),
    (3, 'B 002', 2),
    (4, 'B 003', 1),
    (5, 'B 011', 3),
    (6, 'B 012', 2),
    (7, 'B 013', 1);
 insert into 'wrcswindon298-r'.purchase_watermeterdata (Id, SerialNo, WaterMeterData_id, PurchaseBoxId)
 values  (2, 'SN-123456-1', null, 2),
        (3, 'SN_123456-2', null, 2),
        (4, 'SN_123456-3', null, 2),
        (5, 'SN_123456-4', null, 2),
        (6, 'SN_132456-5', null, 2),
        (7, 'SN_123456-6', null, 2),
        (8, 'SN-123457-1', null, 5),
        (9, 'SN_123457-2', null, 5),
        (10, 'SN_123457-3', null, 5),
        (11, 'SN_123457-4', null, 5),
        (12, 'SN_132457-5', null, 5),
        (13, 'SN_123457-6', null, 5),
        (14, 'SN-1234-1', null, 2),
        (15, 'SN_1234-2', null, 3),
        (16, 'SN_1234-3', null, 4),
        (17, 'SN_1234-4', null, 5),
        (18, 'SN_1324-5', null, 6),
        (19, 'SN_1234-6', null, 7);
@@ -1,41 +0,0 @@
 create table purchase_orderdata
 (
    Id            int auto_increment
        primary key,
    PurchaseOrder varchar(255) null
 );
 create table purchase_boxdata
 (
    Id              int auto_increment
        primary key,
    BoxNo           varchar(255) null,
    PurchaseOrderId int          null comment 'index to Purchase order',
    constraint purchase_boxdata_toOrder___fk
        foreign key (PurchaseOrderId) references purchase_orderdata (Id)
 );
 create index idx_boxdata_boxNo
    on purchase_boxdata (BoxNo);
 create index idx_orderdata_purchaseOrder
    on purchase_orderdata (PurchaseOrder);
 create table purchase_watermeterdata
 (
    Id                int auto_increment
        primary key,
    SerialNo          varchar(255) null,
    WaterMeterData_id int          null,
    PurchaseBoxId     int          null,
    constraint UKgcnskfro3he4kwysdeldnvubf
        unique (WaterMeterData_id),
    constraint FKc376smwypchilry1au44u2uj6
        foreign key (WaterMeterData_id) references watermeter (Id),
    constraint purchase_watermeterdata_purchase_boxdata_Id_fk
        foreign key (PurchaseBoxId) references purchase_boxdata (Id)
 );
 create index idx_watermeterdata_serialNo
    on purchase_watermeterdata (SerialNo);
@@ -1,22 +0,0 @@
 using System.Collections.Generic;
 namespace Results.Entities
 {
    public class PurchaseOrder
    {
        public virtual int    Id { get; protected set; }
        public virtual string Name { get; set; }
        public virtual IList<PurchaseBox> PurchaseBoxList { get; set; }
        public PurchaseOrder()
        {
            PurchaseBoxList = new List<PurchaseBox>();
        }
        public PurchaseOrder(string name)
        {
            PurchaseBoxList = new List<PurchaseBox>();
            Name = name;
        }
    }
 }
--- a/Show More
+++ b/Show More
		`@@ -0,0 +1 @@`
							`22fa51b09dbd9afa4c5d73fd5d4267426f09bc510527f701d437b89d74765cc0`