//Channel ID: 2770744
//Write API Key: 8OAQYS66LTDHX5F0
//Read API Key: 9JIADB6S9Q5277DJ
#include  "WiFi.h" 
#include  "ThingSpeak.h" 
WiFiClient client;
#include "DHTesp.h"

const int DHT_PIN = 15;
DHTesp dhtSensor;;
String thingSpeakAddress = "api.thingspeak.com";
String writeAPIKey;
String tsfield1Name;
String tsfield2Name;
String request_string;
int kondisiMerah;
//nama dan pasword wifi
const char* ssid = "Wokwi-GUEST";
const char* pass = "";
const int ledHijau = 2; // Pin LED (contoh: GPIO 2)
const int ledMerah = 13;

void setup()
{
  Serial.begin(9600);
  WiFi.disconnect();
  WiFi.begin(ssid, pass);
  while ((!(WiFi.status() == WL_CONNECTED))) {
    delay(300);
    Serial.print(".");
  }
  pinMode(ledMerah, OUTPUT);
  pinMode(ledHijau, OUTPUT);
  Serial.println("");
  Serial.println("WiFi terkoneksi");
  Serial.print("IP address: ");
  Serial.println(WiFi.localIP());
  dhtSensor.setup(DHT_PIN, DHTesp::DHT22);
}


void loop()
{
  delay(2000);
  TempAndHumidity  data = dhtSensor.getTempAndHumidity();

  float suhu = data.temperature;
  float kelembaban = data.humidity;
  kirim_thingspeak(suhu, kelembaban);
  baca_thingspeak();
  if (isnan(suhu) || isnan(kelembaban) ) 
  {
    Serial.println("Gagal membaca DHT sensor!");
    return;
  }
  if ((suhu>35)||(kelembaban>90))
  {
    kondisiMerah=1;
    digitalWrite(ledMerah, HIGH); // Nyalakan LED Merah
  }
    else 
    { 
      kondisiMerah=0;
      digitalWrite(ledMerah, LOW); // Padamkan LED Merah 
    }
}

void baca_thingspeak(){
  Serial.println("Menghubungi ThingSpeak...");
  if (client.connect("api.thingspeak.com", 80)) {
   // Membuat permintaan HTTP
    String url = "/channels/";
    url += String(2770744); // Channel ID
    url += "/fields/";
    url += String(3);//Number field
    url += ".json?api_key=";
    url += "9JIADB6S9Q5277DJ";//Read Key
    url += "&results=1"; // Membaca satu data terakhir
    Serial.print("Permintaan URL: ");
    Serial.println(url);

    // Kirim permintaan HTTP GET
    client.print(String("GET ") + url + " HTTP/1.1\r\n" +
                 "Host: " + "api.thingspeak.com"+ "\r\n" +
                 "Connection: close\r\n\r\n");
     // Tunggu respons
    delay(1000);

    String payload = "";
    while (client.available()) {
      payload = client.readString();
       Serial.println ("payload :"+String(payload)); 
    }
String line = client.readStringUntil('\r');
    Serial.println(line);
    client.stop();
      // Memproses data JSON untuk mendapatkan nilai field3
      int fieldStart = payload.indexOf("\"field3\":\"") + 10; // Posisi awal nilai field1
      int fieldEnd = payload.indexOf("\"",fieldStart);      // Posisi akhir nilai field1
      String switchStatus= payload.substring(fieldStart, fieldEnd); // Ekstraksi nilai
      Serial.println("Nilai field3: " + switchStatus);
      Serial.print("Status switch: ");
      Serial.println(switchStatus);
        // Mengontrol LED berdasarkan status switch
    if (switchStatus == "1") {
      digitalWrite(ledHijau, HIGH); // Nyalakan LED
      Serial.println("LED ON");
    } else if (switchStatus == "0") {
      digitalWrite(ledHijau, LOW); // Matikan LED
      Serial.println("LED OFF");
    } else {
      Serial.println("Data tidak valid!");
    }
  } else {
    Serial.println("Gagal terhubung ke ThingSpeak!");
  }

  delay(5000); // Tunggu 5 detik sebelum membaca lagi
}


void kirim_thingspeak(float suhu, float kelembaban) {
  if (client.connect("api.thingspeak.com", 100)) {
    request_string = "/update?";
    request_string += "key=";
    request_string += "8OAQYS66LTDHX5F0";
    request_string += "&";
    request_string += "field1";
    request_string += "=";
    request_string += suhu;
    request_string += "&";
    request_string += "field2";
    request_string += "=";
    request_string += kelembaban;
    request_string += "&";
    request_string += "field3";
    request_string += "=";
    request_string += kondisiMerah;
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");
  }
}