// #include <WiFi.h>
// #include <MQTT.h>

// WiFiClient TCPclient;
// MQTTClient MQTTclient;

// char * MQTThostName = "public.cloud.shiftr.io";
// IPAddress MQTThostIP(34, 77, 13, 55);

// void setup() {
//   Serial.begin(115200);
//   Serial.print("Connecting to WiFi");
//   WiFi.begin("Wokwi-GUEST", "");

//   while (WiFi.status() != WL_CONNECTED) {
//     delay(1000);
//     Serial.print(".");
//   }
//   Serial.println(" Connected!");

//   MQTTclient.begin(MQTThostIP, 1883, TCPclient);
//   MQTTclient.connect("akita", "public", "public");
//   MQTTclient.publish("topic", "payload");
// }

// void loop() {

// }

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

// Змінні для WiFi
const char *ssid = "Wokwi-GUEST";
const char *password = "";

// Змінні для MQTT
const char *mqtt_server = "public.cloud.shifr.io";
const int mqtt_port = 1883;
const char *mqtt_user = "public";    // Залиште порожнім, якщо не потрібно
const char *mqtt_password = "public"; // Залиште порожнім, якщо не потрібно
const char *mqtt_topic = "it126mykola/text";

// Об'єкт клієнта WiFi та MQTT
WiFiClient espClient;
PubSubClient client(espClient);

void setup_wifi() {
  delay(10);
  // Встановлення з'єднання з WiFi
  Serial.println();
  Serial.print("Connecting to ");
  Serial.println(ssid);

  WiFi.begin(ssid, password);

  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }

  Serial.println("");
  Serial.println("WiFi connected");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());
}

void callback(char *topic, byte *payload, unsigned int length) {
  Serial.print("Message arrived [");
  Serial.print(topic);
  Serial.print("] ");
  
  for (int i = 0; i < length; i++) {
    Serial.print((char)payload[i]);
  }
  Serial.println();
}

void reconnect() {
  // Перевірка з'єднання з сервером MQTT
  while (!client.connected()) {
    Serial.print("Attempting MQTT connection...");
    
    if (client.connect("ESP32Client", mqtt_user, mqtt_password)) {
      Serial.println("connected");
      client.subscribe(mqtt_topic);
    } else {
      Serial.print("failed, rc=");
      Serial.print(client.state());
      Serial.println(" try again in 5 seconds");
      
      delay(5000);
    }
  }
}

void setup() {
  Serial.begin(115200);

  setup_wifi();
  
  client.setServer(mqtt_server, mqtt_port);
  client.setCallback(callback);
}

void loop() {
  if (!client.connected()) {
    reconnect();
  }
  
  // Перевірка з'єднання з сервером MQTT
  client.loop();

  // Відправлення простого текстового повідомлення
  client.publish(mqtt_topic, "Hello from ESP32");
}