#include <WiFi.h>
#include "PubSubClient.h"
#include "DHTesp.h"

const char * MQTTServer = "broker.emqx.io";
const char * MQTT_Topic = "TUAN";

// Tạo ID ngẫu nhiên tại: https://www.guidgen.com/
const char * MQTT_ID = "";
int Port = 1883;

WiFiClient espClient;
PubSubClient client(espClient);
const int ledPin = 2;

void WIFIConnect() {
Serial.println("Connecting to SSID: Wokwi-GUEST");
WiFi.begin("Wokwi-GUEST", "");
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(".");
}
Serial.println("");
Serial.print("WiFi connected");
Serial.print(", IP address: ");
Serial.println(WiFi.localIP());
}

void MQTT_Reconnect() {
while (!client.connected()) {
if (client.connect(MQTT_ID)) {
Serial.print("MQTT Topic: ");
Serial.print(MQTT_Topic);
Serial.print(" connected");
client.subscribe(MQTT_Topic);
Serial.println("");
} else {
Serial.print("failed, rc=");
Serial.print(client.state());
Serial.println(" try again in 5 seconds");
delay(5000);
}
}
}

void callback(char* topic, byte* message, unsigned int length) {
Serial.print("Message arrived on topic: ");
Serial.println(topic);
Serial.print("Message: ");
String stMessage;

for (int i = 0; i < length; i++) {
Serial.print((char)message[i]);
stMessage += (char)message[i];
}
Serial.println();
}

const int DHT_PIN = 15;

DHTesp dhtSensor;

void setup() {
Serial.begin(115200);

WIFIConnect();
client.setServer(MQTTServer, Port);
client.setCallback(callback);
dhtSensor.setup(DHT_PIN, DHTesp::DHT22);
}

float arr[3]={0,0,0};
int co=0;

void loop() {
TempAndHumidity data = dhtSensor.getTempAndHumidity();

if (!client.connected()) {
MQTT_Reconnect();
}
client.loop();

float tong=0;
if(co==0){
for(int i=0;i<3;i++){
arr[i]=data.temperature;
}
for(int i=0;i<3;i++){
tong+=arr[i];
}
co=1;
}else{
for(int i=0;i<2;i++){
arr[i]=arr[i+1];
}
arr[2]=data.temperature;
for(int i=0;i<3;i++){
tong+=arr[i];
}
}
Serial.println(data.temperature);
Serial.println(tong);
String send = "{\"trungbinh\":\""+String(tong/3)+"\"}";
client.publish("TUAN",String(send).c_str());
delay(2000);
}