monitoring.hpp

#pragma once
 
#ifndef __PERCEMON_MONITORING_HPP__
#define __PERCEMON_MONITORING_HPP__
 
#include "percemon/ast.hpp"
#include "percemon/datastream.hpp"
 
// TODO: Consider unordered_map if memory and hashing isn't an issue.
#include <map>
 
// TODO: Consider performance/space efficiency of deque vs vector.
#include <deque>
 
#include <optional>
 
namespace percemon::monitoring {
 
// bool is_past_time(const percemon::ast::Expr& expr);
 
std::optional<size_t> get_horizon(const percemon::ast::Expr& expr);
 
std::optional<size_t> get_horizon(const percemon::ast::Expr& expr, double fps);
 
struct OnlineMonitor {
 public:
  OnlineMonitor() = delete;
  OnlineMonitor(
      ast::Expr phi_,
      const double fps_,
      double x_boundary,
      double y_boundary);
 
  void add_frame(const datastream::Frame& frame);
  void add_frame(datastream::Frame&& frame); // Efficient move semantics
 
  double eval();
 
  [[nodiscard]] size_t get_max_horizon() const { return max_horizon; }
  [[nodiscard]] size_t get_fps() const { return fps; };
  const ast::Expr& get_phi() { return phi; }
 
 private:
  const ast::Expr phi;
  const double fps;
 
  std::deque<datastream::Frame> buffer;
 
  size_t max_horizon;
 
  double universe_x, universe_y;
};
 
} // namespace percemon::monitoring
 
#endif /* end of include guard: __PERCEMON_MONITORING_HPP__ */