Using RTDB and Firebase database in the sam time #224

matehubert · 2025-02-18T19:06:15Z

matehubert
Feb 18, 2025

Dear Mobizt,

Thank you for you library!

I want to use two services simultaneously: Realtime Database (RTDB) and the standard Firestore Database.

Short Description of the Program:
The system collects data from two sensors and displays the values on a screen. A Cloud Function, triggered by a button press from a Flutter app, creates an entry in the /sync node of RTDB, which the WEMOS listens to. When a new entry appears, the WEMOS writes the current sensor values into it.

At the same time, every 5 minutes, the system should upload the current sensor data to the Firestore Database.

The Problem:
For some reason, uploading data to Firestore is not working. When the system attempts to upload the sensor data to Firestore, I get the following error:
🔥 Firebase inicializálás...
SSL konfiguráció: setInsecure() called.
✅ Async event (UID: authTask): Code=7 - authenticating
ℹ️ Async callback: no more message.
✅ Async event (UID: authTask): Code=8 - auth request sent
⏳ Firebase auth...⏳ Firebase auth...⏳ Firebase auth...⏳ Firebase auth...⏳ Firebase auth...⏳ Firebase auth...⏳ Firebase auth...⏳ Firebase auth...⏳ Firebase auth...⏳ Firebase auth...⏳ Firebase auth...⏳ Firebase auth...⏳ Firebase auth...⏳ Firebase auth...⏳ Firebase auth...⏳ Firebase auth...⏳ Firebase auth...✅ Async event (UID: authTask): Code=9 - auth response received
✅ Async event (UID: authTask): Code=10 - ready

✅ Firebase auth ready!
✅ Firestore ready!
🔍 RTDB Stream Listening: /sync
✅ Firebase ready!
🔑 Token: eyJhbGciOiJSUzI1NiIsImtpZCI6IjBjYmJiZDI2NjNhY2U4OTU4YTFhOTY4ZmZjNDQxN2U4MDEyYmVmYmUiLCJ0eXAiOiJKV1QifQ.eyJpc3MiOiJodHRwczovL3NlY3VyZXRva2VuLmdvb2dsZS5jb20vYXF1YXRoZXJtbzEiLCJhdWQiOiJhcXVhdGhlcm1vMSIsImF1dGhfdGltZSI6MTczOTkwNDg2MywidXNlcl9pZCI6IkFhUGpPb2dzczRlQXVzV2N2YmNLcjdFSTUzSzIiLCJzdWIiOiJBYVBqT29nc3M0ZUF1c1djdmJjS3I3RUk1M0syIiwiaWF0IjoxNzM5OTA0ODYzLCJleHAiOjE3Mzk5MDg0NjMsImVtYWlsIjoibWF0ZXN6b2tvbEBnbWFpbC5jb20iLCJlbWFpbF92ZXJpZmllZCI6ZmFsc2UsImZpcmViYXNlIjp7ImlkZW50aXRpZXMiOnsiZW1haWwiOlsibWF0ZXN6b2tvbEBnbWFpbC5jb20iXX0sInNpZ25faW5fcHJvdmlkZXIiOiJwYXNzd29yZCJ9fQ.TuiQ9WoWFnksc9IYvzK-2jQa8ptmjYyQPS8uNTm8pIVdH5kocs_Z7rRq6ZMXfkf6KawvuQdELQI_f4Md1AU8ajmuXKHD4bn7cTw_biMnIZT4ipTBBV0fnVo5T-m9JCfULVh15xG5Iv4BpwmTPYsC_ESXdf-ZGlOwwyB_d84dP8I0LzuA1JHhJGH6cF1mnwvujwsSbDKy3Bif4WHwJ9mL8D39syZA6bwfNJheS_Yn9QKsAEjTIM_hkxi6s-zrPdHh179reRNvmeivLkC2vweav9p0dMvXVRXIwdXSCxJpuTxVUb4KZOQPurtIbbzkQxOX0CoRjicxCS1ZmNb0bqiZOA
⏳ TTL: 3299
🔹 Setup ready.
💾 Szabad heap memória: 13952 bajt
RTDB stream stopped.
⚠️ Stream callback: Empty message received.
❌ Firestore upload failed: TCP connection failed
✅ Firestore: Upload successful.
📄 Measurement uploaded: timestamp: 2025-02-18T19:54:36Z, internalTemp: 21.7, externalTemp: 0.0, humidity: 0.0
RTDB stream restarted.
Meanwhile, RTDB is working perfectly without any issues.

It shows it uploaded but it doesnt(wrong debug handle)
What Could Be the Issue?
I have already checked everything, tested different solutions, and even asked various AI models, but I still can't solve it.
This is the code:

#include <Arduino.h>
#include <ESP8266WiFi.h>
#define FIREBASE_ASYNC_QUEUE_LIMIT 20
#include <FirebaseClient.h>  // Új FirebaseClient könyvtár
#include <Adafruit_SSD1306.h>
#include <OneWire.h>
#include <DallasTemperature.h>
#include <DHT.h>
#include <NTPClient.h>
#include <WiFiUdp.h>
#include <LittleFS.h>
#include <ArduinoJson.h>
#include <math.h>

// ======= DEBUG beállítások =======
#define DEBUG 1
#if DEBUG
  #define DPRINT(x) Serial.print(x)
  #define DPRINTLN(x) Serial.println(x)
  #define DPRINTF(...) Serial.printf(__VA_ARGS__)
  #define DPRINTLNF(...) { Serial.printf(__VA_ARGS__); Serial.println(); }
#else
  #define DPRINT(x)
  #define DPRINTLN(x)
  #define DPRINTF(...)
  #define DPRINTLNF(...)
#endif

// -------------------- Wi-Fi adatok --------------------
#define WIFI_SSID "******"
#define WIFI_PASSWORD "*****"

// ----------------- Firebase adatok --------------------
#define FIREBASE_USER_EMAIL "*********"
#define FIREBASE_USER_PASSWORD "****"
#define FIREBASE_PROJECT_ID "********"
#define FIREBASE_API_KEY "***************"
#define DATABASE_URL "*******************************"

// ---------- Hálózati interfész ----------
DefaultNetwork wifi_network;  // Hálózati interfész kezelése

// Két külön SSL kliens:
// - sslClientRTDB: a Realtime Database-hez
// - sslClientFirestore: a Firestore-hoz
WiFiClientSecure sslClientRTDB;
WiFiClientSecure sslClientFirestore;

// Ezekből két külön AsyncClientClass példány jön létre:
AsyncClientClass asyncClientRTDB(sslClientRTDB, getNetwork(wifi_network));
AsyncClientClass asyncClientFirestore(sslClientFirestore, getNetwork(wifi_network));

// -------------------- Firebase objektumok --------------------
FirebaseApp app;
Firestore::Documents firestoreDocs;
UserAuth auth(FIREBASE_API_KEY, FIREBASE_USER_EMAIL, FIREBASE_USER_PASSWORD);
RealtimeDatabase database;
AsyncResult asyncResult;
AsyncResult streamResult;
char lastFirestorePush[8] = "--:--";  // Csak ez marad

// RTDB stream objektum
AsyncResult dbStream;

// -------------------- NTP Client ---------------------------
WiFiUDP ntpUDP;
NTPClient timeClient(ntpUDP, "pool.ntp.org");

// ------------------- OLED kijelző --------------------------
#define SCREEN_WIDTH 128
#define SCREEN_HEIGHT 64
Adafruit_SSD1306 display(SCREEN_WIDTH, SCREEN_HEIGHT, &Wire, -1);

// ------------------ DS18B20 szenzor (belső) -----------------
#define ONE_WIRE_BUS 2
OneWire oneWire(ONE_WIRE_BUS);
DallasTemperature ds18b20(&oneWire);

