blynk support

README.md

@@ -69,6 +69,7 @@ It uses the Arduino Core for ESP8266 framework and a number of 3rd party librari
     * Integration via MQTT Discover or copy-pasting configuration code
 * [**InfluxDB**](https://www.influxdata.com/) integration via HTTP API
 * [**Thingspeak**](https://thingspeak.com/) integration via HTTP API (HTTPS available for custom builds)
+* [**Blynk**](https://www.blynk.cc/) integration via native Blynk API.
 * **Sonoff RF Bridge** support
     * Multiple virtual switches (tested with up to 16)
     * MQTT-to-RF two-way bridge (no need to learn codes)

code/espurna/blynk.ino

@@ -0,0 +1,158 @@
+/*
+
+BLYNK MODULE
+
+Copyright (C) 2018 by Thomas Häger <thaeger at hdsnetz dot de>
+
+*/
+
+#if BLYNK_SUPPORT
+#include <ESP8266WiFi.h>
+#include <BlynkSimpleStream.h>
+
+bool _blnk_enabled = false;
+WiFiClient _wific;
+
+signed char _blynkRelay(unsigned int vpin) {
+    for (unsigned char relayID=0; relayID<relayCount(); relayID++) {
+        if (getSetting("blnkRelayVpin", relayID, 0).toInt() == vpin) {
+            return relayID;
+        }
+    }
+    return -1;
+}
+
+void _blnkConfigure() {
+    _blnk_enabled = getSetting("blnkEnabled", BLYNK_ENABLED).toInt() == 1;
+    if (_blnk_enabled && (getSetting("blnkHost", BLYNK_HOST).length() == 0)) {
+        _blnk_enabled = false;
+        setSetting("blnkEnabled", 0);
+    }
+    if(!_blnk_enabled) {
+      Blynk.disconnect();
+      _wific.stop();
+      return;
+    }
+}
+
+void _wifi_connect() {
+
+  if (_wific.connect(&getSetting("blnkHost", BLYNK_HOST)[0], getSetting("blnkPort", BLYNK_PORT).toInt()))
+    DEBUG_MSG_P(PSTR("[BLYNK] WiFi Client connected\n"));
+  else
+    DEBUG_MSG_P(PSTR("[BLYNK] WiFi could not connect to %s:%s.\n"),&getSetting("blnkHost", BLYNK_HOST)[0],&getSetting("blnkHost", BLYNK_PORT)[0]);
+}
+
+BLYNK_WRITE_DEFAULT(){
+  signed char relayID = _blynkRelay(request.pin);
+  int value = param[0].asInt();
+  if (relayID >= 0) {
+    DEBUG_MSG_P(PSTR("[BLYNK] Received value %d for VPIN %u\n"), value, request.pin);
+    relayStatus(relayID, value == 1);
+  } else {
+    DEBUG_MSG_P(PSTR("[BLYNK] Received value %d for unassigned VPIN %u\n"), value, request.pin);
+  }
+}
+
+BLYNK_CONNECTED(){
+  DEBUG_MSG_P(PSTR("[BLYNK] Connected to Blynk server\n"));
+  blynkSendRelays();
+}
+
+#if WEB_SUPPORT
+
+bool _blnkWebSocketOnReceive(const char * key, JsonVariant& value) {
+    return (strncmp(key, "blnk", 4) == 0);
+}
+
+void _blnkWebSocketOnSend(JsonObject& root) {
+    root["blnkVisible"] = 1;
+    root["blnkEnabled"] = getSetting("blnkEnabled", BLYNK_ENABLED).toInt() == 1;
+    root["blnkAuthKey"] = getSetting("blnkAuthKey", BLYNK_AUTH_TOKEN);
+    root["blnkHost"] = getSetting("blnkHost", BLYNK_HOST);
+    root["blnkPort"] = getSetting("blnkPort", BLYNK_PORT).toInt();
+
+    JsonArray& relays = root.createNestedArray("blnkRelays");
+    for (unsigned char i=0; i<relayCount(); i++) {
+        relays.add(getSetting("blnkRelayVpin", i, -1).toInt());
+    }
+
+    #if SENSOR_SUPPORT
+        JsonArray& list = root.createNestedArray("blnkMagnitudes");
+        for (byte i=0; i<magnitudeCount(); i++) {
+            JsonObject& element = list.createNestedObject();
+            element["name"] = magnitudeName(i);
+            element["type"] = magnitudeType(i);
+            element["index"] = magnitudeIndex(i);
+            element["idx"] = getSetting("blnkMagnitude", i, -1).toInt();
+        }
+    #endif
+}
+#endif //WEB_SUPPORT
+
+void blynkSendRelays() {
+    for (uint8_t relayID=0; relayID < relayCount(); relayID++) {
+        blynkSendRelay(relayID, relayStatus(relayID) ? 1 : 0);
+    }
+}
+
+void blynkSendMeasurement(unsigned char key, char * payload) {
+    if (!_blnk_enabled) return;
+    int  vpin = getSetting("blnkMagnitude", key, -1).toInt();
+    if(vpin>-1) {
+      //DEBUG_MSG_P(PSTR("[BLYNK] Send sensor data to VPIN %u Data: %s\n"), vpin, payload);
+      Blynk.virtualWrite(vpin,payload);
+    }
+}
+
+void blynkSendRelay(unsigned char key, unsigned char status) {
+    if (!_blnk_enabled) return;
+    DEBUG_MSG_P(PSTR("[BLYNK] Send new status %u to Relay %u\n"),status,key);
+    unsigned int  vpin = getSetting("blnkRelayVpin", key, 0).toInt();
+    Blynk.virtualWrite(vpin,status);
+}
+
+int blynkVpin(unsigned char relayID) {
+    char buffer[17];
+    snprintf_P(buffer, sizeof(buffer), PSTR("blnkRelayVpin%u"), relayID);
+    return getSetting(buffer).toInt();
+}
+
+
+
+void blynkSetup(){
+
+  _blnkConfigure();
+
+  #if WEB_SUPPORT
+      wsOnSendRegister(_blnkWebSocketOnSend);
+      wsOnReceiveRegister(_blnkWebSocketOnReceive);
+  #endif
+
+  espurnaRegisterLoop(blnkLoop);
+  espurnaRegisterReload(_blnkConfigure);
+
+}
+
+
+void blnkLoop(){
+
+  if(!_blnk_enabled) return;
+
+  if (!wifiConnected() || (WiFi.getMode() != WIFI_STA)) return;
+
+  if(!_wific.connected()) _wifi_connect();
+
+  if (!Blynk.connected()) {
+    char auth[50];
+    getSetting("blnkAuthKey", BLYNK_AUTH_TOKEN).toCharArray(auth,50);
+    Blynk.config(_wific, auth);
+    if (!Blynk.connect(3000))
+      DEBUG_MSG_P(PSTR("[BLYNK] Could not connect to Bylnk Server. Token[%s]\n"),auth);
+  }
+
+  Blynk.run();
+
+}
+
+#endif

code/espurna/config/general.h

@@ -1016,6 +1016,18 @@
 #define THINGSPEAK_TRIES            3               // Number of tries when sending data (minimum 1)
 #endif
 
+// -----------------------------------------------------------------------------
+// BLYNK
+// -----------------------------------------------------------------------------
+
+#ifndef BLYNK_SUPPORT
+#define BLYNK_SUPPORT        1
+#define BLYNK_ENABLED        0
+#define BLYNK_AUTH_TOKEN     "insert your blynk auth key here"
+#define BLYNK_HOST  "blynk-cloud.com"
+#define BLYNK_PORT  80
+#endif
+
 // -----------------------------------------------------------------------------
 // SCHEDULER
 // -----------------------------------------------------------------------------

code/espurna/config/hardware.h

@@ -39,6 +39,7 @@
     #define BROKER_SUPPORT          0
     #define BUTTON_SUPPORT          0
     #define DOMOTICZ_SUPPORT        0
+    #define BLYNK_SUPPORT           0
     #define HOMEASSISTANT_SUPPORT   0
     #define I2C_SUPPORT             0
     #define MDNS_SERVER_SUPPORT     0
@@ -3025,6 +3026,38 @@
     #define NETBIOS_SUPPORT     1
     #define SSDP_SUPPORT        1
 
+#elif defined(TUYA_TYWE3S_ZX2820)
+
+    // Info
+    #define MANUFACTURER        "Tuya"
+    #define DEVICE              "ZX2820"
+
+    // Buttons
+    #define BUTTON1_PIN         0
+    #define BUTTON1_MODE        BUTTON_PUSHBUTTON | BUTTON_SET_PULLUP | BUTTON_DEFAULT_HIGH
+    #define BUTTON1_PRESS       BUTTON_MODE_NONE
+    #define BUTTON1_CLICK       BUTTON_MODE_TOGGLE
+    #define BUTTON1_DBLCLICK    BUTTON_MODE_NONE
+    #define BUTTON1_LNGCLICK    BUTTON_MODE_NONE
+    #define BUTTON1_LNGLNGCLICK BUTTON_MODE_RESET
+    #define BUTTON1_RELAY       1
+
+    // Relays
+    #define RELAY1_PIN          14
+    #define RELAY1_TYPE         RELAY_TYPE_NORMAL
+
+    // LEDs
+    #define LED1_PIN            13
+    #define LED1_PIN_INVERSE    0
+
+    // HLW8012
+    #ifndef HLW8012_SUPPORT
+    #define HLW8012_SUPPORT     1
+    #endif
+    #define HLW8012_SEL_PIN     15
+    #define HLW8012_CF1_PIN     5
+    #define HLW8012_CF_PIN      4
+
 #endif
 
 // -----------------------------------------------------------------------------

code/espurna/config/progmem.h

@@ -67,6 +67,9 @@ PROGMEM const char espurna_modules[] =
     #if INFLUXDB_SUPPORT
         "INFLUXDB "
     #endif
+    #if BLYNK_SUPPORT
+        "BLYNK "
+    #endif
     #if IR_SUPPORT
         "IR "
     #endif

code/espurna/espurna.ino

@@ -160,6 +160,9 @@ void setup() {
     #if INFLUXDB_SUPPORT
         idbSetup();
     #endif
+    #if BLYNK_SUPPORT
+        blynkSetup();
+    #endif
     #if THINGSPEAK_SUPPORT
         tspkSetup();
     #endif

code/espurna/relay.ino

@@ -184,6 +184,10 @@ void _relayProcess(bool mode) {
             domoticzSendRelay(id);
         #endif
 
+        #if BLYNK_SUPPORT
+            blynkSendRelay(id,target);
+        #endif
+
         #if INFLUXDB_SUPPORT
             relayInfluxDB(id);
         #endif

code/espurna/sensor.ino

@@ -995,6 +995,9 @@ void _sensorReport(unsigned char index, double value) {
     }
     #endif // DOMOTICZ_SUPPORT
 
+    #if BLYNK_SUPPORT
+      blynkSendMeasurement(index, buffer);
+    #endif //BLYNK_SUPPORT
 }
 
 // -----------------------------------------------------------------------------

code/html/custom.js

@@ -227,7 +227,7 @@ function addValue(data, name, value) {
         "schEnabled", "schSwitch","schAction","schType","schHour","schMinute","schWDs","schUTC",
         "relayBoot", "relayPulse", "relayTime",
         "mqttGroup", "mqttGroupInv", "relayOnDisc",
-        "dczRelayIdx", "dczMagnitude",
+        "dczRelayIdx", "dczMagnitude","blnkRelayVpin","blnkMagnitude",
         "tspkRelay", "tspkMagnitude",
         "ledMode",
         "adminPass",
@@ -1404,6 +1404,24 @@ function processData(data) {
             createMagnitudeList(value, "dczMagnitudes", "dczMagnitudeTemplate");
             return;
         }
+        <!-- endRemoveIf(!sensor)-->
+
+		// ---------------------------------------------------------------------
+        // Blynk
+        // ---------------------------------------------------------------------
+
+        // Blynk - Relays
+        if ("blnkRelays" === key) {
+            createRelayList(value, "blnkRelays", "blnkRelayTemplate");
+            return;
+        }
+
+        // Blynk - Magnitudes
+        <!-- removeIf(!sensor)-->
+        if ("blnkMagnitudes" === key) {
+            createMagnitudeList(value, "blnkMagnitudes", "blnkMagnitudeTemplate");
+            return;
+        }
         <!-- endRemoveIf(!sensor)-->
 
         // ---------------------------------------------------------------------