#include <WiFi.h>
#include <PubSubClient.h>
#include <DHT.h>

const char* ssid = "Wokwi-GUEST";
const char* password = "";
const char* mqtt_server = "broker.mqtt-dashboard.com";
#define mqtt_port 1883
#define MQTT_TOPIC "dk1813"

WiFiClient wifiClient;

#define ledPin 12 // GPIO 2 for ESP32 (D2 on NodeMCU)
#define dhtPin 27 // GPIO 14 for ESP32 (D5 on NodeMCU)

DHT dht(dhtPin, DHT22);

PubSubClient client(wifiClient);

void setup_wifi() {
  delay(10);
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
  }
  randomSeed(micros());
}

void reconnect() {
  while (!client.connected()) {
    String clientId = "ESP32Client-";
    clientId += String(random(0xffff), HEX);
    if (client.connect(clientId.c_str())) {
      client.subscribe(MQTT_TOPIC);
    } else {
      delay(5000);
    }
  }
}

void callback(char* topic, byte* payload, unsigned int length) {
  int value = atoi((char*)payload);
  digitalWrite(ledPin, value);
}

void setup() {
  pinMode(ledPin, OUTPUT);
  dht.begin();
  setup_wifi();
  client.setServer(mqtt_server, mqtt_port);
  client.setCallback(callback);
  reconnect();
}

void loop() {
  client.loop();

  float temperature = dht.readTemperature();
  float humidity = dht.readHumidity();

  if (!isnan(temperature) && !isnan(humidity)) {
    String temperatureStr = String(temperature);
    String humidityStr = String(humidity);
    String topic = MQTT_TOPIC;
    topic.concat("/temperature");
    client.publish(topic.c_str(), temperatureStr.c_str());
    topic = MQTT_TOPIC;
    topic.concat("/humidity");
    client.publish(topic.c_str(), humidityStr.c_str());
  }

  delay(2000);
}