#include <LiquidCrystal_I2C.h>
#include "DS18B20.h"
#include <OneWire.h>
#include <DallasTemperature.h>
#include <WiFi.h>
#include <PubSubClient.h>

#define LED_BUILTIN 2
#define BUTTON 4

LiquidCrystal_I2C lcd(0x27, 16, 2);
const int SENSOR_PIN = 13;

DS18B20 ds(13);
// Setup a oneWire instance to communicate with any OneWire devices
OneWire oneWire(SENSOR_PIN);

// Pass our oneWire reference to Dallas Temperature sensor 
DallasTemperature sensors(&oneWire);

//-------- Red Wi-Fi ---------//
const char* WIFI_SSID = "Wokwi-GUEST";
const char* WIFI_PASSWORD = "";

//-------- Broker MQTT ---------//
const char* mqtt_server = "broker.hivemq.com";
const char *channelTopic = "IoTMQTT/Equipo12/Temp";

WiFiClient espClient;
PubSubClient client(espClient);

long PastTime = 0;
char msg[50];
int value = 0;
int remote_enabled = 0;

void setup_wifi() {
    delay(100);
  // Determinar MAC address
    Serial.println();
    Serial.print("La dirección MAC del dispositivo de red es: ");
    Serial.println(WiFi.macAddress());
  // Conectar a WiFi
  WiFi.begin(WIFI_SSID, WIFI_PASSWORD);
  Serial.println("Connecting");
  while(WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println("");
  Serial.print("Se ha conectado al wifi con la dirección IP: ");
  Serial.println(WiFi.localIP());
}

void callback(char* topic, byte* payload, unsigned int length) 
{
  //Serial.println("payload: "+payload);
  int p =(char)payload[0]-'0';
  // Si el broker MQTT envía un "1", el LED_RED en GPI012 se enciende
  if(p==1) 
  {   
     Serial.println("*** Se activo el publish de temperartura remotamente ***" );
     remote_enabled = 1;
  } 
  // Si el broker MQTT envía un "0", el LED_RED en GPI012 se apaga
  if(p==0)
  {
     Serial.println("*** Se desactivo el publish de temperartura remotamente ***" );
     remote_enabled = 0;
  }
  Serial.println();
}

void reconnect() {
    // Conectar al broker MQTT
    while (!client.connected()) {
        Serial.print("Conectando al broker MQTT");
        Serial.println("");
        // Crear una ID de cliente aleatoria
        String clientId = "ESP8266Client-";
        clientId += String(random(0xffff), HEX);
        //Intenta volver a conectarse ...
        // ... en caso de que el "broker" tenga ID de cliente, nombre de usuario y contraseña
        // ... cambiar la siguiente línea a --> if (client.connect(clientId,userName,passWord))
        if (client.connect(clientId.c_str())) {
            Serial.println("El broker MQTT está conectado");
            //Una vez conectado al broker MQTT, suscribirse al tema
            client.subscribe(channelTopic);
        } else {
            Serial.print("Error de conexión:");
            Serial.print(client.state());
            Serial.println(" ... próximo intento en 5 segundos.");
            // Espera de 6 segundos para el próximo intento de conexión
            delay(6000);
        }
    }
}

void setup() {
  // put your setup code here, to run once:
  Serial.begin(115200);
  Serial.println("Hello, ESP32!");

  // WiFi Setup
  setup_wifi();
  client.setServer(mqtt_server, 1883);//Puerto TCP 1883, estándar en MQTT
  client.setCallback(callback);

  // LCD Setup
  lcd.init();
  lcd.backlight();
  lcd.setCursor(1,0);
  lcd.print("Hola Equipo 12");
  lcd.setCursor(0,5);
  lcd.print("Protocolo MQTT");
  delay(3000);

  // Establecer el mode de input para el sensor
  pinMode(SENSOR_PIN, INPUT);
  // El LED integrado está conectado al pin GPIO2 (D2).
  pinMode(LED_BUILTIN, OUTPUT);
  // El botón de presión está conectado al pin GPIO4 (D4).
  pinMode(BUTTON, INPUT);


  // Start the DS18B20 sensor
  sensors.begin();
  
}



void loop() {
  sensors.requestTemperatures(); 
  Serial.println("Temp: " + String(sensors.getTempCByIndex(0), 2) + " °C");
  //Serial.println("Humidity: " + String(data.humidity, 1) + "%");
  Serial.println("---");

  lcd.clear();
  lcd.setCursor(0,0);
  lcd.print("Temp: " + String(sensors.getTempCByIndex(0), 2) + " C");

  if (!client.connected()) {
      reconnect();
  }
  client.loop();
  long now = millis();  //Lectura del reloj del sistema en milisegundos
  //Validar (por control de tiempo) si han pasado 0.5 segundos desde el informe anterior
  if (now - PastTime > 500) {
      PastTime = now;
      int value = digitalRead(BUTTON);
      String msg = "*** La temperatura actual es: ";
        // Si el boton esta encendido, mandar temperatura
        if (value == 1 || remote_enabled == 1) {
          msg= msg+ String(sensors.getTempCByIndex(0), 2) + "°C ***";
          char message[58];
          msg.toCharArray(message,58);
          Serial.println(message);
          client.publish(channelTopic, message);
        }
  }

  //lcd.setCursor(0,1);
  //lcd.print("Humidity: " + String(data.humidity, 1) + "%");
  delay(2000); // Wait for a new reading from the sensor (DHT22 has ~0.5Hz sample rate)

  // Leer el estado del botón. Cuando está pulsado el pin se pone a nivel bajo
  int estado = digitalRead(BUTTON);
  // Configurar el LED de acuerdo al estado del botón
  digitalWrite(LED_BUILTIN, estado);

}