#include <WiFi.h>
#include <MQTT.h>
const char ssid[] = "Wokwi-GUEST";
const char pass[] = "";
WiFiClient net;
MQTTClient client;
unsigned long lastMillis = 0;
int pot;
void connect() {
Serial.print("checking wifi...");
while (WiFi.status() != WL_CONNECTED) {
Serial.print(".");
delay(1000);
}
Serial.print("\nconnecting...");
while (!client.connect("fadiah")) {
Serial.print(".");
delay(1000);
}
Serial.println("\nconnected!");
client.subscribe("gedung1/fadiah");
// client.unsubscribe("/hello");
}
void dataDiterima(String &topic, String &payload) {
Serial.println("incoming: " + topic + " - " + payload);
if(topic == "gedung1/fadiah" && payload =="nyala"){
digitalWrite(5, HIGH);
} else if(topic == "gedung1/fadiah" && payload =="mati"){
digitalWrite(5, LOW);
} else if(topic == "gedung1/fadiah" && payload =="on"){
digitalWrite(23, HIGH);
} else if(topic == "gedung1/fadiah" && payload =="off"){
digitalWrite(23, LOW);
}
}
void setup() {
Serial.begin(115200);
WiFi.begin(ssid, pass);
client.begin("broker.emqx.io", net);
client.onMessage(dataDiterima);
connect();
pinMode(5, OUTPUT);
pinMode(23, OUTPUT);
}
void loop() {
client.loop();
delay(10); // <- fixes some issues with WiFi stability
pot = analogRead(34);
}