#include <WiFi.h>
#include <PubSubClient.h>
#include <Adafruit_SSD1306.h>
#include <DHT.h>
DHT dht(13,DHT22);

#define LARG_OLED 128
#define ALT_OLED 64
#define RST_OLED -1
Adafruit_SSD1306 dsp(LARG_OLED, ALT_OLED, &Wire, RST_OLED);

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

const char* mqtt_server = "test.mosquitto.org";

WiFiClient ClienteWokwi;
PubSubClient client(ClienteWokwi);

float T,H;

void setup() {
  Serial.begin(115200);
  dht.begin();
  dsp.begin(SSD1306_SWITCHCAPVCC, 0x3C);
  dsp.setTextSize(1);
  dsp.setTextColor(WHITE);
  dsp.display();
  delay(2000);
  dsp.clearDisplay();
  dsp.setTextSize(1);
  dsp.setCursor(20,20);
  dsp.print("Curso Wokwi");
  dsp.setCursor(15,45);
  dsp.print("Atividade - 01");
  dsp.display();
  delay(2000);

  Serial.print("Conectando... ");
  Serial.print(ssid);
  WiFi.mode(WIFI_STA);
  WiFi.begin(ssid, password,6);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println("WiFi connectado!");
  Serial.println("Endereco IP: ");
  Serial.println(WiFi.localIP());

  client.setServer(mqtt_server, 1883);
}

void loop() {
  T=dht.readTemperature();
  H=dht.readHumidity();
  Serial.print(T,1);Serial.print("ºC");Serial.print(",");
  Serial.print(H,1);Serial.print("%");Serial.print("\n");
  dsp.clearDisplay();
  dsp.setTextSize(2);
  dsp.setCursor(0,10);
  dsp.print("T=");
  dsp.print(T,1);
  dsp.write(248);
  dsp.print("C");
  dsp.setCursor(0,40);
  dsp.print("H=");
  dsp.print(H,1);
  dsp.print("%");
  dsp.display();

  if (!client.connected()) {
    reconnect();
  }
  publica_dados();

  delay(5000);
}


void reconnect() {
  while (!client.connected()) {
    Serial.print("Estabelecendo conexao MQTT...");
    if (client.connect("ClienteWokwi")) {
      Serial.println("Conectado");
    } else {
      Serial.print("failed, rc=");
      Serial.print(client.state());
      Serial.println(" tentando novamente em 5 segundos");
      // Aguardando 5 segundos
      delay(5000);
    }
  }
}

void publica_dados()
{
  client.publish("topico_temp",String(T).c_str(),true);
  client.publish("topico_hum",String(H).c_str(),true);
  delay(1000);
}