Adapt for usage with LibreTuya

libretiny-eu · Jan 19, 2023 · a659596 · a659596
1 parent 1dacb48
commit a659596
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 3 deletions.
diff --git a/src/AsyncMqttClient.cpp b/src/AsyncMqttClient.cpp
@@ -41,6 +41,9 @@ AsyncMqttClient::AsyncMqttClient()
   _xSemaphore = xSemaphoreCreateMutex();
 #elif defined(ESP8266)
   sprintf(_generatedClientId, "esp8266-%06x", ESP.getChipId());
+#elif defined(LIBRETUYA)
+  sprintf(_generatedClientId, "lt-%06x", LT.getChipId());
+  _xSemaphore = xSemaphoreCreateMutex();
 #endif
   _clientId = _generatedClientId;
 
@@ -50,7 +53,7 @@ AsyncMqttClient::AsyncMqttClient()
 AsyncMqttClient::~AsyncMqttClient() {
   delete _currentParsedPacket;
   delete[] _parsingInformation.topicBuffer;
-#ifdef ESP32
+#if defined(ESP32) || defined(LIBRETUYA)
   vSemaphoreDelete(_xSemaphore);
 #endif
 }

diff --git a/src/AsyncMqttClient.hpp b/src/AsyncMqttClient.hpp
@@ -10,6 +10,9 @@
 #include <freertos/semphr.h>
 #elif defined(ESP8266)
 #include <ESPAsyncTCP.h>
+#elif defined(LIBRETUYA)
+#include <AsyncTCP.h>
+#include <semphr.h>
 #else
 #error Platform not supported
 #endif
@@ -38,7 +41,7 @@
 #include "AsyncMqttClient/Packets/PubRecPacket.hpp"
 #include "AsyncMqttClient/Packets/PubCompPacket.hpp"
 
-#if ESP32
+#if ESP32 || defined(LIBRETUYA)
 #define SEMAPHORE_TAKE(X) if (xSemaphoreTake(_xSemaphore, 1000 / portTICK_PERIOD_MS) != pdTRUE) { return X; }  // Waits max 1000ms
 #define SEMAPHORE_GIVE() xSemaphoreGive(_xSemaphore);
 #elif defined(ESP8266)
@@ -132,7 +135,7 @@ class AsyncMqttClient {
 
   std::vector<AsyncMqttClientInternals::PendingAck> _toSendAcks;
 
-#ifdef ESP32
+#if defined(ESP32) || defined(LIBRETUYA)
   SemaphoreHandle_t _xSemaphore = nullptr;
 #endif