#if defined(ESP8266)
#include <ESP8266WiFi.h>
#elif defined(ESP32)
#include <WiFi.h>
#endif
#include "ThingsBoard.h"
#include <PubSubClient.h>
#include <DHT.h>

// Define pins used for DHT22 sensor and potentiometer
#define DHTPIN 4 // Pin connected to DHT22 sensor data pin
#define DHTTYPE DHT22 // DHT sensor type (DHT22)
#define POTPIN 34  // Pin connected to potentiometer pin 34

// WiFi Configuration
const char *ssid = "Wokwi-GUEST";
const char *password = "";

// ThingsBoard Configuration
#define TOKEN "FJeuo1Bak5EMTr2Ca9qu" // Access token of the device Display
const char* mqtt_server = "thingsboard.cloud";

// Initialize DHT22 sensor
DHT dht(DHTPIN, DHTTYPE);

WiFiClient wifiClient;
PubSubClient client(wifiClient);
int status = WL_IDLE_STATUS;

void setup() {
Serial.begin(9600);
delay(10);
pinMode(DHTPIN, INPUT);
pinMode(POTPIN, INPUT);
// Initialize DHT22 sensor
dht.begin();
// Initialize WiFi connection
Serial.print("Connecting to ");
Serial.println(ssid);
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(".");
 }
Serial.println();
Serial.print("Connected to WiFi network with IP address: ");
 Serial.println(WiFi.localIP());
// Connect to ThingsBoard MQTT server
client.setServer(mqtt_server, 1883);
}

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

// Read temperature and humidity values from DHT22 sensor
float humidity = dht.readHumidity();
float temperature = dht.readTemperature();
 // Read potentiometer value
int potValue = analogRead(POTPIN);

// Convert sensor data to strings
char humidityStr[8];
dtostrf(humidity, 4, 2, humidityStr);
char temperatureStr[8];
dtostrf(temperature, 4, 2, temperatureStr);
char potValueStr[8];
dtostrf(potValue, 4, 0, potValueStr);

// Construct payload for ThingsBoard
char attributes[100];
snprintf(attributes, sizeof(attributes), "{\"temperature\":%s,\"humidity\":%s,\"potValue\":%s}", temperatureStr, humidityStr, potValueStr);

// Publish data to ThingsBoard using MQTT
client.publish("v1/devices/me/telemetry", attributes);
Serial.println(attributes);

delay(1000); // Adjust delay as needed
}

void reconnect() {
// Loop until reconnected
while (!client.connected()) {
Serial.print("Attempting MQTT connection...");
 // Attempt to connect
 if (client.connect("3a90f960-1ad1-11ed-b480-cbe4cea4aa70", TOKEN, "")) {
Serial.println("connected");
} else {
Serial.print("failed, rc=");
Serial.print(client.state());
Serial.println(" retrying in 5 seconds");
delay(5000);
}
}
}