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

#define DHT_PIN 12

LiquidCrystal_I2C LCD = LiquidCrystal_I2C(0x27, 20, 4);
LiquidCrystal_I2C LCD2 = LiquidCrystal_I2C(0x28, 16, 2);

DHTesp dht;

WiFiClient espClient;

// Create pubsubclient
PubSubClient client(espClient);

// Create mqttServer address
const char* mqtt_server = "test.mosquito.org";

int lastMsg = 0;

int numberOfWifi = 0;
const char* ssid = "Wokwi-GUEST";
const char* password = "";

void setup() {
  Serial.begin(115200);
  Serial.println("Hello, ESP32!");
  
  //  Set mqttServer for the client 

  // Set callback method on connection 
  client.setServer(mqtt_server, 1883);
  client.setCallback(callback);

  dht.setup(DHT_PIN, DHTesp::DHT22);
  
  LCD2.init();
  LCD2.backlight();

  LCD.init();
  LCD.backlight();
  LCD.setCursor(4, 1);
  LCD.print("Temperature");
  LCD.setCursor(6, 2);
  LCD.print("Monitor");
  delay(2000);
  LCD.clear();
  LCD.setCursor(4, 2);
  LCD.print("Setup Done!");
  delay(1000);

  WiFi.mode(WIFI_STA);
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
  }
  Serial.println("WiFi connected");
  Serial.println(WiFi.localIP());

}

void loop() {
  // Check if client is connected

    // Call reconnect function



  // Call loop() method from client
  if (!client.connected()){
    reconnect();
  }

  client.loop();


  
  TempAndHumidity data = dht.getTempAndHumidity();
  float temperature  = data.temperature;
  float humidity  = data.humidity;

  if(temperature > 24){
    LCD2.setCursor(0,0);
    LCD2.print("AC Truned On!");
  }
  else{
    LCD2.setCursor(0,0);
    LCD2.print("AC Truned Off");
  }
  
  LCD.setCursor(0, 0);
  LCD.print("Temperature: ");
  LCD.print(temperature);
  LCD.setCursor(0, 2);
  LCD.print("Humidity: ");
  LCD.print(humidity);

  numberOfWifi = WiFi.scanNetworks();
  
  if (numberOfWifi == 0) {
    Serial.print("No network found.");
  } else {
    Serial.print(numberOfWifi);
    Serial.print(" network found.");
    for (int i = 0; i < numberOfWifi; ++i) {
      Serial.print(WiFi.SSID(i));
      Serial.print(WiFi.RSSI(i));
      delay(10);
    }
  }

  unsigned long now = millis();
  if (now - lastMsg > 2000) {
    lastMsg = now;
    // get the temperature string
    TempAndHumidity data = dht.getTempAndHumidity();
    // Publish the temerature string to "/Temperature"
    String tempStr = String(data.temperature, 2);
    client.publish("/Thinkitive/temp", tempStr.c_str());

    String humStr = String(data.humidity, 1);
    client.publish("/Thinkitive/hum", humStr.c_str()); 

    Serial.println("Data Sent");
  }

  delay(5000);


}

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()) {
    // Set the clientId
    String clientId = "mqttx_b8e1a5c9f496";

    if (client.connect(clientId.c_str())) {
      Serial.println("Connected");
      Serial.println(clientId);
    } else {
      delay(2000);
    }
  }
}