#include "WiFi.h"
#include "Adafruit_MQTT.h"
#include "Adafruit_MQTT_Client.h"
// Adafruit IO setup
#define Server      "io.adafruit.com"
#define Serverport  1883
#define username  "ruthwiik8reddy"
#define key  "aio_QopB55TBrVHBeD2C7glHF8x3t7Rh" 
WiFiClient client;
Adafruit_MQTT_Client mqtt(&client,Server,Serverport,username,key);
Adafruit_MQTT_Subscribe light = Adafruit_MQTT_Subscribe(&mqtt, username "/f/light");

void setup() {
  // put your setup code here, to run once:
  Serial.begin(115200);
  pinMode(15, OUTPUT);
  wifisetup();
  mqtt.subscribe(&light);
  digitalWrite(15, HIGH);//LED ON
  delay(200);
  digitalWrite(15, LOW);//LED OFF
}

void loop() {
  // put your main code here, to run repeatedly:
  adafruitfunc();
  delay(10); // this speeds up the simulation
}

void wifisetup(){
  WiFi.disconnect();
  WiFi.begin("Wokwi-GUEST", "");
  while(WiFi.status()!=WL_CONNECTED){
    delay(200);
    Serial.print("*");
  }
  Serial.println("Connected");
  Serial.println(WiFi.localIP());
}

void adafruitfunc(){
 connect();
 Adafruit_MQTT_Subscribe *subscription;
  while ((subscription = mqtt.readSubscription(1000))) {
    // Handle the received data here
    if (subscription == &light) {
      Serial.print("Received: ");
      Serial.println((char *)light.lastread);
      if(!strcmp((char *)light.lastread, "ON"))
         digitalWrite(15, HIGH);
      else if(!strcmp((char *)light.lastread, "OFF"))
         digitalWrite(15,LOW);
    }
  }
}
void connect(){
 int8_t ret;

  // Stop if already connected.
  if (mqtt.connected()) {
    return;
  }

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

  uint8_t retries = 3;
  while ((ret = mqtt.connect()) != 0) { // connect will return 0 for connected
       Serial.println(mqtt.connectErrorString(ret));
       Serial.println("Retrying MQTT connection in 5 seconds...");
       mqtt.disconnect();
       delay(5000);  // wait 5 seconds
       retries--;
       if (retries == 0) {
         // basically die and wait for WDT to reset me
         while (1);
       }
  }
  Serial.println("MQTT Connected!");
}