// ------------------ DHT12 szenzor (külső) -------------------
#define DHT12_PIN 14
DHT dht(DHT12_PIN, DHT12);

// -------------------- SW420 vibrációs szenzor ---------------------
#define VIBRATION_SENSOR_PIN 12
volatile bool vibrationDetected = false;
void IRAM_ATTR handleVibrationInterrupt() {
  vibrationDetected = true;
}

// -------------------- Nyíl és Wi-Fi ikon bitképek --------------------
static const unsigned char PROGMEM arrowUp8x8[] = {
  0x08, 0x18, 0x3C, 0x7E, 0xFF, 0x00, 0x00, 0x00
};
static const unsigned char PROGMEM wifiIcon8x8[] = {
  0x00, 0xff, 0x00, 0x7e, 0x00, 0x18, 0x00, 0x00
};

// ------------------ Mérési időzítés ------------------
static const unsigned long SAMPLE_INTERVAL_MS = 300000UL;
unsigned long lastSampleMillis = 0;

// ------------------ Callback változók ------------------
volatile bool isProcessingStream = false;

// Minta-struktúra
struct Measurement {
  unsigned long timestamp;
  int16_t internalTemp;  // Celsius fok * 10
  int16_t externalTemp;  // Celsius fok * 10
  int16_t humidity;      // százalék (egész)
};

// A kijelzőn megjelenített szenzorértékek
int16_t dispInternal = 0;
int16_t dispExternal = 0;
int16_t dispHumidity = 0;

// Kijelző alvás/felébresztés vezérléséhez
unsigned long lastDisplayOnTime = 0;
bool displayActive = true;

// 🔹 Időformázó függvények
void getShortLocalTime(unsigned long epochSec, char* buf, size_t bufSize) {
  time_t rawTime = (time_t)epochSec;
  struct tm* ti = localtime(&rawTime);
  strftime(buf, bufSize, "%H:%M", ti);
}

void getFirestoreTimestampUTC(unsigned long epochSec, char* buf, size_t bufSize) {
  time_t rawTime = (time_t)epochSec;
  struct tm* tinfo = gmtime(&rawTime);
  strftime(buf, bufSize, "%Y-%m-%dT%H:%M:%SZ", tinfo);
}

// ---------- SSL beállítások ellenőrzése ----------
void checkSSLConfiguration() {
  DPRINTLN(F("SSL konfiguráció: setInsecure() meghívva."));
}

// 🔹 WiFi SSL konfigurálás: mindkét kliensnél beállítjuk a setInsecure() hívást
void configureWiFiClient() {
  sslClientRTDB.setInsecure();
  sslClientFirestore.setInsecure();
  checkSSLConfiguration();
}

// ------ Async callback ------
void asyncCB(AsyncResult &aResult) {
  if (aResult.isError()) {
    Serial.print("❌ Async error (UID: ");
    Serial.print(aResult.uid());
    Serial.print("): Code=");
    Serial.print(aResult.error().code());
    Serial.print(" - ");
    Serial.println(aResult.error().message());
    // Extra debug információ (ha van)
    Serial.print("🔍 Debug info: ");
    Serial.println(aResult.debug());
  } else if (aResult.isEvent()) {
    Serial.print("✅ Async event (UID: ");
    Serial.print(aResult.uid());
    Serial.print("): Code=");
    Serial.print(aResult.appEvent().code());
    Serial.print(" - ");
    Serial.println(aResult.appEvent().message());
  } else if (aResult.available()) {
    Serial.print("✅ Async success (UID: ");
    Serial.print(aResult.uid());
    Serial.println(")");
  } else {
    Serial.println("ℹ️ Async callback: nincs további üzenet.");
  }
}


bool verifyUser(const String& apiKey, const String& email, const String& password) {
  if (sslClientRTDB.connected()) {
    sslClientRTDB.stop();
  }
  const String host = "www.googleapis.com";
  bool success = false;
  Serial.println("🔍 Firebase hitelesítés indítása...");
  if (sslClientRTDB.connect(host.c_str(), 443)) {
    Serial.println("✅ Sikeres kapcsolat a hitelesítési szerverhez.");
    String payload = "{\"email\":\"" + email + "\",\"password\":\"" + password + "\",\"returnSecureToken\":true}";
    String header = "POST /identitytoolkit/v3/relyingparty/verifyPassword?key=" + apiKey +
                    " HTTP/1.1\r\n" +
                    "Host: " + host + "\r\n" +
                    "Content-Type: application/json\r\n" +
                    "Content-Length: " + String(payload.length()) + "\r\n\r\n";
    Serial.println("📤 Hitelesítési kérés küldése...");
    if (sslClientRTDB.print(header) == header.length() && sslClientRTDB.print(payload) == payload.length()) {
      unsigned long timeout = millis();
      while (sslClientRTDB.connected() && sslClientRTDB.available() == 0 && millis() - timeout < 5000) {
        delay(1);
      }
      while (sslClientRTDB.connected() && sslClientRTDB.available()) {
        String response = sslClientRTDB.readStringUntil('\n');
        Serial.println("🔥 DEBUG Response: " + response);
        if (response.indexOf("HTTP/1.1 200 OK") != -1) {
          success = true;
        }
      }
      sslClientRTDB.stop();
    }
  } else {
    Serial.println("❌ Nem sikerült kapcsolódni a hitelesítési szerverhez!");
  }
  Serial.print("🔎 Hitelesítési eredmény: ");
  Serial.println(success ? "✅ SIKERES" : "❌ SIKERTELEN");
  return success;
}

// 🔹 Firebase inicializálás (maximum 30 mp várakozás a hitelesítési szerre)
void initializeFirebase() {
  Serial.println("🔥 Firebase inicializálás...");
  configureWiFiClient();
  // RTDB inicializálása az asyncClientRTDB-vel:
  initializeApp(asyncClientRTDB, app, getAuth(auth), asyncCB, "authTask");
  unsigned long startTime = millis();
  while (!app.ready() && millis() - startTime < 15000) {
    Serial.print("⏳ Firebase auth...");
    delay(500);
    app.loop();
  }
  if (app.ready()) {
    Serial.println("\n✅ Firebase hitelesítés sikeres!");
  } else {
    Serial.println("\n❌ Firebase hitelesítés sikertelen! Ellenőrizd az API kulcsot és az e-mail/jelszót!");
    return;
  }

    // Firestore inicializálása – itt nem használtunk külön async hívást a setup során,
  // de a Firestore műveleteknél majd az asyncClientFirestore kerül felhasználásra.
  app.getApp<Firestore::Documents>(firestoreDocs);
  DPRINTLN("✅ Firestore inicializálva és készen áll!");

  // RTDB inicializálása:
  app.getApp<RealtimeDatabase>(database);
  database.url(DATABASE_URL);
  database.setSSEFilters("get,put,patch,keep-alive,cancel,auth_revoked");
  Serial.println("🔍 RTDB Stream Listening: /sync");
  database.get(asyncClientRTDB, "/sync", streamCallback, true, "streamTask");
  

}

