#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 = "";
const char* mqttServer = "broker.hivemq.com";
#define MQTT_USERNAME "allarm"
#define MQTT_PASSWORD "1234"
#define MQTT_NAME     "mymqtt"
int port = 1883;
double lasttime;
// ThingsBoard Configuration
// #define TOKEN "KeH41967yQPsJaORlyYs" // Access token of the device Display
//const char* mqtt_server = "broker.hivemq.com";

// 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(mqttServer, port);
}

void loop() {
  if (!client.connected()) {
    reconnect();
  }
  if(millis()-lasttime > 10000){
  // 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 msg[100];
  snprintf(msg, sizeof(msg), "{\"temperature\":%s,\"humidity\":%s,\"potValue\":%s}", temperatureStr, humidityStr, potValueStr);

  // Publish data to ThingsBoard using MQTT
   client.publish("v1/devices/me/telemetry/ee", msg);
   Serial.println(msg);
   lasttime = millis();
  }
  //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(MQTT_NAME, MQTT_USERNAME, MQTT_PASSWORD)) {
      //Serial.print(clientId);
      Serial.println(" connected");
      //client.subscribe("/topicName/led");
    } else {
      Serial.print("failed, rc=");
      //Serial.print(client.state());
      Serial.println(" try again in 5 seconds");
      delay(5000);
    }
  }
}