intermediate: restructure wifi,log

This commit is contained in:
andreas 2021-10-17 15:41:35 +02:00
parent ec67767ca6
commit 0fe10aeef8
8 changed files with 185 additions and 116 deletions

View File

@ -7,9 +7,9 @@ bool isTrue(const char * value){
return (strcasecmp(value,"true") == 0); return (strcasecmp(value,"true") == 0);
} }
class DummyConfig : public ConfigItem{ class DummyConfig : public GwConfigItem{
public: public:
DummyConfig():ConfigItem("dummy",""){} DummyConfig():GwConfigItem("dummy",""){}
virtual void fromString(const String v){ virtual void fromString(const String v){
}; };
virtual void reset(){ virtual void reset(){
@ -17,7 +17,7 @@ class DummyConfig : public ConfigItem{
}; };
DummyConfig dummyConfig; DummyConfig dummyConfig;
String ConfigHandler::toString() const{ String GwConfigHandler::toString() const{
String rt; String rt;
rt+="Config: "; rt+="Config: ";
for (int i=0;i<getNumConfig();i++){ for (int i=0;i<getNumConfig();i++){
@ -29,7 +29,7 @@ String ConfigHandler::toString() const{
return rt; return rt;
} }
String ConfigHandler::toJson() const{ String GwConfigHandler::toJson() const{
String rt; String rt;
DynamicJsonDocument jdoc(50); DynamicJsonDocument jdoc(50);
for (int i=0;i<getNumConfig();i++){ for (int i=0;i<getNumConfig();i++){
@ -38,19 +38,26 @@ String ConfigHandler::toJson() const{
serializeJson(jdoc,rt); serializeJson(jdoc,rt);
return rt; return rt;
} }
ConfigItem * ConfigHandler::findConfig(const String name, bool dummy){ GwConfigItem * GwConfigHandler::findConfig(const String name, bool dummy){
for (int i=0;i<getNumConfig();i++){ for (int i=0;i<getNumConfig();i++){
if (configs[i]->getName() == name) return configs[i]; if (configs[i]->getName() == name) return configs[i];
} }
if (!dummy) return NULL; if (!dummy) return NULL;
return &dummyConfig; return &dummyConfig;
} }
GwConfigInterface * GwConfigHandler::getConfigItem(const String name, bool dummy) const{
#define PREF_NAME "gwprefs" for (int i=0;i<getNumConfig();i++){
ConfigHandler::ConfigHandler(){ if (configs[i]->getName() == name) return configs[i];
}
if (!dummy) return NULL;
return &dummyConfig;
} }
bool ConfigHandler::loadConfig(){ #define PREF_NAME "gwprefs"
GwConfigHandler::GwConfigHandler(GwLog *logger){
this->logger=logger;
}
bool GwConfigHandler::loadConfig(){
logger->logString("config load");
prefs.begin(PREF_NAME,true); prefs.begin(PREF_NAME,true);
for (int i=0;i<getNumConfig();i++){ for (int i=0;i<getNumConfig();i++){
String v=prefs.getString(configs[i]->getName().c_str(),configs[i]->getDefault()); String v=prefs.getString(configs[i]->getName().c_str(),configs[i]->getDefault());
@ -58,31 +65,36 @@ bool ConfigHandler::loadConfig(){
prefs.end(); prefs.end();
return true; return true;
} }
bool ConfigHandler::saveConfig(){ bool GwConfigHandler::saveConfig(){
prefs.begin(PREF_NAME,false); prefs.begin(PREF_NAME,false);
for (int i=0;i<getNumConfig();i++){ for (int i=0;i<getNumConfig();i++){
prefs.putString(configs[i]->getName().c_str(),configs[i]->asString()); prefs.putString(configs[i]->getName().c_str(),configs[i]->asString());
} }
prefs.end(); prefs.end();
logger->logString("saved config");
return true; return true;
} }
bool ConfigHandler::updateValue(const char *name, const char * value){ bool GwConfigHandler::updateValue(const char *name, const char * value){
return false; GwConfigItem *i=findConfig(name);
if (i == NULL) return false;
logger->logString("update config %s=>%s",name,value);
i->fromString(value);
} }
bool ConfigHandler::reset(bool save){ bool GwConfigHandler::reset(bool save){
logger->logString("reset config");
for (int i=0;i<getNumConfig();i++){ for (int i=0;i<getNumConfig();i++){
configs[i]->reset(); configs[i]->reset();
} }
if (!save) return true; if (!save) return true;
return saveConfig(); return saveConfig();
} }
String ConfigHandler::getString(const String name){ String GwConfigHandler::getString(const String name){
ConfigItem *i=findConfig(name); GwConfigItem *i=findConfig(name);
if (!i) return String(); if (!i) return String();
return i->asString(); return i->asString();
} }
bool ConfigHandler::getBool(const String name){ bool GwConfigHandler::getBool(const String name){
ConfigItem *i=findConfig(name); GwConfigItem *i=findConfig(name);
if (!i) return false; if (!i) return false;
return i->asBoolean(); return i->asBoolean();
} }

View File

@ -2,27 +2,37 @@
#define _GWCONFIG_H #define _GWCONFIG_H
#include <Arduino.h> #include <Arduino.h>
#include <Preferences.h> #include <Preferences.h>
#include "GwLog.h"
class ConfigItem{ class GwConfigInterface{
public:
virtual String asString() const=0;
virtual const char * asCString() const =0;
virtual bool asBoolean() const = 0;
};
class GwConfigItem: public GwConfigInterface{
private: private:
String name; String name;
String initialValue; String initialValue;
String value; String value;
public: public:
ConfigItem(const String &name, const String initialValue){ GwConfigItem(const String &name, const String initialValue){
this->name=name; this->name=name;
this->initialValue=initialValue; this->initialValue=initialValue;
this->value=initialValue; this->value=initialValue;
} }
ConfigItem(const String &name, bool initalValue): GwConfigItem(const String &name, bool initalValue):
ConfigItem(name,initalValue?String("true"):String("false")){}; GwConfigItem(name,initalValue?String("true"):String("false")){};
String asString() const{ virtual String asString() const{
return value; return value;
} }
virtual const char * asCString() const{
return value.c_str();
};
virtual void fromString(const String v){ virtual void fromString(const String v){
value=v; value=v;
}; };
bool asBoolean() const{ virtual bool asBoolean() const{
return strcasecmp(value.c_str(),"true") == 0; return strcasecmp(value.c_str(),"true") == 0;
} }
String getName() const{ String getName() const{
@ -40,9 +50,10 @@ class ConfigItem{
}; };
class ConfigHandler{ class GwConfigHandler{
private: private:
Preferences prefs; Preferences prefs;
GwLog *logger;
public: public:
public: public:
const String sendUsb="sendUsb"; const String sendUsb="sendUsb";
@ -50,7 +61,7 @@ class ConfigHandler{
const String wifiClient="wifiClient"; const String wifiClient="wifiClient";
const String wifiPass="wifiPass"; const String wifiPass="wifiPass";
const String wifiSSID="wifiSSID"; const String wifiSSID="wifiSSID";
ConfigHandler(); GwConfigHandler(GwLog *logger);
bool loadConfig(); bool loadConfig();
bool saveConfig(); bool saveConfig();
bool updateValue(const char *name, const char * value); bool updateValue(const char *name, const char * value);
@ -59,17 +70,18 @@ class ConfigHandler{
String toJson() const; String toJson() const;
String getString(const String name); String getString(const String name);
bool getBool(const String name); bool getBool(const String name);
ConfigItem * findConfig(const String name, bool dummy=false); GwConfigItem * findConfig(const String name, bool dummy=false);
GwConfigInterface * getConfigItem(const String name, bool dummy=false) const;
private: private:
ConfigItem* configs[5]={ GwConfigItem* configs[5]={
new ConfigItem(sendUsb,true), new GwConfigItem(sendUsb,true),
new ConfigItem (receiveUsb,false), new GwConfigItem (receiveUsb,false),
new ConfigItem (wifiClient,false), new GwConfigItem (wifiClient,false),
new ConfigItem (wifiSSID,""), new GwConfigItem (wifiSSID,""),
new ConfigItem (wifiPass,"") new GwConfigItem (wifiPass,"")
}; };
int getNumConfig() const{ int getNumConfig() const{
return sizeof(configs)/sizeof(ConfigItem*); return sizeof(configs)/sizeof(GwConfigItem*);
} }
}; };
#endif #endif

14
lib/log/GWLog.cpp Normal file
View File

@ -0,0 +1,14 @@
#include "GwLog.h"
GwLog::GwLog(bool logSerial){
this->logSerial=logSerial;
}
void GwLog::logString(const char *fmt,...){
va_list args;
va_start(args,fmt);
vsnprintf(buffer,99,fmt,args);
if (logSerial){
Serial.print("LOG: ");
Serial.println(buffer);
}
}

12
lib/log/GwLog.h Normal file
View File

@ -0,0 +1,12 @@
#ifndef _GWLOG_H
#define _GWLOG_H
#include <Arduino.h>
class GwLog{
private:
char buffer[100];
bool logSerial=false;
public:
GwLog(bool logSerial);
void logString(const char *fmt,...);
};
#endif

21
lib/wifi/GWWifi.h Normal file
View File

@ -0,0 +1,21 @@
#ifndef _GWWIFI_H
#define _GWWIFI_H
#include <WiFi.h>
#include <GWConfig.h>
class GwWifi{
private:
const GwConfigHandler *config;
GwLog *logger;
const GwConfigInterface *wifiClient;
const GwConfigInterface *wifiSSID;
const GwConfigInterface *wifiPass;
bool connectInternal();
long lastConnectStart=0;
public:
GwWifi(const GwConfigHandler *config,GwLog *log);
void setup();
void loop();
bool clientConnected();
bool connectClient();
};
#endif

56
lib/wifi/GwWifi.cpp Normal file
View File

@ -0,0 +1,56 @@
#include "GWWifi.h"
const char *AP_ssid = "ESP32NMEA2K"; // ESP32 as AP
const char *AP_password = "esp32nmea2k"; //too short - so no pass
GwWifi::GwWifi(const GwConfigHandler *config,GwLog *log){
this->config=config;
this->logger=log;
wifiClient=config->getConfigItem(config->wifiClient,true);
wifiSSID=config->getConfigItem(config->wifiSSID,true);
wifiPass=config->getConfigItem(config->wifiPass,true);
}
void GwWifi::setup(){
logger->logString("Wifi setup");
IPAddress AP_local_ip(192, 168, 15, 1); // Static address for AP
IPAddress AP_gateway(192, 168, 15, 1);
IPAddress AP_subnet(255, 255, 255, 0);
WiFi.mode(WIFI_AP_STA); //enable both AP and client
WiFi.softAP(AP_ssid,AP_password);
delay(100);
WiFi.softAPConfig(AP_local_ip, AP_gateway, AP_subnet);
logger->logString("WifiAP created: ssid=%s,adress=%s",
AP_ssid,
WiFi.softAPIP().toString().c_str()
);
connectInternal();
}
bool GwWifi::connectInternal(){
if (wifiClient->asBoolean()){
logger->logString("creating wifiClient ssid=%s",wifiSSID->asString().c_str());
WiFi.begin(wifiSSID->asCString(),wifiPass->asCString());
lastConnectStart=millis();
return true;
}
return false;
}
#define RETRY_MILLIS 5000
void GwWifi::loop(){
if (wifiClient->asBoolean() && ! clientConnected()){
long now=millis();
if (lastConnectStart > now || (lastConnectStart+RETRY_MILLIS) < now){
logger->logString("wifiClient: retry connect to %s",wifiSSID->asCString());
WiFi.disconnect();
connectInternal();
}
}
}
bool GwWifi::clientConnected(){
return WiFi.status() == WL_CONNECTED;
};
bool GwWifi::connectClient(){
WiFi.disconnect();
return connectInternal();
}

View File

@ -23,6 +23,7 @@
#define ESP32_CAN_RX_PIN GPIO_NUM_4 // Set CAN RX port to 4 #define ESP32_CAN_RX_PIN GPIO_NUM_4 // Set CAN RX port to 4
#endif #endif
#define LOG_SERIAL true
#include <Arduino.h> #include <Arduino.h>
#include <NMEA2000_CAN.h> // This will automatically choose right CAN library and create suitable NMEA2000 object #include <NMEA2000_CAN.h> // This will automatically choose right CAN library and create suitable NMEA2000 object
@ -37,7 +38,10 @@
#include "List.h" #include "List.h"
#include "BoatData.h" #include "BoatData.h"
#include "GwLog.h"
#include "GWConfig.h" #include "GWConfig.h"
#include "GWWifi.h"
@ -47,29 +51,11 @@
#define HighTempAlarm 12 // Alarm level for fridge temperature (higher) #define HighTempAlarm 12 // Alarm level for fridge temperature (higher)
#define LowVoltageAlarm 11 // Alarm level for battery voltage (lower) #define LowVoltageAlarm 11 // Alarm level for battery voltage (lower)
#define ADC_Calibration_Value 34.3 // The real value depends on the true resistor values for the ADC input (100K / 27 K)
#define WLAN_CLIENT 0 // Set to 1 to enable client network. 0 to act as AP only GwLog logger(LOG_SERIAL);
GwConfigHandler config(&logger);
GwWifi gwWifi(&config,&logger);
ConfigHandler config;
// Wifi cofiguration Client and Access Point
const char *AP_ssid = "MyESP32"; // ESP32 as AP
const char *CL_ssid = "MyWLAN"; // ESP32 as client in network
const char *AP_password = "appassw"; // AP password
const char *CL_password = "clientpw"; // Client password
// Put IP address details here
IPAddress AP_local_ip(192, 168, 15, 1); // Static address for AP
IPAddress AP_gateway(192, 168, 15, 1);
IPAddress AP_subnet(255, 255, 255, 0);
IPAddress CL_local_ip(192, 168, 1, 10); // Static address for Client Network. Please adjust to your AP IP and DHCP range!
IPAddress CL_gateway(192, 168, 1, 1);
IPAddress CL_subnet(255, 255, 255, 0);
int wifiType = 0; // 0= Client 1= AP
//counter //counter
int numCan=0; int numCan=0;
@ -175,6 +161,8 @@ void js_status(){
DynamicJsonDocument status(50); DynamicJsonDocument status(50);
status["numcan"]=numCan; status["numcan"]=numCan;
status["version"]=VERSION; status["version"]=VERSION;
status["wifiConnected"]=gwWifi.clientConnected();
status["clientIP"]=WiFi.localIP().toString();
String buf; String buf;
serializeJson(status,buf); serializeJson(status,buf);
webserver.send(200,F("application/json"),buf); webserver.send(200,F("application/json"),buf);
@ -184,7 +172,7 @@ void js_config(){
webserver.send(200,F("application/json"),config.toJson()); webserver.send(200,F("application/json"),config.toJson());
} }
void web_config(){ void web_setConfig(){
} }
void handleNotFound() void handleNotFound()
@ -193,14 +181,14 @@ void handleNotFound()
} }
ConfigItem *sendUsb=NULL; GwConfigInterface *sendUsb=NULL;
void setup() { void setup() {
uint8_t chipid[6]; uint8_t chipid[6];
uint32_t id = 0; uint32_t id = 0;
int i = 0; int i = 0;
int wifi_retry = 0;
// Init USB serial port // Init USB serial port
@ -208,46 +196,9 @@ void setup() {
Serial.println("Starting..."); Serial.println("Starting...");
config.loadConfig(); config.loadConfig();
Serial.println(config.toString()); Serial.println(config.toString());
sendUsb=config.findConfig(config.sendUsb,true); sendUsb=config.getConfigItem(config.sendUsb,true);
// Init AIS serial port 2
//Serial2.begin(baudrate, rs_config);
//NMEA0183.Begin(&Serial2, 3, baudrate);
if (WLAN_CLIENT == 1) {
Serial.println("Start WLAN Client"); // WiFi Mode Client
WiFi.config(CL_local_ip, CL_gateway, CL_subnet, CL_gateway);
delay(100);
WiFi.begin(CL_ssid, CL_password);
while (WiFi.status() != WL_CONNECTED && wifi_retry < 20) { // Check connection, try 10 seconds
wifi_retry++;
delay(5000);
Serial.print(".");
}
}
if (WiFi.status() != WL_CONNECTED) { // No client connection start AP
// Init wifi connection
Serial.println("Start WLAN AP"); // WiFi Mode AP
WiFi.mode(WIFI_AP);
WiFi.softAP(AP_ssid, AP_password);
delay(100);
WiFi.softAPConfig(AP_local_ip, AP_gateway, AP_subnet);
IPAddress IP = WiFi.softAPIP();
Serial.println("");
Serial.print("AP IP address: ");
Serial.println(IP);
wifiType = 1;
} else { // Wifi Client connection was sucessfull
Serial.println("");
Serial.println("WiFi client connected");
Serial.println("IP client address: ");
Serial.println(WiFi.localIP());
}
gwWifi.setup();
// Start TCP server // Start TCP server
server.begin(); server.begin();
@ -477,6 +428,7 @@ void loop() {
int wifi_retry; int wifi_retry;
webserver.handleClient(); webserver.handleClient();
gwWifi.loop();
handle_json(); handle_json();
if (NMEA0183.GetMessage(NMEA0183Msg)) { // Get AIS NMEA sentences from serial2 if (NMEA0183.GetMessage(NMEA0183Msg)) { // Get AIS NMEA sentences from serial2
@ -517,22 +469,4 @@ void loop() {
Serial.read(); Serial.read();
} }
if (wifiType == 0) { // Check connection if working as client
wifi_retry = 0;
while (WiFi.status() != WL_CONNECTED && wifi_retry < 5 ) { // Connection lost, 5 tries to reconnect
wifi_retry++;
Serial.println("WiFi not connected. Try to reconnect");
WiFi.disconnect();
WiFi.mode(WIFI_OFF);
WiFi.mode(WIFI_STA);
WiFi.begin(CL_ssid, CL_password);
delay(1000);
}
if (wifi_retry >= 5) {
Serial.println("\nReboot"); // Did not work -> restart ESP32
ESP.restart();
}
}
} }

View File

@ -57,6 +57,14 @@ span.label {
<span class="label"># CAN messages</span> <span class="label"># CAN messages</span>
<span class="value" id="numcan">---</span> <span class="value" id="numcan">---</span>
</div> </div>
<div class="row">
<span class="label">wifi client connected</span>
<span class="value" id="wifiConnected">---</span>
</div>
<div class="row">
<span class="label">wifi client IP</span>
<span class="value" id="clientIP">---</span>
</div>
<button id="reset" onclick="reset();">Reset</button> <button id="reset" onclick="reset();">Reset</button>
</div> </div>
</body> </body>