#include <WiFi.h>
#include <PubSubClient.h>
#include <DHT.h> // Library for DHT sensor

// DHT sensor pin configuration
#define DHT_PIN 4
#define DHT_TYPE DHT22

float pressure;
float leakage;
float temperature;
float humidity;
char data3;

void callback(char* subscribetopic, byte* payload, unsigned int payloadLength);

// IBM Watson IoT Platform credentials
#define ORG "c1nban"
#define DEVICE_TYPE "Gas_Pipeline_Monitoring"
#define DEVICE_ID "100100C40A24"
#define TOKEN "20021215"

// Customized values
char server[] = ORG ".messaging.internetofthings.ibmcloud.com";
char publishTopic[] = "iot-2/evt/Data/fmt/json";
char subscribetopic[] = "iot-2/cmd/test/fmt/String";
char authMethod[] = "use-token-auth";
char token[] = TOKEN;
char clientId[] = "d:" ORG ":" DEVICE_TYPE ":" DEVICE_ID;

WiFiClient wifiClient;
PubSubClient client(server, 1883, callback ,wifiClient);
DHT dht(DHT_PIN, DHT_TYPE);

void setup()
{
  Serial.begin(115200);
  delay(10);
  Serial.println();
  wificonnect();
  mqttconnect();
  dht.begin(); // Initialize DHT sensor
}

void loop()
{
  pressure = analogRead(34);
  leakage = analogRead(32);
  temperature = dht.readTemperature(); // Read temperature from DHT sensor
  humidity = dht.readHumidity(); // Read humidity from DHT sensor

  Serial.print("Pressure: ");
  Serial.println(pressure);
  Serial.print("Leakage: ");
  Serial.println(leakage);
  Serial.print("Temperature: ");
  Serial.println(temperature);
  Serial.print("Humidity: ");
  Serial.println(humidity);
  delay(1000);

  PublishData(pressure, leakage, temperature, humidity);
  delay(1000);
  
  if (!client.loop()) {
    mqttconnect();
  }
}

void PublishData(float pressure, float leakage, float temperature, float humidity)
{
  mqttconnect();

  String payload = "{\"pressure\":";
  payload += pressure;
  payload += ",\"leakage\":";
  payload += leakage;
  payload += ",\"temperature\":";
  payload += temperature;
  payload += ",\"humidity\":";
  payload += humidity;
  payload += "}";

  Serial.print("Sending payload: ");
  Serial.println(payload);

  if (client.publish(publishTopic, (char*) payload.c_str())) {
    Serial.println("Publish ok");
  } else {
    Serial.println("Publish failed");
  }
}

void mqttconnect()
{
  if (!client.connected()) {
    Serial.print("Reconnecting client to ");
    Serial.println(server);
    while (!!!client.connect(clientId, authMethod, token)) {
      Serial.print(".");
      delay(500);
    }
    initManagedDevice();
    Serial.println();
  }
}

void wificonnect()
{
  Serial.println();
  Serial.print("Connecting to ");
  WiFi.begin("Wokwi-GUEST", "", 6);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println("");
  Serial.println("WiFi connected");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());
}

void initManagedDevice()
{
if (client.subscribe(subscribetopic)) { Serial.println((subscribetopic)); Serial.println("subscribe to cmd OK"); } else {

Serial.println("subscribe to cmd FAIILED");

} }

void callback(char* subscribetopic, byte* payload, unsigned int payloadLength) {

Serial.print("callback invoked for topic: ");

Serial.println(subscribetopic);

for (int i = 0; i < payloadLength; i++) { //Serial.print((char)payload[i]); 
 data3 += (char)payload[i];

}

Serial.println("data: "+ data3);

data3="";
}