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

#define POT_PIN 34
#define LED_VERDE 25
#define LED_AMARILLO 26
#define LED_ROJO 27
#define TEMP_UMBRAL_BAJO 170
#define TEMP_UMBRAL_ALTO 180

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

// Configuración MQTT
const char* mqttServer = "broker.hivemq.com";
const int mqttPort = 1883;
const char* topic = "sensor/temperatura";

WiFiClient espClient;
PubSubClient client(espClient);

// Configuración Telegram
const char* botToken = "AAGFsUteG7uoNdc6R-wERBKvra8OFJ13Lfo";  // Token
const char* chatID = "7609767313"; 

void setup() {
  Serial.begin(115200);
  pinMode(LED_VERDE, OUTPUT);
  pinMode(LED_AMARILLO, OUTPUT);
  pinMode(LED_ROJO, OUTPUT);

  conectarWiFi();
  conectarMQTT();
}

void loop() {
  if (!client.connected()) {
    conectarMQTT();
  }
  client.loop();

  int valorPot = analogRead(POT_PIN);
  float voltaje = valorPot * (3.3 / 4095.0);
  float temperatura = voltaje * 100.0;

  Serial.print("Temperatura: ");
  Serial.print(temperatura);
  Serial.println(" °C");

  // Enviar datos a Node-RED vía MQTT
  char msg[10];
  dtostrf(temperatura, 6, 2, msg);
  client.publish(topic, msg);

  // Control de LEDs y notificación
  if (temperatura < TEMP_UMBRAL_BAJO) {
    digitalWrite(LED_VERDE, HIGH);
    digitalWrite(LED_AMARILLO, LOW);
    digitalWrite(LED_ROJO, LOW);
  } else if (temperatura >= TEMP_UMBRAL_BAJO && temperatura <= TEMP_UMBRAL_ALTO) {
    digitalWrite(LED_VERDE, LOW);
    digitalWrite(LED_AMARILLO, HIGH);
    digitalWrite(LED_ROJO, LOW);
  } else {
    digitalWrite(LED_VERDE, LOW);
    digitalWrite(LED_AMARILLO, LOW);
    digitalWrite(LED_ROJO, HIGH);
    enviarNotificacionTelegram(temperatura);  // Enviar notificación cuando la temperatura sea mayor a 180 grados
  }

  delay(500);
}

void conectarWiFi() {
  Serial.print("Conectando a WiFi");
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println("\n✅ Conectado a WiFi. Dirección IP: " + WiFi.localIP().toString());
}

void conectarMQTT() {
  client.setServer(mqttServer, mqttPort);
  Serial.print("Conectando a MQTT...");
  while (!client.connected()) {
    if (client.connect("ESP32")) {
      Serial.println("\n✅ Conectado a MQTT");
    } else {
      Serial.print("\n❌ Fallo MQTT, rc=");
      Serial.print(client.state());
      Serial.println(" Intentando nuevamente en 2s...");
      delay(2000);
    }
  }
}

void enviarNotificacionTelegram(float temp) {
  if (WiFi.status() != WL_CONNECTED) {
    Serial.println("⚠️ WiFi desconectado, intentando reconectar...");
    conectarWiFi();
  }

  HTTPClient http;
  String mensaje = "⚠️ Alerta! Temperatura alta: " + String(temp) + " °C 🔥";
  String url = "https://api.telegram.org/bot" + String(botToken) + 
               "/sendMessage?chat_id=" + String(chatID) + 
               "&text=" + mensaje;
  
  http.begin(url);
  int httpCode = http.GET();
  
  if (httpCode > 0) {
    Serial.println("✅ Mensaje enviado a Telegram");
  } else {
    Serial.print("❌ Error enviando mensaje. Código HTTP: ");
    Serial.println(httpCode);
  }
  
  http.end();
}