change_filter.cpp

Go to the documentation of this file.

#include "change_filter.h"
 
namespace sensesp {
 
static float absf(float val) {
  if (val < 0) {
    return -val;
  }
  return val;
}
 
ChangeFilter::ChangeFilter(float min_delta, float max_delta, int max_skips,
                           const String& config_path)
    : FloatTransform(config_path),
      min_delta_{min_delta},
      max_delta_{max_delta},
      max_skips_{max_skips},
      skips_(max_skips_ + 1) {
  load();
}
 
void ChangeFilter::set(const float& new_value) {
  float delta = absf(new_value - output_);
  if ((delta >= min_delta_ && delta <= max_delta_) || skips_ > max_skips_) {
    skips_ = 0;
    this->emit(new_value);
  } else {
    skips_++;
  }
}
 
bool ChangeFilter::to_json(JsonObject& root) {
  root["min_delta"] = min_delta_;
  root["max_delta"] = max_delta_;
  root["max_skips"] = max_skips_;
  return true;
}
 
bool ChangeFilter::from_json(const JsonObject& config) {
  String const expected[] = {"min_delta", "max_delta", "max_skips"};
  for (auto str : expected) {
    if (!config[str].is<JsonVariant>()) {
      return false;
    }
  }
  min_delta_ = config["min_delta"];
  max_delta_ = config["max_delta"];
  max_skips_ = config["max_skips"];
  skips_ = max_skips_ + 1;
  return true;
}
 
const String ConfigSchema(ChangeFilter& obj) {
  return R"###({"type":"object","properties":{"min_delta":{"title":"Minimum delta","description":"Minimum difference in change of value before forwarding","type":"number"},"max_delta":{"title":"Maximum delta","description":"Maximum difference in change of value to allow forwarding","type":"number"},"max_skips":{"title":"Max skip count","description":"Maximum number of consecutive filtered values before one is allowed through","type":"number"}}})###";
}
 
}  // namespace sensesp