#include "DHTesp.h"
#include <WiFi.h>
#include <Wire.h>
#include <LiquidCrystal_I2C.h>
#include <ThingSpeak.h>


LiquidCrystal_I2C LCD = LiquidCrystal_I2C(0x27, 20, 4);

#define WIFI_SSID           "Wokwi-GUEST"
#define WIFI_PASSWORD       ""
#define LM 13


int status = WL_IDLE_STATUS;

const int DHT_PIN = 15;
const int trig = 4;
const int echo = 2;
DHTesp dhtSensor;
WiFiClient client;


String thingSpeakAddress = "api.thingspeak.com";
String writeAPIKey;
String tsfield1Name;
String request_string;

long duration;
float distanceCm;
float distanceInch;

void InitWiFi()
{
  Serial.println("Connecting to AP ...");

  WiFi.begin(WIFI_SSID, WIFI_PASSWORD);
  while (WiFi.status() != WL_CONNECTED) {

  
      
  }
  Serial.println("");
  Serial.println("Connected to AP");
}

void reconnect() {
  status = WiFi.status();
  if ( status != WL_CONNECTED) {
    WiFi.begin(WIFI_SSID, WIFI_PASSWORD);
    while (WiFi.status() != WL_CONNECTED) {
    }
    Serial.println("");
    Serial.println("Connected to AP");
  }
}

void setup() {
  LCD.init();
  LCD.backlight();
  
  Serial.begin(115200);
  pinMode(trig, OUTPUT);
  pinMode(echo, INPUT);
 
  dhtSensor.setup(DHT_PIN, DHTesp::DHT22);
  InitWiFi();
}

float ultrasonic() {

  digitalWrite(trig, LOW);
  delayMicroseconds(2);
  digitalWrite(trig, HIGH);
  delayMicroseconds(10);
  digitalWrite(trig, LOW);

  duration = pulseIn(echo, HIGH);
  distanceCm = duration * SOUND_SPEED/2;
  distanceInch = distanceCm * CM_TO_INCH;

 Serial.print("Distance (cm): ");
 Serial.println(distanceCm);
 Serial.print("Distance (inch): ");
 Serial.println(distanceInch);



}

void loop() {
  
  if (WiFi.status() != WL_CONNECTED) {
    reconnect();
  }
  
  
  else {
    Serial.print("WiFi sudah terkoneksi dengan: ");
    Serial.println(WIFI_SSID);
    Serial.print("IP: ");
    Serial.println(WiFi.localIP());
    Serial.print("RSSI :");
    Serial.println(WiFi.RSSI());

  }
  TempAndHumidity  data = dhtSensor.getTempAndHumidity();
  float distance = ultrasonic();
  Serial.println("Temp   : " + String(data.temperature, 2) + "C");
  Serial.println("Humidity: " + String(data.humidity, 1) + "%");
  Serial.println("Jarak: " + distance + "cm");
  
  Serial.println("---");
  delay(1000);

  LCD.setCursor(0, 0);
  LCD.print("Temp   : " + String(data.temperature, 2) + " C") ;
  LCD.setCursor(0, 1);
  LCD.print("Humidity: " + String(data.humidity, 1) + " %");
  LCD.setCursor(0, 2);
  LCD.print("Distance: " + String(data.distanceCm, 3) + " CM");
  LCD.setCursor(0, 3);
  LCD.print("Distance: " + String(data.distanceInch, 4) + " INCH");

  kirim_thingspeak_temperature(data.temperature, data.humidity, distanceCm, distanceInch);

  ultrasonic();
}

void kirim_thingspeak_temperature(float suhu, float hum, float distanceCm, float distanceInch) {
  if (client.connect("api.thingspeak.com", 80)) {
    request_string = "/update?";
    request_string += "key=";
    request_string += "K3G6NVUHIIVGQ6HP";
    request_string += "&";
    request_string += "field1";
    request_string += "=";
    request_string += suhu;
     request_string += "&";
    request_string += "field2";
    request_string += "=";
    request_string += hum;
     request_string += "&";
    request_string += "field3";
    request_string += "=";
    request_string += distanceCm;
     request_string += "&";
    request_string += "field4";
    request_string += "=";
    request_string += distanceInch;

  
    Serial.println(String("GET ") + request_string + " HTTP/1.1\r\n" +
                 "Host: " + thingSpeakAddress + "\r\n" +
                 "Connection: close\r\n\r\n");
                 
    client.print(String("GET ") + request_string + " HTTP/1.1\r\n" +
                 "Host: " + thingSpeakAddress + "\r\n" +
                 "Connection: close\r\n\r\n");
    unsigned long timeout = millis();
    while (client.available() == 0) {
      if (millis() - timeout > 5000) {
        Serial.println(">>> Client Timeout !");
        client.stop();
        return;
      }
    }

    while (client.available()) {
      String line = client.readStringUntil('\r');
      Serial.print(line);
    }
    Serial.println();
    Serial.println("closing connection");
  }
}