Seich
/
HomeSpan
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Initial test of StreamBuffer added to WebLog

This commit is contained in:
Gregg 2023-12-29 22:19:49 -06:00
parent ffe56e7261
commit f3e98601b0
3 changed files with 111 additions and 61 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

105
src/HAP.cpp
View File

@ -1131,6 +1131,10 @@ int HAPClient::putPrepareURL(char *json){
int HAPClient::getStatusURL(){ int HAPClient::getStatusURL(){
// StreamBuffer *sBuf = new StreamBuffer(&client); // create buffered stream that will output to screen and client
StreamBuffer sBuf(&client);
std::ostream out(&sBuf);
char clocktime[33]; char clocktime[33];
if(homeSpan.webLog.timeInit){ if(homeSpan.webLog.timeInit){
@ -1150,86 +1154,81 @@ int HAPClient::getStatusURL(){
sprintf(uptime,"%d:%02d:%02d:%02d",days,hours,mins,secs); sprintf(uptime,"%d:%02d:%02d:%02d",days,hours,mins,secs);
String response="HTTP/1.1 200 OK\r\nContent-type: text/html; charset=utf-8\r\n\r\n"; LOG2("\n>>>>>>>>>> %s >>>>>>>>>>\n",client.remoteIP().toString().c_str());
response+="<html><head><title>" + String(homeSpan.displayName) + "</title>\n"; out << "HTTP/1.1 200 OK\r\nContent-type: text/html; charset=utf-8\r\n\r\n";
response+="<style>body {background-color:lightblue;} th, td {padding-right: 10px; padding-left: 10px; border:1px solid black;}" + homeSpan.webLog.css + "</style></head>\n"; out << "<html><head><title>" << homeSpan.displayName << "</title>\n";
response+="<body class=bod1><h2>" + String(homeSpan.displayName) + "</h2>\n"; out << "<style>body {background-color:lightblue;} th, td {padding-right: 10px; padding-left: 10px; border:1px solid black;}" << homeSpan.webLog.css << "</style></head>\n";
out << "<body class=bod1><h2>" << homeSpan.displayName << "</h2>\n";
response+="<table class=tab1>\n"; out << "<table class=tab1>\n";
response+="<tr><td>Up Time:</td><td>" + String(uptime) + "</td></tr>\n"; out << "<tr><td>Up Time:</td><td>" << uptime << "</td></tr>\n";
response+="<tr><td>Current Time:</td><td>" + String(clocktime) + "</td></tr>\n"; out << "<tr><td>Current Time:</td><td>" << clocktime << "</td></tr>\n";
response+="<tr><td>Boot Time:</td><td>" + String(homeSpan.webLog.bootTime) + "</td></tr>\n"; out << "<tr><td>Boot Time:</td><td>" << homeSpan.webLog.bootTime << "</td></tr>\n";
out << "<tr><td>Reset Reason:</td><td>";
response+="<tr><td>Reset Reason:</td><td>";
switch(esp_reset_reason()) { switch(esp_reset_reason()) {
case ESP_RST_UNKNOWN: case ESP_RST_UNKNOWN:
response += "Cannot be determined"; out << "Cannot be determined";
break; break;
case ESP_RST_POWERON: case ESP_RST_POWERON:
response += "Power-on event"; out << "Power-on event";
break; break;
case ESP_RST_EXT: case ESP_RST_EXT:
response += "External pin"; out << "External pin";
break; break;
case ESP_RST_SW: case ESP_RST_SW:
response += "Software reboot via esp_restart"; out << "Software reboot via esp_restart";
break; break;
case ESP_RST_PANIC: case ESP_RST_PANIC:
response += "Software Exception/Panic"; out << "Software Exception/Panic";
break; break;
case ESP_RST_INT_WDT: case ESP_RST_INT_WDT:
response += "Interrupt watchdog"; out << "Interrupt watchdog";
break; break;
case ESP_RST_TASK_WDT: case ESP_RST_TASK_WDT:
response += "Task watchdog"; out << "Task watchdog";
break; break;
case ESP_RST_WDT: case ESP_RST_WDT:
response += "Other watchdogs"; out << "Other watchdogs";
break; break;
case ESP_RST_DEEPSLEEP: case ESP_RST_DEEPSLEEP:
response += "Exiting deep sleep mode"; out << "Exiting deep sleep mode";
break; break;
case ESP_RST_BROWNOUT: case ESP_RST_BROWNOUT:
response += "Brownout"; out << "Brownout";
break; break;
case ESP_RST_SDIO: case ESP_RST_SDIO:
response += "SDIO"; out << "SDIO";
break; break;
default: default:
response += "Unknown Reset Code"; out << "Unknown Reset Code";
} }
response+=" (" + String(esp_reset_reason()) + ")</td></tr>\n";
response+="<tr><td>WiFi Disconnects:</td><td>" + String(homeSpan.connected/2) + "</td></tr>\n"; out << " (" << esp_reset_reason() << ")</td></tr>\n";
response+="<tr><td>WiFi Signal:</td><td>" + String(WiFi.RSSI()) + " dBm</td></tr>\n";
response+="<tr><td>WiFi Gateway:</td><td>" + WiFi.gatewayIP().toString() + "</td></tr>\n"; out << "<tr><td>WiFi Disconnects:</td><td>" << homeSpan.connected/2 << "</td></tr>\n";
response+="<tr><td>ESP32 Board:</td><td>" + String(ARDUINO_BOARD) + "</td></tr>\n"; out << "<tr><td>WiFi Signal:</td><td>" << (int)WiFi.RSSI() << " dBm</td></tr>\n";
response+="<tr><td>Arduino-ESP Version:</td><td>" + String(ARDUINO_ESP_VERSION) + "</td></tr>\n"; out << "<tr><td>WiFi Gateway:</td><td>" << WiFi.gatewayIP().toString().c_str() << "</td></tr>\n";
response+="<tr><td>ESP-IDF Version:</td><td>" + String(ESP_IDF_VERSION_MAJOR) + "." + String(ESP_IDF_VERSION_MINOR) + "." + String(ESP_IDF_VERSION_PATCH) + "</td></tr>\n"; out << "<tr><td>ESP32 Board:</td><td>" << ARDUINO_BOARD << "</td></tr>\n";
response+="<tr><td>HomeSpan Version:</td><td>" + String(HOMESPAN_VERSION) + "</td></tr>\n"; out << "<tr><td>Arduino-ESP Version:</td><td>" << ARDUINO_ESP_VERSION << "</td></tr>\n";
response+="<tr><td>Sketch Version:</td><td>" + String(homeSpan.getSketchVersion()) + "</td></tr>\n"; out << "<tr><td>ESP-IDF Version:</td><td>" << ESP_IDF_VERSION_MAJOR << "." << ESP_IDF_VERSION_MINOR << "." << ESP_IDF_VERSION_PATCH << "</td></tr>\n";
response+="<tr><td>Sodium Version:</td><td>" + String(sodium_version_string()) + " Lib " + String(sodium_library_version_major()) + "." + String(sodium_library_version_minor()) +"</td></tr>\n"; out << "<tr><td>HomeSpan Version:</td><td>" << HOMESPAN_VERSION << "</td></tr>\n";
out << "<tr><td>Sketch Version:</td><td>" << homeSpan.getSketchVersion() << "</td></tr>\n";
out << "<tr><td>Sodium Version:</td><td>" << sodium_version_string() << " Lib " << sodium_library_version_major() << "." << sodium_library_version_minor() << "</td></tr>\n";
char mbtlsv[64]; char mbtlsv[64];
mbedtls_version_get_string_full(mbtlsv); mbedtls_version_get_string_full(mbtlsv);
response+="<tr><td>MbedTLS Version:</td><td>" + String(mbtlsv) + "</td></tr>\n"; out << "<tr><td>MbedTLS Version:</td><td>" << mbtlsv << "</td></tr>\n";
response+="<tr><td>HomeKit Status:</td><td>" + String(HAPClient::nAdminControllers()?"PAIRED":"NOT PAIRED") + "</td></tr>\n"; out << "<tr><td>HomeKit Status:</td><td>" << (HAPClient::nAdminControllers()?"PAIRED":"NOT PAIRED") << "</td></tr>\n";
response+="<tr><td>Max Log Entries:</td><td>" + String(homeSpan.webLog.maxEntries) + "</td></tr>\n"; out << "<tr><td>Max Log Entries:</td><td>" << homeSpan.webLog.maxEntries << "</td></tr>\n";
if(homeSpan.weblogCallback) out << "</table>\n";
homeSpan.weblogCallback(response); out << "<p></p>";
response+="</table>\n";
response+="<p></p>";
LOG2("\n>>>>>>>>>> ");
LOG2(client.remoteIP());
LOG2(" >>>>>>>>>>\n");
if(homeSpan.webLog.maxEntries>0){ if(homeSpan.webLog.maxEntries>0){
response+="<table class=tab2><tr><th>Entry</th><th>Up Time</th><th>Log Time</th><th>Client</th><th>Message</th></tr>\n"; out << "<table class=tab2><tr><th>Entry</th><th>Up Time</th><th>Log Time</th><th>Client</th><th>Message</th></tr>\n";
int lastIndex=homeSpan.webLog.nEntries-homeSpan.webLog.maxEntries; int lastIndex=homeSpan.webLog.nEntries-homeSpan.webLog.maxEntries;
if(lastIndex<0) if(lastIndex<0)
lastIndex=0; lastIndex=0;
@ -1248,28 +1247,16 @@ int HAPClient::getStatusURL(){
else else
sprintf(clocktime,"Unknown"); sprintf(clocktime,"Unknown");
response+="<tr><td>" + String(i+1) + "</td><td>" + String(uptime) + "</td><td>" + String(clocktime) + "</td><td>" + homeSpan.webLog.log[index].clientIP + "</td><td>" + String(homeSpan.webLog.log[index].message) + "</td></tr>\n"; out << "<tr><td>" << i+1 << "</td><td>" << uptime << "</td><td>" << clocktime << "</td><td>" << homeSpan.webLog.log[index].clientIP << "</td><td>" << homeSpan.webLog.log[index].message << "</td></tr>\n";
if(response.length()>1024){ // if response grows too big, transmit chunk and reset
LOG2(response);
client.print(response);
delay(1); // slight pause seems to be required
response.clear();
} }
} out << "</table>\n";
response+="</table>\n";
} }
response+="</body></html>"; out << "</body></html>" << std::endl;
LOG2(response);
LOG2("\n");
client.print(response);
LOG2("------------ SENT! --------------\n"); LOG2("------------ SENT! --------------\n");
delay(1);
client.stop(); client.stop();
return(1); return(1);
} }

62
src/Utils.h
View File

@ -27,6 +27,9 @@
#pragma once #pragma once
#include <sstream>
#include <WiFi.h>
#include <Arduino.h> #include <Arduino.h>
#include <driver/timer.h> #include <driver/timer.h>
@ -49,6 +52,65 @@ String mask(char *c, int n); // simply utility that creates a String fr
} }
/////////////////////////////////////////////////
class StreamBuffer : public std::streambuf {
protected:
char *buffer;
WiFiClient *client;
public:
StreamBuffer(WiFiClient *client, size_t bufSize=1024){
this->client=client;
buffer=(char *)HS_MALLOC(bufSize);
setp (buffer, buffer+bufSize-1);
}
virtual ~StreamBuffer() {
free(buffer);
sync();
}
protected:
int flushBuffer(){
int num=pptr()-pbase();
// if(write(1,buffer,num)!=num)
// return EOF;
write(1,buffer,num);
client->write(buffer,num);
delay(1);
pbump(-num);
return num;
}
virtual int_type overflow(int_type c){ // buffer is full
if(c!=EOF){
*pptr() = c;
pbump(1);
}
if(flushBuffer()==EOF)
return EOF;
return c;
}
virtual int sync(){
if(flushBuffer()==EOF)
return -1;
return 0;
}
};
///////////////////////////////////////////////// /////////////////////////////////////////////////
// Creates a temporary buffer that is freed after // Creates a temporary buffer that is freed after
// going out of scope // going out of scope

3
src/src.ino
View File

@ -33,7 +33,8 @@ void setup() {
Serial.begin(115200); Serial.begin(115200);
homeSpan.setLogLevel(2); // .setPairingCode("33344456"); homeSpan.setLogLevel(2);
homeSpan.enableWebLog(200);
homeSpan.begin(Category::Lighting,"HomeSpan Max"); homeSpan.begin(Category::Lighting,"HomeSpan Max");