#include "web_server.h" namespace config { // Values should be defined in config.h #ifdef HTTP_USER const char *http_user = HTTP_USER; #else const char *http_user = ""; #endif #ifdef HTTP_PASSWORD const char *http_password = HTTP_PASSWORD; #else const char *http_password = ""; #endif } namespace web_server { const char *header_template; const char *body_template; const char *script_template; void handleWebServerRoot(); void handleWebServerCSV(); void handlePageNotFound(); void handleDeleteCSV(); #if defined(ESP8266) ESP8266WebServer http(80); // Create a webserver object that listens for HTTP request on port 80 #endif #if defined(ESP32) WebServer http(80); #endif void update() { http.handleClient(); // Listen for HTTP requests from clients } void initialize() { header_template = PSTR("" "\n" "%d ppm - CO2 SENSOR - %s - %s\n" "" // HfT Favicon "" // Responsive grid: "\n" "\n" // JS Graphs: "\n" // Fullscreen "\n" // Refresh after every measurement. // "\n" "\n" "\n" "

HfT-Stuttgart CO2 sensor

\n" "
\n"); body_template = PSTR("
\n" "
\n" // Graph placeholder "
\n" "
\n" //Sensor table "\n" "\n" "\n" "\n" "\n" "\n" "\n" "\n" "\n" #ifdef MQTT "\n" "\n" #endif "\n" "\n" "\n" "\n" "\n" "\n" "\n" "\n" "
Sensor%s
CO2 concentration%5d ppm
Temperature%.1f℃
Humidity%.1f%%
Last measurement%s
Measurement timestep%5d s
Last CSV write%s
CSV timestep%5d s
Last MQTT publish%s
MQTT publish timestep%5d s
Temperature offset%.1fK
Local address%s.local
Local IP%s
Free heap space%6d bytes
Available drive space%d kB
Max loop duration%5d ms
Board%s
Uptime%4d h %02d min %02d s
\n" // CSV placeholder "
\n" "
" "" "
\n" "
\n"); script_template = PSTR("\n" "\n" ""); // Web-server http.on("/", handleWebServerRoot); http.on("/" + csv_writer::filename, handleWebServerCSV); http.on("/delete_csv", HTTP_POST, handleDeleteCSV); http.onNotFound(handlePageNotFound); http.begin(); Serial.print(F("You can access this sensor via http://")); Serial.print(SENSOR_ID); Serial.print(F(".local (might be unstable) or http://")); Serial.println(WiFi.localIP()); } // Allow access if http_user or http_password are empty, or if provided credentials match bool shouldBeAllowed() { return strcmp(config::http_user, "") == 0 || strcmp(config::http_password, "") == 0 || http.authenticate(config::http_user, config::http_password); } void handleWebServerRoot() { if (!shouldBeAllowed()) { return http.requestAuthentication(DIGEST_AUTH); } unsigned long ss = seconds(); unsigned int hh = ss / 3600; ss -= hh * 3600; uint8_t mm = ss / 60; ss -= mm * 60; uint16_t available_fs_space = csv_writer::getAvailableSpace() / 1024; //NOTE: Splitting in multiple parts in order to use less RAM char content[2000]; // Update if needed // Header size : 1383 - Body size : 1246 - Script size : 1648 // Header snprintf_P(content, sizeof(content), header_template, sensor::co2, SENSOR_ID.c_str(), WiFi.localIP().toString().c_str(), csv_writer::filename.c_str()); http.setContentLength(CONTENT_LENGTH_UNKNOWN); http.send_P(200, PSTR("text/html"), content); // Body snprintf_P(content, sizeof(content), body_template, SENSOR_ID.c_str(), sensor::co2, sensor::temperature, sensor::humidity, sensor::timestamp.c_str(), config::measurement_timestep, csv_writer::last_successful_write.c_str(), config::csv_interval, #ifdef MQTT mqtt::last_successful_publish.c_str(), config::sending_interval, #endif config::temperature_offset, SENSOR_ID.c_str(), SENSOR_ID.c_str(), WiFi.localIP().toString().c_str(), WiFi.localIP().toString().c_str(), get_free_heap_size(), available_fs_space, max_loop_duration, BOARD, hh, mm, ss); http.sendContent(content); // Script snprintf_P(content, sizeof(content), script_template, csv_writer::filename.c_str(), SENSOR_ID.c_str()); http.sendContent(content); } void handleWebServerCSV() { if (!shouldBeAllowed()) { return http.requestAuthentication(DIGEST_AUTH); } if (FS_LIB.exists(csv_writer::filename)) { fs::File csv_file = FS_LIB.open(csv_writer::filename, "r"); http.sendHeader("Content-Length", String(csv_file.size())); http.streamFile(csv_file, F("text/csv")); csv_file.close(); } else { http.send(204, F("text/html"), F("No data available.")); } } void handleDeleteCSV() { if (!shouldBeAllowed()) { return http.requestAuthentication(DIGEST_AUTH); } Serial.print("Removing CSV file..."); FS_LIB.remove(csv_writer::filename); Serial.println(" Done!"); http.sendHeader("Location", "/"); http.send(303); } void handlePageNotFound() { http.send(404, F("text/plain"), F("404: Not found")); } }