[WIP] New Vue Web UI

.github/CODEOWNERS

@@ -0,0 +1,5 @@
+# Global owners
+* @xoseperez @mcspr
+
+# Vue ui codeowner
+/code/ui/ @tofandel

.gitignore

@@ -15,5 +15,6 @@ custom.h
 .env
 .DS_Store
 .vscode
+.idea
 _pycache_/
-*.py[cod]
+*.py[cod]

code/espurna/alexa.ino

@@ -27,9 +27,15 @@ bool _alexaWebSocketOnKeyCheck(const char * key, JsonVariant& value) {
     return (strncmp(key, "alexa", 5) == 0);
 }
 
+void _alexaWebSocketOnVisible(JsonObject& root) {
+    JsonObject& modules = root["_modules"];
+    modules["alexa"] = 1;
+}
+
 void _alexaWebSocketOnConnected(JsonObject& root) {
-    root["alexaEnabled"] = alexaEnabled();
-    root["alexaName"] = getSetting("alexaName");
+    JsonObject& alexa = root.createNestedObject("alexa");
+    alexa["enabled"] = alexaEnabled();
+    alexa["name"] = getSetting("alexaName");
 }
 
 void _alexaConfigure() {
@@ -49,7 +55,7 @@ void _alexaConfigure() {
 
 #if BROKER_SUPPORT
 void _alexaBrokerCallback(const String& topic, unsigned char id, unsigned int value) {
-    
+
     // Only process status messages for switches and channels
     if (!topic.equals(MQTT_TOPIC_CHANNEL)
         && !topic.equals(MQTT_TOPIC_RELAY)) {
@@ -124,7 +130,7 @@ void alexaSetup() {
         webBodyRegister(_alexaBodyCallback);
         webRequestRegister(_alexaRequestCallback);
         wsRegister()
-            .onVisible([](JsonObject& root) { root["alexaVisible"] = 1; })
+            .onVisible(_alexaWebSocketOnVisible)
             .onConnected(_alexaWebSocketOnConnected)
             .onKeyCheck(_alexaWebSocketOnKeyCheck);
     #endif

code/espurna/api.ino

@@ -38,11 +38,17 @@ bool _apiWebSocketOnKeyCheck(const char * key, JsonVariant& value) {
     return (strncmp(key, "api", 3) == 0);
 }
 
+void _apiWebSocketOnVisible(JsonObject& root) {
+    JsonObject& modules = root["_modules"];
+    modules["api"] = 1;
+}
+
 void _apiWebSocketOnConnected(JsonObject& root) {
-    root["apiEnabled"] = _apiEnabled();
-    root["apiKey"] = _apiKey();
-    root["apiRestFul"] = _apiRestFul();
-    root["apiRealTime"] = getSetting("apiRealTime", 1 == API_REAL_TIME_VALUES);
+    JsonObject& api = root.createNestedObject("api");
+    api["enabled"] = _apiEnabled();
+    api["key"] = _apiKey();
+    api["restFul"] = _apiRestFul();
+    api["realTime"] = getSetting("apiRealTime", 1 == API_REAL_TIME_VALUES);
 }
 
 void _apiConfigure() {
@@ -253,7 +259,7 @@ void apiRegister(const char * key, api_get_callback_f getFn, api_put_callback_f
 void apiSetup() {
     _apiConfigure();
     wsRegister()
-        .onVisible([](JsonObject& root) { root["apiVisible"] = 1; })
+        .onVisible(_apiWebSocketOnVisible)
         .onConnected(_apiWebSocketOnConnected)
         .onKeyCheck(_apiWebSocketOnKeyCheck);
     webRequestRegister(_apiRequestCallback);

code/espurna/button.ino

@@ -59,7 +59,8 @@ void buttonMQTT(unsigned char id, uint8_t event) {
 
 void _buttonWebSocketOnVisible(JsonObject& root) {
     if (buttonCount() > 0) {
-        root["btnVisible"] = 1;
+        JsonObject& modules = root["_modules"];
+        modules["btn"] = 1;
     }
 }
 
@@ -104,15 +105,15 @@ void buttonEvent(unsigned char id, unsigned char event) {
     if (BUTTON_MODE_OFF == action) {
         relayStatus(button.relayID, false);
     }
-    
+
     if (BUTTON_MODE_AP == action) {
         if (wifiState() & WIFI_STATE_AP) {
             wifiStartSTA();
         } else {
             wifiStartAP();
         }
     }
-    
+
     if (BUTTON_MODE_RESET == action) {
         deferredReset(100, CUSTOM_RESET_HARDWARE);
     }
@@ -128,13 +129,13 @@ void buttonEvent(unsigned char id, unsigned char event) {
             wifiStartWPS();
         }
     #endif // defined(JUSTWIFI_ENABLE_WPS)
-    
+
     #if defined(JUSTWIFI_ENABLE_SMARTCONFIG)
         if (BUTTON_MODE_SMART_CONFIG == action) {
             wifiStartSmartConfig();
         }
     #endif // defined(JUSTWIFI_ENABLE_SMARTCONFIG)
-    
+
     #if LIGHT_PROVIDER != LIGHT_PROVIDER_NONE
     if (BUTTON_MODE_DIM_UP == action) {
         lightBrightnessStep(1);

code/espurna/config/general.h

@@ -689,7 +689,7 @@
 // there are no special requirements. Any static web server will do (NGinx, Apache, Lighttpd,...).
 // The only requirement is that the resource must be available under this domain.
 #ifndef WEB_REMOTE_DOMAIN
-#define WEB_REMOTE_DOMAIN           "http://espurna.io"
+#define WEB_REMOTE_DOMAIN           "*"
 #endif
 
 // -----------------------------------------------------------------------------

code/espurna/debug.ino

@@ -214,6 +214,12 @@ void _debugSendInternal(const char * message, bool add_timestamp) {
 
 #if DEBUG_WEB_SUPPORT
 
+void _debugWebSocketOnVisible(JsonObject& root) {
+    JsonObject& modules = root["_modules"];
+
+    modules["dbg"] = 1;
+}
+
 void _debugWebSocketOnAction(uint32_t client_id, const char * action, JsonObject& data) {
 
         #if TERMINAL_SUPPORT
@@ -232,7 +238,7 @@ void _debugWebSocketOnAction(uint32_t client_id, const char * action, JsonObject
 void debugWebSetup() {
 
     wsRegister()
-        .onVisible([](JsonObject& root) { root["dbgVisible"] = 1; })
+        .onVisible(_debugWebSocketOnVisible)
         .onAction(_debugWebSocketOnAction);
 
     // TODO: if hostname string changes, need to update header too
@@ -305,7 +311,7 @@ DebugLogMode _debugLogModeDeserialize(const String& value) {
 
 void debugConfigureBoot() {
     static_assert(
-        std::is_same<int, std::underlying_type<DebugLogMode>::type>::value, 
+        std::is_same<int, std::underlying_type<DebugLogMode>::type>::value,
         "should be able to match DebugLogMode with int"
     );
 

code/espurna/domoticz.ino

@@ -199,24 +199,28 @@ bool _domoticzWebSocketOnKeyCheck(const char * key, JsonVariant& value) {
 }
 
 void _domoticzWebSocketOnVisible(JsonObject& root) {
-    root["dczVisible"] = static_cast<unsigned char>(haveRelaysOrSensors());
+    JsonObject& modules = root["_modules"];
+    modules["dcz"] = static_cast<unsigned char>(haveRelaysOrSensors());
 }
 
 void _domoticzWebSocketOnConnected(JsonObject& root) {
+    JsonObject& dcz = root.createNestedObject("dcz");
 
-    root["dczEnabled"] = getSetting("dczEnabled", 1 == DOMOTICZ_ENABLED);
-    root["dczTopicIn"] = getSetting("dczTopicIn", DOMOTICZ_IN_TOPIC);
-    root["dczTopicOut"] = getSetting("dczTopicOut", DOMOTICZ_OUT_TOPIC);
+    dcz["enabled"] = getSetting("dczEnabled", 1 == DOMOTICZ_ENABLED);
+    dcz["topicIn"] = getSetting("dczTopicIn", DOMOTICZ_IN_TOPIC);
+    dcz["topicOut"] = getSetting("dczTopicOut", DOMOTICZ_OUT_TOPIC);
 
-    JsonArray& relays = root.createNestedArray("dczRelays");
+    JsonArray& relays = dcz.createNestedArray("relays");
     for (unsigned char i=0; i<relayCount(); i++) {
         relays.add(_domoticzIdx(i));
     }
 
+    //Is this really needed since already done in sensor
+    /*
     #if SENSOR_SUPPORT
-        _sensorWebSocketMagnitudes(root, "dcz");
+        _sensorWebSocketMagnitudesConfig(dcz);
     #endif
-
+    */
 }
 
 #endif // WEB_SUPPORT

code/espurna/homeassistant.ino

@@ -204,7 +204,7 @@ void _haSendMagnitude(unsigned char i, JsonObject& config) {
     unsigned char type = magnitudeType(i);
     config["name"] = _haFixName(getSetting("hostname") + String(" ") + magnitudeTopic(type));
     config["state_topic"] = mqttTopic(magnitudeTopicIndex(i).c_str(), false);
-    config["unit_of_measurement"] = magnitudeUnits(type);
+    config["unit_of_measurement"] = magnitudeUnit(type);
 }
 
 void ha_discovery_t::prepareMagnitudes(ha_config_t& config) {
@@ -224,7 +224,7 @@ void ha_discovery_t::prepareMagnitudes(ha_config_t& config) {
             _haSendMagnitude(i, root);
             root["uniq_id"] = getIdentifier() + "_" + magnitudeTopic(magnitudeType(i)) + "_" + String(i);
             root["device"] = config.deviceConfig;
-            
+
             message.reserve(root.measureLength());
             root.printTo(message);
         }
@@ -423,7 +423,7 @@ void _haSend() {
     #if SENSOR_SUPPORT
         _ha_discovery->prepareMagnitudes(config);
     #endif
-    
+
     _ha_send_flag = false;
     schedule_function(_haSendDiscovery);
 
@@ -456,12 +456,15 @@ bool _haWebSocketOnKeyCheck(const char * key, JsonVariant& value) {
 }
 
 void _haWebSocketOnVisible(JsonObject& root) {
-    root["haVisible"] = 1;
+    JsonObject& modules = root["_modules"];
+    modules["ha"] = 1;
 }
 
 void _haWebSocketOnConnected(JsonObject& root) {
-    root["haPrefix"] = getSetting("haPrefix", HOMEASSISTANT_PREFIX);
-    root["haEnabled"] = getSetting("haEnabled", 1 == HOMEASSISTANT_ENABLED);
+    JsonObject& ha = root.createNestedObject("ha");
+
+    ha["enabled"] = getSetting("haEnabled", 1 == HOMEASSISTANT_ENABLED);
+    ha["prefix"] = getSetting("haPrefix", HOMEASSISTANT_PREFIX);
 }
 
 void _haWebSocketOnAction(uint32_t client_id, const char * action, JsonObject& data) {

code/espurna/influxdb.ino

@@ -114,16 +114,19 @@ bool _idbWebSocketOnKeyCheck(const char * key, JsonVariant& value) {
 }
 
 void _idbWebSocketOnVisible(JsonObject& root) {
-    root["idbVisible"] = 1;
+    JsonObject& modules = root["_modules"];
+    modules["idb"] = 1;
 }
 
 void _idbWebSocketOnConnected(JsonObject& root) {
-    root["idbEnabled"] = getSetting("idbEnabled", 1 == INFLUXDB_ENABLED);
-    root["idbHost"] = getSetting("idbHost", INFLUXDB_HOST);
-    root["idbPort"] = getSetting("idbPort", INFLUXDB_PORT);
-    root["idbDatabase"] = getSetting("idbDatabase", INFLUXDB_DATABASE);
-    root["idbUsername"] = getSetting("idbUsername", INFLUXDB_USERNAME);
-    root["idbPassword"] = getSetting("idbPassword", INFLUXDB_PASSWORD);
+    JsonObject& idb = root.createNestedObject("idb");
+
+    idb["enabled"] = getSetting("idbEnabled", 1 == INFLUXDB_ENABLED);
+    idb["host"] = getSetting("idbHost", INFLUXDB_HOST);
+    idb["port"] = getSetting("idbPort", INFLUXDB_PORT);
+    idb["database"] = getSetting("idbDatabase", INFLUXDB_DATABASE);
+    idb["username"] = getSetting("idbUsername", INFLUXDB_USERNAME);
+    idb["password"] = getSetting("idbPassword", INFLUXDB_PASSWORD);
 }
 
 void _idbConfigure() {

code/espurna/ir.ino

@@ -398,13 +398,13 @@ void irSetup() {
 
     #if defined(IR_RX_PIN)
         _ir_receiver.enableIRIn();
-        DEBUG_MSG_P(PSTR("[IR] Receiver initialized \n"));
+        DEBUG_MSG_P(PSTR("[IR] Receiver initialized\n"));
     #endif
 
     #if MQTT_SUPPORT && defined(IR_TX_PIN)
         _ir_sender.begin();
         mqttRegister(_irMqttCallback);
-        DEBUG_MSG_P(PSTR("[IR] Transmitter initialized \n"));
+        DEBUG_MSG_P(PSTR("[IR] Transmitter initialized\n"));
     #endif
 
     espurnaRegisterLoop(_irLoop);

code/espurna/led.ino

@@ -106,17 +106,25 @@ bool _ledWebSocketOnKeyCheck(const char * key, JsonVariant& value) {
 
 void _ledWebSocketOnVisible(JsonObject& root) {
     if (_ledCount() > 0) {
-        root["ledVisible"] = 1;
+        JsonObject& modules = root["_modules"];
+        modules["led"] = 1;
     }
 }
 
 void _ledWebSocketOnConnected(JsonObject& root) {
     if (!_ledCount()) return;
-    JsonArray& leds = root.createNestedArray("ledConfig");
-    for (unsigned char id = 0; id < _ledCount(); ++id) {
-        JsonObject& led = leds.createNestedObject();
-        led["mode"] = getSetting({"ledMode", id}, _leds[id].mode);
-        led["relay"] = getSetting<unsigned char>({"ledRelay", id}, _leds[id].relayID);
+    JsonObject& led = root.createNestedObject("led");
+
+    JsonArray& schema = led.createNestedArray("_schema");
+
+    schema.add("mode");
+    schema.add("relay");
+
+    JsonArray& leds = root.createNestedArray("list");
+    for (unsigned char id = 0; id <_ledCount(); ++id) {
+        JsonArray& led = leds.createNestedArray();
+        led.add(getSetting({"ledMode", id}, _leds[id].mode));
+        led.add(getSetting<unsigned char>({"ledRelay", id}, _leds[id].relayID));
     }
 }
 

code/espurna/light.ino

@@ -781,13 +781,13 @@ void lightMQTT() {
         mqttSend(MQTT_TOPIC_COLOR_HSV, buffer);
 
     }
-    
+
     if (_light_has_color || _light_use_cct) {
-      
+
       // Mireds
       snprintf_P(buffer, sizeof(buffer), PSTR("%d"), _light_mireds);
       mqttSend(MQTT_TOPIC_MIRED, buffer);
-    
+
     }
 
     // Channels
@@ -1042,7 +1042,8 @@ void _lightWebSocketStatus(JsonObject& root) {
 }
 
 void _lightWebSocketOnVisible(JsonObject& root) {
-    root["colorVisible"] = 1;
+    JsonObject& modules = root["_modules"];
+    modules["color"] = 1;
 }
 
 void _lightWebSocketOnConnected(JsonObject& root) {

code/espurna/lightfox.ino

@@ -28,7 +28,7 @@ void lightfoxLearn() {
     Serial.write(LIGHTFOX_CODE_STOP);
     Serial.println();
     Serial.flush();
-    DEBUG_MSG_P(PSTR("[LIGHTFOX] Learn comman sent\n"));
+    DEBUG_MSG_P(PSTR("[LIGHTFOX] Learn command sent\n"));
 }
 
 void lightfoxClear() {
@@ -38,7 +38,7 @@ void lightfoxClear() {
     Serial.write(LIGHTFOX_CODE_STOP);
     Serial.println();
     Serial.flush();
-    DEBUG_MSG_P(PSTR("[LIGHTFOX] Clear comman sent\n"));
+    DEBUG_MSG_P(PSTR("[LIGHTFOX] Clear command sent\n"));
 }
 
 // -----------------------------------------------------------------------------
@@ -48,10 +48,12 @@ void lightfoxClear() {
 #if WEB_SUPPORT
 
 void _lightfoxWebSocketOnConnected(JsonObject& root) {
-    root["lightfoxVisible"] = 1;
+    JsonObject& lightfox = root.createNestedObject("lightfox");
+
+    lightfox["enabled"] = 1;
+
     uint8_t buttonsCount = _buttons.size();
-    root["lightfoxRelayCount"] = relayCount();
-    JsonArray& rfb = root.createNestedArray("lightfoxButtons");
+    JsonArray& rfb = root.createNestedArray("buttons");
     for (byte id=0; id<buttonsCount; id++) {
         JsonObject& node = rfb.createNestedObject();
         node["id"] = id;