unauthenticate, code: -106 , Code blocking

[ehabtawfikelbwab]

I did follow all docs and everything is great like the docs

and i got code blocked after loop did run for just one time and last thing i get is the 0 from Serial.println(app.ready()); and stay for ever like that

debug:

Connected to WiFi
Debug task: streamTask, msg: Terminating the server connection...
Error task: streamTask, msg: unauthenticate, code: -106
Firebase Initilized!
Event task: authTask, msg: authenticating, code: 7
Debug task: authTask, msg: Connecting to server...
Event task: authTask, msg: auth request sent, code: 8
0

Code:

#define DATABASE_URL "tawlink-72503-default-rtdb.firebaseio.com"

// The API key can be obtained from Firebase console > Project Overview > Project settings.
#define API_KEY "the Web API Key on project settings"

// User Email and password that already registerd or added in your project.
#define USER_EMAIL "the email i did add on Authentication (authentication/users) "
#define USER_PASSWORD "the password i did add on Authentication (authentication/users)"

NetworkClient basic_client1, basic_client2;
ESP_SSLClient ssl_client1, ssl_client2;

DefaultNetwork network;
AsyncClientClass aclient_1(ssl_client1, getNetwork(network)), aclient_2(ssl_client2, getNetwork(network));

FirebaseApp app;
RealtimeDatabase Database;


AsyncResult result;
UserAuth user_auth(API_KEY, USER_EMAIL, USER_PASSWORD);

void asyncCB(AsyncResult& result);
void HandleFirebaseRequests(AsyncResult& result);

bool firebaseInitilized = false;


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

  InitilizeRTC();
  InitilizeLittleFS();
  InitializeWifi();
  InitilizeFirebase();
  InitilizeMqttServer();
}

void loop() {
  delay(5);
  StableConnectionLoop(); //check wifi is connected 
  mqtt.loop();

  HandleFirebaseLoop();

  Serial.println(app.ready());
}


void InitilizeFirebase() {
  if (CanUseFirebase()) {
    IPAddress gateway = WiFi.gatewayIP();
    String gatewayString = gateway.toString();

    basic_client1.connect(gatewayString.c_str(), 80); 
    basic_client2.connect(gatewayString.c_str(), 80);

    ssl_client1.setClient(&basic_client1, true);
    ssl_client2.setClient(&basic_client2, true);

    ssl_client1.setInsecure();
    ssl_client2.setInsecure();

    ssl_client1.setBufferSizes(2048, 1024);
    ssl_client2.setBufferSizes(2048, 1024);

    ssl_client1.setDebugLevel(1);
    ssl_client2.setDebugLevel(1);

    ssl_client1.setSessionTimeout(150);
    ssl_client2.setSessionTimeout(150);

    // Initialize the authentication handler.
    initializeApp(aclient_2, app, getAuth(user_auth), asyncCB, "authTask");

    // Binding the authentication handler with your Database class object.
    app.getApp<RealtimeDatabase>(Database);

    // Set your database URL
    Database.url(DATABASE_URL);

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

    Database.get(aclient_1, "users/" + FirebaseClient_Sub + "/devices", asyncCB, true /* SSE mode (HTTP Streaming) */, "streamTask");
    firebaseInitilized = true;

    Serial.println("Firebase Initilized!");
  } else {
    Serial.println("Error: Firebase not Initilized");
  }
}


void asyncCB(AsyncResult& result) {
  // Implementation of asyncCB here

  HandleFirebaseRequests(result);
}



void HandleFirebaseRequests(AsyncResult& result) {
  if (result.isEvent()) {
    Firebase.printf("Event task: %s, msg: %s, code: %d\n", result.uid().c_str(), result.appEvent().message().c_str(), result.appEvent().code());
  }

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

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

  if (result.available()) {
    RealtimeDatabaseResult& RTDB = result.to<RealtimeDatabaseResult>();
    if (RTDB.isStream()) {
      String v5 = RTDB.to<String>();
      Serial.println(v5);
    }
  }
}

[mobizt]

Please read the documentation thoroughly and follow the examples recommendation comment.

FirebaseClient/examples/RealtimeDatabase/Async/Callback/Stream/Stream.ino

