Class MavlinkTelemetrySink

OpenHD/ohd_common/src/openhd_spdlog.cpp:56–80

Sinks the messages into a buffer For the telemetry thread to fetch

// Sinks the messages into a buffer
// For the telemetry thread to fetch
class MavlinkTelemetrySink : public spdlog::sinks::base_sink<std::mutex> {
 protected:
  void sink_it_(const spdlog::details::log_msg& msg) override {
    // log_msg is a struct containing the log entry info like level, timestamp,
    // thread id etc. msg.raw contains pre formatted log If needed (very likely
    // but not mandatory), the sink formats the message before sending it to its
    // final destination:
    if (msg.level >= spdlog::level::warn) {
      // We do not use the formatter here, since we are limited by 50 chars (and
      // the level, for example, is embedded already but not as a string).
      // spdlog::memory_buf_t formatted;
      // spdlog::sinks::base_sink<std::mutex>::formatter_->format(msg,
      // formatted);
      const auto msg_string = fmt::to_string(msg.payload);
      const std::string msg_with_tag =
          fmt::format("{} {}", msg.logger_name, msg_string);
      const auto level = openhd::log::level_spdlog_to_mavlink(msg.level);
      auto tmp = safe_create(static_cast<int>(level), msg_with_tag);
      MavlinkLogMessageBuffer::instance().enqueue_log_message(tmp);
    }
  }
  void flush_() override {
    // std::cout << std::flush;
  }
};

}  // namespace openhd::log::sink