#include <WiFi.h>
#include "PubSubClient.h"

const char* ssid = "Wokwi-GUEST";
const char* password = "";
const char* mqttServer = "broker.emqx.io";
int port = 1883;
String stMac;
char mac[50];
char clientId[50];

WiFiClient espClient;
PubSubClient client(espClient);

unsigned long pesanTerakhir = 0;
#define MSG_BUFFER_SIZE (50)
char pesan[MSG_BUFFER_SIZE];
int nilaiValue = 0;

const int pinLedBiru = 13;
const int pinLedMerah = 12;
const int pinLedKuning = 14;

void setup() {
  Serial.begin(115200);
  randomSeed(analogRead(0));

  delay(10);
  Serial.println();
  Serial.print("Terkoneksi Ke ");
  Serial.println(ssid);

  WiFiConnect();

  Serial.println("");
  Serial.println("WiFi Terkoneksi");
  Serial.println("IP Address: ");
  Serial.println(WiFi.localIP());
  Serial.println(WiFi.macAddress());
  stMac = WiFi.macAddress();
  stMac.replace(":","_");
  Serial.println(stMac);

  client.setServer(mqttServer, port);
  client.setCallback(callback);
  Serial.println(pinLedBiru, OUTPUT);
  Serial.println(pinLedMerah, OUTPUT);
  Serial.println(pinLedKuning, OUTPUT);

}

void WiFiConnect() {
  WiFi.mode(WIFI_STA);
  WiFi.begin(ssid, password);
  while (WiFi.status() !=WL_CONNECTED){
    delay(500);
    Serial.print(".");
  }
  }

void mqttRecconect(){
  while (!client.connected()){
    Serial.print("Menghubungkan Koneksi MQTT");
    long data = random(1000);
    sprintf(clientId, "client-%Id", data);
    if (client.connect(clientId)){
        Serial.print(clientId);
        Serial.println(" Terkoneksi ");
        client.subscribe("Artika/projectKomputerVision333");

    }else{
      Serial.print(" Gagal, koneksi");
      Serial.print(client.state());
      Serial.println(" Tunggu waktu sampai 5 detik ");
      delay(5000);
}
}
}

void callback(char* topic, byte* message, unsigned int length){
  if((char)message[0] == '1'){
    ledBiruOFF();
  }
  else{
    ledBiruON();
  }
  if((char)message[0] == '2'){
    ledMerahOFF();
  }
  else{
    ledMerahON();
  }
  if((char)message[0] == '3'){
    ledKuningOFF();
  }
  else{
    ledKuningON();
  }
}

void ledBiruON(){
  digitalWrite(pinLedBiru, HIGH);
}

void ledBiruOFF(){
  digitalWrite(pinLedBiru, LOW);
}

void ledMerahON(){
  digitalWrite(pinLedMerah, HIGH);
}

void ledMerahOFF(){
  digitalWrite(pinLedMerah, LOW);
}

void ledKuningON(){
  digitalWrite(pinLedKuning, HIGH);
}

void ledKuningOFF(){
  digitalWrite(pinLedKuning, LOW);
}

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