any_message_view.h

Go to the documentation of this file.

// Copyright (c) Space-ng, inc. All rights reserved.
#pragma once
#include "sol3/core/fb_json.h"
#include "sol3/core/file_identifier.h"
#include "sol3/core/message_schema.h"
#include "sol3/core/msg/message_header.h"
#include "sol3/core/seq_ring.h"
#include "sol3/log/except.h"
 
#include <flatbuffers/flatbuffers.h>
#include <flatbuffers/idl.h>
#include <flatbuffers/reflection.h>
#include <spdlog/spdlog.h>
 
#include <vector>
 
namespace sol3::core {
 
class AnyMessageView {
 public:
  AnyMessageView() = default;
 
  void update(
      SeqRingSlotView const& slot_view,
      MessageSchema schema,
      std::chrono::steady_clock::duration time_out);
 
  bool valid() const;
  bool hasValue() const;
 
  operator bool() const;
 
  bool cached() const;
  void setCached(bool cached);
 
  void checkHasValue() const;
 
  void checkValid() const;
 
  msg::MessageHeader const& header() const;
 
  template <typename TTableType>
  TTableType const& payload() const {
    if (makeFileIdentifier<typename TTableType::NativeTableType>() !=
        expected_file_identifier_) {
      SOL3_PANIC(
          "payload type mismatch: {} != {}",
          stringFromFileIdentifier(
              makeFileIdentifier<typename TTableType::NativeTableType>()),
          stringFromFileIdentifier(expected_file_identifier_));
    }
    checkHasValue();
    return *flatbuffers::GetSizePrefixedRoot<TTableType>(payload_data_);
  }
 
  uint64_t seq() const;
 
  flatbuffers::span<uint8_t const> headerSpan() const;
 
  flatbuffers::span<uint8_t const> payloadSpan() const;
 
  flatbuffers::span<uint8_t const> messageSpan() const;
 
  void reset();
 
  MessageSchema const& schema() const;
 
  void payloadToJson(JsonFormat format, std::string& out_json) const;
  std::string payloadToJson(JsonFormat format) const;
 
 private:
  uint32_t expected_file_identifier_ = 0;
 
  std::shared_ptr<std::vector<uint8_t>> buffer_;
  std::shared_ptr<uint64_t> reader_seq_;
  MessageSchema schema_;
  uint64_t seq_ = 0;
 
  uint8_t const* header_data_ = nullptr;
  size_t header_size_ = 0;
 
  uint8_t const* payload_data_ = nullptr;
  size_t payload_size_ = 0;
 
  bool cached_ = false;
};
 
void toJson(
    AnyMessageView const& view,
    std::string& out_json,
    JsonFormat format = JsonFormat::SINGLE_LINE);
std::string toJson(
    AnyMessageView const& view, JsonFormat format = JsonFormat::SINGLE_LINE);
 
inline std::string format_as(AnyMessageView& view) { return toJson(view); }
}  // namespace sol3::core