Could I set key and listen a stream simultaneously?

[hawkhsieh]

I combine the FirebaseDemo and FirebaseStream to set a key and watch a key simultaneously.
The key is set successfully.
But it doesnt show "event:" on UART about stream function.
revesion is 854bb0c
source code is below:

//
// Copyright 2015 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 demo the different functions
// of the FirebaseArduino API.

#include <ESP8266WiFi.h>
#include <FirebaseArduino.h>

// Set these to run example.
#define FIREBASE_HOST "api-project.firebaseio.com" 
#define FIREBASE_AUTH "nZPE6hBzwDXfCUYteuGIQ6dRJH2ac1Ldff7cP"
#define WIFI_SSID "NETGEAR29"
#define WIFI_PASSWORD "093548"

void setup() {
  Serial.begin(115200);

  // 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());

  Firebase.begin(FIREBASE_HOST, FIREBASE_AUTH);
  Firebase.stream("/watch/device1");  

     if (Firebase.success()) {
          Serial.println("streaming ok");
     }
}

int n = 0;

void loop() {
  // set value
  Firebase.setFloat("number", 42.0);
  // handle error
  if (Firebase.failed()) {
      Serial.print("setting /number failed:42");
      Serial.println(Firebase.error());  
      delay(1000);
      return;
  }
  delay(3000);

  // update value
  Firebase.setFloat("number", 43.0);
  // handle error
  if (Firebase.failed()) {
      Serial.print("setting /number failed:43");
      Serial.println(Firebase.error());  
      return;
  }
  delay(3000);

  // get value 
  Serial.print("number: ");
  Serial.println(Firebase.getFloat("number"));
  delay(1000);

  // remove value
  Firebase.remove("number");
  delay(1000);

  // set string value
  Firebase.setString("message", "hello world");
  // handle error
  if (Firebase.failed()) {
      Serial.print("setting /message failed:");
      Serial.println(Firebase.error());  
      return;
  }
  delay(1000);

  // set bool value
  Firebase.setBool("truth", false);
  // handle error
  if (Firebase.failed()) {
      Serial.print("setting /truth failed:");
      Serial.println(Firebase.error());  
      return;
  }
  delay(1000);

  // append a new value to /logs
  String name = Firebase.pushInt("logs", n++);
  // handle error
  if (Firebase.failed()) {
      Serial.print("pushing /logs failed:");
      Serial.println(Firebase.error());  
      return;
  }
  Serial.print("pushed: /logs/");
  Serial.println(name);
  delay(1000);


    if (Firebase.available()) {
     FirebaseObject event = Firebase.readEvent();
     String eventType = event.getString("type");
     eventType.toLowerCase();

     Serial.print("event: ");
     Serial.println(eventType);
     if (eventType == "put") {
       Serial.print("data: ");
       Serial.println(event.getString("data"));
       String path = event.getString("path");
       String data = event.getString("data");
     }
  }  
}

[Twoaster]

Hi hawkhsieh,
I had an issue like yours while using Firebase and the ESP8266 shield. To solve it, I had to declare 2 variables of the Firebase type like this:

Firebase.begin(FIREBASE_HOST, FIREBASE_AUTH); FirebaseStream.begin(FIREBASE_HOST, FIREBASE_AUTH); FirebaseStream.stream(node);

