#include<PubSubClient.h>
#include <WiFi.h>
const float GAMMA = 0.7;
const float RL10 = 50;

const int LDR_PIN1=4;
const int LDR_PIN2=2;
// DHTesp dht;

const char* ssid="Wokwi-GUEST";
const char* password="";
const char* mqtt_server="test.mosquitto.org";

WiFiClient espClient;
PubSubClient client(espClient);

unsigned long lastMsg=0;
float temp=0;
float hum=0;

void setup_wifi(){
  delay(10);
  Serial.print(" ");
  Serial.print("Connecting to ");
  Serial.println(ssid);

  WiFi.mode(WIFI_STA);
  WiFi.begin(ssid,password);

  while(WiFi.status()!=WL_CONNECTED){
    delay(500);
    Serial.print('.');
  }

  randomSeed(micros());

  Serial.println("WiFi is connected ");
  Serial.print("IP Address : ");
  Serial.println(WiFi.localIP());  

}

void callback(char * topic, byte * payload , unsigned int length){
  Serial.print("Message arrived[ ");
  Serial.print(topic);
  Serial.print(" ]");

  for(int i=0;i<length ;i++){
    Serial.print((char)payload[i]);
  }
}

void reconnect(){
  while(!client.connected()){
    Serial.print("Attempting MQTT connection ...");
    String clientID="ESP32Client";
    clientID+=String(random(0xffff),HEX);
    if(client.connect(clientID.c_str())){
      Serial.println("Client connected");
      client.publish("/DHT/Publish","welcome");
      client.subscribe("/DHT/Subscribe");
    }
    else{
      Serial.print("failed rc= ");
      Serial.print(client.state());
      Serial.println("Try in 5 second....");
      delay(5000);
    }
  }
}


void setup() {
  // put your setup code here, to run once:
  Serial.begin(115200);
  setup_wifi();
  client.setServer(mqtt_server,1883);
  client.setCallback(callback);
  pinMode(LDR_PIN1, INPUT);
  pinMode(LDR_PIN2, INPUT);
}

void loop() {

  if(!client.connected()){
    reconnect();
  }
  client.loop();
  unsigned int now=millis();
  int lux1  = analogRead(LDR_PIN1);
  if(now-lastMsg>200){
   lastMsg=now;
  
  
  Serial.println(lux1);
  if (lux1 < 50) {
    Serial.println(" LED 1 ON!");
  } else {
    Serial.println("LED 1 OFF!");
  }
  Serial.println("            ");
  int lux2 = analogRead(LDR_PIN2);
 
  

   Serial.println(lux2);

  if (lux2 < 50) {
    Serial.println(" LED 2 ON!");
  } else {
    Serial.println("LED 2 OFF!");
  }
   delay(100);

  delay(10); // this speeds up the simulation

   String temp=String(lux1);
   client.publish("/        Temperature and Humidity    /temp",temp.c_str());
   String hum=String(lux2);
   client.publish("/       Temperature and Humidity    /hum",hum.c_str());

   Serial.print("Temperature : ");
   Serial.println(temp);
   Serial.print("Humidity : ");
    Serial.println(hum);
  }

 delay(1000);
}