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

// ===== Pines =====
#define DHTPIN 16
#define DHTTYPE DHT22
#define SOIL_PIN 34

DHT dht(DHTPIN, DHTTYPE);

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

// ===== MQTT =====
const char* mqtt_server = "broker.hivemq.com";

WiFiClient espClient;
PubSubClient client(espClient);

// 🔌 Conectar WiFi
void setup_wifi() {
  Serial.print("Conectando WiFi...");
  WiFi.begin(ssid, password);

  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }

  Serial.println("\n✅ WiFi conectado");
  Serial.print("IP: ");
  Serial.println(WiFi.localIP());

  delay(2000); 
}

// 🔁 Reconectar MQTT
void reconnect() {
  while (!client.connected()) {
    Serial.print("Conectando MQTT...");

    if (client.connect("ESP32_Lipsy")) {
      Serial.println("✅ Conectado a MQTT");
    } else {
      Serial.print("Error: ");
      Serial.println(client.state());
      Serial.println("Reintentando en 5 segundos...");
      delay(5000); // 🔥 evita error -2 constante
    }
  }
}

void setup() {
  Serial.begin(115200);

  setup_wifi();

  client.setServer(mqtt_server, 1883);

  dht.begin();
}

void loop() {

  if (!client.connected()) {
    reconnect();
  }
  client.loop();

  // 🌡️ Leer sensores
  float t = dht.readTemperature();
  float h = dht.readHumidity();
  int soil = analogRead(SOIL_PIN);

  if (isnan(t) || isnan(h)) {
    Serial.println("❌ Error leyendo DHT22");
    delay(2000);
    return;
  }

  // 🌱 Estado del suelo
  String estadoSuelo;

  if (soil > 3000) {
    estadoSuelo = "SECO";
  } else if (soil > 1500) {
    estadoSuelo = "NORMAL";
  } else {
    estadoSuelo = "HUMEDO";
  }

  // 📦 JSON
  String payload = "{";
  payload += "\"temp\":" + String(t,2) + ",";
  payload += "\"hum\":" + String(h,2) + ",";
  payload += "\"soil\":" + String(soil) + ",";
  payload += "\"estado\":\"" + estadoSuelo + "\"";
  payload += "}";

  // 📡 Publicar
  client.publish("lipsy/sensores", payload.c_str());

  // 🖥️ Debug
  Serial.println("📡 Enviado MQTT:");
  Serial.println(payload);

  delay(500); 
}