added mqtt to the example

Author: wassfila

09_esp_now/data/config.json

@@ -1,8 +1,13 @@
 {
     "wifi":{
-        "mode":"STA",
+        "mode":"AP",
         "channel":1
     },
     "espnow":{
+    },
+    "mqtt" : {
+        "host":"10.0.0.42",
+        "port":1883,
+        "client_id":"esp_test3_now"
     }
 }

09_esp_now/platformio.ini

@@ -4,6 +4,7 @@ framework = arduino
 lib_deps =
     [email protected]
     [email protected]
+    [email protected]   #MQTT 256dpi/arduino-mqtt
 lib_ldf_mode = deep+
 [env:esp32dev]
 platform = [email protected]

09_esp_now/src/main.cpp

@@ -1,11 +1,15 @@
 #include <Arduino.h>
 #include <ArduinoJson.h>
+#include <WiFi.h>
+#include <MQTT.h>
 
 #include <ConfigUtils.h>
 #include <EspNowWrapper.h>
 
 DynamicJsonDocument config(5*1024);//5 KB
 DynamicJsonDocument secret(1*1024);//1 KB
+MQTTClient mqtt(1*1024);
+WiFiClient wifi;//needed to stay on global scope
 NowApp espnow;
 
 uint32_t cycle_count = 0;
@@ -14,6 +18,13 @@ void meshMessage(String &payload,String from){
   Serial.printf("RX> from(%s) => [%s]\n",from.c_str(),payload.c_str());
 }
 
+void mqtt_start(DynamicJsonDocument &config){
+  mqtt.begin(config["mqtt"]["host"],config["mqtt"]["port"], wifi);
+  if(mqtt.connect(config["mqtt"]["client_id"])){
+    Serial.println("mqtt>connected");
+  }
+}
+
 void setup() {
 
   Serial.begin(115200);
@@ -23,6 +34,18 @@ void setup() {
   load_json(secret,"/secret.json");
   timelog("config loaded");
 
+  String ssid = secret["wifi"]["access_point"];
+  String pass = secret["wifi"]["password"];
+  WiFi.begin(ssid.c_str(),pass.c_str());
+  while (WiFi.status() != WL_CONNECTED) {
+    Serial.print(".");
+    delay(1000);
+  }
+  timelog("config loaded");
+  mqtt_start(config);
+  mqtt.publish("espnow","test");
+  mqtt.loop();
+
   espnow.start(config,secret);
   espnow.onMessage(meshMessage);
 
@@ -34,6 +57,8 @@ void loop() {
   cycle_count++;
   Serial.printf("\n\n");
   timelog("loop start cycle ("+String(cycle_count)+")");
+  mqtt.publish("espnow","Mqtt("+String(cycle_count)+")");
+  delay(1000);
   espnow.print_info();
   espnow.broadcast("Hello Everyone ("+String(cycle_count)+")");
   delay(5000);