App not listening to database changes

[kkbughunter]

Just iam working on the smart lighting project I try to implement stream(Listen for firebase change for real-time update)
the device at some time the app/device is not listening to database when I reset it listening
some time first time listening properly but not after clicking reset button in ESP32.

#include <Arduino.h>
#include <WiFi.h>
#include <WiFiClientSecure.h>

#include <FirebaseClient.h>

#define DEVICE_ID "IET-a-7021"
#define WIFI_SSID "loop"
#define WIFI_PASSWORD "cyber@123"

#include <configs/FirebaseConfig.h>  // this file have all required firebase API and URLs 

void initasyncCB(AsyncResult &aResult);
void WriterAsyncCallBack(AsyncResult &aResult);
void ListenerCallback(AsyncResult &aResult);

// Firebase Auth
UserAuth user_auth(API_KEY, USER_EMAIL, USER_PASSWORD, 3000);

// Network Config
DefaultNetwork network;
WiFiClientSecure ssl_client1, ssl_client2;
AsyncClientClass aClient1(ssl_client1, getNetwork(network)), aClient2(ssl_client2, getNetwork(network));

FirebaseApp app;
RealtimeDatabase Database;
DatabaseOptions options;
unsigned long tmo = 0;

void setup()
{

    Serial.begin(115200);

    WiFi.begin(WIFI_SSID, WIFI_PASSWORD);

    Serial.print("Connecting to Wi-Fi");
    unsigned long ms = millis();
    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);
    Serial.println("Initializing app...");
    ssl_client1.setInsecure();
    ssl_client2.setInsecure();

    // Initialize the FirebaseApp or auth task handler.
    // To deinitialize, use deinitializeApp(app).
    initializeApp(aClient1, app, getAuth(user_auth), initasyncCB, "Client-1-auth-Task");

    // Binding the FirebaseApp for authentication handler.
    // To unbind, use Database.resetApp();
    app.getApp<RealtimeDatabase>(Database);
    Database.url(DATABASE_URL);

    // This is optional to allow specific events filtering.
    Database.setSSEFilters("get,put,patch,keep-alive,cancel,auth_revoked");

    delay(100);

    options.readTimeout = 5000;
    Database.get(aClient2, "/devices/IET-a-7021", ListenerCallback, true, "Listener-Task");
    delay(100);
}

void loop()
{
    app.loop();
    Database.loop();

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

        JsonWriter writer;

        object_t json, obj1, obj2;

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

        Database.set<object_t>(aClient1, "/test/stream/number", json, WriterAsyncCallBack, "Writer-Task");
    }
}

void initasyncCB(AsyncResult &aResult)
{
    if (aResult.isEvent())
        Firebase.printf("-> Event task: %s, msg: %s, code: %d\n", aResult.uid().c_str(), aResult.appEvent().message().c_str(), aResult.appEvent().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())
        Firebase.printf("-> task: %s, payload: %s\n", aResult.uid().c_str(), aResult.c_str());
}

void WriterAsyncCallBack(AsyncResult &aResult)
{

    if (aResult.isEvent())
        Firebase.printf("--> Event task: %s, msg: %s, code: %d\n", aResult.uid().c_str(), aResult.appEvent().message().c_str(), aResult.appEvent().code());
    if (aResult.available())
        Firebase.printf("--> task: %s, payload: %s\n", aResult.uid().c_str(), aResult.c_str());
}

void ListenerCallback(AsyncResult &aResult)
{
    if (aResult.available())
        Firebase.printf("---> payload: %s\n", aResult.c_str());
}

output: first time not listening and listening after reset button is pressed CASE

Another case is
in the boot first time device listen to firebase on the next reset device is not listening to firebase

need help

[mobizt]

You never check the debug/error events in your callback, then you will not know what is going on.

No need to separate the callbacks for async tasks because it increases your code size.

[kkbughunter]

in the document where i can find the function details...

[mobizt]

You should spend the time to read it instead.