From a37fbc17efcf60102b8d3bb5c248ed4c6aaa8b02 Mon Sep 17 00:00:00 2001
From: vvzvlad <git@vvzvlad.xyz>
Date: Tue, 30 May 2023 17:42:36 +0700
Subject: [PATCH] add modbus_err_stats.py util

---
 modbus_err_stats.py | 57 +++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 57 insertions(+)
 create mode 100755 modbus_err_stats.py

diff --git a/modbus_err_stats.py b/modbus_err_stats.py
new file mode 100755
index 0000000..824d426
--- /dev/null
+++ b/modbus_err_stats.py
@@ -0,0 +1,57 @@
+#!/usr/bin/env python3
+import subprocess
+import re
+import os
+import json
+
+def restart_service():
+    subprocess.Popen(["systemctl", "restart", "wb-mqtt-serial"], stdout=subprocess.PIPE)
+
+def parse_config_file(filename):
+    with open(filename, "r") as file:
+        config_data = json.load(file)
+
+    device_to_port = {}
+    device_errors = {}
+    for port in config_data["ports"]:
+        for device in port["devices"]:
+            device_to_port[device["slave_id"]] = port["path"]
+            device_errors[device["slave_id"]] = 0  # Initialize error count as zero
+
+    return device_to_port, device_errors
+
+def parse_journal(device_to_port, device_errors):
+    p = subprocess.Popen(["journalctl", "-f", "-u", "wb-mqtt-serial"], stdout=subprocess.PIPE)
+    last_log_line = None
+
+    for line in iter(p.stdout.readline, b''):
+        line = line.decode('utf-8')  # convert bytes to string
+        match = re.search(r'modbus:(\d+): Serial protocol error: request timed out', line)
+        if match:
+            device_number = match.group(1)
+            device_errors[device_number] += 1
+        last_log_line = line
+
+        # clear the console
+        os.system('cls' if os.name == 'nt' else 'clear')
+
+        # print the last log line
+        print(f"Last log line: {last_log_line}")
+
+        # print error statistics
+        print_error_statistics(device_errors, device_to_port)
+
+def print_error_statistics(device_errors, device_to_port):
+    print("\n--- Error Statistics ---")
+
+    # sort by error count
+    sorted_device_errors = sorted(device_errors.items(), key=lambda x: x[1], reverse=True)
+
+    for device, error_count in sorted_device_errors:
+        device_port = device_to_port.get(device, "Unknown port")
+        print(f"Device number {device}\t(port: {device_port})\t had {error_count} errors")
+
+if __name__ == "__main__":
+    restart_service()
+    device_to_port, device_errors = parse_config_file("/mnt/data/etc/wb-mqtt-serial.conf")
+    parse_journal(device_to_port, device_errors)