#include <PubSubClient.h>
#include<WiFi.h>
#include "DHT.h"
#define DHTPIN 2
String data_send;
const char* mqtt_server = "broker.hivemq.com";
 
int status = WL_IDLE_STATUS;
WiFiClient wifiClient;
PubSubClient client(wifiClient);
 
#define DHTTYPE DHT22 
 
float tempC = 0.0;
float cToFRate = 1.8;
float cToF32 = 32;
float humidity = 0.0;
 DHT dht(DHTPIN, DHTTYPE);
void setup() {
  Serial.begin(115200);
  delay(10);
 
  WiFi.mode(WIFI_STA);
  WiFi.disconnect();
 
  delay(100);
  dht.begin();
  connectWifi();
  initMQTT();
}
 
void loop() {
  if(WiFi.status() != WL_CONNECTED){
    connectWifi();
  } else {
    if(!client.connected()){
      connectMQTT();
    } else {
      publishDHT22(); //doc dl dht
    }
  }
  client.loop();
  delay(100);
}
 
void initMQTT(){
  Serial.println("Initializing MQTT");
   
  randomSeed(micros());
  client.setServer(mqtt_server, 1883);
  connectMQTT();
}
 
void connectMQTT(){
   
  while(!client.connected()){
    String clientId = "Client-";
    clientId += String(random(0xffff), HEX);
    if(client.connect(clientId.c_str())){
      Serial.println("Successfully connected MQTT");
    } else {
      Serial.println("Error!");
      Serial.println(client.state());
      delay(500);
    }
  }
}
 
void publishDHT22(){

    float h = dht.readHumidity();
    float t = dht.readTemperature();
    data_send = "{\"temp_value\":\"" + String(t) + "\",\"press_value\":\"" + String(h) + "\"}";
    Serial.println(data_send);
    client.publish("VLUTE/PhatTrienIoT/DHT221", String(data_send).c_str()); 
}
 
void connectWifi(){
  WiFi.begin("Wokwi-GUEST", "");
   
  while(status != WL_CONNECTED){
    status = WiFi.status();
    delay(1000);
    Serial.print(".");
  }
}
 
float convertCtoF(float t){
  return ((t * cToFRate) + cToF32);
}