модуль БрокерMqtt (picoMqtt)

src/modules/exec/BrokerMQTT/BrokerMQTT.cpp

@@ -0,0 +1,158 @@
+#include "Global.h"
+#include "classes/IoTItem.h"
+#include <Arduino.h>
+#include <PicoMQTT.h>
+
+namespace _Broker
+{
+#define DEF_PORT 1883
+
+    class myPicoMQTT : public PicoMQTT::Server
+    {
+    private:
+        bool _debug;
+
+    public:
+        myPicoMQTT(int port) : PicoMQTT::Server(port)
+        {
+        }
+
+        void setDebug(bool debug)
+        {
+            _debug = debug;
+        }
+
+    protected:
+        void on_connected(const char *client_id)
+        {
+            if (_debug)
+            {
+                Serial.print("[BrokerMQTT], Client connected: ");
+                Serial.println(client_id);
+            }
+        }
+        void on_disconnected(const char *client_id)
+        {
+            if (_debug)
+
+            {
+                // SerialPrint("i", "BrokerMQTT", "Client disconnected: " + client_id);
+                Serial.print("[BrokerMQTT], Client disconnected: ");
+                Serial.println(client_id);
+            }
+        }
+        void on_subscribe(const char *client_id, const char *topic)
+        {
+            if (_debug)
+
+            {
+                // SerialPrint("i", "BrokerMQTT", "Client " + client_id + ", subscribe: " + topic);
+                Serial.print("[BrokerMQTT], Client: ");
+                Serial.print(client_id);
+                Serial.print(", subscribe: ");
+                Serial.println(topic);
+            }
+        }
+        void on_unsubscribe(const char *client_id, const char *topic)
+        {
+            if (_debug)
+
+            {
+                // SerialPrint("i", "BrokerMQTT", "Client " + client_id + ", unsubscribe: " + topic);
+                Serial.print("[BrokerMQTT], Client: ");
+                Serial.print(client_id);
+                Serial.print(", unsubscribe: ");
+                Serial.println(topic);
+            }
+        }
+    };
+    // MqttBroker broker(1883);
+    myPicoMQTT *picoMqtt = nullptr;
+
+    myPicoMQTT *instanceBroker(int port)
+    {
+        if (!picoMqtt)
+        {
+            picoMqtt = new myPicoMQTT(port);
+            // ot->begin();
+        }
+        return picoMqtt;
+    }
+
+    TaskHandle_t brokerTask;
+    // void Task2code( void * pvParameters );
+
+    void tBrokerMQTT(void *pvParameters)
+    {
+        TickType_t xLastWakeTime = xTaskGetTickCount();
+        Serial.print("Task PicoMQTT running on core ");
+        Serial.println(xPortGetCoreID());
+        for (;;)
+        {
+            instanceBroker(DEF_PORT)->loop();
+            // picoMqtt.loop();
+            // vTaskDelayUntil(&xLastWakeTime, pdMS_TO_TICKS(5));
+        }
+    }
+
+    class BrokerMQTT : public IoTItem
+    {
+    private:
+        unsigned long ts = 0;
+        int _port = 0;
+        bool _debug;
+
+    public:
+        BrokerMQTT(String parameters) : IoTItem(parameters)
+        {
+            SerialPrint("i", F("BrokerMQTT"), " START...   ");
+            jsonRead(parameters, "port", _port);
+            jsonRead(parameters, "debug", _debug);
+        }
+
+        void doByInterval()
+        {
+            static bool flagOne = false;
+            if (!flagOne)
+            {
+                if (!_port)
+                    _port = DEF_PORT;
+                instanceBroker(_port)->begin();
+                instanceBroker(_port)->setDebug(_debug);
+                // picoMqtt.begin();
+                xTaskCreatePinnedToCore(
+                    tBrokerMQTT,  // Функция задачи.
+                    "BrokerMQTT", // Имя задачи.
+                    10000,        // Размер стека
+                    NULL,         // Параметры задачи
+                    0,            // Приоритет
+                    &brokerTask,  // Дескриптор задачи для отслеживания
+                    0);
+                flagOne = true;
+            }
+        }
+
+        // Основной цикл программы
+        void loop()
+        {
+            IoTItem::loop();
+        }
+
+        ~BrokerMQTT()
+        {
+            // delete picoMqtt;
+        }
+    };
+}
+
+void *getAPI_BrokerMQTT(String subtype, String param)
+{
+    if (subtype == F("BrokerMQTT"))
+    {
+        return new _Broker::BrokerMQTT(param);
+    }
+    else
+    {
+        return nullptr;
+    }
+}

src/modules/exec/BrokerMQTT/modinfo.json

@@ -0,0 +1,42 @@
+{
+  "menuSection": "executive_devices",
+  "configItem": [
+    {
+      "global": 0,
+      "name": "BrokerMQTT",
+      "type": "Reading",
+      "subtype": "BrokerMQTT",
+      "id": "broker",
+      "widget": "",
+      "page": "",
+      "descr": "",
+      "int": 10,
+      "value": "",
+      "port": 1883,
+      "debug": 1
+    }
+  ],
+  "about": {
+    "authorName": "Mikhail Bubnov",
+    "authorContact": "https://t.me/Mit4bmw",
+    "authorGit": "https://github.com/Mit4el",
+    "specialThanks": "Андрей Душин",
+    "moduleName": "BrokerMQTT",
+    "moduleVersion": "0.1",
+    "usedRam": {
+      "esp32_4mb": 15,
+      "esp8266_4mb": 15
+    },
+    "title": "BrokerMQTT",
+    "moduleDesc": "MQTT Брокер на основе Pico Mqtt",
+    "propInfo": {
+      "port":"Порт, по умолчанию 1883"
+    }
+  },
+  "defActive": true,
+  "usedLibs": {
+    "esp32_4mb3f": [],
+    "esp32*": [],
+    "esp82*": []
+  }
+}