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

#define led 2
// Deklarasi Variable dan Konstanta
String wifiSSID = "Wokwi-GUEST";
String wifiPassword = "";
String mqttBroker = "test.mosquitto.org";
WiFiClient client;
PubSubClient mqtt(client);

// Deklarasi Fungsi
void connectWifi();
void connect_mqtt();
String randomTemp();
void mqttReceivedMessage(char *topic, byte *msg, unsigned int msgLength);

void setup()
{
    pinMode(15, OUTPUT);
    pinMode(2, OUTPUT);
    pinMode(4, OUTPUT);
    Serial.begin(9600);
    connectWifi();
    mqtt.setServer(mqttBroker.c_str(), 1883);
    mqtt.setCallback(mqttReceivedMessage);
}

void loop()
{
    if (!mqtt.connected())
    {
        connect_mqtt();
        Serial.println("MQTT Connected");
        mqtt.publish("esp32/temphum", "ESP 32 Online!");
    }
    mqtt.loop();
    // mqtt.publish("esp32/temphum", randomTemp().c_str());
    // delay(1000);
}

void mqttReceivedMessage(char *topic, byte *msg, unsigned int msgLength)
{
    if (String(topic) == "esp32/temphum")
    {
        Serial.println(topic);
        String perintah = "";
        for (int i = 0; i < msgLength; i++)
        {
            Serial.print(char(msg[i]));
            perintah += String(char(msg[i]));
        }
        Serial.println("");
        Serial.println(perintah);
        if (perintah == "ON1")
        {
            digitalWrite(15, 1);
        }
        if (perintah == "OFF1")
        {
            digitalWrite(15, 0);
        }
        if (perintah == "ON2")
        {
            digitalWrite(2, 1);
        }
        if (perintah == "OFF2")
        {
            digitalWrite(2, 0);
        }
        if (perintah == "ON3")
        {
            digitalWrite(4, 1);
        }
        if (perintah == "OFF3")
        {
            digitalWrite(4, 0);
        }       
    }
}

String randomTemp()
{

    int randTemp = random(20, 40);
    Serial.println(randTemp);
    return String(randTemp);
}

void connect_mqtt()
{
    while (!mqtt.connected())
    {
        Serial.println("Connecting MQTT...");
        if (mqtt.connect("esp32"))
        {
            mqtt.subscribe("esp32/temphum");
        }
    }
}

void connectWifi()
{
    Serial.println("Connecting To Wifi");
    WiFi.begin(wifiSSID.c_str(), wifiPassword.c_str());
    while (WiFi.status() != WL_CONNECTED)
    {
        Serial.print(".");
        delay(500);
    }

    Serial.println("Wifi Connected");
    Serial.println(WiFi.SSID());
    Serial.println(WiFi.RSSI());
    Serial.println(WiFi.macAddress());
    Serial.println(WiFi.localIP());
    Serial.println(WiFi.gatewayIP());
    Serial.println(WiFi.dnsIP());
}