/*
#include "DHTesp.h"

const int DHT_Pin=15;

DHTesp dhtSensor;

void setup() {
  // put your setup code here, to run once:
  Serial.begin(115200);
  dhtSensor.setup(DHT_Pin, DHTesp::DHT22);
}

void loop() {
 // put your main code here, to run repeatedly:
  TempAndHumidity data = dhtSensor.getTempAndHumidity();
  Serial.println("Temp:" + String(data.temperature, 2)+"'C");
  Serial.println("Humidity:" + String(data.humidity, 1)+"%");
  Serial.println("---");
  delay(1000);
}


#include <WiFi.h>

const char* ssid = "Wokwi-GUEST";
const char* password = "";

void wifiConnect() {
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println(" Connected!");
}

void setup() {
  Serial.begin(9600);
  Serial.print("Connecting to WiFi");

  wifiConnect();
}

void loop() {
  delay(5000);
}
*/


#include <WiFi.h>
#include <PubSubClient.h>
#include "DHTesp.h"

const int DHT_Pin=15;

DHTesp dhtSensor;

const char* ssid = "Wokwi-GUEST";
const char* password = "";

//***Set server***
const char* mqttServer = "broker.hivemq.com"; 
int port = 1883;

WiFiClient wifiClient;
PubSubClient mqttClient(wifiClient);

void wifiConnect() {
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println(" Connected!");
}

void mqttConnect() {
  while(!mqttClient.connected()) {
    Serial.println("Attemping MQTT connection...");
    String clientId = "ESP32Client-";
    clientId += String(random(0xffff), HEX);
    if(mqttClient.connect(clientId.c_str())) {
      Serial.println("connected");
      mqttClient.subscribe("21127670/mssv");
      //***Subscribe all topic you need***
     
    }
    else {
      Serial.println("try again in 5 seconds");
      delay(5000);
    }
  }
}

//MQTT Receiver
void callback(char* topic, byte* message, unsigned int length) {
  Serial.println(topic);
  String strMsg;
  for(int i=0; i<length; i++) {
    strMsg += (char)message[i];
  }
  Serial.println(strMsg);
  char buffer[50];
  if(strMsg == "21127670"){
    sprintf(buffer,"21127670-Hồ Thế Phúc");
    mqttClient.publish("21127670/mssv_list", buffer);
  }
  else if(strMsg = "21127262"){
    sprintf(buffer,"21127262-Lê Trường Giang");
    mqttClient.publish("21127670/mssv_list", buffer);
  }
  else if(strMsg = "21127342"){
    sprintf(buffer,"21127342-Nguyễn Đức Việt Linh");
    mqttClient.publish("21127670/mssv_list", buffer);
  }
  //***Code here to process the received package***

}

void setup() {
  Serial.begin(9600);
  Serial.print("Connecting to WiFi");
  pinMode(12, OUTPUT);
  dhtSensor.setup(DHT_Pin, DHTesp::DHT22);

  wifiConnect();
  mqttClient.setServer(mqttServer, port);
  mqttClient.setCallback(callback);
  mqttClient.setKeepAlive( 90 );
}


void loop() {
  if(!mqttClient.connected()) {
    mqttConnect();
  }
  mqttClient.loop();

  //***Publish data to MQTT Server***
  //TempAndHumidity data = dhtSensor.getTempAndHumidity();
  //int temp = data.temperature;
  //int humid = data.humidity;
  //char buffer[50];
  //sprintf(buffer,"{\"key1\":%d, \"key2\":%d}", temp, humid);
  //mqttClient.publish("21127670/mssv_list", buffer);
  
  delay(5000);
}