#pragma once

#include "../SinricProRequest.h"
#include "../EventLimiter.h"
#include "../SinricProStrings.h"

#include "../SinricProNamespace.h"
namespace SINRICPRO_NAMESPACE {

FSTR(RANGE, setRangeValue);       // "setRangeValue"
FSTR(RANGE, rangeValue);          // "rangeValue"
FSTR(RANGE, adjustRangeValue);    // "adjustRangeValue"
FSTR(RANGE, rangeValueDelta);     // "rangeValueDelta"

/**
 * @brief Callback definition for onRangeValue function
 * 
 * Gets called when device receive a `setRangeValue` reuqest \n
 * @param[in]   deviceId    String which contains the ID of device
 * @param[in]   rangeValue  for range value device has to be set
 * @param[out]  rangeValue  returning the current range value
 * @return      the success of the request
 * @retval      true        request handled properly
 * @retval      false       request was not handled properly because of some error
 * 
 * @section SetRangeValueCallback Example-Code
 * @snippet callbacks.cpp onRangeValue
 **/

using GenericRangeValueCallback_int   = bool (*)(const String &, const String &, int &);
using GenericRangeValueCallback_float = bool (*)(const String &, const String &, float &);

struct GenericRangeValueCallback {
  GenericRangeValueCallback() : type(type_unknown) {}
  GenericRangeValueCallback(GenericRangeValueCallback_int cb)   : type(type_int), cb_int(cb) {}
  GenericRangeValueCallback(GenericRangeValueCallback_float cb) : type(type_float), cb_float(cb) {}
  enum {
    type_unknown,
    type_int,
    type_float
  } type;
  union {
    GenericRangeValueCallback_int   cb_int;
    GenericRangeValueCallback_float cb_float;
  };
};

using SetRangeValueCallback = bool (*)(const String &, int &);

/**
 * @brief Callback definition for onRangeValue function on a specific instance
 * 
 * Gets called when device receive a `setRangeValue` reuqest \n
 * @param[in]   deviceId    String which contains the ID of device
 * @param[in]   instance    String instance name
 * @param[in]   rangeValue  for range value device has to be set
 * @param[out]  rangeValue  returning the current range value
 * @return      the success of the request
 * @retval      true        request handled properly
 * @retval      false       request was not handled properly because of some error
 * 
 * @section GenericSetRangeValueCallback Example-Code
 * @snippet callbacks.cpp onRangeValueGeneric
 **/
 using GenericSetRangeValueCallback_int = GenericRangeValueCallback_int;
 using GenericSetRangeValueCallback_float = GenericRangeValueCallback_float;

/**
 * @brief Callback definition for onAdjustRangeValue function
 * 
 * Gets called when device receive a `adjustRangeValue` reuqest \n
 * @param[in]   deviceId    String which contains the ID of device
 * @param[in]   rangeValue  delta value for range value have to change
 * @param[out]  rangeValue  returning the absolute range value 
 * @return      the success of the request
 * @retval      true        request handled properly
 * @retval      false       request was not handled properly because of some error
 * 
 * @section AdjustRangeValueCallback Example-Code
 * @snippet callbacks.cpp onAdjustRangeValue
 **/
using AdjustRangeValueCallback = bool (*)(const String &, int &);

/**
 * @brief Callback definition for onAdjustRangeValue function on a specific instance for custom devices
 * 
 * Gets called when device receive a `adjustRangeValue` reuqest \n
 * @param[in]   deviceId    String which contains the ID of device
 * @param[in]   instance    String instance name
 * @param[in]   rangeValue  delta value for range value have to change
 * @param[out]  rangeValue  returning the absolute range value 
 * @return      the success of the request
 * @retval      true        request handled properly
 * @retval      false       request was not handled properly because of some error
 * 
 * @section GenericAdjustRangeValueCallback Example-Code
 * @snippet callbacks.cpp onAdjustRangeValueGeneric
 **/
using GenericAdjustRangeValueCallback_int   = GenericRangeValueCallback_int;
using GenericAdjustRangeValueCallback_float = GenericRangeValueCallback_float;



/**
 * @brief RangeControllerFloatInt
 * @ingroup Capabilities
 **/
template <typename T>
class RangeController {
  public:

    RangeController();

    void onRangeValue(SetRangeValueCallback cb);
    void onRangeValue(const String& instance, GenericSetRangeValueCallback_int cb);
    void onRangeValue(const String& instance, GenericSetRangeValueCallback_float cb);

