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

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

const int pinRed = 2;
const int pinGreen = 4;
const int pinBlue = 16;

WiFiClient net;
MQTTClient client;

void setup() {
  pinMode(33, OUTPUT);
  pinMode(pinRed, OUTPUT);
  pinMode(pinGreen, OUTPUT);
  pinMode(pinBlue, OUTPUT);
  Serial.begin(9600);
  WiFi.begin(ssid, pass);
  client.begin("broker.emqx.io", net);

  client.onMessage(diterima);

  connect();
}

void loop() {
  client.loop();
  delay(10);
  // client.publish("kelasiot/mantap", "ini datanya");
}

void connect(){
  Serial.print("Menghubungkan ke WiFi");
  while(WiFi.status() != WL_CONNECTED){
    rgb(1,0,0);
    delay(500);
  }
  

  rgb(0,1,0);
  while(!client.connect("TIDAK BOLEH SAMA!!")){
    Serial.print(".");
  }
  rgb(0,0,1);
  client.subscribe("kelasiot/lampu/#", 1);

}


void diterima(String &topic, String &data){
  if(topic == "kelasiot/lampu/dapur"){
    if(data == "true"){
      digitalWrite(33, 1);
      Serial.println("nyala");
    } else {
      digitalWrite(33, 0);
      Serial.println("mati");
    }
  }
}

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