signalk_listener.h

Go to the documentation of this file.

#ifndef SENSESP_SIGNALK_LISTENER_H_
#define SENSESP_SIGNALK_LISTENER_H_
 
#include "sensesp.h"
 
#include <ArduinoJson.h>
#include <memory>
#include <set>
 
#include "sensesp/system/observable.h"
#include "sensesp/system/valueproducer.h"
#include "sensesp/ui/config_item.h"
 
namespace sensesp {
 
class SKListener : virtual public Observable, public FileSystemSaveable {
 public:
  SKListener(const String& sk_path, int listen_delay,
             const String& config_path = "");
 
  virtual ~SKListener();
 
  String& get_sk_path() { return sk_path; }
 
  int get_listen_delay() { return listen_delay; }
 
  virtual void parse_value(const JsonObject& json) {}
 
  virtual bool wants_meta() const { return false; }
 
  virtual void parse_meta(const std::shared_ptr<const JsonDocument>& meta_doc) {}
 
  static const std::vector<SKListener*>& get_listeners() { return listeners_; }
 
  static void clear_registry();
 
  static bool take_semaphore(uint64_t timeout_ms = 0);
  static void release_semaphore();
 
 protected:
  String sk_path{};
 
 private:
  static std::vector<SKListener*> listeners_;
  int listen_delay;
  static StaticSemaphore_t semaphore_buffer_;
  static SemaphoreHandle_t semaphore_;
 
  virtual bool to_json(JsonObject& root) override;
  virtual bool from_json(const JsonObject& config) override;
 
  void set_sk_path(const String& path);
};
 
const String ConfigSchema(const SKListener& obj);
 
}  // namespace sensesp
 
#endif