// ------ Kijelző rajzolás ------
void drawDisplay(const char* topTimeStr) {
  display.clearDisplay();
  display.setTextSize(1);
  display.setTextColor(SSD1306_WHITE);
  display.setCursor(0, 0);
  display.print(topTimeStr);
  display.drawBitmap(112, 0, wifiIcon8x8, 8, 8, SSD1306_WHITE);
  display.setCursor(2, 18);
  display.setTextSize(1);
  display.print("k");
  display.setTextSize(2);
  display.setCursor(2, 30);
  {
    int intPart = dispExternal / 10;
    int fracPart = abs(dispExternal % 10);
    display.printf("%d.%dC", intPart, fracPart);
  }
  display.setTextSize(1);
  display.setCursor(2, 50);
  display.printf("Para: %d%%", dispHumidity);
  display.setCursor(66, 18);
  display.setTextSize(1);
  display.print("B");
  display.setTextSize(2);
  display.setCursor(66, 30);
  {
    int intPart = dispInternal / 10;
    int fracPart = abs(dispInternal % 10);
    display.printf("%d.%dC", intPart, fracPart);
  }
  display.setTextSize(1);
  display.setCursor(64, 48);
  display.drawBitmap(display.getCursorX(), display.getCursorY(), arrowUp8x8, 8, 8, SSD1306_WHITE);
  display.setCursor(display.getCursorX() + 10, display.getCursorY());
  if (strlen(lastFirestorePush) == 0) {
    display.print(F(": --:--"));
  } else {
    display.print(F(": "));
    display.print(lastFirestorePush);
  }
  display.display();
}


// --- RTDB stream leállítása és újraindítása ---
void pauseRTDBStream() {
  asyncClientRTDB.stopAsync(true);
  Serial.println("RTDB stream leállítva.");
}

void resumeRTDBStream() {
  database.get(asyncClientRTDB, "/sync", streamCallback, true, "streamTask");
  Serial.println("RTDB stream újraindítva.");
}

void uploadMeasurementToFirestore() {
  // Ideiglenesen állítsuk le a RTDB stream-et
  pauseRTDBStream();
  delay(1000);
  
  if (!app.ready()) {
    DPRINTLN("❌ Firestore: Not ready, skipping upload.");
    resumeRTDBStream();
    return;
  }
  
  Firestore::Parent parent(FIREBASE_PROJECT_ID);
  char firestoreTimestamp[30];
  unsigned long currentTimestamp = timeClient.getEpochTime();
  getFirestoreTimestampUTC(currentTimestamp, firestoreTimestamp, sizeof(firestoreTimestamp));
  
  double internalT = dispInternal / 10.0;
  double externalT = dispExternal / 10.0;
  double hum = dispHumidity;
  
  Document<Values::Value> doc;
  doc.setName("");  // Auto-ID
  // Itt natív timestampValue-t használunk
  doc.add("timestamp", Values::Value(Values::TimestampValue(firestoreTimestamp)));
  doc.add("internalTemp", Values::Value(Values::DoubleValue(internalT)));
  doc.add("externalTemp", Values::Value(Values::DoubleValue(externalT)));
  doc.add("humidity", Values::Value(Values::DoubleValue(hum)));
  
  firestoreDocs.createDocument(asyncClientFirestore, parent, "measurements", DocumentMask(), doc, asyncFirestoreCallback);
  DPRINTF("📄 Measurement uploaded: timestamp: %s, internalTemp: %.1f, externalTemp: %.1f, humidity: %.1f\n",
          firestoreTimestamp, internalT, externalT, hum);
  delay(300);
  resumeRTDBStream();
}


// ✅ Callback function for handling Firestore single-document upload results
void asyncFirestoreCallback(AsyncResult& aResult) {
  if (aResult.isError()) {
    DPRINT("❌ Firestore upload failed: ");
    DPRINTLN(aResult.error().message());
  } else {
    DPRINTLN("✅ Firestore: Upload successful.");
  }
}

void streamCallback(AsyncResult& result) {
  if (!result.available()) {
    Serial.println("⚠️ Stream callback: Empty message received.");
    return;
  }
  Serial.println("----- 🔥 RAW STREAM PAYLOAD 🔥 -----");
  Serial.println(result.payload());
  Serial.println("----- END OF PAYLOAD -----");
  if (isProcessingStream) {
    Serial.println("⚠️ Stream callback: Skipping, another process is running.");
    return;
  }
  isProcessingStream = true;
  
  // Extract JSON safely
  String rawData = result.payload();
  rawData.trim();
  int jsonStart = rawData.indexOf("data:");
  if (jsonStart == -1) {
    Serial.println("❌ JSON Parsing Error: 'data:' not found in the payload.");
    isProcessingStream = false;
    return;
  }
  String jsonData = rawData.substring(jsonStart + 5);
  jsonData.trim();
  int firstBrace = jsonData.indexOf("{");
  int lastBrace = jsonData.lastIndexOf("}");
  if (firstBrace == -1 || lastBrace == -1 || lastBrace <= firstBrace) {
    Serial.println("❌ JSON Parsing Error: JSON object not found!");
    isProcessingStream = false;
    return;
  }
  jsonData = jsonData.substring(firstBrace, lastBrace + 1);
  Serial.println("✅ Extracted JSON Data:");
  Serial.println(jsonData);
  
  StaticJsonDocument<1024> jsonPayload;
  DeserializationError error = deserializeJson(jsonPayload, jsonData);
  if (error) {
    Serial.print("❌ JSON Parsing Error: ");
    Serial.println(error.f_str());
    Serial.println("⚠️ Possible issue: JSON structure might be incorrect.");
    isProcessingStream = false;
    return;
  }
  if (!jsonPayload.containsKey("data")) {
    Serial.println("⚠️ Stream callback: 'data' field is missing in JSON.");
    isProcessingStream = false;
    return;
  }
  JsonObject dataObj = jsonPayload["data"];
  if (!dataObj.containsKey("requestId")) {
    Serial.println("⚠️ Stream callback: No requestId found in JSON.");
    isProcessingStream = false;
    return;
  }
  const char* latestRequestId = dataObj["requestId"];
  Serial.printf("✅ Stream detected new requestId: %s\n", latestRequestId);
  
  // Step 1: Delete old requests and keep only the latest
  deleteOldSyncDocuments(latestRequestId);
  // Step 2: Send sensor data to the latest request
  sendTemperatureToRTDB(latestRequestId);
  
  isProcessingStream = false;
}

void deleteOldSyncDocuments(const char* latestRequestId) {
  Serial.println("🗑️ Deleting old sync requests...");
  database.remove(asyncClientRTDB, "/sync", asyncCB, "removeOldSyncs");
  
  // Recreate the latest request document to ensure it still exists:
  String path = "/sync/" + String(latestRequestId);
  object_t syncStatus;
  JsonWriter writer;
  writer.create(syncStatus, "syncStatus", true);
  
  database.update(asyncClientRTDB, path.c_str(), syncStatus, asyncCB, "restoreLatestSync");
  Serial.printf("✅ Keeping only latest sync document: %s\n", latestRequestId);
}

// ------ RTDB Update: Send fresh sensor data ------
void sendTemperatureToRTDB(const char* requestId) {
  if (!app.ready()) {
    Serial.println("❌ RTDB: Firebase app is not ready, skipping data upload.");
    return;
  }
  ds18b20.requestTemperatures();
  float internalTemp = ds18b20.getTempCByIndex(0);
  if (internalTemp == DEVICE_DISCONNECTED_C)
    internalTemp = dispInternal / 10.0;
  float externalTemp = dht.readTemperature();
  if (isnan(externalTemp))
    externalTemp = dispExternal / 10.0;
  float humidity = dht.readHumidity();
  if (isnan(humidity))
    humidity = dispHumidity;
  
  dispInternal = (int16_t)(internalTemp * 10);
  dispExternal = (int16_t)(externalTemp * 10);
  dispHumidity = (int16_t)(humidity);
  
  Serial.printf("📤 RTDB: Sending updated values, Heap: %d bytes\n", ESP.getFreeHeap());
  
  object_t reqIdObj, syncStatusObj, internalTempObj, externalTempObj, humidityObj, timestampObj, json;
  JsonWriter writer;
  
  writer.create(reqIdObj, "requestId", string_t(requestId));
  writer.create(syncStatusObj, "syncStatus", false);
  writer.create(internalTempObj, "internalTemp", number_t(internalTemp, 2));
  writer.create(externalTempObj, "externalTemp", number_t(externalTemp, 2));
  writer.create(humidityObj, "humidity", number_t(humidity, 2));
  
  char firestoreTimestamp[30];
  getFirestoreTimestampUTC(timeClient.getEpochTime(), firestoreTimestamp, sizeof(firestoreTimestamp));
  writer.create(timestampObj, "timestamp", string_t(firestoreTimestamp));
  
  writer.join(json, 6, reqIdObj, syncStatusObj, internalTempObj, externalTempObj, humidityObj, timestampObj);
  
  String path = "/sync/" + String(requestId);
  Serial.printf("🔥 RTDB Update Path: %s\n", path.c_str());
  
  database.update(asyncClientRTDB, path.c_str(), json, asyncCB, "updateTask");
}

