#include "Consts.h"
#ifdef EnableSensorDht
#include "items/vSensorDht.h"

#include <Arduino.h>

#include "BufferExecute.h"
#include "Class/LineParsing.h"
#include "Global.h"

SensorDht::SensorDht(const paramsDht& paramsTmp, const paramsDht& paramsHum) {
    _paramsTmp = paramsDht(paramsTmp);
    _paramsHum = paramsDht(paramsHum);

    dht = new DHTesp();

    if (_paramsHum.type == "dht11") {
        dht->setup(_paramsHum.pin, DHTesp::DHT11);
    } else if (_paramsHum.type == "dht22") {
        dht->setup(_paramsHum.pin, DHTesp::DHT22);
    }

    _paramsHum.interval = _paramsHum.interval + dht->getMinimumSamplingPeriod();
}

SensorDht::~SensorDht() {}

void SensorDht::loop() {
    difference = millis() - prevMillis;
    if (difference >= _paramsHum.interval) {
        prevMillis = millis();
        readTmpHum();
    }
}

void SensorDht::readTmpHum() {
    float tmp = dht->getTemperature();
    float hum = dht->getHumidity();

    if (String(tmp) != "nan" && String(hum) != "nan") {
        tmp = tmp * _paramsTmp.c;
        hum = hum * _paramsHum.c;

        eventGen2(_paramsTmp.key, String(tmp));
        jsonWriteStr(configLiveJson, _paramsTmp.key, String(tmp));
        publishStatus(_paramsTmp.key, String(tmp));
             String path = mqttRootDevice + "/" +_paramsTmp.key + "/status";
    String json = "{}";
    jsonWriteStr(json, "status", String(tmp));
    String MyJson = json; 
    jsonWriteStr(MyJson, "topic", path); 
    ws.textAll(MyJson);
        SerialPrint("I", "Sensor", "'" + _paramsTmp.key + "' data: " + String(tmp));

        eventGen2(_paramsHum.key, String(hum));
        jsonWriteStr(configLiveJson, _paramsHum.key, String(hum));
        publishStatus(_paramsHum.key, String(hum));
           path = mqttRootDevice + "/" +_paramsHum.key + "/status";
     json = "{}";
    jsonWriteStr(json, "status", String(hum));
     MyJson = json; 
    jsonWriteStr(MyJson, "topic", path); 
    ws.textAll(MyJson);
        SerialPrint("I", "Sensor", "'" + _paramsHum.key + "' data: " + String(hum));

    } else {
        SerialPrint("E", "Sensor DHT", "Error");
    }
}

MySensorDhtVector* mySensorDht = nullptr;

void dhtSensor() {
    myLineParsing.update();
    String type = myLineParsing.gtype();
    String interval = myLineParsing.gint();
    String pin = myLineParsing.gpin();
    String key = myLineParsing.gkey();
    String c = myLineParsing.gc();
    myLineParsing.clear();

    static int enterCnt = -1;
    enterCnt++;

    static paramsDht paramsTmp;
    static paramsDht paramsHum;

    if (enterCnt == 0) {
        paramsTmp.key = key;
        paramsTmp.interval = interval.toInt() * 1000;
        paramsTmp.c = c.toFloat();
    }

    if (enterCnt == 1) {
        paramsHum.type = type;
        paramsHum.key = key;
        paramsHum.interval = interval.toInt() * 1000;
        paramsHum.pin = pin.toInt();
        paramsHum.c = c.toFloat();

        static bool firstTime = true;
        if (firstTime) mySensorDht = new MySensorDhtVector();
        firstTime = false;
        mySensorDht->push_back(SensorDht(paramsTmp, paramsHum));

        enterCnt = -1;
    }
}
#endif