#include "DHTesp.h"
#include <WiFi.h>
#include <MQTT.h>
#include <NusabotSimpleTimer.h>

WiFiClient net;

MQTTClient client;

DHTesp dhtSensor;

NusabotSimpleTimer timer;

const char ssid[] = "Wokwi-GUEST";
const char pass[] = "";

// Variabel LED dan LED RGB
const int pinBlue = 25;
const int pinGreen = 26;
const int pinRed = 27;
const int pinLED = 32;

//Variabel nilai dht
float temp = 0;
float hum = 0;
int dht, oldht = 0;

void setup() {
  pinMode(25, OUTPUT);
  pinMode(26, OUTPUT);
  pinMode(27, OUTPUT);
  pinMode(32, OUTPUT);

  WiFi.begin(ssid, pass);
  client.begin("bitterprincess291.cloud.shiftr.io", net);

  client.onMessage(subscribe);

  dhtSensor.setup(13, DHTesp::DHT22);

  timer.setInterval(2000, publish);

  connect();
}

void loop() {
  client.loop();
  timer.run();

  // Fitur reconnect
  if (!client.connected()) {
    connect();
  }

  delay(2000); // this speeds up the simulation
}

void connect() {
  rgb(0, 0, 1); // RGB Merah
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
  }
  rgb(0, 1, 0); // RGB Hijau

  // Koneksi ke broker
  while (!client.connect("ESP32", "bitterprincess291", "Kabere02")) {
    delay(500);
  }
  rgb(1, 0, 0); //RGB Biru

  client.subscribe("hjn/#", 1);
}

void publish() {
  TempAndHumidity  data = dhtSensor.getTempAndHumidity();
  String temp = String(data.temperature, 2);
  client.publish("hjn/suhu", temp.c_str()); //pulish data suhu

  String hum = String(data.humidity, 1);
  client.publish("hjn/hum", hum.c_str()); //publish data lembab
}

void subscribe(String &topic, String &data) {
  if (topic == "hjn/led") {
    if (data == "nyala") {
      digitalWrite(pinLED, 1);
    } else {
      digitalWrite(pinLED, 0);
    }
  }
}

void rgb(bool blue, bool green, bool red) {
  digitalWrite(pinBlue, blue);
  digitalWrite(pinGreen, green);
  digitalWrite(pinRed, red);
}