#include <Arduino.h>

/* * LED purposes:
 * - To use the feature, uncomment WITH_LEDS_BLINKING in MyConfig.h
 * - RX (green) - blink fast on radio message received. In inclusion mode will blink fast only on presentation received
 * - TX (yellow) - blink fast on radio message transmitted. In inclusion mode will blink slowly
 * - ERR (red) - fast blink on error during transmission error or receive crc error
 *
 */

#define MY_DEBUG
#define MY_BAUD_RATE 9600
#define MY_RADIO_RF24
#define MY_GATEWAY_ESP8266
// #define MY_DISABLED_SERIAL
// #define MY_SPLASH_SCREEN_DISABLED
#define MY_RF24_PA_LEVEL (RF24_PA_MAX)
#define MY_RF24_CHANNEL (15)
#define MY_RF24_DATARATE (RF24_250KBPS)

#define MY_WIFI_SSID "wf-home"
#define MY_WIFI_PASSWORD "0ndthnrf"

#define MY_HOSTNAME "ESP8266_GW"

#define MY_PORT 5003

// How many clients should be able to connect to this gateway (default 1)
#define MY_GATEWAY_MAX_CLIENTS 12

// #define MY_DEFAULT_LED_BLINK_PERIOD 300

// Flash leds on rx/tx/err
#define MY_DEFAULT_ERR_LED_PIN D3  // Error led pin
#define MY_DEFAULT_RX_LED_PIN  D4  // Receive led pin
//#define MY_DEFAULT_TX_LED_PIN  1  // the PCB, on board LED
#define MY_WITH_LEDS_BLINKING_INVERSE
#define MY_RF24_CE_PIN D0

#include <ArduinoOTA.h>
#include <MySensors.h>
#include "SdsDustSensor.h"

int rxPin = D1;
int txPin = D2;
SdsDustSensor sds(rxPin, txPin);

unsigned long cRun;
int cSec = 0;

#define CHILD_ID_25 0
#define CHILD_ID_10 1

MyMessage msg25(CHILD_ID_25, V_VAR1);
MyMessage msg10(CHILD_ID_10, V_VAR2);

void setup()
{
  WiFi.begin(MY_WIFI_SSID, MY_WIFI_PASSWORD);
  if(WiFi.waitForConnectResult() == WL_CONNECTED){
    delay(500);
    Serial.print(".");
  }
  Serial.println("");
  Serial.print("Connected to ");
  Serial.println(MY_WIFI_SSID);
  Serial.print("IP address: ");
  Serial.println(WiFi.localIP());

	ArduinoOTA.onStart([]() {
		Serial.println("ArduinoOTA start");
	});
	ArduinoOTA.onEnd([]() {
		Serial.println("\nArduinoOTA end");
	});
	ArduinoOTA.onProgress([](unsigned int progress, unsigned int total) {
		Serial.printf("OTA Progress: %u%%\r", (progress / (total / 100)));
	});
	ArduinoOTA.onError([](ota_error_t error) {
		Serial.printf("Error[%u]: ", error);
		if (error == OTA_AUTH_ERROR) {
			Serial.println("Auth Failed");
		} else if (error == OTA_BEGIN_ERROR) {
			Serial.println("Begin Failed");
		} else if (error == OTA_CONNECT_ERROR) {
			Serial.println("Connect Failed");
		} else if (error == OTA_RECEIVE_ERROR) {
			Serial.println("Receive Failed");
		} else if (error == OTA_END_ERROR) {
			Serial.println("End Failed");
		}
	});
	ArduinoOTA.begin();
  sds.begin();

  // Serial.println(sds.queryFirmwareVersion().toString()); // prints firmware version
  // Serial.println(sds.setActiveReportingMode().toString()); // ensures sensor is in 'active' reporting mode
  // Serial.println(sds.setCustomWorkingPeriod(3).toString()); // sensor sends data every 3 minutes
  sds.setActiveReportingMode();
  sds.setCustomWorkingPeriod(1);

  cRun = millis();
}

void presentation()
{
	sendSketchInfo("GateWayDust", "2.0");
	present(CHILD_ID_25, S_AIR_QUALITY, "Dust 2.5");
  wait(50);
	present(CHILD_ID_10, S_AIR_QUALITY, "Dust 10");
}

void loop()
{
	// Send locally attached sensors data here
	ArduinoOTA.handle();
  if(cRun + 1000 < millis()){
    cRun = millis();
    PmResult pm = sds.readPm();
    cSec++;
    if (pm.isOk()) {
      // Serial.print(cSec); Serial.print("\t");
      // Serial.print("PM2.5 = ");
      // Serial.print(pm.pm25);
      // Serial.print(", PM10 = ");
      // Serial.println(pm.pm10);

      // // if you want to just print the measured values, you can use toString() method as well
      // Serial.println(pm.toString());
      send(msg25.set(pm.pm25, 1));
      wait(100);
      send(msg10.set(pm.pm10, 1));
      cSec = 0;
    //} else {
      // // notice that loop delay is set to 5s (sensor sends data every 3 minutes) and some reads are not available
      // Serial.print(cSec); Serial.print("\t");
      // Serial.print("Could not read values from sensor, reason: ");
      // Serial.println(pm.statusToString());
    }
  }
}