#include <PubSubClient.h>
#include <WiFi.h>
#include <DHT.h>
#define BLUE_LED_PIN 26
#define RED_LED_PIN 32 
#define DHT_TYPE 22
#define DHT_PIN 33

DHT dht(DHT_PIN, DHT_TYPE);

// WiFi config
const char* ssid = "Wokwi-GUEST";
const char* password = "";
WiFiClient wifiClient;

// MQTT client config
const char* mqttServer = "broker.hivemq.com";
const int mqttPort = 1883;
const char* mqttUser ="";
const char* mqttPassword ="";
const char* topic_pub = "ITKPS/Lab/counter55555555";
PubSubClient mqttClient(wifiClient);

String publishMessage;

void setup_wifi() {
Serial.println();
Serial.print("Connecting to ");
Serial.println(ssid);
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(".");
}
Serial.println();
Serial.print("WiFi connected on ");
Serial.print("IP address: ");
Serial.print(WiFi.localIP());
Serial.print(" MAC address: ");
Serial.println(WiFi.macAddress());
}

void reconnectMQTT() {
 char mqttinfo[80];
 char clientId[100] = "\0";
 snprintf (mqttinfo, 75, "Attempting MQTT connection at %s:%d (%s/%s)...", mqttServer, mqttPort, mqttUser, mqttPassword);
 while (!mqttClient.connected()) {
 Serial.println(mqttinfo);
 sprintf(clientId, "ESP32Client-%04X", random(0xffff));
 if (mqttClient.connect(clientId)) {
 Serial.println("...MQTT Broker connected...");
 
 } else {
 Serial.print("failed, rc=");
 Serial.print(mqttClient.state());
 Serial.println(" try again in 5 seconds");
 // Wait 5 seconds before retrying
  delay(5000); 
  }
 }
}
void doProcess(float temp) {
    Serial.print("Processing temperature: ");
    Serial.println(temp);
    if (temp >= 25.0 && temp <= 30.0) {
        digitalWrite(BLUE_LED_PIN, HIGH);
        digitalWrite(RED_LED_PIN, LOW);

    } else {
      digitalWrite(BLUE_LED_PIN, LOW);
      digitalWrite(RED_LED_PIN, HIGH);

    }
}
void setup() {
    Serial.begin(115200);
    dht.begin();
    setup_wifi();
    mqttClient.setServer(mqttServer, mqttPort);
}

void loop() {
    if (!mqttClient.connected()) {
        reconnectMQTT();
    }
    mqttClient.loop();

    float t = dht.readTemperature();
    float h = dht.readHumidity();

    if (isnan(t) || isnan(h)) { 
        Serial.println("Failed to read from DHT sensor!");
        return;
    }

   

    publishMessage =  String(t) + "/" + String(h);
    mqttClient.publish(topic_pub, publishMessage.c_str());

    Serial.println(publishMessage);
    delay(2000);
}