    void onAdjustRangeValue(AdjustRangeValueCallback cb);
    void onAdjustRangeValue(const String& instance, GenericAdjustRangeValueCallback_int cb);
    void onAdjustRangeValue(const String& instance, GenericAdjustRangeValueCallback_float cb);

    bool sendRangeValueEvent(int rangeValue, String cause = FSTR_SINRICPRO_PHYSICAL_INTERACTION);
    bool sendRangeValueEvent(const String& instance, int rangeValue, String cause = FSTR_SINRICPRO_PHYSICAL_INTERACTION);
    bool sendRangeValueEvent(const String& instance, float rangeValue, String cause = FSTR_SINRICPRO_PHYSICAL_INTERACTION);

  protected:
    bool handleRangeController(SinricProRequest &request);

  private:
    EventLimiter event_limiter;
    std::map<String, EventLimiter> event_limiter_generic;
    SetRangeValueCallback setRangeValueCallback;
    std::map<String, GenericRangeValueCallback> genericSetRangeValueCallback;
    AdjustRangeValueCallback adjustRangeValueCallback;
    std::map<String, GenericRangeValueCallback> genericAdjustRangeValueCallback;
};

template <typename T>
RangeController<T>::RangeController()
: event_limiter(EVENT_LIMIT_STATE) { 
  T* device = static_cast<T*>(this);
  device->registerRequestHandler(std::bind(&RangeController<T>::handleRangeController, this, std::placeholders::_1)); 
}

/**
 * @brief Set callback function for `setRangeValue` request
 * 
 * @param cb Function pointer to a `SetRangeValueCallback` function
 * @see SetRangeValueCallback
 */
template <typename T>
void RangeController<T>::onRangeValue(SetRangeValueCallback cb) {
  setRangeValueCallback = cb;
}

/**
 * @brief Set callback function for `setRangeValue` request on a specific instance (custom device)
 * 
 * @param instance String instance name (custom device)
 * @param cb Function pointer to a `GenericSetRangeValueCallback` function
 * @see GenericSetRangeValueCallback
 */
template <typename T>
void RangeController<T>::onRangeValue(const String& instance, GenericSetRangeValueCallback_int cb) {
  genericSetRangeValueCallback[instance] = GenericRangeValueCallback(cb);
}

template <typename T>
void RangeController<T>::onRangeValue(const String& instance, GenericSetRangeValueCallback_float cb) {
  genericSetRangeValueCallback[instance] = GenericRangeValueCallback(cb);
}

/**
 * @brief Set callback function for `adjustRangeValue` request
 * 
 * @param cb Function pointer to a `AdjustRangeValueCallback` function
 * @see AdjustRangeValueCallback
 */
template <typename T>
void RangeController<T>::onAdjustRangeValue(AdjustRangeValueCallback cb) {
  adjustRangeValueCallback = cb;
}

template <typename T>
void RangeController<T>::onAdjustRangeValue(const String &instance, GenericAdjustRangeValueCallback_int cb) {
  genericAdjustRangeValueCallback[instance] = GenericRangeValueCallback(cb);
}

template <typename T>
void RangeController<T>::onAdjustRangeValue(const String &instance, GenericAdjustRangeValueCallback_float cb) {
  genericAdjustRangeValueCallback[instance] = GenericRangeValueCallback(cb);
}

/**
 * @brief Send `rangeValue` event to report curent rangeValue to SinricPro server
 * 
 * @param   rangeValue  Value between 0..3
 * @param   cause       (optional) `String` reason why event is sent (default = `"PHYSICAL_INTERACTION"`)
 * @return  the success of sending the even
 * @retval  true        event has been sent successfully
 * @retval  false       event has not been sent, maybe you sent to much events in a short distance of time
 */
template <typename T>
bool RangeController<T>::sendRangeValueEvent(int rangeValue, String cause) {
  if (event_limiter) return false;
  T* device = static_cast<T*>(this);
  
  JsonDocument eventMessage = device->prepareEvent(FSTR_RANGE_setRangeValue, cause.c_str());
  JsonObject event_value = eventMessage[FSTR_SINRICPRO_payload][FSTR_SINRICPRO_value];
  event_value[FSTR_RANGE_rangeValue] = rangeValue;
  return device->sendEvent(eventMessage);
}

/**
 * @brief Send `rangeValue` event to report curent rangeValue to SinricPro server for a specific instance (custom device)
 * 
 * @param   instance    String instance name
 * @param   rangeValue  Value between 0..3
 * @param   cause       (optional) `String` reason why event is sent (default = `"PHYSICAL_INTERACTION"`)
 * @return  the success of sending the even
 * @retval  true        event has been sent successfully
 * @retval  false       event has not been sent, maybe you sent to much events in a short distance of time
 */
template <typename T>
bool RangeController<T>::sendRangeValueEvent(const String& instance, int rangeValue, String cause){
  if (event_limiter_generic.find(instance) == event_limiter_generic.end()) event_limiter_generic[instance] = EventLimiter(EVENT_LIMIT_STATE);
  if (event_limiter_generic[instance]) return false;
  T* device = static_cast<T*>(this);

  JsonDocument eventMessage = device->prepareEvent(FSTR_RANGE_setRangeValue, cause.c_str());
  eventMessage[FSTR_SINRICPRO_payload][FSTR_SINRICPRO_instanceId] = instance;

  JsonObject event_value = eventMessage[FSTR_SINRICPRO_payload][FSTR_SINRICPRO_value];
  event_value[FSTR_RANGE_rangeValue] = rangeValue;
  return device->sendEvent(eventMessage);
}

template <typename T>
bool RangeController<T>::sendRangeValueEvent(const String& instance, float rangeValue, String cause) {
  if (event_limiter_generic.find(instance) == event_limiter_generic.end()) event_limiter_generic[instance] = EventLimiter(EVENT_LIMIT_STATE);
  if (event_limiter_generic[instance]) return false;
  T* device = static_cast<T*>(this);

  JsonDocument eventMessage = device->prepareEvent(FSTR_RANGE_setRangeValue, cause.c_str());
  eventMessage[FSTR_SINRICPRO_payload][FSTR_SINRICPRO_instanceId] = instance;

  JsonObject event_value = eventMessage[FSTR_SINRICPRO_payload][FSTR_SINRICPRO_value];
  event_value[FSTR_RANGE_rangeValue] = rangeValue;
  return device->sendEvent(eventMessage);
}

template <typename T>
bool RangeController<T>::handleRangeController(SinricProRequest &request) {
  T* device = static_cast<T*>(this);

  bool success = false;

  if (request.action == FSTR_RANGE_setRangeValue) {

    if (request.instance == "") {

      int rangeValue = request.request_value[FSTR_RANGE_rangeValue];
      if (setRangeValueCallback) success = setRangeValueCallback(device->deviceId, rangeValue);
      request.response_value[FSTR_RANGE_rangeValue] = rangeValue;
      return success;

    } else {

      if (genericSetRangeValueCallback.find(request.instance) == genericSetRangeValueCallback.end()) return false;

      auto& cb = genericSetRangeValueCallback[request.instance];

      if (cb.type == GenericRangeValueCallback::type_float) {
        float value = request.request_value[FSTR_RANGE_rangeValue];
        success = cb.cb_float(device->deviceId, request.instance, value);
        request.response_value[FSTR_RANGE_rangeValue] = value;
        return success;
      }

      if (cb.type == GenericRangeValueCallback::type_int) {
        int value = request.request_value[FSTR_RANGE_rangeValue];
        success = cb.cb_int(device->deviceId, request.instance, value);
        request.response_value[FSTR_RANGE_rangeValue] = value;
        return success;
      }
    }
  }

  if (request.action == FSTR_RANGE_adjustRangeValue) {

    if (request.instance == "") {

      int rangeValue = request.request_value[FSTR_RANGE_rangeValueDelta];
      if (adjustRangeValueCallback) success = adjustRangeValueCallback(device->deviceId, rangeValue);
      request.response_value[FSTR_RANGE_rangeValue] = rangeValue;
      return success;

    } else {

      if (genericAdjustRangeValueCallback.find(request.instance) == genericAdjustRangeValueCallback.end()) return false;

      auto& cb = genericAdjustRangeValueCallback[request.instance];

      if (cb.type == GenericRangeValueCallback::type_float) {
        float value = request.request_value[FSTR_RANGE_rangeValueDelta];
        success = cb.cb_float(device->deviceId, request.instance, value);
        request.response_value[FSTR_RANGE_rangeValue] = value;
        return success;
      }

      if (cb.type == GenericRangeValueCallback::type_int) {
        int value = request.request_value[FSTR_RANGE_rangeValueDelta];
        success = cb.cb_int(device->deviceId, request.instance, value);
        request.response_value[FSTR_RANGE_rangeValue] = value;
        return success;
      }
    }
  }

  return false;
}

} // SINRICPRO_NAMESPACE

template <typename T>
using RangeController = SINRICPRO_NAMESPACE::RangeController<T>;