signalk_listener.cpp

Go to the documentation of this file.

#include "signalk_listener.h"
 
#include <algorithm>
 
#include "sensesp/system/saveable.h"
 
namespace sensesp {
 
std::vector<SKListener *> SKListener::listeners_;
 
StaticSemaphore_t SKListener::semaphore_buffer_;
SemaphoreHandle_t SKListener::semaphore_ =
    xSemaphoreCreateRecursiveMutexStatic(&SKListener::semaphore_buffer_);
 
SKListener::SKListener(const String &sk_path, int listen_delay,
                       const String &config_path)
    : FileSystemSaveable(config_path),
      sk_path{sk_path},
      listen_delay{listen_delay} {
  listeners_.push_back(this);
  this->load();
}
 
SKListener::~SKListener() {
  take_semaphore();
  listeners_.erase(std::remove(listeners_.begin(), listeners_.end(), this),
                   listeners_.end());
  release_semaphore();
}
 
void SKListener::clear_registry() {
  take_semaphore();
  listeners_.clear();
  release_semaphore();
}
 
bool SKListener::take_semaphore(uint64_t timeout_ms) {
  if (timeout_ms == 0) {
    return xSemaphoreTakeRecursive(semaphore_, portMAX_DELAY) == pdTRUE;
  } else {
    return xSemaphoreTakeRecursive(semaphore_, timeout_ms) == pdTRUE;
  }
}
 
void SKListener::release_semaphore() { xSemaphoreGiveRecursive(semaphore_); }
 
bool SKListener::to_json(JsonObject &root) {
  root["sk_path"] = this->get_sk_path();
  return true;
}
 
bool SKListener::from_json(const JsonObject &config) {
  if (!config["sk_path"].is<String>()) {
    return false;
  }
  this->set_sk_path(config["sk_path"].as<String>());
  return true;
}
 
void SKListener::set_sk_path(const String &path) { sk_path = path; }
 
const String ConfigSchema(const SKListener &obj) {
  return R"({"type":"object","properties":{"listen_delay":{"title":"Listen delay","type":"number","description":"The time, in milliseconds, between each read of the input"}}  })";
}
 
}  // namespace sensesp