#include <WiFi.h>               // library for WiFi
#include <PubSubClient.h>       // library for MQTT

#define LED 5
#define LED2 4
#define LED3 2
int LDR = 32;
int LDRReading = 0;
int threshold_val = 800;
int lEDBrightness = 0;
int flag = 0;

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

//-------credentials of IBM Accounts------
#define ORG "stuloy"              // IBM ORGANIZATION ID
#define DEVICE_TYPE "abcd"        // Device type mentioned in IBM Watson IoT Platform
#define DEVICE_ID "1234"          // Device ID mentioned in IBM Watson IoT Platform
#define TOKEN "12345678"          // Token
String data3;
float h, t;

//-------- Customise the above values --------
char server[] = ORG ".messaging.internetofthings.ibmcloud.com";   // Server Name
char publishTopic[] = "iot-2/evt/Data/fmt/json";                   // Topic name and type of event performed and format in which data to be sent
char subscribetopic[] = "iot-2/cmd/test/fmt/String";               // Command represents command type and command is "test" of format string
char authMethod[] = "use-token-auth";                              // Authentication method
char token[] = TOKEN;
char clientId[] = "d:" ORG ":" DEVICE_TYPE ":" DEVICE_ID;          // Client ID

//-----------------------------------------
WiFiClient wifiClient;                                              // Creating an instance of WiFiClient
PubSubClient client(server, 1883, callback, wifiClient);             // Initializing PubSubClient with server, port, callback, and WiFiClient

void setup()
{
  Serial.begin(115200);

  pinMode(LED, OUTPUT);
  pinMode(LED2, OUTPUT);
  pinMode(LED3, OUTPUT);
  delay(10);
  Serial.println();
  wificonnect();
  mqttconnect();
}

void loop()
{
  if (!client.loop()) {
    mqttconnect();
  }
}

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);  // Passing WiFi credentials to establish the connection
  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 FAILED");
  }
}

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++) {
    data3 += (char)payload[i];
  }

  Serial.println("data: " + data3);
  if (data3 == "lighton1") {
    Serial.println(data3);
    digitalWrite(LED, HIGH);
  } else if (data3 == "lightoff1") {
    Serial.println(data3);
    digitalWrite(LED, LOW);
  } else if (data3 == "lighton2") {
    Serial.println(data3);
    digitalWrite(LED2, HIGH);
  } else if (data3 == "lightoff2") {
    Serial.println(data3);
    digitalWrite(LED2, LOW);
  } else if (data3 == "lighton3") {
    Serial.println(data3);
    digitalWrite(LED3, HIGH);
  } else if (data3 == "lightoff3") {
    Serial.println(data3);
    digitalWrite(LED3, LOW);
  }
  data3 = "";
}