#include "DHTesp.h"
#include <WiFi.h>
#include <ThingSpeak.h> // always include thingspeak header file after other header files and custom macros
const int trig = 32;
const int echo = 33;

const int trigf = 21;
const int echof = 19;


long duration;
float distance;

long durationf;
float distancef;

#define SECRET_SSID "Wokwi-GUEST"    // replace with your WiFi network name
#define SECRET_PASS "" // replace with your WiFi password

#define SECRET_CH_ID 2634761  // replace 0000000 with your channel number
#define SECRET_CH_IDrw 2024385
#define SECRET_CH_IDrf 2025907
#define SECRET_WRITE_APIKEYwf "KA72V5Q3EAANFCGP"   // replace XYZ with your channel write API Key
#define SECRET_READ_APIKEYwater "47F3VAS1J5ZLFY1G"   // replace XYZ with your channel read API Key
#define SECRET_READ_APIKEYfeed "UVPNAILKWQWEWH88"   // replace XYZ with your channel read API Key

char ssid[] = SECRET_SSID;   // your network SSID (name) 
char pass[] = SECRET_PASS;   // your network password
int keyIndex = 0;            // your network key Index number (needed only for WEP)
WiFiClient  client;

//reading and writing 
unsigned long myChannelNumber = SECRET_CH_ID;
unsigned long readmyChannelNumberw = SECRET_CH_IDrw;
unsigned long readmyChannelNumberf = SECRET_CH_IDrf;
const char * myWriteAPIKey = SECRET_WRITE_APIKEYwf;
const char * myReadAPIKeyw = SECRET_READ_APIKEYwater;
const char * myReadAPIKeyf = SECRET_READ_APIKEYfeed;
//water pin27 and feed pin18

unsigned int dataFieldOnewater = 1; 
unsigned int dataFieldOnefeed = 1;

float aConst1 = 2.25E-02;
float aConst2 = 2.25E-02;

const int DHT_PIN = 15;

DHTesp dhtSensor;
void setup() {
   Serial.begin(115200);
  dhtSensor.setup(DHT_PIN, DHTesp::DHT22);
  //water
  pinMode(trig, OUTPUT);
  pinMode(echo, INPUT);
  pinMode(27, OUTPUT);

//feed
  pinMode(trigf, OUTPUT);
  pinMode(echof, INPUT);
  pinMode(18, OUTPUT);
  while (!Serial) {
    ; // wait for serial port to connect. Needed for Leonardo native USB port only
  }
    WiFi.mode(WIFI_STA);   
  ThingSpeak.begin(client);  // Initialize ThingSpeak
}
 

void loop() {
  if(WiFi.status() != WL_CONNECTED)
  {
    Serial.print("Attempting to connect to SSID: ");
    Serial.println(SECRET_SSID);
    while(WiFi.status() != WL_CONNECTED)
    {
      WiFi.begin(ssid, pass); // Connect to WPA/WPA2 network. Change this  line if using open or WEP network
      Serial.print(".");
      delay(5000);     
    } 
    Serial.println("\nConnected.");
  }
int statusCode;
//DHT11
  TempAndHumidity  data = dhtSensor.getTempAndHumidity();
  Serial.println("Temp: " + String(data.temperature, 2) + "°C");
  Serial.println("Humidity: " + String(data.humidity, 1) + "%");
  Serial.println("---");
//Ultrasonic water level
digitalWrite(trig,LOW);
delayMicroseconds(2);
digitalWrite(trig, HIGH);
delayMicroseconds(10);
digitalWrite(trig, LOW);
duration = pulseIn(echo, HIGH);
//Serial.println(duration);
distance = duration*0.034/2;
Serial.println(distance);

//Ultrasonic feed level
  digitalWrite(trigf,LOW);
delayMicroseconds(2);
digitalWrite(trigf, HIGH);
delayMicroseconds(10);
digitalWrite(trigf, LOW);
durationf = pulseIn(echof, HIGH);
//Serial.println(duration);
distancef = durationf*0.034/2;
Serial.println(distancef);


//Thingspeak
  ThingSpeak.setField(1,data.humidity);
  ThingSpeak.setField(2,data.temperature);
  ThingSpeak.setField(3,distance);
  ThingSpeak.setField(4,distancef);

  statusCode = ThingSpeak.writeFields(myChannelNumber,SECRET_WRITE_APIKEYwf);

  aConst1 = readTSDatawater( readmyChannelNumberw, dataFieldOnewater );
  aConst2 = readTSDatafeed( readmyChannelNumberf, dataFieldOnefeed );


  Serial.println(aConst1);
  if(aConst1 == 1){
    digitalWrite(27, HIGH);
     Serial.println("water Relay on");
  }
  else{
    digitalWrite(27,LOW);
     Serial.println("water Relay off");
  }

   Serial.println(aConst2);
  if(aConst2 == 1){
    digitalWrite(18, HIGH);
     Serial.println("feed Relay on");
  }
  else{
    digitalWrite(18,LOW);
     Serial.println("feed Relay off");
  }

  if(statusCode == 200) { //successful writing code
      Serial.println("Channel update successful.");
  }
  else {
      Serial.println("Problem Writing data. HTTP error code :" + String(statusCode));
  }  delay(15000); // data to be uploaded every 15secs 
 if (data.temperature<40)
 Serial.println("Temperature Low");
 else
 Serial.println("Temperature Normal");
}

float readTSDatawater( long TSChannel1, unsigned int TSField1 ) {

  float data =  ThingSpeak.readFloatField( TSChannel1, TSField1, SECRET_READ_APIKEYwater );
 // Serial.println( " Data read from ThingSpeak: " + String( data, 9 ) );
  return data;

}

float readTSDatafeed( long TSChannel2, unsigned int TSField2 ) {

  float data =  ThingSpeak.readFloatField( TSChannel2, TSField2, SECRET_READ_APIKEYfeed );
 // Serial.println( " Data read from ThingSpeak: " + String( data, 9 ) );
  return data;

}