/** * Copyright (C) 2026 Ralf Burger * ralf@RalfBurger.com * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see . */ #pragma once #include #include #include #include "pid_registry.h" #define HTTP_PORT 80 WiFiServer httpServer(HTTP_PORT); extern bool apMode; extern bool wifiOk; #if defined(DEVICE_BRIDGE) #include extern NimBLEClient* pClient; // DTC-Funktionen (definiert in obd_bridge.ino) extern void readDTCs(); extern void clearDTCs(); // Akku-Info (definiert in obd_bridge.ino) extern bool batGetValid(); extern float batGetVolt(); extern int batGetPct(); #elif defined(DEVICE_RECEIVER) extern RxStats rx; #endif // ---- PROGMEM strings ---------------------------------------- static const char HTTP_HDR[] PROGMEM = "HTTP/1.1 200 OK\r\nContent-Type: text/html; charset=utf-8\r\n" "Cache-Control: no-cache\r\nConnection: close\r\n\r\n"; static const char HTML_404[] PROGMEM = "HTTP/1.1 404 Not Found\r\nContent-Type: text/plain\r\n" "Connection: close\r\n\r\n404 - nur GET / verfuegbar"; static const char HTML_CSS[] PROGMEM = ""; static const char HTML_FOOT[] PROGMEM = "
(C) 2026 Ralf Burger  ·  GPL v3" "  ·  ralf@RalfBurger.com" "  ·  TCP Port 1234
" "" "" ""; // ---- Macros ------------------------------------------------- #define PP(c, s) c.print((__FlashStringHelper*)(s)) #define HPR(c, s) c.print(F(s)) #define PF(c, ...) do { char _b[96]; snprintf(_b,sizeof(_b),__VA_ARGS__); c.print(_b); } while(0) // ---- Helper ------------------------------------------------- static const char* _grpCls(int i) { if(i <= 6) return "mo"; if(i <= 17) return "kr"; if(i <= 26) return "ab"; if(i <= 31) return "zu"; if(i <= 38) return "fe"; return "in"; } static void _sbCell(WiFiClient& c, const char* label, bool valid, const char* cls, const char* val, const char* unit) { PF(c, "
%s
", label); if(valid) { PF(c, "
%s
", cls, val); } else { HPR(c, "
—
"); } PF(c, "
%s
", unit); } // ---- Main page ---------------------------------------------- static void __attribute__((noinline)) httpSendPage(WiFiClient& client) { char tmp[32]; // Device-specific constants -- set before any use const char* devName; const char* devColor; #if defined(DEVICE_BRIDGE) devName = "obdBT-Bridge v3.1"; devColor = "#0055cc"; #else devName = "obdBT-Receiver v1.3"; devColor = "#007a3d"; #endif String ip = apMode ? WiFi.softAPIP().toString() : WiFi.localIP().toString(); PP(client, HTTP_HDR); // Head HPR(client, "" "" "" "" /* refresh via JS */); PF(client, "%s", devName); PP(client, HTML_CSS); HPR(client, ""); // Nav + refresh controls HPR(client, "
"); // Status bar HPR(client, "
"); // RPM if(pidValid[PID_RPM]) snprintf(tmp,sizeof(tmp),"%d",(int)pidValues[PID_RPM]); _sbCell(client,"RPM", pidValid[PID_RPM],"ok", tmp,"1/min"); // Speed if(pidValid[PID_SPEED]) snprintf(tmp,sizeof(tmp),"%d",(int)pidValues[PID_SPEED]); _sbCell(client,"Speed", pidValid[PID_SPEED],"ok", tmp,"km/h"); // Temp if(pidValid[PID_TEMP]) { const char* tc = pidValues[PID_TEMP]>105?"er":pidValues[PID_TEMP]>95?"wa":"ok"; snprintf(tmp,sizeof(tmp),"%d",(int)pidValues[PID_TEMP]); _sbCell(client,"Kuehlmittel", true, tc, tmp,"°C"); } else { _sbCell(client,"Kuehlmittel", false,"ok","","°C"); } // Voltage if(pidValid[PID_ECU_SPANNUNG]) { const char* vc = pidValues[PID_ECU_SPANNUNG]<11.5f?"er" : pidValues[PID_ECU_SPANNUNG]>14.8f?"wa":"ok"; snprintf(tmp,sizeof(tmp),"%.1f",pidValues[PID_ECU_SPANNUNG]); _sbCell(client,"Spannung", true, vc, tmp,"V"); } else { _sbCell(client,"Spannung", false,"ok","","V"); } #if defined(DEVICE_BRIDGE) // Akku (µC-seitig) { if(batGetValid()) { int pct = batGetPct(); float v = batGetVolt(); const char* bc = pct<15?"er":pct<30?"wa":"ok"; snprintf(tmp,sizeof(tmp),"%d",pct); char unit[12]; snprintf(unit,sizeof(unit),"%% %.2fV",v); _sbCell(client,"Akku", true, bc, tmp, unit); } else { _sbCell(client,"Akku", false,"ok","",""); } } #endif #if defined(DEVICE_BRIDGE) // MIL if(pidValid[PID_MIL_STATUS]) { bool mil = pidValues[PID_MIL_STATUS]>0.5f; _sbCell(client,"MIL", true, mil?"er":"ok", mil?"AN":"AUS",""); } else { _sbCell(client,"MIL", false,"ok","",""); } // BLE { bool con = pClient && pClient->isConnected(); _sbCell(client,"BLE", true, con?"ok":"er", con?"OK":"GETRENNT",""); } #endif #if defined(DEVICE_RECEIVER) { bool stale = (rx.rawCount==0)||(millis()-rx.lastRx>10000UL); if(!stale && rx.rawCount>0) { const char* rc = rx.rssi<-100.0f?"er":rx.rssi<-80.0f?"wa":"ok"; snprintf(tmp,sizeof(tmp),"%.0f",rx.rssi); _sbCell(client,"LoRa RSSI", true, rc, tmp,"dBm"); snprintf(tmp,sizeof(tmp),"%.0f",rx.snr); _sbCell(client,"SNR", true,"ok", tmp,"dB"); } else { _sbCell(client,"LoRa", true,"wa","WARTE",""); } } #endif HPR(client, "
"); // sb #if defined(DEVICE_BRIDGE) // DTC-Aktionsleiste (nur Bridge) HPR(client, "
"); HPR(client, "
" "" "
"); HPR(client, "
" "" "
"); HPR(client, "
"); #endif // PID table static const char* grpNames[] = { "Motor","Kraftstoff","Abgas","Zuendung","Fehler","Info" }; static const int grpEnd[] = {7,18,27,32,39,PID_COUNT_USED}; for(int g=0; g<6; g++) { int start = (g==0)?0:grpEnd[g-1]; int end = grpEnd[g]; bool any = false; for(int i=start;i%s",grpNames[g]); HPR(client,"
"); for(int i=start;i",v?"":" st"); PF(client,"%s",_grpCls(i),PID_INFO[i].id); PF(client,"%s",PID_INFO[i].name); if(v) { int dec = PID_INFO[i].decimals; if(PID_INFO[i].unit[0]=='\0') { PF(client,"%d",(int)pidValues[i]); } else if(dec==0) { PF(client,"%d" "%s", (int)pidValues[i],PID_INFO[i].unit); } else { PF(client,"%.*f" "%s", dec,pidValues[i],PID_INFO[i].unit); } } else { HPR(client,"—"); } HPR(client,"
"); } HPR(client,"
"); // pg } PP(client, HTML_FOOT); } // ---- HTTP connection state (non-blocking) ------------------- static WiFiClient _httpClient; static String _httpReq = ""; static bool _httpActive = false; static uint8_t _httpState = 0; // 0=read req, 1=drain headers, 2=respond static unsigned long _httpT = 0; #define HTTP_TIMEOUT_MS 400 void httpCheck() { // Accept new connection only when idle if(!_httpActive) { _httpClient = httpServer.available(); if(!_httpClient) return; _httpClient.setNoDelay(true); _httpReq = ""; _httpState = 0; _httpActive = true; _httpT = millis(); } // Timeout guard if(millis() - _httpT > HTTP_TIMEOUT_MS) { _httpClient.stop(); _httpActive = false; return; } if(!_httpClient.connected()) { _httpActive = false; return; } // State 0: read first request line (non-blocking, one char per call) if(_httpState == 0) { while(_httpClient.available()) { char c = (char)_httpClient.read(); if(c == '\n') { _httpState = 1; break; } if(c != '\r' && _httpReq.length() < 64) _httpReq += c; } return; } // State 1: drain remaining HTTP headers if(_httpState == 1) { while(_httpClient.available()) { char c = (char)_httpClient.read(); (void)c; } if(!_httpClient.available()) _httpState = 2; return; } // State 2: send response if(_httpState == 2) { if(_httpReq.startsWith("GET / ") || _httpReq == "GET /") { httpSendPage(_httpClient); #if defined(DEVICE_BRIDGE) } else if(_httpReq.startsWith("POST /dtc")) { // DTC lesen -- Redirect zurueck zur Hauptseite readDTCs(); _httpClient.print(F("HTTP/1.1 303 See Other\r\nLocation: /\r\nConnection: close\r\n\r\n")); } else if(_httpReq.startsWith("POST /cleardtc")) { // DTC loeschen -- Redirect zurueck zur Hauptseite clearDTCs(); _httpClient.print(F("HTTP/1.1 303 See Other\r\nLocation: /\r\nConnection: close\r\n\r\n")); #endif } else { PP(_httpClient, HTML_404); } _httpClient.stop(); _httpActive = false; } }