Subversion Repositories ESP32_P1_Meter

#include <ArduinoOTA.h>

#include <EEPROM.h>

#include <FS.h>

#include <Ticker.h>

#include <LittleFS.h>

#include <MQTTRemote.h>

#include <AsyncFsWebServer.h>  //https://github.com/cotestatnt/async-esp-fs-webserver

#include <FS.h>

#define FILESYSTEM LittleFS

#include <LittleFS.h>

bool captiveRun = false;

#include <AsyncFsWebServer.h>  //https://github.com/cotestatnt/async-esp-fs-webserver

// AsyncFsWebServer server(80, FILESYSTEM, "esphost");

AsyncFsWebServer server(80, FILESYSTEM);

// * Include settings

#include "settings.h"

#ifndef Default_MQTT_Port

#define Default_MQTT_Port 1883

// * Initiate led blinker library

#endif

Ticker ticker;

#define BTN_SAVE  5

#define FILESYSTEM LittleFS

bool captiveRun = false;

// Test "options" values

uint16_t MQTT_Port = Default_MQTT_Port;

// AsyncFsWebServer server(80, FILESYSTEM, "esphost");

bool MQTT_Enabled = false;

AsyncFsWebServer server(80, FILESYSTEM);

String MQTT_Server = "";

String MQTT_User = "";

#ifndef Default_MQTT_Port

String MQTT_Password = "";

#define Default_MQTT_Port 1883

String MQTT_Prefix = "";

#endif

// Var labels (in /setup webpage)

#define BTN_SAVE  5

#define MQTT_ENABLED_LABEL "MQTT Enabled"

#define MQTT_SERVER_LABEL "MQTT Server"

// Test "options" values

#define MQTT_PORT_LABEL "MQTT Server Port"

uint16_t MQTT_Port = Default_MQTT_Port;

#define MQTT_USER_LABEL "MQTT User"

bool MQTT_Enabled = false;

#define MQTT_PASSWORD_LABEL "MQTT Password"

String MQTT_Client = "ESP32_P1_Meter";

#define MQTT_PREFIX_LABEL "MQTT Prefix"

String MQTT_Server = "";

String MQTT_User = "";

// Timezone definition to get properly time from NTP server

String MQTT_Password = "";

#define MYTZ "CET-1CEST,M3.5.0,M10.5.0/3"

String MQTT_Prefix = "";

struct tm Time;

// Var labels (in /setup webpage)

static const char save_btn_htm[] PROGMEM = R"EOF(

#define MQTT_ENABLED_LABEL "MQTT Enabled"

<div class="btn-bar">

#define MQTT_CLIENT_LABEL "MQTT Client"

  <a class="btn" id="reload-btn">Reload options</a>

#define MQTT_SERVER_LABEL "MQTT Server"

</div>

#define MQTT_PORT_LABEL "MQTT Server Port"

)EOF";

#define MQTT_USER_LABEL "MQTT User"

#define MQTT_PASSWORD_LABEL "MQTT Password"

static const char button_script[] PROGMEM = R"EOF(

#define MQTT_PREFIX_LABEL "MQTT Prefix"

/* Add click listener to button */

document.getElementById('reload-btn').addEventListener('click', reload);

// Timezone definition to get properly time from NTP server

function reload() {

#define MYTZ "CET-1CEST,M3.5.0,M10.5.0/3"

  console.log('Reload configuration options');

struct tm Time;

  fetch('/reload')

  .then((response) => {

static const char save_btn_htm[] PROGMEM = R"EOF(

    if (response.ok) {

<div class="btn-bar">

      openModalMessage('Options loaded', 'Options was reloaded from configuration file');

  <a class="btn" id="reload-btn">Reload options</a>

      return;

</div>

    }

)EOF";

    throw new Error('Something goes wrong with fetch');

  })

static const char button_script[] PROGMEM = R"EOF(

  .catch((error) => {

/* Add click listener to button */

    openModalMessage('Error', 'Something goes wrong with your request');

document.getElementById('reload-btn').addEventListener('click', reload);

  });

function reload() {

}

  console.log('Reload configuration options');

)EOF";

  fetch('/reload')

  .then((response) => {

    if (response.ok) {

////////////////////////////////  Filesystem  /////////////////////////////////////////

      openModalMessage('Options loaded', 'Options was reloaded from configuration file');

bool startFilesystem() {

      return;

  if (FILESYSTEM.begin()){

    }

    server.printFileList(FILESYSTEM, "/", 2);

    throw new Error('Something goes wrong with fetch');

    return true;

  })

  }

  .catch((error) => {

  else {

    openModalMessage('Error', 'Something goes wrong with your request');

    Serial.println("ERROR on mounting filesystem. It will be reformatted!");

  });

    FILESYSTEM.format();

}

    ESP.restart();

)EOF";

  }

  return false;

}

////////////////////////////////  Filesystem  /////////////////////////////////////////

bool startFilesystem() {

/*

  if (FILESYSTEM.begin()){

* Getting FS info (total and free bytes) is strictly related to

    server.printFileList(FILESYSTEM, "/", 2);

* filesystem library used (LittleFS, FFat, SPIFFS etc etc) and ESP framework

    return true;

*/

  }