void streamTimeoutCallback(bool timeout) {
  if (timeout) {
    DPRINTLN("Stream timeout, újrapróbálás...");
  }
}

void setup() {
  Serial.begin(115200);
  Wire.begin();
  delay(100);
  
  if (!LittleFS.begin()) {
    DPRINTLN(F("LittleFS indítás hiba!"));
  }
  
  if (!display.begin(SSD1306_SWITCHCAPVCC, 0x3C)) {
    DPRINTLN(F("SSD1306 hiba!"));
    for (;;);
  }
  display.clearDisplay();
  display.display();
  display.setCursor(0, 0);
  display.setTextSize(1);
  display.setTextColor(SSD1306_WHITE);
  display.println(F("Csatlakozás a WiFihez..."));
  display.display();
  
  WiFi.disconnect(true);
  WiFi.mode(WIFI_STA);
  IPAddress staticIP(192, 168, 0, 103);
  IPAddress gateway(192, 168, 0, 1);
  IPAddress subnet(255, 255, 255, 0);
  IPAddress dns(8, 8, 8, 8);
  WiFi.config(staticIP, gateway, subnet, dns);
  WiFi.begin(WIFI_SSID, WIFI_PASSWORD);
  
  int maxAttempts = 40;
  while (WiFi.status() != WL_CONNECTED && maxAttempts > 0) {
    DPRINT(".");
    delay(250);
    maxAttempts--;
  }
  if (WiFi.status() != WL_CONNECTED) {
    DPRINTLN();
    DPRINTLN(F("❌ WiFi nem elérhető, újraindítás..."));
    ESP.restart();
  }
  DPRINTLN();
  DPRINTLN(F("✅ WiFi OK!"));
  DPRINT(F("📡 IP: "));
  DPRINTLN(WiFi.localIP());
  
  display.clearDisplay();
  display.setCursor(0, 0);
  display.println(F("WiFi OK!"));
  display.drawBitmap(112, 0, wifiIcon8x8, 8, 8, SSD1306_WHITE);
  display.setCursor(0, 16);
  display.print(F("📡 IP: "));
  display.println(WiFi.localIP());
  display.display();
  delay(1500);
  
  timeClient.begin();
  timeClient.setTimeOffset(3600);
  ds18b20.begin();
  dht.begin();
  
  Serial.println(F("🔥 Firebase hitelesítés..."));
  if (!verifyUser(FIREBASE_API_KEY, FIREBASE_USER_EMAIL, FIREBASE_USER_PASSWORD)) {
    Serial.println("❌ Firebase hitelesítés SIKERTELEN! Ellenőrizd az API kulcsot és az e-mail/jelszót!");
  } else {
    Serial.println("✅ Firebase hitelesítés SIKERES!");
  }
  
  initializeFirebase();
  if (app.ready()) {
    Serial.println(F("✅ Firebase KÉSZ!"));
    Serial.print("🔑 Token: ");
    Serial.println(app.getToken());
    Serial.print("⏳ TTL: ");
    Serial.println(app.ttl());
  } else {
    Serial.println(F("❌ Firebase inicializáció SIKERTELEN! Ellenőrizd a hitelesítési adatokat."));
  }
  DPRINTLN(F("🔹 Setup KÉSZ."));
  delay(2000);
  lastSampleMillis = millis() - SAMPLE_INTERVAL_MS;
  pinMode(VIBRATION_SENSOR_PIN, INPUT);
  attachInterrupt(digitalPinToInterrupt(VIBRATION_SENSOR_PIN), handleVibrationInterrupt, RISING);
  lastDisplayOnTime = millis();
}

void loop() {
  app.loop();
  database.loop();
  
  static unsigned long lastHeapPrint = 0;
  if (millis() - lastHeapPrint > 5000) {
    lastHeapPrint = millis();
    DPRINTF("💾 Szabad heap memória: %d bajt\n", ESP.getFreeHeap());
  }
  
  if (vibrationDetected) {
    vibrationDetected = false;
    if (!displayActive) {
      displayActive = true;
      display.ssd1306_command(SSD1306_DISPLAYON);
      timeClient.update();
      unsigned long ep = timeClient.getEpochTime();
      time_t raw = (time_t)ep;
      struct tm* tinfo = localtime(&raw);
      char buf[20];
      strftime(buf, sizeof(buf), "%Y.%m.%d %H:%M", tinfo);
      drawDisplay(buf);
      lastDisplayOnTime = millis();
    }
  }
  
  static unsigned long livePrev = 0;
  if (millis() - livePrev >= 1000) {
    livePrev = millis();
    ds18b20.requestTemperatures();
    float liInt = ds18b20.getTempCByIndex(0);
    if (liInt == DEVICE_DISCONNECTED_C)
      liInt = dispInternal / 10.0;
    float liExt = dht.readTemperature();
    if (isnan(liExt))
      liExt = dispExternal / 10.0;
    float liHum = dht.readHumidity();
    if (isnan(liHum))
      liHum = dispHumidity;
    dispInternal = (int16_t)(liInt * 10);
    dispExternal = (int16_t)(liExt * 10);
    dispHumidity = (int16_t)(liHum);
    timeClient.update();
    unsigned long ep = timeClient.getEpochTime();
    time_t raw = (time_t)ep;
    struct tm* tinfo = localtime(&raw);
    char buf[20];
    strftime(buf, sizeof(buf), "%Y.%m.%d %H:%M", tinfo);
    if (displayActive) {
      drawDisplay(buf);
    }
  }
  
  if (millis() - lastSampleMillis >= SAMPLE_INTERVAL_MS) {
    lastSampleMillis = millis();
    // Directly upload the current measurement to Firestore:
    uploadMeasurementToFirestore();
  }
  
  static unsigned long lastDisplayCheck = millis();
  if (displayActive && (millis() - lastDisplayOnTime >= 15000)) {
    displayActive = false;
    display.ssd1306_command(SSD1306_DISPLAYOFF);
  }
}

Any help would be greatly appreciated! Thank you!

eXtr3me26 · 2025-02-18T20:51:41Z

eXtr3me26
Feb 18, 2025

Szia, matehubert,
shouldnt you create 2 separate apps for your use case?
One for Firestore-Communication and one for RTDB?
I think this wont work with only one app, because the initialization is completely different.

4 replies

matehubert Feb 18, 2025
Author

Hello Extreme,

Maybe I'll try with old library I can use it simultaniusly, but always run out from heap memory. With this new library I can't bring them together. I'll update here if its worked!

eXtr3me26 Feb 18, 2025

I would continue with the new one. It seems that its pretty reliable and state of the art.
But if the old works, go for it!

eXtr3me26 Feb 18, 2025

You just have to add the app and another sslClient for Firestore.
This is the example you can use:
https://github.com/mobizt/FirebaseClient/blob/main/examples/FirestoreDatabase/Documents/Sync/Patch/UpdateDocument/UpdateDocument.ino

matehubert Feb 19, 2025
Author

