/*
  O projeto não foi incluido a Alexa por conta da limitação do simulador. Apenas o protocolo MQTT foi
  integrado na simulação
*/

#include <WiFi.h>

#include <Adafruit_GFX.h>
#include <Adafruit_SSD1306.h>
#include "PubSubClient.h"

#define WIFI_SSID       "Wokwi-GUEST"
#define WIFI_PASS       ""

#define LED_AZUL        19
#define LED_AMARELO     5
#define LED_VERDE       4

const char *mqttServer = "broker.hivemq.com";
const int port = 1883;
char clientId[50];
String stMac;
char mac[50];


WiFiClient espClient;
PubSubClient client(espClient);

Adafruit_SSD1306 display(-1);

const float BETA = 3950; // Deve corresponder ao coeficiente beta do termistor

void setup() {

  Serial.begin(115200);
  randomSeed(analogRead(0));
  analogReadResolution(10);
  pinMode(32, INPUT);

  pinMode(LED_AZUL, OUTPUT);
  pinMode(LED_AMARELO, OUTPUT);
  pinMode(LED_VERDE, OUTPUT);
  pinMode(2, OUTPUT);

  digitalWrite(2, HIGH);

  delay(10);
  Serial.println();
  Serial.print("Connecting to ");
  Serial.println(WIFI_SSID);

  wifiConnect();

  Serial.println("");
  Serial.println("WiFi connected");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());
  Serial.println(WiFi.macAddress());
  stMac = WiFi.macAddress();
  stMac.replace(":", "_");
  Serial.println(stMac);
  client.setServer(mqttServer, port);
  client.setCallback(callback);

  display.begin(SSD1306_SWITCHCAPVCC, 0x3C);
  display.clearDisplay();
  // Display Text
  display.setTextSize(1);
  display.setTextColor(WHITE);
  display.setCursor(10, 28);
  display.println("Bem vindo (a)");
  display.setCursor(10, 38);
  display.println("a Casa Inteligente");
  display.display();

}

void wifiConnect() {
  WiFi.mode(WIFI_STA);
  WiFi.begin(WIFI_SSID, WIFI_PASS);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
}


void loop() {

  if (!client.connected()) {
    mqttReconnect();
  }

  client.loop();
}

void mqttReconnect() {
  while (!client.connected()) {
    Serial.print("Attempting MQTT connection...");
    long r = random(1000);
    sprintf(clientId, "clientId-%ld", r);
    if (client.connect(clientId)) {
      Serial.print(clientId);
      Serial.println(" connected");
      client.subscribe("Snarloff/sala");
      client.subscribe("Snarloff/quarto");
      client.subscribe("Snarloff/cozinha");
      client.subscribe("Snarloff/intensidade");
      client.subscribe("Snarloff/intensidadequarto");
      client.subscribe("Snarloff/intensidadecozinha");
      client.subscribe("Snarloff/sensor");
      client.subscribe("Snarloff/temperatura");
    } else {
      Serial.print("failed, rc=");
      Serial.print(client.state());
      Serial.println(" try again in 5 seconds");
      delay(5000);
    }
  }
}

void callback(char *topic, byte *message, unsigned int length) {
  Serial.print("Mensagem recebida no topico: ");
  Serial.print(topic);
  Serial.print(". Messagem: ");
  String stMessage;

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

  Serial.println();

  if (String(topic) == "Snarloff/sala") {
    Serial.print("Saida alterada para ");
    if (stMessage == "on") {
      powerMessage("Ligando a luz da sala...");
      Serial.println("on");
      analogWrite(LED_AZUL, 255);
    } else if (stMessage == "off") {
      powerMessage("Desligando a luz da sala...");
      Serial.println("off");
      analogWrite(LED_AZUL, 0);
    }
  }

  if (String(topic) == "Snarloff/cozinha") {
    Serial.print("Saida alterada para ");
    if (stMessage == "on") {
      powerMessage("Ligando a luz da cozinha...");
      Serial.println("on");
      analogWrite(LED_AMARELO, 255);
    } else if (stMessage == "off") {
      powerMessage("Desligando a luz da cozinha...");
      Serial.println("off");
      analogWrite(LED_AMARELO, 0);
    }
  }

  if (String(topic) == "Snarloff/quarto") {
    Serial.print("Saida alterada para");
    if (stMessage == "on") {
      powerMessage("Ligando a luz do quarto...");
      Serial.println("on");
      analogWrite(LED_VERDE, 255);
    } else if (stMessage == "off") {
      powerMessage("Desligando a luz do quarto...");
      Serial.println("off");
      analogWrite(LED_VERDE, 0);
    }
  }

  if (String(topic) == "Snarloff/intensidade") {
    Serial.print("Alterando intensidade para ");
    analogWrite(LED_AZUL, stMessage.toInt());
    powerMessage("Intensidade para " + String(stMessage));
  }

  if (String(topic) == "Snarloff/intensidadequarto") {
    Serial.print("Alterando intensidade para ");
    analogWrite(LED_VERDE, stMessage.toInt());
    powerMessage("Intensidade para " + String(stMessage));
  }

  if (String(topic) == "Snarloff/intensidadecozinha") {
    Serial.print("Alterando intensidade para ");
    analogWrite(LED_AMARELO, stMessage.toInt());
    powerMessage("Intensidade para " + String(stMessage));
  }

  if (String(topic) == "Snarloff/sensor") {
    Serial.print("Sensor alterado para");
    if (stMessage == "on") {

      powerMessage("Lendo sensor...");
      int analogValue = analogRead(32);
      float celsius = 1 / (log(1 / (1023. / analogValue - 1)) / BETA + 1.0 / 298.15) - 273.15;
      Serial.print("Temperature: ");
      Serial.print(celsius);

      char msg_out[20];
      dtostrf(celsius, 2, 2, msg_out);

      client.publish("Snarloff/temperatura", msg_out);


    } else if (stMessage == "off") {

      powerMessage("Desligando a leitura do sensor...");
      Serial.println("off");


    }
  }

}

void powerMessage(const String &message) {

  // Clear the buffer.
  display.clearDisplay();

  // Display Text
  display.setTextSize(1);
  display.setTextColor(WHITE);
  display.setCursor(0, 28);
  display.println(message);
  display.display();

}