#include <WiFi.h>
#include "Adafruit_MQTT.h"
#include "Adafruit_MQTT_Client.h"
#include "DHT.h"

#define DHTPIN 13
#define DHTTYPE DHT11
DHT dht(DHTPIN, DHTTYPE);
void MQTT_connect();

int led1=2;

#define WLAN_SSID "Wokwi-GUEST"
#define WLAN_PASS ""

#define AIO_SERVER "io.adafruit.com"
#define AIO_SERVERPORT 1883
#define AIO_USERNAME "dharun_2003"
#define AIO_KEY "aio_WpTi57fkurDyjr3sFCK74Fu7MGMa"

WiFiClient client;
Adafruit_MQTT_Client mqtt(&client,AIO_SERVER,AIO_SERVERPORT,AIO_USERNAME,AIO_KEY);

Adafruit_MQTT_Publish dht_temp = Adafruit_MQTT_Publish(&mqtt,AIO_USERNAME"/feeds/DHT_TEMP");
Adafruit_MQTT_Publish dht_humditiy = Adafruit_MQTT_Publish(&mqtt,AIO_USERNAME"/feeds/DHT_Humidity");

Adafruit_MQTT_Subscribe onoffbutton = Adafruit_MQTT_Subscribe (&mqtt,AIO_USERNAME"/feeds/onoff");

void setup(){
  Serial.begin(9600);
  delay(10);

  Serial.println (F("DHTxx test!"));
  dht.begin();
  Serial.println(F("Adafruit MQTT demo"));

  Serial.println(); Serial.println();
  Serial.print("Conneting to ");
  Serial.println(WLAN_SSID);

  WiFi.begin(WLAN_SSID, WLAN_PASS);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print("");
  }
  Serial.println();
  
  Serial.println("WiFi connected");
  Serial.println("IP address: "); Serial.println(WiFi.localIP());
  //digitalwrite(led1, HIGH);

  //Setup MQTT subscription for onoff feed.
  pinMode(led1,OUTPUT);
  mqtt.subscribe(&onoffbutton);

  //digitalWrite(led1, HIGH),
}

void loop(){
  MQTT_connect();

  Adafruit_MQTT_Subscribe *subscription;
  while ((subscription = mqtt.readSubscription(5000))){
  if (subscription == &onoffbutton) {
    Serial.print(F("Got: "));
    Serial.println((char *)onoffbutton.lastread);
  if (strcmp((char*)onoffbutton.lastread,"ON")==0){
  digitalWrite(led1, HIGH);
  Serial.println("led is on");
  }
  if (strcmp((char *)onoffbutton.lastread, "OFF")==0) {
    digitalWrite(led1, LOW);
    Serial.println("led is off");
  }
  }
  }
  float h =dht.readHumidity();
  float t =dht.readTemperature();
  float f = dht.readTemperature(true);
  //int r=analogRead(A6):

  Serial.print("Humidity(%): ");
  Serial.print(h);
  Serial.print(" Temperature (°C): ");

  Serial.print(t);
  Serial.print("Temperature(F): ");
  Serial.println(f);

  if (! dht_temp.publish(t)) {
  Serial.println(F("Failed"));
 } else {
  Serial.println(F("OK!"));
  delay(10000);
 }
 if (! dht_humditiy.publish(h)){
  Serial.println(F("Failed"));
} else {
  Serial.println(F("OK!"));
 }
 /*delay( 1000);
 if (! pot.publish(r)){
 Serial.println(F("Failed"));
} else{}
Serial.println(F("OK!");
}*/
/*
if(! mqtt.ping()) {
  mqtt.disconnect();
}
*/
}

void MQTT_connect(){
  int8_t ret;

  if(mqtt.connected()){
    return;
  }

  Serial.print("Connecting to MQTT..");

  uint8_t retries = 1;
  while((ret=mqtt.connect())!=0){
    Serial.println((mqtt.connectErrorString(ret)));
    Serial.println("Retrying MQTT connection in 3 seconds...");
    mqtt.disconnect();
    delay(3000);
    retries--;
    if(retries == 0){
      while(1);
    }
  }
  Serial.println("MQTT Connected!");
}