Fix undefined error in mqtt implemetation

absmach · Jan 13, 2025 · 82937a0 · 82937a0
1 parent 5809dba
commit 82937a0
Show file tree

Hide file tree

Showing 4 changed files with 245 additions and 243 deletions.
diff --git a/embed-proplet/prj.conf b/embed-proplet/prj.conf
@@ -54,12 +54,12 @@ CONFIG_NET_STATISTICS=y
 CONFIG_NET_STATISTICS_PERIODIC_OUTPUT=n
 
 # Thread Analyzer
-CONFIG_THREAD_NAME=y
-CONFIG_THREAD_ANALYZER=y
-CONFIG_THREAD_ANALYZER_AUTO=y
+CONFIG_THREAD_NAME=n
+CONFIG_THREAD_ANALYZER=n
+CONFIG_THREAD_ANALYZER_AUTO=n
 CONFIG_THREAD_ANALYZER_AUTO_INTERVAL=5
-CONFIG_THREAD_ANALYZER_LOG_LEVEL_DBG=y
-CONFIG_THREAD_ANALYZER_ISR_STACK_USAGE=y
+CONFIG_THREAD_ANALYZER_LOG_LEVEL_DBG=n
+CONFIG_THREAD_ANALYZER_ISR_STACK_USAGE=n
 
 # Miscellaneous
 CONFIG_MAIN_STACK_SIZE=8192

diff --git a/embed-proplet/src/main.c b/embed-proplet/src/main.c
@@ -1,14 +1,14 @@
 #include <zephyr/kernel.h>
 #include <zephyr/logging/log.h>
 #include "wifi_manager.h"
-// #include "mqtt_client.h"
+#include "mqtt_client.h"
 
 LOG_MODULE_REGISTER(main);
 
-#define WIFI_SSID "YourSSID"
-#define WIFI_PSK  "YourPassword"
-// #define PROPLET_ID "proplet-esp32s3"
-// #define CHANNEL_ID "default_channel"
+#define WIFI_SSID "Octavifi"
+#define WIFI_PSK  "Unic0rn_2030"
+#define PROPLET_ID "proplet-esp32s3"
+#define CHANNEL_ID "default_channel"
 
 void main(void)
 {
@@ -24,30 +24,30 @@ void main(void)
         return;
     }
 
-    // /* Initialize and connect MQTT client */
-    // ret = mqtt_client_init_and_connect();
-    // if (ret != 0) {
-    //     LOG_ERR("Failed to initialize MQTT client, exiting");
-    //     return;
-    // }
-
-    // /* Announce discovery */
-    // ret = mqtt_client_discovery_announce(PROPLET_ID, CHANNEL_ID);
-    // if (ret != 0) {
-    //     LOG_ERR("Failed to publish discovery announcement, exiting");
-    //     return;
-    // }
-
-    // /* Subscribe to topics */
-    // ret = mqtt_client_subscribe(CHANNEL_ID);
-    // if (ret != 0) {
-    //     LOG_ERR("Failed to subscribe to topics, exiting");
-    //     return;
-    // }
-
-    // /* Main loop for processing MQTT events */
-    // while (1) {
-    //     mqtt_client_process(); /* Process MQTT events */
-    //     k_sleep(K_SECONDS(5)); /* Sleep for a while */
-    // }
+    /* Initialize and connect MQTT client */
+    ret = mqtt_client_init_and_connect();
+    if (ret != 0) {
+        LOG_ERR("Failed to initialize MQTT client, exiting");
+        return;
+    }
+
+    /* Announce discovery */
+    ret = mqtt_client_discovery_announce(PROPLET_ID, CHANNEL_ID);
+    if (ret != 0) {
+        LOG_ERR("Failed to publish discovery announcement, exiting");
+        return;
+    }
+
+    /* Subscribe to topics */
+    ret = mqtt_client_subscribe(CHANNEL_ID);
+    if (ret != 0) {
+        LOG_ERR("Failed to subscribe to topics, exiting");
+        return;
+    }
+
+    /* Main loop for processing MQTT events */
+    while (1) {
+        mqtt_client_process(); /* Process MQTT events */
+        k_sleep(K_SECONDS(5)); /* Sleep for a while */
+    }
 }