But I already have two SSL clients. So as I understan you, if switch from async/nocallback createdocument to sync/patch/ update document it doing the same( create a new document in every 5 minutes in the firestore) and the RTDB functionality is remain the same?

mobizt · 2025-02-19T06:29:38Z

mobizt
Feb 19, 2025
Maintainer

You can use the same FirebaseApp for Firestore and Realtime Database for user authentication as you have done.

This statement is not quite right.

It shows it uploaded but it doesnt(wrong debug handle)

The returning payload in case Firestore is from server directly, the returning HTTP code 200 was checked to confirm the REST API HTTP request is successful.

The change on server side depends on your data and function you used.

You should use one AsyncClient for Realtime Database Stream only without sharing to any functions.

You should leave Stream task running in its async queue in specific AsyncClient alone. Stream interruption by adding other auth/sync/async taks to its AsyncClient queue is not recommended as it is not efficient usage.

Another one AsyncClient can be used for all e.g. initializeApp, Firestore, Cloud Functions and Realtime Database functions except Stream.

0 replies

mobizt · 2025-02-19T06:40:43Z

mobizt
Feb 19, 2025
Maintainer

The memory option should be set too.
https://github.com/mobizt/FirebaseClient?tab=readme-ov-file#memory-options

If you are using WiFiClientSecure without setting the buffer size, it will consume about 32k (16k for rx and 16k for tx) by default when connecting to the server. This leads to not enough memory for another SSL client to work.

You should set lower buffer size to gain more Heap like this.

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

Lines 106 to 107 in 697044a

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

1 reply

matehubert Feb 19, 2025
Author

Dear Mobizt, now its working, but now it's running much more less heap than the doesnt working previous version. On the version where I doesn't setBuffersizes, i got on 13-16 heap now ist runing 6-8. what coud be the problem?:
#include <Arduino.h>
#include <ESP8266WiFi.h>
#include <FirebaseClient.h> // Új FirebaseClient könyvtár
#include <Adafruit_SSD1306.h>
#include <OneWire.h>
#include <DallasTemperature.h>
#include <DHT.h>
#include <NTPClient.h>
#include <WiFiUdp.h>
#include <LittleFS.h>
#include <ArduinoJson.h>
#include <math.h>

// ======= DEBUG beállítások =======
#define DEBUG 1
#if DEBUG
#define DPRINT(x) Serial.print(x)
#define DPRINTLN(x) Serial.println(x)
#define DPRINTF(...) Serial.printf(VA_ARGS)
#define DPRINTLNF(...)
{
Serial.printf(VA_ARGS);
Serial.println();
}
#else
#define DPRINT(x)
#define DPRINTLN(x)
#define DPRINTF(...)
#define DPRINTLNF(...)
#endif

// -------------------- Wi-Fi adatok --------------------
#define WIFI_SSID "*"
#define WIFI_PASSWORD ""

// ----------------- Firebase adatok --------------------
#define FIREBASE_USER_EMAIL ""
#define FIREBASE_USER_PASSWORD ""
#define FIREBASE_PROJECT_ID ""
#define FIREBASE_API_KEY "****************"
#define DATABASE_URL "*****************"

// ---------- Hálózati interfész ----------
DefaultNetwork wifi_network; // Hálózati interfész kezelése

WiFiClientSecure sslClientRTDB;
WiFiClientSecure sslClientFirestore;

// Ezekből két külön AsyncClientClass példány jön létre:
AsyncClientClass asyncClientRTDBStream(sslClientRTDB, getNetwork(wifi_network)); // For RTDB stream only
AsyncClientClass asyncClientGeneral(sslClientFirestore, getNetwork(wifi_network)); // For all other operations

// -------------------- Firebase objektumok --------------------
FirebaseApp app;
Firestore::Documents firestoreDocs;
UserAuth auth(FIREBASE_API_KEY, FIREBASE_USER_EMAIL, FIREBASE_USER_PASSWORD);
RealtimeDatabase database;
AsyncResult asyncResult;
AsyncResult streamResult;
char lastFirestorePush[8] = "--:--"; // Csak ez marad

// RTDB stream objektum
AsyncResult dbStream;

// -------------------- NTP Client ---------------------------
WiFiUDP ntpUDP;
NTPClient timeClient(ntpUDP, "pool.ntp.org");

// ------------------- OLED kijelző --------------------------
#define SCREEN_WIDTH 128
#define SCREEN_HEIGHT 64
Adafruit_SSD1306 display(SCREEN_WIDTH, SCREEN_HEIGHT, &Wire, -1);

// ------------------ DS18B20 szenzor (belső) -----------------
#define ONE_WIRE_BUS 2
OneWire oneWire(ONE_WIRE_BUS);
DallasTemperature ds18b20(&oneWire);

// ------------------ DHT12 szenzor (külső) -------------------
#define DHT12_PIN 14
DHT dht(DHT12_PIN, DHT12);

// -------------------- SW420 vibrációs szenzor ---------------------
#define VIBRATION_SENSOR_PIN 12
volatile bool vibrationDetected = false;
void IRAM_ATTR handleVibrationInterrupt() {
vibrationDetected = true;
}

// -------------------- Nyíl és Wi-Fi ikon bitképek --------------------
static const unsigned char PROGMEM arrowUp8x8[] = {
0x08, 0x18, 0x3C, 0x7E, 0xFF, 0x00, 0x00, 0x00
};
static const unsigned char PROGMEM wifiIcon8x8[] = {
0x00, 0xff, 0x00, 0x7e, 0x00, 0x18, 0x00, 0x00
};

// ------------------ Mérési időzítés ------------------
static const unsigned long SAMPLE_INTERVAL_MS = 300000UL;
unsigned long lastSampleMillis = 0;

// ------------------ Callback változók ------------------
volatile bool isProcessingStream = false;

// Minta-struktúra
struct Measurement {
unsigned long timestamp;
int16_t internalTemp; // Celsius fok * 10
int16_t externalTemp; // Celsius fok * 10
int16_t humidity; // százalék (egész)
};

// A kijelzőn megjelenített szenzorértékek
int16_t dispInternal = 0;
int16_t dispExternal = 0;
int16_t dispHumidity = 0;

// Kijelző alvás/felébresztés vezérléséhez
unsigned long lastDisplayOnTime = 0;
bool displayActive = true;

// 🔹 Időformázó függvények
void getShortLocalTime(unsigned long epochSec, char* buf, size_t bufSize) {
time_t rawTime = (time_t)epochSec;
struct tm* ti = localtime(&rawTime);
strftime(buf, bufSize, "%H:%M", ti);
}

void getFirestoreTimestampUTC(unsigned long epochSec, char* buf, size_t bufSize) {
time_t rawTime = (time_t)epochSec;
struct tm* tinfo = gmtime(&rawTime);
strftime(buf, bufSize, "%Y-%m-%dT%H:%M:%SZ", tinfo);
}

// ---------- SSL beállítások ellenőrzése ----------
void checkSSLConfiguration() {
DPRINTLN(F("SSL konfiguráció: setInsecure() meghívva."));
}

// 🔹 WiFi SSL konfigurálás: mindkét kliensnél beállítjuk a setInsecure() hívást
void configureWiFiClient() {
sslClientRTDB.setInsecure();
sslClientFirestore.setInsecure();
checkSSLConfiguration();
}

// ------ Async callback ------
void asyncCB(AsyncResult& aResult) {
if (aResult.isError()) {
DPRINTF("Error: %s\n", aResult.error().message().c_str());
}
}

