#include "BufferExecute.h"
//
#include "items/SensorDallas.h"
#include "items/ButtonOut.h"
//
#include "Global.h"
#include "Module/Terminal.h"

void loopCmdAdd(const String& cmdStr) {
    orderBuf += cmdStr;
    if (!cmdStr.endsWith(",")) {
        orderBuf += ",";
    }
}

void fileCmdExecute(const String& filename) {
    String cmdStr = readFile(filename, 4096);
    csvCmdExecute(cmdStr);
}

void csvCmdExecute(String& cmdStr) {
    cmdStr.replace(";", " ");
    cmdStr += "\r\n";
    cmdStr.replace("\r\n", "\n");
    cmdStr.replace("\r", "\n");
    int count = 0;
    while (cmdStr.length()) {
        String buf = selectToMarker(cmdStr, "\n");



        buf = deleteBeforeDelimiter(buf, " ");  //отсечка чекбокса

        count++;
        if (count > 1) {
            SerialPrint("I", "Items", buf);
            String order = selectToMarker(buf, " "); //отсечка самой команды

            if (order == F("button-out")) {
                sCmd.addCommand(order.c_str(), buttonOut);
            }
            else if (order == F("pwm-out")) {
                sCmd.addCommand(order.c_str(), pwmOut);
            }
            else if (order == F("button-in")) {
                sCmd.addCommand(order.c_str(), buttonIn);
            }
            else if (order == F("input-digit")) {
                sCmd.addCommand(order.c_str(), inputDigit);
            }
            else if (order == F("input-time")) {
                sCmd.addCommand(order.c_str(), inputTime);
            }
            else if (order == F("output-text")) {
                sCmd.addCommand(order.c_str(), textOut);
            }
            else if (order == F("analog-adc")) {
                sCmd.addCommand(order.c_str(), analogAdc);
            }
            else if (order == F("ultrasonic-cm")) {
                sCmd.addCommand(order.c_str(), ultrasonicCm);
            }
            else if (order == F("dallas-temp")) {
                sCmd.addCommand(order.c_str(), dallas);
            }
            else if (order == F("dht-temp")) {
                sCmd.addCommand(order.c_str(), dhtTemp);
            }
            else if (order == F("dht-hum")) {
                sCmd.addCommand(order.c_str(), dhtHum);
            }
            else if (order == F("bme280-temp")) {
                sCmd.addCommand(order.c_str(), bme280Temp);
            }
            else if (order == F("bme280-hum")) {
                sCmd.addCommand(order.c_str(), bme280Hum);
            }
            else if (order == F("bme280-press")) {
                sCmd.addCommand(order.c_str(), bme280Press);
            }
            else if (order == F("bmp280-temp")) {
                sCmd.addCommand(order.c_str(), bmp280Temp);
            }
            else if (order == F("bmp280-press")) {
                sCmd.addCommand(order.c_str(), bmp280Press);
            }
            else if (order == F("modbus")) {
                //sCmd.addCommand(order.c_str(), modbus);
            }
            else if (order == F("uptime")) {
                sCmd.addCommand(order.c_str(), sysUptime);
            }
            else if (order == F("logging")) {
                sCmd.addCommand(order.c_str(), logging);
            }
            else if (order == F("impuls-out")) {
                sCmd.addCommand(order.c_str(), impuls);
            }
            


            sCmd.readStr(buf);
        }
        cmdStr = deleteBeforeDelimiter(cmdStr, "\n");
    }
}

void spaceCmdExecute(String& cmdStr) {
    cmdStr += "\r\n";
    cmdStr.replace("\r\n", "\n");
    cmdStr.replace("\r", "\n");
    while (cmdStr.length()) {
        String buf = selectToMarker(cmdStr, "\n");
        sCmd.readStr(buf);
        cmdStr = deleteBeforeDelimiter(cmdStr, "\n");
    }
}

void loopCmdExecute() {
    if (orderBuf.length()) {
        String tmp = selectToMarker(orderBuf, ",");  //выделяем первую команду rel 5 1,
        SerialPrint("I", "CMD", "do: " + tmp);
        sCmd.readStr(tmp);                                //выполняем
        orderBuf = deleteBeforeDelimiter(orderBuf, ",");  //осекаем
    }
}

void sensorsInit() {
    ts.add(
        SENSORS10SEC, 10000, [&](void*) {
            String buf = sensorReadingMap10sec;
            while (buf.length()) {
                String tmp = selectToMarker(buf, ",");
                sCmd.readStr(tmp);
                buf = deleteBeforeDelimiter(buf, ",");
            }
        },
        nullptr, true);

    ts.add(
        SENSORS30SEC, 30000, [&](void*) {
            String buf = sensorReadingMap30sec;
            while (buf.length()) {
                String tmp = selectToMarker(buf, ",");
                sCmd.readStr(tmp);
                buf = deleteBeforeDelimiter(buf, ",");
            }
        },
        nullptr, true);
}

void addKey(String& key, String& keyNumberTable, int number) {
    keyNumberTable += key + " " + String(number) + ",";
}

int getKeyNum(String& key, String& keyNumberTable) {
    String keyNumberTableBuf = keyNumberTable;

    int number = -1;
    while (keyNumberTableBuf.length()) {
        String tmp = selectToMarker(keyNumberTableBuf, ",");
        String keyIncomming = selectToMarker(tmp, " ");
        if (keyIncomming == key) {
            number = selectToMarkerLast(tmp, " ").toInt();
        }
        keyNumberTableBuf = deleteBeforeDelimiter(keyNumberTableBuf, ",");
    }
    return number;
}