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

#define LED_BLUE 2
#define LED_RED 12
#define BUTTON 4

// Potentiometer is connected to GPIO 34 (Analog ADC1_CH6) 
const int potPin = 34;

// variable for storing the potentiometer value
int potValue = 0;

//-------- 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 = "IoTLabMQTT";

WiFiClient espClient;
PubSubClient client(espClient);

long PastTime = 0;
char msg[50];
int value = 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(1000);
    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) 
{
  int p =(char)payload[0]-'0';
  // Si el broker MQTT envía un "1", el LED_RED en GPI012 se enciende
  if(p==1) 
  {
     digitalWrite(LED_RED, HIGH); 
     Serial.println("*** El LED ROJO fue ENCENDIDO de manera remota ***" );
  } 
  // Si el broker MQTT envía un "0", el LED_RED en GPI012 se apaga
  if(p==0)
  {
     digitalWrite(LED_RED, LOW); 
     Serial.println("*** El LED ROJO fue APAGADO de manera remota ***" );
  }
  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() {
    Serial.begin(115200);
    setup_wifi();
    client.setServer(mqtt_server, 1883);//Puerto TCP 1883, estándar en MQTT
    client.setCallback(callback);
    pinMode(LED_BLUE, OUTPUT);
    pinMode(LED_RED, OUTPUT);
    pinMode(BUTTON, INPUT);  
    digitalWrite(LED_BLUE, LOW);
    

}

void loop() {
    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);
        //digitalWrite(LED_BLUE, value); 
        //String msg="*** El LED AZUL está: ";
        //  if (value == 1) {
        //    msg= msg+"ENCENDIDO ***";
        //  } else {
        //    msg= msg+"APAGADO ***";
        //  }

        
        potValue = analogRead(potPin);
        delay(50);

        String texto = (String) potValue;



        String msg=texto;

        char message[58];
        msg.toCharArray(message,58);
        Serial.println(message);
        client.publish(channelTopic, message);
    }
}