Dodać klienta mqtt

lib/mqtt_client/mqtt_client.cpp

@@ -0,0 +1,48 @@
+#include "mqtt_client.h"
+
+MQTTClient::MQTTClient() : PubSubClient(this->wifi_client){
+
+    // const char* mqtt_server = MQTT_SERVER_IP;
+    // unsigned long lastMsg = 0;
+    // char msg[MSG_BUFFER_SIZE];
+    // int value = 0;
+}
+
+void MQTTClient::setup() {
+    setServer(MQTT_SERVER_IP, MQTT_SERVER_PORT);
+    setCallback(this->callback);
+}
+
+
+
+void MQTTClient::callback(char* topic, byte* payload, unsigned int length) {
+  Serial.print("Message arrived [");
+  Serial.print(topic);
+  Serial.print("] ");
+  for (int i = 0; i < length; i++) {
+    Serial.print((char)payload[i]);
+  }
+  Serial.println();
+}
+
+void MQTTClient::assureConnection() {
+    if (!connected()) reconnect();
+}
+
+void MQTTClient::reconnect() {
+
+  // Loop until we're reconnected
+    while (!connected()) {
+        Serial.print("Attempting MQTT connection...");
+
+    if (connect(MQTT_CLIENT_ID)) {
+        Serial.println("connected");
+    } else {
+        Serial.print(" failed, rc=");
+        Serial.print(state());
+        Serial.println(" retry in 3 seconds");
+        // Wait 3 seconds before retrying
+        delay(3000);
+    }
+  }
+}

lib/mqtt_client/mqtt_client.h

@@ -0,0 +1,26 @@
+#include <ESP8266WiFi.h>
+#include <PubSubClient.h>
+
+#define MQTT_SERVER_IP "192.168.1.100"
+#define MQTT_SERVER_PORT 1883
+#define MQTT_CLIENT_ID "SynerMycha"
+#define MSG_BUFFER_SIZE	(50)
+
+
+class MQTTClient : public PubSubClient {
+    public:
+        MQTTClient();
+
+        const char* mqtt_server;
+
+        void setup();
+        void reconnect();
+        void assureConnection();
+
+    private:
+    //     WiFiManager wifiManager;
+        WiFiClient wifi_client;
+
+        static void callback(char* topic, byte* payload, unsigned int length);
+
+};

lib/wifi/wifi.h

@@ -1,4 +1,4 @@
-#include <ESP8266WiFi.h>
+// #include <ESP8266WiFi.h>
 #include <WiFiManager.h>
 
 #define SSID "SynerMycha"

src/main.cpp

@@ -1,16 +1,29 @@
 #include "wifi.h"
-
-#include <WiFiManager.h>
-#include <PubSubClient.h>
+#include "mqtt_client.h"
 
 WIFI wifi;
+MQTTClient mqtt_client;
 
 void setup() {
+  pinMode(LED_BUILTIN, OUTPUT); 
   Serial.begin(9600);
   wifi.setup();
-
+  mqtt_client.setup();
 }
 
+
 void loop() {
+  mqtt_client.assureConnection();
+  mqtt_client.loop();
+
+  // unsigned long now = millis();
+  // if (now - lastMsg > 2000) {
+  //   lastMsg = now;
+  //   ++value;
+  //   snprintf (msg, MSG_BUFFER_SIZE, "hello world #%ld", value);
+  //   Serial.print("Publish message: ");
+  //   Serial.println(msg);
+  //   client.publish("outTopic", msg);
+  // }
 
 }