/*

Part of MQTT and API modules

Copyright (C) 2020 by Maxim Prokhorov <prokhorov dot max at outlook dot com>

*/

#if MQTT_SUPPORT || API_SUPPORT

#include <Schedule.h>
#include <cstring>

#include "system.h"
#include "utils.h"
#include "rpc.h"

bool rpcHandleAction(const String& action) {
    bool result = false;
    if (action.equals("reboot")) {
        result = true;
        schedule_function([]() {
            deferredReset(100, CUSTOM_RESET_RPC);
        });
    } else if (action.equals("heartbeat")) {
        result = true;
        schedule_function(heartbeat);
    }
    return result;
}

PayloadStatus rpcParsePayload(const char* payload, const rpc_payload_check_t ext_check) {

    // Don't parse empty strings
    const auto len = strlen(payload);
    if (!len) return PayloadStatus::Unknown;

    // Check most commonly used payloads
    if (len == 1) {
        if (payload[0] == '0') return PayloadStatus::Off;
        if (payload[0] == '1') return PayloadStatus::On;
        if (payload[0] == '2') return PayloadStatus::Toggle;
        return PayloadStatus::Unknown;
    }

    // If possible, use externally provided payload checker
    if (ext_check) {
        const PayloadStatus result = ext_check(payload);
        if (result != PayloadStatus::Unknown) {
            return result;
        }
    }

    // Finally, check for "OFF", "ON", "TOGGLE" (both lower and upper cases)
    String temp(payload);
    temp.trim();

    if (temp.equalsIgnoreCase("off")) {
        return PayloadStatus::Off;
    } else if (temp.equalsIgnoreCase("on")) {
        return PayloadStatus::On;
    } else if (temp.equalsIgnoreCase("toggle")) {
        return PayloadStatus::Toggle;
    }

    return PayloadStatus::Unknown;

}

#endif // MQTT_SUPPORT || API_SUPPORT