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

WiFiClient net;
MQTTClient client;

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

const int pinRed = 4;
const int pinGreen = 2;
const int pinBlue = 16;
const int ledBiru = 13;
const int ledMerah = 12;

void setup() {
  pinMode(pinRed, OUTPUT);
  pinMode(pinGreen, OUTPUT);
  pinMode(pinBlue, OUTPUT);
  pinMode(ledBiru, OUTPUT);
  pinMode(ledMerah, OUTPUT);

  WiFi.begin(ssid, pass);
  client.begin("broker.emqx.io", net);
  client.onMessage(subscribe);

  connect();
}

void loop() {
  client.loop();
  if (!client.connected()) {//dia akan berusaha nyambung
    connect();
  }

}
void subscribe(String &topic, String &data ) {
  if ( topic == "kelasiot/led") {//harus subscribe topic kelasiot/led
    if (data == "biru") {//jika data bertuliskan on maka nyala
      digitalWrite(ledBiru, 1);
    } else if (data == "merah") {
      digitalWrite(ledMerah, 1);
    } else if (data == "biru mati"){
      digitalWrite(ledBiru, 0);
    } else if (data == "merah mati"){
      digitalWrite(ledMerah, 0);
    }
  }
}
void rgb (bool red, bool green, bool blue) {
  digitalWrite(pinRed, red);
  digitalWrite(pinGreen, green);
  digitalWrite(pinBlue, blue);
}

void connect(){
/*cek apakah wifi connect/tidak
udh nyambung ke broker apa blom
*/
  rgb(1, 0, 0); //merah
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);

  }
  rgb(0, 1, 0); //hijau

  while (!client.connect("37bf811a")) {
    delay(500);
  }

  rgb(0, 0, 1);
  client.subscribe("kelasiot/#", 1); //Suscribe menggunakan QoS 1
}