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

const char* ssid = "Wokwi-GUEST"; //ssid wifi
const char* pass = ""; // pass wifi
const char* mqtt_server = "broker.emqx.io"; //link broker mqtt


WiFiClient espClient;
PubSubClient client(espClient);


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

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

 client.setServer(mqtt_server, 1833);
 client.setCallback(callback);

}

void setup_wifi(){
  delay(10);
  Serial.println("Menghubungkan ke");
  Serial.println(ssid);

  WiFi.begin(ssid, password);

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

  client.setServer(mqtt_server, 1883);
  client.subscribe("GedungH/RuangMeeting/Wafi/#");
}

void reconnect() { 

  while (!client.connected()) {
    Serial.print("Mencoba Menghubungkan ke MQTT");

    if (client.connect("ArduinoClient"))
    {
      Serial.println("terhubung");

      client.subscribe("percobaan");

    }
    else { Serial.print("gagal, Rc = ")
    Serial.print(client.state());
    Serial.println("Coba lagi dalam 5 Detik");
    
    delay(5000);
    }
  }
}

void loop() {
  if(!client.connected()){
    reconnect();
  }
  client.loop();

  unsigned long currentmillis = millis();

  // if ( currentmillis - lastsend > 10000){
  //   sprintf (pesan, "test");
  //   client.publish(topic_pub, pesan);
  //   lastsend = currentmillis;
  // }
  
}

// void reconnect() {
//   while (!client.connected()) {
//     Serial.print("Attempting MQTT connection...");
//     if (client.connect(clientID.c_str(), accessKey.c_str(), accessToken.c_str())) {
//       Serial.println("connected");
//       client.publish(topic_pub, "hello world");
//     }
//     else {
//       Serial.print("failed, rc=");
//       Serial.print(client.state());
//       Serial.println(" try again in 5 seconds");
//       delay(5000);
//     }
//   }}



void subscribe(String &topic, String &payload)
{
  Serial.println("subscribe" + topic + "-" +payload);
}