#include <WiFi.h>                 // Biblioteca para conexão Wi-Fi
#include <PubSubClient.h>         // Biblioteca para cliente MQTT

const char* ssid = "Wokwi-GUEST"; // Nome da rede Wi-Fi
const char* password = "";        // Senha da rede Wi-Fi (vazia no caso do Wokwi)

const char* mqtt_server = "test.mosquitto.org"; // Endereço do broker MQTT
const int mqtt_port = 1883;                     // Porta do broker MQTT (padrão)
const char* mqtt_topic = "saiam indianos";      // Tópico onde as mensagens serão publicadas/recebidas

#define bt 5                     // Define o pino 5 como botão

WiFiClient espClient;           // Cria um cliente Wi-Fi
PubSubClient client(espClient); // Usa o cliente Wi-Fi para o MQTT

// Função chamada quando uma mensagem é recebida no tópico MQTT
void callback(char* topic, byte* message, unsigned int length) {
  Serial.print("Mensagem recebida no tópico: ");
  Serial.println(topic);
  Serial.print("Mensagem: ");

  // Imprime a mensagem recebida, caractere por caractere
  for (int i = 0; i < length; i++) {
    Serial.print((char)message[i]);
  }
  Serial.println();
}

// Função para conectar ao Wi-Fi
void setup_wifi() {
  delay(100);
  Serial.println("Conectando ao Wi-Fi...");
  WiFi.begin(ssid, password); // Inicia conexão com Wi-Fi
  while (WiFi.status() != WL_CONNECTED) { // Espera até conectar
    delay(500);
    Serial.print(".");
  }
  Serial.println("");
  Serial.println("Wi-Fi conectado!");
  Serial.println(WiFi.localIP()); // Mostra o IP obtido
}

// Função para conectar (ou reconectar) ao servidor MQTT
void reconnect() {
  while (!client.connected()) {
    Serial.print("Tentando conexão MQTT...");
    String clientId = "ESP32Client-" + String(random(0xffff), HEX); // Gera ID aleatório
    if (client.connect(clientId.c_str())) {
      Serial.println("Conectado!");
      client.subscribe(mqtt_topic); // Se inscreve no tópico
    } else {
      Serial.print("Falha, rc=");
      Serial.print(client.state());
      Serial.println(" tentando novamente em 5 segundos");
      delay(5000); // Aguarda antes de tentar novamente
    }
  }
}

void setup() {
  Serial.begin(115200); // Inicializa comunicação serial
  pinMode(bt, INPUT);   // Define o pino do botão como entrada
  setup_wifi();         // Chama função para conectar ao Wi-Fi
  client.setServer(mqtt_server, mqtt_port); // Configura servidor MQTT
  client.setCallback(callback);             // Define função de callback para mensagens recebidas
}

void loop() {
  if (!client.connected()) {
    reconnect(); // Reconecta se necessário
  }
  client.loop(); // Mantém o cliente MQTT funcionando

  // Verifica o estado do botão e envia a mensagem correspondente
  if (digitalRead(bt) == HIGH) {
    String msg = "true";             // Cria a mensagem "true"          // Armazena o tempo (OBS: lastMsg não foi declarado!)
    client.publish(mqtt_topic, msg.c_str()); // Publica a mensagem no tópico
    Serial.print("Mensagem enviada: ");
    Serial.println(msg);  
  } else {
    String msg = "false";            // Cria a mensagem "false"             // Armazena o tempo (OBS: lastMsg não foi declarado!)
    client.publish(mqtt_topic, msg.c_str()); // Publica a mensagem no tópico
    Serial.print("Mensagem enviada: ");
    Serial.println(msg);
  }
}