signalk_put_request_listener.h

Go to the documentation of this file.

#ifndef _signalk_putrequestlistener_H_
#define _signalk_putrequestlistener_H_
 
#include <ArduinoJson.h>
 
#include <set>
 
#include "sensesp.h"
#include "sensesp/system/configurable.h"
#include "sensesp/system/observable.h"
#include "sensesp/system/valueproducer.h"
 
namespace sensesp {
 
class SKPutListener : virtual public Observable {
 public:
  SKPutListener(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 == "") {
      debugE(
          "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