mirror of
https://github.com/rstrouse/ESPSomfy-RTS.git
synced 2025-12-16 12:22:13 +01:00
Compare commits
9 commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
eb75868adb | ||
|
|
3d9e6c11c2 | ||
|
|
e478d17c7f | ||
|
|
93ebddd29d | ||
|
|
fb1f18e260 | ||
|
|
c3ada3b40e | ||
|
|
75928b4ac8 | ||
|
|
0b985c0880 | ||
|
|
e04d7e3fc7 |
20 changed files with 394 additions and 195 deletions
4
.github/workflows/release.yaml
vendored
4
.github/workflows/release.yaml
vendored
|
|
@ -91,7 +91,7 @@ jobs:
|
||||||
- board: esp32c3
|
- board: esp32c3
|
||||||
addr_bootloader: 0x0
|
addr_bootloader: 0x0
|
||||||
chip: ESP32-C3
|
chip: ESP32-C3
|
||||||
fqbn: esp32:esp32:esp32c3:JTAGAdapter=default,CDCOnBoot=default,PartitionScheme=default,CPUFreq=160,FlashMode=qio,FlashFreq=80,FlashSize=4M,UploadSpeed=921600,DebugLevel=none,EraseFlash=none
|
fqbn: esp32:esp32:esp32c3:JTAGAdapter=default,CDCOnBoot=cdc,PartitionScheme=default,CPUFreq=160,FlashMode=qio,FlashFreq=80,FlashSize=4M,UploadSpeed=921600,DebugLevel=none,EraseFlash=none
|
||||||
# esp32:esp32:esp32c3:JTAGAdapter=default,CDCOnBoot=default,PartitionScheme=default,CPUFreq=160,FlashMode=qio,FlashFreq=80,FlashSize=4M,UploadSpeed=921600,DebugLevel=none,EraseFlash=none
|
# esp32:esp32:esp32c3:JTAGAdapter=default,CDCOnBoot=default,PartitionScheme=default,CPUFreq=160,FlashMode=qio,FlashFreq=80,FlashSize=4M,UploadSpeed=921600,DebugLevel=none,EraseFlash=none
|
||||||
name: ESP32C3
|
name: ESP32C3
|
||||||
obname: SomfyController.onboard.esp32c3.bin
|
obname: SomfyController.onboard.esp32c3.bin
|
||||||
|
|
@ -99,7 +99,7 @@ jobs:
|
||||||
- board: esp32s2
|
- board: esp32s2
|
||||||
addr_bootloader: 0x1000
|
addr_bootloader: 0x1000
|
||||||
chip: ESP32-S2
|
chip: ESP32-S2
|
||||||
fqbn: esp32:esp32:esp32s2:JTAGAdapter=default,CDCOnBoot=default,MSCOnBoot=default,DFUOnBoot=default,UploadMode=default,PSRAM=disabled,PartitionScheme=default,CPUFreq=240,FlashMode=qio,FlashFreq=80,FlashSize=4M,UploadSpeed=921600,DebugLevel=none,EraseFlash=none
|
fqbn: esp32:esp32:esp32s2:JTAGAdapter=default,CDCOnBoot=cdc,MSCOnBoot=default,DFUOnBoot=default,UploadMode=default,PSRAM=disabled,PartitionScheme=default,CPUFreq=240,FlashMode=qio,FlashFreq=80,FlashSize=4M,UploadSpeed=921600,DebugLevel=none,EraseFlash=none
|
||||||
# esp32:esp32:esp32s2:JTAGAdapter=default,CDCOnBoot=default,MSCOnBoot=default,DFUOnBoot=default,UploadMode=default,PSRAM=disabled,PartitionScheme=default,CPUFreq=240,FlashMode=qio,FlashFreq=80,FlashSize=4M,UploadSpeed=921600,DebugLevel=none,EraseFlash=none
|
# esp32:esp32:esp32s2:JTAGAdapter=default,CDCOnBoot=default,MSCOnBoot=default,DFUOnBoot=default,UploadMode=default,PSRAM=disabled,PartitionScheme=default,CPUFreq=240,FlashMode=qio,FlashFreq=80,FlashSize=4M,UploadSpeed=921600,DebugLevel=none,EraseFlash=none
|
||||||
name: ESP32S2
|
name: ESP32S2
|
||||||
obname: SomfyController.onboard.esp32s2.bin
|
obname: SomfyController.onboard.esp32s2.bin
|
||||||
|
|
|
||||||
1
.gitignore
vendored
1
.gitignore
vendored
|
|
@ -7,3 +7,4 @@ debug.cfg
|
||||||
SomfyController.ino.XIAO_ESP32S3.bin
|
SomfyController.ino.XIAO_ESP32S3.bin
|
||||||
SomfyController.ino.esp32c3.bin
|
SomfyController.ino.esp32c3.bin
|
||||||
SomfyController.ino.esp32s2.bin
|
SomfyController.ino.esp32s2.bin
|
||||||
|
.vscode/settings.json
|
||||||
|
|
|
||||||
|
|
@ -580,18 +580,21 @@ bool WifiSettings::fromJSON(JsonObject &obj) {
|
||||||
this->parseValueString(obj, "ssid", this->ssid, sizeof(this->ssid));
|
this->parseValueString(obj, "ssid", this->ssid, sizeof(this->ssid));
|
||||||
this->parseValueString(obj, "passphrase", this->passphrase, sizeof(this->passphrase));
|
this->parseValueString(obj, "passphrase", this->passphrase, sizeof(this->passphrase));
|
||||||
if(obj.containsKey("roaming")) this->roaming = obj["roaming"];
|
if(obj.containsKey("roaming")) this->roaming = obj["roaming"];
|
||||||
|
if(obj.containsKey("hidden")) this->hidden = obj["hidden"];
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
bool WifiSettings::toJSON(JsonObject &obj) {
|
bool WifiSettings::toJSON(JsonObject &obj) {
|
||||||
obj["ssid"] = this->ssid;
|
obj["ssid"] = this->ssid;
|
||||||
obj["passphrase"] = this->passphrase;
|
obj["passphrase"] = this->passphrase;
|
||||||
obj["roaming"] = this->roaming;
|
obj["roaming"] = this->roaming;
|
||||||
|
obj["hidden"] = this->hidden;
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
void WifiSettings::toJSON(JsonResponse &json) {
|
void WifiSettings::toJSON(JsonResponse &json) {
|
||||||
json.addElem("ssid", this->ssid);
|
json.addElem("ssid", this->ssid);
|
||||||
json.addElem("passphrase", this->passphrase);
|
json.addElem("passphrase", this->passphrase);
|
||||||
json.addElem("roaming", this->roaming);
|
json.addElem("roaming", this->roaming);
|
||||||
|
json.addElem("hidden", this->hidden);
|
||||||
}
|
}
|
||||||
|
|
||||||
bool WifiSettings::save() {
|
bool WifiSettings::save() {
|
||||||
|
|
@ -600,6 +603,7 @@ bool WifiSettings::save() {
|
||||||
pref.putString("ssid", this->ssid);
|
pref.putString("ssid", this->ssid);
|
||||||
pref.putString("passphrase", this->passphrase);
|
pref.putString("passphrase", this->passphrase);
|
||||||
pref.putBool("roaming", this->roaming);
|
pref.putBool("roaming", this->roaming);
|
||||||
|
pref.putBool("hidden", this->hidden);
|
||||||
pref.end();
|
pref.end();
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
@ -610,6 +614,7 @@ bool WifiSettings::load() {
|
||||||
this->ssid[sizeof(this->ssid) - 1] = '\0';
|
this->ssid[sizeof(this->ssid) - 1] = '\0';
|
||||||
this->passphrase[sizeof(this->passphrase) - 1] = '\0';
|
this->passphrase[sizeof(this->passphrase) - 1] = '\0';
|
||||||
this->roaming = pref.getBool("roaming", true);
|
this->roaming = pref.getBool("roaming", true);
|
||||||
|
this->hidden = pref.getBool("hidden", false);
|
||||||
pref.end();
|
pref.end();
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -3,7 +3,7 @@
|
||||||
#ifndef configsettings_h
|
#ifndef configsettings_h
|
||||||
#define configsettings_h
|
#define configsettings_h
|
||||||
#include "WResp.h"
|
#include "WResp.h"
|
||||||
#define FW_VERSION "v2.4.5"
|
#define FW_VERSION "v2.4.7"
|
||||||
enum class conn_types_t : byte {
|
enum class conn_types_t : byte {
|
||||||
unset = 0x00,
|
unset = 0x00,
|
||||||
wifi = 0x01,
|
wifi = 0x01,
|
||||||
|
|
@ -72,6 +72,7 @@ class WifiSettings: BaseSettings {
|
||||||
public:
|
public:
|
||||||
WifiSettings();
|
WifiSettings();
|
||||||
bool roaming = true;
|
bool roaming = true;
|
||||||
|
bool hidden = false;
|
||||||
char ssid[65] = "";
|
char ssid[65] = "";
|
||||||
char passphrase[65] = "";
|
char passphrase[65] = "";
|
||||||
//bool ssdpBroadcast = true;
|
//bool ssdpBroadcast = true;
|
||||||
|
|
|
||||||
|
|
@ -252,6 +252,7 @@ void GitRepo::toJSON(JsonResponse &json) {
|
||||||
#define ERR_DOWNLOAD_CONNECTION -42
|
#define ERR_DOWNLOAD_CONNECTION -42
|
||||||
|
|
||||||
void GitUpdater::loop() {
|
void GitUpdater::loop() {
|
||||||
|
if(!net.connected()) return;
|
||||||
if(this->status == GIT_STATUS_READY) {
|
if(this->status == GIT_STATUS_READY) {
|
||||||
if(settings.checkForUpdate &&
|
if(settings.checkForUpdate &&
|
||||||
(millis() > net.connectTime + 60000) && // Wait a minute before checking after connection.
|
(millis() > net.connectTime + 60000) && // Wait a minute before checking after connection.
|
||||||
|
|
|
||||||
14
MQTT.cpp
14
MQTT.cpp
|
|
@ -35,12 +35,16 @@ void MQTTClass::reset() {
|
||||||
this->connect();
|
this->connect();
|
||||||
}
|
}
|
||||||
bool MQTTClass::loop() {
|
bool MQTTClass::loop() {
|
||||||
if(settings.MQTT.enabled && !rebootDelay.reboot && !this->suspended && !mqttClient.connected())
|
if(settings.MQTT.enabled && !rebootDelay.reboot && !this->suspended && !mqttClient.connected()) {
|
||||||
this->connect();
|
esp_task_wdt_reset();
|
||||||
|
if(!this->connected() && net.connected()) this->connect();
|
||||||
|
}
|
||||||
|
esp_task_wdt_reset();
|
||||||
if(settings.MQTT.enabled) mqttClient.loop();
|
if(settings.MQTT.enabled) mqttClient.loop();
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
void MQTTClass::receive(const char *topic, byte*payload, uint32_t length) {
|
void MQTTClass::receive(const char *topic, byte*payload, uint32_t length) {
|
||||||
|
esp_task_wdt_reset(); // Make sure we do not reboot here.
|
||||||
Serial.print("MQTT Topic:");
|
Serial.print("MQTT Topic:");
|
||||||
Serial.print(topic);
|
Serial.print(topic);
|
||||||
Serial.print(" payload:");
|
Serial.print(" payload:");
|
||||||
|
|
@ -179,8 +183,10 @@ void MQTTClass::receive(const char *topic, byte*payload, uint32_t length) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
esp_task_wdt_reset(); // Make sure we do not reboot here.
|
||||||
}
|
}
|
||||||
bool MQTTClass::connect() {
|
bool MQTTClass::connect() {
|
||||||
|
esp_task_wdt_reset(); // Make sure we do not reboot here.
|
||||||
if(mqttClient.connected()) {
|
if(mqttClient.connected()) {
|
||||||
if(!settings.MQTT.enabled || this->suspended)
|
if(!settings.MQTT.enabled || this->suspended)
|
||||||
return this->disconnect();
|
return this->disconnect();
|
||||||
|
|
@ -275,6 +281,7 @@ bool MQTTClass::unsubscribe(const char *topic) {
|
||||||
}
|
}
|
||||||
bool MQTTClass::subscribe(const char *topic) {
|
bool MQTTClass::subscribe(const char *topic) {
|
||||||
if(mqttClient.connected()) {
|
if(mqttClient.connected()) {
|
||||||
|
esp_task_wdt_reset(); // Make sure we do not reboot here.
|
||||||
char top[128];
|
char top[128];
|
||||||
if(strlen(settings.MQTT.rootTopic) > 0)
|
if(strlen(settings.MQTT.rootTopic) > 0)
|
||||||
snprintf(top, sizeof(top), "%s/%s", settings.MQTT.rootTopic, topic);
|
snprintf(top, sizeof(top), "%s/%s", settings.MQTT.rootTopic, topic);
|
||||||
|
|
@ -293,6 +300,7 @@ bool MQTTClass::publish(const char *topic, const char *payload, bool retain) {
|
||||||
snprintf(top, sizeof(top), "%s/%s", settings.MQTT.rootTopic, topic);
|
snprintf(top, sizeof(top), "%s/%s", settings.MQTT.rootTopic, topic);
|
||||||
else
|
else
|
||||||
strlcpy(top, topic, sizeof(top));
|
strlcpy(top, topic, sizeof(top));
|
||||||
|
esp_task_wdt_reset(); // Make sure we do not reboot here.
|
||||||
mqttClient.publish(top, payload, retain);
|
mqttClient.publish(top, payload, retain);
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
@ -309,6 +317,7 @@ bool MQTTClass::unpublish(const char *topic) {
|
||||||
snprintf(top, sizeof(top), "%s/%s", settings.MQTT.rootTopic, topic);
|
snprintf(top, sizeof(top), "%s/%s", settings.MQTT.rootTopic, topic);
|
||||||
else
|
else
|
||||||
strlcpy(top, topic, sizeof(top));
|
strlcpy(top, topic, sizeof(top));
|
||||||
|
esp_task_wdt_reset(); // Make sure we do not reboot here.
|
||||||
mqttClient.publish(top, (const uint8_t *)"", 0, true);
|
mqttClient.publish(top, (const uint8_t *)"", 0, true);
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
@ -323,6 +332,7 @@ bool MQTTClass::publishBuffer(const char *topic, uint8_t *data, uint16_t len, bo
|
||||||
uint16_t offset = 0;
|
uint16_t offset = 0;
|
||||||
uint16_t to_write = len;
|
uint16_t to_write = len;
|
||||||
uint16_t buff_len;
|
uint16_t buff_len;
|
||||||
|
esp_task_wdt_reset(); // Make sure we do not reboot here.
|
||||||
mqttClient.beginPublish(topic, len, retain);
|
mqttClient.beginPublish(topic, len, retain);
|
||||||
do {
|
do {
|
||||||
buff_len = to_write;
|
buff_len = to_write;
|
||||||
|
|
|
||||||
312
Network.cpp
312
Network.cpp
|
|
@ -34,7 +34,9 @@ bool Network::setup() {
|
||||||
WiFi.setScanMethod(WIFI_ALL_CHANNEL_SCAN);
|
WiFi.setScanMethod(WIFI_ALL_CHANNEL_SCAN);
|
||||||
WiFi.setSortMethod(WIFI_CONNECT_AP_BY_SIGNAL);
|
WiFi.setSortMethod(WIFI_CONNECT_AP_BY_SIGNAL);
|
||||||
WiFi.persistent(false);
|
WiFi.persistent(false);
|
||||||
|
WiFi.setAutoReconnect(false);
|
||||||
WiFi.onEvent(this->networkEvent);
|
WiFi.onEvent(this->networkEvent);
|
||||||
|
this->disconnectTime = millis();
|
||||||
if(WiFi.status() == WL_CONNECTED) WiFi.disconnect(true, true);
|
if(WiFi.status() == WL_CONNECTED) WiFi.disconnect(true, true);
|
||||||
if(settings.connType == conn_types_t::wifi || settings.connType == conn_types_t::unset) {
|
if(settings.connType == conn_types_t::wifi || settings.connType == conn_types_t::unset) {
|
||||||
WiFi.persistent(false);
|
WiFi.persistent(false);
|
||||||
|
|
@ -42,66 +44,125 @@ bool Network::setup() {
|
||||||
Serial.print("WiFi Mode: ");
|
Serial.print("WiFi Mode: ");
|
||||||
Serial.println(WiFi.getMode());
|
Serial.println(WiFi.getMode());
|
||||||
WiFi.mode(WIFI_STA);
|
WiFi.mode(WIFI_STA);
|
||||||
//settings.WIFI.printNetworks();
|
|
||||||
}
|
}
|
||||||
sockEmit.begin();
|
sockEmit.begin();
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
conn_types_t Network::preferredConnType() {
|
||||||
|
switch(settings.connType) {
|
||||||
|
case conn_types_t::wifi:
|
||||||
|
return settings.WIFI.ssid[0] != '\0' ? conn_types_t::wifi : conn_types_t::ap;
|
||||||
|
case conn_types_t::unset:
|
||||||
|
case conn_types_t::ap:
|
||||||
|
return conn_types_t::ap;
|
||||||
|
case conn_types_t::ethernetpref:
|
||||||
|
return settings.WIFI.ssid[0] != '\0' && (!ETH.linkUp() && this->ethStarted) ? conn_types_t::wifi : conn_types_t::ethernet;
|
||||||
|
case conn_types_t::ethernet:
|
||||||
|
return ETH.linkUp() || !this->ethStarted ? conn_types_t::ethernet : conn_types_t::ap;
|
||||||
|
default:
|
||||||
|
return settings.connType;
|
||||||
|
}
|
||||||
|
}
|
||||||
void Network::loop() {
|
void Network::loop() {
|
||||||
this->connect();
|
// ORDER OF OPERATIONS:
|
||||||
if(!this->connected() || this->connecting()) return;
|
// ----------------------------------------------
|
||||||
if(millis() - this->lastEmit > 1500) {
|
// 1. If we are in the middle of a connection process we need to simply bail after the connect method. The
|
||||||
this->lastEmit = millis();
|
// connect method will take care of our target connection for us.
|
||||||
if(this->connected()) {
|
// 2. Check to see what type of target connection we need.
|
||||||
this->emitSockets();
|
// a. If this is an ethernet target then the connection needs to perform a fallback if applicable.
|
||||||
this->lastEmit = millis();
|
// b. If this is a wifi target then we need to first check to see if the SSID is available.
|
||||||
}
|
// c. If an SSID has not been set then we need to turn on the Soft AP.
|
||||||
}
|
// 3. If the Soft AP is open and the target is either wifi, ethernet, or ethernetpref then
|
||||||
sockEmit.loop();
|
// we need to shut it down if there are no connections and the preferred connection is available.
|
||||||
if(this->connected() && millis() - this->lastMDNS > 60000) {
|
// a. Ethernet: Check for an active ethernet connection. We cannot rely on linkup because the PHY will
|
||||||
// Every 60 seconds we are going to look at wifi connectivity
|
// report that the link is up when no IP address is being served.
|
||||||
// to get around the roaming issues with ESP32. We will try to do this in an async manner. If
|
// b. WiFi: Perform synchronous scan for APs related to the SSID. If the SSID can be found then perform
|
||||||
// there is a channel that is better we will stop the wifi radio and reconnect
|
// the connection process for the WiFi connection.
|
||||||
if(this->connType == conn_types_t::wifi && settings.WIFI.roaming && !this->softAPOpened) {
|
// c. SoftAP: This condition retains the Soft AP because no other connection method is available.
|
||||||
// If we are not already scanning then we need to start a passive scan
|
conn_types_t ctype = this->preferredConnType();
|
||||||
// and only respond if there is a better connection.
|
this->connect(ctype); // Connection timeout handled in connect function as well as the opening of the Soft AP if needed.
|
||||||
// 1. If there is currently a waiting scan don't do anything
|
if(this->connecting()) return; // If we are currently attempting to connect to something then we need to bail here.
|
||||||
if(!_apScanning && WiFi.scanNetworks(true, false, true, 300, 0, settings.WIFI.ssid) == -1) {
|
|
||||||
_apScanning = true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
this->lastMDNS = millis();
|
|
||||||
}
|
|
||||||
if(_apScanning) {
|
if(_apScanning) {
|
||||||
if(!settings.WIFI.roaming || this->connType != conn_types_t::wifi || this->softAPOpened) _apScanning = false;
|
if(settings.WIFI.hidden || // This user has elected to use a hidden AP.
|
||||||
|
(this->connected() && !settings.WIFI.roaming) || // We are already connected and should not be roaming.
|
||||||
|
(this->softAPOpened && WiFi.softAPgetStationNum() != 0) || // The Soft AP is open and a user is connected.
|
||||||
|
(ctype != conn_types_t::wifi)) { // The Ethernet link is up so we should ignore this scan.
|
||||||
|
Serial.println("Cancelling WiFi STA Scan...");
|
||||||
|
_apScanning = false;
|
||||||
|
WiFi.scanDelete();
|
||||||
|
}
|
||||||
else {
|
else {
|
||||||
uint16_t n = WiFi.scanComplete();
|
int16_t n = WiFi.scanComplete();
|
||||||
if( n > 0) {
|
if( n >= 0) { // If the scan is complete but the WiFi isn't ready this can return 0.
|
||||||
uint8_t bssid[6];
|
uint8_t bssid[6];
|
||||||
int32_t channel = 0;
|
int32_t channel = 0;
|
||||||
if(this->getStrongestAP(settings.WIFI.ssid, bssid, &channel)) {
|
if(this->getStrongestAP(settings.WIFI.ssid, bssid, &channel)) {
|
||||||
if(memcmp(bssid, WiFi.BSSID(), sizeof(bssid)) != 0) {
|
if(!WiFi.BSSID() || memcmp(bssid, WiFi.BSSID(), sizeof(bssid)) != 0) {
|
||||||
Serial.printf("Found stronger AP %d %02X:%02X:%02X:%02X:%02X:%02X\n", channel, bssid[0], bssid[1], bssid[2], bssid[3], bssid[4], bssid[5]);
|
if(!this->connected()) {
|
||||||
|
Serial.printf("Connecting to AP %02X:%02X:%02X:%02X:%02X:%02X CH: %d\n", bssid[0], bssid[1], bssid[2], bssid[3], bssid[4], bssid[5], channel);
|
||||||
|
this->connectWiFi(bssid, channel);
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
Serial.printf("Found stronger AP %02X:%02X:%02X:%02X:%02X:%02X CH: %d\n", bssid[0], bssid[1], bssid[2], bssid[3], bssid[4], bssid[5], channel);
|
||||||
this->changeAP(bssid, channel);
|
this->changeAP(bssid, channel);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
_apScanning = false;
|
_apScanning = false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if(settings.ssdpBroadcast) {
|
if(!this->connecting() && !settings.WIFI.hidden) {
|
||||||
|
if((this->softAPOpened && WiFi.softAPgetStationNum() == 0) ||
|
||||||
|
(!this->connected() && ctype == conn_types_t::wifi)) {
|
||||||
|
// If the Soft AP is opened and there are no clients connected then we need to scan for an AP. If
|
||||||
|
// our target exists we will exit out of the Soft AP and start that connection. We are also
|
||||||
|
// going to continuously scan when there is no connection and our preferred connection is wifi.
|
||||||
|
if(ctype == conn_types_t::wifi) {
|
||||||
|
// Scan for an AP but only if we are not already scanning.
|
||||||
|
if(!_apScanning && WiFi.scanNetworks(true, false, true, 300, 0, settings.WIFI.ssid) == -1) {
|
||||||
|
_apScanning = true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else if(this->connected() && ctype == conn_types_t::wifi && settings.WIFI.roaming) {
|
||||||
|
// Periodically look for a roaming AP.
|
||||||
|
if(millis() > SSID_SCAN_INTERVAL + this->lastWifiScan) {
|
||||||
|
//Serial.println("Started scan for access points");
|
||||||
|
if(!_apScanning && WiFi.scanNetworks(true, false, true, 300, 0, settings.WIFI.ssid) == -1) {
|
||||||
|
_apScanning = true;
|
||||||
|
this->lastWifiScan = millis();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(millis() - this->lastEmit > 1500) {
|
||||||
|
// Post our connection status if needed.
|
||||||
|
this->lastEmit = millis();
|
||||||
|
if(this->connected()) {
|
||||||
|
this->emitSockets();
|
||||||
|
this->lastEmit = millis();
|
||||||
|
}
|
||||||
|
esp_task_wdt_reset(); // Make sure we do not reboot here.
|
||||||
|
}
|
||||||
|
|
||||||
|
sockEmit.loop();
|
||||||
|
mqtt.loop();
|
||||||
|
if(settings.ssdpBroadcast && this->connected()) {
|
||||||
if(!SSDP.isStarted) SSDP.begin();
|
if(!SSDP.isStarted) SSDP.begin();
|
||||||
if(SSDP.isStarted) SSDP.loop();
|
if(SSDP.isStarted) SSDP.loop();
|
||||||
}
|
}
|
||||||
else if(!settings.ssdpBroadcast && SSDP.isStarted) SSDP.end();
|
else if(!settings.ssdpBroadcast && SSDP.isStarted) SSDP.end();
|
||||||
mqtt.loop();
|
|
||||||
}
|
}
|
||||||
bool Network::changeAP(const uint8_t *bssid, const int32_t channel) {
|
bool Network::changeAP(const uint8_t *bssid, const int32_t channel) {
|
||||||
esp_task_wdt_reset(); // Make sure we do not reboot here.
|
esp_task_wdt_reset(); // Make sure we do not reboot here.
|
||||||
if(SSDP.isStarted) SSDP.end();
|
if(SSDP.isStarted) SSDP.end();
|
||||||
mqtt.disconnect();
|
mqtt.disconnect();
|
||||||
sockEmit.end();
|
//sockEmit.end();
|
||||||
WiFi.disconnect(false, true);
|
WiFi.disconnect(false, true);
|
||||||
|
this->connType = conn_types_t::unset;
|
||||||
|
this->_connecting = true;
|
||||||
|
this->connectStart = millis();
|
||||||
WiFi.begin(settings.WIFI.ssid, settings.WIFI.passphrase, channel, bssid);
|
WiFi.begin(settings.WIFI.ssid, settings.WIFI.passphrase, channel, bssid);
|
||||||
this->connectStart = millis();
|
this->connectStart = millis();
|
||||||
return false;
|
return false;
|
||||||
|
|
@ -116,7 +177,6 @@ void Network::emitSockets() {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
void Network::emitSockets(uint8_t num) {
|
void Network::emitSockets(uint8_t num) {
|
||||||
//char buf[128];
|
|
||||||
if(this->connType == conn_types_t::ethernet) {
|
if(this->connType == conn_types_t::ethernet) {
|
||||||
JsonSockEvent *json = sockEmit.beginEmit("ethernet");
|
JsonSockEvent *json = sockEmit.beginEmit("ethernet");
|
||||||
json->beginObject();
|
json->beginObject();
|
||||||
|
|
@ -125,13 +185,6 @@ void Network::emitSockets(uint8_t num) {
|
||||||
json->addElem("fullduplex", ETH.fullDuplex());
|
json->addElem("fullduplex", ETH.fullDuplex());
|
||||||
json->endObject();
|
json->endObject();
|
||||||
sockEmit.endEmit(num);
|
sockEmit.endEmit(num);
|
||||||
/*
|
|
||||||
snprintf(buf, sizeof(buf), "{\"connected\":%s,\"speed\":%d,\"fullduplex\":%s}", this->connected() ? "true" : "false", ETH.linkSpeed(), ETH.fullDuplex() ? "true" : "false");
|
|
||||||
if(num == 255)
|
|
||||||
sockEmit.sendToClients("ethernet", buf);
|
|
||||||
else
|
|
||||||
sockEmit.sendToClient(num, "ethernet", buf);
|
|
||||||
*/
|
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
if(WiFi.status() == WL_CONNECTED) {
|
if(WiFi.status() == WL_CONNECTED) {
|
||||||
|
|
@ -142,13 +195,6 @@ void Network::emitSockets(uint8_t num) {
|
||||||
json->addElem("channel", (int32_t)this->channel);
|
json->addElem("channel", (int32_t)this->channel);
|
||||||
json->endObject();
|
json->endObject();
|
||||||
sockEmit.endEmit(num);
|
sockEmit.endEmit(num);
|
||||||
/*
|
|
||||||
snprintf(buf, sizeof(buf), "{\"ssid\":\"%s\",\"strength\":%d,\"channel\":%d}", WiFi.SSID().c_str(), WiFi.RSSI(), this->channel);
|
|
||||||
if(num == 255)
|
|
||||||
sockEmit.sendToClients("wifiStrength", buf);
|
|
||||||
else
|
|
||||||
sockEmit.sendToClient(num, "wifiStrength", buf);
|
|
||||||
*/
|
|
||||||
this->lastRSSI = WiFi.RSSI();
|
this->lastRSSI = WiFi.RSSI();
|
||||||
this->lastChannel = WiFi.channel();
|
this->lastChannel = WiFi.channel();
|
||||||
}
|
}
|
||||||
|
|
@ -168,17 +214,6 @@ void Network::emitSockets(uint8_t num) {
|
||||||
json->addElem("fullduplex", false);
|
json->addElem("fullduplex", false);
|
||||||
json->endObject();
|
json->endObject();
|
||||||
sockEmit.endEmit(num);
|
sockEmit.endEmit(num);
|
||||||
/*
|
|
||||||
|
|
||||||
if(num == 255) {
|
|
||||||
sockEmit.sendToClients("wifiStrength", "{\"ssid\":\"\", \"strength\":-100,\"channel\":-1}");
|
|
||||||
sockEmit.sendToClients("ethernet", "{\"connected\":false,\"speed\":0,\"fullduplex\":false}");
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
sockEmit.sendToClient(num, "wifiStrength", "{\"ssid\":\"\", \"strength\":-100,\"channel\":-1}");
|
|
||||||
sockEmit.sendToClient(num, "ethernet", "{\"connected\":false,\"speed\":0,\"fullduplex\":false}");
|
|
||||||
}
|
|
||||||
*/
|
|
||||||
this->lastRSSI = -100;
|
this->lastRSSI = -100;
|
||||||
this->lastChannel = -1;
|
this->lastChannel = -1;
|
||||||
}
|
}
|
||||||
|
|
@ -186,9 +221,11 @@ void Network::emitSockets(uint8_t num) {
|
||||||
this->emitHeap(num);
|
this->emitHeap(num);
|
||||||
}
|
}
|
||||||
void Network::setConnected(conn_types_t connType) {
|
void Network::setConnected(conn_types_t connType) {
|
||||||
|
esp_task_wdt_reset();
|
||||||
this->connType = connType;
|
this->connType = connType;
|
||||||
this->connectTime = millis();
|
this->connectTime = millis();
|
||||||
connectRetries = 0;
|
connectRetries = 0;
|
||||||
|
Serial.println("Setting connected...");
|
||||||
if(this->connType == conn_types_t::wifi) {
|
if(this->connType == conn_types_t::wifi) {
|
||||||
if(this->softAPOpened && WiFi.softAPgetStationNum() == 0) {
|
if(this->softAPOpened && WiFi.softAPgetStationNum() == 0) {
|
||||||
WiFi.softAPdisconnect(true);
|
WiFi.softAPdisconnect(true);
|
||||||
|
|
@ -213,6 +250,8 @@ void Network::setConnected(conn_types_t connType) {
|
||||||
}
|
}
|
||||||
// NET: Begin this in the startup.
|
// NET: Begin this in the startup.
|
||||||
//sockEmit.begin();
|
//sockEmit.begin();
|
||||||
|
esp_task_wdt_reset();
|
||||||
|
|
||||||
if(this->connectAttempts == 1) {
|
if(this->connectAttempts == 1) {
|
||||||
Serial.println();
|
Serial.println();
|
||||||
if(this->connType == conn_types_t::wifi) {
|
if(this->connType == conn_types_t::wifi) {
|
||||||
|
|
@ -245,6 +284,7 @@ void Network::setConnected(conn_types_t connType) {
|
||||||
settings.IP.dns1 = ETH.dnsIP(0);
|
settings.IP.dns1 = ETH.dnsIP(0);
|
||||||
settings.IP.dns2 = ETH.dnsIP(1);
|
settings.IP.dns2 = ETH.dnsIP(1);
|
||||||
}
|
}
|
||||||
|
esp_task_wdt_reset();
|
||||||
JsonSockEvent *json = sockEmit.beginEmit("ethernet");
|
JsonSockEvent *json = sockEmit.beginEmit("ethernet");
|
||||||
json->beginObject();
|
json->beginObject();
|
||||||
json->addElem("connected", this->connected());
|
json->addElem("connected", this->connected());
|
||||||
|
|
@ -252,6 +292,7 @@ void Network::setConnected(conn_types_t connType) {
|
||||||
json->addElem("fullduplex", ETH.fullDuplex());
|
json->addElem("fullduplex", ETH.fullDuplex());
|
||||||
json->endObject();
|
json->endObject();
|
||||||
sockEmit.endEmit();
|
sockEmit.endEmit();
|
||||||
|
esp_task_wdt_reset();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
|
|
@ -302,6 +343,7 @@ void Network::setConnected(conn_types_t connType) {
|
||||||
SSDP.setManufacturerURL(0, "https://github.com/rstrouse");
|
SSDP.setManufacturerURL(0, "https://github.com/rstrouse");
|
||||||
SSDP.setURL(0, "/");
|
SSDP.setURL(0, "/");
|
||||||
SSDP.setActive(0, true);
|
SSDP.setActive(0, true);
|
||||||
|
esp_task_wdt_reset();
|
||||||
if(MDNS.begin(settings.hostname)) {
|
if(MDNS.begin(settings.hostname)) {
|
||||||
Serial.printf("MDNS Responder Started: serverId=%s\n", settings.serverId);
|
Serial.printf("MDNS Responder Started: serverId=%s\n", settings.serverId);
|
||||||
MDNS.addService("http", "tcp", 80);
|
MDNS.addService("http", "tcp", 80);
|
||||||
|
|
@ -314,9 +356,11 @@ void Network::setConnected(conn_types_t connType) {
|
||||||
MDNS.addServiceTxt("espsomfy_rts", "tcp", "version", String(settings.fwVersion.name));
|
MDNS.addServiceTxt("espsomfy_rts", "tcp", "version", String(settings.fwVersion.name));
|
||||||
}
|
}
|
||||||
if(settings.ssdpBroadcast) {
|
if(settings.ssdpBroadcast) {
|
||||||
|
esp_task_wdt_reset();
|
||||||
SSDP.begin();
|
SSDP.begin();
|
||||||
}
|
}
|
||||||
else if(SSDP.isStarted) SSDP.end();
|
else if(SSDP.isStarted) SSDP.end();
|
||||||
|
esp_task_wdt_reset();
|
||||||
this->emitSockets();
|
this->emitSockets();
|
||||||
settings.printAvailHeap();
|
settings.printAvailHeap();
|
||||||
this->needsBroadcast = true;
|
this->needsBroadcast = true;
|
||||||
|
|
@ -325,15 +369,15 @@ bool Network::connectWired() {
|
||||||
if(ETH.linkUp()) {
|
if(ETH.linkUp()) {
|
||||||
// If the ethernet link is re-established then we need to shut down wifi.
|
// If the ethernet link is re-established then we need to shut down wifi.
|
||||||
if(WiFi.status() == WL_CONNECTED) {
|
if(WiFi.status() == WL_CONNECTED) {
|
||||||
sockEmit.end();
|
//sockEmit.end();
|
||||||
WiFi.disconnect(true);
|
WiFi.disconnect(true);
|
||||||
WiFi.mode(WIFI_OFF);
|
WiFi.mode(WIFI_OFF);
|
||||||
}
|
}
|
||||||
if(this->connType != conn_types_t::ethernet) this->setConnected(conn_types_t::ethernet);
|
if(this->connType != conn_types_t::ethernet) this->setConnected(conn_types_t::ethernet);
|
||||||
this->wifiFallback = false;
|
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
else if(this->ethStarted) {
|
else if(this->ethStarted) {
|
||||||
|
// There is no wired connection so we need to fallback if appropriate.
|
||||||
if(settings.connType == conn_types_t::ethernetpref && settings.WIFI.ssid[0] != '\0')
|
if(settings.connType == conn_types_t::ethernetpref && settings.WIFI.ssid[0] != '\0')
|
||||||
return this->connectWiFi();
|
return this->connectWiFi();
|
||||||
}
|
}
|
||||||
|
|
@ -347,13 +391,13 @@ bool Network::connectWired() {
|
||||||
this->connTarget = conn_types_t::ethernet;
|
this->connTarget = conn_types_t::ethernet;
|
||||||
this->connType = conn_types_t::unset;
|
this->connType = conn_types_t::unset;
|
||||||
if(!this->ethStarted) {
|
if(!this->ethStarted) {
|
||||||
|
// Currently the ethernet module will leak memory if you call begin more than once.
|
||||||
this->ethStarted = true;
|
this->ethStarted = true;
|
||||||
WiFi.mode(WIFI_OFF);
|
WiFi.mode(WIFI_OFF);
|
||||||
if(settings.hostname[0] != '\0')
|
if(settings.hostname[0] != '\0')
|
||||||
ETH.setHostname(settings.hostname);
|
ETH.setHostname(settings.hostname);
|
||||||
else
|
else
|
||||||
ETH.setHostname("ESPSomfy-RTS");
|
ETH.setHostname("ESPSomfy-RTS");
|
||||||
|
|
||||||
Serial.print("Set hostname to:");
|
Serial.print("Set hostname to:");
|
||||||
Serial.println(ETH.getHostname());
|
Serial.println(ETH.getHostname());
|
||||||
if(!ETH.begin(settings.Ethernet.phyAddress, settings.Ethernet.PWRPin, settings.Ethernet.MDCPin, settings.Ethernet.MDIOPin, settings.Ethernet.phyType, settings.Ethernet.CLKMode)) {
|
if(!ETH.begin(settings.Ethernet.phyAddress, settings.Ethernet.PWRPin, settings.Ethernet.MDCPin, settings.Ethernet.MDIOPin, settings.Ethernet.phyType, settings.Ethernet.CLKMode)) {
|
||||||
|
|
@ -396,18 +440,43 @@ void Network::updateHostname() {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
bool Network::connectWiFi() {
|
bool Network::connectWiFi(const uint8_t *bssid, const int32_t channel) {
|
||||||
if(this->softAPOpened && WiFi.softAPgetStationNum() > 0) {
|
if(this->softAPOpened && WiFi.softAPgetStationNum() > 0) {
|
||||||
|
// There is a client connected to the soft AP. We do not want to close out the connection. While both the
|
||||||
|
// Soft AP and a wifi connection can coexist on ESP32 the performance is abysmal.
|
||||||
WiFi.disconnect(false);
|
WiFi.disconnect(false);
|
||||||
this->_connecting = false;
|
this->_connecting = false;
|
||||||
this->connType = conn_types_t::unset;
|
this->connType = conn_types_t::unset;
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
WiFi.setSleep(false);
|
||||||
|
if(!settings.IP.dhcp) {
|
||||||
|
if(!WiFi.config(settings.IP.ip, settings.IP.gateway, settings.IP.subnet, settings.IP.dns1, settings.IP.dns2))
|
||||||
|
WiFi.config(INADDR_NONE, INADDR_NONE, INADDR_NONE, INADDR_NONE);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
WiFi.config(INADDR_NONE, INADDR_NONE, INADDR_NONE, INADDR_NONE);
|
||||||
|
if(settings.hostname[0] != '\0') WiFi.setHostname(settings.hostname);
|
||||||
|
delay(100);
|
||||||
|
|
||||||
if(settings.WIFI.ssid[0] != '\0') {
|
if(bssid && channel > 0) {
|
||||||
|
if(WiFi.status() == WL_CONNECTED && WiFi.SSID().compareTo(settings.WIFI.ssid) == 0
|
||||||
|
&& WiFi.channel() == channel) {
|
||||||
|
this->disconnected = 0;
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
this->connTarget = conn_types_t::wifi;
|
||||||
|
this->connType = conn_types_t::unset;
|
||||||
|
Serial.println("WiFi begin...");
|
||||||
|
this->_connecting = true;
|
||||||
|
WiFi.begin(settings.WIFI.ssid, settings.WIFI.passphrase, channel, bssid);
|
||||||
|
this->connectStart = millis();
|
||||||
|
}
|
||||||
|
else if(settings.WIFI.ssid[0] != '\0') {
|
||||||
if(WiFi.status() == WL_CONNECTED && WiFi.SSID().compareTo(settings.WIFI.ssid) == 0) {
|
if(WiFi.status() == WL_CONNECTED && WiFi.SSID().compareTo(settings.WIFI.ssid) == 0) {
|
||||||
// If we are connected to the target SSID then just return.
|
// If we are connected to the target SSID then just return.
|
||||||
this->disconnected = 0;
|
this->disconnected = 0;
|
||||||
|
this->_connecting = true;
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
if(this->_connecting) return true;
|
if(this->_connecting) return true;
|
||||||
|
|
@ -424,74 +493,49 @@ bool Network::connectWiFi() {
|
||||||
Serial.println("dbm) ");
|
Serial.println("dbm) ");
|
||||||
}
|
}
|
||||||
else Serial.println("Connecting to AP");
|
else Serial.println("Connecting to AP");
|
||||||
// If the soft AP is currently opened then we do not want to kill it.
|
|
||||||
WiFi.setSleep(false);
|
|
||||||
WiFi.disconnect(false);
|
|
||||||
//WiFi.mode(WIFI_MODE_NULL);
|
|
||||||
if(!settings.IP.dhcp) {
|
|
||||||
if(!WiFi.config(settings.IP.ip, settings.IP.gateway, settings.IP.subnet, settings.IP.dns1, settings.IP.dns2))
|
|
||||||
WiFi.config(INADDR_NONE, INADDR_NONE, INADDR_NONE, INADDR_NONE);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
WiFi.config(INADDR_NONE, INADDR_NONE, INADDR_NONE, INADDR_NONE);
|
|
||||||
delay(100);
|
delay(100);
|
||||||
// There is also another method simply called hostname() but this is legacy for esp8266.
|
// There is also another method simply called hostname() but this is legacy for esp8266.
|
||||||
if(settings.hostname[0] != '\0') WiFi.setHostname(settings.hostname);
|
if(settings.hostname[0] != '\0') WiFi.setHostname(settings.hostname);
|
||||||
Serial.print("Set hostname to:");
|
Serial.print("Set hostname to:");
|
||||||
Serial.println(WiFi.getHostname());
|
Serial.println(WiFi.getHostname());
|
||||||
//WiFi.mode(WIFI_STA);
|
|
||||||
WiFi.setScanMethod(WIFI_ALL_CHANNEL_SCAN);
|
WiFi.setScanMethod(WIFI_ALL_CHANNEL_SCAN);
|
||||||
WiFi.setSortMethod(WIFI_CONNECT_AP_BY_SIGNAL);
|
WiFi.setSortMethod(WIFI_CONNECT_AP_BY_SIGNAL);
|
||||||
uint8_t bssid[6];
|
uint8_t _bssid[6];
|
||||||
int32_t channel = 0;
|
int32_t _channel = 0;
|
||||||
if(this->getStrongestAP(settings.WIFI.ssid, bssid, &channel)) {
|
if(!settings.WIFI.hidden && this->getStrongestAP(settings.WIFI.ssid, _bssid, &_channel)) {
|
||||||
Serial.printf("Found strongest AP %d %02X:%02X:%02X:%02X:%02X:%02X\n", channel, bssid[0], bssid[1], bssid[2], bssid[3], bssid[4], bssid[5]);
|
Serial.printf("Found strongest AP %02X:%02X:%02X:%02X:%02X:%02X CH:%d\n", _bssid[0], _bssid[1], _bssid[2], _bssid[3], _bssid[4], _bssid[5], _channel);
|
||||||
WiFi.begin(settings.WIFI.ssid, settings.WIFI.passphrase, channel, bssid);
|
WiFi.begin(settings.WIFI.ssid, settings.WIFI.passphrase, _channel, _bssid);
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
|
// If the user has the hidden flag set just connect to whatever the AP gives us.
|
||||||
WiFi.begin(settings.WIFI.ssid, settings.WIFI.passphrase);
|
WiFi.begin(settings.WIFI.ssid, settings.WIFI.passphrase);
|
||||||
}
|
}
|
||||||
this->connectStart = millis();
|
this->connectStart = millis();
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
bool Network::connect() {
|
bool Network::connect(conn_types_t ctype) {
|
||||||
if(this->connecting()) {
|
|
||||||
// We are currently connecting and this flag is triggered while there is an attempt
|
|
||||||
// to connect to the network. If the connection type is set then we need to
|
|
||||||
// finish the connection. If it is not then we need to fall back to AP or in
|
|
||||||
// the case where the target was originally ethernet then we need to open the softAP.
|
|
||||||
if(this->connType == conn_types_t::unset) {
|
|
||||||
// If we reached our timeout for the connection then we need to open the soft ap.
|
|
||||||
if(millis() > this->connectStart + CONNECT_TIMEOUT) {
|
|
||||||
esp_task_wdt_reset();
|
esp_task_wdt_reset();
|
||||||
if(this->connTarget == conn_types_t::ethernet && settings.connType == conn_types_t::ethernetpref && settings.WIFI.ssid[0] != '\0')
|
if(this->connecting()) return true;
|
||||||
this->connectWiFi();
|
if(this->disconnectTime == 0) this->disconnectTime = millis();
|
||||||
else if(this->softAPOpened) {
|
if(ctype == conn_types_t::ethernet && this->connType != conn_types_t::ethernet) {
|
||||||
if(settings.connType == conn_types_t::ethernet || settings.connType == conn_types_t::ethernetpref)
|
// Here we need to call the connect to ethernet.
|
||||||
this->connectWired();
|
this->connectWired();
|
||||||
else if(settings.connType == conn_types_t::wifi && strlen(settings.WIFI.ssid) > 0)
|
|
||||||
this->connectWiFi();
|
|
||||||
}
|
}
|
||||||
else {
|
else if(ctype == conn_types_t::ap || (!this->connected() && millis() > this->disconnectTime + CONNECT_TIMEOUT)) {
|
||||||
//Serial.println("Fell into timeout");
|
if(!this->softAPOpened && !this->openingSoftAP) {
|
||||||
|
this->disconnectTime = millis();
|
||||||
this->openSoftAP();
|
this->openSoftAP();
|
||||||
}
|
}
|
||||||
}
|
else if(this->softAPOpened && !this->openingSoftAP &&
|
||||||
}
|
(ctype == conn_types_t::wifi && this->connType != conn_types_t::wifi && settings.WIFI.hidden)) {
|
||||||
else
|
// When thge softAP is open then we need to try to connect to wifi repeatedly if the user connects to a hidden SSID.
|
||||||
this->setConnected(this->connTarget);
|
|
||||||
}
|
|
||||||
else if(settings.connType == conn_types_t::ethernet || settings.connType == conn_types_t::ethernetpref)
|
|
||||||
this->connectWired();
|
|
||||||
else if(settings.connType == conn_types_t::wifi && strlen(settings.WIFI.ssid) > 0)
|
|
||||||
this->connectWiFi();
|
this->connectWiFi();
|
||||||
else
|
|
||||||
this->openSoftAP();
|
|
||||||
if(this->softAPOpened && this->connected() && WiFi.softAPgetStationNum() == 0) {
|
|
||||||
Serial.println("Closing uneeded SoftAP");
|
|
||||||
WiFi.softAPdisconnect(true);
|
|
||||||
if(this->connType == conn_types_t::wifi) WiFi.mode(WIFI_STA);
|
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
else if((ctype == conn_types_t::wifi && this->connType != conn_types_t::wifi && settings.WIFI.hidden)) {
|
||||||
|
this->connectWiFi();
|
||||||
|
}
|
||||||
|
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
uint32_t Network::getChipId() {
|
uint32_t Network::getChipId() {
|
||||||
|
|
@ -502,16 +546,16 @@ uint32_t Network::getChipId() {
|
||||||
}
|
}
|
||||||
return chipId;
|
return chipId;
|
||||||
}
|
}
|
||||||
|
|
||||||
bool Network::getStrongestAP(const char *ssid, uint8_t *bssid, int32_t *channel) {
|
bool Network::getStrongestAP(const char *ssid, uint8_t *bssid, int32_t *channel) {
|
||||||
// The new AP must be at least 10dbm greater.
|
// The new AP must be at least 10dbm greater.
|
||||||
int32_t strength = this->connected() ? WiFi.RSSI() + 10 : -127;
|
int32_t strength = this->connected() ? WiFi.RSSI() + 10 : -127;
|
||||||
int32_t chan = -1;
|
int32_t chan = -1;
|
||||||
memset(bssid, 0x00, 6);
|
memset(bssid, 0x00, 6);
|
||||||
esp_task_wdt_delete(NULL);
|
esp_task_wdt_delete(NULL);
|
||||||
uint8_t n = this->connected() ? WiFi.scanComplete() : WiFi.scanNetworks(false, false, false, 300, 0, ssid);
|
int16_t n = WiFi.scanComplete();
|
||||||
|
//int16_t n = this->connected() ? WiFi.scanComplete() : WiFi.scanNetworks(false, false, false, 300, 0, ssid);
|
||||||
esp_task_wdt_add(NULL);
|
esp_task_wdt_add(NULL);
|
||||||
for(uint8_t i = 0; i < n; i++) {
|
for(int16_t i = 0; i < n; i++) {
|
||||||
if(WiFi.SSID(i).compareTo(ssid) == 0) {
|
if(WiFi.SSID(i).compareTo(ssid) == 0) {
|
||||||
if(WiFi.RSSI(i) > strength) {
|
if(WiFi.RSSI(i) > strength) {
|
||||||
strength = WiFi.RSSI(i);
|
strength = WiFi.RSSI(i);
|
||||||
|
|
@ -525,13 +569,12 @@ bool Network::getStrongestAP(const char *ssid, uint8_t *bssid, int32_t *channel)
|
||||||
}
|
}
|
||||||
bool Network::openSoftAP() {
|
bool Network::openSoftAP() {
|
||||||
if(this->softAPOpened || this->openingSoftAP) return true;
|
if(this->softAPOpened || this->openingSoftAP) return true;
|
||||||
WiFi.disconnect(false);
|
if(this->connected()) WiFi.disconnect(false);
|
||||||
this->openingSoftAP = true;
|
this->openingSoftAP = true;
|
||||||
Serial.println();
|
Serial.println();
|
||||||
Serial.println("Turning the HotSpot On");
|
Serial.println("Turning the HotSpot On");
|
||||||
esp_task_wdt_reset(); // Make sure we do not reboot here.
|
esp_task_wdt_reset(); // Make sure we do not reboot here.
|
||||||
WiFi.softAP("ESPSomfy RTS", "");
|
WiFi.softAP(strlen(settings.hostname) > 0 ? settings.hostname : "ESPSomfy RTS", "");
|
||||||
Serial.println("Initializing AP for credentials modification");
|
|
||||||
delay(200);
|
delay(200);
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
@ -544,25 +587,37 @@ bool Network::connected() {
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
bool Network::connecting() {
|
bool Network::connecting() {
|
||||||
|
if(this->_connecting && millis() > this->connectStart + CONNECT_TIMEOUT) this->_connecting = false;
|
||||||
return this->_connecting;
|
return this->_connecting;
|
||||||
}
|
}
|
||||||
|
void Network::clearConnecting() { this->_connecting = false; }
|
||||||
void Network::networkEvent(WiFiEvent_t event) {
|
void Network::networkEvent(WiFiEvent_t event) {
|
||||||
switch(event) {
|
switch(event) {
|
||||||
case ARDUINO_EVENT_WIFI_READY: Serial.println("(evt) WiFi interface ready"); break;
|
case ARDUINO_EVENT_WIFI_READY: Serial.println("(evt) WiFi interface ready"); break;
|
||||||
case ARDUINO_EVENT_WIFI_SCAN_DONE: Serial.println("(evt) Completed scan for access points"); break;
|
case ARDUINO_EVENT_WIFI_SCAN_DONE:
|
||||||
|
Serial.printf("(evt) Completed scan for access points (%d)\n", WiFi.scanComplete());
|
||||||
|
//Serial.println("(evt) Completed scan for access points");
|
||||||
|
net.lastWifiScan = millis();
|
||||||
|
break;
|
||||||
case ARDUINO_EVENT_WIFI_STA_START:
|
case ARDUINO_EVENT_WIFI_STA_START:
|
||||||
Serial.println("WiFi station mode started");
|
Serial.println("WiFi station mode started");
|
||||||
if(settings.hostname[0] != '\0') WiFi.setHostname(settings.hostname);
|
if(settings.hostname[0] != '\0') WiFi.setHostname(settings.hostname);
|
||||||
break;
|
break;
|
||||||
case ARDUINO_EVENT_WIFI_STA_STOP: Serial.println("(evt) WiFi clients stopped"); break;
|
case ARDUINO_EVENT_WIFI_STA_STOP: Serial.println("(evt) WiFi clients stopped"); break;
|
||||||
case ARDUINO_EVENT_WIFI_STA_CONNECTED: Serial.println("(evt) Connected to access point"); break;
|
case ARDUINO_EVENT_WIFI_STA_CONNECTED: Serial.println("(evt) Connected to WiFi STA access point"); break;
|
||||||
case ARDUINO_EVENT_WIFI_STA_DISCONNECTED: Serial.println("(evt) Disconnected from WiFi access point"); break;
|
case ARDUINO_EVENT_WIFI_STA_DISCONNECTED:
|
||||||
case ARDUINO_EVENT_WIFI_STA_AUTHMODE_CHANGE: Serial.println("(evt) Authentication mode of access point has changed"); break;
|
Serial.printf("(evt) Disconnected from WiFi STA access point. Connecting: %d\n", net.connecting());
|
||||||
|
net.connType = conn_types_t::unset;
|
||||||
|
net.disconnectTime = millis();
|
||||||
|
net.clearConnecting();
|
||||||
|
break;
|
||||||
|
case ARDUINO_EVENT_WIFI_STA_AUTHMODE_CHANGE: Serial.println("(evt) Authentication mode of STA access point has changed"); break;
|
||||||
case ARDUINO_EVENT_WIFI_STA_GOT_IP:
|
case ARDUINO_EVENT_WIFI_STA_GOT_IP:
|
||||||
Serial.print("Got WiFi IP: ");
|
Serial.print("(evt) Got WiFi STA IP: ");
|
||||||
Serial.println(WiFi.localIP());
|
Serial.println(WiFi.localIP());
|
||||||
net.connType = conn_types_t::wifi;
|
net.connType = conn_types_t::wifi;
|
||||||
net.connectTime = millis();
|
net.connectTime = millis();
|
||||||
|
net.setConnected(conn_types_t::wifi);
|
||||||
break;
|
break;
|
||||||
case ARDUINO_EVENT_WIFI_STA_LOST_IP: Serial.println("Lost IP address and IP address is reset to 0"); break;
|
case ARDUINO_EVENT_WIFI_STA_LOST_IP: Serial.println("Lost IP address and IP address is reset to 0"); break;
|
||||||
case ARDUINO_EVENT_ETH_GOT_IP:
|
case ARDUINO_EVENT_ETH_GOT_IP:
|
||||||
|
|
@ -572,6 +627,14 @@ void Network::networkEvent(WiFiEvent_t event) {
|
||||||
Serial.println(ETH.localIP());
|
Serial.println(ETH.localIP());
|
||||||
net.connectTime = millis();
|
net.connectTime = millis();
|
||||||
net.connType = conn_types_t::ethernet;
|
net.connType = conn_types_t::ethernet;
|
||||||
|
if(settings.IP.dhcp) {
|
||||||
|
settings.IP.ip = ETH.localIP();
|
||||||
|
settings.IP.subnet = ETH.subnetMask();
|
||||||
|
settings.IP.gateway = ETH.gatewayIP();
|
||||||
|
settings.IP.dns1 = ETH.dnsIP(0);
|
||||||
|
settings.IP.dns2 = ETH.dnsIP(1);
|
||||||
|
}
|
||||||
|
net.setConnected(conn_types_t::ethernet);
|
||||||
break;
|
break;
|
||||||
case ARDUINO_EVENT_ETH_CONNECTED:
|
case ARDUINO_EVENT_ETH_CONNECTED:
|
||||||
Serial.print("(evt) Ethernet Connected ");
|
Serial.print("(evt) Ethernet Connected ");
|
||||||
|
|
@ -579,6 +642,8 @@ void Network::networkEvent(WiFiEvent_t event) {
|
||||||
case ARDUINO_EVENT_ETH_DISCONNECTED:
|
case ARDUINO_EVENT_ETH_DISCONNECTED:
|
||||||
Serial.println("(evt) Ethernet Disconnected");
|
Serial.println("(evt) Ethernet Disconnected");
|
||||||
net.connType = conn_types_t::unset;
|
net.connType = conn_types_t::unset;
|
||||||
|
net.disconnectTime = millis();
|
||||||
|
net.clearConnecting();
|
||||||
break;
|
break;
|
||||||
case ARDUINO_EVENT_ETH_START:
|
case ARDUINO_EVENT_ETH_START:
|
||||||
Serial.println("(evt) Ethernet Started");
|
Serial.println("(evt) Ethernet Started");
|
||||||
|
|
@ -596,8 +661,7 @@ void Network::networkEvent(WiFiEvent_t event) {
|
||||||
net.softAPOpened = true;
|
net.softAPOpened = true;
|
||||||
break;
|
break;
|
||||||
case ARDUINO_EVENT_WIFI_AP_STOP:
|
case ARDUINO_EVENT_WIFI_AP_STOP:
|
||||||
Serial.println("(evt) WiFi SoftAP Stopped");
|
if(!net.openingSoftAP) Serial.println("(evt) WiFi SoftAP Stopped");
|
||||||
//if(net.softAPOpened) net.openingSoftAP = false;
|
|
||||||
net.softAPOpened = false;
|
net.softAPOpened = false;
|
||||||
break;
|
break;
|
||||||
default:
|
default:
|
||||||
|
|
|
||||||
|
|
@ -6,6 +6,7 @@
|
||||||
//enum class conn_types_t : byte;
|
//enum class conn_types_t : byte;
|
||||||
|
|
||||||
#define CONNECT_TIMEOUT 20000
|
#define CONNECT_TIMEOUT 20000
|
||||||
|
#define SSID_SCAN_INTERVAL 60000
|
||||||
class Network {
|
class Network {
|
||||||
protected:
|
protected:
|
||||||
unsigned long lastEmit = 0;
|
unsigned long lastEmit = 0;
|
||||||
|
|
@ -15,6 +16,7 @@ class Network {
|
||||||
int linkSpeed = 0;
|
int linkSpeed = 0;
|
||||||
bool _connecting = false;
|
bool _connecting = false;
|
||||||
public:
|
public:
|
||||||
|
unsigned long lastWifiScan = 0;
|
||||||
bool ethStarted = false;
|
bool ethStarted = false;
|
||||||
bool wifiFallback = false;
|
bool wifiFallback = false;
|
||||||
bool softAPOpened = false;
|
bool softAPOpened = false;
|
||||||
|
|
@ -24,17 +26,20 @@ class Network {
|
||||||
conn_types_t connTarget = conn_types_t::unset;
|
conn_types_t connTarget = conn_types_t::unset;
|
||||||
bool connected();
|
bool connected();
|
||||||
bool connecting();
|
bool connecting();
|
||||||
|
void clearConnecting();
|
||||||
|
conn_types_t preferredConnType();
|
||||||
String ssid;
|
String ssid;
|
||||||
String mac;
|
String mac;
|
||||||
int channel;
|
int channel;
|
||||||
int strength;
|
int strength;
|
||||||
int disconnected = 0;
|
int disconnected = 0;
|
||||||
int connectAttempts = 0;
|
int connectAttempts = 0;
|
||||||
|
uint32_t disconnectTime = 0;
|
||||||
uint32_t connectStart = 0;
|
uint32_t connectStart = 0;
|
||||||
uint32_t connectTime = 0;
|
uint32_t connectTime = 0;
|
||||||
bool openSoftAP();
|
bool openSoftAP();
|
||||||
bool connect();
|
bool connect(conn_types_t ctype);
|
||||||
bool connectWiFi();
|
bool connectWiFi(const uint8_t *bssid = nullptr, const int32_t channel = -1);
|
||||||
bool connectWired();
|
bool connectWired();
|
||||||
void setConnected(conn_types_t connType);
|
void setConnected(conn_types_t connType);
|
||||||
bool getStrongestAP(const char *ssid, uint8_t *bssid, int32_t *channel);
|
bool getStrongestAP(const char *ssid, uint8_t *bssid, int32_t *channel);
|
||||||
|
|
|
||||||
5
SSDP.cpp
5
SSDP.cpp
|
|
@ -161,7 +161,7 @@ void UPNPDeviceType::setChipId(uint32_t chipId) {
|
||||||
(uint16_t)chipId & 0xff);
|
(uint16_t)chipId & 0xff);
|
||||||
}
|
}
|
||||||
SSDPClass::SSDPClass():sendQueue{false, INADDR_NONE, 0, nullptr, false, 0, "", response_types_t::root} {}
|
SSDPClass::SSDPClass():sendQueue{false, INADDR_NONE, 0, nullptr, false, 0, "", response_types_t::root} {}
|
||||||
SSDPClass::~SSDPClass() { end(); }
|
SSDPClass::~SSDPClass() { end(); this->isStarted = false; }
|
||||||
bool SSDPClass::begin() {
|
bool SSDPClass::begin() {
|
||||||
for(int i = 0; i < SSDP_QUEUE_SIZE; i++) {
|
for(int i = 0; i < SSDP_QUEUE_SIZE; i++) {
|
||||||
this->sendQueue[i].waiting = false;
|
this->sendQueue[i].waiting = false;
|
||||||
|
|
@ -209,6 +209,7 @@ void SSDPClass::end() {
|
||||||
if(this->_server.connected()) {
|
if(this->_server.connected()) {
|
||||||
this->_sendByeBye();
|
this->_sendByeBye();
|
||||||
this->_server.close();
|
this->_server.close();
|
||||||
|
Serial.println("Disconnected from SSDP...");
|
||||||
}
|
}
|
||||||
this->isStarted = false;
|
this->isStarted = false;
|
||||||
// Clear out the last notified so if the user starts us up again it will notify
|
// Clear out the last notified so if the user starts us up again it will notify
|
||||||
|
|
@ -216,8 +217,6 @@ void SSDPClass::end() {
|
||||||
for(uint8_t i = 0; i < this->m_cdeviceTypes; i++) {
|
for(uint8_t i = 0; i < this->m_cdeviceTypes; i++) {
|
||||||
this->deviceTypes[i].lastNotified = 0;
|
this->deviceTypes[i].lastNotified = 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
Serial.println("Disconnected from SSDP...");
|
|
||||||
}
|
}
|
||||||
UPNPDeviceType* SSDPClass::getDeviceType(uint8_t ndx) { if(ndx < this->m_cdeviceTypes) return &this->deviceTypes[ndx]; return nullptr; }
|
UPNPDeviceType* SSDPClass::getDeviceType(uint8_t ndx) { if(ndx < this->m_cdeviceTypes) return &this->deviceTypes[ndx]; return nullptr; }
|
||||||
UPNPDeviceType* SSDPClass::findDeviceByType(char *devType) {
|
UPNPDeviceType* SSDPClass::findDeviceByType(char *devType) {
|
||||||
|
|
|
||||||
11
Sockets.cpp
11
Sockets.cpp
|
|
@ -43,6 +43,9 @@ bool room_t::leave(uint8_t num) {
|
||||||
}
|
}
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
void room_t::clear() {
|
||||||
|
memset(this->clients, 255, sizeof(this->clients));
|
||||||
|
}
|
||||||
uint8_t room_t::activeClients() {
|
uint8_t room_t::activeClients() {
|
||||||
uint8_t n = 0;
|
uint8_t n = 0;
|
||||||
for(uint8_t i = 0; i < sizeof(this->clients); i++) {
|
for(uint8_t i = 0; i < sizeof(this->clients); i++) {
|
||||||
|
|
@ -77,7 +80,7 @@ void SocketEmitter::begin() {
|
||||||
sockServer.enableHeartbeat(20000, 10000, 3);
|
sockServer.enableHeartbeat(20000, 10000, 3);
|
||||||
sockServer.onEvent(this->wsEvent);
|
sockServer.onEvent(this->wsEvent);
|
||||||
Serial.println("Socket Server Started...");
|
Serial.println("Socket Server Started...");
|
||||||
settings.printAvailHeap();
|
//settings.printAvailHeap();
|
||||||
}
|
}
|
||||||
void SocketEmitter::loop() {
|
void SocketEmitter::loop() {
|
||||||
this->initClients();
|
this->initClients();
|
||||||
|
|
@ -126,7 +129,11 @@ void SocketEmitter::delayInit(uint8_t num) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
void SocketEmitter::end() { sockServer.close(); }
|
void SocketEmitter::end() {
|
||||||
|
sockServer.close();
|
||||||
|
for(uint8_t i = 0; i < SOCK_MAX_ROOMS; i++)
|
||||||
|
this->rooms[i].clear();
|
||||||
|
}
|
||||||
void SocketEmitter::disconnect() { sockServer.disconnect(); }
|
void SocketEmitter::disconnect() { sockServer.disconnect(); }
|
||||||
void SocketEmitter::wsEvent(uint8_t num, WStype_t type, uint8_t *payload, size_t length) {
|
void SocketEmitter::wsEvent(uint8_t num, WStype_t type, uint8_t *payload, size_t length) {
|
||||||
switch(type) {
|
switch(type) {
|
||||||
|
|
|
||||||
|
|
@ -12,6 +12,7 @@ struct room_t {
|
||||||
bool isJoined(uint8_t num);
|
bool isJoined(uint8_t num);
|
||||||
bool join(uint8_t num);
|
bool join(uint8_t num);
|
||||||
bool leave(uint8_t num);
|
bool leave(uint8_t num);
|
||||||
|
void clear();
|
||||||
};
|
};
|
||||||
class SocketEmitter {
|
class SocketEmitter {
|
||||||
protected:
|
protected:
|
||||||
|
|
|
||||||
|
|
@ -49,7 +49,9 @@ void loop() {
|
||||||
Serial.print("Rebooting after ");
|
Serial.print("Rebooting after ");
|
||||||
Serial.print(rebootDelay.rebootTime);
|
Serial.print(rebootDelay.rebootTime);
|
||||||
Serial.println("ms");
|
Serial.println("ms");
|
||||||
|
net.end();
|
||||||
ESP.restart();
|
ESP.restart();
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
uint32_t timing = millis();
|
uint32_t timing = millis();
|
||||||
|
|
||||||
|
|
|
||||||
Binary file not shown.
Binary file not shown.
Binary file not shown.
71
WResp.cpp
71
WResp.cpp
|
|
@ -21,7 +21,7 @@ void JsonSockEvent::endEvent(uint8_t num) {
|
||||||
else this->server->sendTXT(num, this->buff);
|
else this->server->sendTXT(num, this->buff);
|
||||||
}
|
}
|
||||||
void JsonSockEvent::_safecat(const char *val, bool escape) {
|
void JsonSockEvent::_safecat(const char *val, bool escape) {
|
||||||
size_t len = strlen(val) + strlen(this->buff);
|
size_t len = (escape ? this->calcEscapedLength(val) : strlen(val)) + strlen(this->buff);
|
||||||
if(escape) len += 2;
|
if(escape) len += 2;
|
||||||
if(len >= this->buffSize) {
|
if(len >= this->buffSize) {
|
||||||
Serial.printf("Socket exceeded buffer size %d - %d\n", this->buffSize, len);
|
Serial.printf("Socket exceeded buffer size %d - %d\n", this->buffSize, len);
|
||||||
|
|
@ -29,7 +29,8 @@ void JsonSockEvent::_safecat(const char *val, bool escape) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
if(escape) strcat(this->buff, "\"");
|
if(escape) strcat(this->buff, "\"");
|
||||||
strcat(this->buff, val);
|
if(escape) this->escapeString(val, &this->buff[strlen(this->buff)]);
|
||||||
|
else strcat(this->buff, val);
|
||||||
if(escape) strcat(this->buff, "\"");
|
if(escape) strcat(this->buff, "\"");
|
||||||
}
|
}
|
||||||
void JsonResponse::beginResponse(WebServer *server, char *buff, size_t buffSize) {
|
void JsonResponse::beginResponse(WebServer *server, char *buff, size_t buffSize) {
|
||||||
|
|
@ -52,13 +53,14 @@ void JsonResponse::send() {
|
||||||
this->_headersSent = true;
|
this->_headersSent = true;
|
||||||
}
|
}
|
||||||
void JsonResponse::_safecat(const char *val, bool escape) {
|
void JsonResponse::_safecat(const char *val, bool escape) {
|
||||||
size_t len = strlen(val) + strlen(this->buff);
|
size_t len = (escape ? this->calcEscapedLength(val) : strlen(val)) + strlen(this->buff);
|
||||||
if(escape) len += 2;
|
if(escape) len += 2;
|
||||||
if(len >= this->buffSize) {
|
if(len >= this->buffSize) {
|
||||||
this->send();
|
this->send();
|
||||||
}
|
}
|
||||||
if(escape) strcat(this->buff, "\"");
|
if(escape) strcat(this->buff, "\"");
|
||||||
strcat(this->buff, val);
|
if(escape) this->escapeString(val, &this->buff[strlen(this->buff)]);
|
||||||
|
else strcat(this->buff, val);
|
||||||
if(escape) strcat(this->buff, "\"");
|
if(escape) strcat(this->buff, "\"");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -133,13 +135,70 @@ void JsonFormatter::addElem(const char *name, uint64_t lval) { sprintf(this->_nu
|
||||||
void JsonFormatter::addElem(const char *name, bool bval) { strcpy(this->_numbuff, bval ? "true" : "false"); this->_appendNumber(name); }
|
void JsonFormatter::addElem(const char *name, bool bval) { strcpy(this->_numbuff, bval ? "true" : "false"); this->_appendNumber(name); }
|
||||||
|
|
||||||
void JsonFormatter::_safecat(const char *val, bool escape) {
|
void JsonFormatter::_safecat(const char *val, bool escape) {
|
||||||
size_t len = strlen(val) + strlen(this->buff);
|
size_t len = (escape ? this->calcEscapedLength(val) : strlen(val)) + strlen(this->buff);
|
||||||
if(escape) len += 2;
|
if(escape) len += 2;
|
||||||
if(len >= this->buffSize) {
|
if(len >= this->buffSize) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
if(escape) strcat(this->buff, "\"");
|
if(escape) strcat(this->buff, "\"");
|
||||||
strcat(this->buff, val);
|
if(escape) this->escapeString(val, &this->buff[strlen(this->buff)]);
|
||||||
|
else strcat(this->buff, val);
|
||||||
if(escape) strcat(this->buff, "\"");
|
if(escape) strcat(this->buff, "\"");
|
||||||
}
|
}
|
||||||
void JsonFormatter::_appendNumber(const char *name) { this->appendElem(name); this->_safecat(this->_numbuff); }
|
void JsonFormatter::_appendNumber(const char *name) { this->appendElem(name); this->_safecat(this->_numbuff); }
|
||||||
|
uint32_t JsonFormatter::calcEscapedLength(const char *raw) {
|
||||||
|
uint32_t len = 0;
|
||||||
|
for(size_t i = strlen(raw); i > 0; i--) {
|
||||||
|
switch(raw[i]) {
|
||||||
|
case '"':
|
||||||
|
case '/':
|
||||||
|
case '\b':
|
||||||
|
case '\f':
|
||||||
|
case '\n':
|
||||||
|
case '\r':
|
||||||
|
case '\t':
|
||||||
|
case '\\':
|
||||||
|
len += 2;
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
len++;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return len;
|
||||||
|
}
|
||||||
|
void JsonFormatter::escapeString(const char *raw, char *escaped) {
|
||||||
|
for(uint32_t i = 0; i < strlen(raw); i++) {
|
||||||
|
switch(raw[i]) {
|
||||||
|
case '"':
|
||||||
|
strcat(escaped, "\\\"");
|
||||||
|
break;
|
||||||
|
case '/':
|
||||||
|
strcat(escaped, "\\/");
|
||||||
|
break;
|
||||||
|
case '\b':
|
||||||
|
strcat(escaped, "\\b");
|
||||||
|
break;
|
||||||
|
case '\f':
|
||||||
|
strcat(escaped, "\\f");
|
||||||
|
break;
|
||||||
|
case '\n':
|
||||||
|
strcat(escaped, "\\n");
|
||||||
|
break;
|
||||||
|
case '\r':
|
||||||
|
strcat(escaped, "\\r");
|
||||||
|
break;
|
||||||
|
case '\t':
|
||||||
|
strcat(escaped, "\\t");
|
||||||
|
break;
|
||||||
|
case '\\':
|
||||||
|
strcat(escaped, "\\\\");
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
size_t len = strlen(escaped);
|
||||||
|
escaped[len] = raw[i];
|
||||||
|
escaped[len+1] = 0x00;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
|
||||||
2
WResp.h
2
WResp.h
|
|
@ -16,6 +16,8 @@ class JsonFormatter {
|
||||||
virtual void _safecat(const char *val, bool escape = false);
|
virtual void _safecat(const char *val, bool escape = false);
|
||||||
void _appendNumber(const char *name);
|
void _appendNumber(const char *name);
|
||||||
public:
|
public:
|
||||||
|
void escapeString(const char *raw, char *escaped);
|
||||||
|
uint32_t calcEscapedLength(const char *raw);
|
||||||
void beginObject(const char *name = nullptr);
|
void beginObject(const char *name = nullptr);
|
||||||
void endObject();
|
void endObject();
|
||||||
void beginArray(const char *name = nullptr);
|
void beginArray(const char *name = nullptr);
|
||||||
|
|
|
||||||
|
|
@ -1 +1 @@
|
||||||
2.4.5
|
2.4.7
|
||||||
|
|
@ -8,9 +8,9 @@
|
||||||
<meta name="apple-mobile-web-app-title" content="ESPSomfy RTS App">
|
<meta name="apple-mobile-web-app-title" content="ESPSomfy RTS App">
|
||||||
<meta name="apple-mobile-web-app-status-bar-style" content="black">
|
<meta name="apple-mobile-web-app-status-bar-style" content="black">
|
||||||
|
|
||||||
<link rel="stylesheet" href="main.css?v=2.4.5c" type="text/css" />
|
<link rel="stylesheet" href="main.css?v=2.4.7c" type="text/css" />
|
||||||
<link rel="stylesheet" href="widgets.css?v=2.4.5c" type="text/css" />
|
<link rel="stylesheet" href="widgets.css?v=2.4.7c" type="text/css" />
|
||||||
<link rel="stylesheet" href="icons.css?v=2.4.5c" type="text/css" />
|
<link rel="stylesheet" href="icons.css?v=2.4.7c" type="text/css" />
|
||||||
<link rel="icon" type="image/png" href="favicon.png" />
|
<link rel="icon" type="image/png" href="favicon.png" />
|
||||||
|
|
||||||
<!-- iPad retina icon -->
|
<!-- iPad retina icon -->
|
||||||
|
|
@ -114,7 +114,7 @@
|
||||||
rel="apple-touch-startup-image">
|
rel="apple-touch-startup-image">
|
||||||
|
|
||||||
|
|
||||||
<script type="text/javascript" src="index.js?v=2.4.5c"></script>
|
<script type="text/javascript" src="index.js?v=2.4.7c"></script>
|
||||||
</head>
|
</head>
|
||||||
<body>
|
<body>
|
||||||
<div id="divContainer" class="container main" data-auth="false">
|
<div id="divContainer" class="container main" data-auth="false">
|
||||||
|
|
@ -160,7 +160,7 @@
|
||||||
<input id="cbSsdpBroadcast" name="ssdpBroadcast" type="checkbox" data-bind="general.ssdpBroadcast" style="display:inline-block;" />
|
<input id="cbSsdpBroadcast" name="ssdpBroadcast" type="checkbox" data-bind="general.ssdpBroadcast" style="display:inline-block;" />
|
||||||
<label for="cbSsdpBroadcast" style="display:inline-block;cursor:pointer;">Broadcast uPnP over SSDP</label>
|
<label for="cbSsdpBroadcast" style="display:inline-block;cursor:pointer;">Broadcast uPnP over SSDP</label>
|
||||||
</div>
|
</div>
|
||||||
<div class="field-group">
|
<div class="field-group" style="margin-top:-12px;">
|
||||||
<input id="cbCheckForUpdate" type="checkbox" data-bind="general.checkForUpdate" style="display:inline-block;" />
|
<input id="cbCheckForUpdate" type="checkbox" data-bind="general.checkForUpdate" style="display:inline-block;" />
|
||||||
<label for="cbCheckForUpdate" style="display:inline-block;cursor:pointer;">Auto Check for Updates</label>
|
<label for="cbCheckForUpdate" style="display:inline-block;cursor:pointer;">Auto Check for Updates</label>
|
||||||
</div>
|
</div>
|
||||||
|
|
@ -275,18 +275,25 @@
|
||||||
<div id="divNetworkSettings" style="display:none;">
|
<div id="divNetworkSettings" style="display:none;">
|
||||||
<div class="subtab-container"><span class="selected" data-grpid="divNetAdapter">Adapter</span><span data-grpid="divDHCP">DHCP/Static IP</span><span data-grpid="divMQTT">MQTT</span></div>
|
<div class="subtab-container"><span class="selected" data-grpid="divNetAdapter">Adapter</span><span data-grpid="divDHCP">DHCP/Static IP</span><span data-grpid="divMQTT">MQTT</span></div>
|
||||||
<div id="divNetAdapter" class="subtab-content">
|
<div id="divNetAdapter" class="subtab-content">
|
||||||
<div class="field-group" style="vertical-align:middle;color:#00bcd4;margin-top:-24px;margin-bottom:18px;">
|
<div class="field-group" style="vertical-align:middle;color:#00bcd4;margin-top:-24px;">
|
||||||
<input id="cbHardwired" name="hardwired" data-bind="ethernet.hardwired" type="checkbox" style="display:inline-block;" onclick="wifi.useEthernetClicked();" />
|
<input id="cbHardwired" name="hardwired" data-bind="ethernet.hardwired" type="checkbox" style="display:inline-block;" onclick="wifi.useEthernetClicked();" />
|
||||||
<label for="cbHardwired" style="display:inline-block;cursor:pointer;">Use Ethernet</label>
|
<label for="cbHardwired" style="display:inline-block;cursor:pointer;">Use Ethernet</label>
|
||||||
<div id="divRoaming" style="display:inline-block;padding-left:7px;">
|
|
||||||
<input id="cbRoaming" name="roaming" data-bind="wifi.roaming" type="checkbox" style="display:inline-block;" />
|
|
||||||
<label for="cbRoaming" style="display:inline-block;cursor:pointer;">Enable Roaming</label>
|
|
||||||
</div>
|
|
||||||
<div id="divFallbackWireless" style="display:inline-block;padding-left:7px;">
|
<div id="divFallbackWireless" style="display:inline-block;padding-left:7px;">
|
||||||
<input id="cbFallbackWireless" name="fallbackwireless" data-bind="ethernet.wirelessFallback" type="checkbox" style="display:inline-block;" />
|
<input id="cbFallbackWireless" name="fallbackwireless" data-bind="ethernet.wirelessFallback" type="checkbox" style="display:inline-block;" />
|
||||||
<label for="cbFallbackWireless" style="display:inline-block;cursor:pointer;">Fallback to Wireless</label>
|
<label for="cbFallbackWireless" style="display:inline-block;cursor:pointer;">Fallback to Wireless</label>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
|
<div class="field-group" style="vertical-align:middle;color:#00bcd4;margin-top:-12px;margin-bottom:18px;">
|
||||||
|
<div id="divHiddenSSID" style="display:inline-block;">
|
||||||
|
<input id="cbHiddenSSID" data-bind="wifi.hidden" type="checkbox" style="display:inline-block;" onclick="wifi.hiddenSSIDClicked();" />
|
||||||
|
<label for="cbHiddenSSID" style="display:inline-block;cursor:pointer;">Use Hidden SSID</label>
|
||||||
|
</div>
|
||||||
|
<div id="divRoaming" style="display:inline-block;padding-left:7px;">
|
||||||
|
<input id="cbRoaming" name="roaming" data-bind="wifi.roaming" type="checkbox" style="display:inline-block;" />
|
||||||
|
<label for="cbRoaming" style="display:inline-block;cursor:pointer;">Enable Roaming</label>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
</div>
|
||||||
<div id="divWiFiMode">
|
<div id="divWiFiMode">
|
||||||
<form method="post" action="/scan">
|
<form method="post" action="/scan">
|
||||||
<div id="divAps" data-lastloaded="0" style="border-radius:5px;border:solid 1px #00bcd4;margin-bottom:-10px;"></div>
|
<div id="divAps" data-lastloaded="0" style="border-radius:5px;border:solid 1px #00bcd4;margin-bottom:-10px;"></div>
|
||||||
|
|
|
||||||
|
|
@ -1270,7 +1270,7 @@ var security = new Security();
|
||||||
|
|
||||||
class General {
|
class General {
|
||||||
initialized = false;
|
initialized = false;
|
||||||
appVersion = 'v2.4.5';
|
appVersion = 'v2.4.7';
|
||||||
reloadApp = false;
|
reloadApp = false;
|
||||||
init() {
|
init() {
|
||||||
if (this.initialized) return;
|
if (this.initialized) return;
|
||||||
|
|
@ -1603,12 +1603,13 @@ var general = new General();
|
||||||
class Wifi {
|
class Wifi {
|
||||||
initialized = false;
|
initialized = false;
|
||||||
ethBoardTypes = [{ val: 0, label: 'Custom Config' },
|
ethBoardTypes = [{ val: 0, label: 'Custom Config' },
|
||||||
{ val: 1, label: 'WT32-ETH01', clk: 0, ct: 0, addr: 1, pwr: 16, mdc: 23, mdio: 18 },
|
{ val: 7, label: 'EST-PoE-32 - Everything Smart', clk: 3, ct: 0, addr: 0, pwr: 12, mdc: 23, mdio: 18 },
|
||||||
{ val: 2, label: 'Olimex ESP32-POE', clk: 3, ct: 0, addr: 0, pwr: 12, mdc: 23, mdio: 18 },
|
{ val: 3, label: 'ESP32-EVB - Olimex', clk: 0, ct: 0, addr: 0, pwr: -1, mdc: 23, mdio: 18 },
|
||||||
{ val: 3, label: 'Olimex ESP32-EVB', clk: 0, ct: 0, addr: 0, pwr: -1, mdc: 23, mdio: 18 },
|
{ val: 2, label: 'ESP32-POE - Olimex', clk: 3, ct: 0, addr: 0, pwr: 12, mdc: 23, mdio: 18 },
|
||||||
{ val: 4, label: 'LILYGO T-Internet POE', clk: 3, ct: 0, addr: 0, pwr: 16, mdc: 23, mdio: 18 },
|
{ val: 4, label: 'T-Internet POE - LILYGO', clk: 3, ct: 0, addr: 0, pwr: 16, mdc: 23, mdio: 18 },
|
||||||
{ val: 5, label: 'wESP32 v7+', clk: 0, ct: 2, addr: 0, pwr: -1, mdc: 16, mdio: 17 },
|
{ val: 5, label: 'wESP32 v7+ - Silicognition', clk: 0, ct: 2, addr: 0, pwr: -1, mdc: 16, mdio: 17 },
|
||||||
{ val: 6, label: 'wESP32 < v7', clk: 0, ct: 0, addr: 0, pwr: -1, mdc: 16, mdio: 17 }
|
{ val: 6, label: 'wESP32 < v7 - Silicognition', clk: 0, ct: 0, addr: 0, pwr: -1, mdc: 16, mdio: 17 },
|
||||||
|
{ val: 1, label: 'WT32-ETH01 - Wireless Tag', clk: 0, ct: 0, addr: 1, pwr: 16, mdc: 23, mdio: 18 }
|
||||||
];
|
];
|
||||||
ethClockModes = [{ val: 0, label: 'GPIO0 IN' }, { val: 1, label: 'GPIO0 OUT' }, { val: 2, label: 'GPIO16 OUT' }, { val: 3, label: 'GPIO17 OUT' }];
|
ethClockModes = [{ val: 0, label: 'GPIO0 IN' }, { val: 1, label: 'GPIO0 OUT' }, { val: 2, label: 'GPIO16 OUT' }, { val: 3, label: 'GPIO17 OUT' }];
|
||||||
ethPhyTypes = [{ val: 0, label: 'LAN8720' }, { val: 1, label: 'TLK110' }, { val: 2, label: 'RTL8201' }, { val: 3, label: 'DP83848' }, { val: 4, label: 'DM9051' }, { val: 5, label: 'KZ8081' }];
|
ethPhyTypes = [{ val: 0, label: 'LAN8720' }, { val: 1, label: 'TLK110' }, { val: 2, label: 'RTL8201' }, { val: 3, label: 'DP83848' }, { val: 4, label: 'DM9051' }, { val: 5, label: 'KZ8081' }];
|
||||||
|
|
@ -1675,6 +1676,7 @@ class Wifi {
|
||||||
document.getElementById('cbHardwired').checked = settings.connType >= 2;
|
document.getElementById('cbHardwired').checked = settings.connType >= 2;
|
||||||
document.getElementById('cbFallbackWireless').checked = settings.connType === 3;
|
document.getElementById('cbFallbackWireless').checked = settings.connType === 3;
|
||||||
ui.toElement(pnl, settings);
|
ui.toElement(pnl, settings);
|
||||||
|
/*
|
||||||
if (settings.connType >= 2) {
|
if (settings.connType >= 2) {
|
||||||
document.getElementById('divWiFiMode').style.display = 'none';
|
document.getElementById('divWiFiMode').style.display = 'none';
|
||||||
document.getElementById('divEthernetMode').style.display = '';
|
document.getElementById('divEthernetMode').style.display = '';
|
||||||
|
|
@ -1687,10 +1689,13 @@ class Wifi {
|
||||||
document.getElementById('divFallbackWireless').style.display = 'none';
|
document.getElementById('divFallbackWireless').style.display = 'none';
|
||||||
document.getElementById('divRoaming').style.display = 'inline-block';
|
document.getElementById('divRoaming').style.display = 'inline-block';
|
||||||
}
|
}
|
||||||
|
*/
|
||||||
|
ui.toElement(document.getElementById('divDHCP'), settings);
|
||||||
document.getElementById('divETHSettings').style.display = settings.ethernet.boardType === 0 ? '' : 'none';
|
document.getElementById('divETHSettings').style.display = settings.ethernet.boardType === 0 ? '' : 'none';
|
||||||
document.getElementById('divStaticIP').style.display = settings.ip.dhcp ? 'none' : '';
|
document.getElementById('divStaticIP').style.display = settings.ip.dhcp ? 'none' : '';
|
||||||
ui.toElement(document.getElementById('divDHCP'), settings);
|
|
||||||
document.getElementById('spanCurrentIP').innerHTML = settings.ip.ip;
|
document.getElementById('spanCurrentIP').innerHTML = settings.ip.ip;
|
||||||
|
this.useEthernetClicked();
|
||||||
|
this.hiddenSSIDClicked();
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
@ -1701,6 +1706,12 @@ class Wifi {
|
||||||
document.getElementById('divEthernetMode').style.display = useEthernet ? '' : 'none';
|
document.getElementById('divEthernetMode').style.display = useEthernet ? '' : 'none';
|
||||||
document.getElementById('divFallbackWireless').style.display = useEthernet ? 'inline-block' : 'none';
|
document.getElementById('divFallbackWireless').style.display = useEthernet ? 'inline-block' : 'none';
|
||||||
document.getElementById('divRoaming').style.display = useEthernet ? 'none' : 'inline-block';
|
document.getElementById('divRoaming').style.display = useEthernet ? 'none' : 'inline-block';
|
||||||
|
document.getElementById('divHiddenSSID').style.display = useEthernet ? 'none' : 'inline-block';
|
||||||
|
}
|
||||||
|
hiddenSSIDClicked() {
|
||||||
|
let hidden = document.getElementById('cbHiddenSSID').checked;
|
||||||
|
if (hidden) document.getElementById('cbRoaming').checked = false;
|
||||||
|
document.getElementById('cbRoaming').disabled = hidden;
|
||||||
}
|
}
|
||||||
async loadAPs() {
|
async loadAPs() {
|
||||||
if (document.getElementById('btnScanAPs').classList.contains('disabled')) return;
|
if (document.getElementById('btnScanAPs').classList.contains('disabled')) return;
|
||||||
|
|
@ -2786,7 +2797,7 @@ class Somfy {
|
||||||
pinMaps = [
|
pinMaps = [
|
||||||
{ name: '', maxPins: 39, inputs: [0, 1, 6, 7, 8, 9, 10, 11, 37, 38], outputs: [3, 6, 7, 8, 9, 10, 11, 34, 35, 36, 37, 38, 39] },
|
{ name: '', maxPins: 39, inputs: [0, 1, 6, 7, 8, 9, 10, 11, 37, 38], outputs: [3, 6, 7, 8, 9, 10, 11, 34, 35, 36, 37, 38, 39] },
|
||||||
{ name: 's2', maxPins: 46, inputs: [0, 19, 20, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 45], outputs: [0, 19, 20, 26, 27, 28, 29, 30, 31, 32, 45, 46]},
|
{ name: 's2', maxPins: 46, inputs: [0, 19, 20, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 45], outputs: [0, 19, 20, 26, 27, 28, 29, 30, 31, 32, 45, 46]},
|
||||||
{ name: 's3', maxPins: 48, inputs: [0, 19, 20, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 39, 40, 41, 42, 43], outputs: [0, 19, 20, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 39, 40, 41, 42, 43] },
|
{ name: 's3', maxPins: 48, inputs: [19, 20, 22, 23, 24, 25, 27, 28, 29, 30, 31, 32], outputs: [19, 20, 22, 23, 24, 25, 27, 28, 29, 30, 31, 32] },
|
||||||
{ name: 'c3', maxPins: 21, inputs: [11, 12, 13, 14, 15, 16, 17, 18, 19, 20], outputs: [11, 12, 13, 14, 15, 16, 17, 21] }
|
{ name: 'c3', maxPins: 21, inputs: [11, 12, 13, 14, 15, 16, 17, 18, 19, 20], outputs: [11, 12, 13, 14, 15, 16, 17, 21] }
|
||||||
];
|
];
|
||||||
|
|
||||||
|
|
@ -3691,12 +3702,36 @@ class Somfy {
|
||||||
html += '<li>If the shade does not jog, press the prog button again until the shade jogs.</li>';
|
html += '<li>If the shade does not jog, press the prog button again until the shade jogs.</li>';
|
||||||
html += '</ul>';
|
html += '</ul>';
|
||||||
html += `<div class="button-container">`;
|
html += `<div class="button-container">`;
|
||||||
html += `<button id="btnSendUnpairing" type="button" style="padding-left:20px;padding-right:20px;display:inline-block;" onclick="somfy.sendCommand(${shadeId}, 'prog', 1);">Prog</button>`;
|
html += `<button id="btnSendUnpairing" type="button" style="padding-left:20px;padding-right:20px;display:inline-block;">Prog</button>`;
|
||||||
html += `<button id="btnMarkPaired" type="button" style="padding-left:20px;padding-right:20px;display:inline-block;" onclick="somfy.setPaired(${shadeId}, false);">Shade Unpaired</button>`;
|
html += `<button id="btnMarkPaired" type="button" style="padding-left:20px;padding-right:20px;display:inline-block;" onclick="somfy.setPaired(${shadeId}, false);">Shade Unpaired</button>`;
|
||||||
html += `<button id="btnStopUnpairing" type="button" style="padding-left:20px;padding-right:20px;display:inline-block" onclick="document.getElementById('divPairing').remove();">Close</button>`;
|
html += `<button id="btnStopUnpairing" type="button" style="padding-left:20px;padding-right:20px;display:inline-block" onclick="document.getElementById('divPairing').remove();">Close</button>`;
|
||||||
html += `</div>`;
|
html += `</div>`;
|
||||||
div.innerHTML = html;
|
div.innerHTML = html;
|
||||||
|
let fnRepeatProg = (err, shade) => {
|
||||||
|
if (this.btnTimer) {
|
||||||
|
clearTimeout(this.btnTimer);
|
||||||
|
this.btnTimer = null;
|
||||||
|
}
|
||||||
|
if (err) return;
|
||||||
|
if (mouseDown) {
|
||||||
|
somfy.sendCommandRepeat(shadeId, 'prog', null, fnRepeatProg);
|
||||||
|
}
|
||||||
|
}
|
||||||
document.getElementById('somfyShade').appendChild(div);
|
document.getElementById('somfyShade').appendChild(div);
|
||||||
|
let btn = document.getElementById('btnSendUnpairing');
|
||||||
|
btn.addEventListener('mousedown', (event) => {
|
||||||
|
console.log(this);
|
||||||
|
console.log(event);
|
||||||
|
console.log('mousedown');
|
||||||
|
somfy.sendCommand(shadeId, 'prog', null, (err, shade) => { fnRepeatProg(err, shade); });
|
||||||
|
}, true);
|
||||||
|
btn.addEventListener('touchstart', (event) => {
|
||||||
|
console.log(this);
|
||||||
|
console.log(event);
|
||||||
|
console.log('touchstart');
|
||||||
|
somfy.sendCommand(shadeId, 'prog', null, (err, shade) => { fnRepeatProg(err, shade); });
|
||||||
|
}, true);
|
||||||
|
|
||||||
return div;
|
return div;
|
||||||
}
|
}
|
||||||
sendCommand(shadeId, command, repeat, cb) {
|
sendCommand(shadeId, command, repeat, cb) {
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue