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

const int pinMerah = 2;
const int pinGreen = 4;
const int pinBlue = 16;
const int pinLed1 = 14;
const int pinLed2 = 27;

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

WiFiClient net;
MQTTClient client;

void setup()
{
  Serial.begin(9600);
  pinMode(pinMerah, OUTPUT);
  pinMode(pinGreen, OUTPUT);
  pinMode(pinBlue, OUTPUT);
  pinMode(pinLed1, OUTPUT);
  pinMode(pinLed2, OUTPUT);
  WiFi.begin(ssid, pass);
  client.begin("broker.emqx.io", net);
  client.onMessage(messageReceived);
  connect();
}

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

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

void messageReceived(String &topic, String &payload) {
  Serial.println("incoming: " + topic + " - " + payload);
  if(topic == "kelasiot/LED1"){
    if (payload == "Nyala"){
      led(14,1);
    } else if(payload == "Mati"){
      led(14,0);
    }
  }
  if(topic == "kelasiot/LED2"){
    if (payload == "Nyala"){
      led(27,1);
    } else if(payload == "Mati"){
      led(27,0);
    }
  }
}

void connect(){
    rgb(1, 0, 0);
  while (WiFi.status() != WL_CONNECTED)
  {
    delay(500);
  }
  rgb(0, 1, 0);
  while (!client.connect("ddbhbahdbavfvdfd66")) {
    Serial.print(".");
    delay(1000);
  }
  rgb(0, 0, 1);
  client.subscribe("kelasiot/+");
}

void led(int Ledx, int ledStatus){
  digitalWrite(Ledx, ledStatus);
}