Than you need to check the variable if (FirebaseStream.available()) { to see if there is any change on the database and use the variable Firebase.set("node","data"); to set and get data

Hope it can help!

I am having similar issues. Specifically, a crash if I try to write anything to a FirebaseArduino that I am streaming from. Are you using the "Firebase" class (from Firebase.h/cpp) instead of FirebaseArduino? If so, could you share how you set this up? Thanks.

[tabvn]

The issue still existing i had is we could not do use both stream and get or push, or put .

put,post,get durring set streaming it will be get crash. (ESP8266)/ Seem Firebase had implements of esp8266httpclient but they still fixing this issue.

[proppy]

I was able to stream using two different FirebaseArduino instance, like described in #193 (comment)

FirebaseArduino FirebaseStream

It would be nice to have something simpler like described in #159

[RaemondBW]

I think the issue this is referring to, as mentioned in a couple of other issues, is the inability to push/get while maintaining an open stream. Not having two simultaneous streams. For this case, I have tried having two FirebaseArduino instances and have yet to get it to work.

[proppy]

@RaemondBW we did manage to get it work with two FirebaseArduino instance in the past, see #48 (comment)

I'd be very interested to see if that snippet crash for people noticing that behavior, gather proper debugging and version information and try to reproduce the issue.

[RaemondBW]

@proppy Here is an example sketch that exhibits the issue:

#include <FirebaseArduino.h>
#include <ESP8266WiFi.h>

FirebaseArduino firebaseRW;

//Placeholder values
#define FIREBASE_HOST "url.firebaseio.com"
#define FIREBASE_AUTH "auth token"
const String URL = "/value";


void setup() {
  Serial.begin(115200);
  Serial.println("Connecting to WiFi");
  WiFi.mode(WIFI_STA);
  WiFi.begin();
  while (WiFi.status() != WL_CONNECTED) {
    delay(10);
  }
  if (WiFi.status() == WL_CONNECTED) {
    Serial.println("WiFi Connected");
    Firebase.begin(FIREBASE_HOST, FIREBASE_AUTH);
    Firebase.stream(URL);
    firebaseRW.begin(FIREBASE_HOST, FIREBASE_AUTH);
  }
}

void loop() {
  if (Firebase.available()) {
    FirebaseObject event = Firebase.readEvent();
    String eventType = event.getString("type");
    if (eventType == "put") {
      Serial.print("value from stream: ");
      Serial.println(event.getInt("data"));
    }
  }

  delay(1000);
  firebaseRW.setInt(URL, 1);
  delay(100);
}

And the resulting error:

[HTTP-Client][begin] host: url.firebaseio.com port: 443 url: /value.json?auth=FIREBASE_AUTH httpsFingerprint: 7A 54 06 9B DC 7A 25 B3 86 8D 66 53 48 2C 0B 96 42 C7 B3 0A
[HTTP-Client] connected to url.firebaseio.com:443
[HTTP-Client][handleHeaderResponse] RX: 'HTTP/1.1 307 Temporary Redirect'
[HTTP-Client][handleHeaderResponse] RX: 'Content-Length: 0'
[HTTP-Client][handleHeaderResponse] RX: 'Content-Type: text/plain'
[HTTP-Client][handleHeaderResponse] RX: 'Location: https://s-usc1c-nss-109.firebaseio.com/value.json?auth=FIREBASE_AUTH&ns=url&sse=true'
[HTTP-Client][handleHeaderResponse] RX: 'Access-Control-Allow-Origin: *'
[HTTP-Client][handleHeaderResponse] RX: 'Strict-Transport-Security: max-age=31556926; includeSubDomains; preload'
[HTTP-Client][handleHeaderResponse] RX: ''
[HTTP-Client][handleHeaderResponse] code: 307
[HTTP-Client][end] tcp stop
[HTTP-Client][begin] url: https://s-usc1c-nss-109.firebaseio.com/value.json?auth=FIREBASE_AUTH&ns=url&sse=true
[HTTP-Client][begin] host: s-usc1c-nss-109.firebaseio.com port: 443 url: /value.json?auth=FIREBASE_AUTH&ns=url&sse=true
[HTTP-Client][begin] httpsFingerprint: 7A 54 06 9B DC 7A 25 B3 86 8D 66 53 48 2C 0B 96 42 C7 B3 0A
[HTTP-Client] connected to s-usc1c-nss-109.firebaseio.com:443
[HTTP-Client][handleHeaderResponse] RX: 'HTTP/1.1 200 OK'
[HTTP-Client][handleHeaderResponse] RX: 'Server: nginx'
[HTTP-Client][handleHeaderResponse] RX: 'Date: Mon, 26 Sep 2016 18:10:05 GMT'
[HTTP-Client][handleHeaderResponse] RX: 'Content-Type: text/event-stream'
[HTTP-Client][handleHeaderResponse] RX: 'Connection: close'
[HTTP-Client][handleHeaderResponse] RX: 'Cache-Control: no-cache'
[HTTP-Client][handleHeaderResponse] RX: 'Access-Control-Allow-Origin: *'
[HTTP-Client][handleHeaderResponse] RX: 'Strict-Transport-Security: max-age=31556926; includeSubDomains; preload'
[HTTP-Client][handleHeaderResponse] RX: ''
[HTTP-Client][handleHeaderResponse] code: 200

value from stream: 0

[HTTP-Client][begin] host: url.firebaseio.com port: 443 url: /value.json?auth=FIREBASE_AUTH httpsFingerprint: 7A 54 06 9B DC 7A 25 B3 86 8D 66 53 48 2C 0B 96 42 C7 B3 0A
please start sntp first !
State: sending Client Hello (1)
State:  receiving Server Hello (2)
State:   receiving Certificate (11)
Fatal exception 29(StoreProhibitedCause):
epc1=0x4000dfd9, epc2=0x00000000, epc3=0x00000000, excvaddr=0x00000000, depc=0x00000000

Exception (29):
epc1=0x4000dfd9 epc2=0x00000000 epc3=0x00000000 excvaddr=0x00000000 depc=0x00000000

ctx: cont
sp: 3fff10f0 end: 3fff1c20 offset: 01a0

the stream starts successfully. When I try to write, the issue comes up.

[RaemondBW]

I just tested the code at Comment #48 and it results in the same crash.

[proppy]

@RaemondBW can you confirm which version of the arduino core you're using?

[RaemondBW]

@proppy I tested with arduino 1.6.12 and the latest release of FirebaseArduino

[proppy]

@RaemondBW which version of the Arduino ESP core https://github.com/esp8266/Arduino?

[RaemondBW]

@proppy sorry, ESP Core version 2.3.0