bool verifyUser(const String& apiKey, const String& email, const String& password) {
if (sslClientRTDB.connected()) {
sslClientRTDB.stop();
}
const String host = "www.googleapis.com";
bool success = false;
DPRINTLN("🔍 Firebase hitelesítés indítása...");
if (sslClientRTDB.connect(host.c_str(), 443)) {
DPRINTLN("✅ Sikeres kapcsolat a hitelesítési szerverhez.");
String payload = "{"email":"" + email + "","password":"" + password + "","returnSecureToken":true}";
String header = "POST /identitytoolkit/v3/relyingparty/verifyPassword?key=" + apiKey + " HTTP/1.1\r\n" + "Host: " + host + "\r\n" + "Content-Type: application/json\r\n" + "Content-Length: " + String(payload.length()) + "\r\n\r\n";
DPRINTLN("📤 Hitelesítési kérés küldése...");
if (sslClientRTDB.print(header) == header.length() && sslClientRTDB.print(payload) == payload.length()) {
unsigned long timeout = millis();
while (sslClientRTDB.connected() && sslClientRTDB.available() == 0 && millis() - timeout < 5000) {
delay(1);
}
while (sslClientRTDB.connected() && sslClientRTDB.available()) {
String response = sslClientRTDB.readStringUntil('\n');
DPRINTLN("🔥 DEBUG Response: " + response);
if (response.indexOf("HTTP/1.1 200 OK") != -1) {
success = true;
}
}
sslClientRTDB.stop();
}
} else {
DPRINTLN("❌ Nem sikerült kapcsolódni a hitelesítési szerverhez!");
}
DPRINT("🔎 Hitelesítési eredmény: ");
DPRINTLN(success ? "✅ SIKERES" : "❌ SIKERTELEN");
return success;
}

// 🔹 Firebase inicializálás (maximum 30 mp várakozás a hitelesítési szerre)
void initializeFirebase() {
Serial.println("🔥 Firebase inicializálás...");
configureWiFiClient();
// Use asyncClientGeneral for initialization
initializeApp(asyncClientGeneral, app, getAuth(auth), asyncCB, "authTask");
unsigned long startTime = millis();
while (!app.ready() && millis() - startTime < 15000) {
Serial.print("⏳ Firebase auth...");
delay(500);
app.loop();
}
if (app.ready()) {
Serial.println("\n✅ Firebase hitelesítés sikeres!");
} else {
Serial.println("\n❌ Firebase hitelesítés sikertelen! Ellenőrizd az API kulcsot és az e-mail/jelszót!");
return;
}

// Firestore initialization
app.getAppFirestore::Documents(firestoreDocs);
DPRINTLN("✅ Firestore inicializálva és készen áll!");

// RTDB initialization
app.getApp(database);
database.url(DATABASE_URL);
database.setSSEFilters("get,put,patch,keep-alive,cancel,auth_revoked");
Serial.println("🔍 RTDB Stream Listening: /sync");

// Use asyncClientRTDBStream for the stream
database.get(asyncClientRTDBStream, "/sync", streamCallback, true, "streamTask");
}

// ------ Kijelző rajzolás ------
void drawDisplay(const char* topTimeStr) {
display.clearDisplay();
display.setTextSize(1);
display.setTextColor(SSD1306_WHITE);
display.setCursor(0, 0);
display.print(topTimeStr);
display.drawBitmap(112, 0, wifiIcon8x8, 8, 8, SSD1306_WHITE);
display.setCursor(2, 18);
display.setTextSize(1);
display.print("k");
display.setTextSize(2);
display.setCursor(2, 30);
{
int intPart = dispExternal / 10;
int fracPart = abs(dispExternal % 10);
display.printf("%d.%dC", intPart, fracPart);
}
display.setTextSize(1);
display.setCursor(2, 50);
display.printf("Para: %d%%", dispHumidity);
display.setCursor(66, 18);
display.setTextSize(1);
display.print("B");
display.setTextSize(2);
display.setCursor(66, 30);
{
int intPart = dispInternal / 10;
int fracPart = abs(dispInternal % 10);
display.printf("%d.%dC", intPart, fracPart);
}
display.setTextSize(1);
display.setCursor(64, 48);
display.drawBitmap(display.getCursorX(), display.getCursorY(), arrowUp8x8, 8, 8, SSD1306_WHITE);
display.setCursor(display.getCursorX() + 10, display.getCursorY());
if (strlen(lastFirestorePush) == 0) {
display.print(F(": --:--"));
} else {
display.print(F(": "));
display.print(lastFirestorePush);
}
display.display();
}

void uploadMeasurementToFirestore() {
DPRINTLN("Starting Firestore upload...");
DPRINTF("RSSI: %d\n", WiFi.RSSI());
DPRINTF("WiFi Status: %d\n", WiFi.status());

Firestore::Parent parent(FIREBASE_PROJECT_ID);
char firestoreTimestamp[30];
unsigned long currentTimestamp = timeClient.getEpochTime();
getFirestoreTimestampUTC(currentTimestamp, firestoreTimestamp, sizeof(firestoreTimestamp));

double internalT = dispInternal / 10.0;
double externalT = dispExternal / 10.0;
double hum = dispHumidity;

DocumentValues::Value doc;
doc.setName(""); // Auto-ID
doc.add("timestamp", Values::Value(Values::TimestampValue(firestoreTimestamp)));
doc.add("internalTemp", Values::Value(Values::DoubleValue(internalT)));
doc.add("externalTemp", Values::Value(Values::DoubleValue(externalT)));
doc.add("humidity", Values::Value(Values::DoubleValue(hum)));

DPRINTF("Uploading with timestamp: %s\n", firestoreTimestamp);
firestoreDocs.createDocument(asyncClientGeneral, parent, "measurements", DocumentMask(), doc, asyncFirestoreCallback);
DPRINTF("📄 Measurement uploaded: timestamp: %s, internalTemp: %.1f, externalTemp: %.1f, humidity: %.1f\n",
firestoreTimestamp, internalT, externalT, hum);
}

// ✅ Callback function for handling Firestore single-document upload results
void asyncFirestoreCallback(AsyncResult& aResult) {
if (aResult.isError()) {
DPRINT("❌ Firestore upload failed: ");
DPRINTLN(aResult.error().message());
DPRINTF("Error Code: %d\n", aResult.error().code());
} else {
DPRINTLN("✅ Firestore: Upload successful.");
}
}

void streamCallback(AsyncResult& result) {
if (!result.available()) {
Serial.println("⚠️ Stream callback: Empty message received.");
return;
}
Serial.println("----- 🔥 RAW STREAM PAYLOAD 🔥 -----");
Serial.println(result.payload());
Serial.println("----- END OF PAYLOAD -----");

if (isProcessingStream) {
Serial.println("⚠️ Stream callback: Skipping, another process is running.");
return;
}
isProcessingStream = true;

String rawData = result.payload();
rawData.trim();
int jsonStart = rawData.indexOf("data:");
if (jsonStart == -1) {
Serial.println("❌ JSON Parsing Error: 'data:' not found in the payload.");
isProcessingStream = false;
return;
}

String jsonData = rawData.substring(jsonStart + 5);
jsonData.trim();
int firstBrace = jsonData.indexOf("{");
int lastBrace = jsonData.lastIndexOf("}");
if (firstBrace == -1 || lastBrace == -1 || lastBrace <= firstBrace) {
Serial.println("❌ JSON Parsing Error: JSON object not found!");
isProcessingStream = false;
return;
}

jsonData = jsonData.substring(firstBrace, lastBrace + 1);
Serial.println("✅ Extracted JSON Data:");
Serial.println(jsonData);

StaticJsonDocument<1024> jsonPayload;
DeserializationError error = deserializeJson(jsonPayload, jsonData);
if (error) {
Serial.print("❌ JSON Parsing Error: ");
Serial.println(error.f_str());
Serial.println("⚠️ Possible issue: JSON structure might be incorrect.");
isProcessingStream = false;
return;
}

if (!jsonPayload.containsKey("data")) {
Serial.println("⚠️ Stream callback: 'data' field is missing in JSON.");
isProcessingStream = false;
return;
}

JsonObject dataObj = jsonPayload["data"];
if (!dataObj.containsKey("requestId")) {
Serial.println("⚠️ Stream callback: No requestId found in JSON.");
isProcessingStream = false;
return;
}

const char* latestRequestId = dataObj["requestId"];
Serial.printf("✅ Stream detected new requestId: %s\n", latestRequestId);

deleteOldSyncDocuments(latestRequestId);
sendTemperatureToRTDB(latestRequestId);

isProcessingStream = false;
}

