Updated FW-Version

Software/data_src/index.htm

@@ -10,6 +10,7 @@
   <link rel="stylesheet" href="static/css/tweaks.css">
   <script src="static/js/jquery.min.js"></script>
   <script src="static/js/bootstrap.min.js"></script>
+  <script src="static/js/websocket.js"></script>
   <link rel="apple-touch-icon" sizes="180x180" href="static/img/apple-touch-icon.png">
   <link rel="icon" type="image/png" sizes="32x32" href="static/img/favicon-32x32.png">
   <link rel="icon" type="image/png" sizes="16x16" href="static/img/favicon-16x16.png">
@@ -523,6 +524,19 @@
         </table>
         </p>
         <hr />
+        <p>
+          <h4>Live Debug</h4>
+            <div class="form-group row">
+              <textarea class="form-control" spellcheck="false" id="livedebug-out" rows="3" readonly></textarea>
+            </div>
+            <div class="form-group row">
+              <div class="col text-center">
+                <button id="btn-ws-start" class="btn btn-outline-primary">Start</button>
+                <button id="btn-ws-stop" class="btn btn-outline-primary ml-2">Stop</button>
+              </div>
+            </div>
+          </p>
+          <hr />
       </div>
       <!-- Div Tab SystemInfo -->
       <!-- Div Tab Firmware Update-->
@@ -662,7 +676,12 @@
       $.getJSON('static/tt_dtc/dtc_' + dtc + '.json', function (data) {
         modal.find('.modal-title').text(data.title)
         modal.find('.dtc-desc').text(data.description)
-        modal.find('.dtc-debugval').text(debugval)
+        if (debugval > 0) {
+          modal.find('.dtc-debugval').text("Debugvalue: " + debugval)
+        }
+        else {
+          modal.find('.dtc-debugval').remove()
+        }
       }).fail(function () {
         console.log("An error has occurred.");
         modal.find('.modal-title').text("Fehler")

Software/data_src/static/css/tweaks.css

@@ -18,3 +18,10 @@ hr {
     background-color: gray
 }
 
+.dtc-debugval {
+    color: #F2771A;
+    font: 0.8rem Inconsolata, monospace;
+    background-color: black;
+    padding: 10px;
+}
+

Software/data_src/static/js/websocket.js

@@ -0,0 +1,68 @@
+var gateway = `ws://${window.location.hostname}/ws`;
+var websocket;
+
+window.addEventListener("load", onLoad);
+
+function initWebSocket() {
+  console.log("Trying to open a WebSocket connection...");
+  websocket = new WebSocket(gateway);
+  websocket.onopen = onOpen;
+  websocket.onclose = onClose;
+  websocket.onmessage = onMessage; // <-- add this line
+}
+
+function initButtons() {
+  document
+    .getElementById("btn-ws-stop")
+    .addEventListener("click", livedebug_stop);
+  document
+    .getElementById("btn-ws-start")
+    .addEventListener("click", livedebug_start);
+}
+
+function onOpen(event) {
+  console.log("Connection opened");
+}
+
+function onClose(event) {
+  console.log("Connection closed");
+  setTimeout(initWebSocket, 2000);
+}
+
+function onMessage(event) {
+  var livedebug_out = document.getElementById("livedebug-out");
+  var textarea_heigth = livedebug_out.scrollHeight;
+  livedebug_out.value += event.data;
+  livedebug_out.scrollTop = livedebug_out.scrollHeight;
+  do_resize(livedebug_out);
+}
+
+function onLoad(event) {
+  initWebSocket();
+  initButtons();
+}
+
+function livedebug_start() {
+  websocket.send("start");
+}
+
+function livedebug_stop() {
+  websocket.send("stop");
+}
+
+function do_resize(textbox) {
+  var maxrows = 15;
+  var minrows = 3;
+  var txt = textbox.value;
+  var cols = textbox.cols;
+
+  var arraytxt = txt.split("\n");
+  var rows = arraytxt.length;
+
+  for (i = 0; i < arraytxt.length; i++)
+    rows += parseInt(arraytxt[i].length / cols);
+
+  if (rows > maxrows) textbox.rows = maxrows;
+  else if (rows < minrows) textbox.rows = minrows;
+  else textbox.rows = rows;
+}

Software/platformio.ini

@@ -33,12 +33,12 @@ build_flags =
   -DWIFI_AP_IP_GW=10,0,0,1
   -DATOMIC_FS_UPDATE
   -DFEATURE_ENABLE_WIFI_CLIENT
-  -DFEATURE_ENABLE_REMOTE_DEBUG
   -DFEATURE_ENABLE_OLED
   -DFEATURE_ENABLE_CAN
-  -DFEATURE_ENABLE_GPS
+  ;-DFEATURE_ENABLE_GPS
+  -DFEATURE_ENABLE_WEBSOCKETS
   -DPCB_REV=4
-  -DNO_MODE_FLASH
+  ;-DNO_MODE_FLASH
 
 ;build_type = debug
 
@@ -52,8 +52,7 @@ board_build.ldscript = eagle.flash.4m1m.ld
 lib_ldf_mode = deep
 lib_deps = 
     olikraus/U8g2 @ ^2.28.8
-    joaolopesf/RemoteDebug @ ^2.1.2
-    fastled/FastLED @ ^3.5.0
+    https://github.com/FastLED/FastLED.git#3d2ab78 ;fastled/FastLED @ ^3.5.0
     sstaub/Ticker @ ^4.2.0
     coryjfowler/mcp_can @ ^1.5.0
     robtillaart/I2C_EEPROM @ ^1.5.2

Software/src/can.cpp

@@ -23,9 +23,11 @@ uint32_t Process_CAN_WheelSpeed()
     can_frame canMsg;
     static uint32_t lastRecTimestamp = 0;
     uint16_t RearWheelSpeed_raw;
+    uint32_t milimeters_to_add = 0;
 
     if (CAN0.readMsgBuf(&canMsg.can_id, &canMsg.can_dlc, canMsg.data) == CAN_OK)
     {
+
         RearWheelSpeed_raw = (uint16_t)canMsg.data[5] << 8 | canMsg.data[6];
         // raw / FACTOR_RWP_KMH_890ADV -> km/h * 100000 -> cm/h / 3600 -> cm/s
         // raw * 500 -> cm/s
@@ -34,13 +36,14 @@ uint32_t Process_CAN_WheelSpeed()
         uint32_t timesincelast = millis() - lastRecTimestamp;
         lastRecTimestamp = millis();
 
-        uint32_t milimeters_to_add = (RWP_millimeter_per_second * timesincelast) / 1000;
-
-        return milimeters_to_add;
+        milimeters_to_add = (RWP_millimeter_per_second * timesincelast) / 1000;
     }
 
-    MaintainDTC(DTC_NO_CAN_SIGNAL, DTC_CRITICAL, (millis() > lastRecTimestamp + 10000 ? true : false));
+    if (lastRecTimestamp != 0)
+    {
+        MaintainDTC(DTC_NO_CAN_SIGNAL, DTC_CRITICAL, (millis() > lastRecTimestamp + 10000 ? true : false));
+    }
 
-    return 0;
+    return milimeters_to_add;
 }
 #endif

Software/src/common.h

@@ -26,8 +26,8 @@
 #define HOST_NAME "ChainLube_%06X" // Use printf-Formatting - Chip-ID (uin32_t) will be added
 #endif
 
-#define SW_VERSION 1.3
-#define FLASH_FS_VERSION 1.3
+#define SW_VERSION 1.4
+#define FLASH_FS_VERSION 1.4
 
 #ifndef OTA_DELAY
 #define OTA_DELAY 50 // ticks -> 10ms / tick

Software/src/config.cpp

@@ -1,4 +1,5 @@
 #include "config.h"
+#include "debugger.h"
 
 I2C_eeprom ee(0x50, EEPROM_SIZE_BYTES);
 
@@ -25,45 +26,45 @@ void EEPROM_Process()
   case EE_CFG_SAVE:
     StoreConfig_EEPROM();
     globals.requestEEAction = EE_IDLE;
-    Serial.println("Stored EEPROM CFG");
+    Debug_pushMessage("Stored EEPROM CFG\n");
     break;
   case EE_CFG_LOAD:
     GetConfig_EEPROM();
     globals.requestEEAction = EE_IDLE;
-    Serial.println("Loaded EEPROM CFG");
+    Debug_pushMessage("Loaded EEPROM CFG\n");
     break;
   case EE_CFG_FORMAT:
     FormatConfig_EEPROM();
     globals.requestEEAction = EE_IDLE;
     globals.systemStatus = sysStat_Shutdown;
-    Serial.println("Formated EEPROM CFG");
+    Debug_pushMessage("Formated EEPROM CFG\n");
     break;
   case EE_PDS_SAVE:
     StorePersistence_EEPROM();
     globals.requestEEAction = EE_IDLE;
-    Serial.println("Stored EEPROM PDS");
+    Debug_pushMessage("Stored EEPROM PDS\n");
     break;
   case EE_PDS_LOAD:
     GetPersistence_EEPROM();
     globals.requestEEAction = EE_IDLE;
-    Serial.println("Loaded EEPROM PDS");
+    Debug_pushMessage("Loaded EEPROM PDS\n");
     break;
   case EE_PDS_FORMAT:
     FormatPersistence_EEPROM();
     globals.requestEEAction = EE_IDLE;
-    Serial.println("Formated EEPROM PDS");
+    Debug_pushMessage("Formated EEPROM PDS\n");
     break;
   case EE_FORMAT_ALL:
     FormatConfig_EEPROM();
     FormatPersistence_EEPROM();
     globals.requestEEAction = EE_IDLE;
-    Serial.println("Formated EEPROM ALL");
+    Debug_pushMessage("Formated EEPROM ALL\n");
     break;
   case EE_ALL_SAVE:
     StorePersistence_EEPROM();
     StoreConfig_EEPROM();
     globals.requestEEAction = EE_IDLE;
-    Serial.println("Stored EEPROM ALL");
+    Debug_pushMessage("Stored EEPROM ALL\n");
     break;
   case EE_IDLE:
   default:
@@ -153,7 +154,7 @@ void GetPersistence_EEPROM()
 
 void FormatConfig_EEPROM()
 {
-  Serial.println("Formatting Config-Partition");
+  Debug_pushMessage("Formatting Config-Partition\n");
   LubeConfig = LubeConfig_defaults;
   LubeConfig.EEPROM_Version = eeVersion;
   StoreConfig_EEPROM();
@@ -161,8 +162,9 @@ void FormatConfig_EEPROM()
 
 void FormatPersistence_EEPROM()
 {
-  Serial.println("Formatting Persistance-Partition");
-  memset(&PersistenceData, 0, sizeof(PersistenceData));
+  Debug_pushMessage("Formatting Persistance-Partition\n");
+  PersistenceData = {0};
+  // memset(&PersistenceData, 0, sizeof(PersistenceData));
   StorePersistence_EEPROM();
 }
 
@@ -211,9 +213,9 @@ void dumpEEPROM(uint16_t memoryAddress, uint16_t length)
 
   char ascii_buf[BLOCK_TO_LENGTH + 1];
   sprintf(ascii_buf, "%*s", BLOCK_TO_LENGTH, "ASCII");
-  Serial.print(PSTR("\nAddress "));
+  Debug_pushMessage(PSTR("\nAddress "));
   for (int x = 0; x < BLOCK_TO_LENGTH; x++)
-    Serial.printf("%3d", x);
+    Debug_pushMessage("%3d", x);
 
   memoryAddress = memoryAddress / BLOCK_TO_LENGTH * BLOCK_TO_LENGTH;
   length = (length + BLOCK_TO_LENGTH - 1) / BLOCK_TO_LENGTH * BLOCK_TO_LENGTH;
@@ -224,16 +226,16 @@ void dumpEEPROM(uint16_t memoryAddress, uint16_t length)
     if (blockpoint == 0)
     {
       ascii_buf[BLOCK_TO_LENGTH] = 0;
-      Serial.printf("  %s", ascii_buf);
-      Serial.printf("\n0x%05X:", memoryAddress);
+      Debug_pushMessage("  %s", ascii_buf);
+      Debug_pushMessage("\n0x%05X:", memoryAddress);
     }
     ascii_buf[blockpoint] = ee.readByte(memoryAddress);
-    Serial.printf(" %02X", ascii_buf[blockpoint]);
+    Debug_pushMessage(" %02X", ascii_buf[blockpoint]);
     if (ascii_buf[blockpoint] < 0x20 || ascii_buf[blockpoint] > 0x7E)
       ascii_buf[blockpoint] = '.';
     memoryAddress++;
   }
-  Serial.println();
+  Debug_pushMessage("\n");
 }
 
 boolean checkEEPROMavailable()
