Stop stream when we set value to avoid memory issues. Added example.

Author: ed7coyne

examples/FirebaseTranscriber_ESP8266/FirebaseTranscriber_ESP8266.ino

@@ -0,0 +1,70 @@
+//
+// Copyright 2016 Google Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+
+// FirebaseDemo_ESP8266 is a sample that binds several pins to paths in
+// firebase using the transcriber object.
+
+#include <ESP8266WiFi.h>
+#include <Transcriber.h>
+
+// Set these to run example.
+#define FIREBASE_HOST ""
+#define FIREBASE_PATH "/fthing"
+#define FIREBASE_AUTH ""
+#define WIFI_SSID ""
+#define WIFI_PASSWORD ""
+
+#define DIGITAL_IN D1
+#define DIGITAL_OUT BUILTIN_LED
+#define ANALOG_IN A0
+#define ANALOG_OUT D8
+
+thing::Config config = {
+  FIREBASE_HOST,
+  FIREBASE_AUTH,
+  FIREBASE_PATH,
+  WIFI_SSID,
+  WIFI_PASSWORD,
+  DIGITAL_OUT,
+  DIGITAL_IN,
+  ANALOG_OUT,
+  ANALOG_IN};
+
+void setup() {
+  Serial.begin(9600);
+
+  // connect to wifi.
+  WiFi.begin(WIFI_SSID, WIFI_PASSWORD);
+  Serial.print("connecting");
+  while (WiFi.status() != WL_CONNECTED) {
+    Serial.print(".");
+    delay(500);
+  }
+  Serial.println();
+  Serial.print("connected: ");
+  Serial.println(WiFi.localIP());
+
+  pinMode(DIGITAL_IN, INPUT);
+  pinMode(DIGITAL_OUT, OUTPUT);
+  pinMode(ANALOG_IN, INPUT);
+  pinMode(ANALOG_OUT, OUTPUT);
+}
+
+void loop() {
+  static thing::Transcriber tscribe(config);
+  tscribe.Loop();
+  delay(200);
+}

src/Firebase.cpp

@@ -133,6 +133,12 @@ FirebaseCall::FirebaseCall(const std::string& host, const std::string& auth,
   }
 }
 
+FirebaseCall::~FirebaseCall() {
+  if (http_) {
+    http_->end();
+  }
+}
+
 const JsonObject& FirebaseCall::json() {
   //TODO(edcoyne): This is not efficient, we should do something smarter with
   //the buffers.
@@ -157,6 +163,7 @@ FirebaseSet::FirebaseSet(const std::string& host, const std::string& auth,
     json_ = response();
   }
 }
+
 // FirebasePush
 FirebasePush::FirebasePush(const std::string& host, const std::string& auth,
                            const std::string& path, const std::string& value,

src/Firebase.h

@@ -79,7 +79,7 @@ class FirebaseCall {
                const char* method, const std::string& path,
                const std::string& data = "",
                FirebaseHttpClient* http = NULL);
-  virtual ~FirebaseCall() {}
+  virtual ~FirebaseCall();
 
   virtual const FirebaseError& error() const {
     return error_;

src/thing/Transcriber.cpp

@@ -19,13 +19,20 @@ void Transcriber::UpdateConfig(const Config& config) {
 }
 
 void Transcriber::Init(const Config& config) {
+  path_ = config.path;
   pin_digital_out_ = config.pin_digital_out;
   pin_digital_in_ = config.pin_digital_in;
   pin_analog_out_ = config.pin_analog_out;
   pin_analog_in_ = config.pin_analog_in;
 
   fbase_.reset(new Firebase(config.host, config.auth));
-  stream_ = fbase_->streamPtr(config.path);
+  stream_ = fbase_->streamPtr(path_);
+}
+
+void Transcriber::SetValue(const std::string& path, const std::string& value) {
+  stream_.reset(nullptr);
+  fbase_->set(path, value);
+  stream_ = fbase_->streamPtr(path_);
 }
 
 void Transcriber::Loop() {
@@ -47,15 +54,13 @@ void Transcriber::Loop() {
   // Send values to cloud
   int digital_in = digitalRead(pin_digital_in_);
   if (digital_in != digital_in_) {
-Serial.println(String(digital_in).c_str());
-    FirebaseSet set = fbase_->set(kSubPathDigitalIn, String(digital_in).c_str());
+    SetValue(kSubPathDigitalIn, String(digital_in).c_str());
     digital_in_ = digital_in;
   }
 
   float analog_in = analogRead(pin_analog_in_);
   if (analog_in != analog_in_) {
-Serial.println(String(analog_in).c_str());
-    FirebaseSet set = fbase_->set(kSubPathAnalogIn, String(analog_in).c_str());
+    SetValue(kSubPathAnalogIn, String(analog_in).c_str());
     analog_in_ = analog_in;
   }
 }

src/thing/Transcriber.h

@@ -40,6 +40,11 @@ class Transcriber {
   void ProcessInitialUpdate(const FirebaseObject& update);
   void ProcessIncrementalUpdate(const FirebaseObject& update);
 
+  // Wrapper around Firebase::Set that stops the stream before setting,
+  // Currently we have memory issues if we try to have two simultanious
+  // SSL connections.
+  void SetValue(const std::string& path, const std::string& value);
+
   std::unique_ptr<Firebase> fbase_;
   std::unique_ptr<FirebaseStream> stream_;
 
@@ -50,6 +55,8 @@ class Transcriber {
   int pin_digital_in_;
   int pin_analog_out_;
   int pin_analog_in_;
+
+  std::string path_;
 };
 
 };  // thing