#include <WiFi.h>
#include <DHTesp.h>
#include <MySQL_Connection.h>
#include <MySQL_Cursor.h>

const int DHT_PIN = 15;
DHTesp dht;

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

IPAddress server_addr(154,26,136,192); // IP dari MySQL server
const char* user = "root";
const char* db_password = "password";
const char* db_name = "bintang_iot";

WiFiClient espClient;

float temp = 0;

void setup_wifi() { //perintah koneksi wifi
  delay(10);
  // We start by connecting to a WiFi network
  Serial.println();
  Serial.print("Connecting to ");
  Serial.println(ssid);

  WiFi.mode(WIFI_STA); //setting wifi chip sebagai station/client
  WiFi.begin(ssid, password); //koneksi ke jaringan wifi

  while (WiFi.status() != WL_CONNECTED) { //perintah tunggu esp32 sampi terkoneksi ke wifi
    delay(500);
    Serial.print(".");
  }

  randomSeed(micros());

  Serial.println("");
  Serial.println("WiFi connected");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());
}

void setup() {
  pinMode(2, OUTPUT);     // inisialisasi pin 2 / ledbuiltin sebagai output
  Serial.begin(115200);
  setup_wifi(); //memanggil void setup_wifi untuk dieksekusi
  dht.setup(DHT_PIN, DHTesp::DHT22);//inisialiasi komunikasi dengan sensor dht22
  MySQL_Connection conn((Client *)&espClient);
}

void loop() {
  unsigned long now = millis();
  TempAndHumidity  data = dht.getTempAndHumidity();

  String temp = String(data.temperature, 2); //membuat variabel temp untuk di publish ke broker mqtt

  MySQL_Cursor *cur_mem = new MySQL_Cursor(&conn);
  
  String queryString = "INSERT INTO suhu (suhu) VALUES (" + temp + ")";
  cur_mem->execute(queryString.c_str());
  delete cur_mem;

  Serial.print("Temperature: ");
  Serial.println(temp);
  delay(10000);
}