@@ -241,7 +243,6 @@ boolean checkEEPROMavailable()
   if (!ee.isConnected())
   {
     MaintainDTC(DTC_NO_EEPROM_FOUND, DTC_CRITICAL, true);
-    globals.systemStatus = sysStat_Error;
     return false;
   }
   MaintainDTC(DTC_NO_EEPROM_FOUND, DTC_CRITICAL, false);
@@ -273,11 +274,11 @@ uint32_t ConfigSanityCheck(bool autocorrect)
       LubeConfig.tankCapacity_ml = LubeConfig_defaults.tankCapacity_ml;
   }
 
-  if (!(LubeConfig.amountPerDose_µl > 0) || !(LubeConfig.amountPerDose_µl < 100))
+  if (!(LubeConfig.amountPerDose_microL > 0) || !(LubeConfig.amountPerDose_microL < 100))
   {
     setting_reset_bits = setting_reset_bits | (1 << 3);
     if (autocorrect)
-      LubeConfig.amountPerDose_µl = LubeConfig_defaults.amountPerDose_µl;
+      LubeConfig.amountPerDose_microL = LubeConfig_defaults.amountPerDose_microL;
   }
 
   if (!(LubeConfig.TankRemindAtPercentage >= 0) || !(LubeConfig.TankRemindAtPercentage <= 100))

Software/src/config.h

@@ -8,7 +8,11 @@
 #include "dtc.h"
 #include "common.h"
 
+#if PCB_REV == 1 || PCB_REV == 2 || PCB_REV == 3
+#define EEPROM_SIZE_BYTES I2C_DEVICESIZE_24LC64
+#elif PCB_REV == 4
 #define EEPROM_SIZE_BYTES I2C_DEVICESIZE_24LC256
