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

const char* ssid = "Wokwi-GUEST";
const char* pass = "";

const int pinRed = 25;
const int pinGreen = 26;
const int pinBlue = 27;

WiFiClient  net;
MQTTClient client;

void setup() {
  Serial.begin(115200);
  pinMode(pinRed, OUTPUT);
  pinMode(pinGreen, OUTPUT);
  pinMode(pinBlue, OUTPUT);

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

  client.onMessage(subscribe);

  connect();
}

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

void subscribe(String &topic, String &data){
  Serial.print("Topik: ");
  Serial.println(topic);
  Serial.print("Data: ");
  Serial.println(data);
}

void rgb (bool red, bool green, bool blue){
  digitalWrite(pinRed, red);
  digitalWrite(pinGreen, green);
  digitalWrite(pinBlue, blue);
}

void connect (){

  rgb(HIGH,LOW,LOW); //Jika merah menyala menandakan menghbungkan ke wfi

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

  rgb(LOW,HIGH,LOW); // Jika Hijau maka wifi terhbung

  while(!client.connect("clientid-unik")){
    delay(500);
  }

  rgb(LOW,LOW,HIGH); // Jika biru maka terhbung ke broker MQTT

  client.subscribe("kelasiot/#", 1); // subscribe ke qos 1 jika berhasil terhbung
}