Stream not working when using ServiceAuth since version 2.0.0

[Maxisvegeta]

Hello,
I am experiencing an issue with the stream not working when using ServiceAuth since version 2.0.0.
(I am using ServiceAuth because I am implementing FCM, also).
I used your example sketch of Stream with ServiceAuth, as shown below:

#include <Arduino.h>
#include <FirebaseClient.h>
#include "ExampleFunctions.h" // Provides the functions used in the examples.

#define WIFI_SSID ""
#define WIFI_PASSWORD ""

#define DATABASE_URL ""

#define FIREBASE_PROJECT_ID ""
#define FIREBASE_CLIENT_EMAIL ""
const char PRIVATE_KEY[] PROGMEM = "";

void processData(AsyncResult &aResult);

SSL_CLIENT ssl_client, stream_ssl_client;

using AsyncClient = AsyncClientClass;
AsyncClient aClient(ssl_client), streamClient(stream_ssl_client);

ServiceAuth sa_auth(FIREBASE_CLIENT_EMAIL, FIREBASE_PROJECT_ID, PRIVATE_KEY, 3000 /* expire period in seconds (<= 3600) */);

FirebaseApp app;
RealtimeDatabase Database;
AsyncResult streamResult;

unsigned long ms = 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();

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

set_ssl_client_insecure_and_buffer(ssl_client);
set_ssl_client_insecure_and_buffer(stream_ssl_client);

Serial.println("Initializing app...");
//initializeApp(aClient, app, getAuth(user_auth), auth_debug_print, "🔐 authTaskUser");
 app.setTime(get_ntp_time());
initializeApp(aClient, app, getAuth(sa_auth), auth_debug_print, "🔐 authTask");

app.getApp<RealtimeDatabase>(Database);

Database.url(DATABASE_URL);

streamClient.setSSEFilters("get,put,patch,keep-alive,cancel,auth_revoked");

Database.get(streamClient, "/examples/Stream/data", processData, true /* SSE mode (HTTP Streaming) */, "streamTask");

}

void loop()
{
// To maintain the authentication and async tasks
app.loop();

if (app.ready() && millis() - ms > 20000)
{
    ms = millis();

    JsonWriter writer;

    object_t json, obj1, obj2;

    writer.create(obj1, "ms", ms);
    writer.create(obj2, "rand", random(10000, 30000));
    writer.join(json, 2, obj1, obj2);

    Database.set<object_t>(aClient, "/examples/Stream/data", json, processData, "setTask");
}

// For async call with AsyncResult.
//processData(streamResult);

}

void processData(AsyncResult &aResult)
{
// Exits when no result available when calling from the loop.
if (!aResult.isResult())
return;

if (aResult.isEvent())
{
    Firebase.printf("Event task: %s, msg: %s, code: %d\n", aResult.uid().c_str(), aResult.eventLog().message().c_str(), aResult.eventLog().code());
}

if (aResult.isDebug())
{
    Firebase.printf("Debug task: %s, msg: %s\n", aResult.uid().c_str(), aResult.debug().c_str());
}

if (aResult.isError())
{
    Firebase.printf("Error task: %s, msg: %s, code: %d\n", aResult.uid().c_str(), aResult.error().message().c_str(), aResult.error().code());
}

if (aResult.available())
{
    RealtimeDatabaseResult &RTDB = aResult.to<RealtimeDatabaseResult>();
    if (RTDB.isStream())
    {
        Serial.println("----------------------------");
        Firebase.printf("task: %s\n", aResult.uid().c_str());
        Firebase.printf("event: %s\n", RTDB.event().c_str());
        Firebase.printf("path: %s\n", RTDB.dataPath().c_str());
        Firebase.printf("data: %s\n", RTDB.to<const char *>());
        Firebase.printf("type: %d\n", RTDB.type());

        // The stream event from RealtimeDatabaseResult can be converted to the values as following.
        bool v1 = RTDB.to<bool>();
        int v2 = RTDB.to<int>();
        float v3 = RTDB.to<float>();
        double v4 = RTDB.to<double>();
        String v5 = RTDB.to<String>();
    }
    else
    {
        Serial.println("----------------------------");
        Firebase.printf("task: %s, payload: %s\n", aResult.uid().c_str(), aResult.c_str());
    }

#if defined(ESP32) || defined(ESP8266)
Firebase.printf("Free Heap: %d\n", ESP.getFreeHeap());
#elif defined(ARDUINO_RASPBERRY_PI_PICO_W)
Firebase.printf("Free Heap: %d\n", rp2040.getFreeHeap());
#endif
}
}

And I get the following results:

Connecting to Wi-Fi.........
Connected with IP: 192.168.18.80

Firebase Client v2.0.0
Initializing app...
Getting time from NTP server... failed, retry... success
Event task: 🔐 authTask, msg: initializing, code: 1
Event task: 🔐 authTask, msg: token signing, code: 6
Event task: 🔐 authTask, msg: authenticating, code: 7
Debug task: 🔐 authTask, msg: Connecting to server...
Event task: 🔐 authTask, msg: auth request sent, code: 8
Event task: 🔐 authTask, msg: auth response received, code: 9
Debug task: 🔐 authTask, msg: Terminating the server connection...
Event task: 🔐 authTask, msg: ready, code: 10
Debug task: streamTask, msg: Connecting to server...
Debug task: setTask, msg: Connecting to server...

task: setTask, payload: {"ms":20001,"rand":26155}
Free Heap: 91372

task: setTask, payload: {"ms":40002,"rand":19450}
Free Heap: 91456

task: setTask, payload: {"ms":60003,"rand":19753}
Free Heap: 91096

What am I doing wrong? Thank you very much in advance!

[mobizt]

If you noticed that why the library version changed its major version from 1 to 2, it should be something totally changes.

The big reliability improvement in the core which reduces the code complexity in v2.0.0.

The library examples are changed too.

Please follow the new examples.
https://github.com/mobizt/FirebaseClient/blob/main/examples/App/AppInitialization/ServiceAuth/ServiceAuth.ino

[Maxisvegeta]

Thank you very much for your response; I really appreciate it.
The example I’m using to demonstrate the problem is the latest example published (version 2.0.0), which is not part of my code.
The only change I made was replacing user_auth with sa_auth, following the latest example in ServiceAuth.ino. As mentioned, the authentication works perfectly, the set functions work, but the stream remains stuck at:

Debug task: streamTask, msg: Connecting to server...

full log:
Connecting to Wi-Fi.........
Connected with IP: 192.168.18.80
Firebase Client v2.0.0
Initializing app...
Getting time from NTP server... failed, retry... success
Event task: 🔐 authTask, msg: initializing, code: 1
Event task: 🔐 authTask, msg: token signing, code: 6
Event task: 🔐 authTask, msg: authenticating, code: 7
Debug task: 🔐 authTask, msg: Connecting to server...
Event task: 🔐 authTask, msg: auth request sent, code: 8
Event task: 🔐 authTask, msg: auth response received, code: 9
Debug task: 🔐 authTask, msg: Terminating the server connection...
Event task: 🔐 authTask, msg: ready, code: 10
Debug task: streamTask, msg: Connecting to server...
Debug task: setTask, msg: Connecting to server...
task: setTask, payload: {"ms":20001,"rand":26155}
Free Heap: 91372
task: setTask, payload: {"ms":40002,"rand":19450}
Free Heap: 91456

[mobizt]

Ok I will check it and update the result.

[mobizt]

Now you can update to v2.0.1 that fixed this issue.