//https://testclient-cloud.mqtt.cool/

// Codice per il monitoraggio da remoto della temperatura e umidità
#include "Adafruit_Sensor.h"
#include <DHT.h>

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

#include <iostream>
#include <string>

// Wokwi Virtual WiFi
const char* ssid = "Wokwi-GUEST";
const char* password = "";

const char* mqtt_server = "test.mosquitto.org";// MQTT Broker address
int mqtt_broker_port = 1883;

char* mqttTopic_DHT_temp = "esp32/iot1/dht/temp"; // MQTT topic2: sensor-temerature
char* mqttTopic_DHT_hum = "esp32/iot1/dht/hum";  // MQTT topic3: sensor-humidity
char* mqttTopic_DHT_dist = "esp32/iot1/dht/dist"; // MQTT topic2: sensor-temerature
char* mqttTopic_JSON = "esp32/iot1/payloadJSON"; // MQTT topic2: sensor-temerature

WiFiClient wifiClient;
PubSubClient pubSubClient(wifiClient);
// Se si volessero introdurre certificati di SSL/TLS bisognerebbe
// creare qui gli oggetti a partire dal client(espClient)


//Constants
#define DHTPIN 4     // pin DATI sul GPIO
#define DHTTYPE DHT11   // Sensore DHT11 (AM2302)
//#define DHTTYPE DHT22   // DHT 11  (AM2302)
DHT dht(DHTPIN, DHTTYPE); // Inizializza il sensore

float temp;      // valori sensore temperatura
float humidity;  // valori sensore umidità
float distance;  // valori sensore distanza

int LEDPIN = 22; //GPIO pin usato dal LED

void setup() {
  Serial.begin(115200); // Inizializzazione del monitor seriale (solo per il debugging!)
  //myservo.attach(5); // Evetuale servo sul GPIO 5
 
  pinMode(LEDPIN, OUTPUT);
 
  dht.begin();

  setup_wifi();
  pubSubClient.setServer(mqtt_server, mqtt_broker_port); // Server e porta MQTT del broker al quale puntare
  //pubSubClient.setCallback(callback); // Funzione di callback per i messaggi in ingresso
 
  delay(2000);
}

void setup_wifi() { // Connessione al WiFi

  WiFi.mode(WIFI_STA); // default, se non lo si dichiara non serve

  //delay(10);

  Serial.println();
  Serial.print("Connecting to ");
  Serial.println(ssid);

  WiFi.begin(ssid, password);

  while (WiFi.status() != WL_CONNECTED) {
    delay(100);
    Serial.print(".");
  }

  Serial.println("");
  Serial.println("WiFi connected");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP()); // Indirizzo IP associato all'ESP32 una volta connesso
}
// Process incoming MQTT message and control the servo motor
//void callback(char* topic, byte* payload, unsigned int length) {  
  //if (topic = mqttTopic_DHT_temp){
   
  //}
//}

void mqttReconnect() { // Riconnessione al broker MQTT
  while (!pubSubClient.connected()) {
   
    Serial.print("Attempting MQTT connection...");
   
    if (pubSubClient.connect("ESPClient")) {
      Serial.println("connected");
      pubSubClient.subscribe(mqttTopic_DHT_temp);
      pubSubClient.subscribe(mqttTopic_DHT_hum);
      pubSubClient.subscribe(mqttTopic_DHT_dist);
      pubSubClient.subscribe(mqttTopic_JSON);

    } else {
      Serial.print("failed, rc=");
      Serial.print(pubSubClient.state());
      Serial.println(" try again in 5 seconds");
      delay(5000);
    }
  }
}



void loop() {

  //dinamico
  std::string jsonMessage = R"({ "name": "wow", "lat": -33, "lon": 53, "layer": "punti"})";
  //std::string jsonMessage = "AAatest";



  

  if (!pubSubClient.connected()) { // Verifica lo stato della connessione MQTT
    digitalWrite(LEDPIN, LOW);
    mqttReconnect();
  } else {
    digitalWrite(LEDPIN, HIGH);
  }

  pubSubClient.loop();
  delay(100); // ritardo per gestire il canale loop
  temp = dht.readTemperature();
  humidity = dht.readHumidity();
  distance = 5.6; //fix
 
  Serial.print("Temp : ");
  Serial.print(temp);
  Serial.println(" C ");
  Serial.print("Humidity : ");
  Serial.print(humidity);
  Serial.println(" % ");
  Serial.print("Distance : ");
  Serial.print(distance);
  Serial.println(" m ");

  Serial.print("mqttTopic_JSON : ");
  Serial.print(mqttTopic_JSON);
  Serial.println(" ");
  std::cout << "Messaggio JSON: " << jsonMessage << std::endl;
  Serial.println(" ");


  String messaget = String(temp);     // Formato di scambio stringhe  con pubsubclient
  String messageh = String(humidity); // Formato di scambio stringhe  con pubsubclient
  String messaged = String(distance); // Formato di scambio stringhe  con pubsubclient

  pubSubClient.publish(mqttTopic_DHT_temp, messaget.c_str());
  pubSubClient.publish(mqttTopic_DHT_hum, messageh.c_str());
  pubSubClient.publish(mqttTopic_DHT_dist, messaged.c_str());
 
  pubSubClient.publish(mqttTopic_JSON, jsonMessage.c_str());

  delay(1000);
 
}