Lines 138 to 145 in ec93413

	void loop()
	{
	// The async task handler should run inside the main loop
	// without blocking delay or bypassing with millis code blocks.
	app.loop();
	Database.loop();

I don't have time to fix your usage error.

[ehabtawfikelbwab]

I have inside: HandleFirebaseLoop();

     app.loop(); 
  
     Database.loop(); 

this for passing rotuer firewall by calling the router ip to open connections
i got failed to to connect to server -1 if i did not use it

  basic_client1.connect(gatewayString.c_str(), 80); 
 basic_client2.connect(gatewayString.c_str(), 80);

even without ture the same result

  ssl_client1.setClient(&basic_client1, true);
 ssl_client2.setClient(&basic_client2, true);

[mobizt]

You don't understand what you are doing.

If you don't know how ESP_SSLClient works, don't use it. If you want to use it you should read its documentation here and test with all examples.

Otherwise, go back to use WiFiClientSecure.

[mobizt]

this for passing rotuer firewall by calling the router ip to open connections

Who tell you to do that? It does not really help anything but make more trouble.

[mobizt]

Why you do this?

 basic_client1.connect(gatewayString.c_str(), 80); 
 basic_client2.connect(gatewayString.c_str(), 80);

And set this?

 ssl_client1.setClient(&basic_client1, true);
 ssl_client2.setClient(&basic_client2, true);

[mobizt]

Are you new to ESP32 Arduino programming?

[ehabtawfikelbwab]

Can you help me or not, Sir ?

[ehabtawfikelbwab]

I'm trying my best i'm New yes

[ehabtawfikelbwab]

I did it!
I'm now connected to database and app.ready() return true (1)

I did get the data from database and it is working so good!

but i get the data from realtime database for first time and after that i get a null response
I did check the documentation , I didn't get why returning null and app.ready() return true (1)

also can i speed up the response of streaming?

[mobizt]

You should test the Stream example which no user code run in the loop for how fast the stream is.

You will never miss any SSE event data that pushed from server even you place the small delay (up to 5 seconds) in the main loop.

If you still get laggy SSE event response when running the Stream example code, your network is the problem.

[mobizt]

The latency is the most important for Stream and it was intensively tested even in the old Firebase library.

[mobizt]

The lagging and missing SSE data are due to user code blocking and device/network problem.

[ehabtawfikelbwab]

I did change the device and the network and the device and the network working fine
Also the mqtt working perfect

after get the first payload correct from String path_ = "users/" + FirebaseClient_Sub + "/states";

I did notice the distance between two null is static 30sec :

17:46:20.452 -> {"103-1":{"on":true,"online":true},"103-2":{"on":true,"online":true},"104-0":{"on":true,"online":true},"104-2":{"on":true,"online":true},"ezkvke-0":{"on":true,"online":true},"ezkvke-1":{"on":true,"online":true},"ezkvke-2":{"on":true,"online":true},"kd3xg8-0":{"on":true,"online":true},"kd3xg8-1":{"on":true,"online":true},"kd3xg8-2":{"on":true,"online":true}}
17:46:50.452 -> null
17:47:20.362 -> null
17:47:50.392 -> null
17:48:20.470 -> null
17:48:50.399 -> null
17:49:20.405 -> null

also loop function is looping well i did debug

[mobizt]

You are also new to Firebase. Did you ever read the Firebase Realtime Database REST API documentation?

I always told you about documentation which you should read it thoroughly.

That's a keep-alive event data that pushed from server to notify the client that the Stream is still alive.

The keep-alive event timing is approx. 30 seconds. This keep-alive data was used as the heartbeat signal to determine the Stream timed out of this library.

You can ignore any SSE events with filter in this library.

FirebaseClient/examples/RealtimeDatabase/Async/Callback/Stream/Stream.ino

Lines 120 to 130 in 766c4df

	// Since v1.2.1, in SSE mode (HTTP Streaming) task, you can filter the Stream events by using RealtimeDatabase::setSSEFilters(<keywords>),
	// which the <keywords> is the comma separated events.
	// The event keywords supported are:
	// get - To allow the http get response (first put event since stream connected).
	// put - To allow the put event.
	// patch - To allow the patch event.
	// keep-alive - To allow the keep-alive event.
	// cancel - To allow the cancel event.
	// auth_revoked - To allow the auth_revoked event.
	// To clear all prevousely set filter to allow all Stream events, use RealtimeDatabase::setSSEFilters().
	Database.setSSEFilters("get,put,patch,keep-alive,cancel,auth_revoked");

[ehabtawfikelbwab]

To solve the "Failed to connect to server -1" issue, I set the WiFi DNS to the router's gateway IP. This resolved the connection problem.

Here’s a sample configuration for setting up a static IP on WiFi, including the gateway:
WiFi.config(staticIP, gateway, subnet, gateway);

If anyone else encounters this issue, changing the DNS to your router's gateway might help!

[mobizt]

I lock this discussion now as it was complete and to stop the off-topic discussion.