MQTT Implementation and HiveMQ connection

src/CMakeLists.txt

@@ -39,5 +39,7 @@ idf_build_set_property(COMPILE_OPTIONS "-Wno-format-nonliteral;-Wno-format-secur
 #
 # See https://gcc.gnu.org/bugzilla/show_bug.cgi?id=80635
 idf_build_set_property(COMPILE_OPTIONS "-Wno-error=maybe-uninitialized" APPEND)
+target_add_binary_data(matterHub.elf "main/mqtt_hivemq.pem" TEXT)
+
 
 flashing_script()

src/main/CMakeLists.txt

@@ -9,6 +9,7 @@ idf_component_register(PRIV_INCLUDE_DIRS
                       "${CMAKE_SOURCE_DIR}/third_party/connectedhomeip/zzz_generated/light-switch-app"
                       "${CMAKE_CURRENT_LIST_DIR}/include"
                       "${CMAKE_SOURCE_DIR}/third_party/connectedhomeip/examples/platform/esp32"
+                      "${CMAKE_SOURCE_DIR}/third_party/connectedhomeip/zzz_generated/app-common/app-common/zap-generated/ids"
                       SRC_DIRS
                       "${CMAKE_CURRENT_LIST_DIR}"
                       "${CMAKE_SOURCE_DIR}/third_party/connectedhomeip/zzz_generated/app-common/app-common/zap-generated/attributes"
@@ -47,7 +48,8 @@ idf_component_register(PRIV_INCLUDE_DIRS
                       "${CMAKE_SOURCE_DIR}/third_party/connectedhomeip/src/app/clusters/ota-requestor"
                       "${CMAKE_SOURCE_DIR}/third_party/connectedhomeip/src/app/clusters/groups-server"
                       "${CMAKE_SOURCE_DIR}/third_party/connectedhomeip/src/app/clusters/group-key-mgmt-server"
-                      PRIV_REQUIRES chip QRCode bt app_update)
+                      PRIV_REQUIRES mqtt chip QRCode bt app_update json)
+
 
 set_property(TARGET ${COMPONENT_LIB} PROPERTY CXX_STANDARD 17)
 target_compile_options(${COMPONENT_LIB} PRIVATE "-DLWIP_IPV6_SCOPES=0" "-DCHIP_HAVE_CONFIG_H")

src/main/InteractionModel.cpp

@@ -17,6 +17,7 @@
  */
 
 #include "InteractionModel.h"
+#include "esp_log.h"
 
 using namespace chip;
 using namespace chip::app;
@@ -100,11 +101,13 @@ void InteractionModel::Shutdown()
 /////////// ReadClient Callback Interface /////////
 void InteractionModel::OnAttributeData(const ConcreteDataAttributePath & path, TLV::TLVReader * data, const StatusIB & status)
 {
+    ESP_LOGE("ATTRIBUTE DATA", "EndpointId: %x", path.mEndpointId);
     OnResponse(status, data);
 }
 
 void InteractionModel::OnEventData(const EventHeader & eventHeader, TLV::TLVReader * data, const StatusIB * status)
 {
+    ESP_LOGE("ATTRIBUTE DATA", "Event Data");
     OnResponse(status == nullptr ? StatusIB() : *status, data);
 }
 

src/main/Kconfig.projbuild

@@ -73,3 +73,11 @@ menu "Demo"
        default 8 if RENDEZVOUS_MODE_ETHERNET
 
 endmenu
+menu "MQTT Configuration"
+    config MQTT_CLIENT_URI
+       string "MQTT URI"
+    config MQTT_CLIENT_USERNAME
+       string "MQTT Username"
+    config MQTT_CLIENT_PASSWORD
+	string "MQTT Password"
+endmenu

src/main/MQTTCommands.cpp

@@ -0,0 +1,141 @@
+/*
+ *    Published under MIT License
+ *    Copyright (c) 2022 OpenFogStack
+ *    Based on code written by Project CHIP Authors, which was published under Apache License, Version 2.0 (c) 2022
+ */
+#include "MQTTCommands.h"
+#include "MQTTManager.h"
+#include "app/server/Server.h"
+#include <lib/support/CodeUtils.h>
+
+#if CONFIG_ENABLE_CHIP_SHELL
+#include "lib/shell/Engine.h"
+#include "lib/shell/commands/Help.h"
+#endif // ENABLE_CHIP_SHELL
+
+using namespace chip;
+using namespace chip::app;
+
+#if CONFIG_ENABLE_CHIP_SHELL
+using Shell::Engine;
+using Shell::shell_command_t;
+using Shell::streamer_get;
+using Shell::streamer_printf;
+
+Engine sShellMQTTSubCommands;
+
+#endif // defined(ENABLE_CHIP_SHELL)
+
+static const char * TAG = "MQTT Commands";
+namespace shell {
+
+#ifdef CONFIG_ENABLE_CHIP_SHELL
+
+/********************************************************
+ * MQTT shell functions
+ *********************************************************/
+
+CHIP_ERROR MQTTHelpHandler(int argc, char ** argv)
+{
+    sShellMQTTSubCommands.ForEachCommand(Shell::PrintCommandHelp, nullptr);
+    return CHIP_NO_ERROR;
+}
+
+CHIP_ERROR MQTTCommandHandler(int argc, char ** argv)
+{
+    if (argc == 0)
+    {
+        return MQTTHelpHandler(argc, argv);
+    }
+
+    return sShellMQTTSubCommands.ExecCommand(argc, argv);
+}
+
+/********************************************************
+ * MQTT sub and pub shell functions
+ *********************************************************/
+
+CHIP_ERROR MQTTSubCommandHelpHandler(int argc, char ** argv)
+{
+    sShellMQTTSubCommands.ForEachCommand(Shell::PrintCommandHelp, nullptr);
+    return CHIP_NO_ERROR;
+}
+
+CHIP_ERROR MQTTSubHandler(int argc, char ** argv)
+{
+    if (argc != 1)
+    {
+        return MQTTSubCommandHelpHandler(argc, argv);
+    }
+    MQTTCommandData * data = Platform::New<MQTTCommandData>();
+    data->topic            = argv[0];
+    data->data             = NULL;
+    data->task             = MQTTCommandTask::subscribe;
+    DeviceLayer::PlatformMgr().ScheduleWork(MQTTCommandWorkerFunction, reinterpret_cast<intptr_t>(data));
+    return CHIP_NO_ERROR;
+}
+
+CHIP_ERROR MQTTUnsubHandler(int argc, char ** argv)
+{
+    if (argc != 1)
+    {
+        return MQTTSubCommandHelpHandler(argc, argv);
+    }
+    MQTTCommandData * data = Platform::New<MQTTCommandData>();
+    data->topic            = argv[0];
+    data->data             = NULL;
+    data->task             = MQTTCommandTask::unsubscribe;
+    DeviceLayer::PlatformMgr().ScheduleWork(MQTTCommandWorkerFunction, reinterpret_cast<intptr_t>(data));
+    return CHIP_NO_ERROR;
+}
+
+CHIP_ERROR MQTTPubHandler(int argc, char ** argv)
+{
+    if (argc != 2)
+    {
+        return MQTTSubCommandHelpHandler(argc, argv);
+    }
+    MQTTCommandData * data = Platform::New<MQTTCommandData>();
+    data->topic            = argv[0];
+    data->data             = argv[1];
+    data->task             = MQTTCommandTask::publish;
+    DeviceLayer::PlatformMgr().ScheduleWork(MQTTCommandWorkerFunction, reinterpret_cast<intptr_t>(data));
+    return CHIP_NO_ERROR;
+}
+
+#endif // ENABLE_CHIP_SHELL
+
+} // namespace shell
+
+namespace shell {
+void RegisterMQTTCommands()
+{
+    using namespace shell;
+    static const shell_command_t sMQTTSubCommands[] = { { &MQTTSubCommandHelpHandler, "help", "Usage: mqtt <subcommand>" },
+                                                        { &MQTTSubHandler, "sub", " Usage: cluster sub <topic>" },
+                                                        { &MQTTUnsubHandler, "unsub", " Usage: cluster unsub <topic>" },
+                                                        { &MQTTPubHandler, "pub", " Usage: cluster pub <topic> <data>" } };
+
+    static const shell_command_t sMQTTCommand = { &MQTTCommandHandler, "mqtt", "MQTT commands. Usage: mqtt <subcommand>" };
+
+    sShellMQTTSubCommands.RegisterCommands(sMQTTSubCommands, ArraySize(sMQTTSubCommands));
+
+    Engine::Root().RegisterCommands(&sMQTTCommand, 1);
+}
+
+void MQTTCommandWorkerFunction(intptr_t context)
+{
+    if (context == 0)
+    {
+        ChipLogError(NotSpecified, "MQTTCommandWorkerFunction - Invalid work data");
+        return;
+    }
+    shell::MQTTCommandData * data = reinterpret_cast<shell::MQTTCommandData *>(context);
+    ESP_LOGI(TAG, " - Topic: '%s'", data->topic);
+    if (data->data)
+    {
+        ESP_LOGI(TAG, " - Data: '%s'", data->data);
+    }
+    MQTTManager::GetInstance().ProcessCommand(data);
+}
+} // End namespace shell