Fix TCP session issue.

library.json

@@ -1,6 +1,6 @@
 {
   "name": "FirebaseClient",
-  "version": "1.0.11",
+  "version": "1.0.12",
   "keywords": "communication, REST, esp32, esp8266, arduino",
   "description": "Async Firebase Client library for Arduino.",
   "repository": {

library.properties

@@ -1,6 +1,6 @@
 name=FirebaseClient
 
-version=1.0.11
+version=1.0.12
 
 author=Mobizt
 

src/FirebaseClient.h

@@ -30,7 +30,7 @@
 #undef FIREBASE_CLIENT_VERSION
 #endif
 
-#define FIREBASE_CLIENT_VERSION "1.0.11"
+#define FIREBASE_CLIENT_VERSION "1.0.12"
 
 #include <Arduino.h>
 #include "./core/FirebaseApp.h"

src/core/AsyncClient/AsyncClient.h

@@ -1,5 +1,5 @@
 /**
- * Created April 6, 2024
+ * Created April 7, 2024
  *
  * For MCU build target (CORE_ARDUINO_XXXX), see Options.h.
  *
@@ -47,15 +47,6 @@
 
 using namespace firebase;
 
-__attribute__((unused)) static void meminfo(int pos)
-{
-#if defined(ESP8266)
-    Serial.printf("Pos: %d, Heap: %d, Stack: %d\n", pos, ESP.getFreeHeap(), ESP.getFreeContStack());
-#elif defined(ESP32)
-    Serial.printf("Pos: %d, Heap: %d\n", pos, ESP.getFreeHeap());
-#endif
-}
-
 enum async_state
 {
     async_state_undefined,
@@ -197,6 +188,8 @@ class AsyncClientClass
 #endif
     async_request_handler_t::tcp_client_type client_type = async_request_handler_t::tcp_client_type_sync;
     bool sse = false;
+    String host;
+    uint16_t port;
     std::vector<uint32_t> sVec;
     Memory mem;
     Base64Util but;
@@ -232,6 +225,13 @@ class AsyncClientClass
         return true;
     }
 
+    void newCon(async_data_item_t *sData, const char *host, uint16_t port)
+    {
+        if ((sse && !sData->sse) || (!sse && sData->sse) || (sData->auth_used && sData->state == async_state_undefined) ||
+            strcmp(this->host.c_str(), host) != 0 || this->port != port)
+            stop(sData);
+    }
+
     function_return_type sendHeader(async_data_item_t *sData, const char *data)
     {
         return send(sData, (uint8_t *)data, data ? strlen(data) : 0, data ? strlen(data) : 0, async_state_send_header);
@@ -504,8 +504,7 @@ class AsyncClientClass
 
         if (sData->state == async_state_undefined || sData->state == async_state_send_header)
         {
-            if ((sse && !sData->sse) || (!sse && sData->sse) || (sData->auth_used && sData->state == async_state_undefined))
-                stop(sData);
+            newCon(sData, getHost(sData, true).c_str(), sData->request.port);
 
             if ((client_type == async_request_handler_t::tcp_client_type_sync && !client->connected()) || client_type == async_request_handler_t::tcp_client_type_async)
             {
@@ -1314,6 +1313,8 @@ class AsyncClientClass
 #endif
         }
 
+        this->host = host;
+        this->port = port;
         return sData->return_type;
     }
 
@@ -1870,6 +1871,9 @@ class AsyncClientClass
                 async_tcp_config->tcpStop();
 #endif
         }
+
+        clear(host);
+        port = 0;
     }
 
     FirebaseError lastError() const { return lastErr; }