sensor.h

Go to the documentation of this file.

#ifndef SENSESP_SENSORS_SENSOR_H_
#define SENSESP_SENSORS_SENSOR_H_
 
#include <Arduino.h>
#include <set>
 
#include "ReactESP.h"
#include "sensesp/system/observable.h"
#include "sensesp/system/saveable.h"
#include "sensesp/system/valueproducer.h"
#include "sensesp_base_app.h"
 
namespace sensesp {

class SensorConfig : virtual public Observable, public FileSystemSaveable {
 public:
  SensorConfig(const String& config_path) : FileSystemSaveable(config_path) {}
 
 private:
};

template <typename T>
class Sensor : public SensorConfig, virtual public ValueProducer<T> {
 public:
  Sensor(String config_path) : SensorConfig(config_path), ValueProducer<T>() {}
};
 
typedef Sensor<float> FloatSensor;
typedef Sensor<int> IntSensor;
typedef Sensor<bool> BoolSensor;
typedef Sensor<String> StringSensor;
 
template <class T>
class RepeatSensor : public Sensor<T> {
 public:
  RepeatSensor(unsigned int repeat_interval_ms, std::function<T()> callback)
      : Sensor<T>(""),
        repeat_interval_ms_(repeat_interval_ms),
        returning_callback_(callback) {
    repeat_event_ = event_loop()->onRepeat(repeat_interval_ms_, [this]() {
      this->emit(this->returning_callback_());
    });
  }

  RepeatSensor(unsigned int repeat_interval_ms,
               std::function<void(RepeatSensor<T>*)> callback)
      : Sensor<T>(""),
        repeat_interval_ms_(repeat_interval_ms),
        emitting_callback_(callback) {
    repeat_event_ = event_loop()->onRepeat(repeat_interval_ms_,
                           [this]() { emitting_callback_(this); });
  }
 
  virtual ~RepeatSensor() {
    if (repeat_event_ != nullptr) {
      repeat_event_->remove(event_loop());
    }
  }
 
 protected:
  unsigned int repeat_interval_ms_;
  std::function<T()> returning_callback_ = nullptr;
  std::function<void(RepeatSensor<T>*)> emitting_callback_ = nullptr;
  reactesp::RepeatEvent* repeat_event_ = nullptr;
};
 
}  // namespace sensesp
 
#endif