Diff: BlynkSimpleShieldEsp8266_HardSer.h

Revision:

3:4cd9171ba989

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/BlynkSimpleShieldEsp8266_HardSer.h	Thu Jun 16 08:08:30 2016 +0000
@@ -0,0 +1,210 @@
+/**
+ * @file       BlynkSimpleShieldEsp8266.h
+ * @author     Volodymyr Shymanskyy
+ * @license    This project is released under the MIT License (MIT)
+ * @copyright  Copyright (c) 2015 Volodymyr Shymanskyy
+ * @date       Jun 2015
+ * @brief
+ *
+ */
+
+#ifndef BlynkSimpleShieldEsp8266_h
+#define BlynkSimpleShieldEsp8266_h
+
+#ifdef ESP8266
+#error This code is not intended to run on the ESP8266 platform! Please check your Tools->Board setting.
+#endif
+
+#ifndef BLYNK_INFO_CONNECTION
+#define BLYNK_INFO_CONNECTION  "ESP8266"
+#endif
+
+extern Serial pc;
+//#define LOG_ESP8266
+#ifdef LOG_ESP8266
+#define ESP8266_LOG pc.printf
+#define LOG_ENTER ESP8266_LOG("Enter %s\r\n", __func__);
+#else
+#define ESP8266_LOG(...)
+#define LOG_ENTER
+#endif
+
+#define BLYNK_SEND_ATOMIC
+
+// TODO: Remove this hotfix
+#define BLYNK_NO_INFO
+
+//#include <BlynkApiArduino.h>
+#include <BlynkApiMbed.h>
+#include <Blynk/BlynkProtocol.h>
+#include <utility/BlynkFifo.h>
+#include <ESP8266_HardSer.h>
+
+class BlynkTransportShieldEsp8266
+{
+    static void onData(uint8_t mux_id, uint32_t len, void* ptr) {
+        ((BlynkTransportShieldEsp8266*)ptr)->onData(mux_id, len);
+    }
+
+    void onData(uint8_t mux_id, uint32_t len) {
+        //BLYNK_LOG2("Got ", len);
+        while (len) {
+            if (client->getUart()->readable()) {
+                uint8_t b = client->getUart()->getc();
+                if(!buffer.push(b)) {
+                    BLYNK_LOG1(BLYNK_F("Buffer overflow"));
+                    ESP8266_LOG(BLYNK_F("Buffer overflow"));
+                }
+                len--;
+            }
+        }
+    }
+
+public:
+    BlynkTransportShieldEsp8266()
+        : client(NULL)
+        , status(false)
+        , domain(NULL)
+        , port(0)
+    {}
+
+    void begin_domain(ESP8266* esp8266, const char* d,  uint16_t p) {
+        LOG_ENTER;
+        client = esp8266;
+        client->setOnData(onData, this);
+        domain = d;
+        port = p;
+    }
+
+    bool connect() {
+        ESP8266_LOG("connect(), domain = %s, port = %d\r\n", domain, port);
+        if (!domain || !port)
+            return false;
+        status = client->createTCP(domain, port);
+        return status;
+    }
+
+    void disconnect() {
+        #if 0
+        LOG_ENTER;
+        
+        status = false;
+        buffer.clear();
+        client->releaseTCP();
+        #endif
+    }
+
+    size_t read(void* buf, size_t len) {
+        uint32_t start = millis();
+        ESP8266_LOG("Waiting: %d, Occuied: %d\r\n", len, buffer.getOccupied());
+        //BLYNK_LOG4("Waiting: ", len, " Occuied: ", buffer.getOccupied());
+        while ((buffer.getOccupied() < len) && (millis() - start < 4500)) {
+            client->run();
+        }
+        return buffer.read((uint8_t*)buf, len);
+    }
+    size_t write(const void* buf, size_t len) {
+        ESP8266_LOG("Enter write, len = %d\r\n", len);
+        if (client->send((const uint8_t*)buf, len)) {
+            return len;
+        }
+        return 0;
+    }
+
+    bool connected() {
+        return status;
+    }
+
+    int available() {
+        LOG_ENTER;
+        client->run();
+        //BLYNK_LOG2("Still: ", buffer.getOccupied());
+        return buffer.getOccupied();
+    }
+
+private:
+    ESP8266* client;
+    bool status;
+    BlynkFifo<uint8_t,256> buffer;
+    const char* domain;
+    uint16_t    port;
+};
+
+class BlynkWifi
+    : public BlynkProtocol<BlynkTransportShieldEsp8266>
+{
+    typedef BlynkProtocol<BlynkTransportShieldEsp8266> Base;
+public:
+    BlynkWifi(BlynkTransportShieldEsp8266& transp)
+        : Base(transp)
+        , wifi(NULL)
+    {}
+
+    bool connectWiFi(const char* ssid, const char* pass) {
+        LOG_ENTER;
+        delay(500);
+        BLYNK_LOG2(BLYNK_F("Connecting to "), ssid);
+        ESP8266_LOG(BLYNK_F("Connecting to %s\r\n"), ssid);
+        /*if (!wifi->restart()) {
+            BLYNK_LOG1(BLYNK_F("Failed to restart"));
+            return false;
+        }*/
+        if (!wifi->setEcho(0)) {
+            BLYNK_LOG1(BLYNK_F("Failed to disable Echo"));
+            ESP8266_LOG(BLYNK_F("Failed to disable Echo"));
+            return false;
+        }
+        if (!wifi->setOprToStation()) {
+            BLYNK_LOG1(BLYNK_F("Failed to set STA mode"));
+            ESP8266_LOG(BLYNK_F("Failed to set STA mode"));
+            return false;
+        }
+        if (wifi->joinAP(ssid, pass)) {
+            BLYNK_LOG2(BLYNK_F("IP: "), wifi->getLocalIP().c_str());
+            ESP8266_LOG(BLYNK_F("IP: "), wifi->getLocalIP().c_str());
+        } else {
+            BLYNK_LOG1(BLYNK_F("Failed to connect WiFi"));
+            ESP8266_LOG(BLYNK_F("Failed to connect WiFi"));
+            return false;
+        }
+        if (!wifi->disableMUX()) {
+            BLYNK_LOG1(BLYNK_F("Failed to disable MUX"));
+            ESP8266_LOG(BLYNK_F("Failed to disable MUX"));
+        }
+        BLYNK_LOG1(BLYNK_F("Connected to WiFi"));
+        ESP8266_LOG(BLYNK_F("Connected to WiFi"));
+        return true;
+    }
+
+    void config(ESP8266&    esp8266,
+                const char* auth,
+                const char* domain = BLYNK_DEFAULT_DOMAIN,
+                uint16_t    port   = BLYNK_DEFAULT_PORT) {
+        LOG_ENTER;
+        Base::begin(auth);
+        wifi = &esp8266;
+        this->conn.begin_domain(wifi, domain, port);
+    }
+
+    void begin(const char* auth,
+               ESP8266&    esp8266,
+               const char* ssid,
+               const char* pass,
+               const char* domain = BLYNK_DEFAULT_DOMAIN,
+               uint16_t    port   = BLYNK_DEFAULT_PORT) {
+        LOG_ENTER;
+        config(esp8266, auth, domain, port);
+        connectWiFi(ssid, pass);
+    }
+
+private:
+    ESP8266* wifi;
+};
+
+static BlynkTransportShieldEsp8266 _blynkTransport;
+BlynkWifi Blynk(_blynkTransport);
+
+#include <BlynkWidgets.h>
+
+#endif
+