Firebase Stream Compilation error #236

chemo1001 · 2022-01-22T00:45:26Z

chemo1001
Jan 22, 2022

Hello!!
Thank you so much about your library. It has been very useful to me.

I have been using it to program an ESP32 using Arduino IDE in order to set and get some data in Firebase RTDB. Thay way it works great. :)

However, my issue comes when I try using "Stream" functions in order to subscribe to data changes at specific node in Firebase RTDB with a callback function. Arduino IDE can't compile and pops me the following errors

It looks like the methods where not defined in the class or i am not directing the methods correctly. the library is good installed because as I mentioned before it works for setInt and getInt methods.

I took as basis one of the examples codes and i called Firebase.SetStreamCallback and Firebase.beginStream functions. I also declared the void streamCallback(StreamData data) function at the end.

I appreciate a lot your support.

The general code is:

/**

Created by K. Suwatchai (Mobizt)
Email: [email protected]
Github: https://github.com/mobizt/Firebase-ESP-Client
Copyright (c) 2022 mobizt

*/

/** This example will show how to authenticate as a user with Email and password.
*

You need to enable Email/Password provider.
In Firebase console, select Authentication, select Sign-in method tab,
under the Sign-in providers list, enable Email/Password provider.
From this example, the user will be granted to access the specific location that matches
the user uid.
This example will modify the database rules to set up the security rule which need to
guard the unauthorized access with the user Email.
*/

#if defined(ESP32)
#include <WiFi.h>
#elif defined(ESP8266)
#include <ESP8266WiFi.h>
#endif

#include <Firebase_ESP_Client.h>

//Provide the token generation process info.
#include <addons/TokenHelper.h>

//Provide the RTDB payload printing info and other helper functions.
#include <addons/RTDBHelper.h>

/* 1. Define the WiFi credentials */
#define WIFI_SSID "WIFI"
#define WIFI_PASSWORD "PASS"

/** 2. Define the API key
*

The API key (required) can be obtained since you created the project and set up
the Authentication in Firebase console. Then you will get the API key from
Firebase project Web API key in Project settings, on General tab should show the
Web API Key.
You may need to enable the Identity provider at https://console.cloud.google.com/customer-identity/providers
Select your project, click at ENABLE IDENTITY PLATFORM button.
The API key also available by click at the link APPLICATION SETUP DETAILS.

/
#define API_KEY "********************************"

/* 3. Define the user Email and password that already registerd or added in your project /
#define USER_EMAIL "******@gmail.com"
#define USER_PASSWORD "58555555"

/* 4. If work with RTDB, define the RTDB URL /
#define DATABASE_URL "**************************" //.firebaseio.com or ..firebasedatabase.app

/** 5. Define the database secret (optional)

*/
#define DATABASE_SECRET "DATABASE_SECRET"

/* 6. Define the Firebase Data object */
FirebaseData fbdo;

/* 7. Define the FirebaseAuth data for authentication data */
FirebaseAuth auth;

/* 8. Define the FirebaseConfig data for config data */
FirebaseConfig config;

unsigned long dataMillis = 0;
int count = 0;

void setup()
{

Serial.begin(115200);

WiFi.begin(WIFI_SSID, WIFI_PASSWORD);
Serial.print("Connecting to Wi-Fi");
while (WiFi.status() != WL_CONNECTED)
{
    Serial.print(".");
    delay(300);
}
Serial.println();
Serial.print("Connected with IP: ");
Serial.println(WiFi.localIP());
Serial.println();

Serial.printf("Firebase Client v%s\n\n", FIREBASE_CLIENT_VERSION);

/* Assign the api key (required) */
config.api_key = API_KEY;

/* Assign the user sign in credentials */
auth.user.email = USER_EMAIL;
auth.user.password = USER_PASSWORD;

/* Assign the RTDB URL */
config.database_url = DATABASE_URL;

Firebase.reconnectWiFi(true);
fbdo.setResponseSize(4096);

String base_path = "/UsersData/";

/* Assign the callback function for the long running token generation task */
config.token_status_callback = tokenStatusCallback; //see addons/TokenHelper.h

/** Assign the maximum retry of token generation */
config.max_token_generation_retry = 5;

/* Initialize the library with the Firebase authen and config */
Firebase.begin(&config, &auth);


Firebase.setStreamCallback(fbdo, streamCallback, streamTimeoutCallback);

  if (!Firebase.beginStream(fbdo,"/test/data"))

{
//Could not begin stream connection, then print out the error detail
Serial.println(fbdo.errorReason());
}

}

void loop()
{
//Firebase.ready works for authentication management and should be called repeatedly in the loop.

if (millis() - dataMillis > 5000 && Firebase.ready())
{
    dataMillis = millis();
    String path = "/UsersData/";
    path += auth.token.uid.c_str(); //<- user uid of current user that sign in with Emal/Password
    path += "/test/int";
    Serial.printf("Set int... %s\n", Firebase.RTDB.setInt(&fbdo, path, count++) ? "ok" : fbdo.errorReason().c_str());
    
}

}

void streamCallback(StreamData data)
{

//Print out all information

Serial.println("Stream Data...");
Serial.println(data.streamPath());
Serial.println(data.dataPath());
Serial.println(data.dataType());

//Print out the value
//Stream data can be many types which can be determined from function dataType

if (data.dataTypeEnum() == fb_esp_rtdb_data_type_integer)
Serial.println(data.to());
else if (data.dataTypeEnum() == fb_esp_rtdb_data_type_float)
Serial.println(data.to(), 5);
else if (data.dataTypeEnum() == fb_esp_rtdb_data_type_double)
printf("%.9lf\n", data.to());
else if (data.dataTypeEnum() == fb_esp_rtdb_data_type_boolean)
Serial.println(data.to()? "true" : "false");
else if (data.dataTypeEnum() == fb_esp_rtdb_data_type_string)
Serial.println(data.to());
else if (data.dataTypeEnum() == fb_esp_rtdb_data_type_json)
{
FirebaseJson *json = data.to<FirebaseJson *>();
Serial.println(json->raw());
}
else if (data.dataTypeEnum() == fb_esp_rtdb_data_type_array)
{
FirebaseJsonArray *arr = data.to<FirebaseJsonArray *>();
Serial.println(arr->raw());
}

}

//Global function that notifies when stream connection lost
//The library will resume the stream connection automatically
void streamTimeoutCallback(bool timeout)
{
if(timeout){
//Stream timeout occurred
Serial.println("Stream timeout, resume streaming...");
}
}