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

const char ssid[] = "Wokwi-GUEST";
const char pass[] = "";

// deklarasi variabel class library
WiFiClient net;
MQTTClient client;

// deklarasi 
unsigned long lastMillis = 0;
// deklarasi potensio
int pot;

// cek koneksi
void connect() {
  Serial.print("checking wifi...");
  while (WiFi.status() != WL_CONNECTED) {
    Serial.print(".");
    delay(1000);
  }

  Serial.print("\nconnecting...");
  while (!client.connect("bebas-desktop")) {
    Serial.print(".");
    delay(1000);
  }

  Serial.println("\nconnected!");

  client.subscribe("pat/belajar/#", 1);
  // client.unsubscribe("/hello");
}

void messageReceived(String &topic, String &payload) {
  Serial.println("incoming: " + topic + " - " + payload);

  if (topic == "pat/belajar/dendra/led1") {
    digitalWrite(5, payload.toInt());
  }

  if (topic == "pat/belajar/dendra/led2") {
    digitalWrite(4, payload.toInt());
  }
  // Note: Do not use the client in the callback to publish, subscribe or
  // unsubscribe as it may cause deadlocks when other things arrive while
  // sending and receiving acknowledgments. Instead, change a global variable,
  // or push to a queue and handle it in the loop after calling `client.loop()`.
}

// melakukan koneksi
void setup() {
  Serial.begin(115200);
  WiFi.begin(ssid, pass);

  // Note: Local domain names (e.g. "Computer.local" on OSX) are not supported
  // by Arduino. You need to set the IP address directly.
  client.begin("broker.emqx.io", net);
  client.onMessage(messageReceived);

  connect();

  // konfigurasi lampu led
  pinMode(5, OUTPUT);
  pinMode(4, OUTPUT);
}

// mengecek  atau koneksi
void loop() {
  client.loop();
  // konfigurasi potensio:
  delay(10); // untuk membantu menjaga kestabilan koneksi wifi

  pot = analogRead(32); // arduino menggunakan 12 bit atau 4095
  // Serial.println(pot); // digunakan untuk memastikan potensio berjalan

  if (!client.connected()) {
    connect();
  }

  // publish a message roughly every second.
  if (millis() - lastMillis > 1000) {
    lastMillis = millis();
    client.publish("pat/iot", String(pot)); //untuk mengirimkan data potensio, diperlukan
    // konversi dari int (potensio) ke string
  }
}