//Libreria wifi
#include <WiFi.h>

//Libreria adafruit
#include <Adafruit_MQTT.h>
#include <Adafruit_MQTT_Client.h>

// Libreria LCD
#include <LiquidCrystal_I2C.h>
LiquidCrystal_I2C LCD = LiquidCrystal_I2C(0x27, 16, 2);

//Credenciales para la conexion a adafruit
#define AIO_SERVIDOR "io.adafruit.com"
#define AIO_PUERTOSERVIDOR 1883
#define AIO_USUARIO  "dprado"
#define AIO_KEY       "aio_bhqK68fmvKwxgerLKCTjQlDBpb7n"

//Credenciales leds
#define led_azul 18
#define led_blanco 19

WiFiClient client;

Adafruit_MQTT_Client mqtt(&client, AIO_SERVIDOR, AIO_PUERTOSERVIDOR, AIO_USUARIO, AIO_KEY);
Adafruit_MQTT_Subscribe luz = Adafruit_MQTT_Subscribe(&mqtt, AIO_USUARIO"/feeds/LED1");
Adafruit_MQTT_Subscribe luz2 = Adafruit_MQTT_Subscribe(&mqtt, AIO_USUARIO"/feeds/LED2");
Adafruit_MQTT_Subscribe Slider = Adafruit_MQTT_Subscribe(&mqtt, AIO_USUARIO"/feeds/Slider");

void setup() {
  Serial.begin(9600);
  Serial.print("conectando a wifi");
  WiFi.begin("Wokwi-GUEST", "", 6);
  while (WiFi.status() != WL_CONNECTED) {
    delay(100);
    Serial.print(".");
  }
  Serial.print("Conectado!!! 🥳");

  pinMode(led_azul, OUTPUT);
  pinMode(led_blanco, OUTPUT);

  mqtt.subscribe (&luz);
  mqtt.subscribe (&luz2);
  mqtt.subscribe (&Slider);
  }

void loop() {
  MQTT_connect();

  Adafruit_MQTT_Subscribe*subscription;
  while(subscription = mqtt.readSubscription(2000)) {
    if(subscription==&luz) {
      Serial.print(F("llega el dato del led azul"));
      Serial.println((char*)luz.lastread);
      int luz_state = atoi((char*)luz.lastread);
      digitalWrite(led_azul, luz_state); 
    }
    if(subscription==&luz2) {
      Serial.print(F("llega el dato del led blanco"));
      Serial.println((char*)luz2.lastread);
      int luz2_state = atoi((char*)luz2.lastread);
      digitalWrite(led_blanco, luz2_state);
    }
    if (subscription == &Slider) {
      Serial.print(F("Slider Value: "));
      Serial.print((char*)Slider.lastread);
      Serial.println("%");
      int Slider_state = atoi((char*)Slider.lastread);
      LCD.setCursor(1, 1);
      LCD.print(String(Slider_state));  // Convert Slider_state to a String before printing
    }

  }
}


void MQTT_connect() {
  int8_t ret;

  if (mqtt.connected()) {
    return;
  }

  Serial.print("Connecting to MQTT...");

  uint8_t retries = 3;

  while (ret=mqtt.connect()!=0) {
    Serial.println(mqtt.connectErrorString(ret));
    Serial.println("reintentando conectar en 5 segundos...");
    mqtt.disconnect();
    delay(5000);
    if(retries==0) {
      while(1);
    }
  }
  Serial.println("mqtt Conectado!!! 🥳");
}