json_logging.cpp

Go to the documentation of this file.

// Copyright (c) 2023 anabrid GmbH
// Contact: https://www.anabrid.com/licensing/
// SPDX-License-Identifier: MIT OR GPL-2.0-or-later
 
#include "../../../../include/protocol/transport.h"
#include "protocol/jsonl_logging.h"
 
size_t msg::StreamLogger::write(uint8_t b) {
  // size_t write(const uint8_t *buffer, size_t size) override {
  if (new_line) {
    target.begin_dict();
    target.kv("type", "log");
    target.kv("count", line_count++);
    target.kv("time", millis());
    target.key("msg");
    target.begin_str();
    new_line = false;
  }
  if (b == '\r')
    return 1; // ignore CR in CR NL line endings.
  if (b == '\n') {
    target.end_str();
    target.end_dict();
    target.output.println("");
    target.output.flush();
    new_line = true;
    return 1;
  } else {
    return target.output.write(b);
  }
}
 
void msg::StartupLog::to_pb(pb_SyslogResponse &stream) {
  stream.is_active = is_active();
  stream.max_size = buf.max_size;
  stream.entries = nullptr; buf.data();
  //TODO @chris
}
 
void msg::activate_serial_log() { msg::Log::get().sinks.add_Serial(); }