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


const char* ssid = "Wokwi-GUEST";
const char* password = "";

const char* mqtt_server = "test.mosquitto.org";
WiFiClient espClient; 
PubSubClient client(espClient);
const int dht_pin = 15;

DHTesp dht;
int lastmsg = 0;

void setup_wifi(){
  Serial.begin(115200);
  WiFi.begin(ssid,password);
  while(WiFi.status()!=WL_CONNECTED){
    delay(500);
  }
  Serial.println("wifi connected");
  Serial.println(WiFi.localIP());
}
void callback(char* topic,byte* payload,int length){
  for(int i = 0;i < length; i++){
    Serial.print((char) payload[i]);
  }
}

void reconnect(){
  while(!client.connected()){
    String clientID = "esp32client-";
    clientID += String(random(0xffff),HEX);
    if(client.connect(clientID.c_str())){
      Serial.println("connected to mqtt");
      client.subscribe("subscribe");
    }
    else{
      delay(2000);
    }
  }
}

void setup() {
  // Initialize the serial connection
  Serial.begin(115200);

  // Set up the WiFi connection
  setup_wifi();

  // Configure the MQTT client and callback function
  client.setServer(mqtt_server, 1883);
  client.setCallback(callback);

  // Initialize the DHT sensor
  dht.setup(dht_pin, DHTesp::DHT22);
}

void loop() {
  // If not connected to the MQTT broker, attempt to reconnect
  if (!client.connected()) {
    reconnect();
  }

  // Process any incoming MQTT messages
  client.loop();

  // Publish sensor data at regular intervals
  unsigned long now = millis();
  if (now - lastmsg > 2000){
    lastmsg = now;
    TempAndHumidity data = dht.getTempAndHumidity();

    // Publish temperature data to the MQTT topic
    String tempStr = String(data.temperature, 2);
    client.publish("/Temperature", tempStr.c_str());

    // Publish humidity data to the MQTT topic
    String humStr = String(data.humidity, 1);
    client.publish("/Humidity", humStr.c_str());
  }
}