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

int DHT_Pin = 15;
int pot_pin = 32;

WiFiClient espClient;
PubSubClient mqttClient(espClient);
DHTesp dhtSensor;

char tempAr[6];
char humAr[6];
char potAr[6];

int potVal = 0;

void setup() {
    Serial.begin(115200);
    setupWiFi();
    setupMqtt();
    dhtSensor.setup(DHT_Pin, DHTesp::DHT22);
}

void loop() {
    if (!mqttClient.connected()){
        connectToBroker();
    }

    mqttClient.loop();

    //updateTemperature();
    updatePotentiometer();
    delay(1000);
}

void setupWiFi(){
    WiFi.begin("Wokwi-GUEST", "");
    
    while (WiFi.status() != WL_CONNECTED){
        delay(500);
        Serial.print(".");
    }

    Serial.println("");
    Serial.println("WiFi connected");
    Serial.print("IP address : ");
    Serial.println(WiFi.localIP());
}

void setupMqtt(){
    mqttClient.setServer("test.mosquitto.org", 1883);
    //mqttClient.setCallback(espCallback);
}

void connectToBroker(){
    while (!mqttClient.connected()){
        Serial.print("Attempting MQTT connection...");
        if (mqttClient.connect("ESP32-113165131365")){
            Serial.println("connected");
        }
        else{
            Serial.print("failed ");
            Serial.println(mqttClient.state());
            delay(500);
        }
    }
}

void updateTemperature(){
  TempAndHumidity data = dhtSensor.getTempAndHumidity();
  String(data.temperature, 2).toCharArray(tempAr, 6);
  String(data.humidity, 2).toCharArray(humAr, 6);
  mqttClient.publish("temperature", tempAr);
  mqttClient.publish("humidity", humAr);
}

void updatePotentiometer(){
  potVal = analogRead(pot_pin);
  String(potVal, 2).toCharArray(potAr, 6);
  mqttClient.publish("potentiometer", potAr);
}