#include <WiFi.h>

#define ECHO_PIN 4
#define TRIG_PIN 5

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

WiFiClient client;

void setup() {
  Serial.begin(115200);
  pinMode(LED_BUILTIN, OUTPUT);
  pinMode(TRIG_PIN, OUTPUT);
  pinMode(ECHO_PIN, INPUT);
  pinMode(12, OUTPUT);
  pinMode(14, OUTPUT);
  pinMode(27, OUTPUT);
  WiFi.disconnect();
  WiFi.begin("Wokwi-GUEST", "");
  while ((!(WiFi.status() == WL_CONNECTED))) {
    delay(300);
    Serial.print(".");
  }
  Serial.println("");
  Serial.println("WiFi connected");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());
 }


float readDistanceCM() {
  digitalWrite(TRIG_PIN, LOW);
  delayMicroseconds(2);
  digitalWrite(TRIG_PIN, HIGH);
  delayMicroseconds(10);
  digitalWrite(TRIG_PIN, LOW);
  int duration = pulseIn(ECHO_PIN, HIGH);
  return duration * 0.034 / 2;
}
void loop() {
  float distance = readDistanceCM();

  Serial.print("Jarak: ");
  Serial.println(distance);

  {

  if(distance >100){
    digitalWrite(27, HIGH); // LED Hijau
    digitalWrite(14, LOW);
    digitalWrite(12, LOW);
    Serial.println("Aman");
    kirim_thingspeak(distance,4);


  } else if (distance <100 && distance >= 50){
    digitalWrite(27, LOW);
    digitalWrite(14, HIGH);// LED Kuning
    digitalWrite(12, LOW);
    Serial.println("Siaga");
    kirim_thingspeak(distance,3);


  } else if (distance <50) {
    digitalWrite(27, LOW);
    digitalWrite(14, LOW);
    digitalWrite(12, HIGH); // LED Merah
    Serial.println("Banjir");
    kirim_thingspeak(distance,2);
 
  }

}  

}

void kirim_thingspeak(float jarak, int led1) {
  if (client.connect("api.thingspeak.com", 80)) {
    request_string = "/update?";
    request_string += "key=";
    request_string += "ISI APIKEY";
    request_string += "&";
    request_string += "field1";
    request_string += "=";
    request_string += jarak;
    request_string += "&";
    request_string += "field2";
    request_string += "=";
    request_string += led1;


    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");



  }
}