#include "DHT.h"

#define DHTPIN 11     
#define DHTTYPE DHT22   // DHT 22  (AM2302), AM2321
#define FLAME_SENSOR 10
#define GAS_SENSOR A0
#define WATER_LEVEL A1  

int motion_sensor = 12;          // choose the input pin for PIR sensor
int pirState = LOW;             // we start, assuming no motion detected
int val = 0;                    // variable for reading the pin status

int motionDetectAlert = 7;
int heatDetectAlert = 8;
int flameDetectAlert = 6;
int gasDetectAlert = 5;
int waterOverDetectAlert = 4;

int pump_pin = 9;
int buzzer_pin = 13;

DHT dht(DHTPIN, DHTTYPE);

void setup() {
  Serial.begin(9600);

  pinMode(motion_sensor, INPUT);     // declare sensor as input
  pinMode(GAS_SENSOR, INPUT);
  pinMode(DHTPIN, INPUT);
  pinMode(FLAME_SENSOR, INPUT);
  pinMode(WATER_LEVEL, INPUT);

  pinMode(pump_pin, OUTPUT);
  pinMode(buzzer_pin, OUTPUT);

  pinMode(motionDetectAlert, OUTPUT);
  pinMode(heatDetectAlert, OUTPUT);
  pinMode(flameDetectAlert, OUTPUT);
  pinMode(gasDetectAlert, OUTPUT);
  pinMode(waterOverDetectAlert, OUTPUT);

  dht.begin();
}

void loop() {
  temperatureSensor();
  motionSensor();
  flameSensor();
  gasSensor();
  waterLevelSensor();
  delay(300);
}

void temperatureSensor(){
  float temperature = dht.readTemperature();
  float humidity = dht.readHumidity();
  // Check if any reads failed and exit early (to try again).
  if (isnan(temperature) || isnan(humidity)) {
    Serial.println("Failed to read from DHT sensor!");
    return;
  }
  else if (temperature > 60){
    digitalWrite(heatDetectAlert, HIGH);
    digitalWrite(pump_pin, HIGH);
    digitalWrite(buzzer_pin, HIGH);
  }
  else{
    digitalWrite(heatDetectAlert, LOW);
    digitalWrite(pump_pin, LOW);
    digitalWrite(buzzer_pin, LOW);
  }
  // Wait a few seconds between measurements.
  delay(200);
}

void motionSensor(){
  val = digitalRead(motion_sensor);  // read input value
  if (val == HIGH) {            // check if the input is HIGH
    if (pirState == LOW) {
      // we have just turned on
      digitalWrite(motionDetectAlert, HIGH);
      Serial.println("Motion detected!");
      // We only want to print on the output change, not state
      pirState = HIGH;
    }
  } 
  else {
    // send message motion end
    if (pirState == HIGH) {
      // we have just turned of
      digitalWrite(motionDetectAlert, LOW);
      Serial.println("Motion ended!");
      // We only want to print on the output change, not state
      pirState = LOW;
    }
  }
}

void flameSensor(){
  if (digitalRead(FLAME_SENSOR) == LOW) {
    digitalWrite(flameDetectAlert, HIGH);
    digitalWrite(pump_pin, HIGH);
    digitalWrite(buzzer_pin, HIGH);
  } 
  else {
    digitalWrite(flameDetectAlert, LOW);
    digitalWrite(pump_pin, LOW);
    digitalWrite(buzzer_pin, LOW);
  }
  delay(100);
}

void gasSensor() {
  unsigned int sensorValue = analogRead(GAS_SENSOR);  // Read the analog value from sensor
  unsigned int outputValue = map(sensorValue, 0, 1023, 0, 255); // map the 10-bit data to 8-bit data

    if (outputValue > 65){
      digitalWrite(gasDetectAlert, HIGH);
      digitalWrite(pump_pin, HIGH);
      digitalWrite(buzzer_pin, HIGH);
    }
    else{
      digitalWrite(gasDetectAlert, LOW);
      digitalWrite(pump_pin, LOW);
      digitalWrite(buzzer_pin, LOW);
    }
}

void waterLevelSensor(){
  unsigned int sensorValue = analogRead(WATER_LEVEL);
  if (sensorValue < 540){
    return;
  }
  uint8_t outputValue = map(sensorValue, 540, 800, 0, 255);
  if(outputValue > 245){
    // send a message warning!
    digitalWrite(waterOverDetectAlert, HIGH);
  }
  else{
    digitalWrite(waterOverDetectAlert, LOW);
  }
}