/*  
  Theengs OpenMQTTGateway - We Unite Sensors in One Open-Source Interface

   Act as a gateway between your 433mhz, infrared IR, BLE, LoRa signal and one interface like an MQTT broker 
   Send and receiving command by MQTT
 
   This is the MQ2 GAS Sensor Addon based on modules with a MQ:
   - Measures flammable gas
   - Required Hardware Module: MQ2

   Connection Scheme:
   --------------------

   MQ-2 -------> ESP8266
   ==============================================
   Vcc ---------> 3.3V or 5V
   GND ---------> GND
   A0 ----------> A0
   D0 ----------> D4
  
    This file is part of OpenMQTTGateway.
    
    OpenMQTTGateway is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.

    OpenMQTTGateway is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program.  If not, see <http://www.gnu.org/licenses/>.
*/
#include "User_config.h"

#ifdef ZsensorMQ2
#  include "TheengsCommon.h"
#  include "Wire.h"
#  include "config_MQ2.h"
#  include "math.h"

//Time used to wait for an interval before resending measured values
unsigned long timemq2 = 0;

void setupZsensorMQ2() {
  THEENGS_LOG_NOTICE(F("Setup MQ2 detection on pin: %d" CR), MQ2SENSORDETECTPIN);
  pinMode(MQ2SENSORDETECTPIN, INPUT); // declare GPIOInput pin as input_pullup to prevent floating. Pin will be high when not connected to ground

  THEENGS_LOG_NOTICE(F("Starting MQ2 calibration on pin: %d" CR), MQ2SENSORADCPIN);

  //Simple calibrate
  float sensorValue;
  for (int x = 0; x < 1000; x++) {
    analogRead(MQ2SENSORADCPIN);
  }
  delay(1000);

  THEENGS_LOG_TRACE(F("MQ2 Initialized." CR));
}

void MeasureGasMQ2() {
  if (millis() > (timemq2 + TimeBetweenReadingmq2)) {
    timemq2 = millis();

    THEENGS_LOG_TRACE(F("Creating MQ2 buffer" CR));
    StaticJsonDocument<JSON_MSG_BUFFER> MQ2dataBuffer;
    JsonObject MQ2data = MQ2dataBuffer.to<JsonObject>();

    MQ2data["gas"] = analogRead(MQ2SENSORADCPIN);
    MQ2data["detected"] = digitalRead(MQ2SENSORDETECTPIN) == HIGH ? "false" : "true";
    MQ2data["origin"] = subjectMQ2toMQTT;
    enqueueJsonObject(MQ2data);
  }
}
#endif