#ifdef ESP32

  else {

void getFsInfo(fsInfo_t* fsInfo) {

    Serial.println("ERROR on mounting filesystem. It will be reformatted!");

	fsInfo->fsName = "LittleFS";

    FILESYSTEM.format();

	fsInfo->totalBytes = LittleFS.totalBytes();

    ESP.restart();

	fsInfo->usedBytes = LittleFS.usedBytes();

  }

}

  return false;

#endif

}

////////////////////  Load application options from filesystem  ////////////////////

/*

bool loadOptions() {

* Getting FS info (total and free bytes) is strictly related to

  if (FILESYSTEM.exists(server.getConfiFileName())) {

* filesystem library used (LittleFS, FFat, SPIFFS etc etc) and ESP framework

    server.getOptionValue(MQTT_ENABLED_LABEL, MQTT_Enabled);

*/

    server.getOptionValue(MQTT_SERVER_LABEL, MQTT_Server);

#ifdef ESP32

    server.getOptionValue(MQTT_PORT_LABEL, MQTT_Port);

void getFsInfo(fsInfo_t* fsInfo) {

    server.getOptionValue(MQTT_USER_LABEL, MQTT_User);

	fsInfo->fsName = "LittleFS";

    server.getOptionValue(MQTT_PASSWORD_LABEL, MQTT_Password);

	fsInfo->totalBytes = LittleFS.totalBytes();

    server.getOptionValue(MQTT_PREFIX_LABEL, MQTT_Prefix);

	fsInfo->usedBytes = LittleFS.usedBytes();

}

    Serial.println("\nThis are the current values stored: \n");

#endif

    Serial.printf("MQTT Enabled: %s\n", MQTT_Enabled ? "true" : "false");

    Serial.printf("MQTT Server: %s\n", MQTT_Server.c_str());

////////////////////  Load application options from filesystem  ////////////////////

    Serial.printf("MQTT Server Port: %d\n", MQTT_Port);

bool loadOptions() {

    Serial.printf("MQTT User: %s\n", MQTT_User.c_str());

  if (FILESYSTEM.exists(server.getConfiFileName())) {

    Serial.printf("MQTT password: %s\n", MQTT_Password.c_str());

    server.getOptionValue(MQTT_ENABLED_LABEL, MQTT_Enabled);

    Serial.printf("MQTT Prefix: %s\n", MQTT_Prefix.c_str());

    server.getOptionValue(MQTT_CLIENT_LABEL, MQTT_Client);

    return true;

    server.getOptionValue(MQTT_SERVER_LABEL, MQTT_Server);

  }

    server.getOptionValue(MQTT_PORT_LABEL, MQTT_Port);

  else

    server.getOptionValue(MQTT_USER_LABEL, MQTT_User);

    Serial.println(F("Config file not exist"));

    server.getOptionValue(MQTT_PASSWORD_LABEL, MQTT_Password);

  return false;

    server.getOptionValue(MQTT_PREFIX_LABEL, MQTT_Prefix);

}

    Serial.println("\nThis are the current values stored: \n");

void saveOptions() {

    Serial.printf("MQTT Enabled: %s\n", MQTT_Enabled ? "true" : "false");

  // server.saveOptionValue(LED_LABEL, ledPin);

    Serial.printf("MQTT Client: %s\n", MQTT_Client.c_str());

  // server.saveOptionValue(BOOL_LABEL, boolVar);

    Serial.printf("MQTT Server: %s\n", MQTT_Server.c_str());

  // server.saveOptionValue(LONG_LABEL, longVar);

    Serial.printf("MQTT Server Port: %d\n", MQTT_Port);

  // server.saveOptionValue(FLOAT_LABEL, floatVar);

    Serial.printf("MQTT User: %s\n", MQTT_User.c_str());

  // server.saveOptionValue(STRING_LABEL, stringVar);

    Serial.printf("MQTT password: %s\n", MQTT_Password.c_str());

  // server.saveOptionValue(DROPDOWN_LABEL, dropdownSelected);

    Serial.printf("MQTT Prefix: %s\n", MQTT_Prefix.c_str());

  Serial.println(F("Application options saved."));

    return true;

}

  }

  else

////////////////////////////  HTTP Request Handlers  ////////////////////////////////////

    Serial.println(F("Config file not exist"));

void handleLoadOptions(AsyncWebServerRequest *request) {

  return false;

  request->send(200, "text/plain", "Options loaded");

}

  loadOptions();

  Serial.println("Application option loaded after web request");

MQTTRemote _mqtt_remote(MQTT_Client.c_str(), MQTT_Server.c_str(), MQTT_Port.c_str(), MQTT_User.c_str(), MQTT_Password.c_str(),

}

                        {.rx_buffer_size = 2048, .tx_buffer_size = 2048, .keep_alive_s = 10});

bool _was_connected = false;