void deleteOldSyncDocuments(const char* latestRequestId) {
Serial.println("🗑️ Deleting old sync requests...");
database.remove(asyncClientGeneral, "/sync", asyncCB, "removeOldSyncs");

// Recreate the latest request document to ensure it still exists:
String path = "/sync/" + String(latestRequestId);
object_t syncStatus;
JsonWriter writer;
writer.create(syncStatus, "syncStatus", true);

database.update(asyncClientGeneral, path.c_str(), syncStatus, asyncCB, "restoreLatestSync");
Serial.printf("✅ Keeping only latest sync document: %s\n", latestRequestId);
}

// ------ RTDB Update: Send fresh sensor data ------
void sendTemperatureToRTDB(const char* requestId) {
if (!app.ready()) {
Serial.println("❌ RTDB: Firebase app is not ready, skipping data upload.");
return;
}
ds18b20.requestTemperatures();
float internalTemp = ds18b20.getTempCByIndex(0);
if (internalTemp == DEVICE_DISCONNECTED_C)
internalTemp = dispInternal / 10.0;
float externalTemp = dht.readTemperature();
if (isnan(externalTemp))
externalTemp = dispExternal / 10.0;
float humidity = dht.readHumidity();
if (isnan(humidity))
humidity = dispHumidity;

dispInternal = (int16_t)(internalTemp * 10);
dispExternal = (int16_t)(externalTemp * 10);
dispHumidity = (int16_t)(humidity);

Serial.printf("📤 RTDB: Sending updated values, Heap: %d bytes\n", ESP.getFreeHeap());

object_t reqIdObj, syncStatusObj, internalTempObj, externalTempObj, humidityObj, timestampObj, json;
JsonWriter writer;

writer.create(reqIdObj, "requestId", string_t(requestId));
writer.create(syncStatusObj, "syncStatus", false);
writer.create(internalTempObj, "internalTemp", number_t(internalTemp, 2));
writer.create(externalTempObj, "externalTemp", number_t(externalTemp, 2));
writer.create(humidityObj, "humidity", number_t(humidity, 2));

char firestoreTimestamp[30];
getFirestoreTimestampUTC(timeClient.getEpochTime(), firestoreTimestamp, sizeof(firestoreTimestamp));
writer.create(timestampObj, "timestamp", string_t(firestoreTimestamp));

writer.join(json, 6, reqIdObj, syncStatusObj, internalTempObj, externalTempObj, humidityObj, timestampObj);

String path = "/sync/" + String(requestId);
Serial.printf("🔥 RTDB Update Path: %s\n", path.c_str());

database.update(asyncClientGeneral, path.c_str(), json, asyncCB, "updateTask");
}

void streamTimeoutCallback(bool timeout) {
if (timeout) {
DPRINTLN("Stream timeout, újrapróbálás...");
}
}

void setup() {
Serial.begin(115200);
Wire.begin();
delay(100);

sslClientRTDB.setBufferSizes(4096, 1024); // 4096 for RX, 1024 for TX
sslClientFirestore.setBufferSizes(4096, 1024);

if (!display.begin(SSD1306_SWITCHCAPVCC, 0x3C)) {
DPRINTLN(F("SSD1306 hiba!"));
for (;;)
;
}
display.clearDisplay();
display.display();
display.setCursor(0, 0);
display.setTextSize(1);
display.setTextColor(SSD1306_WHITE);
display.println(F("Csatlakozás a WiFihez..."));
display.display();

WiFi.disconnect(true);
WiFi.mode(WIFI_STA);
IPAddress staticIP(192, 168, 0, 103);
IPAddress gateway(192, 168, 0, 1);
IPAddress subnet(255, 255, 255, 0);
IPAddress dns(8, 8, 8, 8);
WiFi.config(staticIP, gateway, subnet, dns);
WiFi.begin(WIFI_SSID, WIFI_PASSWORD);

int maxAttempts = 40;
while (WiFi.status() != WL_CONNECTED && maxAttempts > 0) {
DPRINT(".");
delay(250);
maxAttempts--;
}
if (WiFi.status() != WL_CONNECTED) {
DPRINTLN();
DPRINTLN(F("❌ WiFi nem elérhető, újraindítás..."));
ESP.restart();
}
DPRINTLN();
DPRINTLN(F("✅ WiFi OK!"));
DPRINT(F("📡 IP: "));
DPRINTLN(WiFi.localIP());

display.clearDisplay();
display.setCursor(0, 0);
display.println(F("WiFi OK!"));
display.drawBitmap(112, 0, wifiIcon8x8, 8, 8, SSD1306_WHITE);
display.setCursor(0, 16);
display.print(F("📡 IP: "));
display.println(WiFi.localIP());
display.display();
delay(1500);

timeClient.begin();
timeClient.setTimeOffset(3600);
ds18b20.begin();
dht.begin();

initializeFirebase();
DPRINTLN(F("🔥 Firebase hitelesítés..."));
if (!verifyUser(FIREBASE_API_KEY, FIREBASE_USER_EMAIL, FIREBASE_USER_PASSWORD)) {
DPRINTLN("❌ Firebase hitelesítés SIKERTELEN! Ellenőrizd az API kulcsot és az e-mail/jelszót!");
} else {
DPRINTLN("✅ Firebase hitelesítés SIKERES!");
}
if (app.ready()) {
DPRINTLN(F("✅ Firebase KÉSZ!"));
DPRINT(F("🔑 Token: "));
DPRINTLN(app.getToken());
DPRINT(F("⏳ TTL: "));
DPRINTLN(app.ttl());
} else {
DPRINTLN(F("❌ Firebase inicializáció SIKERTELEN! Ellenőrizd a hitelesítési adatokat."));
}
DPRINTLN(F("🔹 Setup KÉSZ."));
delay(2000);
lastSampleMillis = millis() - SAMPLE_INTERVAL_MS;
pinMode(VIBRATION_SENSOR_PIN, INPUT);
attachInterrupt(digitalPinToInterrupt(VIBRATION_SENSOR_PIN), handleVibrationInterrupt, RISING);
lastDisplayOnTime = millis();
}

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

static unsigned long lastHeapPrint = 0;
if (millis() - lastHeapPrint > 5000) {
lastHeapPrint = millis();
Serial.Print("💾 Szabad heap memória: %d bajt\n", ESP.getFreeHeap());
}

static unsigned long lastWiFiCheck = 0;
if (millis() - lastWiFiCheck > 5000) {
lastWiFiCheck = millis();
if (WiFi.status() != WL_CONNECTED) {
DPRINTLN("WiFi reconnecting...");
WiFi.reconnect();
}
}

if (vibrationDetected) {
vibrationDetected = false;
if (!displayActive) {
displayActive = true;
display.ssd1306_command(SSD1306_DISPLAYON);
timeClient.update();
unsigned long ep = timeClient.getEpochTime();
time_t raw = (time_t)ep;
struct tm* tinfo = localtime(&raw);
char buf[20];
strftime(buf, sizeof(buf), "%Y.%m.%d %H:%M", tinfo);
drawDisplay(buf);
lastDisplayOnTime = millis();
}
}