+#endif
 
 typedef enum SpeedSource_e
 {
@@ -64,7 +68,7 @@ const size_t SpeedSourceString_Elements = sizeof(SpeedSourceString) / sizeof(Spe
 typedef struct
 {
   uint16_t writeCycleCounter = 0;
-  uint32_t tankRemain_µl = 0;
+  uint32_t tankRemain_microL = 0;
   uint32_t TravelDistance_highRes_mm = 0;
   uint32_t odometer_mm = 0;
   uint32_t odometer = 0;
@@ -77,7 +81,7 @@ typedef struct
   uint32_t DistancePerLube_Default = 8000;
   uint32_t DistancePerLube_Rain = 4000;
   uint32_t tankCapacity_ml = 320;
-  uint32_t amountPerDose_µl = DEFAULT_PUMP_DOSE;
+  uint32_t amountPerDose_microL = DEFAULT_PUMP_DOSE;
   uint8_t TankRemindAtPercentage = 30;
   uint8_t PulsePerRevolution = 1;
   uint32_t TireWidth_mm = 150;
@@ -95,7 +99,7 @@ typedef struct
   uint32_t checksum = 0;
 } LubeConfig_t;
 
-const LubeConfig_t LubeConfig_defaults{
+const LubeConfig_t LubeConfig_defaults = {
     0, 8000, 4000, 320, DEFAULT_PUMP_DOSE, 30, 1, 150, 70, 18, 2000, 25, SOURCE_IMPULSE,
 #ifdef FEATURE_ENABLE_GPS
     BAUD_115200,

Software/src/debugger.cpp

@@ -0,0 +1,253 @@
+#include "debugger.h"
+
+DebugStatus_t DebuggerStatus[dbg_cntElements];
+
+String IpAddress2String(const IPAddress &ipAddress);
+void processCmdDebug();
+void Debug_formatCFG();
+void Debug_formatPersistence();
+void Debug_printSystemInfo();
+void Debug_printWifiInfo();
+void Debug_CheckEEPOM();
+void Debug_dumpConfig();
+void Debug_dumpPersistance();
+void Debug_ShowDTCs();
+void Debug_dumpGlobals();
+
+void initDebugger()
+{
+    DebuggerStatus[dbg_Serial] = disabled;
+    DebuggerStatus[dbg_Webui] = disabled;
+
+    Serial.setDebugOutput(false);
+}
+
+void SetDebugportStatus(DebugPorts_t port, DebugStatus_t status)
+{
+    if (status == disabled)
+        Debug_pushMessage("disable DebugPort %s", sDebugPorts[port]);
+
+    DebuggerStatus[port] = status;
+
+    if (status == enabled)
+        Debug_pushMessage("enabled DebugPort %s", sDebugPorts[port]);
+}
+
+void Debug_pushMessage(const char *format, ...)
+{
+    if ((DebuggerStatus[dbg_Serial] == enabled) || (DebuggerStatus[dbg_Webui] == enabled))
+    {
+        char buff[64];
+        va_list arg;
+        va_start(arg, format);
+        vsnprintf(buff, sizeof(buff), format, arg);
+        va_end(arg);
+
+        if (DebuggerStatus[dbg_Serial] == enabled)
+        {
+            Serial.print(buff);
+        }
+        if (DebuggerStatus[dbg_Webui] == enabled)
+        {
+            Websocket_PushLiveDebug(String(buff));
+        }
+    }
+}
+
+void pushCANDebug(uint32_t id, uint8_t dlc, uint8_t *data)
+{
+    if ((DebuggerStatus[dbg_Serial] == enabled) || (DebuggerStatus[dbg_Webui] == enabled))
+    {
+        char buff[100];
+        char *p = buff;
+        p += snprintf(p, sizeof(buff), "CAN: 0x%08X | %d | ", id, dlc);
+        for (int i = 0; i < dlc; i++)
+        {
+            p += snprintf(p, sizeof(buff) - (p - buff), "%02X ", data[i]);
+        }
+        *(p++) = '\n';
+        *p = '\0';
+
+        if (DebuggerStatus[dbg_Serial] == enabled)
+        {
+            Serial.print(buff);
+        }
+        if (DebuggerStatus[dbg_Webui] == enabled)
+        {
+            Websocket_PushLiveDebug(String(buff));
+        }
+    }
+}
+
+void processCmdDebug(String command)
+{
+    if (command == "sysinfo")
+        Debug_printSystemInfo();
+    else if (command == "netinfo")
+        Debug_printWifiInfo();
+    else if (command == "formatCFG")
+        Debug_formatCFG();
+    else if (command == "formatPDS")
+        Debug_formatPersistence();
+    else if (command == "checkEE")
+        Debug_CheckEEPOM();
+    else if (command == "dumpEE1k")
+        dumpEEPROM(0, 1024);
+    else if (command == "dumpEE")
+        dumpEEPROM(0, EEPROM_SIZE_BYTES);
+    else if (command == "resetPageEE")
+        MovePersistencePage_EEPROM(true);
+    else if (command == "dumpCFG")
+        Debug_dumpConfig();
+    else if (command == "dumpPDS")
+        Debug_dumpPersistance();
+    else if (command == "saveEE")
+        globals.requestEEAction = EE_ALL_SAVE;
+    else if (command == "showdtc")
+        Debug_ShowDTCs();
+    else if (command == "dumpGlobals")
+        Debug_dumpGlobals();
+}
+
+void Debug_formatCFG()
+{
+    Debug_pushMessage("Formatting Config-EEPROM and reseting to default");
+    FormatConfig_EEPROM();
+}
+
+void Debug_formatPersistence()
+{
+    Debug_pushMessage("Formatting Persistence-EEPROM and reseting to default");
+    FormatPersistence_EEPROM();
+}
+
+void RemotDebug_printSystemInfo()
+{
+    Debug_pushMessage("Souko's ChainOiler Mk1");
+    Debug_pushMessage("Hostname: %s", globals.DeviceName);
+
+    FlashMode_t ideMode = ESP.getFlashChipMode();
+    Debug_pushMessage("Sdk version: %s", ESP.getSdkVersion());
+    Debug_pushMessage("Core Version: %s", ESP.getCoreVersion().c_str());
+    Debug_pushMessage("Boot Version: %u", ESP.getBootVersion());
+    Debug_pushMessage("Boot Mode: %u", ESP.getBootMode());
+    Debug_pushMessage("CPU Frequency: %u MHz", ESP.getCpuFreqMHz());
+    Debug_pushMessage("Reset reason: %s", ESP.getResetReason().c_str());
+    Debug_pushMessage("Flash Size: %d", ESP.getFlashChipRealSize());
+    Debug_pushMessage("Flash Size IDE: %d", ESP.getFlashChipSize());
+    Debug_pushMessage("Flash ide mode:  %s", (ideMode == FM_QIO ? "QIO" : ideMode == FM_QOUT ? "QOUT"
+                                                           : ideMode == FM_DIO    ? "DIO"
+                                                           : ideMode == FM_DOUT   ? "DOUT"
+                                                                                  : "UNKNOWN"));
+    Debug_pushMessage("OTA-Pass: %s", QUOTE(ADMIN_PASSWORD));
+    Debug_pushMessage("Git-Revison: %s", GIT_REV);
+    Debug_pushMessage("Sw-Version: %s", QUOTE(SW_VERSION));
+}
+
+void Debug_dumpConfig()
+{
+    Debug_pushMessage("DistancePerLube_Default: %d", LubeConfig.DistancePerLube_Default);
+    Debug_pushMessage("DistancePerLube_Rain: %d", LubeConfig.DistancePerLube_Rain);
+    Debug_pushMessage("tankCapacity_ml: %d", LubeConfig.tankCapacity_ml);
+    Debug_pushMessage("amountPerDose_microL: %d", LubeConfig.amountPerDose_microL);
+    Debug_pushMessage("TankRemindAtPercentage: %d", LubeConfig.TankRemindAtPercentage);
+    Debug_pushMessage("PulsePerRevolution: %d", LubeConfig.PulsePerRevolution);
+    Debug_pushMessage("TireWidth_mm: %d", LubeConfig.TireWidth_mm);
+    Debug_pushMessage("TireWidthHeight_Ratio: %d", LubeConfig.TireWidth_mm);
+    Debug_pushMessage("RimDiameter_Inch: %d", LubeConfig.RimDiameter_Inch);
+    Debug_pushMessage("DistancePerRevolution_mm: %d", LubeConfig.DistancePerRevolution_mm);
+    Debug_pushMessage("BleedingPulses: %d", LubeConfig.BleedingPulses);
+    Debug_pushMessage("SpeedSource: %d", LubeConfig.SpeedSource);
+#ifdef FEATURE_ENABLE_GPS
+    Debug_pushMessage("GPSBaudRate: %d", LubeConfig.GPSBaudRate);
+#endif
+#ifdef FEATURE_ENABLE_CAN
+    Debug_pushMessage("CANSource: %d", LubeConfig.CANSource);
+#endif
+    Debug_pushMessage("checksum: 0x%08X", LubeConfig.checksum);
+}
+
+void Debug_dumpGlobals()
+{
+    Debug_pushMessage("systemStatus: %d", globals.systemStatus);
+    Debug_pushMessage("resumeStatus: %d", globals.resumeStatus);
+    Debug_pushMessage("systemStatustxt: %s", globals.systemStatustxt);
+    Debug_pushMessage("purgePulses: %d", globals.purgePulses);
+    Debug_pushMessage("requestEEAction: %d", globals.requestEEAction);
+    Debug_pushMessage("DeviceName: %s", globals.DeviceName);
+    Debug_pushMessage("FlashVersion: %s", globals.FlashVersion);
+    Debug_pushMessage("eePersistanceAdress: %d", globals.eePersistanceAdress);
+    Debug_pushMessage("TankPercentage: %d", globals.TankPercentage);
+    Debug_pushMessage("hasDTC: %d", globals.hasDTC);
+}
+
+void Debug_dumpPersistance()
+{
+    Debug_pushMessage("writeCycleCounter: %d", PersistenceData.writeCycleCounter);
+    Debug_pushMessage("tankRemain_microL: %d", PersistenceData.tankRemain_microL);
+    Debug_pushMessage("TravelDistance_highRes_mm: %d", PersistenceData.TravelDistance_highRes_mm);
+    Debug_pushMessage("checksum: %d", PersistenceData.checksum);
+    Debug_pushMessage("PSD Adress: 0x%04X", globals.eePersistanceAdress);
+}
+
+void Debug_printWifiInfo()
+{
+}
+
+void Debug_CheckEEPOM()
+{
+    uint32_t checksum = PersistenceData.checksum;
+    PersistenceData.checksum = 0;
+
+    if (Checksum_EEPROM((uint8_t *)&PersistenceData, sizeof(PersistenceData)) == checksum)
+    {
+        Debug_pushMessage("PersistenceData EEPROM Checksum OK\n");
+    }
+    else
+    {
+        Debug_pushMessage("PersistenceData EEPROM Checksum BAD\n");
+    }
+
+    PersistenceData.checksum = checksum;
+
+    checksum = LubeConfig.checksum;
+    LubeConfig.checksum = 0;
+
+    if (Checksum_EEPROM((uint8_t *)&LubeConfig, sizeof(LubeConfig)) == checksum)
+    {
+        Debug_pushMessage("LubeConfig EEPROM Checksum OK\n");
+    }
+    else
+    {
+        Debug_pushMessage("LubeConfig EEPROM Checksum BAD\n");
+    }
+    LubeConfig.checksum = checksum;
+}
+
+void Debug_ShowDTCs()
+{
+    char buff_timestamp[16]; // Format: DD-hh:mm:ss:xxx
+    char buff_active[9];
+
+    for (uint32_t i = 0; i < MAX_DTC_STORAGE; i++)
+    {
+        if (DTCStorage[i].Number < DTC_LAST_DTC)
+        {
+            sprintf(buff_timestamp, "%02d-%02d:%02d:%02d:%03d",
+                    DTCStorage[i].timestamp / 86400000,    // Days
+                    DTCStorage[i].timestamp / 360000 % 24, // Hours
+                    DTCStorage[i].timestamp / 60000 % 60,  // Minutes
+                    DTCStorage[i].timestamp / 1000 % 60,   // Seconds
+                    DTCStorage[i].timestamp % 1000);       // milliseconds
+
+            if (DTCStorage[i].active == DTC_ACTIVE)
+                strcpy(buff_active, "active");
+            else if (DTCStorage[i].active == DTC_PREVIOUS)
+                strcpy(buff_active, "previous");
+            else
+                strcpy(buff_active, "none");
+
+            Debug_pushMessage("%s \t %6d \t %s \t %d", buff_timestamp, DTCStorage[i].Number, buff_active, DTCStorage[i].severity);
+        }
+    }
+}

Software/src/debugger.h

@@ -1,3 +1,9 @@
+#ifndef _DEBUGGER_H_
+#define _DEBUGGER_H_
+
+#include <Arduino.h>
+#include "webui.h"
+
 const char helpCmd[] = "sysinfo     - System Info\r\n"
                        "netinfo     - WiFi Info\r\n"
                        "formatPDS   - Format Persistence EEPROM Data\r\n"
@@ -11,3 +17,29 @@ const char helpCmd[] = "sysinfo     - System Info\r\n"
                        "saveEE      - save EE-Data\r\n"
                        "showdtc     - Show all DTCs\r\n"
                        "dumpGlobals - print globals\r\n";
+
+typedef enum DebugStatus_e
+{
+    disabled,
+    enabled
+} DebugStatus_t;
+
+typedef enum DebugPorts_e
+{
+    dbg_Serial,
+    dbg_Webui,
+    dbg_cntElements
+} DebugPorts_t;
+
+const char sDebugPorts[dbg_cntElements][7] = {
+    "Serial",
+    "WebUI"};
+
+extern DebugStatus_t DebuggerStatus[dbg_cntElements];
+
+void initDebugger();
+void pushCANDebug(uint32_t id, uint8_t dlc, uint8_t *data);
+void Debug_pushMessage(const char *format, ...);
+void SetDebugportStatus(DebugPorts_t port, DebugStatus_t status);
+
+#endif

Software/src/dtc.cpp

@@ -1,4 +1,5 @@
 #include "dtc.h"
+#include "debugger.h"
 
 DTCEntry_s DTCStorage[MAX_DTC_STORAGE];
 
@@ -10,7 +11,7 @@ void MaintainDTC(DTCNums_t DTC_no, DTCSeverity_t DTC_severity, boolean active, u
         {
             if (active && DTCStorage[i].active != DTC_ACTIVE)
             {
-                Serial.printf("DTC gone active: %d, DebugVal: %d\n", DTC_no, DebugValue);
+                Debug_pushMessage("DTC gone active: %d, DebugVal: %d\n", DTC_no, DebugValue);
                 DTCStorage[i].timestamp = millis();
                 DTCStorage[i].active = DTC_ACTIVE;
                 DTCStorage[i].severity = DTC_severity;
@@ -18,7 +19,7 @@ void MaintainDTC(DTCNums_t DTC_no, DTCSeverity_t DTC_severity, boolean active, u
             }
             if (!active && DTCStorage[i].active == DTC_ACTIVE)
             {
-                Serial.printf("DTC gone previous: %d\n", DTC_no);
+                Debug_pushMessage("DTC gone previous: %d\n", DTC_no);
                 DTCStorage[i].active = DTC_PREVIOUS;
             }
             return;
@@ -33,11 +34,12 @@ void MaintainDTC(DTCNums_t DTC_no, DTCSeverity_t DTC_severity, boolean active, u
         {
             if (DTCStorage[i].Number == DTC_LAST_DTC)
             {
-                Serial.printf("new DTC registered: %d, DebugVal: %d\n", DTC_no, DebugValue);
+                Debug_pushMessage("new DTC registered: %d, DebugVal: %d\n", DTC_no, DebugValue);
                 DTCStorage[i].Number = DTC_no;
                 DTCStorage[i].timestamp = millis();
                 DTCStorage[i].active = DTC_ACTIVE;
                 DTCStorage[i].debugVal = DebugValue;
+                DTCStorage[i].severity = DTC_severity;
                 return;
             }
         }
@@ -106,3 +108,32 @@ DTCNums_t getlastDTC_Severity(boolean only_active, DTCSeverity_t severity)
 
     return pointer >= 0 ? DTCStorage[pointer].Number : DTC_LAST_DTC;
 }
+
+void DTC_Process()
+{
+    static tSystem_Status preserverSysStatusError;
+
+    if (getlastDTC(false) < DTC_LAST_DTC)
+    {
+        globals.hasDTC = true;
+        if (getlastDTC_Severity(true, DTC_CRITICAL) < DTC_LAST_DTC)
+        {
+            if (globals.systemStatus != sysStat_Error)
+            {
+                preserverSysStatusError = globals.systemStatus;
+            }
+            globals.systemStatus = sysStat_Error;
+        }
+        else
+        {
+            if (globals.systemStatus == sysStat_Error)
+            {
+                globals.systemStatus = preserverSysStatusError;
+            }
+        }
+    }
+    else
+    {
+        globals.hasDTC = false;
+    }
+}

Software/src/dtc.h

@@ -55,6 +55,7 @@ void ClearDTC(DTCNums_t DTC_no);
 void ClearAllDTC();
 DTCNums_t getlastDTC(boolean only_active);
 DTCNums_t getlastDTC_Severity(boolean only_active, DTCSeverity_t severity);
+void DTC_Process();
 
 extern DTCEntry_s DTCStorage[MAX_DTC_STORAGE];
 #endif

Software/src/globals.cpp

@@ -0,0 +1,11 @@
+#include "globals.h"
+
+Globals_t globals;
+
+void initGlobals()
+{
+  globals.purgePulses = 0;
+  globals.requestEEAction = EE_IDLE;
+  globals.resumeStatus = sysStat_Normal;
+  globals.systemStatus = sysStat_Startup;
+}

Software/src/globals.h

@@ -43,4 +43,6 @@ typedef struct Globals_s
 
 extern Globals_t globals;
 
+void initGlobals();
+
 #endif

Software/src/gps.cpp

@@ -19,7 +19,7 @@ void Init_GPS()
         break;
     }
 
-    Serial.printf(PSTR("Init GPS with Baud %d\n"), baudrate);
+    Debug_pushMessage(PSTR("Init GPS with Baud %d\n"), baudrate);
     Serial.begin(baudrate);
 }
 

Software/src/lubeapp.cpp

@@ -5,37 +5,11 @@ uint32_t lubePulseTimestamp = 0;
 void RunLubeApp(uint32_t add_milimeters)
 {
 
-    globals.TankPercentage = PersistenceData.tankRemain_µl / (LubeConfig.tankCapacity_ml * 10);
+    globals.TankPercentage = PersistenceData.tankRemain_microL / (LubeConfig.tankCapacity_ml * 10);
 
-    MaintainDTC(DTC_TANK_EMPTY, DTC_CRITICAL, (PersistenceData.tankRemain_µl < LubeConfig.amountPerDose_µl));
+    MaintainDTC(DTC_TANK_EMPTY, DTC_CRITICAL, (PersistenceData.tankRemain_microL < LubeConfig.amountPerDose_microL));
     MaintainDTC(DTC_TANK_LOW, DTC_WARN, (globals.TankPercentage < LubeConfig.TankRemindAtPercentage));
 
-    static tSystem_Status preserverSysStatusError;
-
-    if (getlastDTC(false) < DTC_LAST_DTC)
-    {
-        globals.hasDTC = true;
-        if (getlastDTC_Severity(true, DTC_CRITICAL) < DTC_LAST_DTC)
-        {
-            if (globals.systemStatus != sysStat_Error)
-            {
-                preserverSysStatusError = globals.systemStatus;
-            }
-            globals.systemStatus = sysStat_Error;
-        }
-        else
-        {
-            if (globals.systemStatus == sysStat_Error)
-            {
-                globals.systemStatus = preserverSysStatusError;
-            }
-        }
-    }
-    else
-    {
-        globals.hasDTC = false;
-    }
-
     // Add traveled Distance in mm
     PersistenceData.TravelDistance_highRes_mm += add_milimeters;
     PersistenceData.odometer_mm += add_milimeters;
@@ -121,13 +95,13 @@ void RunLubeApp(uint32_t add_milimeters)
 
 void LubePulse()
 {
-    if (PersistenceData.tankRemain_µl > 0) // Only Lube if theres Oil remaining!
+    if (PersistenceData.tankRemain_microL > 0) // Only Lube if theres Oil remaining!
     {
         lubePulseTimestamp = millis() + LUBE_PULSE_LENGHT_MS;
 
-        if (PersistenceData.tankRemain_µl < LubeConfig.amountPerDose_µl) // Prevent underrun and shiftover
-            PersistenceData.tankRemain_µl = 0;
+        if (PersistenceData.tankRemain_microL < LubeConfig.amountPerDose_microL) // Prevent underrun and shiftover
+            PersistenceData.tankRemain_microL = 0;
         else
-            PersistenceData.tankRemain_µl = PersistenceData.tankRemain_µl - LubeConfig.amountPerDose_µl;
+            PersistenceData.tankRemain_microL = PersistenceData.tankRemain_microL - LubeConfig.amountPerDose_microL;
     }
 }

Software/src/main.cpp

@@ -17,6 +17,7 @@
 #include "webui.h"
 #include "config.h"
 #include "globals.h"
+#include "debugger.h"
 #ifdef FEATURE_ENABLE_CAN
 #include "can.h"
 #endif
@@ -25,14 +26,6 @@
 #endif
 #include "dtc.h"
 
-#ifdef FEATURE_ENABLE_REMOTE_DEBUG
-#include <RemoteDebug.h>
-#include "rmtdbghelp.h"
-#else
-#define debugV Serial.println
-#define debugE Serial.println
-#endif
-
 #ifdef FEATURE_ENABLE_WIFI_CLIENT
 #include <ESP8266WiFiMulti.h>
 
@@ -44,9 +37,6 @@ ESP8266WiFiMulti wifiMulti;
 #endif
 
 bool startSetupMode = false;
-
-Globals_t globals;
-uint32_t TravelDistance_highRes;
 volatile uint32_t wheel_pulse = 0;
 
 CRGB leds[1];
@@ -63,22 +53,6 @@ void toggleWiFiAP(boolean shutdown = false);
 void SystemShutdown();
 uint32_t Process_Impulse_WheelSpeed();
 void EEPROMCyclicPDS_callback();
-void initGlobals();
-
-#ifdef FEATURE_ENABLE_REMOTE_DEBUG
-RemoteDebug Debug;
-String IpAddress2String(const IPAddress &ipAddress);
-void processCmdRemoteDebug();
-void RemoteDebug_formatCFG();
-void RemoteDebug_formatPersistence();
-void RemotDebug_printSystemInfo();
-void RemoteDebug_printWifiInfo();
-void RemoteDebug_CheckEEPOM();
-void RemoteDebug_dumpConfig();
-void RemoteDebug_dumpPersistance();
-void RemoteDebug_ShowDTCs();
-void RemoteDebug_dumpGlobals();
-#endif
 
 #ifdef FEATURE_ENABLE_WIFI_CLIENT
 void wifiMaintainConnectionTicker_callback();
@@ -104,8 +78,6 @@ void setup()
 #endif
 
   Serial.begin(115200);
-  Serial.setDebugOutput(false);
-
   Serial.println("\n\nSouko's ChainLube Mk1");
   Serial.println(globals.DeviceName);
 
@@ -138,26 +110,13 @@ void setup()
     break;
 #endif
   default:
-    debugE("Source Setting N/A");
+    Debug_pushMessage("Source Setting N/A");
     break;
   }
 
   pinMode(GPIO_BUTTON, INPUT_PULLUP);
   pinMode(GPIO_PUMP, OUTPUT);
 
-#ifdef FEATURE_ENABLE_REMOTE_DEBUG
-  Debug.begin(globals.DeviceName);
-  Debug.setResetCmdEnabled(true);
-  Debug.showProfiler(false);
-  Debug.showColors(true);
-  Debug.setPassword(QUOTE(ADMIN_PASSWORD));
-  Debug.setSerialEnabled(true);
-  Debug.showDebugLevel(true);
-
-  Debug.setHelpProjectsCmds(helpCmd);
-  Debug.setCallBackProjectCmds(&processCmdRemoteDebug);
-#endif
-
   ArduinoOTA.setPort(8266);
   ArduinoOTA.setHostname(globals.DeviceName);
   ArduinoOTA.setPassword(QUOTE(ADMIN_PASSWORD));
@@ -226,18 +185,17 @@ void loop()
   }
 
   RunLubeApp(wheelDistance);
-  EEPROMCyclicPDSTicker.update();
 #ifdef FEATURE_ENABLE_OLED
   Display_Process();
 #endif
   Button_Process();
   LED_Process();
   EEPROM_Process();
+  Webserver_Process();
+  DTC_Process();
 
   ArduinoOTA.handle();
-#ifdef FEATURE_ENABLE_REMOTE_DEBUG
-  Debug.handle();
-#endif
+  EEPROMCyclicPDSTicker.update();
 #ifdef FEATURE_ENABLE_WIFI_CLIENT
   WiFiMaintainConnectionTicker.update();
 #endif
@@ -254,163 +212,6 @@ String IpAddress2String(const IPAddress &ipAddress)
          String(ipAddress[3]);
 }
 
-void initGlobals()
-{
-  globals.purgePulses = 0;
-  globals.requestEEAction = EE_IDLE;
-  globals.resumeStatus = sysStat_Normal;
-  globals.systemStatus = sysStat_Startup;
-}
-
-#ifdef FEATURE_ENABLE_REMOTE_DEBUG
-void processCmdRemoteDebug()
-{
-  String lastCmd = Debug.getLastCommand();
-
-  if (lastCmd == "sysinfo")
-    RemotDebug_printSystemInfo();
-  else if (lastCmd == "netinfo")
-    RemoteDebug_printWifiInfo();
-  else if (lastCmd == "formatCFG")
-    RemoteDebug_formatCFG();
-  else if (lastCmd == "formatPDS")
-    RemoteDebug_formatPersistence();
-  else if (lastCmd == "checkEE")
-    RemoteDebug_CheckEEPOM();
-  else if (lastCmd == "dumpEE1k")
-    dumpEEPROM(0, 1024);
-  else if (lastCmd == "dumpEE")
-    dumpEEPROM(0, EEPROM_SIZE_BYTES);
-  else if (lastCmd == "resetPageEE")
-    MovePersistencePage_EEPROM(true);
-  else if (lastCmd == "dumpCFG")
-    RemoteDebug_dumpConfig();
-  else if (lastCmd == "dumpPDS")
-    RemoteDebug_dumpPersistance();
-  else if (lastCmd == "saveEE")
-    globals.requestEEAction = EE_ALL_SAVE;
-  else if (lastCmd == "showdtc")
-    RemoteDebug_ShowDTCs();
-  else if (lastCmd == "dumpGlobals")
-    RemoteDebug_dumpGlobals();
-}
-
-void RemoteDebug_formatCFG()
-{
-  debugA("Formatting Config-EEPROM and reseting to default");
-  FormatConfig_EEPROM();
-}
-
-void RemoteDebug_formatPersistence()
-{
-  debugA("Formatting Persistence-EEPROM and reseting to default");
-  FormatPersistence_EEPROM();
-}
-
-void RemotDebug_printSystemInfo()
-{
-  debugA("Souko's ChainOiler Mk1");
-  debugA("Hostname: %s", globals.DeviceName);
-
-  FlashMode_t ideMode = ESP.getFlashChipMode();
-  debugA("Sdk version: %s", ESP.getSdkVersion());
-  debugA("Core Version: %s", ESP.getCoreVersion().c_str());
-  debugA("Boot Version: %u", ESP.getBootVersion());
-  debugA("Boot Mode: %u", ESP.getBootMode());
-  debugA("CPU Frequency: %u MHz", ESP.getCpuFreqMHz());
-  debugA("Reset reason: %s", ESP.getResetReason().c_str());
-  debugA("Flash Size: %d", ESP.getFlashChipRealSize());
-  debugA("Flash Size IDE: %d", ESP.getFlashChipSize());
-  debugA("Flash ide mode:  %s", (ideMode == FM_QIO ? "QIO" : ideMode == FM_QOUT ? "QOUT"
-                                                         : ideMode == FM_DIO    ? "DIO"
-                                                         : ideMode == FM_DOUT   ? "DOUT"
-                                                                                : "UNKNOWN"));
-  debugA("OTA-Pass: %s", QUOTE(ADMIN_PASSWORD));
-  debugA("Git-Revison: %s", GIT_REV);
-  debugA("Sw-Version: %s", QUOTE(SW_VERSION));
-}
-
-void RemoteDebug_dumpConfig()
-{
-  debugA("DistancePerLube_Default: %d", LubeConfig.DistancePerLube_Default);
-  debugA("DistancePerLube_Rain: %d", LubeConfig.DistancePerLube_Rain);
-  debugA("tankCapacity_ml: %d", LubeConfig.tankCapacity_ml);
-  debugA("amountPerDose_µl: %d", LubeConfig.amountPerDose_µl);
-  debugA("TankRemindAtPercentage: %d", LubeConfig.TankRemindAtPercentage);
-  debugA("PulsePerRevolution: %d", LubeConfig.PulsePerRevolution);
-  debugA("TireWidth_mm: %d", LubeConfig.TireWidth_mm);
-  debugA("TireWidthHeight_Ratio: %d", LubeConfig.TireWidth_mm);
-  debugA("RimDiameter_Inch: %d", LubeConfig.RimDiameter_Inch);
-  debugA("DistancePerRevolution_mm: %d", LubeConfig.DistancePerRevolution_mm);
-  debugA("BleedingPulses: %d", LubeConfig.BleedingPulses);
-  debugA("SpeedSource: %d", LubeConfig.SpeedSource);
-#ifdef FEATURE_ENABLE_GPS
-  debugA("GPSBaudRate: %d", LubeConfig.GPSBaudRate);
-#endif
-#ifdef FEATURE_ENABLE_CAN
-  debugA("CANSource: %d", LubeConfig.CANSource);
-#endif
-  debugA("checksum: 0x%08X", LubeConfig.checksum);
-}
-
-void RemoteDebug_dumpGlobals()
-{
-  debugA("systemStatus: %d", globals.systemStatus);
-  debugA("resumeStatus: %d", globals.resumeStatus);
-  debugA("systemStatustxt: %s", globals.systemStatustxt);
-  debugA("purgePulses: %d", globals.purgePulses);
-  debugA("requestEEAction: %d", globals.requestEEAction);
-  debugA("DeviceName: %s", globals.DeviceName);
-  debugA("FlashVersion: %s", globals.FlashVersion);
-  debugA("eePersistanceAdress: %d", globals.eePersistanceAdress);
-  debugA("TankPercentage: %d", globals.TankPercentage);
-  debugA("hasDTC: %d", globals.hasDTC);
-}
-
-void RemoteDebug_dumpPersistance()
-{
-  debugA("writeCycleCounter: %d", PersistenceData.writeCycleCounter);
-  debugA("tankRemain_µl: %d", PersistenceData.tankRemain_µl);
-  debugA("TravelDistance_highRes_mm: %d", PersistenceData.TravelDistance_highRes_mm);
-  debugA("checksum: %d", PersistenceData.checksum);
-  debugA("PSD Adress: 0x%04X", globals.eePersistanceAdress);
-}
-
-void RemoteDebug_printWifiInfo()
-{
-}
-
-void RemoteDebug_CheckEEPOM()
-{
-  uint32_t checksum = PersistenceData.checksum;
-  PersistenceData.checksum = 0;
-
-  if (Checksum_EEPROM((uint8_t *)&PersistenceData, sizeof(PersistenceData)) == checksum)
-  {
-    debugA("PersistenceData EEPROM Checksum OK\n");
-  }
-  else
-  {
-    debugA("PersistenceData EEPROM Checksum BAD\n");
-  }
-
-  PersistenceData.checksum = checksum;
-
-  checksum = LubeConfig.checksum;
-  LubeConfig.checksum = 0;
-
-  if (Checksum_EEPROM((uint8_t *)&LubeConfig, sizeof(LubeConfig)) == checksum)
-  {
-    debugA("LubeConfig EEPROM Checksum OK\n");
-  }
-  else
-  {
-    debugA("LubeConfig EEPROM Checksum BAD\n");
-  }
-  LubeConfig.checksum = checksum;
-}
-#endif
-
 #ifdef FEATURE_ENABLE_WIFI_CLIENT
 void wifiMaintainConnectionTicker_callback()
 {
@@ -429,7 +230,7 @@ void wifiMaintainConnectionTicker_callback()
     }
     else
     {
-      debugV("WiFi not connected! - Start AP");
+      Debug_pushMessage("WiFi not connected! - Start AP");
       toggleWiFiAP();
     }
   }
@@ -475,7 +276,7 @@ void LED_Process(uint8_t override, CRGB SetColor)
     if (LED_Status != LED_Override)
     {
       LED_ResumeOverrideStatus = LED_Status;
-      debugV("Override LED_Status");
+      Debug_pushMessage("Override LED_Status");
     }
     LED_Status = LED_Override;
     LED_override_color = SetColor;
@@ -486,7 +287,7 @@ void LED_Process(uint8_t override, CRGB SetColor)
     if (LED_Status == LED_Override)
     {
       LED_Status = LED_ResumeOverrideStatus;
-      debugV("Resume LED_Status");
+      Debug_pushMessage("Resume LED_Status");
     }
   }
 
@@ -496,25 +297,25 @@ void LED_Process(uint8_t override, CRGB SetColor)
     {
     case sysStat_Startup:
       LED_Status = LED_Startup;
-      debugV("sysStat: Startup");
+      Debug_pushMessage("sysStat: Startup");
       break;
     case sysStat_Normal:
       timestamp = timer + 3500;
       LED_Status = LED_Confirm_Normal;
-      debugV("sysStat: Normal");
+      Debug_pushMessage("sysStat: Normal");
       break;
     case sysStat_Rain:
       timestamp = timer + 3500;
       LED_Status = LED_Confirm_Rain;
-      debugV("sysStat: Rain");
+      Debug_pushMessage("sysStat: Rain");
       break;
     case sysStat_Purge:
       LED_Status = LED_Purge;
-      debugV("sysStat: Purge");
+      Debug_pushMessage("sysStat: Purge");
       break;
     case sysStat_Error:
       LED_Status = LED_Error;
-      debugV("sysStat: Error");
+      Debug_pushMessage("sysStat: Error");
       break;
     case sysStat_Shutdown:
     default:
@@ -541,7 +342,7 @@ void LED_Process(uint8_t override, CRGB SetColor)
     {
       LED_Status = LED_Normal;
       FastLED.setBrightness(64);
-      debugV("LED_Status: Confirm -> Normal");
+      Debug_pushMessage("LED_Status: Confirm -> Normal");
     }
     break;
 
@@ -565,7 +366,7 @@ void LED_Process(uint8_t override, CRGB SetColor)
     {
       LED_Status = LED_Rain;
       FastLED.setBrightness(64);
-      debugV("LED_Status: Confirm -> Rain");
+      Debug_pushMessage("LED_Status: Confirm -> Rain");
     }
     break;
 
@@ -619,7 +420,7 @@ void Display_Process()
 
   u8x8.setCursor(0, 1);
   uint32_t DistRemain = globals.systemStatus == sysStat_Normal ? LubeConfig.DistancePerLube_Default : LubeConfig.DistancePerLube_Rain;
-  DistRemain -= TravelDistance_highRes / 1000;
+  DistRemain = DistRemain - (PersistenceData.TravelDistance_highRes_mm / 1000);
   u8x8.printf(PSTR("Mode: %10s\n"), globals.systemStatustxt);
   if (globals.systemStatus == sysStat_Error)
   {
@@ -628,7 +429,7 @@ void Display_Process()
   else
   {
     u8x8.printf(PSTR("next Lube: %4dm\n"), DistRemain);
-    u8x8.printf(PSTR("Tank: %8dml\n"), PersistenceData.tankRemain_µl / 1000);
+    u8x8.printf(PSTR("Tank: %8dml\n"), PersistenceData.tankRemain_microL / 1000);
     u8x8.printf(PSTR("WiFi: %10s\n"), (WiFi.getMode() == WIFI_AP ? "AP" : WiFi.getMode() == WIFI_OFF ? "OFF"
                                                                       : WiFi.getMode() == WIFI_STA   ? "CLIENT"
                                                                                                      : "UNKNOWN"));
@@ -695,13 +496,13 @@ void Button_Process()
       {
       case BTN_TOGGLEWIFI:
         toggleWiFiAP();
-        debugV("Starting WiFi AP");
+        Debug_pushMessage("Starting WiFi AP");
         break;
 
       case BTN_STARTPURGE:
         globals.systemStatus = sysStat_Purge;
         globals.purgePulses = LubeConfig.BleedingPulses;
-        debugV("Starting Purge");
+        Debug_pushMessage("Starting Purge");
         break;
 
       case BTN_TOGGLEMODE:
@@ -719,12 +520,12 @@ void Button_Process()
         default:
           break;
         }
-        debugV("Toggling Mode");
+        Debug_pushMessage("Toggling Mode");
         break;
 
       case BTN_NOTHING:
       default:
-        debugV("Nothing or invalid");
+        Debug_pushMessage("Nothing or invalid");
         break;
       }
       LED_Process(2);
@@ -739,7 +540,7 @@ void toggleWiFiAP(boolean shutdown)
   if (WiFi.getMode() != WIFI_OFF)
   {
     WiFi.mode(WIFI_OFF);
-    debugV("WiFi turned off");
+    Debug_pushMessage("WiFi turned off");
 #ifdef FEATURE_ENABLE_WIFI_CLIENT
     WiFiMaintainConnectionTicker.stop();
 #endif
@@ -751,9 +552,9 @@ void toggleWiFiAP(boolean shutdown)
     WiFi.softAP(globals.DeviceName, QUOTE(WIFI_AP_PASSWORD));
 #ifdef FEATURE_ENABLE_WIFI_CLIENT
     WiFiMaintainConnectionTicker.stop();
-    debugV("WiFi AP started, stopped Maintain-Timer");
+    Debug_pushMessage("WiFi AP started, stopped Maintain-Timer");
 #else
-    debugV("WiFi AP started");
+    Debug_pushMessage("WiFi AP started");
 #endif
   }
 }
@@ -785,32 +586,3 @@ uint32_t Process_Impulse_WheelSpeed()
   return add_milimeters;
 }
 
-#ifdef FEATURE_ENABLE_REMOTE_DEBUG
-void RemoteDebug_ShowDTCs()
-{
-  char buff_timestamp[16]; // Format: DD-hh:mm:ss:xxx
-  char buff_active[9];
-
-  for (uint32_t i = 0; i < MAX_DTC_STORAGE; i++)
-  {
-    if (DTCStorage[i].Number < DTC_LAST_DTC)
-    {
-      sprintf(buff_timestamp, "%02d-%02d:%02d:%02d:%03d",
-              DTCStorage[i].timestamp / 86400000,    // Days
-              DTCStorage[i].timestamp / 360000 % 24, // Hours
-              DTCStorage[i].timestamp / 60000 % 60,  // Minutes
-              DTCStorage[i].timestamp / 1000 % 60,   // Seconds
-              DTCStorage[i].timestamp % 1000);       // milliseconds
-
-      if (DTCStorage[i].active == DTC_ACTIVE)
-        strcpy(buff_active, "active");
-      else if (DTCStorage[i].active == DTC_PREVIOUS)
-        strcpy(buff_active, "previous");
-      else
-        strcpy(buff_active, "none");
-
-      debugA("%s \t %6d \t %s", buff_timestamp, DTCStorage[i].Number, buff_active);
-    }
-  }
-}
-#endif

Software/src/webui.cpp

@@ -13,11 +13,20 @@ void WebserverEERestore_Callback(AsyncWebServerRequest *request, const String &f
 void WebServerEEJSON_Callback(AsyncWebServerRequest *request);
 void GetFlashVersion(char *buff, size_t buff_size);
 
+#ifdef FEATURE_ENABLE_WEBSOCKETS
+
+AsyncWebSocket webSocket("/ws");
+
+void WebsocketEvent_Callback(AsyncWebSocket *server, AsyncWebSocketClient *client, AwsEventType type, void *arg, uint8_t *data, size_t len);
+void Websocket_HandleMessage(void *arg, uint8_t *data, size_t len);
+
+#endif
+
 void initWebUI()
 {
   if (!LittleFS.begin())
   {
-    Serial.println("An Error has occurred while mounting LittleFS");
+    Debug_pushMessage("An Error has occurred while mounting LittleFS\n");
     MaintainDTC(DTC_FLASHFS_ERROR, DTC_CRITICAL, true);
     return;
   }
@@ -30,9 +39,13 @@ void initWebUI()
   }
 
   MDNS.begin(globals.DeviceName);
-  MDNS.addService("telnet", "tcp", 23);
   MDNS.addService("http", "tcp", 80);
 
+#ifdef FEATURE_ENABLE_WEBSOCKETS
+  webSocket.onEvent(WebsocketEvent_Callback);
+  webServer.addHandler(&webSocket);
+#endif
+
   webServer.serveStatic("/static/", LittleFS, "/static/").setCacheControl("max-age=360000");
   webServer.on("/", HTTP_GET, [](AsyncWebServerRequest *request)
                { request->redirect("/index.htm"); });
@@ -48,10 +61,17 @@ void initWebUI()
   webServer.begin();
 }
 
+void Webserver_Process()
+{
+#ifdef FEATURE_ENABLE_WEBSOCKETS
+  webSocket.cleanupClients();
+#endif
+}
+
 String processor(const String &var)
 {
   if (var == "TANK_REMAIN_CAPACITY")
-    return String((PersistenceData.tankRemain_µl / 10) / LubeConfig.tankCapacity_ml);
+    return String((PersistenceData.tankRemain_microL / 10) / LubeConfig.tankCapacity_ml);
   if (var == "LUBE_DISTANCE_NORMAL")
     return String(LubeConfig.DistancePerLube_Default);
   if (var == "LUBE_DISTANCE_RAIN")
@@ -59,7 +79,7 @@ String processor(const String &var)
   if (var == "TANK_CAPACITY")
     return String(LubeConfig.tankCapacity_ml);
   if (var == "AMOUNT_PER_DOSE")
-    return String(LubeConfig.amountPerDose_µl);
+    return String(LubeConfig.amountPerDose_microL);
   if (var == "TANK_REMIND")
     return String(LubeConfig.TankRemindAtPercentage);
   if (var == "PULSE_PER_REV")
@@ -99,7 +119,7 @@ String processor(const String &var)
   if (var == "PERSISTENCE_MARKER")
     return String(globals.eePersistanceAdress);
   if (var == "TANK_REMAIN_UL")
-    return String(PersistenceData.tankRemain_µl);
+    return String(PersistenceData.tankRemain_microL);
   if (var == "TRAVEL_DISTANCE_HIGHRES")
     return String(PersistenceData.TravelDistance_highRes_mm);
   if (var == "ODOMETER")
@@ -236,19 +256,19 @@ void WebserverPOST_Callback(AsyncWebServerRequest *request)
 {
   request->send(LittleFS, "/post.htm", "text/html", false, processor);
 
-  Serial.print("POST:\n");
+  Debug_pushMessage("POST:\n");
   int paramsNr = request->params();
   for (int i = 0; i < paramsNr; i++)
   {
     AsyncWebParameter *p = request->getParam(i);
-    Serial.printf("%s : %s\n", p->name().c_str(), p->value().c_str());
+    Debug_pushMessage("%s : %s\n", p->name().c_str(), p->value().c_str());
 
     // begin: POST Form Source Changed
     if (p->name() == "sourceselect")
     {
       SpeedSource_t temp = (SpeedSource_t)p->value().toInt();
-      Serial.printf("temp: %d", temp);
-      Serial.printf("SpeedSource: %d", LubeConfig.SpeedSource);
+      Debug_pushMessage("temp: %d", temp);
+      Debug_pushMessage("SpeedSource: %d", LubeConfig.SpeedSource);
       if (LubeConfig.SpeedSource != temp)
       {
         LubeConfig.SpeedSource = temp;
@@ -298,7 +318,7 @@ void WebserverPOST_Callback(AsyncWebServerRequest *request)
     if (p->name() == "tankwarn")
       LubeConfig.TankRemindAtPercentage = p->value().toInt();
     if (p->name() == "pumppulse")
-      LubeConfig.amountPerDose_µl = p->value().toInt();
+      LubeConfig.amountPerDose_microL = p->value().toInt();
     if (p->name() == "oilsave")
       globals.requestEEAction = EE_CFG_SAVE;
     // end: POST Form Oiltank
@@ -309,7 +329,7 @@ void WebserverPOST_Callback(AsyncWebServerRequest *request)
       globals.requestEEAction = EE_CFG_SAVE;
     if (p->name() == "resettank")
     {
-      PersistenceData.tankRemain_µl = LubeConfig.tankCapacity_ml * 1000;
+      PersistenceData.tankRemain_microL = LubeConfig.tankCapacity_ml * 1000;
       globals.requestEEAction = EE_PDS_SAVE;
     }
     if (p->name() == "reset_ee_btn")
@@ -332,7 +352,7 @@ void WebserverPOST_Callback(AsyncWebServerRequest *request)
       globals.systemStatus = sysStat_Purge;
       globals.purgePulses = LubeConfig.BleedingPulses;
     }
-    if(p->name() == "reboot")
+    if (p->name() == "reboot")
     {
       globals.systemStatus = sysStat_Shutdown;
     }
@@ -367,7 +387,7 @@ void WebserverFirmwareUpdate_Callback(AsyncWebServerRequest *request, const Stri
 
   if (!index)
   {
-    Serial.println("Update");
+    Debug_pushMessage("Update");
     size_t content_len = request->contentLength();
     int cmd = (filename.indexOf(".fs") > -1) ? U_FS : U_FLASH;
     Update.runAsync(true);
@@ -383,7 +403,7 @@ void WebserverFirmwareUpdate_Callback(AsyncWebServerRequest *request, const Stri
   }
   else
   {
-    Serial.printf("Progress: %d%%\n", (Update.progress() * 100) / Update.size());
+    Debug_pushMessage("Progress: %d%%\n", (Update.progress() * 100) / Update.size());
   }
 
   if (final)
@@ -398,8 +418,7 @@ void WebserverFirmwareUpdate_Callback(AsyncWebServerRequest *request, const Stri
     }
     else
     {
-      Serial.println("Update complete");
-      Serial.flush();
+      Debug_pushMessage("Update complete\n");
       globals.systemStatus = sysStat_Shutdown;
     }
   }
@@ -413,14 +432,14 @@ void WebserverEERestore_Callback(AsyncWebServerRequest *request, const String &f
 
   if (!index)
   {
-    Serial.println("EEPROM restore");
-    size_t content_len = request->contentLength();
+    Debug_pushMessage("EEPROM restore\n");
+    // size_t content_len = request->contentLength();
     validext = (filename.indexOf(".ee.json") > -1);
   }
 
   if (validext)
   {
-    Serial.println("Restoring EEPROM-Stuff");
+    Debug_pushMessage("Restoring EEPROM-Stuff\n");
   }
 
   if (final)
@@ -431,8 +450,7 @@ void WebserverEERestore_Callback(AsyncWebServerRequest *request, const String &f
     request->send(response);
     if (ee_done)
     {
-      Serial.println("Update complete");
-      Serial.flush();
+      Debug_pushMessage("Update complete");
       globals.systemStatus = sysStat_Shutdown;
     }
     else
@@ -459,7 +477,7 @@ void WebServerEEJSON_Callback(AsyncWebServerRequest *request)
   config["DistancePerLube_Default"] = LubeConfig.DistancePerLube_Default;
   config["DistancePerLube_Rain"] = LubeConfig.DistancePerLube_Rain;
   config["tankCapacity_ml"] = LubeConfig.tankCapacity_ml;
-  config["amountPerDose_µl"] = LubeConfig.amountPerDose_µl;
+  config["amountPerDose_microL"] = LubeConfig.amountPerDose_microL;
   config["TankRemindAtPercentage"] = LubeConfig.TankRemindAtPercentage;
   config["PulsePerRevolution"] = LubeConfig.PulsePerRevolution;
   config["TireWidth_mm"] = LubeConfig.TireWidth_mm;
@@ -488,7 +506,7 @@ void WebServerEEJSON_Callback(AsyncWebServerRequest *request)
   JsonObject persis = json.createNestedObject("persis");
 
   persis["writeCycleCounter"] = PersistenceData.writeCycleCounter;
-  persis["tankRemain_µl"] = PersistenceData.tankRemain_µl;
+  persis["tankRemain_microL"] = PersistenceData.tankRemain_microL;
   persis["TravelDistance_highRes_mm"] = PersistenceData.TravelDistance_highRes_mm;
   persis["odometer_mm"] = PersistenceData.odometer_mm;
   persis["odometer"] = PersistenceData.odometer;
@@ -501,3 +519,53 @@ void WebServerEEJSON_Callback(AsyncWebServerRequest *request)
 
   request->send(response);
 }
+
+#ifdef FEATURE_ENABLE_WEBSOCKETS
+void WebsocketEvent_Callback(AsyncWebSocket *server, AsyncWebSocketClient *client, AwsEventType type, void *arg, uint8_t *data, size_t len)
+{
+  switch (type)
+  {
+  case WS_EVT_CONNECT:
+    Debug_pushMessage("WebSocket client #%u connected from %s\n", client->id(), client->remoteIP().toString().c_str());
+    break;
+  case WS_EVT_DISCONNECT:
+    Debug_pushMessage("WebSocket client #%u disconnected\n", client->id());
+    break;
+  case WS_EVT_DATA:
+    Websocket_HandleMessage(arg, data, len);
+    break;
+  case WS_EVT_PONG:
+  case WS_EVT_ERROR:
+    break;
+  }
+}
+
+void Websocket_HandleMessage(void *arg, uint8_t *data, size_t len)
+{
+  AwsFrameInfo *info = (AwsFrameInfo *)arg;
+  if (info->final && info->index == 0 && info->len == len && info->opcode == WS_TEXT)
+  {
+    data[len] = 0;
+
+    Debug_pushMessage("Got WebSocket Message: %s \n", (char *)data);
+
+    if (strcmp((char *)data, "start") == 0)
+    {
+      SetDebugportStatus(dbg_Webui, enabled);
+    }
+    else if (strcmp((char *)data, "stop") == 0)
+    {
+      SetDebugportStatus(dbg_Webui, disabled);
+    }
+    else if (strcmp((char *)data, "foo") == 0)
+    {
+      Debug_pushMessage("Got WebSocket Message 'foo' from client\n");
+    }
+  }
+}
+
+void Websocket_PushLiveDebug(String Message)
+{
+  webSocket.textAll(Message + "\n");
+}
+#endif

Software/src/webui.h

@@ -15,7 +15,13 @@
 #include "globals.h"
 #include "dtc.h"
 #include "common.h"
+#include "debugger.h"
 
 void initWebUI();
+void Webserver_Process();
+
+#ifdef FEATURE_ENABLE_WEBSOCKETS
+void Websocket_PushLiveDebug(String Message);
+#endif
 
 #endif