signalk_put_request_listener.h

Go to the documentation of this file.

#ifndef SENSESP_SIGNALK_SIGNALK_PUT_REQUEST_LISTENER_H_
#define SENSESP_SIGNALK_SIGNALK_PUT_REQUEST_LISTENER_H_
 
#include "sensesp.h"
 
#include <ArduinoJson.h>
#include <set>
 
#include "sensesp/system/observable.h"
#include "sensesp/system/valueproducer.h"
 
namespace sensesp {

class SKPutListener : virtual public Observable {
 public:
  SKPutListener(const String& sk_path);
 
  String& get_sk_path() { return sk_path; }
 
  virtual void parse_value(const JsonObject& put) = 0;
 
  static const std::vector<SKPutListener*>& get_listeners() {
    return listeners_;
  }
 
 protected:
  String sk_path{};
 
 private:
  static std::vector<SKPutListener*> listeners_;
  int listen_delay{};
};

template <class T>
class SKPutRequestListener : public SKPutListener, public ValueProducer<T> {
 public:
  SKPutRequestListener(String sk_path) : SKPutListener(sk_path) {
    if (sk_path == "") {
      ESP_LOGE(
          __FILENAME__,
          "SKPutRequestListener: User has provided no sk_path to respond to.");
    }
  }
 
  void parse_value(const JsonObject& put) override {
    this->emit(put["value"].as<T>());
  }
};
 
typedef SKPutRequestListener<float> FloatSKPutRequestListener;
typedef SKPutRequestListener<int> IntSKPutRequestListener;
typedef SKPutRequestListener<bool> BoolSKPutRequestListener;
typedef SKPutRequestListener<String> StringSKPutRequestListener;
 
}  // namespace sensesp
 
#endif