static unsigned long livePrev = 0;
if (millis() - livePrev >= 1000) {
livePrev = millis();
ds18b20.requestTemperatures();
float liInt = ds18b20.getTempCByIndex(0);
if (liInt == DEVICE_DISCONNECTED_C)
liInt = dispInternal / 10.0;
float liExt = dht.readTemperature();
if (isnan(liExt))
liExt = dispExternal / 10.0;
float liHum = dht.readHumidity();
if (isnan(liHum))
liHum = dispHumidity;
dispInternal = (int16_t)(liInt * 10);
dispExternal = (int16_t)(liExt * 10);
dispHumidity = (int16_t)(liHum);
timeClient.update();
unsigned long ep = timeClient.getEpochTime();
time_t raw = (time_t)ep;
struct tm* tinfo = localtime(&raw);
char buf[20];
strftime(buf, sizeof(buf), "%Y.%m.%d %H:%M", tinfo);
if (displayActive) {
drawDisplay(buf);
}
}

if (millis() - lastSampleMillis >= SAMPLE_INTERVAL_MS) {
lastSampleMillis = millis();
// Directly upload the current measurement to Firestore:
uploadMeasurementToFirestore();
}

static unsigned long lastDisplayCheck = millis();
if (displayActive && (millis() - lastDisplayOnTime >= 15000)) {
displayActive = false;
display.ssd1306_command(SSD1306_DISPLAYOFF);
}
}

There is a serial monitor:
⏳ TTL: 3297
🔹 Setup KÉSZ.
💾 Szabad heap memória: 18552 bajt
Starting Firestore upload...
RSSI: -68
WiFi Status: 3
Uploading with timestamp: 2025-02-19T15:12:28Z
📄 Measurement uploaded: timestamp: 2025-02-19T15:12:28Z, internalTemp: 22.6, externalTemp: 0.0, humidity: 0.0
----- 🔥 RAW STREAM PAYLOAD 🔥 -----
event: put
data: {"path":"/","data":null}

----- END OF PAYLOAD -----
✅ Extracted JSON Data:
{"path":"/","data":null}
⚠️ Stream callback: No requestId found in JSON.
✅ Firestore: Upload successful.
💾 Szabad heap memória: 8576 bajt
💾 Szabad heap memória: 8576 bajt
💾 Szabad heap memória: 8576 bajt
----- 🔥 RAW STREAM PAYLOAD 🔥 -----

event: put
data: {"path":"/-OJTYSOI1900giBcTy76","data":{"requestId":"-OJTYSOI1900giBcTy76","syncStatus":true,"timestamp":"2025-02-19T14:12:46Z"}}

----- END OF PAYLOAD -----
✅ Extracted JSON Data:
{"path":"/-OJTYSOI1900giBcTy76","data":{"requestId":"-OJTYSOI1900giBcTy76","syncStatus":true,"timestamp":"2025-02-19T14:12:46Z"}}
🗑️ Deleting old sync requests...
✅ Keeping only latest sync document: -OJTYSOI1900giBcTy76
📤 RTDB: Sending updated values, Heap: 3536 bytes
🔥 RTDB Update Path: /sync/-OJTYSOI1900giBcTy76
----- 🔥 RAW STREAM PAYLOAD 🔥 -----

event: put
data: {"path":"/","data":null}

----- END OF PAYLOAD -----
✅ Extracted JSON Data:
{"path":"/","data":null}
⚠️ Stream callback: No requestId found in JSON.
----- 🔥 RAW STREAM PAYLOAD 🔥 -----

event: patch
data: {"path":"/-OJTYSOI1900giBcTy76","data":{"syncStatus":true}}

----- END OF PAYLOAD -----
✅ Extracted JSON Data:
{"path":"/-OJTYSOI1900giBcTy76","data":{"syncStatus":true}}
⚠️ Stream callback: No requestId found in JSON.
----- 🔥 RAW STREAM PAYLOAD 🔥 -----

event: patch
data: {"path":"/-OJTYSOI1900giBcTy76","data":{"timestamp":"2025-02-19T15:12:47Z","syncStatus":false,"humidity":0.0,"externalTemp":0.0,"internalTemp":22.81,"requestId":"-OJTYSOI1900giBcTy76"}}

----- END OF PAYLOAD -----
✅ Extracted JSON Data:
{"path":"/-OJTYSOI1900giBcTy76","data":{"timestamp":"2025-02-19T15:12:47Z","syncStatus":false,"humidity":0.0,"externalTemp":0.0,"internalTemp":22.81,"requestId":"-OJTYSOI1900giBcTy76"}}
✅ Stream detected new requestId: -OJTYSOI1900giBcTy76
🗑️ Deleting old sync requests...

User exception (panic/abort/assert)
--------------- CUT HERE FOR EXCEPTION DECODER ---------------

Unhandled C++ exception: OOM

stack>>>

ctx: cont
sp: 3fff2930 end: 3fff2e60 offset: 0010

Thank you for your help, and sorry for my noob questions, I'ma newbie. I have the memory settings as in your read me.
Thanky,

mobizt · 2025-02-19T14:36:09Z

mobizt
Feb 19, 2025
Maintainer

You said that you never set the buffer size in ESP8266 WiFiClientSecure which is not possible to get two SSL clients run simultaneously.

No matter which library you used e.g. Firebase, HTTP client and MQTT client, you can't get more than one SSL client to work without adjusting the BearSSL buffer size.

After you set the BearSSL buffer size lower, you can run two or more SSL clients simultaneously by keeping the TCP session alive with the MMU option 3, 16KB cache + 48KB IRAM and 2nd Heap (shared).

The free heap available in your application is too low, only 8k which leads to system task failure and wdt reset crashed. It should have at least 10k free memory.

You have to manage your memory usage in your application.

0 replies

mobizt · 2025-02-19T14:50:27Z

mobizt
Feb 19, 2025
Maintainer

You should remove your code for printing any large payload as it causes stack overflow too.

It should be noted that you don't have enough memory to adapt your Firestore code in your application because of limited memory nearly 30k with blank sketch.

I often said about this in the old Firebase library about the risk of ESP8266 when works with Firestore which its payload required large buffer memory to handle.

You should consider using ESP32 or RaspberryPi Zero W or Arduino MKR devices.

0 replies

matehubert · 2025-02-19T16:21:51Z

matehubert
Feb 19, 2025
Author

Dear Mobizt!
Thank you so much for your help, and for your time! I'll try to optimze my code, and if it doesnt work I'm going to switch to ESP32.

0 replies

Uh oh!

Using RTDB and Firebase database in the sam time #224

Uh oh!

Uh oh!

matehubert Feb 18, 2025

Replies: 6 comments · 5 replies

Uh oh!

eXtr3me26 Feb 18, 2025

Uh oh!

matehubert Feb 18, 2025 Author

Uh oh!

eXtr3me26 Feb 18, 2025

Uh oh!

eXtr3me26 Feb 18, 2025

Uh oh!

matehubert Feb 19, 2025 Author

Uh oh!

mobizt Feb 19, 2025 Maintainer

Uh oh!

mobizt Feb 19, 2025 Maintainer

Uh oh!

Uh oh!

matehubert Feb 19, 2025 Author

Uh oh!

mobizt Feb 19, 2025 Maintainer

Uh oh!

mobizt Feb 19, 2025 Maintainer

Uh oh!

matehubert Feb 19, 2025 Author

matehubert
Feb 18, 2025

Replies: 6 comments 5 replies

eXtr3me26
Feb 18, 2025

matehubert Feb 18, 2025
Author

matehubert Feb 19, 2025
Author

mobizt
Feb 19, 2025
Maintainer

mobizt
Feb 19, 2025
Maintainer

matehubert Feb 19, 2025
Author

mobizt
Feb 19, 2025
Maintainer

mobizt
Feb 19, 2025
Maintainer

matehubert
Feb 19, 2025
Author