void setup() {

void saveOptions() {

  Serial.begin(115200);

  // server.saveOptionValue(LED_LABEL, ledPin);

  pinMode(BTN_SAVE, INPUT_PULLUP);

  // server.saveOptionValue(BOOL_LABEL, boolVar);

  // server.saveOptionValue(LONG_LABEL, longVar);

  // FILESYSTEM INIT

  // server.saveOptionValue(FLOAT_LABEL, floatVar);

  if (startFilesystem()){

  // server.saveOptionValue(STRING_LABEL, stringVar);

    // Load configuration (if not present, default will be created when webserver will start)

  // server.saveOptionValue(DROPDOWN_LABEL, dropdownSelected);

    if (loadOptions())

  Serial.println(F("Application options saved."));

      Serial.println(F("Application option loaded"));

}

    else

      Serial.println(F("Application options NOT loaded!"));

////////////////////////////  HTTP Request Handlers  ////////////////////////////////////

  }

void handleLoadOptions(AsyncWebServerRequest *request) {

  request->send(200, "text/plain", "Options loaded");

  // Try to connect to stored SSID, start AP with captive portal if fails after timeout

  loadOptions();

  IPAddress myIP = server.startWiFi(15000);

  Serial.println("Application option loaded after web request");

  if (!myIP) {

}

    Serial.println("\n\nNo WiFi connection, start AP and Captive Portal\n");

    server.startCaptivePortal("ESP_AP", "123456789", "/setup");

    myIP = WiFi.softAPIP();

void setup() {

    captiveRun = true;

  Serial.begin(115200);

  }

  pinMode(BTN_SAVE, INPUT_PULLUP);

  // Add custom page handlers to webserver

  // FILESYSTEM INIT

  server.on("/reload", HTTP_GET, handleLoadOptions);

  if (startFilesystem()){

    // Load configuration (if not present, default will be created when webserver will start)

  // Configure /setup page and start Web Server

    if (loadOptions())

  server.addOptionBox("MQTT");

      Serial.println(F("Application option loaded"));

    else

  server.addOption(MQTT_ENABLED_LABEL, MQTT_Enabled);

      Serial.println(F("Application options NOT loaded!"));

  server.addOption(MQTT_SERVER_LABEL, MQTT_Server);

  }

  server.addOption(MQTT_PORT_LABEL, MQTT_Port);

  server.addOption(MQTT_USER_LABEL, MQTT_User);

  // Try to connect to stored SSID, start AP with captive portal if fails after timeout

  server.addOption(MQTT_PASSWORD_LABEL, MQTT_Password);

  IPAddress myIP = server.startWiFi(15000);

  server.addOption(MQTT_PREFIX_LABEL, MQTT_Prefix);

  if (!myIP) {

  server.addOptionBox(const char *title);

    Serial.println("\n\nNo WiFi connection, start AP and Captive Portal\n");

    server.startCaptivePortal("ESP_AP", "123456789", "/setup");

  server.addHTML(save_btn_htm, "buttons", /*overwrite*/ false);

    myIP = WiFi.softAPIP();

  server.addJavascript(button_script, "js", /*overwrite*/ false);

    captiveRun = true;

  }

  // Enable ACE FS file web editor and add FS info callback function

  server.enableFsCodeEditor();

  // Add custom page handlers to webserver

  #ifdef ESP32

  server.on("/reload", HTTP_GET, handleLoadOptions);

  server.setFsInfoCallback(getFsInfo);

  #endif

  // Configure /setup page and start Web Server

  server.addOptionBox("MQTT");

  // set /setup and /edit page authentication

  server.setAuthentication("admin", "admin");

  server.addOption(MQTT_ENABLED_LABEL, MQTT_Enabled);

  server.addOption(MQTT_SERVER_LABEL, MQTT_Server);

  // Start server

  server.addOption(MQTT_PORT_LABEL, MQTT_Port);

  server.init();

  server.addOption(MQTT_USER_LABEL, MQTT_User);

  Serial.print(F("ESP Web Server started on IP Address: "));

  server.addOption(MQTT_PASSWORD_LABEL, MQTT_Password);

  Serial.println(myIP);

  server.addOption(MQTT_PREFIX_LABEL, MQTT_Prefix);

  Serial.println(F(

  server.addOptionBox(const char *title);

      "This is \"customOptions.ino\" example.\n"

      "Open /setup page to configure optional parameters.\n"

  server.addHTML(save_btn_htm, "buttons", /*overwrite*/ false);

      "Open /edit page to view, edit or upload example or your custom webserver source files."

  server.addJavascript(button_script, "js", /*overwrite*/ false);

  ));

}

  // Enable ACE FS file web editor and add FS info callback function

  server.enableFsCodeEditor();

void loop() {

  #ifdef ESP32

  if (captiveRun)

  server.setFsInfoCallback(getFsInfo);

    server.updateDNS();

  #endif

  // Savew options also on button click

  // set /setup and /edit page authentication

  if (! digitalRead(BTN_SAVE)) {

  server.setAuthentication("admin", "admin");

    saveOptions();

    delay(1000);

  // Start server

  }

  server.init();

}

  Serial.print(F("ESP Web Server started on IP Address: "));